controller

Documentation

Index

• type Controller
  • func NewController(client kubernetes.Interface, resource string, namespace string, ...) (*Controller, error)
  • func (c *Controller) Add(obj interface{})
  • func (c *Controller) Delete(old interface{})
  • func (c *Controller) Run(threadiness int, stopCh chan struct{})
  • func (c *Controller) Update(old interface{}, new interface{})

Types

type Controller

type Controller struct {
	// contains filtered or unexported fields
}

Controller for checking events

func NewController

func NewController(
	client kubernetes.Interface, resource string, namespace string, ignoredNamespaces []string, namespaceLabelSelector string, resourceLabelSelector string, collectors metrics.Collectors) (*Controller, error)

NewController for initializing a Controller

func (*Controller) Add

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

Add function to add a new object to the queue in case of creating a resource

func (*Controller) Delete

func (c *Controller) Delete(old interface{})

Delete function to add an object to the queue in case of deleting a resource

func (*Controller) Run

func (c *Controller) Run(threadiness int, stopCh chan struct{})

Run function for controller which handles the queue

func (*Controller) Update

func (c *Controller) Update(old interface{}, new interface{})

Update function to add an old object and a new object to the queue in case of updating a resource