Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewController ¶
func NewController(controlCtx *ControlClusterContext, targetCtx *TargetClusterContext) *common.Controller
NewController creates a new instance of NewController which in turn is capable of replicating Secrets.
Types ¶
type ControlClusterContext ¶
type ControlClusterContext struct {
// ResourceNamespace determines the location of the managed secrets.
ResourceNamespace string
Client kubernetes.Interface
SecretLister v1.SecretLister
SecretInformer cache.SharedIndexInformer
SecretSync cache.InformerSynced
}
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 adds the object of a certain namespace to the queue if the obj's name alings to the anticipated control cluster pattern.
func (*EventHandler) OnDelete ¶
func (e *EventHandler) OnDelete(obj interface{})
OnDelete events are ignores
func (*EventHandler) OnUpdate ¶
func (e *EventHandler) OnUpdate(oldObj, newObj interface{})
OnUpdate adds the object of a certain namespace to the queue if the obj's name alings to the anticipated control cluster pattern and oldObj differs from newObj.
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
type TargetClusterContext ¶
type TargetClusterContext struct {
Client kubernetes.Interface
IngressLister v1beta1.IngressLister
IngressSync cache.InformerSynced
}
TargetClusterContext holds information about the target cluster.
Source Files