controller

Documentation

Index

• type ConfigMapController
  • func NewConfigMapControllerWithEventHandler(configmapInformer coreinformers.ConfigMapInformer, resyncPeriod time.Duration, ...) *ConfigMapController
  • func (c *ConfigMapController) Run(stopCh <-chan struct{})
• type ConfigMapFilterFunc
• type ConfigMapHandler
• type ConfigMapStore
  • func (l *ConfigMapStore) ByKey(key string) (*corev1.ConfigMap, error)
• type EndpointStore
  • func (l *EndpointStore) ByKey(key string) (*corev1.Endpoints, error)
• type EndpointsController
  • func NewEndpointsControllerWithEventHandler(endpointsInformer coreinformers.EndpointsInformer, resyncPeriod time.Duration, ...) *EndpointsController
  • func (c *EndpointsController) Run(stopCh <-chan struct{})
• type EndpointsHandler
• type IngressClassv1Controller
  • func NewIngressClassv1ControllerWithEventHandler(ingressClassInformer networkingv1informers.IngressClassInformer, ...) *IngressClassv1Controller
  • func (c *IngressClassv1Controller) Run(stopCh <-chan struct{})
• type IngressClassv1Handler
• type IngressClassv1Store
  • func (l *IngressClassv1Store) ByKey(key string) (*networkingv1.IngressClass, error)
• type Ingressv1Controller
  • func NewIngressv1ControllerWithEventHandler(ingressInformer networkingv1informers.IngressInformer, ...) *Ingressv1Controller
  • func (c *Ingressv1Controller) Run(stopCh <-chan struct{})
• type Ingressv1Handler
• type Ingressv1Store
  • func (l *Ingressv1Store) ByKey(key string) (*networkingv1.Ingress, error)
• type ServiceController
  • func NewServiceControllerWithEventHandler(serviceInformer coreinformers.ServiceInformer, resyncPeriod time.Duration, ...) *ServiceController
  • func (c *ServiceController) Run(stopCh <-chan struct{})
• type ServiceHandler
• type ServiceStore
  • func (l *ServiceStore) ByKey(key string) (*corev1.Service, error)

Types

type ConfigMapController

type ConfigMapController struct {
	Informer  cache.SharedIndexInformer
	Store     ConfigMapStore
	HasSynced cache.InformerSynced
	Lister    v1.ConfigMapLister
	// contains filtered or unexported fields
}

func NewConfigMapControllerWithEventHandler

func NewConfigMapControllerWithEventHandler(configmapInformer coreinformers.ConfigMapInformer, resyncPeriod time.Duration, handler ConfigMapHandler, filter ConfigMapFilterFunc) *ConfigMapController

func (*ConfigMapController) Run

func (c *ConfigMapController) Run(stopCh <-chan struct{})

type ConfigMapFilterFunc

type ConfigMapFilterFunc func(obj interface{}) bool

type ConfigMapHandler

type ConfigMapHandler interface {
	OnConfigMapAdd(cm *corev1.ConfigMap)
	OnConfigMapUpdate(oldCm, cm *corev1.ConfigMap)
	OnConfigMapDelete(cm *corev1.ConfigMap)
	OnConfigMapSynced()
}

type ConfigMapStore

type ConfigMapStore struct {
	cache.Store
}

func (*ConfigMapStore) ByKey

func (l *ConfigMapStore) ByKey(key string) (*corev1.ConfigMap, error)

type EndpointStore

type EndpointStore struct {
	cache.Store
}

func (*EndpointStore) ByKey

func (l *EndpointStore) ByKey(key string) (*corev1.Endpoints, error)

type EndpointsController

type EndpointsController struct {
	Informer  cache.SharedIndexInformer
	Store     EndpointStore
	HasSynced cache.InformerSynced
	Lister    v1.EndpointsLister
	// contains filtered or unexported fields
}

func NewEndpointsControllerWithEventHandler

func NewEndpointsControllerWithEventHandler(endpointsInformer coreinformers.EndpointsInformer, resyncPeriod time.Duration, handler EndpointsHandler) *EndpointsController

func (*EndpointsController) Run

func (c *EndpointsController) Run(stopCh <-chan struct{})

type EndpointsHandler

type EndpointsHandler interface {
	OnEndpointsAdd(endpoints *corev1.Endpoints)
	OnEndpointsUpdate(oldEndpoints, endpoints *corev1.Endpoints)
	OnEndpointsDelete(endpoints *corev1.Endpoints)
	OnEndpointsSynced()
}

type IngressClassv1Controller

type IngressClassv1Controller struct {
	Informer  cache.SharedIndexInformer
	Store     IngressClassv1Store
	HasSynced cache.InformerSynced
	Lister    networkingv1lister.IngressClassLister
	// contains filtered or unexported fields
}

func NewIngressClassv1ControllerWithEventHandler

func NewIngressClassv1ControllerWithEventHandler(ingressClassInformer networkingv1informers.IngressClassInformer, resyncPeriod time.Duration, handler IngressClassv1Handler) *IngressClassv1Controller

func (*IngressClassv1Controller) Run

func (c *IngressClassv1Controller) Run(stopCh <-chan struct{})

type IngressClassv1Handler

type IngressClassv1Handler interface {
	OnIngressClassv1Add(ingressClass *networkingv1.IngressClass)
	OnIngressClassv1Update(oldIngressClass, ingressClass *networkingv1.IngressClass)
	OnIngressClassv1Delete(ingressClass *networkingv1.IngressClass)
	OnIngressClassv1Synced()
}

type IngressClassv1Store

type IngressClassv1Store struct {
	cache.Store
}

func (*IngressClassv1Store) ByKey

func (l *IngressClassv1Store) ByKey(key string) (*networkingv1.IngressClass, error)

type Ingressv1Controller

type Ingressv1Controller struct {
	Informer  cache.SharedIndexInformer
	Store     Ingressv1Store
	HasSynced cache.InformerSynced
	Lister    networkingv1lister.IngressLister
	// contains filtered or unexported fields
}

func NewIngressv1ControllerWithEventHandler

func NewIngressv1ControllerWithEventHandler(ingressInformer networkingv1informers.IngressInformer, resyncPeriod time.Duration, handler Ingressv1Handler) *Ingressv1Controller

func (*Ingressv1Controller) Run

func (c *Ingressv1Controller) Run(stopCh <-chan struct{})

type Ingressv1Handler

type Ingressv1Handler interface {
	OnIngressv1Add(ingress *networkingv1.Ingress)
	OnIngressv1Update(oldIngress, ingress *networkingv1.Ingress)
	OnIngressv1Delete(ingress *networkingv1.Ingress)
	OnIngressv1Synced()
}

type Ingressv1Store

type Ingressv1Store struct {
	cache.Store
}

func (*Ingressv1Store) ByKey

func (l *Ingressv1Store) ByKey(key string) (*networkingv1.Ingress, error)

type ServiceController

type ServiceController struct {
	Informer  cache.SharedIndexInformer
	Store     ServiceStore
	HasSynced cache.InformerSynced
	Lister    v1.ServiceLister
	// contains filtered or unexported fields
}

func NewServiceControllerWithEventHandler

func NewServiceControllerWithEventHandler(serviceInformer coreinformers.ServiceInformer, resyncPeriod time.Duration, handler ServiceHandler) *ServiceController

func (*ServiceController) Run

func (c *ServiceController) Run(stopCh <-chan struct{})

type ServiceHandler

type ServiceHandler interface {
	OnServiceAdd(service *corev1.Service)
	OnServiceUpdate(oldService, service *corev1.Service)
	OnServiceDelete(service *corev1.Service)
	OnServiceSynced()
}

type ServiceStore

type ServiceStore struct {
	cache.Store
}

func (*ServiceStore) ByKey

func (l *ServiceStore) ByKey(key string) (*corev1.Service, error)