Documentation
¶
Index ¶
- type QueueBindingEventHandler
- type QueueBindingReconciler
- func (r *QueueBindingReconciler) Create(e event.CreateEvent) bool
- func (r *QueueBindingReconciler) Delete(e event.DeleteEvent) bool
- func (r *QueueBindingReconciler) Generic(e event.GenericEvent) bool
- func (r *QueueBindingReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
- func (r *QueueBindingReconciler) SetupWithManager(mgr ctrl.Manager) error
- func (r *QueueBindingReconciler) Update(e event.UpdateEvent) bool
- type QueueReconciler
- func (r *QueueReconciler) Create(e event.CreateEvent) bool
- func (r *QueueReconciler) Delete(e event.DeleteEvent) bool
- func (r *QueueReconciler) Generic(e event.GenericEvent) bool
- func (r *QueueReconciler) HandleQueueBindingUpdateEvent(qb *moirai.QueueBinding)
- func (r *QueueReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
- func (r *QueueReconciler) SetupWithManager(mgr ctrl.Manager) error
- func (r *QueueReconciler) Update(e event.UpdateEvent) bool
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type QueueBindingEventHandler ¶
type QueueBindingEventHandler interface {
// HandleQueueBindingUpdateEvent handles the QueueBinding update events.
HandleQueueBindingUpdateEvent(*moirai.QueueBinding)
}
QueueBindingEventHandler is an interface that handles QueueBinding events.
type QueueBindingReconciler ¶
type QueueBindingReconciler struct {
client.Client
Scheme *runtime.Scheme
Log logr.Logger
Recorder record.EventRecorder
Handlers []QueueBindingEventHandler
}
QueueBindingReconciler reconciles a QueueBinding object
func NewQueueBindingReconciler ¶
func NewQueueBindingReconciler( client client.Client, scheme *runtime.Scheme, recorder record.EventRecorder, handlers ...QueueBindingEventHandler, ) *QueueBindingReconciler
NewQueueBindingReconciler returns a new QueueBindingReconciler.
func (*QueueBindingReconciler) Create ¶
func (r *QueueBindingReconciler) Create(e event.CreateEvent) bool
Create returns true if the Create event should be processed
func (*QueueBindingReconciler) Delete ¶
func (r *QueueBindingReconciler) Delete(e event.DeleteEvent) bool
Delete returns true if the Delete event should be processed
func (*QueueBindingReconciler) Generic ¶
func (r *QueueBindingReconciler) Generic(e event.GenericEvent) bool
Generic returns true if the Generic event should be processed
func (*QueueBindingReconciler) Reconcile ¶
func (r *QueueBindingReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.
func (*QueueBindingReconciler) SetupWithManager ¶
func (r *QueueBindingReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
func (*QueueBindingReconciler) Update ¶
func (r *QueueBindingReconciler) Update(e event.UpdateEvent) bool
Update returns true if the Update event should be processed
type QueueReconciler ¶
type QueueReconciler struct {
client.Client
Scheme *runtime.Scheme
Log logr.Logger
Recorder record.EventRecorder
// contains filtered or unexported fields
}
QueueReconciler reconciles a Queue object
func NewQueueReconciler ¶
func NewQueueReconciler( client client.Client, scheme *runtime.Scheme, recorder record.EventRecorder, ) *QueueReconciler
NewQueueReconciler returns a new QueueReconciler.
func (*QueueReconciler) Create ¶
func (r *QueueReconciler) Create(e event.CreateEvent) bool
Create returns true if the Create event should be processed
func (*QueueReconciler) Delete ¶
func (r *QueueReconciler) Delete(e event.DeleteEvent) bool
Delete returns true if the Delete event should be processed
func (*QueueReconciler) Generic ¶
func (r *QueueReconciler) Generic(e event.GenericEvent) bool
Generic returns true if the Generic event should be processed
func (*QueueReconciler) HandleQueueBindingUpdateEvent ¶
func (r *QueueReconciler) HandleQueueBindingUpdateEvent(qb *moirai.QueueBinding)
HandleQueueBindingUpdateEvent is a handler for QueueBinding update events.
func (*QueueReconciler) Reconcile ¶
Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.
func (*QueueReconciler) SetupWithManager ¶
func (r *QueueReconciler) SetupWithManager(mgr ctrl.Manager) error
SetupWithManager sets up the controller with the Manager.
func (*QueueReconciler) Update ¶
func (r *QueueReconciler) Update(e event.UpdateEvent) bool
Update returns true if the Update event should be processed
Source Files
Directories