- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for WaitForNamedCacheSync (0.62 sec)
-
pkg/controller/daemon/daemon_controller.go
defer dsc.queue.ShutDown() logger := klog.FromContext(ctx) logger.Info("Starting daemon sets controller") defer logger.Info("Shutting down daemon sets controller") if !cache.WaitForNamedCacheSync("daemon sets", ctx.Done(), dsc.podStoreSynced, dsc.nodeStoreSynced, dsc.historyStoreSynced, dsc.dsStoreSynced) { return } for i := 0; i < workers; i++ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.3K bytes - Viewed (0) -
pkg/controller/nodelifecycle/node_lifecycle_controller.go
defer nc.nodeUpdateQueue.ShutDown() defer nc.podUpdateQueue.ShutDown() logger.Info("Starting node controller") defer logger.Info("Shutting down node controller") if !cache.WaitForNamedCacheSync("taint", ctx.Done(), nc.leaseInformerSynced, nc.nodeInformerSynced, nc.podInformerSynced, nc.daemonSetInformerSynced) { return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.6K bytes - Viewed (0) -
pkg/controller/podautoscaler/horizontal.go
defer utilruntime.HandleCrash() defer a.queue.ShutDown() logger := klog.FromContext(ctx) logger.Info("Starting HPA controller") defer logger.Info("Shutting down HPA controller") if !cache.WaitForNamedCacheSync("HPA", ctx.Done(), a.hpaListerSynced, a.podListerSynced) { return } for i := 0; i < workers; i++ { go wait.UntilWithContext(ctx, a.worker, time.Second) } <-ctx.Done() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 63.6K bytes - Viewed (0) -
pkg/controller/endpoint/endpoints_controller_test.go
endpoints.servicesSynced = test.servicesSynced endpoints.endpointsSynced = test.endpointsSynced endpoints.workerLoopPeriod = 10 * time.Millisecond go endpoints.Run(tCtx, 1) // cache.WaitForNamedCacheSync has a 100ms poll period, and the endpoints worker has a 10ms period. // To ensure we get all updates, including unexpected ones, we need to wait at least as long as
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 87.7K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
defer jm.broadcaster.Shutdown() defer jm.queue.ShutDown() defer jm.orphanQueue.ShutDown() logger.Info("Starting job controller") defer logger.Info("Shutting down job controller") if !cache.WaitForNamedCacheSync("job", ctx.Done(), jm.podStoreSynced, jm.jobStoreSynced) { return } for i := 0; i < workers; i++ { go wait.UntilWithContext(ctx, jm.worker, time.Second) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0)