units

Mar 3, 2026

Changes in this version

+ type BreakUnit struct

+ func (u *BreakUnit) Execute(ctx context.Context, state core.ContextMap, self *core.Node) (*core.ExecutionResult, error)

+ func (u *BreakUnit) GetUnitMeta() *core.Unit

+ func (u *BreakUnit) GetUnitName() string

+ type ContinueUnit struct

+ func (u *ContinueUnit) Execute(ctx context.Context, state core.ContextMap, self *core.Node) (*core.ExecutionResult, error)

+ func (u *ContinueUnit) GetUnitMeta() *core.Unit

+ func (u *ContinueUnit) GetUnitName() string

+ type GotoUnit struct

+ func (u *GotoUnit) Execute(ctx context.Context, state core.ContextMap, self *core.Node) (*core.ExecutionResult, error)

+ func (u *GotoUnit) GetUnitMeta() *core.Unit

+ func (u *GotoUnit) GetUnitName() string

type LogicUnit

+ func (t *LogicUnit) GetUnitMeta() *core.Unit

+ type ReadableUnit struct

+ func NewReadableUnit() ReadableUnit

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

+ func (t *ReadableUnit) GetUnitMeta() *core.Unit

+ func (t *ReadableUnit) GetUnitName() string

type RemarkUnit

+ func (t *RemarkUnit) GetUnitMeta() *core.Unit

type ScriptUnit

+ func (t *ScriptUnit) GetUnitMeta() *core.Unit

type SetEnvUnit

+ func (t *SetEnvUnit) GetUnitMeta() *core.Unit

type TerminalUnit

+ func (t *TerminalUnit) GetUnitMeta() *core.Unit

type TimeoutUnit

+ func (t *TimeoutUnit) GetUnitMeta() *core.Unit

+ type WhileUnit struct

+ func (u *WhileUnit) Execute(ctx context.Context, state core.ContextMap, self *core.Node) (*core.ExecutionResult, error)

+ func (u *WhileUnit) GetUnitMeta() *core.Unit

+ func (u *WhileUnit) GetUnitName() string

Aug 16, 2025

Changes in this version

+ func AutoRegister()

+ func NewIfUnit() flow.IfUnit

+ func NewWhileUnit() flow.WhileUnit

+ type HttpUnit struct

+ 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 struct

+ func NewLogUnit() LogicUnit

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

+ func (t *LogicUnit) GetUnitName() string

+ type RemarkUnit struct

+ func NewRemarkUnit() RemarkUnit

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

+ func (t *RemarkUnit) GetUnitName() string

+ type ScriptUnit struct

+ Script string

+ 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 struct

+ func NewSetEnvUnit() SetEnvUnit

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

+ func (t *SetEnvUnit) GetUnitName() string

+ type TerminalUnit struct

+ func NewTerminalUnit() TerminalUnit

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

+ func (t *TerminalUnit) GetUnitName() string

+ type TimeoutUnit struct

+ func NewTimeoutUnit() TimeoutUnit

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

+ func (t *TimeoutUnit) GetUnitName() string