resources

func LabelsForSequenceChannelsEventPolicy ¶ added in v0.43.0

func LabelsForSequenceChannelsEventPolicy(sequenceName string) map[string]string

func MakeEventPolicyForSequenceChannel ¶ added in v0.43.0

func MakeEventPolicyForSequenceChannel(s *flowsv1.Sequence, channel *eventingduckv1.Channelable, subscription *messagingv1.Subscription) *eventingv1alpha1.EventPolicy

func MakeEventPolicyForSequenceInputChannel ¶ added in v0.43.0

func MakeEventPolicyForSequenceInputChannel(s *flowsv1.Sequence, inputChannel *eventingduckv1.Channelable, sequencePolicy *eventingv1alpha1.EventPolicy) *eventingv1alpha1.EventPolicy

MakeEventPolicyForSequenceInputChannel creates an EventPolicy for the input channel of a Sequence

func NewSubscription ¶

func NewSubscription(stepNumber int, s *v1.Sequence) *messagingv1.Subscription

func SequenceChannelName ¶

func SequenceChannelName(sequenceName string, step int) string

SequenceChannelName creates a name for the Channel fronting a specific step.

func SequenceEventPolicyName ¶ added in v0.43.0

func SequenceEventPolicyName(sequenceName, postfix string) string

func SequenceSubscriptionName ¶

func SequenceSubscriptionName(sequenceName string, step int) string