handler

Documentation

Index

• type CRDEventHandler
  • func (h *CRDEventHandler) Create(e event.CreateEvent, _ workqueue.RateLimitingInterface)
  • func (h *CRDEventHandler) Delete(e event.DeleteEvent, _ workqueue.RateLimitingInterface)
  • func (h *CRDEventHandler) Generic(e event.GenericEvent, _ workqueue.RateLimitingInterface)
  • func (h *CRDEventHandler) Update(e event.UpdateEvent, _ workqueue.RateLimitingInterface)
• type EnqueueEventToChannel
  • func (e *EnqueueEventToChannel) OnAdd(obj interface{})
  • func (e *EnqueueEventToChannel) OnDelete(obj interface{})
  • func (e *EnqueueEventToChannel) OnUpdate(_, newObj interface{})
• type Throttler
  • func NewThrottler(d time.Duration) *Throttler
  • func (e *Throttler) Create(event.CreateEvent, workqueue.RateLimitingInterface)
  • func (e *Throttler) Delete(event.DeleteEvent, workqueue.RateLimitingInterface)
  • func (e *Throttler) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)
  • func (e *Throttler) Update(event.UpdateEvent, workqueue.RateLimitingInterface)

Types

type CRDEventHandler

type CRDEventHandler struct {
	Mapping resourceMap
	Channel chan event.GenericEvent
	Log     logr.Logger
}

CRDEventHandler pushes an event to ResourceGroup event channel when the CRD or its CRs are contained in some ResourceGroup CRs.

func (*CRDEventHandler) Create

func (h *CRDEventHandler) Create(e event.CreateEvent, _ workqueue.RateLimitingInterface)

Create implements EventHandler

func (*CRDEventHandler) Delete

func (h *CRDEventHandler) Delete(e event.DeleteEvent, _ workqueue.RateLimitingInterface)

Delete implements EventHandler

func (*CRDEventHandler) Generic

func (h *CRDEventHandler) Generic(e event.GenericEvent, _ workqueue.RateLimitingInterface)

Generic implements EventHandler

func (*CRDEventHandler) Update

func (h *CRDEventHandler) Update(e event.UpdateEvent, _ workqueue.RateLimitingInterface)

Update implements EventHandler

type EnqueueEventToChannel

type EnqueueEventToChannel struct {
	Mapping resourceMap
	Channel chan event.GenericEvent
	Log     logr.Logger
	GVK     schema.GroupVersionKind
}

EnqueueEventToChannel pushes an event to ResourceGroup event channel instead of enqueue a Reqeust for ResourceGroup.

func (*EnqueueEventToChannel) OnAdd

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

OnAdd implements EventHandler

func (*EnqueueEventToChannel) OnDelete

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

OnDelete implements EventHandler

func (*EnqueueEventToChannel) OnUpdate

func (e *EnqueueEventToChannel) OnUpdate(_, newObj interface{})

OnUpdate implements EventHandler

type Throttler

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

Throttler only pushes a request to ResourceGroup work queue when there is no same event in the queue. It works with only GenericEvent and no-op for other events.

func NewThrottler

func NewThrottler(d time.Duration) *Throttler

NewThrottler returns an instance of Throttler

func (*Throttler) Create

func (e *Throttler) Create(event.CreateEvent, workqueue.RateLimitingInterface)

Create implements EventHandler. All create events are ignored.

func (*Throttler) Delete

func (e *Throttler) Delete(event.DeleteEvent, workqueue.RateLimitingInterface)

Delete implements EventHandler. All delete events are ignored.

func (*Throttler) Generic

func (e *Throttler) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)

Generic implements EventHandler. It pushes at most one event for the same object to the queue during duration.

func (*Throttler) Update

func (e *Throttler) Update(event.UpdateEvent, workqueue.RateLimitingInterface)

Update implements EventHandler. All update events are ignored.