handler

Documentation

Index

• Constants
• type EventHandler
  • func NewEventHandler(opts ...Option) *EventHandler
  • func (e *EventHandler) Create(ctx context.Context, ev event.CreateEvent, ...)
  • func (e *EventHandler) Delete(ctx context.Context, ev event.DeleteEvent, ...)
  • func (e *EventHandler) Forget(rateLimiterName, name string)
  • func (e *EventHandler) Generic(ctx context.Context, ev event.GenericEvent, ...)
  • func (e *EventHandler) RequestReconcile(rateLimiterName, name string, failureLimit *int) bool
  • func (e *EventHandler) Update(ctx context.Context, ev event.UpdateEvent, ...)
• type Option
  • func WithLogger(logger logging.Logger) Option

Constants

const NoRateLimiter = ""

Types

type EventHandler

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

EventHandler handles Kubernetes events by queueing reconcile requests for objects and allows upjet components to queue reconcile requests.

func NewEventHandler

func NewEventHandler(opts ...Option) *EventHandler

NewEventHandler initializes a new EventHandler instance.

func (*EventHandler) Create

func (e *EventHandler) Create(ctx context.Context, ev event.CreateEvent, limitingInterface workqueue.RateLimitingInterface)

func (*EventHandler) Delete

func (e *EventHandler) Delete(ctx context.Context, ev event.DeleteEvent, limitingInterface workqueue.RateLimitingInterface)

func (*EventHandler) Forget

func (e *EventHandler) Forget(rateLimiterName, name string)

Forget indicates that the reconcile retries is finished for the specified name.

func (*EventHandler) Generic

func (e *EventHandler) Generic(ctx context.Context, ev event.GenericEvent, limitingInterface workqueue.RateLimitingInterface)

func (*EventHandler) RequestReconcile

func (e *EventHandler) RequestReconcile(rateLimiterName, name string, failureLimit *int) bool

RequestReconcile requeues a reconciliation request for the specified name. Returns true if the reconcile request was successfully queued.

func (*EventHandler) Update

func (e *EventHandler) Update(ctx context.Context, ev event.UpdateEvent, limitingInterface workqueue.RateLimitingInterface)

type Option

type Option func(eventHandler *EventHandler)

Option configures an option for the EventHandler.

func WithLogger

func WithLogger(logger logging.Logger) Option

WithLogger configures the logger for the EventHandler.