events

Documentation

Index

• func NewController(controlCtx *ControlClusterContext, targetCtx *TargetClusterContext) *common.Controller
• type ControlClusterContext
• type EventHandler
  • func (e *EventHandler) OnAdd(obj interface{})
  • func (e *EventHandler) OnDelete(obj interface{})
  • func (e *EventHandler) OnUpdate(oldObj, newObj interface{})
• type Handler
  • func (h *Handler) GetInformerSyncs() []cache.InformerSynced
  • func (h *Handler) GetWorkQueue() workqueue.RateLimitingInterface
  • func (h *Handler) Sync(key string) error
• type TargetClusterContext

Functions

func NewController

func NewController(controlCtx *ControlClusterContext, targetCtx *TargetClusterContext) *common.Controller

NewController creates a new instance of Controller which in turn is capable of replicating Ingress resources.

Types

type ControlClusterContext

type ControlClusterContext struct {
	// ResourceNamespace determines the location of replicated Ingress resources.
	EventInformer      cache.SharedIndexInformer
	EventLister        corev1.EventLister
	EventSync          cache.InformerSynced
	CertificatesLister cache.GenericLister
	CertificatesSync   cache.InformerSynced
	Client             kubernetes.Interface
}

ControlClusterContext holds information about the control cluster.

type EventHandler

type EventHandler struct {
	Queue workqueue.RateLimitingInterface
}

EventHandler dispatches events to a queue of type RateLimitingInterface.

func (*EventHandler) OnAdd

func (e *EventHandler) OnAdd(obj interface{})

OnAdd events are ignored yet.

func (*EventHandler) OnDelete

func (e *EventHandler) OnDelete(obj interface{})

OnDelete events are ignored yet.

func (*EventHandler) OnUpdate

func (e *EventHandler) OnUpdate(oldObj, newObj interface{})

OnUpdate puts the object to the queue in case a new K8s Event was recorded.

type Handler

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

Handler holds information about the traget and control cluster.

func (*Handler) GetInformerSyncs

func (h *Handler) GetInformerSyncs() []cache.InformerSynced

GetInformerSyncs gets the informer sync functions to be waited for before using the handlers listers

func (*Handler) GetWorkQueue

func (h *Handler) GetWorkQueue() workqueue.RateLimitingInterface

GetWorkQueue gets the workqueue managed by this handler

func (*Handler) Sync

func (h *Handler) Sync(key string) error

Sync handles actions for the passed reource key

type TargetClusterContext

type TargetClusterContext struct {
	Client        kubernetes.Interface
	IngressLister lv1beta1.IngressLister
	IngressSync   cache.InformerSynced
}

TargetClusterContext holds information about the target cluster.