Documentation
¶
Index ¶
- type Builder
- type CompiledWorkflow
- func (c CompiledWorkflow) Graph() *graph.Graph
- func (c CompiledWorkflow) Name() string
- func (c *CompiledWorkflow) NodeList() []nodes.Node
- func (c CompiledWorkflow) Nodes() map[string]nodes.Node
- func (c CompiledWorkflow) Order() []string
- func (c *CompiledWorkflow) Source() *definition.WorkflowDefinition
- type Workflow
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Builder ¶
type Builder struct {
// contains filtered or unexported fields
}
func NewBuilder ¶
func NewBuilder(reg *nodes.NodeRegistry) *Builder
func (*Builder) Build ¶
func (b *Builder) Build(def *definition.WorkflowDefinition) (Workflow, error)
Build 构建DAG
func (*Builder) GetRegister ¶
func (b *Builder) GetRegister() *nodes.NodeRegistry
type CompiledWorkflow ¶
type CompiledWorkflow struct {
// contains filtered or unexported fields
}
func (CompiledWorkflow) Graph ¶
func (c CompiledWorkflow) Graph() *graph.Graph
func (CompiledWorkflow) Name ¶
func (c CompiledWorkflow) Name() string
func (*CompiledWorkflow) NodeList ¶
func (c *CompiledWorkflow) NodeList() []nodes.Node
func (CompiledWorkflow) Order ¶
func (c CompiledWorkflow) Order() []string
func (*CompiledWorkflow) Source ¶
func (c *CompiledWorkflow) Source() *definition.WorkflowDefinition
Click to show internal directories.
Click to hide internal directories.