controller

Documentation

Index

• func AddRemoteControllerReference(child metav1.Object, parent metav1.Object, parentClusterName string)
• func HandleAddUpdateWith(f func(obj interface{})) cache.ResourceEventHandlerFuncs
• func HandleAllWith(f func(obj interface{})) cache.ResourceEventHandlerFuncs
• func HasFinalizer(finalizers []string, finalizer string) (bool, int)
• func IndexByRemoteController(parentClusterName string) cache.IndexFunc
• func IsOptimisticLockError(err error) bool
• func IsRemoteControlled(object metav1.Object, parentClusterName string) bool
• func ParentControlsChild(child metav1.Object, parent metav1.Object) bool
• func ParentKey(child metav1.Object) string
• 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(parentClusterName string) func(obj interface{})
  • func (c *Controller) Run(ctx context.Context, threadiness int) error
• type GetOwner
• type Reconciler

Functions

func AddRemoteControllerReference

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

func HandleAddUpdateWith

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

func HandleAllWith

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

func HasFinalizer

func HasFinalizer(finalizers []string, finalizer string) (bool, int)

func IndexByRemoteController

func IndexByRemoteController(parentClusterName string) cache.IndexFunc

func IsOptimisticLockError

func IsOptimisticLockError(err error) bool

func IsRemoteControlled

func IsRemoteControlled(object metav1.Object, parentClusterName string) bool

func ParentControlsChild

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

func ParentKey

func ParentKey(child metav1.Object) string

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(parentClusterName string) func(obj interface{})

func (*Controller) Run

func (c *Controller) Run(ctx context.Context, threadiness int) 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)
}