controller

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 New(name string, reconciler Reconciler, informersSynced ...cache.InformerSynced) *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

Functions

func AddRemoteControllerReference

func AddRemoteControllerReference(child metav1.Object, parent metav1.Object)

func HandleAddUpdateWith

func HandleAddUpdateWith(f func(obj interface{})) cache.ResourceEventHandlerFuncs

func HandleAllWith

func HandleAllWith(f func(obj interface{})) cache.ResourceEventHandlerFuncs

func IsOptimisticLockError

func IsOptimisticLockError(err error) bool

func ParentControlsChild

func ParentControlsChild(child metav1.Object, parent metav1.Object) bool

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

func (c *Controller) EnqueueController(ownerKind string, getOwner GetOwner) func(obj interface{})

func (*Controller) EnqueueKey

func (c *Controller) EnqueueKey(key interface{})

func (*Controller) EnqueueObject

func (c *Controller) EnqueueObject(obj interface{})

func (*Controller) EnqueueRemoteController

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 GetOwner

type GetOwner func(namespace string, name string) (metav1.Object, error)

type Reconciler

type Reconciler interface {
	Handle(key interface{}) (requeueAfter *time.Duration, err error)
}