- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for NewMemCacheClient (0.21 sec)
-
pkg/kube/client_factory.go
} d, err := discovery.NewDiscoveryClientForConfig(restConfig) if err != nil { return nil, err } return memory.NewMemCacheClient(d), nil }) out.mapper = lazy.NewWithRetry(func() (meta.ResettableRESTMapper, error) { discoveryClient, err := out.ToDiscoveryClient() if err != nil { return nil, err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Dec 15 21:30:37 UTC 2023 - 5.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/admission.go
if err != nil { return fmt.Errorf("failed to read plugin config: %v", err) } discoveryClient := cacheddiscovery.NewMemCacheClient(kubeClient.Discovery()) discoveryRESTMapper := restmapper.NewDeferredDiscoveryRESTMapper(discoveryClient) genericInitializer := initializer.New(kubeClient, dynamicClient, informers, c.Authorization.Authorizer, features,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun May 12 08:49:42 UTC 2024 - 9.7K bytes - Viewed (0) -
cmd/kube-controller-manager/app/controllermanager.go
} // Use a discovery client capable of being refreshed. discoveryClient := rootClientBuilder.DiscoveryClientOrDie("controller-discovery") cachedClient := cacheddiscovery.NewMemCacheClient(discoveryClient) restMapper := restmapper.NewDeferredDiscoveryRESTMapper(cachedClient) go wait.Until(func() { restMapper.Reset() }, 30*time.Second, ctx.Done())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 01 13:03:53 UTC 2024 - 37.5K bytes - Viewed (0)