- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 51 for WaitForNamedCacheSync (0.4 sec)
-
pkg/controller/resourcequota/resource_quota_controller.go
logger.Info("Starting resource quota controller") defer logger.Info("Shutting down resource quota controller") if rq.quotaMonitor != nil { go rq.quotaMonitor.Run(ctx) } if !cache.WaitForNamedCacheSync("resource quota", ctx.Done(), rq.informerSyncedFuncs...) { return } // the workers that chug through the quota calculation backlog 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 - 21.3K bytes - Viewed (0) -
pkg/controller/volume/ephemeral/controller.go
defer ec.queue.ShutDown() logger := klog.FromContext(ctx) logger.Info("Starting ephemeral volume controller") defer logger.Info("Shutting down ephemeral volume controller") if !cache.WaitForNamedCacheSync("ephemeral", ctx.Done(), ec.podSynced, ec.pvcsSynced) { return } for i := 0; i < workers; i++ { go wait.UntilWithContext(ctx, ec.runWorker, time.Second) } <-ctx.Done() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/authentication/request/headerrequest/requestheader_controller.go
klog.Infof("Starting %s", c.name) defer klog.Infof("Shutting down %s", c.name) go c.configmapInformer.Run(ctx.Done()) // wait for caches to fill before starting your work if !cache.WaitForNamedCacheSync(c.name, ctx.Done(), c.configmapInformerSynced) { return } // doesn't matter what workers say, only start one. go wait.Until(c.runWorker, time.Second, ctx.Done()) <-ctx.Done() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 10.9K bytes - Viewed (0) -
pkg/controller/ttlafterfinished/ttlafterfinished_controller.go
defer tc.queue.ShutDown() logger := klog.FromContext(ctx) logger.Info("Starting TTL after finished controller") defer logger.Info("Shutting down TTL after finished controller") if !cache.WaitForNamedCacheSync("TTL after finished", ctx.Done(), tc.jListerSynced) { return } for i := 0; i < workers; i++ { go wait.UntilWithContext(ctx, tc.worker, time.Second) } <-ctx.Done() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 07 23:59:28 UTC 2024 - 10.4K bytes - Viewed (0) -
pkg/controller/podgc/gc_controller.go
logger := klog.FromContext(ctx) defer utilruntime.HandleCrash() logger.Info("Starting GC controller") defer gcc.nodeQueue.ShutDown() defer logger.Info("Shutting down GC controller") if !cache.WaitForNamedCacheSync("GC", ctx.Done(), gcc.podListerSynced, gcc.nodeListerSynced) { return } go wait.UntilWithContext(ctx, gcc.gc, gcc.gcCheckPeriod) <-ctx.Done() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 13.3K bytes - Viewed (0) -
pkg/controller/volume/pvcprotection/pvc_protection_controller.go
defer c.queue.ShutDown() logger := klog.FromContext(ctx) logger.Info("Starting PVC protection controller") defer logger.Info("Shutting down PVC protection controller") if !cache.WaitForNamedCacheSync("PVC protection", ctx.Done(), c.pvcListerSynced, c.podListerSynced) { return } for i := 0; i < workers; i++ { go wait.UntilWithContext(ctx, c.runWorker, time.Second) } <-ctx.Done() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 14K bytes - Viewed (0) -
pkg/controller/volume/expand/expand_controller.go
defer runtime.HandleCrash() defer expc.queue.ShutDown() logger := klog.FromContext(ctx) logger.Info("Starting expand controller") defer logger.Info("Shutting down expand controller") if !cache.WaitForNamedCacheSync("expand", ctx.Done(), expc.pvcsSynced) { return } for i := 0; i < defaultWorkerCount; i++ { go wait.UntilWithContext(ctx, expc.runWorker, time.Second) } <-ctx.Done() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 16.2K bytes - Viewed (0) -
pkg/controller/garbagecollector/garbagecollector.go
logger.Info("Starting controller", "controller", "garbagecollector") defer logger.Info("Shutting down controller", "controller", "garbagecollector") go gc.dependencyGraphBuilder.Run(ctx) if !cache.WaitForNamedCacheSync("garbage collector", ctx.Done(), func() bool { return gc.dependencyGraphBuilder.IsSynced(logger) }) { return } logger.Info("All resource monitors have synced. Proceeding to collect garbage")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.9K bytes - Viewed (0) -
pkg/controlplane/controller/clusterauthenticationtrust/cluster_authentication_trust_controller.go
// we have a personal informer that is narrowly scoped, start it. go c.kubeSystemConfigMapInformer.Run(ctx.Done()) // wait for your secondary caches to fill before starting your work if !cache.WaitForNamedCacheSync("cluster_authentication_trust_controller", ctx.Done(), c.preRunCaches...) { return } // only run one worker go wait.Until(c.runWorker, time.Second, ctx.Done())
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 18.2K bytes - Viewed (0) -
pkg/controller/servicecidrs/servicecidrs_controller.go
logger := klog.FromContext(ctx) logger.Info("Starting", "controller", controllerName) defer logger.Info("Shutting down", "controller", controllerName) if !cache.WaitForNamedCacheSync(controllerName, ctx.Done(), c.serviceCIDRsSynced, c.ipAddressSynced) { return } for i := 0; i < workers; i++ { go wait.UntilWithContext(ctx, c.worker, c.workerLoopPeriod) } <-ctx.Done() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 18K bytes - Viewed (0)