- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 40 for runWorker (0.12 sec)
-
pkg/controller/clusterroleaggregation/clusterroleaggregation_controller.go
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) { } } func (c *ClusterRoleAggregationController) processNextWorkItem(ctx context.Context) bool {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/dynamic_serving_content.go
defer c.queue.ShutDown() klog.InfoS("Starting controller", "name", c.name) defer klog.InfoS("Shutting down controller", "name", c.name) // doesn't matter what workers say, only start one. go wait.Until(c.runWorker, time.Second, ctx.Done()) // start the loop that watches the cert and key files until stopCh is closed. go wait.Until(func() { if err := c.watchCertKeyFile(ctx.Done()); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.9K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/nonstructuralschema/nonstructuralschema_controller.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 *ConditionController) 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 - 8.3K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/openapiv3/controller.go
continue } c.buildV3Spec(crd, crd.Name, v.Name) } } // only start one worker thread since its a slow moving API go wait.Until(c.runWorker, time.Second, stopCh) <-stopCh } func (c *Controller) runWorker() { for c.processNextWorkItem() { } } func (c *Controller) processNextWorkItem() bool { key, quit := c.queue.Get() if quit { return false }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller.go
} return err } waitGroup := sync.WaitGroup{} for i := uint(0); i < c.options.Workers; i++ { waitGroup.Add(1) go func() { defer waitGroup.Done() wait.Until(c.runWorker, time.Second, ctx.Done()) }() } klog.Infof("Started %v workers for %v", c.options.Workers, c.options.Name) // Wait for context cancel. <-ctx.Done()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/dynamic_cafile_content.go
defer c.queue.ShutDown() klog.InfoS("Starting controller", "name", c.name) defer klog.InfoS("Shutting down controller", "name", c.name) // doesn't matter what workers say, only start one. go wait.Until(c.runWorker, time.Second, ctx.Done()) // start the loop that watches the CA file until stopCh is closed. go wait.Until(func() { if err := c.watchCAFile(ctx.Done()); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/configmap_cafile_content.go
go wait.Until(c.runWorker, time.Second, ctx.Done()) // start timer that rechecks every minute, just in case. this also serves to prime the controller quickly. go wait.PollImmediateUntil(FileRefreshDuration, func() (bool, error) { c.queue.Add(workItemKey) return false, nil }, ctx.Done()) <-ctx.Done() } func (c *ConfigMapCAController) runWorker() { for c.processNextWorkItem() { }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.9K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/openapi/controller.go
} c.specsByName[crd.Name] = createSpecCache(crd) } c.updateSpecLocked() // only start one worker thread since its a slow moving API go wait.Until(c.runWorker, time.Second, stopCh) <-stopCh } func (c *Controller) runWorker() { for c.processNextWorkItem() { } } func (c *Controller) processNextWorkItem() bool { key, quit := c.queue.Get() if quit { return false }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/authentication/request/headerrequest/requestheader_controller.go
if !cache.WaitForNamedCacheSync(c.name, ctx.Done(), c.configmapInformerSynced) { return } // doesn't matter what workers say, only start one. go wait.Until(c.runWorker, time.Second, ctx.Done()) <-ctx.Done() } // // RunOnce runs a single sync loop func (c *RequestHeaderAuthRequestController) RunOnce(ctx context.Context) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 10.9K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_discovery_controller.go
panic(fmt.Errorf("unexpected error: %v", err)) } close(synchedCh) // only start one worker thread since its a slow moving API go wait.Until(c.runWorker, time.Second, stopCh) <-stopCh } func (c *DiscoveryController) 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: Sun Apr 21 11:40:03 UTC 2024 - 12.8K bytes - Viewed (0)