- Sort Score
- Result 10 results
- Languages All
Results 41 - 42 of 42 for UntilWithContext (3.18 sec)
-
pkg/controller/daemon/daemon_controller.go
if !cache.WaitForNamedCacheSync("daemon sets", ctx.Done(), dsc.podStoreSynced, dsc.nodeStoreSynced, dsc.historyStoreSynced, dsc.dsStoreSynced) { return } for i := 0; i < workers; i++ { go wait.UntilWithContext(ctx, dsc.runWorker, time.Second) } go wait.Until(dsc.failedPodsBackoff.GC, BackoffGCInterval, ctx.Done()) <-ctx.Done() } func (dsc *DaemonSetsController) runWorker(ctx context.Context) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.3K bytes - Viewed (0) -
pkg/controller/podautoscaler/horizontal.go
defer logger.Info("Shutting down HPA controller") if !cache.WaitForNamedCacheSync("HPA", ctx.Done(), a.hpaListerSynced, a.podListerSynced) { return } for i := 0; i < workers; i++ { go wait.UntilWithContext(ctx, a.worker, time.Second) } <-ctx.Done() } // obj could be an *v1.HorizontalPodAutoscaler, or a DeletionFinalStateUnknown marker item. func (a *HorizontalController) updateHPA(old, cur interface{}) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 63.6K bytes - Viewed (0)