controllers

package
v1.13.0 Latest Latest
Warning

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

 Go to latest Published: Jan 30, 2024 License: MPL-2.0 Imports: 31 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"
	OperatorPolicyControllerName    = "operator-policy-controller"
	PermissionControllerName        = "permission-controller"
	SchemaReplicationControllerName = "schema-replication-controller"
	FederationControllerName        = "federation-controller"
	ShovelControllerName            = "shovel-controller"
	SuperStreamControllerName       = "super-stream-controller"
	TopicPermissionControllerName   = "topic-permission-controller"
)

names for each of the controllers

View Source 
const (
	KubernetesInternalDomainEnvVar = "MESSAGING_DOMAIN_NAME"
	OperatorNamespaceEnvVar        = "OPERATOR_NAMESPACE"
	EnableWebhooksEnvVar           = "ENABLE_WEBHOOKS"
	ControllerSyncPeriodEnvVar     = "SYNC_PERIOD"
	ConnectUsingPlainHTTPEnvVar    = "CONNECT_USING_PLAIN_HTTP"
)

names for environment variables

View Source 
const SchemaReplicationParameterName = "schema_definition_sync_upstream"

Variables

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

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

Functions

This section is empty.

Types

type BindingReconciler 

type BindingReconciler struct{}

func (*BindingReconciler) DeclareFunc 

func (r *BindingReconciler) DeclareFunc(_ context.Context, client rabbitmqclient.Client, obj topology.TopologyResource) error

func (*BindingReconciler) DeleteFunc 

func (r *BindingReconciler) DeleteFunc(ctx context.Context, client rabbitmqclient.Client, obj topology.TopologyResource) error

DeleteFunc deletes binding from rabbitmq server; bindings have no name; server needs BindingInfo to delete them when server responds with '404' Not Found, it logs and does not requeue on error if no binding argument is set, generating properties key by using internal.GeneratePropertiesKey if binding arguments are set, list all bindings between source/destination to find the binding; if it failed to find corresponding binding, it assumes that the binding is already deleted and returns no error

type ExchangeReconciler 

type ExchangeReconciler struct{}

func (*ExchangeReconciler) DeclareFunc 

func (r *ExchangeReconciler) DeclareFunc(_ context.Context, client rabbitmqclient.Client, obj topology.TopologyResource) error

func (*ExchangeReconciler) DeleteFunc 

func (r *ExchangeReconciler) DeleteFunc(ctx context.Context, client rabbitmqclient.Client, obj topology.TopologyResource) error

DeleteFunc deletes exchange from rabbitmq server if server responds with '404' Not Found, it logs and does not requeue on error

type FederationReconciler 

type FederationReconciler struct {
	client.Client
}

func (*FederationReconciler) DeclareFunc 

func (r *FederationReconciler) DeclareFunc(ctx context.Context, client rabbitmqclient.Client, obj topology.TopologyResource) error

func (*FederationReconciler) DeleteFunc 

func (r *FederationReconciler) DeleteFunc(ctx context.Context, client rabbitmqclient.Client, obj topology.TopologyResource) error

DeleteFunc deletes federation from rabbitmq server if server responds with '404' Not Found, it logs and does not requeue on error

type OperatorPolicyReconciler added in v1.13.0 

type OperatorPolicyReconciler struct{}

func (*OperatorPolicyReconciler) DeclareFunc added in v1.13.0 

func (r *OperatorPolicyReconciler) DeclareFunc(_ context.Context, client rabbitmqclient.Client, obj topology.TopologyResource) error

DeclareFunc creates or updates a given operator policy using rabbithole client.PutOperatorPolicy

func (*OperatorPolicyReconciler) DeleteFunc added in v1.13.0 

func (r *OperatorPolicyReconciler) DeleteFunc(ctx context.Context, client rabbitmqclient.Client, obj topology.TopologyResource) error

DeleteFunc deletes operator policy from rabbitmq server if server responds with '404' Not Found, it logs and does not requeue on error

type PermissionReconciler 

type PermissionReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

func (*PermissionReconciler) DeclareFunc 

func (r *PermissionReconciler) DeclareFunc(ctx context.Context, client rabbitmqclient.Client, obj topology.TopologyResource) error

func (*PermissionReconciler) DeleteFunc 

func (r *PermissionReconciler) DeleteFunc(ctx context.Context, client rabbitmqclient.Client, obj topology.TopologyResource) error

type PolicyReconciler 

type PolicyReconciler struct{}

func (*PolicyReconciler) DeclareFunc 

func (r *PolicyReconciler) DeclareFunc(_ context.Context, client rabbitmqclient.Client, obj topology.TopologyResource) error

DeclareFunc creates or updates a given policy using rabbithole client.PutPolicy

func (*PolicyReconciler) DeleteFunc 

func (r *PolicyReconciler) DeleteFunc(ctx context.Context, client rabbitmqclient.Client, obj topology.TopologyResource) error

DeleteFunc deletes policy from rabbitmq server if server responds with '404' Not Found, it logs and does not requeue on error

type QueueReconciler 

type QueueReconciler struct{}

func (*QueueReconciler) DeclareFunc 

func (r *QueueReconciler) DeclareFunc(_ context.Context, client rabbitmqclient.Client, obj topology.TopologyResource) error

func (*QueueReconciler) DeleteFunc 

func (r *QueueReconciler) DeleteFunc(ctx context.Context, client rabbitmqclient.Client, obj topology.TopologyResource) error

DeleteFunc deletes queue from rabbitmq server if server responds with '404' Not Found, it logs and does not requeue on error queues could be deleted manually or gone because of AutoDelete

type ReconcileFunc 

type ReconcileFunc interface {
	DeclareFunc(ctx context.Context, client rabbitmqclient.Client, resource topology.TopologyResource) error
	DeleteFunc(ctx context.Context, client rabbitmqclient.Client, resource topology.TopologyResource) error
}

type SchemaReplicationReconciler 

type SchemaReplicationReconciler struct {
	client.Client
}

func (*SchemaReplicationReconciler) DeclareFunc 

func (r *SchemaReplicationReconciler) DeclareFunc(ctx context.Context, client rabbitmqclient.Client, obj topology.TopologyResource) error

func (*SchemaReplicationReconciler) DeleteFunc 

func (r *SchemaReplicationReconciler) DeleteFunc(ctx context.Context, client rabbitmqclient.Client, _ topology.TopologyResource) error

type ShovelReconciler 

type ShovelReconciler struct {
	client.Client
}

func (*ShovelReconciler) DeclareFunc 

func (r *ShovelReconciler) DeclareFunc(ctx context.Context, client rabbitmqclient.Client, obj topology.TopologyResource) error

func (*ShovelReconciler) DeleteFunc 

func (r *ShovelReconciler) DeleteFunc(ctx context.Context, client rabbitmqclient.Client, obj topology.TopologyResource) error

DeleteFunc deletes shovel configuration from rabbitmq server if server responds with '404' Not Found, it logs and does not requeue on error

type SuperStreamReconciler 

type SuperStreamReconciler struct {
	client.Client
	Log                     logr.Logger
	Scheme                  *runtime.Scheme
	Recorder                record.EventRecorder
	RabbitmqClientFactory   rabbitmqclient.Factory
	KubernetesClusterDomain 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) 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 TopicPermissionReconciler 

type TopicPermissionReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

func (*TopicPermissionReconciler) DeclareFunc 

func (r *TopicPermissionReconciler) DeclareFunc(ctx context.Context, client rabbitmqclient.Client, obj topology.TopologyResource) error

func (*TopicPermissionReconciler) DeleteFunc 

func (r *TopicPermissionReconciler) DeleteFunc(ctx context.Context, client rabbitmqclient.Client, obj topology.TopologyResource) error

type TopologyReconciler 

type TopologyReconciler struct {
	client.Client
	ReconcileFunc
	Type                    client.Object
	WatchTypes              []client.Object
	Log                     logr.Logger
	Scheme                  *runtime.Scheme
	Recorder                record.EventRecorder
	RabbitmqClientFactory   rabbitmqclient.Factory
	KubernetesClusterDomain string
	ConnectUsingPlainHTTP   bool
}

TopologyReconciler reconciles any topology rabbitmq objects

func (*TopologyReconciler) Reconcile 

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

func (*TopologyReconciler) SetupWithManager 

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

type UserReconciler 

type UserReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

func (*UserReconciler) DeclareFunc 

func (r *UserReconciler) DeclareFunc(ctx context.Context, client rabbitmqclient.Client, obj topology.TopologyResource) error

func (*UserReconciler) DeleteFunc 

func (r *UserReconciler) DeleteFunc(ctx context.Context, client rabbitmqclient.Client, obj topology.TopologyResource) error

type VhostReconciler 

type VhostReconciler struct {
	client.Client
}

func (*VhostReconciler) DeclareFunc 

func (r *VhostReconciler) DeclareFunc(_ context.Context, client rabbitmqclient.Client, obj topology.TopologyResource) error

func (*VhostReconciler) DeleteFunc 

func (r *VhostReconciler) DeleteFunc(ctx context.Context, client rabbitmqclient.Client, obj topology.TopologyResource) error

DeleteFunc deletes vhost from server if server responds with '404' Not Found, it logs and does not requeue on 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.