controllers

package
v0.8.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 28, 2021 License: MPL-2.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

View Source 
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

View Source 
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

Functions

This section is empty.

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 added in v0.2.0 

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

func (*BindingReconciler) SetupWithManager added in v0.2.0 

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 added in v0.2.0 

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

func (*ExchangeReconciler) SetupWithManager added in v0.2.0 

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 added in v0.5.0 

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

func (*PermissionReconciler) SetupWithManager added in v0.5.0 

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 added in v0.4.0 

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

func (*PolicyReconciler) SetupWithManager added in v0.4.0 

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 added in v0.2.0 

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

func (*QueueReconciler) SetupWithManager added in v0.2.0 

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 added in v0.6.0 

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

func (*SchemaReplicationReconciler) SetupWithManager added in v0.6.0 

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 added in v0.3.0 

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

func (*UserReconciler) SetupWithManager added in v0.3.0 

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 added in v0.3.0 

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

func (*VhostReconciler) SetupWithManager added in v0.3.0 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.