resources

Documentation

Index

• Constants
• func DispatcherLabels(brokerName string) map[string]string
• func DispatcherName(brokerName string) string
• func ExchangeLabels(b *eventingv1.Broker, t *eventingv1.Trigger) map[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 NewExchange(ctx context.Context, args *ExchangeArgs) *rabbitv1beta1.Exchange
• func SecretLabels(brokerName string) map[string]string
• func SecretName(brokerName string) string
• type DispatcherArgs
• type ExchangeArgs
• type IngressArgs

Constants

const (
	BrokerURLSecretKey = "brokerURL"
)

Functions

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 ExchangeLabels

func ExchangeLabels(b *eventingv1.Broker, t *eventingv1.Trigger) map[string]string

ExchangeLabels generates the labels present on the Exchange linking the Broker to the Exchange.

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

MakeIngress 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 NewExchange

func NewExchange(ctx context.Context, args *ExchangeArgs) *rabbitv1beta1.Exchange

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
	//ServiceAccountName string
	RabbitMQHost       string
	RabbitMQSecretName string
	QueueName          string
	BrokerUrlSecretKey string
	BrokerIngressURL   *apis.URL
	Subscriber         *apis.URL
}

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 at the end..
	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
}

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