Documentation ¶
Index ¶
- type InterfaceProvider
- type Node
- func (_m *Node) GetBranchNode() *core.BranchNode
- func (_m *Node) GetCoreNode() *core.Node
- func (_m *Node) GetId() string
- func (_m *Node) GetInputs() []*core.Binding
- func (_m *Node) GetInterface() *core.TypedInterface
- func (_m *Node) GetMetadata() *core.NodeMetadata
- func (_m *Node) GetOutputAliases() []*core.Alias
- func (_m *Node) GetSubWorkflow() common.Workflow
- func (_m *Node) GetTask() common.Task
- func (_m *Node) GetTaskNode() *core.TaskNode
- func (_m *Node) GetUpstreamNodeIds() []string
- func (_m *Node) GetWorkflowNode() *core.WorkflowNode
- type NodeBuilder
- func (_m *NodeBuilder) GetBranchNode() *core.BranchNode
- func (_m *NodeBuilder) GetCoreNode() *core.Node
- func (_m *NodeBuilder) GetId() string
- func (_m *NodeBuilder) GetInputs() []*core.Binding
- func (_m *NodeBuilder) GetInterface() *core.TypedInterface
- func (_m *NodeBuilder) GetMetadata() *core.NodeMetadata
- func (_m *NodeBuilder) GetOutputAliases() []*core.Alias
- func (_m *NodeBuilder) GetSubWorkflow() common.Workflow
- func (_m *NodeBuilder) GetTask() common.Task
- func (_m *NodeBuilder) GetTaskNode() *core.TaskNode
- func (_m *NodeBuilder) GetUpstreamNodeIds() []string
- func (_m *NodeBuilder) GetWorkflowNode() *core.WorkflowNode
- func (_m *NodeBuilder) SetInputs(inputs []*core.Binding)
- func (_m *NodeBuilder) SetInterface(iface *core.TypedInterface)
- func (_m *NodeBuilder) SetSubWorkflow(wf common.Workflow)
- func (_m *NodeBuilder) SetTask(task common.Task)
- type Task
- type Workflow
- func (_m *Workflow) GetCoreWorkflow() *core.CompiledWorkflow
- func (_m *Workflow) GetDownstreamNodes() common.StringAdjacencyList
- func (_m *Workflow) GetFailureNode() common.Node
- func (_m *Workflow) GetLaunchPlan(id core.Identifier) (common.InterfaceProvider, bool)
- func (_m *Workflow) GetNode(id string) (common.NodeBuilder, bool)
- func (_m *Workflow) GetNodes() common.NodeIndex
- func (_m *Workflow) GetSubWorkflow(id core.Identifier) (*core.CompiledWorkflow, bool)
- func (_m *Workflow) GetTask(id core.Identifier) (common.Task, bool)
- func (_m *Workflow) GetTasks() common.TaskIndex
- func (_m *Workflow) GetUpstreamNodes() common.StringAdjacencyList
- type WorkflowBuilder
- func (_m *WorkflowBuilder) AddExecutionEdge(nodeFrom string, nodeTo string)
- func (_m *WorkflowBuilder) AddNode(n common.NodeBuilder, errs errors.CompileErrors) (common.NodeBuilder, bool)
- func (_m *WorkflowBuilder) GetCoreWorkflow() *core.CompiledWorkflow
- func (_m *WorkflowBuilder) GetDownstreamNodes() common.StringAdjacencyList
- func (_m *WorkflowBuilder) GetFailureNode() common.Node
- func (_m *WorkflowBuilder) GetLaunchPlan(id core.Identifier) (common.InterfaceProvider, bool)
- func (_m *WorkflowBuilder) GetNode(id string) (common.NodeBuilder, bool)
- func (_m *WorkflowBuilder) GetNodes() common.NodeIndex
- func (_m *WorkflowBuilder) GetSubWorkflow(id core.Identifier) (*core.CompiledWorkflow, bool)
- func (_m *WorkflowBuilder) GetTask(id core.Identifier) (common.Task, bool)
- func (_m *WorkflowBuilder) GetTasks() common.TaskIndex
- func (_m *WorkflowBuilder) GetUpstreamNodes() common.StringAdjacencyList
- func (_m *WorkflowBuilder) NewNodeBuilder(n *core.Node) common.NodeBuilder
- func (_m *WorkflowBuilder) ValidateWorkflow(fg *core.CompiledWorkflow, errs errors.CompileErrors) (common.Workflow, bool)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type InterfaceProvider ¶
InterfaceProvider is an autogenerated mock type for the InterfaceProvider type
func (*InterfaceProvider) GetExpectedInputs ¶
func (_m *InterfaceProvider) GetExpectedInputs() *core.ParameterMap
GetExpectedInputs provides a mock function with given fields:
func (*InterfaceProvider) GetExpectedOutputs ¶
func (_m *InterfaceProvider) GetExpectedOutputs() *core.VariableMap
GetExpectedOutputs provides a mock function with given fields:
func (*InterfaceProvider) GetID ¶
func (_m *InterfaceProvider) GetID() *core.Identifier
GetID provides a mock function with given fields:
type Node ¶
Node is an autogenerated mock type for the Node type
func (*Node) GetBranchNode ¶
func (_m *Node) GetBranchNode() *core.BranchNode
GetBranchNode provides a mock function with given fields:
func (*Node) GetCoreNode ¶
GetCoreNode provides a mock function with given fields:
func (*Node) GetInterface ¶
func (_m *Node) GetInterface() *core.TypedInterface
GetInterface provides a mock function with given fields:
func (*Node) GetMetadata ¶
func (_m *Node) GetMetadata() *core.NodeMetadata
GetMetadata provides a mock function with given fields:
func (*Node) GetOutputAliases ¶
GetOutputAliases provides a mock function with given fields:
func (*Node) GetSubWorkflow ¶
GetSubWorkflow provides a mock function with given fields:
func (*Node) GetTaskNode ¶
GetTaskNode provides a mock function with given fields:
func (*Node) GetUpstreamNodeIds ¶
GetUpstreamNodeIds provides a mock function with given fields:
func (*Node) GetWorkflowNode ¶
func (_m *Node) GetWorkflowNode() *core.WorkflowNode
GetWorkflowNode provides a mock function with given fields:
type NodeBuilder ¶
NodeBuilder is an autogenerated mock type for the NodeBuilder type
func (*NodeBuilder) GetBranchNode ¶
func (_m *NodeBuilder) GetBranchNode() *core.BranchNode
GetBranchNode provides a mock function with given fields:
func (*NodeBuilder) GetCoreNode ¶
func (_m *NodeBuilder) GetCoreNode() *core.Node
GetCoreNode provides a mock function with given fields:
func (*NodeBuilder) GetId ¶
func (_m *NodeBuilder) GetId() string
GetId provides a mock function with given fields:
func (*NodeBuilder) GetInputs ¶
func (_m *NodeBuilder) GetInputs() []*core.Binding
GetInputs provides a mock function with given fields:
func (*NodeBuilder) GetInterface ¶
func (_m *NodeBuilder) GetInterface() *core.TypedInterface
GetInterface provides a mock function with given fields:
func (*NodeBuilder) GetMetadata ¶
func (_m *NodeBuilder) GetMetadata() *core.NodeMetadata
GetMetadata provides a mock function with given fields:
func (*NodeBuilder) GetOutputAliases ¶
func (_m *NodeBuilder) GetOutputAliases() []*core.Alias
GetOutputAliases provides a mock function with given fields:
func (*NodeBuilder) GetSubWorkflow ¶
func (_m *NodeBuilder) GetSubWorkflow() common.Workflow
GetSubWorkflow provides a mock function with given fields:
func (*NodeBuilder) GetTask ¶
func (_m *NodeBuilder) GetTask() common.Task
GetTask provides a mock function with given fields:
func (*NodeBuilder) GetTaskNode ¶
func (_m *NodeBuilder) GetTaskNode() *core.TaskNode
GetTaskNode provides a mock function with given fields:
func (*NodeBuilder) GetUpstreamNodeIds ¶
func (_m *NodeBuilder) GetUpstreamNodeIds() []string
GetUpstreamNodeIds provides a mock function with given fields:
func (*NodeBuilder) GetWorkflowNode ¶
func (_m *NodeBuilder) GetWorkflowNode() *core.WorkflowNode
GetWorkflowNode provides a mock function with given fields:
func (*NodeBuilder) SetInputs ¶
func (_m *NodeBuilder) SetInputs(inputs []*core.Binding)
SetInputs provides a mock function with given fields: inputs
func (*NodeBuilder) SetInterface ¶
func (_m *NodeBuilder) SetInterface(iface *core.TypedInterface)
SetInterface provides a mock function with given fields: iface
func (*NodeBuilder) SetSubWorkflow ¶
func (_m *NodeBuilder) SetSubWorkflow(wf common.Workflow)
SetSubWorkflow provides a mock function with given fields: wf
func (*NodeBuilder) SetTask ¶
func (_m *NodeBuilder) SetTask(task common.Task)
SetTask provides a mock function with given fields: task
type Task ¶
Task is an autogenerated mock type for the Task type
func (*Task) GetCoreTask ¶
func (_m *Task) GetCoreTask() *core.TaskTemplate
GetCoreTask provides a mock function with given fields:
func (*Task) GetID ¶
func (_m *Task) GetID() core.Identifier
GetID provides a mock function with given fields:
func (*Task) GetInterface ¶
func (_m *Task) GetInterface() *core.TypedInterface
GetInterface provides a mock function with given fields:
type Workflow ¶
Workflow is an autogenerated mock type for the Workflow type
func (*Workflow) GetCoreWorkflow ¶
func (_m *Workflow) GetCoreWorkflow() *core.CompiledWorkflow
GetCoreWorkflow provides a mock function with given fields:
func (*Workflow) GetDownstreamNodes ¶
func (_m *Workflow) GetDownstreamNodes() common.StringAdjacencyList
GetDownstreamNodes provides a mock function with given fields:
func (*Workflow) GetFailureNode ¶
GetFailureNode provides a mock function with given fields:
func (*Workflow) GetLaunchPlan ¶
func (_m *Workflow) GetLaunchPlan(id core.Identifier) (common.InterfaceProvider, bool)
GetLaunchPlan provides a mock function with given fields: id
func (*Workflow) GetNode ¶
func (_m *Workflow) GetNode(id string) (common.NodeBuilder, bool)
GetNode provides a mock function with given fields: id
func (*Workflow) GetSubWorkflow ¶
func (_m *Workflow) GetSubWorkflow(id core.Identifier) (*core.CompiledWorkflow, bool)
GetSubWorkflow provides a mock function with given fields: id
func (*Workflow) GetUpstreamNodes ¶
func (_m *Workflow) GetUpstreamNodes() common.StringAdjacencyList
GetUpstreamNodes provides a mock function with given fields:
type WorkflowBuilder ¶
WorkflowBuilder is an autogenerated mock type for the WorkflowBuilder type
func (*WorkflowBuilder) AddExecutionEdge ¶
func (_m *WorkflowBuilder) AddExecutionEdge(nodeFrom string, nodeTo string)
AddExecutionEdge provides a mock function with given fields: nodeFrom, nodeTo
func (*WorkflowBuilder) AddNode ¶
func (_m *WorkflowBuilder) AddNode(n common.NodeBuilder, errs errors.CompileErrors) (common.NodeBuilder, bool)
AddNode provides a mock function with given fields: n, errs
func (*WorkflowBuilder) GetCoreWorkflow ¶
func (_m *WorkflowBuilder) GetCoreWorkflow() *core.CompiledWorkflow
GetCoreWorkflow provides a mock function with given fields:
func (*WorkflowBuilder) GetDownstreamNodes ¶
func (_m *WorkflowBuilder) GetDownstreamNodes() common.StringAdjacencyList
GetDownstreamNodes provides a mock function with given fields:
func (*WorkflowBuilder) GetFailureNode ¶
func (_m *WorkflowBuilder) GetFailureNode() common.Node
GetFailureNode provides a mock function with given fields:
func (*WorkflowBuilder) GetLaunchPlan ¶
func (_m *WorkflowBuilder) GetLaunchPlan(id core.Identifier) (common.InterfaceProvider, bool)
GetLaunchPlan provides a mock function with given fields: id
func (*WorkflowBuilder) GetNode ¶
func (_m *WorkflowBuilder) GetNode(id string) (common.NodeBuilder, bool)
GetNode provides a mock function with given fields: id
func (*WorkflowBuilder) GetNodes ¶
func (_m *WorkflowBuilder) GetNodes() common.NodeIndex
GetNodes provides a mock function with given fields:
func (*WorkflowBuilder) GetSubWorkflow ¶
func (_m *WorkflowBuilder) GetSubWorkflow(id core.Identifier) (*core.CompiledWorkflow, bool)
GetSubWorkflow provides a mock function with given fields: id
func (*WorkflowBuilder) GetTask ¶
func (_m *WorkflowBuilder) GetTask(id core.Identifier) (common.Task, bool)
GetTask provides a mock function with given fields: id
func (*WorkflowBuilder) GetTasks ¶
func (_m *WorkflowBuilder) GetTasks() common.TaskIndex
GetTasks provides a mock function with given fields:
func (*WorkflowBuilder) GetUpstreamNodes ¶
func (_m *WorkflowBuilder) GetUpstreamNodes() common.StringAdjacencyList
GetUpstreamNodes provides a mock function with given fields:
func (*WorkflowBuilder) NewNodeBuilder ¶
func (_m *WorkflowBuilder) NewNodeBuilder(n *core.Node) common.NodeBuilder
NewNodeBuilder provides a mock function with given fields: n
func (*WorkflowBuilder) ValidateWorkflow ¶
func (_m *WorkflowBuilder) ValidateWorkflow(fg *core.CompiledWorkflow, errs errors.CompileErrors) (common.Workflow, bool)
ValidateWorkflow provides a mock function with given fields: fg, errs