controllers

Documentation

Index

• type QueueBindingEventHandler
• type QueueBindingReconciler
  • func NewQueueBindingReconciler(client client.Client, scheme *runtime.Scheme, recorder record.EventRecorder, ...) *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 NewQueueReconciler(client client.Client, scheme *runtime.Scheme, recorder record.EventRecorder) *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

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

func (r *QueueReconciler) 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 (*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