internal

Documentation

Index

• Variables
• func GenerateBindingInfo(binding *topology.Binding) (*rabbithole.BindingInfo, error)
• func GenerateExchangeSettings(e *topology.Exchange) (*rabbithole.ExchangeSettings, error)
• func GeneratePermissions(p *topology.Permission) rabbithole.Permissions
• func GeneratePolicy(p *topology.Policy) (*rabbithole.Policy, error)
• func GeneratePropertiesKey(binding *topology.Binding) string
• func GenerateQueueSettings(q *topology.Queue) (*rabbithole.QueueSettings, error)
• func GenerateUserSettings(credentials *corev1.Secret, tags []topology.UserTag) (rabbithole.UserSettings, error)
• func GenerateVhostSettings(v *topology.Vhost) *rabbithole.VhostSettings
• func RandomEncodedString(dataLen int) (string, error)
• type RabbitMQClient
• type RabbitMQClientFactory

Variables

var NoSuchRabbitmqClusterError = errors.New("RabbitmqCluster object does not exist")

Functions

func GenerateBindingInfo

func GenerateBindingInfo(binding *topology.Binding) (*rabbithole.BindingInfo, error)

func GenerateExchangeSettings

func GenerateExchangeSettings(e *topology.Exchange) (*rabbithole.ExchangeSettings, error)

func GeneratePermissions

func GeneratePermissions(p *topology.Permission) rabbithole.Permissions

func GeneratePolicy

func GeneratePolicy(p *topology.Policy) (*rabbithole.Policy, error)

func GeneratePropertiesKey

func GeneratePropertiesKey(binding *topology.Binding) string

func GenerateQueueSettings

func GenerateQueueSettings(q *topology.Queue) (*rabbithole.QueueSettings, error)

generates rabbithole.QueueSettings for a given Queue queue.Spec.Arguments (type k8s runtime.RawExtensions) is unmarshalled Unmarshall stores float64, for JSON numbers See: https://golang.org/pkg/encoding/json/#Unmarshal

func GenerateUserSettings

func GenerateUserSettings(credentials *corev1.Secret, tags []topology.UserTag) (rabbithole.UserSettings, error)

func GenerateVhostSettings

func GenerateVhostSettings(v *topology.Vhost) *rabbithole.VhostSettings

func RandomEncodedString

func RandomEncodedString(dataLen int) (string, error)

Types

type RabbitMQClient

type RabbitMQClient interface {
	PutUser(string, rabbithole.UserSettings) (*http.Response, error)
	DeleteUser(string) (*http.Response, error)
	DeclareBinding(string, rabbithole.BindingInfo) (*http.Response, error)
	DeleteBinding(string, rabbithole.BindingInfo) (*http.Response, error)
	ListQueueBindingsBetween(string, string, string) ([]rabbithole.BindingInfo, error)
	ListExchangeBindingsBetween(string, string, string) ([]rabbithole.BindingInfo, error)
	UpdatePermissionsIn(string, string, rabbithole.Permissions) (*http.Response, error)
	ClearPermissionsIn(string, string) (*http.Response, error)
	PutPolicy(string, string, rabbithole.Policy) (*http.Response, error)
	DeletePolicy(string, string) (*http.Response, error)
	DeclareQueue(string, string, rabbithole.QueueSettings) (*http.Response, error)
	DeleteQueue(string, string, ...rabbithole.QueueDeleteOptions) (*http.Response, error)
	DeclareExchange(string, string, rabbithole.ExchangeSettings) (*http.Response, error)
	DeleteExchange(string, string) (*http.Response, error)
	PutVhost(string, rabbithole.VhostSettings) (*http.Response, error)
	DeleteVhost(string) (*http.Response, error)
}

type RabbitMQClientFactory

type RabbitMQClientFactory func(ctx context.Context, c client.Client, rmq topology.RabbitmqClusterReference, namespace string) (RabbitMQClient, error)

var RabbitholeClientFactory RabbitMQClientFactory = func(ctx context.Context, c client.Client, rmq topology.RabbitmqClusterReference, namespace string) (RabbitMQClient, error) {
	return generateRabbitholeClient(ctx, c, rmq, namespace)
}