- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for processNext (0.4 sec)
-
pkg/controlplane/controller/legacytokentracking/controller.go
c.queue.Add(queueKey) <-stopCh klog.Info("Ending legacy_token_tracking_controller") } func (c *Controller) runWorker() { for c.processNext() { } } func (c *Controller) processNext() bool { key, quit := c.queue.Get() if quit { return false } defer c.queue.Done(key) if err := c.syncConfigMap(); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6K bytes - Viewed (0) -
pkg/controller/storageversionmigrator/resourceversion.go
} go wait.UntilWithContext(ctx, rv.worker, time.Second) <-ctx.Done() } func (rv *ResourceVersionController) worker(ctx context.Context) { for rv.processNext(ctx) { } } func (rv *ResourceVersionController) processNext(ctx context.Context) bool { key, quit := rv.queue.Get() if quit { return false } defer rv.queue.Done(key) err := rv.sync(ctx, key) if err == nil {
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/storageversionmigrator/storageversionmigrator.go
go wait.UntilWithContext(ctx, svmc.worker, time.Second) } <-ctx.Done() } func (svmc *SVMController) worker(ctx context.Context) { for svmc.processNext(ctx) { } } func (svmc *SVMController) processNext(ctx context.Context) bool { key, quit := svmc.queue.Get() if quit { return false } defer svmc.queue.Done(key) err := svmc.sync(ctx, key) if err == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.5K bytes - Viewed (0) -
pkg/controller/servicecidrs/servicecidrs_controller.go
serviceCIDRs = append(serviceCIDRs, v.UnsortedList()...) } return serviceCIDRs } func (c *Controller) worker(ctx context.Context) { for c.processNext(ctx) { } } func (c *Controller) processNext(ctx context.Context) bool { key, quit := c.queue.Get() if quit { return false } defer c.queue.Done(key) err := c.sync(ctx, key) if err == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 18K bytes - Viewed (0) -
platforms/core-configuration/model-core/src/main/java/org/gradle/internal/snapshot/impl/AbstractValueProcessor.java
} if (value instanceof Short) { return visitor.shortValue((Short) value); } } if (value instanceof Set) { return processSet((Set<?>) value, visitor); } if (value instanceof Map) { return processMap((Map<?, ?>) value, visitor); } if (valueClass.isArray()) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Feb 05 19:08:37 UTC 2024 - 10K bytes - Viewed (0)