enqueue

type RequestForObjectByOwner ¶

type RequestForObjectByOwner struct {
	// NewGroupKind is the GroupKind of the object
	NewGroupKind   schema.GroupKind
	OwnerGroupKind schema.GroupKind
}

RequestForObjectByOwner enqueues a Request containing the Name and Namespace of the object that is the source of the Event. (e.g. the created / deleted / updated objects Name and Namespace). handler.RequestForObjectByOwner is used by almost all Controllers that have associated Resources (e.g. CRDs) to reconcile the associated Resource.

func (e *RequestForObjectByOwner) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)

func (e *RequestForObjectByOwner) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)

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

func (e *RequestForObjectByOwner) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)

type RequestForObjectGroupKind ¶

type RequestForObjectGroupKind struct {
	// NewGroupKind is the GroupKind of the object
	NewGroupKind schema.GroupKind
}

RequestForObjectGroupKind enqueues a Request containing the Name and Namespace of the object that is the source of the Event. (e.g. the created / deleted / updated objects Name and Namespace). handler.RequestForObjectGroupKind is used by almost all Controllers that have associated Resources (e.g. CRDs) to reconcile the associated Resource.

func (e *RequestForObjectGroupKind) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)

func (e *RequestForObjectGroupKind) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)

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

func (e *RequestForObjectGroupKind) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)

type RequestForOwnerGroupKind ¶

type RequestForOwnerGroupKind struct {
	// OwnerType is the type of the Owner object to look for in OwnerReferences.  Only Group and Kind are compared.
	OwnerType runtime.Object

	// IsController if set will only look at the first OwnerReference with Controller: true.
	IsController bool

	// NewGroupKind is the GroupKind of the object.
	NewGroupKind schema.GroupKind
	// contains filtered or unexported fields
}

RequestForOwnerGroupKind enqueues Requests for the Owners of an object. E.g. the object that created the object that was the source of the Event.

If a ReplicaSet creates Pods, users may reconcile the ReplicaSet in response to Pod Events using:

- a source.Kind Source with Type of Pod.

- a handler.RequestForOwnerGroupKind EventHandler with an OwnerType of ReplicaSet and IsController set to true.

func (e *RequestForOwnerGroupKind) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)

func (e *RequestForOwnerGroupKind) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)

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

func (e *RequestForOwnerGroupKind) InjectMapper(m meta.RESTMapper) error

func (e *RequestForOwnerGroupKind) InjectScheme(s *runtime.Scheme) error

func (e *RequestForOwnerGroupKind) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)