Documentation ¶
Index ¶
- Constants
- Variables
- type ChangeHandlerClient
- type MandatoryTemplateChangeHandler
- type RestrictedEnqueueRequestForOwner
- func (e *RestrictedEnqueueRequestForOwner) Create(_ context.Context, evt event.CreateEvent, q workqueue.RateLimitingInterface)
- func (e *RestrictedEnqueueRequestForOwner) Delete(_ context.Context, evt event.DeleteEvent, q workqueue.RateLimitingInterface)
- func (e *RestrictedEnqueueRequestForOwner) Generic(_ context.Context, evt event.GenericEvent, q workqueue.RateLimitingInterface)
- func (e *RestrictedEnqueueRequestForOwner) InjectMapper(m meta.RESTMapper) error
- func (e *RestrictedEnqueueRequestForOwner) InjectScheme(s *machineryruntime.Scheme) error
- func (e *RestrictedEnqueueRequestForOwner) Update(_ context.Context, evt event.UpdateEvent, q workqueue.RateLimitingInterface)
- type TemplateChangeHandler
Constants ¶
const ( Status = "status" State = "state" )
Variables ¶
var ( ErrNoUniqueKind = errors.New("multiple kind candidates are invalid") ErrStateInvalid = errors.New("state from component object could not be interpreted") )
Functions ¶
This section is empty.
Types ¶
type ChangeHandlerClient ¶
type ChangeHandlerClient interface { client.Reader record.EventRecorder }
type MandatoryTemplateChangeHandler ¶
type MandatoryTemplateChangeHandler struct { client.Reader record.EventRecorder }
func NewMandatoryTemplateChangeHandler ¶
func NewMandatoryTemplateChangeHandler(handlerClient ChangeHandlerClient) *MandatoryTemplateChangeHandler
func (*MandatoryTemplateChangeHandler) Watch ¶
func (h *MandatoryTemplateChangeHandler) Watch() handler.MapFunc
type RestrictedEnqueueRequestForOwner ¶
type RestrictedEnqueueRequestForOwner struct { Log logr.Logger // OwnerType is the type of the Owner object to look for in OwnerReferences. Only Group and Kind are compared. OwnerType machineryruntime.Object // IsController if set will only look at the first OwnerReference with Controller: true. IsController bool // contains filtered or unexported fields }
EnqueueRequestForOwner 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.EnqueueRequestForOwner EventHandler with an OwnerType of ReplicaSet and IsController set to true.
func (*RestrictedEnqueueRequestForOwner) Create ¶
func (e *RestrictedEnqueueRequestForOwner) Create( _ context.Context, evt event.CreateEvent, q workqueue.RateLimitingInterface, )
Create implements EventHandler.
func (*RestrictedEnqueueRequestForOwner) Delete ¶
func (e *RestrictedEnqueueRequestForOwner) Delete( _ context.Context, evt event.DeleteEvent, q workqueue.RateLimitingInterface, )
Delete implements EventHandler.
func (*RestrictedEnqueueRequestForOwner) Generic ¶
func (e *RestrictedEnqueueRequestForOwner) Generic( _ context.Context, evt event.GenericEvent, q workqueue.RateLimitingInterface, )
Generic implements EventHandler.
func (*RestrictedEnqueueRequestForOwner) InjectMapper ¶
func (e *RestrictedEnqueueRequestForOwner) InjectMapper(m meta.RESTMapper) error
InjectMapper is called by the Controller to provide the rest mapper used by the manager.
func (*RestrictedEnqueueRequestForOwner) InjectScheme ¶
func (e *RestrictedEnqueueRequestForOwner) InjectScheme(s *machineryruntime.Scheme) error
InjectScheme is called by the Controller to provide a singleton scheme to the EnqueueRequestForOwner.
func (*RestrictedEnqueueRequestForOwner) Update ¶
func (e *RestrictedEnqueueRequestForOwner) Update( _ context.Context, evt event.UpdateEvent, q workqueue.RateLimitingInterface, )
Update implements EventHandler.
type TemplateChangeHandler ¶
type TemplateChangeHandler struct { client.Reader record.EventRecorder }
func NewTemplateChangeHandler ¶
func NewTemplateChangeHandler(handlerClient ChangeHandlerClient) *TemplateChangeHandler
func (*TemplateChangeHandler) Watch ¶
func (h *TemplateChangeHandler) Watch() handler.MapFunc