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 SecretController
  • func NewSecretControllerWithEventHandler(secretInformer coreinformers.SecretInformer, resyncPeriod time.Duration, ...) *SecretController
  • func (c *SecretController) Run(stopCh <-chan struct{})
• type SecretHandler
• type SecretStore
  • func (l *SecretStore) ByKey(key string) (*corev1.Secret, error)
• type ServiceController
  • func NewServiceControllerWithEventHandler(serviceInformer coreinformers.ServiceInformer, resyncPeriod time.Duration, ...) *ServiceController
  • func (c *ServiceController) Run(stopCh <-chan struct{})
• type ServiceExportController
  • func NewServiceExportControllerWithEventHandler(serviceExportInformer svcexpv1alpha1informers.ServiceExportInformer, ...) *ServiceExportController
  • func (c *ServiceExportController) Run(stopCh <-chan struct{})
• type ServiceExportHandler
• type ServiceExportStore
  • func (l *ServiceExportStore) ByKey(key string) (*svcexpv1alpha1.ServiceExport, error)
• type ServiceHandler
• type ServiceImportController
  • func NewServiceImportControllerWithEventHandler(serviceImportInformer svcimpv1alpha1informers.ServiceImportInformer, ...) *ServiceImportController
  • func (c *ServiceImportController) Run(stopCh <-chan struct{})
• type ServiceImportHandler
• type ServiceImportStore
  • func (l *ServiceImportStore) ByKey(key string) (*svcimpv1alpha1.ServiceImport, error)
• 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 SecretController

type SecretController struct {
	Informer  cache.SharedIndexInformer
	Store     SecretStore
	HasSynced cache.InformerSynced
	Lister    v1.SecretLister
	// contains filtered or unexported fields
}

func NewSecretControllerWithEventHandler

func NewSecretControllerWithEventHandler(secretInformer coreinformers.SecretInformer, resyncPeriod time.Duration, handler SecretHandler) *SecretController

func (*SecretController) Run

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

type SecretHandler

type SecretHandler interface {
	OnSecretAdd(secret *corev1.Secret)
	OnSecretUpdate(oldSecret, secret *corev1.Secret)
	OnSecretDelete(secret *corev1.Secret)
	OnSecretSynced()
}

type SecretStore

type SecretStore struct {
	cache.Store
}

func (*SecretStore) ByKey

func (l *SecretStore) ByKey(key string) (*corev1.Secret, 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 ServiceExportController

type ServiceExportController struct {
	Informer  cache.SharedIndexInformer
	Store     ServiceExportStore
	HasSynced cache.InformerSynced
	Lister    svcexpv1alpha1lister.ServiceExportLister
	// contains filtered or unexported fields
}

func NewServiceExportControllerWithEventHandler

func NewServiceExportControllerWithEventHandler(serviceExportInformer svcexpv1alpha1informers.ServiceExportInformer, resyncPeriod time.Duration, handler ServiceExportHandler) *ServiceExportController

func (*ServiceExportController) Run

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

type ServiceExportHandler

type ServiceExportHandler interface {
	OnServiceExportAdd(serviceExport *svcexpv1alpha1.ServiceExport)
	OnServiceExportUpdate(oldServiceExport, serviceExport *svcexpv1alpha1.ServiceExport)
	OnServiceExportDelete(serviceExport *svcexpv1alpha1.ServiceExport)
	OnServiceExportSynced()
}

type ServiceExportStore

type ServiceExportStore struct {
	cache.Store
}

func (*ServiceExportStore) ByKey

func (l *ServiceExportStore) ByKey(key string) (*svcexpv1alpha1.ServiceExport, error)

type ServiceHandler

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

type ServiceImportController

type ServiceImportController struct {
	Informer  cache.SharedIndexInformer
	Store     ServiceImportStore
	HasSynced cache.InformerSynced
	Lister    svcimpv1alpha1lister.ServiceImportLister
	// contains filtered or unexported fields
}

func NewServiceImportControllerWithEventHandler

func NewServiceImportControllerWithEventHandler(serviceImportInformer svcimpv1alpha1informers.ServiceImportInformer, resyncPeriod time.Duration, handler ServiceImportHandler) *ServiceImportController

func (*ServiceImportController) Run

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

type ServiceImportHandler

type ServiceImportHandler interface {
	OnServiceImportAdd(serviceImport *svcimpv1alpha1.ServiceImport)
	OnServiceImportUpdate(oldServiceImport, serviceImport *svcimpv1alpha1.ServiceImport)
	OnServiceImportDelete(serviceImport *svcimpv1alpha1.ServiceImport)
	OnServiceImportSynced()
}

type ServiceImportStore

type ServiceImportStore struct {
	cache.Store
}

func (*ServiceImportStore) ByKey

func (l *ServiceImportStore) ByKey(key string) (*svcimpv1alpha1.ServiceImport, error)

type ServiceStore

type ServiceStore struct {
	cache.Store
}

func (*ServiceStore) ByKey

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