- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for WaitForHandlersSync (0.16 sec)
-
pkg/scheduler/eventhandlers.go
// syncedPollPeriod controls how often you look at the status of your sync funcs syncedPollPeriod = 100 * time.Millisecond ) // WaitForHandlersSync waits for EventHandlers to sync. // It returns true if it was successful, false if the controller should shut down func (sched *Scheduler) WaitForHandlersSync(ctx context.Context) error { return wait.PollUntilContextCancel(ctx, syncedPollPeriod, true, func(ctx context.Context) (done bool, err error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:21:04 UTC 2024 - 24K bytes - Viewed (0) -
cmd/kube-scheduler/app/server.go
if cc.DynInformerFactory != nil { cc.DynInformerFactory.WaitForCacheSync(ctx.Done()) } // Wait for all handlers to sync (all items in the initial list delivered) before scheduling. if err := sched.WaitForHandlersSync(ctx); err != nil { logger.Error(err, "waiting for handlers to sync") } close(handlerSyncReadyCh) logger.V(3).Info("Handlers synced") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 19:11:24 UTC 2024 - 14.3K bytes - Viewed (0) -
pkg/scheduler/schedule_one_test.go
wg.Done() }) if err != nil { t.Fatal(err) } defer stopFn() // Run scheduler. informerFactory.Start(ctx.Done()) informerFactory.WaitForCacheSync(ctx.Done()) if err = sched.WaitForHandlersSync(ctx); err != nil { t.Fatalf("Handlers failed to sync: %v: ", err) } go sched.Run(ctx) // Send pods to be scheduled. for _, p := range pods {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:20:55 UTC 2024 - 128.1K bytes - Viewed (0)