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 // 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 // Deprecated: the caller should handle injected fields itself. SetFields func(i interface{}) error // Started is true if the Controller has been Started Started bool // CacheSyncTimeout refers to the time limit set on waiting for cache to sync // Defaults to 2 minutes if not set. CacheSyncTimeout time.Duration // RecoverPanic indicates whether the panic caused by reconcile should be recovered. RecoverPanic bool // 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(ctx context.Context) error
Start implements controller.Controller.
func (*Controller) WaitForStarted ¶
func (c *Controller) WaitForStarted(ctx context.Context) bool
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.