controller

Documentation

Index

• type Controller
  • func NewController(name string, handleResource HandleResource, cacheSyncs ...cache.InformerSynced) *Controller
  • func (c *Controller) Queue() workqueue.RateLimitingInterface
  • func (c *Controller) Run(threadiness int, stopCh <-chan struct{}) error
• type HandleResource
• type JobController
  • func NewJobController(kubeClient clientset.Interface, jobInformer batchinformers.JobInformer, ...) *JobController

Types

type Controller

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

Controller is a skeleton for custom controller

func NewController

func NewController(name string, handleResource HandleResource, cacheSyncs ...cache.InformerSynced) *Controller

func (*Controller) Queue

func (c *Controller) Queue() workqueue.RateLimitingInterface

Queue returns the work queue for outside package usage.

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 HandleResource

type HandleResource func(namespace, name string) error

type JobController

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

func NewJobController

func NewJobController(kubeClient clientset.Interface, jobInformer batchinformers.JobInformer, retentionInSeconds int64) *JobController