resources

Documentation

Index

• Constants
• func LabelsForParallelChannelsEventPolicy(parallelName string) map[string]string
• func MakeEventPolicyForParallelChannel(p *flowsv1.Parallel, channel *eventingduckv1.Channelable, ...) *eventingv1alpha1.EventPolicy
• func MakeEventPolicyForParallelIngressChannel(p *flowsv1.Parallel, ingressChannel *eventingduckv1.Channelable, ...) *eventingv1alpha1.EventPolicy
• func NewFilterSubscription(branchNumber int, p *v1.Parallel) *messagingv1.Subscription
• func NewSubscription(branchNumber int, p *v1.Parallel) *messagingv1.Subscription
• func ParallelBranchChannelName(parallelName string, branchNumber int) string
• func ParallelChannelName(parallelName string) string
• func ParallelEventPolicyName(parallelName, suffix string) string
• func ParallelFilterSubscriptionName(parallelName string, branchNumber int) string
• func ParallelSubscriptionName(parallelName string, branchNumber int) string

Constants

const (
	ParallelChannelEventPolicyLabelPrefix = "flows.knative.dev/"
)

Functions

func LabelsForParallelChannelsEventPolicy

func LabelsForParallelChannelsEventPolicy(parallelName string) map[string]string

func MakeEventPolicyForParallelChannel

func MakeEventPolicyForParallelChannel(p *flowsv1.Parallel, channel *eventingduckv1.Channelable, subscription *messagingv1.Subscription) *eventingv1alpha1.EventPolicy

func MakeEventPolicyForParallelIngressChannel

func MakeEventPolicyForParallelIngressChannel(p *flowsv1.Parallel, ingressChannel *eventingduckv1.Channelable, parallelPolicy *eventingv1alpha1.EventPolicy) *eventingv1alpha1.EventPolicy

MakeEventPolicyForParallelIngressChannel creates an EventPolicy for the ingress channel of a Parallel.

func NewFilterSubscription

func NewFilterSubscription(branchNumber int, p *v1.Parallel) *messagingv1.Subscription

func NewSubscription

func NewSubscription(branchNumber int, p *v1.Parallel) *messagingv1.Subscription

func ParallelBranchChannelName

func ParallelBranchChannelName(parallelName string, branchNumber int) string

ParallelBranchChannelName creates a name for the Channel fronting a specific branch

func ParallelChannelName

func ParallelChannelName(parallelName string) string

ParallelChannelName creates a name for the Channel fronting parallel.

func ParallelEventPolicyName

func ParallelEventPolicyName(parallelName, suffix string) string

ParallelEventPolicyName returns the name of the EventPolicy for the Parallel. suffix is either channel name or parent event policy name.

func ParallelFilterSubscriptionName

func ParallelFilterSubscriptionName(parallelName string, branchNumber int) string

func ParallelSubscriptionName

func ParallelSubscriptionName(parallelName string, branchNumber int) string