Documentation
¶
Index ¶
- func BrokerExchangeName(b *eventingv1.Broker, dlx bool) string
- func CreateBrokerDeadLetterQueueName(b *eventingv1.Broker) string
- func CreateSourceRabbitName(s *v1alpha1.RabbitmqSource) string
- func CreateTriggerDeadLetterQueueName(t *eventingv1.Trigger) string
- func CreateTriggerQueueName(t *eventingv1.Trigger) string
- func CreateTriggerQueueRabbitName(t *eventingv1.Trigger, brokerUID string) string
- func TriggerDLXExchangeName(t *eventingv1.Trigger) string
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BrokerExchangeName ¶
func BrokerExchangeName(b *eventingv1.Broker, dlx bool) string
BrokerExchangeName creates a name for Broker Exchange. Format is broker.Namespace.Name.BrokerUID for normal exchanges and broker.Namespace.Name.dlx.BrokerUID for DLX exchanges.
func CreateBrokerDeadLetterQueueName ¶
func CreateBrokerDeadLetterQueueName(b *eventingv1.Broker) string
CreateBrokerDeadLetterQueueName constructs a Broker dead letter queue name. Format is b.Namespace.Name.dlq.BrokerUID
func CreateSourceRabbitName ¶ added in v0.31.0
func CreateSourceRabbitName(s *v1alpha1.RabbitmqSource) string
CreateSourceRabbitName creates queue, exchange, and binding crd names for a RabbitmqSource. Format is s.Namespace.ObjectName.SourceUID
func CreateTriggerDeadLetterQueueName ¶
func CreateTriggerDeadLetterQueueName(t *eventingv1.Trigger) string
CreateTriggerDeadLetterQueueName creates a dead letter queue name for Trigger if Trigger has defined a DeadLetterSink. Format is t.Namespace.Name.dlq.TriggerUID
func CreateTriggerQueueName ¶
func CreateTriggerQueueName(t *eventingv1.Trigger) string
CreateTriggerQueueName creates a queue (crd) name for Trigger events. Format is t.Namespace.Name.TriggerUID
func CreateTriggerQueueRabbitName ¶ added in v0.32.0
func CreateTriggerQueueRabbitName(t *eventingv1.Trigger, brokerUID string) string
CreateTriggerQueueRabbitName creates a RabbitMQ queue name for Trigger events. Format is Namespace.Name.BrokerUID Character limit for both namespace and trigger name are 63 and for broker UUID is 36. RabbitMQ queue name character limit is 255.
func TriggerDLXExchangeName ¶
func TriggerDLXExchangeName(t *eventingv1.Trigger) string
TriggerDLXExchangeName creates a DLX name that's used if Trigger has defined DeadLetterSink. Format is t.Namespace.Name.dlx.TriggerUID
Types ¶
This section is empty.
Source Files