handler

Documentation

Index

• func EnqueueRequestSet(s RequestSet, queue workqueue.RateLimitingInterface)
• func InsertListRequests(s RequestSet, list client.ObjectList) error
• func InsertObjectRequest(s RequestSet, obj client.Object)
• type EnqueueRequestByFieldReference
  • func (e *EnqueueRequestByFieldReference) Create(event event.CreateEvent, queue workqueue.RateLimitingInterface)
  • func (e *EnqueueRequestByFieldReference) Delete(event event.DeleteEvent, queue workqueue.RateLimitingInterface)
  • func (e *EnqueueRequestByFieldReference) Generic(event event.GenericEvent, queue workqueue.RateLimitingInterface)
  • func (e *EnqueueRequestByFieldReference) InjectClient(c client.Client) error
  • func (e *EnqueueRequestByFieldReference) Update(event event.UpdateEvent, queue workqueue.RateLimitingInterface)
• type EnqueueRequestForObjectNamespace
  • func (e *EnqueueRequestForObjectNamespace) Create(event event.CreateEvent, queue workqueue.RateLimitingInterface)
  • func (e *EnqueueRequestForObjectNamespace) Delete(event event.DeleteEvent, queue workqueue.RateLimitingInterface)
  • func (e *EnqueueRequestForObjectNamespace) Generic(event event.GenericEvent, queue workqueue.RateLimitingInterface)
  • func (e *EnqueueRequestForObjectNamespace) Update(event event.UpdateEvent, queue workqueue.RateLimitingInterface)
• type EnqueueStaticRequest
  • func (e EnqueueStaticRequest) Create(_ event.CreateEvent, queue workqueue.RateLimitingInterface)
  • func (e EnqueueStaticRequest) Delete(event event.DeleteEvent, queue workqueue.RateLimitingInterface)
  • func (e EnqueueStaticRequest) Generic(event event.GenericEvent, queue workqueue.RateLimitingInterface)
  • func (e EnqueueStaticRequest) Update(event event.UpdateEvent, queue workqueue.RateLimitingInterface)
• type RequestSet
  • func NewRequestSet(items ...reconcile.Request) RequestSet
  • func (s RequestSet) Insert(items ...reconcile.Request) RequestSet
  • func (s RequestSet) UnsortedList() []reconcile.Request

Functions

func EnqueueRequestSet

func EnqueueRequestSet(s RequestSet, queue workqueue.RateLimitingInterface)

func InsertListRequests

func InsertListRequests(s RequestSet, list client.ObjectList) error

func InsertObjectRequest

func InsertObjectRequest(s RequestSet, obj client.Object)

Types

type EnqueueRequestByFieldReference

type EnqueueRequestByFieldReference struct {
	Type  client.Object
	Field string
	// contains filtered or unexported fields
}

func (*EnqueueRequestByFieldReference) Create

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

func (*EnqueueRequestByFieldReference) Delete

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

func (*EnqueueRequestByFieldReference) Generic

func (e *EnqueueRequestByFieldReference) Generic(event event.GenericEvent, queue workqueue.RateLimitingInterface)

func (*EnqueueRequestByFieldReference) InjectClient

func (e *EnqueueRequestByFieldReference) InjectClient(c client.Client) error

func (*EnqueueRequestByFieldReference) Update

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

type EnqueueRequestForObjectNamespace

type EnqueueRequestForObjectNamespace struct{}

func (*EnqueueRequestForObjectNamespace) Create

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

func (*EnqueueRequestForObjectNamespace) Delete

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

func (*EnqueueRequestForObjectNamespace) Generic

func (e *EnqueueRequestForObjectNamespace) Generic(event event.GenericEvent, queue workqueue.RateLimitingInterface)

func (*EnqueueRequestForObjectNamespace) Update

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

type EnqueueStaticRequest

type EnqueueStaticRequest struct {
	Request reconcile.Request
}

func (EnqueueStaticRequest) Create

func (e EnqueueStaticRequest) Create(_ event.CreateEvent, queue workqueue.RateLimitingInterface)

func (EnqueueStaticRequest) Delete

func (e EnqueueStaticRequest) Delete(event event.DeleteEvent, queue workqueue.RateLimitingInterface)

func (EnqueueStaticRequest) Generic

func (e EnqueueStaticRequest) Generic(event event.GenericEvent, queue workqueue.RateLimitingInterface)

func (EnqueueStaticRequest) Update

func (e EnqueueStaticRequest) Update(event event.UpdateEvent, queue workqueue.RateLimitingInterface)

type RequestSet

type RequestSet map[reconcile.Request]struct{}

func NewRequestSet

func NewRequestSet(items ...reconcile.Request) RequestSet

func (RequestSet) Insert

func (s RequestSet) Insert(items ...reconcile.Request) RequestSet

func (RequestSet) UnsortedList

func (s RequestSet) UnsortedList() []reconcile.Request