- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 39 for UntilWithContext (0.31 sec)
-
pkg/controller/namespace/namespace_controller.go
if !cache.WaitForNamedCacheSync("namespace", ctx.Done(), nm.listerSynced) { return } logger.V(5).Info("Starting workers of namespace controller") for i := 0; i < workers; i++ { go wait.UntilWithContext(ctx, nm.worker, time.Second) } <-ctx.Done()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.6K bytes - Viewed (0) -
pkg/controller/serviceaccount/tokens_controller.go
return } logger := klog.FromContext(ctx) logger.V(5).Info("Starting workers") for i := 0; i < workers; i++ { go wait.UntilWithContext(ctx, e.syncServiceAccount, 0) go wait.UntilWithContext(ctx, e.syncSecret, 0) } <-ctx.Done() logger.V(1).Info("Shutting down") } func (e *TokensController) queueServiceAccountSync(obj interface{}) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 20.5K bytes - Viewed (0) -
pkg/controller/bootstrap/bootstrapsigner.go
if !cache.WaitForNamedCacheSync("bootstrap_signer", ctx.Done(), e.configMapSynced, e.secretSynced) { return } logger := klog.FromContext(ctx) logger.V(5).Info("Starting workers") go wait.UntilWithContext(ctx, e.serviceConfigMapQueue, 0) <-ctx.Done() logger.V(1).Info("Shutting down") } func (e *Signer) pokeConfigMapSync() { e.syncQueue.Add(e.configMapKey) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.2K bytes - Viewed (0) -
pkg/controller/storageversionmigrator/storageversionmigrator.go
if !cache.WaitForNamedCacheSync(svmc.controllerName, ctx.Done(), svmc.svmSynced) { return } for i := 0; i < workers; i++ { go wait.UntilWithContext(ctx, svmc.worker, time.Second) } <-ctx.Done() } func (svmc *SVMController) worker(ctx context.Context) { for svmc.processNext(ctx) { } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.5K bytes - Viewed (0) -
pkg/controller/ttl/ttl_controller.go
defer logger.Info("Shutting down TTL controller") if !cache.WaitForNamedCacheSync("TTL", ctx.Done(), ttlc.hasSynced) { return } for i := 0; i < workers; i++ { go wait.UntilWithContext(ctx, ttlc.worker, time.Second) } <-ctx.Done() } func (ttlc *Controller) addNode(logger klog.Logger, obj interface{}) { node, ok := obj.(*v1.Node) if !ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.5K bytes - Viewed (0) -
pkg/controller/volume/ephemeral/controller.go
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() } func (ec *ephemeralController) runWorker(ctx context.Context) { for ec.processNextWorkItem(ctx) { } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.2K bytes - Viewed (0) -
pkg/controller/nodelifecycle/node_lifecycle_controller.go
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/volume/persistentvolume/pv_controller_base.go
return } ctrl.initializeCaches(logger, ctrl.volumeLister, ctrl.claimLister) go wait.Until(func() { ctrl.resync(ctx) }, ctrl.resyncPeriod, ctx.Done()) go wait.UntilWithContext(ctx, ctrl.volumeWorker, time.Second) go wait.UntilWithContext(ctx, ctrl.claimWorker, time.Second) metrics.Register(ctrl.volumes.store, ctrl.claims, &ctrl.volumePluginMgr) <-ctx.Done() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 29.5K bytes - Viewed (0) -
pkg/controller/ttlafterfinished/ttlafterfinished_controller.go
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() } func (tc *Controller) addJob(logger klog.Logger, obj interface{}) { job := obj.(*batch.Job) logger.V(4).Info("Adding job", "job", klog.KObj(job))
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/resourcequota/resource_quota_monitor.go
// shutted down, so we need to shut it down in a separate goroutine. go func() { defer utilruntime.HandleCrash() defer qm.resourceChanges.ShutDown() <-ctx.Done() }() wait.UntilWithContext(ctx, qm.runProcessResourceChanges, 1*time.Second) // Stop any running monitors. qm.monitorLock.Lock() defer qm.monitorLock.Unlock() monitors := qm.monitors stopped := 0
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 11.6K bytes - Viewed (0)