resources

Documentation

Index

• func BrokerChannelName(brokerName, channelType string) string
• func NewSubscription(t *eventingv1.Trigger, brokerTrigger *corev1.ObjectReference, ...) *messagingv1.Subscription
• func SubscriptionLabels(t *eventingv1.Trigger) map[string]string

Functions

func BrokerChannelName

func BrokerChannelName(brokerName, channelType string) string

BrokerChannelName creates a name for the Channel for a Broker for a given Channel type.

func NewSubscription

func NewSubscription(t *eventingv1.Trigger, brokerTrigger *corev1.ObjectReference, dest, reply *duckv1.Destination, delivery *eventingduckv1.DeliverySpec) *messagingv1.Subscription

NewSubscription returns a placeholder subscription for trigger 't', from brokerTrigger to 'dest' replying to brokerIngress.

func SubscriptionLabels

func SubscriptionLabels(t *eventingv1.Trigger) map[string]string

SubscriptionLabels generates the labels present on the Subscription linking this Trigger to the Broker's Channels.