resources

Documentation

Index

• Constants
• func BrokerChannelName(brokerName, channelType string) string
• func BrokerEventPolicyName(brokerName, channelName string) string
• func LabelsForBackingChannelsEventPolicy(broker *eventingv1.Broker) map[string]string
• func MakeEventPolicyForBackingChannel(b *eventingv1.Broker, backingChannel *eventingduckv1.Channelable) *eventingv1alpha1.EventPolicy
• func NewSubscription(ctx context.Context, t *eventingv1.Trigger, ...) *messagingv1.Subscription
• func SubscriptionLabels(ctx context.Context, t *eventingv1.Trigger) map[string]string

Constants

const (
	BackingChannelEventPolicyLabelPrefix = "eventing.knative.dev/"
	OIDCBrokerSub                        = "system:serviceaccount:knative-eventing:mt-broker-ingress-oidc"
)

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 BrokerEventPolicyName

func BrokerEventPolicyName(brokerName, channelName string) string

func LabelsForBackingChannelsEventPolicy

func LabelsForBackingChannelsEventPolicy(broker *eventingv1.Broker) map[string]string

func MakeEventPolicyForBackingChannel

func MakeEventPolicyForBackingChannel(b *eventingv1.Broker, backingChannel *eventingduckv1.Channelable) *eventingv1alpha1.EventPolicy

func NewSubscription

func NewSubscription(ctx context.Context, 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(ctx context.Context, t *eventingv1.Trigger) map[string]string

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