resources

Documentation

Index

• func DeclareExchange(args *ExchangeArgs) 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 *eventingv1beta1.Broker) *corev1.Service
• func MakeTriggerAuthentication(args *TriggerAuthenticationArgs) *kedav1alpha1.TriggerAuthentication
• type ExchangeArgs
• type IngressArgs
• type TriggerAuthenticationArgs

Functions

func DeclareExchange

func DeclareExchange(args *ExchangeArgs) 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 *eventingv1beta1.Broker) *corev1.Service

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

func MakeTriggerAuthentication

func MakeTriggerAuthentication(args *TriggerAuthenticationArgs) *kedav1alpha1.TriggerAuthentication

Types

type ExchangeArgs

type ExchangeArgs struct {
	Broker      *eventingv1beta1.Broker
	RabbitmqURL string
}

ExchangeArgs are the arguments to create a RabbitMQ Exchange.

type IngressArgs

type IngressArgs struct {
	Broker *eventingv1beta1.Broker
	Image  string
	//ServiceAccountName string
	RabbitMQSecretName string
	BrokerUrlSecretKey string
}

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

type TriggerAuthenticationArgs

type TriggerAuthenticationArgs struct {
	Broker     *eventingv1beta1.Broker
	SecretName string
	SecretKey  string
}