- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for UntilWithContext (0.2 sec)
-
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) -
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) -
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)