Versions in this module Expand all Collapse all v0 v0.11.0 Dec 10, 2019 Changes in this version + func NewChannel(name string, p *v1alpha1.Parallel) (*unstructured.Unstructured, error) + func NewFilterSubscription(branchNumber int, p *v1alpha1.Parallel) *messagingv1alpha1.Subscription + func NewSubscription(branchNumber int, p *v1alpha1.Parallel) *messagingv1alpha1.Subscription + func ParallelBranchChannelName(parallelName string, branchNumber int) string + func ParallelChannelName(parallelName string) string + func ParallelFilterSubscriptionName(parallelName string, branchNumber int) string + func ParallelSubscriptionName(parallelName string, branchNumber int) string