Documentation ¶
Index ¶
- func AddRemoteControllerReference(child metav1.Object, parent metav1.Object)
- func HandleAddUpdateWith(f func(obj interface{})) cache.ResourceEventHandlerFuncs
- func HandleAllWith(f func(obj interface{})) cache.ResourceEventHandlerFuncs
- func IsOptimisticLockError(err error) bool
- func ParentControlsChild(child metav1.Object, parent metav1.Object) bool
- type Controller
- func (c *Controller) EnqueueController(ownerKind string, getOwner GetOwner) func(obj interface{})
- func (c *Controller) EnqueueKey(key interface{})
- func (c *Controller) EnqueueObject(obj interface{})
- func (c *Controller) EnqueueRemoteController(ownerKind string, getOwner GetOwner) func(obj interface{})
- func (c *Controller) Run(threadiness int, stopCh <-chan struct{}) error
- type GetOwner
- type Reconciler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddRemoteControllerReference ¶ added in v0.10.0
func HandleAddUpdateWith ¶ added in v0.9.0
func HandleAddUpdateWith(f func(obj interface{})) cache.ResourceEventHandlerFuncs
func HandleAllWith ¶ added in v0.9.0
func HandleAllWith(f func(obj interface{})) cache.ResourceEventHandlerFuncs
func IsOptimisticLockError ¶ added in v0.12.0
Types ¶
type Controller ¶
type Controller struct {
// contains filtered or unexported fields
}
func New ¶
func New(name string, reconciler Reconciler, informersSynced ...cache.InformerSynced) *Controller
func (*Controller) EnqueueController ¶ added in v0.9.0
func (c *Controller) EnqueueController(ownerKind string, getOwner GetOwner) func(obj interface{})
func (*Controller) EnqueueKey ¶ added in v0.9.0
func (c *Controller) EnqueueKey(key interface{})
func (*Controller) EnqueueObject ¶ added in v0.9.0
func (c *Controller) EnqueueObject(obj interface{})
func (*Controller) EnqueueRemoteController ¶ added in v0.9.0
func (c *Controller) EnqueueRemoteController(ownerKind string, getOwner GetOwner) func(obj interface{})
func (*Controller) Run ¶
func (c *Controller) Run(threadiness int, stopCh <-chan struct{}) error
Run will set up the event handlers for types we are interested in, as well as syncing informer caches and starting workers. It will block until stopCh is closed, at which point it will shutdown the workqueue and wait for workers to finish processing their current work items.
type Reconciler ¶
Click to show internal directories.
Click to hide internal directories.