Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for registeredHandlers (0.2 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top