controller

Documentation

Index

• type Controller
  • func New(kubeclient kubernetes.Interface, heliosclient heliosclientset.Interface, ...) *Controller
  • func (c *Controller) Run(workers int, stopCh <-chan struct{}) error

Types

type Controller

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

func New

func New(
	kubeclient kubernetes.Interface,
	heliosclient heliosclientset.Interface,
	heliosInformer heliosinformersv1.HeliosInformer,
	podInformer coreinformers.PodInformer) *Controller

func (*Controller) Run

func (c *Controller) Run(workers int, stopCh <-chan struct{}) error

Run will setup the event handlers for types we are interested in, as well as syncing informer caches and starting loggers. It will block until stopCh is closed, at which point it will shutdown the queue and wait for loggers to finish processing their current work items.