Documentation ¶
Index ¶
- type INPUT_TYPE
- type InputConfig
- type InputParam
- type PipeLine
- func (this *PipeLine) Add(flow lokas.ITaskPipeLine) lokas.ITaskPipeLine
- func (this *PipeLine) Execute() *promise.Promise
- func (this *PipeLine) GetChildById(idx int) lokas.ITaskPipeLine
- func (this *PipeLine) GetChildByName(s string) lokas.ITaskPipeLine
- func (this *PipeLine) GetChildren() []lokas.ITaskPipeLine
- func (this *PipeLine) GetContext() lokas.IContext
- func (this *PipeLine) GetInput() lokas.IContext
- func (this *PipeLine) GetNext() lokas.ITaskPipeLine
- func (this *PipeLine) GetParent() lokas.ITaskPipeLine
- func (this *PipeLine) GetPrev() lokas.ITaskPipeLine
- func (this *PipeLine) GetSibling(idx int) lokas.ITaskPipeLine
- func (this *PipeLine) Idx() int
- func (this *PipeLine) Insert(flow lokas.ITaskPipeLine, idx int) lokas.ITaskPipeLine
- func (this *PipeLine) Name() string
- func (this *PipeLine) Remove(flow lokas.ITaskPipeLine) lokas.ITaskPipeLine
- func (this *PipeLine) RemoveAt(idx int) lokas.ITaskPipeLine
- func (this *PipeLine) SetContext(context lokas.IContext)
- func (this *PipeLine) SetExecFunc(f func() (IContext error, err error))
- func (this *PipeLine) SetIdx(i int)
- func (this *PipeLine) SetInput(context lokas.IContext)
- func (this *PipeLine) SetName(s string)
- type TASK_ORDER
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type INPUT_TYPE ¶
const ( FROM_CONTEXT INPUT_TYPE = iota //从环境变量 FROM_PARENT_INPUT //从父任务的Input FROM_PREV //从上一个任务 FROM_SIBLING //从同级任务 )
type InputConfig ¶ added in v0.1.28
type InputConfig struct {
Inputs []InputParam
}
type InputParam ¶ added in v0.1.28
type InputParam struct { Type INPUT_TYPE Name string Optional bool }
type PipeLine ¶
type PipeLine struct { Order TASK_ORDER FailedByPass bool // contains filtered or unexported fields }
任务基础类
func (*PipeLine) GetChildById ¶
func (*PipeLine) GetChildByName ¶
func (*PipeLine) GetChildren ¶
func (this *PipeLine) GetChildren() []lokas.ITaskPipeLine
func (*PipeLine) GetContext ¶
func (this *PipeLine) GetContext() lokas.IContext
func (*PipeLine) GetSibling ¶
func (*PipeLine) Remove ¶
func (this *PipeLine) Remove(flow lokas.ITaskPipeLine) lokas.ITaskPipeLine
func (*PipeLine) SetContext ¶
func (this *PipeLine) SetContext(context lokas.IContext)
func (*PipeLine) SetExecFunc ¶
type TASK_ORDER ¶
const ( PARALLEL TASK_ORDER = iota //并行 WATERFALL //串行 )
Click to show internal directories.
Click to hide internal directories.