- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 42 for UntilWithContext (0.29 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/serviceaccount/legacy_serviceaccount_token_cleaner.go
if !cache.WaitForNamedCacheSync("legacy-service-account-token-cleaner", ctx.Done(), tc.saInformerSynced, tc.secretInformerSynced, tc.podInformerSynced) { return } go wait.UntilWithContext(ctx, tc.evaluateSATokens, tc.syncInterval) <-ctx.Done() } func (tc *LegacySATokenCleaner) evaluateSATokens(ctx context.Context) { logger := klog.FromContext(ctx) now := tc.clock.Now().UTC()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 27 03:52:06 UTC 2023 - 10K 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)