- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 61 for WaitForNamedCacheSync (0.8 sec)
-
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) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_source.go
if s.ctx != nil { return fmt.Errorf("policy source already running") } // Wait for initial cache sync of policies and informers before reconciling // any if !cache.WaitForNamedCacheSync(fmt.Sprintf("%T", s), ctx.Done(), s.UpstreamHasSynced) { err := ctx.Err() if err == nil { err = fmt.Errorf("initial cache sync for %T failed", s) } return err } s.ctx = ctx
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 21 23:07:34 UTC 2024 - 15.2K 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) -
pkg/controller/nodeipam/ipam/range_allocator.go
defer r.broadcaster.Shutdown() defer r.queue.ShutDown() logger.Info("Starting range CIDR allocator") defer logger.Info("Shutting down range CIDR allocator") if !cache.WaitForNamedCacheSync("cidrallocator", ctx.Done(), r.nodesSynced) { return } for i := 0; i < cidrUpdateWorkers; i++ { go wait.UntilWithContext(ctx, r.runWorker, time.Second) } <-ctx.Done() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 10:06:15 UTC 2024 - 16.2K bytes - Viewed (0) -
pkg/controller/tainteviction/taint_eviction.go
klog.FlushAndExit(klog.ExitFlushTimeout, 1) } defer tc.broadcaster.Shutdown() defer tc.nodeUpdateQueue.ShutDown() defer tc.podUpdateQueue.ShutDown() // wait for the cache to be synced if !cache.WaitForNamedCacheSync(tc.name, ctx.Done(), tc.podListerSynced, tc.nodeListerSynced) { return } for i := 0; i < UpdateWorkerSize; i++ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 19.9K bytes - Viewed (0) -
pkg/controller/serviceaccount/tokens_controller.go
func (e *TokensController) Run(ctx context.Context, workers int) { // Shut down queues defer utilruntime.HandleCrash() defer e.syncServiceAccountQueue.ShutDown() defer e.syncSecretQueue.ShutDown() if !cache.WaitForNamedCacheSync("tokens", ctx.Done(), e.serviceAccountSynced, e.secretSynced) { return } logger := klog.FromContext(ctx) logger.V(5).Info("Starting workers") 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 - 20.5K bytes - Viewed (0)