controllers

Documentation

Index

• Variables
• type BindingReconciler
  • func (r *BindingReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *BindingReconciler) SetupWithManager(mgr ctrl.Manager) error
• type ExchangeReconciler
  • func (r *ExchangeReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ExchangeReconciler) SetupWithManager(mgr ctrl.Manager) error
• type QueueReconciler
  • func (r *QueueReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *QueueReconciler) SetupWithManager(mgr ctrl.Manager) error
• type UserReconciler
  • func (r *UserReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *UserReconciler) SetupWithManager(mgr ctrl.Manager) error
• type VhostReconciler
  • func (r *VhostReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *VhostReconciler) SetupWithManager(mgr ctrl.Manager) error

Variables

var NotFound = errors.New("not found")

return a custom error if status code is 404 used in QueueReconciler.deleteQueue(), ExchangeReconcilier.deleteExchange() and UserReconciler.deleteUser()

Types

type BindingReconciler

type BindingReconciler struct {
	client.Client
	Log      logr.Logger
	Scheme   *runtime.Scheme
	Recorder record.EventRecorder
}

BindingReconciler reconciles a Binding object

func (*BindingReconciler) Reconcile

func (r *BindingReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*BindingReconciler) SetupWithManager

func (r *BindingReconciler) SetupWithManager(mgr ctrl.Manager) error

type ExchangeReconciler

type ExchangeReconciler struct {
	client.Client
	Log      logr.Logger
	Scheme   *runtime.Scheme
	Recorder record.EventRecorder
}

ExchangeReconciler reconciles a Exchange object

func (*ExchangeReconciler) Reconcile

func (r *ExchangeReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*ExchangeReconciler) SetupWithManager

func (r *ExchangeReconciler) SetupWithManager(mgr ctrl.Manager) error

type QueueReconciler

type QueueReconciler struct {
	client.Client
	Log      logr.Logger
	Scheme   *runtime.Scheme
	Recorder record.EventRecorder
}

QueueReconciler reconciles a RabbitMQ Queue

func (*QueueReconciler) Reconcile

func (r *QueueReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*QueueReconciler) SetupWithManager

func (r *QueueReconciler) SetupWithManager(mgr ctrl.Manager) error

type UserReconciler

type UserReconciler struct {
	client.Client
	Log      logr.Logger
	Scheme   *runtime.Scheme
	Recorder record.EventRecorder
}

UserReconciler reconciles a User object

func (*UserReconciler) Reconcile

func (r *UserReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*UserReconciler) SetupWithManager

func (r *UserReconciler) SetupWithManager(mgr ctrl.Manager) error

type VhostReconciler

type VhostReconciler struct {
	client.Client
	Log      logr.Logger
	Scheme   *runtime.Scheme
	Recorder record.EventRecorder
}

VhostReconciler reconciles a Vhost object

func (*VhostReconciler) Reconcile

func (r *VhostReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*VhostReconciler) SetupWithManager

func (r *VhostReconciler) SetupWithManager(mgr ctrl.Manager) error