- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 42 for UntilWithContext (0.18 sec)
-
pkg/controller/resourcequota/resource_quota_controller.go
for i := 0; i < workers; i++ { go wait.UntilWithContext(ctx, rq.worker(rq.queue), time.Second) go wait.UntilWithContext(ctx, rq.worker(rq.missingUsageQueue), time.Second) } // the timer for how often we do a full recalculation across all quotas if rq.resyncPeriod() > 0 { go wait.UntilWithContext(ctx, rq.enqueueAll, rq.resyncPeriod()) } else {
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/storageversiongc/gc_controller.go
// handles storageversion creation/update with non-existing id. The latter should rarely // happen. It's okay for the two workers to conflict on update. go wait.UntilWithContext(ctx, c.runLeaseWorker, time.Second) go wait.UntilWithContext(ctx, c.runStorageVersionWorker, time.Second) <-ctx.Done() } func (c *Controller) runLeaseWorker(ctx context.Context) { for c.processNextLease(ctx) { } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 10K bytes - Viewed (0) -
pkg/controller/validatingadmissionpolicystatus/controller.go
defer utilruntime.HandleCrash() if !cache.WaitForNamedCacheSync(ControllerName, ctx.Done(), c.policySynced) { return } defer c.policyQueue.ShutDown() 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 - 5.3K bytes - Viewed (0) -
pkg/controller/certificates/certificate_controller.go
if !cache.WaitForNamedCacheSync(fmt.Sprintf("certificate-%s", cc.name), ctx.Done(), cc.csrsSynced) { return } for i := 0; i < workers; i++ { go wait.UntilWithContext(ctx, cc.worker, time.Second) } <-ctx.Done() } // worker runs a thread that dequeues CSRs, handles them, and marks them done. func (cc *CertificateController) worker(ctx context.Context) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.4K bytes - Viewed (0) -
pkg/controller/certificates/rootcacertpublisher/publisher.go
if !cache.WaitForNamedCacheSync("crt configmap", ctx.Done(), c.cmListerSynced) { return } for i := 0; i < workers; i++ { go wait.UntilWithContext(ctx, c.runWorker, time.Second) } <-ctx.Done() } func (c *Publisher) configMapDeleted(obj interface{}) { cm, err := convertToCM(obj) if err != nil { utilruntime.HandleError(err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.8K bytes - Viewed (0) -
pkg/controller/volume/pvprotection/pv_protection_controller.go
defer logger.Info("Shutting down PV protection controller") if !cache.WaitForNamedCacheSync("PV protection", ctx.Done(), c.pvListerSynced) { return } for i := 0; i < workers; i++ { go wait.UntilWithContext(ctx, c.runWorker, time.Second) } <-ctx.Done() } func (c *Controller) runWorker(ctx context.Context) { for c.processNextWorkItem(ctx) { } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.4K bytes - Viewed (0) -
pkg/controller/clusterroleaggregation/clusterroleaggregation_controller.go
if !cache.WaitForNamedCacheSync("ClusterRoleAggregator", ctx.Done(), c.clusterRolesSynced) { return } for i := 0; i < workers; i++ { go wait.UntilWithContext(ctx, c.runWorker, time.Second) } <-ctx.Done() } func (c *ClusterRoleAggregationController) runWorker(ctx context.Context) { for c.processNextWorkItem(ctx) { } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8K bytes - Viewed (0) -
pkg/controller/serviceaccount/serviceaccounts_controller.go
if !cache.WaitForNamedCacheSync("service account", ctx.Done(), c.saListerSynced, c.nsListerSynced) { return } for i := 0; i < workers; i++ { go wait.UntilWithContext(ctx, c.runWorker, time.Second) } <-ctx.Done() } // serviceAccountDeleted reacts to a ServiceAccount deletion by recreating a default ServiceAccount in the namespace if needed
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.5K bytes - Viewed (0) -
pkg/controller/bootstrap/tokencleaner.go
defer logger.Info("Shutting down token cleaner controller") if !cache.WaitForNamedCacheSync("token_cleaner", ctx.Done(), tc.secretSynced) { return } go wait.UntilWithContext(ctx, tc.worker, 10*time.Second) <-ctx.Done() } func (tc *TokenCleaner) enqueueSecrets(obj interface{}) { key, err := controller.KeyFunc(obj) if err != nil { utilruntime.HandleError(err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.3K bytes - Viewed (0) -
pkg/controller/storageversionmigrator/resourceversion.go
defer logger.Info("Shutting down", "controller", ResourceVersionControllerName) if !cache.WaitForNamedCacheSync(ResourceVersionControllerName, ctx.Done(), rv.svmSynced) { return } go wait.UntilWithContext(ctx, rv.worker, time.Second) <-ctx.Done() } func (rv *ResourceVersionController) worker(ctx context.Context) { for rv.processNext(ctx) { } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.5K bytes - Viewed (0)