Documentation ¶
Index ¶
- type RequestForObjectByOwner
- 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
- 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
- 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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
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 (*RequestForObjectByOwner) Create ¶
func (e *RequestForObjectByOwner) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)
Create implements EventHandler.
func (*RequestForObjectByOwner) Delete ¶
func (e *RequestForObjectByOwner) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)
Delete implements EventHandler.
func (*RequestForObjectByOwner) Generic ¶
func (e *RequestForObjectByOwner) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)
Generic implements EventHandler.
func (*RequestForObjectByOwner) Update ¶
func (e *RequestForObjectByOwner) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)
Update implements EventHandler.
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 (*RequestForObjectGroupKind) Create ¶
func (e *RequestForObjectGroupKind) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)
Create implements EventHandler.
func (*RequestForObjectGroupKind) Delete ¶
func (e *RequestForObjectGroupKind) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)
Delete implements EventHandler.
func (*RequestForObjectGroupKind) Generic ¶
func (e *RequestForObjectGroupKind) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)
Generic implements EventHandler.
func (*RequestForObjectGroupKind) Update ¶
func (e *RequestForObjectGroupKind) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)
Update implements EventHandler.
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 (*RequestForOwnerGroupKind) Create ¶
func (e *RequestForOwnerGroupKind) Create(evt event.CreateEvent, q workqueue.RateLimitingInterface)
Create implements EventHandler.
func (*RequestForOwnerGroupKind) Delete ¶
func (e *RequestForOwnerGroupKind) Delete(evt event.DeleteEvent, q workqueue.RateLimitingInterface)
Delete implements EventHandler.
func (*RequestForOwnerGroupKind) Generic ¶
func (e *RequestForOwnerGroupKind) Generic(evt event.GenericEvent, q workqueue.RateLimitingInterface)
Generic implements EventHandler.
func (*RequestForOwnerGroupKind) InjectMapper ¶
func (e *RequestForOwnerGroupKind) InjectMapper(m meta.RESTMapper) error
InjectMapper is called by the Controller to provide the rest mapper used by the manager.
func (*RequestForOwnerGroupKind) InjectScheme ¶
func (e *RequestForOwnerGroupKind) InjectScheme(s *runtime.Scheme) error
InjectScheme is called by the Controller to provide a singleton scheme to the RequestForOwnerGroupKind.
func (*RequestForOwnerGroupKind) Update ¶
func (e *RequestForOwnerGroupKind) Update(evt event.UpdateEvent, q workqueue.RateLimitingInterface)
Update implements EventHandler.