controllers

package
v1.4.1 Latest Latest
Warning

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

 Go to latest Published: Mar 9, 2022 License: MPL-2.0 Imports: 29 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"
)

names for each of the controllers

View Source 
const (
	KubernetesInternalDomainEnvVar = "MESSAGING_DOMAIN_NAME"
	OperatorNamespaceEnvVar        = "OPERATOR_NAMESPACE"
	EnableWebhooksEnvVar           = "ENABLE_WEBHOOKS"
)

names for environment variables

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
	KubernetesClusterDomain string
}

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) SetInternalDomainName added in v1.4.1 

func (r *BindingReconciler) SetInternalDomainName(clusterDomain string)

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
	KubernetesClusterDomain string
}

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) SetInternalDomainName added in v1.4.1 

func (r *ExchangeReconciler) SetInternalDomainName(domainName string)

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
	KubernetesClusterDomain string
}

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) SetInternalDomainName added in v1.4.1 

func (r *FederationReconciler) SetInternalDomainName(domainName string)

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
	KubernetesClusterDomain string
}

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) SetInternalDomainName added in v1.4.1 

func (r *PermissionReconciler) SetInternalDomainName(domainName string)

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
	KubernetesClusterDomain string
}

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) SetInternalDomainName added in v1.4.1 

func (r *PolicyReconciler) SetInternalDomainName(domainName string)

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
	KubernetesClusterDomain string
}

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) SetInternalDomainName added in v1.4.1 

func (r *QueueReconciler) SetInternalDomainName(domainName string)

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
	KubernetesClusterDomain string
}

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) SetInternalDomainName added in v1.4.1 

func (r *SchemaReplicationReconciler) SetInternalDomainName(domainName string)

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
	KubernetesClusterDomain string
}

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) SetInternalDomainName added in v1.4.1 

func (r *ShovelReconciler) SetInternalDomainName(domainName string)

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
	KubernetesInternalDomain string
}

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) SetInternalDomainName added in v1.4.1 

func (r *SuperStreamReconciler) SetInternalDomainName(domainName string)

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 TopologyController added in v1.4.1 

type TopologyController interface {
	Reconcile(context.Context, ctrl.Request) (ctrl.Result, error)
	SetupWithManager(mgr ctrl.Manager) error
	SetInternalDomainName(string)
}

type UserReconciler 

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

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) SetInternalDomainName added in v1.4.1 

func (r *UserReconciler) SetInternalDomainName(domainName string)

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
	KubernetesClusterDomain string
}

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) SetInternalDomainName added in v1.4.1 

func (r *VhostReconciler) SetInternalDomainName(domainName string)

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.