INNER CODE UNIT · Go
setupServerVersionFetcher
kubernetes-sigs/kueue · cmd/kueue/main.go:691
func setupServerVersionFetcher(mgr ctrl.Manager, kubeConfig *rest.Config) (*kubeversion.ServerVersionFetcher, error) {
discoveryClient, err := discovery.NewDiscoveryClientForConfig(kubeConfig)
if err != nil {
return nil, fmt.Errorf("unable to create the discovery client: %w", err)
}
serverVersionFetcher := kubeversion.NewServerVersionFetcher(discoveryClient)
if err := mgr.Add(serverVersionFetcher); err != nil {
return nil, fmt.Errorf("unable to add server version fetcher to manager: %w", err)
}
if err := serverVersionFetcher.FetchServerVersion(); err != nil {
return nil, fmt.Errorf("failed to fetch kubernetes server version: %w", err)
}
return serverVersionFetcher, nil
}