- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 40 for runWorker (0.13 sec)
-
pkg/controller/volume/ephemeral/controller.go
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) { } } func (ec *ephemeralController) processNextWorkItem(ctx context.Context) bool {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/tlsconfig.go
// doesn't matter what workers say, only start one. go wait.Until(c.runWorker, time.Second, stopCh) // start timer that rechecks every minute, just in case. this also serves to prime the controller quickly. go wait.Until(func() { c.Enqueue() }, 1*time.Minute, stopCh) <-stopCh } func (c *DynamicServingCertificateController) runWorker() { for c.processNextWorkItem() { } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 10.3K bytes - Viewed (0) -
pkg/controller/nodeipam/ipam/range_allocator.go
} for i := 0; i < cidrUpdateWorkers; i++ { go wait.UntilWithContext(ctx, r.runWorker, time.Second) } <-ctx.Done() } // runWorker is a long-running function that will continually call the // processNextWorkItem function in order to read and process a message on the // queue. func (r *rangeAllocator) runWorker(ctx context.Context) { for r.processNextNodeWorkItem(ctx) { } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 10:06:15 UTC 2024 - 16.2K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/finalizer/crd_finalizer.go
if !cache.WaitForCacheSync(stopCh, c.crdSynced) { return } for i := 0; i < workers; i++ { go wait.Until(c.runWorker, time.Second, stopCh) } <-stopCh } func (c *CRDFinalizer) runWorker() { for c.processNextWorkItem() { } } // processNextWorkItem deals with one key off the queue. It returns false when it's time to quit.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 12.6K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/status/naming_controller.go
return } // only start one worker thread since its a slow moving API and the naming conflict resolution bits aren't thread-safe go wait.Until(c.runWorker, time.Second, stopCh) <-stopCh } func (c *NamingConditionController) runWorker() { for c.processNextWorkItem() { } } // processNextWorkItem deals with one key off the queue. It returns false when it's time to quit.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 13.2K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/cidrallocator.go
runtime.HandleError(fmt.Errorf("timed out waiting for caches to sync")) return } // this is single threaded only one serviceCIDR at a time go wait.Until(c.runWorker, time.Second, c.internalStopCh) <-c.internalStopCh } func (c *MetaAllocator) runWorker() { for c.processNextItem() { } } func (c *MetaAllocator) processNextItem() bool { // Wait until there is a new item in the working queue
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 13.2K bytes - Viewed (0) -
pkg/controller/volume/pvcprotection/pvc_protection_controller.go
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) { } } // processNextWorkItem deals with one pvcKey off the queue. It returns false when it's time to quit.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 14K bytes - Viewed (0) -
pkg/controller/volume/expand/expand_controller.go
if !cache.WaitForNamedCacheSync("expand", ctx.Done(), expc.pvcsSynced) { return } for i := 0; i < defaultWorkerCount; i++ { go wait.UntilWithContext(ctx, expc.runWorker, time.Second) } <-ctx.Done() } func (expc *expandController) runWorker(ctx context.Context) { for expc.processNextWorkItem(ctx) { } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 16.2K bytes - Viewed (0) -
pkg/controlplane/controller/clusterauthenticationtrust/cluster_authentication_trust_controller.go
if !cache.WaitForNamedCacheSync("cluster_authentication_trust_controller", ctx.Done(), c.preRunCaches...) { return } // only run one worker go wait.Until(c.runWorker, time.Second, ctx.Done()) // checks are cheap. run once a minute just to be sure we stay in sync in case fsnotify fails again
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 18.2K bytes - Viewed (0) -
platforms/software/antlr/src/main/java/org/gradle/api/plugins/antlr/AntlrTask.java
} AntlrWorkerManager manager = new AntlrWorkerManager(); AntlrSpec spec = new AntlrSpecFactory().create(this, grammarFiles, sourceSetDirectories); AntlrResult result = manager.runWorker(projectDir(), getWorkerProcessBuilderFactory(), getAntlrClasspath(), spec); evaluate(result); } private void evaluate(AntlrResult result) { int errorCount = result.getErrorCount();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Sep 14 14:52:10 UTC 2023 - 9.8K bytes - Viewed (0)