enqueuelogger

Documentation

Index

• Variables
• func WrapIfNecessary(kind string, logger logr.Logger, handler handler.EventHandler) handler.EventHandler
• type AdditionNotifierQueue
  • func (q *AdditionNotifierQueue) Add(item reconcile.Request)
  • func (q *AdditionNotifierQueue) AddAfter(item reconcile.Request, duration time.Duration)
  • func (q *AdditionNotifierQueue) AddRateLimited(item reconcile.Request)
  • func (q *AdditionNotifierQueue) Done(item reconcile.Request)
  • func (q *AdditionNotifierQueue) Forget(item reconcile.Request)
  • func (q *AdditionNotifierQueue) Get() (item reconcile.Request, shutdown bool)
  • func (q *AdditionNotifierQueue) Len() int
  • func (q *AdditionNotifierQueue) NumRequeues(item reconcile.Request) int
  • func (q *AdditionNotifierQueue) ShutDown()
  • func (q *AdditionNotifierQueue) ShutDownWithDrain()
  • func (q *AdditionNotifierQueue) ShuttingDown() bool
• type EnqueueEventLogger
  • func (h *EnqueueEventLogger) Create(ctx context.Context, e event.TypedCreateEvent[client.Object], ...)
  • func (h *EnqueueEventLogger) Delete(ctx context.Context, e event.TypedDeleteEvent[client.Object], ...)
  • func (h *EnqueueEventLogger) Generic(ctx context.Context, e event.TypedGenericEvent[client.Object], ...)
  • func (h *EnqueueEventLogger) Update(ctx context.Context, e event.TypedUpdateEvent[client.Object], ...)
• type EventSummary
• type ObjectSummary

Variables

var LogEnqueueEvents = false

Functions

func WrapIfNecessary

func WrapIfNecessary(kind string, logger logr.Logger, handler handler.EventHandler) handler.EventHandler

Types

type AdditionNotifierQueue

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

AdditionNotifierQueue is a queue that calls an onAdd function whenever an item is added to the queue. It is meant to be used in conjunction with EnqueueEventLogger to log items enqueued by a handler.

func (*AdditionNotifierQueue) Add

func (q *AdditionNotifierQueue) Add(item reconcile.Request)

func (*AdditionNotifierQueue) AddAfter

func (q *AdditionNotifierQueue) AddAfter(item reconcile.Request, duration time.Duration)

func (*AdditionNotifierQueue) AddRateLimited

func (q *AdditionNotifierQueue) AddRateLimited(item reconcile.Request)

func (*AdditionNotifierQueue) Done

func (q *AdditionNotifierQueue) Done(item reconcile.Request)

func (*AdditionNotifierQueue) Forget

func (q *AdditionNotifierQueue) Forget(item reconcile.Request)

func (*AdditionNotifierQueue) Get

func (q *AdditionNotifierQueue) Get() (item reconcile.Request, shutdown bool)

func (*AdditionNotifierQueue) Len

func (q *AdditionNotifierQueue) Len() int

func (*AdditionNotifierQueue) NumRequeues

func (q *AdditionNotifierQueue) NumRequeues(item reconcile.Request) int

func (*AdditionNotifierQueue) ShutDown

func (q *AdditionNotifierQueue) ShutDown()

func (*AdditionNotifierQueue) ShutDownWithDrain

func (q *AdditionNotifierQueue) ShutDownWithDrain()

func (*AdditionNotifierQueue) ShuttingDown

func (q *AdditionNotifierQueue) ShuttingDown() bool

type EnqueueEventLogger

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

EnqueueEventLogger is a handler.EventHandler that wraps another handler.EventHandler and logs enqueued items (i.e. if the wrapped handler enqueues items from the event that is being handled, the EnqueueEventLogger logs them). The main purpose of this wrapper is to help with debugging which watch events are causing an object to be enqueued for reconciliation.

func (*EnqueueEventLogger) Create

func (h *EnqueueEventLogger) Create(ctx context.Context, e event.TypedCreateEvent[client.Object], q workqueue.TypedRateLimitingInterface[reconcile.Request])

func (*EnqueueEventLogger) Delete

func (h *EnqueueEventLogger) Delete(ctx context.Context, e event.TypedDeleteEvent[client.Object], q workqueue.TypedRateLimitingInterface[reconcile.Request])

func (*EnqueueEventLogger) Generic

func (h *EnqueueEventLogger) Generic(ctx context.Context, e event.TypedGenericEvent[client.Object], q workqueue.TypedRateLimitingInterface[reconcile.Request])

func (*EnqueueEventLogger) Update

func (h *EnqueueEventLogger) Update(ctx context.Context, e event.TypedUpdateEvent[client.Object], q workqueue.TypedRateLimitingInterface[reconcile.Request])

type EventSummary

type EventSummary struct {
	Type   string        `json:"type"`
	Object ObjectSummary `json:"object"`
}

type ObjectSummary

type ObjectSummary struct {
	Kind      string `json:"kind"`
	Namespace string `json:"namespace,omitempty"`
	Name      string `json:"name"`
}