units

Documentation

Index

• func AutoRegister()
• func NewIfUnit() flow.IfUnit
• func NewWhileUnit() flow.WhileUnit
• type HttpUnit
  • func NewHttpUnit() HttpUnit
  • func (t *HttpUnit) Execute(ctx context.Context, state core.ContextMap, self *core.Node) (*core.ExecutionResult, error)
  • func (t *HttpUnit) GetUnitMeta() *core.Unit
  • func (t *HttpUnit) GetUnitName() string
• type LogicUnit
  • func NewLogUnit() LogicUnit
  • func (t *LogicUnit) Execute(ctx *flow.PipelineContext, i *flow.Input) (*flow.Output, error)
  • func (t *LogicUnit) GetUnitName() string
• type RemarkUnit
  • func NewRemarkUnit() RemarkUnit
  • func (t *RemarkUnit) Execute(ctx *flow.PipelineContext, i *flow.Input) (*flow.Output, error)
  • func (t *RemarkUnit) GetUnitName() string
• type ScriptUnit
  • func NewScriptUnit(script string) ScriptUnit
  • func (t *ScriptUnit) Execute(ctx *flow.PipelineContext, input *flow.Input) (*flow.Output, error)
  • func (t *ScriptUnit) GetUnitName() string
• type SetEnvUnit
  • func NewSetEnvUnit() SetEnvUnit
  • func (t *SetEnvUnit) Execute(ctx *flow.PipelineContext, i *flow.Input) (*flow.Output, error)
  • func (t *SetEnvUnit) GetUnitName() string
• type TerminalUnit
  • func NewTerminalUnit() TerminalUnit
  • func (t *TerminalUnit) Execute(ctx *flow.PipelineContext, i *flow.Input) (*flow.Output, error)
  • func (t *TerminalUnit) GetUnitName() string
• type TimeoutUnit
  • func NewTimeoutUnit() TimeoutUnit
  • func (t *TimeoutUnit) Execute(ctx *flow.PipelineContext, i *flow.Input) (*flow.Output, error)
  • func (t *TimeoutUnit) GetUnitName() string

Functions

func AutoRegister

func AutoRegister()

func NewIfUnit

func NewIfUnit() flow.IfUnit

func NewWhileUnit

func NewWhileUnit() flow.WhileUnit

Types

type HttpUnit

type HttpUnit struct {
	core.Unit
}

func NewHttpUnit

func NewHttpUnit() HttpUnit

func (*HttpUnit) Execute

func (t *HttpUnit) Execute(ctx context.Context, state core.ContextMap, self *core.Node) (*core.ExecutionResult, error)

func (*HttpUnit) GetUnitMeta

func (t *HttpUnit) GetUnitMeta() *core.Unit

func (*HttpUnit) GetUnitName

func (t *HttpUnit) GetUnitName() string

type LogicUnit

type LogicUnit struct {
	flow.BaseUnit
}

func NewLogUnit

func NewLogUnit() LogicUnit

func (*LogicUnit) Execute

func (t *LogicUnit) Execute(ctx *flow.PipelineContext, i *flow.Input) (*flow.Output, error)

func (*LogicUnit) GetUnitName

func (t *LogicUnit) GetUnitName() string

type RemarkUnit

type RemarkUnit struct {
	flow.BaseUnit
}

func NewRemarkUnit

func NewRemarkUnit() RemarkUnit

func (*RemarkUnit) Execute

func (t *RemarkUnit) Execute(ctx *flow.PipelineContext, i *flow.Input) (*flow.Output, error)

func (*RemarkUnit) GetUnitName

func (t *RemarkUnit) GetUnitName() string

type ScriptUnit

type ScriptUnit struct {
	flow.BaseUnit
	Script string `json:"script"` // JavaScript 脚本代码
}

ScriptUnit ===== ScriptUnit 动态 JS 执行单元 =====

func NewScriptUnit

func NewScriptUnit(script string) ScriptUnit

func (*ScriptUnit) Execute

func (t *ScriptUnit) Execute(ctx *flow.PipelineContext, input *flow.Input) (*flow.Output, error)

func (*ScriptUnit) GetUnitName

func (t *ScriptUnit) GetUnitName() string

type SetEnvUnit

type SetEnvUnit struct {
	flow.BaseUnit
}

func NewSetEnvUnit

func NewSetEnvUnit() SetEnvUnit

func (*SetEnvUnit) Execute

func (t *SetEnvUnit) Execute(ctx *flow.PipelineContext, i *flow.Input) (*flow.Output, error)

func (*SetEnvUnit) GetUnitName

func (t *SetEnvUnit) GetUnitName() string

type TerminalUnit

type TerminalUnit struct {
	flow.BaseUnit
}

func NewTerminalUnit

func NewTerminalUnit() TerminalUnit

func (*TerminalUnit) Execute

func (t *TerminalUnit) Execute(ctx *flow.PipelineContext, i *flow.Input) (*flow.Output, error)

func (*TerminalUnit) GetUnitName

func (t *TerminalUnit) GetUnitName() string

type TimeoutUnit

type TimeoutUnit struct {
	flow.BaseUnit
}

func NewTimeoutUnit

func NewTimeoutUnit() TimeoutUnit

func (*TimeoutUnit) Execute

func (t *TimeoutUnit) Execute(ctx *flow.PipelineContext, i *flow.Input) (*flow.Output, error)

func (*TimeoutUnit) GetUnitName

func (t *TimeoutUnit) GetUnitName() string