testing

Documentation

Index

• func NewFlowsParallel(name, namespace string, popt ...FlowsParallelOption) *flowsv1.Parallel
• func NewSequence(name, namespace string, popt ...SequenceOption) *flowsv1.Sequence
• func WithFlowsParallelDeleted(p *flowsv1.Parallel)
• func WithInitFlowsParallelConditions(p *flowsv1.Parallel)
• func WithInitSequenceConditions(p *flowsv1.Sequence)
• func WithSequenceDeleted(p *flowsv1.Sequence)
• type FlowsParallelOption
  • func WithFlowsParallelAddressableNotReady(reason, message string) FlowsParallelOption
  • func WithFlowsParallelBranchStatuses(branchStatuses []flowsv1.ParallelBranchStatus) FlowsParallelOption
  • func WithFlowsParallelBranches(branches []flowsv1.ParallelBranch) FlowsParallelOption
  • func WithFlowsParallelChannelTemplateSpec(cts *messagingv1.ChannelTemplateSpec) FlowsParallelOption
  • func WithFlowsParallelChannelsNotReady(reason, message string) FlowsParallelOption
  • func WithFlowsParallelGeneration(gen int64) FlowsParallelOption
  • func WithFlowsParallelIngressChannelStatus(status flowsv1.ParallelChannelStatus) FlowsParallelOption
  • func WithFlowsParallelReply(reply *duckv1.Destination) FlowsParallelOption
  • func WithFlowsParallelStatusObservedGeneration(gen int64) FlowsParallelOption
  • func WithFlowsParallelSubscriptionsNotReady(reason, message string) FlowsParallelOption
• type SequenceOption
  • func WithSequenceAddressableNotReady(reason, message string) SequenceOption
  • func WithSequenceChannelStatuses(channelStatuses []flowsv1.SequenceChannelStatus) SequenceOption
  • func WithSequenceChannelTemplateSpec(cts *messagingv1.ChannelTemplateSpec) SequenceOption
  • func WithSequenceChannelsNotReady(reason, message string) SequenceOption
  • func WithSequenceGeneration(gen int64) SequenceOption
  • func WithSequenceReply(reply *duckv1.Destination) SequenceOption
  • func WithSequenceStatusObservedGeneration(gen int64) SequenceOption
  • func WithSequenceSteps(steps []flowsv1.SequenceStep) SequenceOption
  • func WithSequenceSubscriptionStatuses(subscriptionStatuses []flowsv1.SequenceSubscriptionStatus) SequenceOption
  • func WithSequenceSubscriptionsNotReady(reason, message string) SequenceOption

Functions

func NewFlowsParallel

func NewFlowsParallel(name, namespace string, popt ...FlowsParallelOption) *flowsv1.Parallel

NewFlowsParallel creates an Parallel with ParallelOptions.

func NewSequence

func NewSequence(name, namespace string, popt ...SequenceOption) *flowsv1.Sequence

NewSequence creates an Sequence with SequenceOptions.

func WithFlowsParallelDeleted

func WithFlowsParallelDeleted(p *flowsv1.Parallel)

func WithInitFlowsParallelConditions

func WithInitFlowsParallelConditions(p *flowsv1.Parallel)

func WithInitSequenceConditions

func WithInitSequenceConditions(p *flowsv1.Sequence)

func WithSequenceDeleted

func WithSequenceDeleted(p *flowsv1.Sequence)

Types

type FlowsParallelOption

type FlowsParallelOption func(*flowsv1.Parallel)

ParallelOption enables further configuration of a Parallel.

func WithFlowsParallelAddressableNotReady

func WithFlowsParallelAddressableNotReady(reason, message string) FlowsParallelOption

func WithFlowsParallelBranchStatuses

func WithFlowsParallelBranchStatuses(branchStatuses []flowsv1.ParallelBranchStatus) FlowsParallelOption

func WithFlowsParallelBranches

func WithFlowsParallelBranches(branches []flowsv1.ParallelBranch) FlowsParallelOption

func WithFlowsParallelChannelTemplateSpec

func WithFlowsParallelChannelTemplateSpec(cts *messagingv1.ChannelTemplateSpec) FlowsParallelOption

func WithFlowsParallelChannelsNotReady

func WithFlowsParallelChannelsNotReady(reason, message string) FlowsParallelOption

func WithFlowsParallelGeneration

func WithFlowsParallelGeneration(gen int64) FlowsParallelOption

func WithFlowsParallelIngressChannelStatus

func WithFlowsParallelIngressChannelStatus(status flowsv1.ParallelChannelStatus) FlowsParallelOption

func WithFlowsParallelReply

func WithFlowsParallelReply(reply *duckv1.Destination) FlowsParallelOption

func WithFlowsParallelStatusObservedGeneration

func WithFlowsParallelStatusObservedGeneration(gen int64) FlowsParallelOption

func WithFlowsParallelSubscriptionsNotReady

func WithFlowsParallelSubscriptionsNotReady(reason, message string) FlowsParallelOption

type SequenceOption

type SequenceOption func(*flowsv1.Sequence)

SequenceOption enables further configuration of a Sequence.

func WithSequenceAddressableNotReady

func WithSequenceAddressableNotReady(reason, message string) SequenceOption

func WithSequenceChannelStatuses

func WithSequenceChannelStatuses(channelStatuses []flowsv1.SequenceChannelStatus) SequenceOption

func WithSequenceChannelTemplateSpec

func WithSequenceChannelTemplateSpec(cts *messagingv1.ChannelTemplateSpec) SequenceOption

func WithSequenceChannelsNotReady

func WithSequenceChannelsNotReady(reason, message string) SequenceOption

func WithSequenceGeneration

func WithSequenceGeneration(gen int64) SequenceOption

func WithSequenceReply

func WithSequenceReply(reply *duckv1.Destination) SequenceOption

func WithSequenceStatusObservedGeneration

func WithSequenceStatusObservedGeneration(gen int64) SequenceOption

func WithSequenceSteps

func WithSequenceSteps(steps []flowsv1.SequenceStep) SequenceOption

func WithSequenceSubscriptionStatuses

func WithSequenceSubscriptionStatuses(subscriptionStatuses []flowsv1.SequenceSubscriptionStatus) SequenceOption

func WithSequenceSubscriptionsNotReady

func WithSequenceSubscriptionsNotReady(reason, message string) SequenceOption