- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 61 for WaitForNamedCacheSync (0.4 sec)
-
pkg/controller/garbagecollector/graph_builder.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 36.9K bytes - Viewed (0) -
pkg/controller/disruption/disruption.go
defer dc.recheckQueue.ShutDown() defer dc.stalePodDisruptionQueue.ShutDown() logger.Info("Starting disruption controller") defer logger.Info("Shutting down disruption controller") if !cache.WaitForNamedCacheSync("disruption", ctx.Done(), dc.podListerSynced, dc.pdbListerSynced, dc.rcListerSynced, dc.rsListerSynced, dc.dListerSynced, dc.ssListerSynced) { return } go wait.UntilWithContext(ctx, dc.worker, time.Second)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 36.1K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set.go
logger := klog.FromContext(ctx) logger.Info("Starting controller", "name", controllerName) defer logger.Info("Shutting down controller", "name", controllerName) if !cache.WaitForNamedCacheSync(rsc.Kind, ctx.Done(), rsc.podListerSynced, rsc.rsListerSynced) { return } for i := 0; i < workers; i++ { go wait.UntilWithContext(ctx, rsc.worker, time.Second) } <-ctx.Done() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 33.2K bytes - Viewed (0) -
pkg/controller/resourceclaim/controller.go
ec.recorder = eventBroadcaster.NewRecorder(scheme.Scheme, v1.EventSource{Component: "resource_claim"}) defer eventBroadcaster.Shutdown() if !cache.WaitForNamedCacheSync("resource_claim", ctx.Done(), ec.podSynced, ec.podSchedulingSynced, ec.claimsSynced, ec.templatesSynced) { return } for i := 0; i < workers; i++ { go wait.UntilWithContext(ctx, ec.runWorker, time.Second)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 37.1K bytes - Viewed (0) -
pkg/controller/podautoscaler/replica_calculator_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Aug 19 03:31:34 UTC 2023 - 68.4K bytes - Viewed (0) -
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)