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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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 ¶
ExchangeName derives the Exchange name from the Broker name
func IngressLabels ¶
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 }
Click to show internal directories.
Click to hide internal directories.