Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Controller ¶
type Controller struct { // Name is used to uniquely identify a Controller in tracing, logging and monitoring. Name is required. Name string // MaxConcurrentReconciles is the maximum number of concurrent Reconciles which can be run. Defaults to 1. MaxConcurrentReconciles int // Reconciler is a function that can be called at any time with the Name / Namespace of an object and // ensures that the state of the system matches the state specified in the object. // Defaults to the DefaultReconcileFunc. Do reconcile.Reconciler // MakeQueue constructs the queue for this controller once the controller is ready to start. // This exists because the standard Kubernetes workqueues start themselves immediately, which // leads to goroutine leaks if something calls controller.New repeatedly. MakeQueue func() workqueue.RateLimitingInterface // Queue is an listeningQueue that listens for events from Informers and adds object keys to // the Queue for processing Queue workqueue.RateLimitingInterface // SetFields is used to inject dependencies into other objects such as Sources, EventHandlers and Predicates SetFields func(i interface{}) error // JitterPeriod allows tests to reduce the JitterPeriod so they complete faster JitterPeriod time.Duration // Started is true if the Controller has been Started Started bool // Log is used to log messages to users during reconciliation, or for example when a watch is started. Log logr.Logger // contains filtered or unexported fields }
Controller implements controller.Controller
func (*Controller) InjectFunc ¶
func (c *Controller) InjectFunc(f inject.Func) error
InjectFunc implement SetFields.Injector
func (*Controller) Start ¶
func (c *Controller) Start(stop <-chan struct{}) error
Start implements controller.Controller
func (*Controller) Watch ¶
func (c *Controller) Watch(src source.Source, evthdler handler.EventHandler, prct ...predicate.Predicate) error
Watch implements controller.Controller
Click to show internal directories.
Click to hide internal directories.