flow

Documentation

Index

• func PlayParFlow(span *model.Span, f *model.Func, env Envelope) (Flow, []Flow, error)
• func PlaySeqFlow(span *model.Span, f *model.Func, env Envelope) (Flow, []Flow, error)
• type Edge
• type Envelope
• type Flow
• type GatherEdge
• type GatherFlow
• type StepPlayer

Functions

func PlayParFlow

func PlayParFlow(span *model.Span, f *model.Func, env Envelope) (Flow, []Flow, error)

func PlaySeqFlow

func PlaySeqFlow(span *model.Span, f *model.Func, env Envelope) (Flow, []Flow, error)

Types

type Edge

type Edge interface{}

Edge stands for data sent between the output of one step and the input of another during playing.

type Envelope

type Envelope interface {
	Enter(*model.Span) (Flow, error)                       // Enter returns the output of the Enter step of the enclosing function.
	Make(*model.Span, interface{}) (Flow, error)           // Make ...
	MakePkgFunc(*model.Span, string, string) (Flow, error) // MakePkgFunc ...
	MakeOp(*model.Span, []string) (Flow, error)            // MakeOp ...
}

type Flow

type Flow interface {
	Link(*model.Span, string, bool) (Flow, error)    // Link ...
	Select(*model.Span, []string) (Flow, error)      // Select ...
	Augment(*model.Span, []GatherFlow) (Flow, error) // Augment ...
	Invoke(*model.Span) (Flow, error)                // Invoke ...
	Leave(*model.Span) (Flow, error)                 // Leave ...
}

type GatherEdge

type GatherEdge struct {
	Field string
	Edge  Edge
}

type GatherFlow

type GatherFlow struct {
	Field string
	Flow  Flow
}

type StepPlayer

type StepPlayer interface {
	PlayStep(step *model.Step, gather []GatherEdge) (returns Edge, err error)
}