controllers

package
v1.3.0 Latest Latest
Warning

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

 Go to latest Published: Jan 26, 2022 License: MPL-2.0 Imports: 28 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"
	FederationControllerName          = "federation-controller"
	ShovelControllerName              = "shovel-controller"
	SuperStreamControllerName         = "super-stream-controller"
	SuperStreamConsumerControllerName = "super-stream-consumer-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 FederationReconciler 

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

FederationReconciler reconciles a Federation object

func (*FederationReconciler) Reconcile added in v0.9.0 

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

func (*FederationReconciler) SetupWithManager added in v0.9.0 

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

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

ShovelReconciler reconciles a Shovel object

func (*ShovelReconciler) Reconcile added in v0.9.0 

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

func (*ShovelReconciler) SetupWithManager added in v0.9.0 

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

type SuperStreamReconciler 

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

SuperStreamReconciler reconciles a RabbitMQ Super Stream, and any resources it comprises of

func (*SuperStreamReconciler) Reconcile 

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

func (*SuperStreamReconciler) SetReconcileSuccess 

func (r *SuperStreamReconciler) SetReconcileSuccess(ctx context.Context, superStream *topologyv1alpha1.SuperStream, condition topology.Condition) error

func (*SuperStreamReconciler) SetupWithManager 

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