resources

Documentation

Index

• Constants
• func DeclareExchange(dialerFunc dialer.DialerFunc, args *ExchangeArgs) (*corev1.Secret, error)
• func DeleteExchange(args *ExchangeArgs) error
• func ExchangeName(brokerName string) string
• func IngressLabels(brokerName string) map[string]string
• 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 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 ExchangeName

func ExchangeName(brokerName string) string

ExchangeName derives the Exchange name from the Broker name

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 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 ExchangeArgs

type ExchangeArgs struct {
	Broker      *eventingv1.Broker
	RabbitMQURL *url.URL
}

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.