controller

type EventHandler struct {
	// contains filtered or unexported fields
}

type Interface interface {
	// Name returns the name of the controller.
	Name() string

	// WorkerCount returns the number of worker(s) that will process item(s)
	// off of the underlying work queue.s
	WorkerCount() int

	//Queue returns the underlying work queue associated with the controller.
	Queue() workqueue.RateLimitingInterface

	// Informer returns the underlying Informer object associated with the controller.
	Informer() cache.Controller

	// Reconciler returns the reconciler function that reconciles a request from a work queue.
	Reconciler() reconcile.Reconciler
}

type Runner interface {
	// Run initializes the given controller and starts it. It waits until the shutdown
	// context is done.
	// The function should return on any error during initialization.
	// Any error encountered during initialization is written to the errorCh channel so
	// that the caller take appropriate action.
	Run(shutdown context.Context, controller Interface, errorCh chan<- error)

	// Done returns a channel that's closed when the Run function finishes.
	Done() <-chan struct{}
}

type WorkerFunc func(shutdown context.Context, controller Interface)