flow

Documentation

Index

• type CancellationTrace
  • func (t CancellationTrace) TraceInterface()
• type CeaseFlowTrace
  • func (t CeaseFlowTrace) TraceInterface()
• type CompletionTrace
  • func (t CompletionTrace) TraceInterface()
• type Flow
  • func New(definitions *schema.Definitions, current flow_node.IFlowNode, ...) *Flow
  • func (flow *Flow) Id() id.Id
  • func (flow *Flow) SequenceFlow() *sequence_flow.SequenceFlow
  • func (flow *Flow) SetTerminate(terminate flow_node.Terminate)
  • func (flow *Flow) Start(ctx context.Context)
• type NewFlowTrace
  • func (t NewFlowTrace) TraceInterface()
• type Retry
  • func (r *Retry) IsContinue() bool
  • func (r *Retry) Reset(retries int32)
  • func (r *Retry) Step()
• type Snapshot
  • func (s *Snapshot) Id() id.Id
  • func (s *Snapshot) SequenceFlow() *sequence_flow.SequenceFlow
• type TerminationTrace
  • func (t TerminationTrace) TraceInterface()
• type Trace
  • func (t Trace) TraceInterface()
• type VisitTrace
  • func (t VisitTrace) TraceInterface()

Types

type CancellationTrace

type CancellationTrace struct {
	FlowId id.Id
}

func (CancellationTrace) TraceInterface

func (t CancellationTrace) TraceInterface()

type CeaseFlowTrace

type CeaseFlowTrace struct{}

func (CeaseFlowTrace) TraceInterface

func (t CeaseFlowTrace) TraceInterface()

type CompletionTrace

type CompletionTrace struct {
	Node schema.FlowNodeInterface
}

func (CompletionTrace) TraceInterface

func (t CompletionTrace) TraceInterface()

type Flow

type Flow struct {
	// contains filtered or unexported fields
}

Flow Represents a flow

func New

func New(definitions *schema.Definitions,
	current flow_node.IFlowNode, tracer tracing.ITracer,
	flowNodeMapping *flow_node.FlowNodeMapping, flowWaitGroup *sync.WaitGroup,
	idGenerator id.IGenerator, actionTransformer flow_node.ActionTransformer,
	locator data.IFlowDataLocator,
) *Flow

New creates a new flow from a flow node

The flow does nothing until it is explicitly started.

func (*Flow) Id

func (flow *Flow) Id() id.Id

func (*Flow) SequenceFlow

func (flow *Flow) SequenceFlow() *sequence_flow.SequenceFlow

func (*Flow) SetTerminate

func (flow *Flow) SetTerminate(terminate flow_node.Terminate)

func (*Flow) Start

func (flow *Flow) Start(ctx context.Context)

Start starts the flow

type NewFlowTrace

type NewFlowTrace struct {
	FlowId id.Id
}

func (NewFlowTrace) TraceInterface

func (t NewFlowTrace) TraceInterface()

type Retry

type Retry struct {
	// contains filtered or unexported fields
}

Retry describes the retry handler for Flow

func (*Retry) IsContinue

func (r *Retry) IsContinue() bool

func (*Retry) Reset

func (r *Retry) Reset(retries int32)

func (*Retry) Step

func (r *Retry) Step()

Step Attempts += 1

type Snapshot

type Snapshot struct {
	// contains filtered or unexported fields
}

func (*Snapshot) Id

func (s *Snapshot) Id() id.Id

func (*Snapshot) SequenceFlow

func (s *Snapshot) SequenceFlow() *sequence_flow.SequenceFlow

type TerminationTrace

type TerminationTrace struct {
	FlowId id.Id
	Source schema.FlowNodeInterface
}

func (TerminationTrace) TraceInterface

func (t TerminationTrace) TraceInterface()

type Trace

type Trace struct {
	Source schema.FlowNodeInterface
	Flows  []Snapshot
}

func (Trace) TraceInterface

func (t Trace) TraceInterface()

type VisitTrace

type VisitTrace struct {
	Node schema.FlowNodeInterface
}

func (VisitTrace) TraceInterface

func (t VisitTrace) TraceInterface()