controllers

Documentation

Index

• Constants
• 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 PermissionReconciler
  • func (r *PermissionReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *PermissionReconciler) SetupWithManager(mgr ctrl.Manager) error
• type PolicyReconciler
  • func (r *PolicyReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *PolicyReconciler) 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 SchemaReplicationReconciler
  • func (r *SchemaReplicationReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *SchemaReplicationReconciler) 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

Constants

const (
	VhostControllerName             = "vhost-controller"
	QueueControllerName             = "queue-controller"
	ExchangeControllerName          = "exchange-controller"
	BindingControllerName           = "binding-controller"
	UserControllerName              = "user-controller"
	PolicyControllerName            = "policy-controller"
	PermissionControllerName        = "permission-controller"
	SchemaReplicationControllerName = "schema-replication-controller"
)

names for each of the controllers

Variables

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

return a custom error if status code is 404 used in all controllers when deleting objects from rabbitmq server

Types

type BindingReconciler

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

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
	RabbitmqClientFactory internal.RabbitMQClientFactory
}

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 PermissionReconciler

type PermissionReconciler struct {
	client.Client
	Log                   logr.Logger
	Scheme                *runtime.Scheme
	Recorder              record.EventRecorder
	RabbitmqClientFactory internal.RabbitMQClientFactory
}

PermissionReconciler reconciles a Permission object

func (*PermissionReconciler) Reconcile

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

func (*PermissionReconciler) SetupWithManager

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

type PolicyReconciler

type PolicyReconciler struct {
	client.Client
	Log                   logr.Logger
	Scheme                *runtime.Scheme
	Recorder              record.EventRecorder
	RabbitmqClientFactory internal.RabbitMQClientFactory
}

PolicyReconciler reconciles a Policy object

func (*PolicyReconciler) Reconcile

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

func (*PolicyReconciler) SetupWithManager

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

type QueueReconciler

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

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 SchemaReplicationReconciler

type SchemaReplicationReconciler struct {
	client.Client
	Log                   logr.Logger
	Scheme                *runtime.Scheme
	Recorder              record.EventRecorder
	RabbitmqClientFactory internal.RabbitMQClientFactory
}

SchemaReplicationReconciler reconciles a SchemaReplication object

func (*SchemaReplicationReconciler) Reconcile

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

func (*SchemaReplicationReconciler) SetupWithManager

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

type UserReconciler

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

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
	RabbitmqClientFactory internal.RabbitMQClientFactory
}

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