- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 45 for UntilWithContext (0.51 sec)
-
staging/src/k8s.io/apimachinery/pkg/util/wait/backoff.go
JitterUntil(f, period, 0.0, true, stopCh) } // UntilWithContext loops until context is done, running f every period. // // UntilWithContext is syntactic sugar on top of JitterUntilWithContext // with zero jitter factor and with sliding = true (which means the timer // for period starts after the f completes). func UntilWithContext(ctx context.Context, f func(context.Context), period time.Duration) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 19:14:11 UTC 2023 - 16.5K bytes - Viewed (0) -
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/volume/attachdetach/populator/desired_state_of_world_populator.go
csiMigratedPluginManager csimigration.PluginManager intreeToCSITranslator csimigration.InTreeToCSITranslator } func (dswp *desiredStateOfWorldPopulator) Run(ctx context.Context) { wait.UntilWithContext(ctx, dswp.populatorLoopFunc(ctx), dswp.loopSleepDuration) } func (dswp *desiredStateOfWorldPopulator) populatorLoopFunc(ctx context.Context) func(ctx context.Context) { return func(ctx context.Context) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 00:37:30 UTC 2023 - 7.7K 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)