resources

Documentation

Index

• func BrokerChannelName(brokerName, channelType string) string
• func NewChannel(channelType string, owner kmeta.OwnerRefable, ...) (*unstructured.Unstructured, error)
• func NewSubscription(t *eventingv1.Trigger, brokerTrigger, brokerRef *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 NewChannel

func NewChannel(channelType string, owner kmeta.OwnerRefable, channelTemplate *messagingv1.ChannelTemplateSpec, l map[string]string) (*unstructured.Unstructured, error)

test NewChannel returns an unstructured.Unstructured based on the ChannelTemplateSpec for a given Broker.

func NewSubscription

func NewSubscription(t *eventingv1.Trigger, brokerTrigger, brokerRef *corev1.ObjectReference, uri *apis.URL, delivery *eventingduckv1.DeliverySpec) *messagingv1.Subscription

NewSubscription returns a placeholder subscription for trigger 't', from brokerTrigger to 'uri' 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.