- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for registeredHandlers (0.22 sec)
-
pkg/kube/kclient/client.go
// are registered (in n.registeredHandlers); this can cause the dynamic filtering to miss events reg, err := n.informer.AddEventHandler(fh) if err != nil { // Should only happen if its already stopped. We should exit early. return } n.registeredHandlers = append(n.registeredHandlers, handlerRegistration{registration: reg, handler: h}) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 17 07:14:28 UTC 2024 - 13K bytes - Viewed (0) -
pkg/scheduler/scheduler.go
// otherwise logging functions will access a nil sink and // panic. logger klog.Logger // registeredHandlers contains the registrations of all handlers. It's used to check if all handlers have finished syncing before the scheduling cycles start. registeredHandlers []cache.ResourceEventHandlerRegistration } func (sched *Scheduler) applyDefaultHandlers() { sched.SchedulePod = sched.schedulePod
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:20:55 UTC 2024 - 20.8K bytes - Viewed (0) -
pkg/scheduler/eventhandlers.go
func (sched *Scheduler) WaitForHandlersSync(ctx context.Context) error { return wait.PollUntilContextCancel(ctx, syncedPollPeriod, true, func(ctx context.Context) (done bool, err error) { for _, handler := range sched.registeredHandlers { if !handler.HasSynced() { return false, nil } } return true, nil }) } // addAllEventHandlers is a helper function used in tests and in Scheduler
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:21:04 UTC 2024 - 24K bytes - Viewed (0)