context

Documentation

Index

• type ControllerContext
  • func NewControllerContext(kubeClient kubernetes.Interface, namespace string, resyncPeriod time.Duration, ...) *ControllerContext
  • func (ctx *ControllerContext) HasSynced() bool
  • func (ctx *ControllerContext) Recorder(ns string) record.EventRecorder
  • func (ctx *ControllerContext) Start(stopCh chan struct{})

Types

type ControllerContext

type ControllerContext struct {
	IngressInformer  cache.SharedIndexInformer
	ServiceInformer  cache.SharedIndexInformer
	PodInformer      cache.SharedIndexInformer
	NodeInformer     cache.SharedIndexInformer
	EndpointInformer cache.SharedIndexInformer
	// contains filtered or unexported fields
}

ControllerContext holds

func NewControllerContext

func NewControllerContext(kubeClient kubernetes.Interface, namespace string, resyncPeriod time.Duration, enableEndpointsInformer bool) *ControllerContext

NewControllerContext returns a new shared set of informers.

func (*ControllerContext) HasSynced

func (ctx *ControllerContext) HasSynced() bool

HasSynced returns true if all relevant informers has been synced.

func (*ControllerContext) Recorder

func (ctx *ControllerContext) Recorder(ns string) record.EventRecorder

func (*ControllerContext) Start

func (ctx *ControllerContext) Start(stopCh chan struct{})

Start all of the informers.