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 ExchangeName(b *eventingv1.Broker, DLX bool) 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 ExchangeName

func ExchangeName(b *eventingv1.Broker, DLX bool) string

ExchangeName constructs a name given a Broker and whether this is a DLX or not. Format is broker.Namespace/broker.Name for normal exchanges and broker.Namespace/broker.Name/DLX for DLX exchanges.

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 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
	RabbitMQURL *url.URL
	// 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
}

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