- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 59 for waitForCacheSync (0.3 sec)
-
pkg/webhooks/validation/controller/controller_test.go
WatchedNamespace: ns, CABundleWatcher: watcher, Revision: revision, ServiceName: "istiod", }, c) stop := test.NewStop(t) c.RunAndWait(stop) go control.Run(stop) kube.WaitForCacheSync("test", stop, control.queue.HasSynced) gatewayError := setupGatewayError(c) return control, gatewayError } func unstartedTestController(c kube.Client) *Controller { revision := "default"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 05 03:21:04 UTC 2024 - 11.8K bytes - Viewed (0) -
pkg/controller/storageversiongc/gc_controller.go
defer c.leaseQueue.ShutDown() defer c.storageVersionQueue.ShutDown() defer logger.Info("Shutting down storage version garbage collector") logger.Info("Starting storage version garbage collector") if !cache.WaitForCacheSync(ctx.Done(), c.leasesSynced, c.storageVersionSynced) { utilruntime.HandleError(fmt.Errorf("timed out waiting for caches to sync")) return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 10K bytes - Viewed (0) -
pkg/scheduler/eventhandlers_test.go
} informerFactory.Start(testSched.StopEverything) dynInformerFactory.Start(testSched.StopEverything) staticInformers := informerFactory.WaitForCacheSync(testSched.StopEverything) dynamicInformers := dynInformerFactory.WaitForCacheSync(testSched.StopEverything) if diff := cmp.Diff(tt.expectStaticInformers, staticInformers); diff != "" { t.Errorf("Unexpected diff (-want, +got):\n%s", diff) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 10 14:38:54 UTC 2024 - 21.5K bytes - Viewed (0) -
pkg/controlplane/apiserver/server.go
return nil }) if c.Extra.PeerProxy != nil { s.GenericAPIServer.AddPostStartHookOrDie("unknown-version-proxy-filter", func(context genericapiserver.PostStartHookContext) error { err := c.Extra.PeerProxy.WaitForCacheSync(context.StopCh) return err }) } } s.GenericAPIServer.AddPostStartHookOrDie("start-cluster-authentication-info-controller", func(hookContext genericapiserver.PostStartHookContext) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 19:24:41 UTC 2024 - 11K bytes - Viewed (0) -
pkg/registry/flowcontrol/rest/storage_flowcontrol.go
// when the StopCh gets closed, whichever happens first. ctx, cancel := contextFromChannelAndMaxWaitDuration(hookContext.StopCh, 5*time.Minute) defer cancel() if !cache.WaitForCacheSync(ctx.Done(), bce.informersSynced...) { return fmt.Errorf("APF bootstrap ensurer timed out waiting for cache sync") } err = wait.PollImmediateUntilWithContext( ctx, time.Second,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:35 UTC 2023 - 12.3K bytes - Viewed (0) -
pilot/pkg/bootstrap/server.go
func (s *Server) addTerminatingStartFunc(name string, fn server.Component) { s.server.RunComponentAsyncAndWait(name, fn) } func (s *Server) waitForCacheSync(stop <-chan struct{}) bool { start := time.Now() log.Info("Waiting for caches to be synced") if !kubelib.WaitForCacheSync("server", stop, s.cachesSynced) { log.Errorf("Failed waiting for cache sync") return false }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 46.3K bytes - Viewed (0) -
pkg/webhooks/validation/controller/controller.go
// no point in retrying unless cert file changes. return nil } return c.updateValidatingWebhookConfiguration(whc, caBundle) } func (c *Controller) Run(stop <-chan struct{}) { kube.WaitForCacheSync("validation", stop, c.webhooks.HasSynced) go c.startCaBundleWatcher(stop) c.queue.Run(stop) } // startCaBundleWatcher listens for updates to the CA bundle and patches the webhooks.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 28 16:52:19 UTC 2024 - 11.3K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_discovery_controller.go
defer utilruntime.HandleCrash() defer c.queue.ShutDown() defer klog.Info("Shutting down DiscoveryController") klog.Info("Starting DiscoveryController") if !cache.WaitForCacheSync(stopCh, c.crdsSynced) { utilruntime.HandleError(fmt.Errorf("timed out waiting for caches to sync")) return } // initially sync all group versions to make sure we serve complete discovery
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 21 11:40:03 UTC 2024 - 12.8K bytes - Viewed (0) -
pkg/volume/plugins.go
CSIDriverLister() storagelistersv1.CSIDriverLister // CSIDriverSynced returns the informer synced for the CSIDriver API Object CSIDriversSynced() cache.InformerSynced // WaitForCacheSync is a helper function that waits for cache sync for CSIDriverLister WaitForCacheSync() error // Returns hostutil.HostUtils GetHostUtil() hostutil.HostUtils // Returns trust anchors from the named ClusterTrustBundle.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 16:13:15 UTC 2024 - 38.2K bytes - Viewed (0) -
cni/pkg/repair/repaircontroller.go
controllers.WithMaxAttempts(5)) c.pods.AddEventHandler(controllers.ObjectHandler(c.queue.AddObject)) return c, nil } func (c *Controller) Run(stop <-chan struct{}) { kube.WaitForCacheSync("repair controller", stop, c.pods.HasSynced) c.queue.Run(stop) c.pods.ShutdownHandlers() } func (c *Controller) Reconcile(key types.NamespacedName) error { pod := c.pods.Get(key.Name, key.Namespace)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Feb 10 00:31:55 UTC 2024 - 10.4K bytes - Viewed (0)