 Documentation
      ¶
      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
	// Client is a lazily initialized Client.  The controllerManager will initialize this when Start is called.
	Client client.Client
	// Scheme is injected by the controllerManager when controllerManager.Start is called
	Scheme *runtime.Scheme
	// informers are injected by the controllerManager when controllerManager.Start is called
	Cache cache.Cache
	// Config is the rest.Config used to talk to the apiserver.  Defaults to one of in-cluster, environment variable
	// specified, or the ~/.kube/Config.
	Config *rest.Config
	// 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
	// WaitForCacheSync allows tests to mock out the WaitForCacheSync function to return an error
	// defaults to Cache.WaitForCacheSync
	WaitForCacheSync func(stopCh <-chan struct{}) bool
	// Started is true if the Controller has been Started
	Started bool
	// Recorder is an event recorder for recording Event resources to the
	// Kubernetes API.
	Recorder record.EventRecorder
	// 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.