resources

Documentation

Index

• Constants
• func DeclareExchange(dialerFunc dialer.DialerFunc, args *ExchangeArgs) (*corev1.Secret, error)
• func DeleteExchange(args *ExchangeArgs) error
• func DispatcherLabels(brokerName string) map[string]string
• func DispatcherName(brokerName string) string
• func IngressLabels(brokerName string) map[string]string
• func MakeDispatcherDeployment(args *DispatcherArgs) *appsv1.Deployment
• func MakeIngressDeployment(args *IngressArgs) *appsv1.Deployment
• func MakeIngressService(b *eventingv1.Broker) *corev1.Service
• func MakeSecret(args *ExchangeArgs) *corev1.Secret
• func SecretLabels(brokerName string) map[string]string
• func SecretName(brokerName string) string
• type DispatcherArgs
• type ExchangeArgs
• type IngressArgs

Constants

const (
	BrokerURLSecretKey = "brokerURL"
)

Functions

func DeclareExchange

func DeclareExchange(dialerFunc dialer.DialerFunc, args *ExchangeArgs) (*corev1.Secret, error)

DeclareExchange declares the Exchange for a Broker.

func DeleteExchange

func DeleteExchange(args *ExchangeArgs) error

DeleteExchange deletes the Exchange for a Broker.

func DispatcherLabels

func DispatcherLabels(brokerName string) map[string]string

DispatcherLabels generates the labels present on all resources representing the dispatcher of the given Broker.

func DispatcherName

func DispatcherName(brokerName string) string

func IngressLabels

func IngressLabels(brokerName string) map[string]string

IngressLabels generates the labels present on all resources representing the ingress of the given Broker.

func MakeDispatcherDeployment

func MakeDispatcherDeployment(args *DispatcherArgs) *appsv1.Deployment

MakeDispatcherDeployment creates the in-memory representation of the Broker's Dispatcher Deployment.

func MakeIngressDeployment

func MakeIngressDeployment(args *IngressArgs) *appsv1.Deployment

MakeIngressDeployment creates the in-memory representation of the Broker's ingress Deployment.

func MakeIngressService

func MakeIngressService(b *eventingv1.Broker) *corev1.Service

MakeIngressService creates the in-memory representation of the Broker's ingress Service.

func MakeSecret

func MakeSecret(args *ExchangeArgs) *corev1.Secret

MakeSecret creates the secret for Broker deployments for Rabbit Broker.

func SecretLabels

func SecretLabels(brokerName string) map[string]string

SecretLabels generates the labels present on all resources representing the secret of the given Broker.

func SecretName

func SecretName(brokerName string) string

Types

type DispatcherArgs

type DispatcherArgs struct {
	Broker             *eventingv1.Broker
	Image              string
	RabbitMQHost       string
	RabbitMQSecretName string
	QueueName          string
	BrokerUrlSecretKey string
	BrokerIngressURL   *apis.URL
	Subscriber         *apis.URL
	Configs            reconcilersource.ConfigAccessor
}

DispatcherArgs are the arguments to create a Broker's Dispatcher Deployment that handles DeadLetterSink deliveries.

type ExchangeArgs

type ExchangeArgs struct {
	Broker          *eventingv1.Broker
	Trigger         *eventingv1.Trigger
	RabbitMQURL     *url.URL
	RabbitMQCluster string
	// Set to true to create a DLX, which basically just means we're going
	// to create it with a /DLX as the prepended name.
	DLX bool
}

ExchangeArgs are the arguments to create a RabbitMQ Exchange.

type IngressArgs

type IngressArgs struct {
	Broker *eventingv1.Broker
	Image  string
	//ServiceAccountName string
	RabbitMQSecretName string
	BrokerUrlSecretKey string
	Configs            reconcilersource.ConfigAccessor
}

IngressArgs are the arguments to create a Broker's ingress Deployment.