flow

Documentation

Index

• func FindReplacePassedInput(key interface{}, dataset map[string]interface{}) (bool, interface{}, error)
• func ReplaceStepIdAll(step FlowStep, old, new string)
• func SwitchFlowStep(flowstep FlowStep, in map[string]interface{}) error
• type CommandStep
  • func (cs *CommandStep) GetId() string
  • func (cs *CommandStep) GetOutputs() interface{}
  • func (cs *CommandStep) SetId(id string)
• type Flow
  • func (f *Flow) UnmarshalJSON(b []byte) error
• type FlowStep
  • func CopyStep(step FlowStep) FlowStep
• type FlowStepInput
  • func (f *FlowStepInput) FindReplaceDeferredInputsFrom(in map[string]interface{}) error
  • func (f *FlowStepInput) FindReplacePassedInputsFrom(in map[string]interface{}) error
  • func (f *FlowStepInput) GetInputs() map[string]interface{}
• type IfStep
  • func (is *IfStep) GetId() string
  • func (is *IfStep) GetOutputs() interface{}
  • func (is *IfStep) SetId(id string)
• type IterationStep
  • func (is *IterationStep) GetId() string
  • func (is *IterationStep) GetOutputs() interface{}
  • func (is *IterationStep) SetId(id string)
• type PrintSpec
• type PrintStep
  • func (ps *PrintStep) GetId() string
  • func (ps *PrintStep) GetOutputs() interface{}
  • func (ps *PrintStep) SetId(id string)

Functions

func FindReplacePassedInput

func FindReplacePassedInput(key interface{}, dataset map[string]interface{}) (bool, interface{}, error)

func ReplaceStepIdAll

func ReplaceStepIdAll(step FlowStep, old, new string)

func SwitchFlowStep

func SwitchFlowStep(flowstep FlowStep, in map[string]interface{}) error

Types

type CommandStep

type CommandStep struct {
	Id      string        `json:"$id"`
	Command string        `json:"$command"`
	Inputs  FlowStepInput `json:"inputs"`
	Outputs interface{}   `json:"outputs,omitempty"`
	Error   error         `json:"error,omitempty"`
}

func (*CommandStep) GetId

func (cs *CommandStep) GetId() string

func (*CommandStep) GetOutputs

func (cs *CommandStep) GetOutputs() interface{}

func (*CommandStep) SetId

func (cs *CommandStep) SetId(id string)

type Flow

type Flow []FlowStep

func (*Flow) UnmarshalJSON

func (f *Flow) UnmarshalJSON(b []byte) error

type FlowStep

type FlowStep interface {
	GetId() string
	SetId(id string)

	GetOutputs() interface{}
	// contains filtered or unexported methods
}

func CopyStep

func CopyStep(step FlowStep) FlowStep

type FlowStepInput

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

func (*FlowStepInput) FindReplaceDeferredInputsFrom

func (f *FlowStepInput) FindReplaceDeferredInputsFrom(in map[string]interface{}) error

func (*FlowStepInput) FindReplacePassedInputsFrom

func (f *FlowStepInput) FindReplacePassedInputsFrom(in map[string]interface{}) error

func (*FlowStepInput) GetInputs

func (f *FlowStepInput) GetInputs() map[string]interface{}

type IfStep

type IfStep struct {
	Id        string      `json:"$id"`
	Condition string      `json:"$condition"`
	Then      []FlowStep  `json:"$then"`
	Else      []FlowStep  `json:"$else"`
	Outputs   interface{} `json:"outputs,omitempty"`
}

func (*IfStep) GetId

func (is *IfStep) GetId() string

func (*IfStep) GetOutputs

func (is *IfStep) GetOutputs() interface{}

func (*IfStep) SetId

func (is *IfStep) SetId(id string)

type IterationStep

type IterationStep struct {
	Id           string      `json:"$id"`
	Range        interface{} `json:"$range"`
	Steps        []FlowStep  `json:"$steps"`
	Outputs      interface{} `json:"outputs,omitempty"`
	Error        error       `json:"error,omitempty"`
	ParentStepId string
}

func (*IterationStep) GetId

func (is *IterationStep) GetId() string

func (*IterationStep) GetOutputs

func (is *IterationStep) GetOutputs() interface{}

func (*IterationStep) SetId

func (is *IterationStep) SetId(id string)

type PrintSpec

type PrintSpec struct {
	Hide interface{} `json:"hide"`
}

type PrintStep

type PrintStep struct {
	Id       string    `json:"$id"`
	Print    PrintSpec `json:"$print"`
	FlowSpec []byte
	Outputs  interface{} `json:"outputs,omitempty"`
	Error    error       `json:"error,omitempty"`
}

func (*PrintStep) GetId

func (ps *PrintStep) GetId() string

func (*PrintStep) GetOutputs

func (ps *PrintStep) GetOutputs() interface{}

func (*PrintStep) SetId

func (ps *PrintStep) SetId(id string)