Documentation ¶
Index ¶
- type InterfaceProvider
- func (_m *InterfaceProvider) GetExpectedInputs() *core.ParameterMap
- func (_m *InterfaceProvider) GetExpectedOutputs() *core.VariableMap
- func (_m *InterfaceProvider) GetID() *core.Identifier
- func (_m *InterfaceProvider) OnGetExpectedInputs() *InterfaceProvider_GetExpectedInputs
- func (_m *InterfaceProvider) OnGetExpectedInputsMatch(matchers ...interface{}) *InterfaceProvider_GetExpectedInputs
- func (_m *InterfaceProvider) OnGetExpectedOutputs() *InterfaceProvider_GetExpectedOutputs
- func (_m *InterfaceProvider) OnGetExpectedOutputsMatch(matchers ...interface{}) *InterfaceProvider_GetExpectedOutputs
- func (_m *InterfaceProvider) OnGetID() *InterfaceProvider_GetID
- func (_m *InterfaceProvider) OnGetIDMatch(matchers ...interface{}) *InterfaceProvider_GetID
- type InterfaceProvider_GetExpectedInputs
- type InterfaceProvider_GetExpectedOutputs
- type InterfaceProvider_GetID
- type Node
- func (_m *Node) GetArrayNode() *core.ArrayNode
- func (_m *Node) GetBranchNode() *core.BranchNode
- func (_m *Node) GetCoreNode() *core.Node
- func (_m *Node) GetGateNode() *core.GateNode
- 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
- func (_m *Node) OnGetArrayNode() *Node_GetArrayNode
- func (_m *Node) OnGetArrayNodeMatch(matchers ...interface{}) *Node_GetArrayNode
- func (_m *Node) OnGetBranchNode() *Node_GetBranchNode
- func (_m *Node) OnGetBranchNodeMatch(matchers ...interface{}) *Node_GetBranchNode
- func (_m *Node) OnGetCoreNode() *Node_GetCoreNode
- func (_m *Node) OnGetCoreNodeMatch(matchers ...interface{}) *Node_GetCoreNode
- func (_m *Node) OnGetGateNode() *Node_GetGateNode
- func (_m *Node) OnGetGateNodeMatch(matchers ...interface{}) *Node_GetGateNode
- func (_m *Node) OnGetId() *Node_GetId
- func (_m *Node) OnGetIdMatch(matchers ...interface{}) *Node_GetId
- func (_m *Node) OnGetInputs() *Node_GetInputs
- func (_m *Node) OnGetInputsMatch(matchers ...interface{}) *Node_GetInputs
- func (_m *Node) OnGetInterface() *Node_GetInterface
- func (_m *Node) OnGetInterfaceMatch(matchers ...interface{}) *Node_GetInterface
- func (_m *Node) OnGetMetadata() *Node_GetMetadata
- func (_m *Node) OnGetMetadataMatch(matchers ...interface{}) *Node_GetMetadata
- func (_m *Node) OnGetOutputAliases() *Node_GetOutputAliases
- func (_m *Node) OnGetOutputAliasesMatch(matchers ...interface{}) *Node_GetOutputAliases
- func (_m *Node) OnGetSubWorkflow() *Node_GetSubWorkflow
- func (_m *Node) OnGetSubWorkflowMatch(matchers ...interface{}) *Node_GetSubWorkflow
- func (_m *Node) OnGetTask() *Node_GetTask
- func (_m *Node) OnGetTaskMatch(matchers ...interface{}) *Node_GetTask
- func (_m *Node) OnGetTaskNode() *Node_GetTaskNode
- func (_m *Node) OnGetTaskNodeMatch(matchers ...interface{}) *Node_GetTaskNode
- func (_m *Node) OnGetUpstreamNodeIds() *Node_GetUpstreamNodeIds
- func (_m *Node) OnGetUpstreamNodeIdsMatch(matchers ...interface{}) *Node_GetUpstreamNodeIds
- func (_m *Node) OnGetWorkflowNode() *Node_GetWorkflowNode
- func (_m *Node) OnGetWorkflowNodeMatch(matchers ...interface{}) *Node_GetWorkflowNode
- type NodeBuilder
- func (_m *NodeBuilder) GetArrayNode() *core.ArrayNode
- func (_m *NodeBuilder) GetBranchNode() *core.BranchNode
- func (_m *NodeBuilder) GetCoreNode() *core.Node
- func (_m *NodeBuilder) GetGateNode() *core.GateNode
- 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) OnGetArrayNode() *NodeBuilder_GetArrayNode
- func (_m *NodeBuilder) OnGetArrayNodeMatch(matchers ...interface{}) *NodeBuilder_GetArrayNode
- func (_m *NodeBuilder) OnGetBranchNode() *NodeBuilder_GetBranchNode
- func (_m *NodeBuilder) OnGetBranchNodeMatch(matchers ...interface{}) *NodeBuilder_GetBranchNode
- func (_m *NodeBuilder) OnGetCoreNode() *NodeBuilder_GetCoreNode
- func (_m *NodeBuilder) OnGetCoreNodeMatch(matchers ...interface{}) *NodeBuilder_GetCoreNode
- func (_m *NodeBuilder) OnGetGateNode() *NodeBuilder_GetGateNode
- func (_m *NodeBuilder) OnGetGateNodeMatch(matchers ...interface{}) *NodeBuilder_GetGateNode
- func (_m *NodeBuilder) OnGetId() *NodeBuilder_GetId
- func (_m *NodeBuilder) OnGetIdMatch(matchers ...interface{}) *NodeBuilder_GetId
- func (_m *NodeBuilder) OnGetInputs() *NodeBuilder_GetInputs
- func (_m *NodeBuilder) OnGetInputsMatch(matchers ...interface{}) *NodeBuilder_GetInputs
- func (_m *NodeBuilder) OnGetInterface() *NodeBuilder_GetInterface
- func (_m *NodeBuilder) OnGetInterfaceMatch(matchers ...interface{}) *NodeBuilder_GetInterface
- func (_m *NodeBuilder) OnGetMetadata() *NodeBuilder_GetMetadata
- func (_m *NodeBuilder) OnGetMetadataMatch(matchers ...interface{}) *NodeBuilder_GetMetadata
- func (_m *NodeBuilder) OnGetOutputAliases() *NodeBuilder_GetOutputAliases
- func (_m *NodeBuilder) OnGetOutputAliasesMatch(matchers ...interface{}) *NodeBuilder_GetOutputAliases
- func (_m *NodeBuilder) OnGetSubWorkflow() *NodeBuilder_GetSubWorkflow
- func (_m *NodeBuilder) OnGetSubWorkflowMatch(matchers ...interface{}) *NodeBuilder_GetSubWorkflow
- func (_m *NodeBuilder) OnGetTask() *NodeBuilder_GetTask
- func (_m *NodeBuilder) OnGetTaskMatch(matchers ...interface{}) *NodeBuilder_GetTask
- func (_m *NodeBuilder) OnGetTaskNode() *NodeBuilder_GetTaskNode
- func (_m *NodeBuilder) OnGetTaskNodeMatch(matchers ...interface{}) *NodeBuilder_GetTaskNode
- func (_m *NodeBuilder) OnGetUpstreamNodeIds() *NodeBuilder_GetUpstreamNodeIds
- func (_m *NodeBuilder) OnGetUpstreamNodeIdsMatch(matchers ...interface{}) *NodeBuilder_GetUpstreamNodeIds
- func (_m *NodeBuilder) OnGetWorkflowNode() *NodeBuilder_GetWorkflowNode
- func (_m *NodeBuilder) OnGetWorkflowNodeMatch(matchers ...interface{}) *NodeBuilder_GetWorkflowNode
- func (_m *NodeBuilder) SetID(id string)
- 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 NodeBuilder_GetArrayNode
- type NodeBuilder_GetBranchNode
- type NodeBuilder_GetCoreNode
- type NodeBuilder_GetGateNode
- type NodeBuilder_GetId
- type NodeBuilder_GetInputs
- type NodeBuilder_GetInterface
- type NodeBuilder_GetMetadata
- type NodeBuilder_GetOutputAliases
- type NodeBuilder_GetSubWorkflow
- type NodeBuilder_GetTask
- type NodeBuilder_GetTaskNode
- type NodeBuilder_GetUpstreamNodeIds
- type NodeBuilder_GetWorkflowNode
- type Node_GetArrayNode
- type Node_GetBranchNode
- type Node_GetCoreNode
- type Node_GetGateNode
- type Node_GetId
- type Node_GetInputs
- type Node_GetInterface
- type Node_GetMetadata
- type Node_GetOutputAliases
- type Node_GetSubWorkflow
- type Node_GetTask
- type Node_GetTaskNode
- type Node_GetUpstreamNodeIds
- type Node_GetWorkflowNode
- type Task
- func (_m *Task) GetCoreTask() *core.TaskTemplate
- func (_m *Task) GetID() core.Identifier
- func (_m *Task) GetInterface() *core.TypedInterface
- func (_m *Task) OnGetCoreTask() *Task_GetCoreTask
- func (_m *Task) OnGetCoreTaskMatch(matchers ...interface{}) *Task_GetCoreTask
- func (_m *Task) OnGetID() *Task_GetID
- func (_m *Task) OnGetIDMatch(matchers ...interface{}) *Task_GetID
- func (_m *Task) OnGetInterface() *Task_GetInterface
- func (_m *Task) OnGetInterfaceMatch(matchers ...interface{}) *Task_GetInterface
- type Task_GetCoreTask
- type Task_GetID
- type Task_GetInterface
- type Workflow
- func (_m *Workflow) GetCompiledSubWorkflow(id core.Identifier) (*core.CompiledWorkflow, bool)
- 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
- func (_m *Workflow) OnGetCompiledSubWorkflow(id core.Identifier) *Workflow_GetCompiledSubWorkflow
- func (_m *Workflow) OnGetCompiledSubWorkflowMatch(matchers ...interface{}) *Workflow_GetCompiledSubWorkflow
- func (_m *Workflow) OnGetCoreWorkflow() *Workflow_GetCoreWorkflow
- func (_m *Workflow) OnGetCoreWorkflowMatch(matchers ...interface{}) *Workflow_GetCoreWorkflow
- func (_m *Workflow) OnGetDownstreamNodes() *Workflow_GetDownstreamNodes
- func (_m *Workflow) OnGetDownstreamNodesMatch(matchers ...interface{}) *Workflow_GetDownstreamNodes
- func (_m *Workflow) OnGetFailureNode() *Workflow_GetFailureNode
- func (_m *Workflow) OnGetFailureNodeMatch(matchers ...interface{}) *Workflow_GetFailureNode
- func (_m *Workflow) OnGetLaunchPlan(id core.Identifier) *Workflow_GetLaunchPlan
- func (_m *Workflow) OnGetLaunchPlanMatch(matchers ...interface{}) *Workflow_GetLaunchPlan
- func (_m *Workflow) OnGetNode(id string) *Workflow_GetNode
- func (_m *Workflow) OnGetNodeMatch(matchers ...interface{}) *Workflow_GetNode
- func (_m *Workflow) OnGetNodes() *Workflow_GetNodes
- func (_m *Workflow) OnGetNodesMatch(matchers ...interface{}) *Workflow_GetNodes
- func (_m *Workflow) OnGetSubWorkflow(id core.Identifier) *Workflow_GetSubWorkflow
- func (_m *Workflow) OnGetSubWorkflowMatch(matchers ...interface{}) *Workflow_GetSubWorkflow
- func (_m *Workflow) OnGetTask(id core.Identifier) *Workflow_GetTask
- func (_m *Workflow) OnGetTaskMatch(matchers ...interface{}) *Workflow_GetTask
- func (_m *Workflow) OnGetTasks() *Workflow_GetTasks
- func (_m *Workflow) OnGetTasksMatch(matchers ...interface{}) *Workflow_GetTasks
- func (_m *Workflow) OnGetUpstreamNodes() *Workflow_GetUpstreamNodes
- func (_m *Workflow) OnGetUpstreamNodesMatch(matchers ...interface{}) *Workflow_GetUpstreamNodes
- type WorkflowBuilder
- func (_m *WorkflowBuilder) AddDownstreamEdge(nodeProvider string, nodeDependent string)
- func (_m *WorkflowBuilder) AddEdges(n common.NodeBuilder, edgeDirection common.EdgeDirection, ...) bool
- func (_m *WorkflowBuilder) AddExecutionEdge(nodeFrom string, nodeTo string)
- func (_m *WorkflowBuilder) AddNode(n common.NodeBuilder, errs errors.CompileErrors) (common.NodeBuilder, bool)
- func (_m *WorkflowBuilder) AddUpstreamEdge(nodeProvider string, nodeDependent string)
- func (_m *WorkflowBuilder) GetCompiledSubWorkflow(id core.Identifier) (*core.CompiledWorkflow, 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) GetOrCreateNodeBuilder(n *core.Node) common.NodeBuilder
- 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) OnAddEdges(n common.NodeBuilder, edgeDirection common.EdgeDirection, ...) *WorkflowBuilder_AddEdges
- func (_m *WorkflowBuilder) OnAddEdgesMatch(matchers ...interface{}) *WorkflowBuilder_AddEdges
- func (_m *WorkflowBuilder) OnAddNode(n common.NodeBuilder, errs errors.CompileErrors) *WorkflowBuilder_AddNode
- func (_m *WorkflowBuilder) OnAddNodeMatch(matchers ...interface{}) *WorkflowBuilder_AddNode
- func (_m *WorkflowBuilder) OnGetCompiledSubWorkflow(id core.Identifier) *WorkflowBuilder_GetCompiledSubWorkflow
- func (_m *WorkflowBuilder) OnGetCompiledSubWorkflowMatch(matchers ...interface{}) *WorkflowBuilder_GetCompiledSubWorkflow
- func (_m *WorkflowBuilder) OnGetCoreWorkflow() *WorkflowBuilder_GetCoreWorkflow
- func (_m *WorkflowBuilder) OnGetCoreWorkflowMatch(matchers ...interface{}) *WorkflowBuilder_GetCoreWorkflow
- func (_m *WorkflowBuilder) OnGetDownstreamNodes() *WorkflowBuilder_GetDownstreamNodes
- func (_m *WorkflowBuilder) OnGetDownstreamNodesMatch(matchers ...interface{}) *WorkflowBuilder_GetDownstreamNodes
- func (_m *WorkflowBuilder) OnGetFailureNode() *WorkflowBuilder_GetFailureNode
- func (_m *WorkflowBuilder) OnGetFailureNodeMatch(matchers ...interface{}) *WorkflowBuilder_GetFailureNode
- func (_m *WorkflowBuilder) OnGetLaunchPlan(id core.Identifier) *WorkflowBuilder_GetLaunchPlan
- func (_m *WorkflowBuilder) OnGetLaunchPlanMatch(matchers ...interface{}) *WorkflowBuilder_GetLaunchPlan
- func (_m *WorkflowBuilder) OnGetNode(id string) *WorkflowBuilder_GetNode
- func (_m *WorkflowBuilder) OnGetNodeMatch(matchers ...interface{}) *WorkflowBuilder_GetNode
- func (_m *WorkflowBuilder) OnGetNodes() *WorkflowBuilder_GetNodes
- func (_m *WorkflowBuilder) OnGetNodesMatch(matchers ...interface{}) *WorkflowBuilder_GetNodes
- func (_m *WorkflowBuilder) OnGetOrCreateNodeBuilder(n *core.Node) *WorkflowBuilder_GetOrCreateNodeBuilder
- func (_m *WorkflowBuilder) OnGetOrCreateNodeBuilderMatch(matchers ...interface{}) *WorkflowBuilder_GetOrCreateNodeBuilder
- func (_m *WorkflowBuilder) OnGetSubWorkflow(id core.Identifier) *WorkflowBuilder_GetSubWorkflow
- func (_m *WorkflowBuilder) OnGetSubWorkflowMatch(matchers ...interface{}) *WorkflowBuilder_GetSubWorkflow
- func (_m *WorkflowBuilder) OnGetTask(id core.Identifier) *WorkflowBuilder_GetTask
- func (_m *WorkflowBuilder) OnGetTaskMatch(matchers ...interface{}) *WorkflowBuilder_GetTask
- func (_m *WorkflowBuilder) OnGetTasks() *WorkflowBuilder_GetTasks
- func (_m *WorkflowBuilder) OnGetTasksMatch(matchers ...interface{}) *WorkflowBuilder_GetTasks
- func (_m *WorkflowBuilder) OnGetUpstreamNodes() *WorkflowBuilder_GetUpstreamNodes
- func (_m *WorkflowBuilder) OnGetUpstreamNodesMatch(matchers ...interface{}) *WorkflowBuilder_GetUpstreamNodes
- func (_m *WorkflowBuilder) OnValidateWorkflow(fg *core.CompiledWorkflow, errs errors.CompileErrors) *WorkflowBuilder_ValidateWorkflow
- func (_m *WorkflowBuilder) OnValidateWorkflowMatch(matchers ...interface{}) *WorkflowBuilder_ValidateWorkflow
- func (_m *WorkflowBuilder) StoreCompiledSubWorkflow(id core.Identifier, compiledWorkflow *core.CompiledWorkflow)
- func (_m *WorkflowBuilder) ValidateWorkflow(fg *core.CompiledWorkflow, errs errors.CompileErrors) (common.Workflow, bool)
- type WorkflowBuilder_AddEdges
- type WorkflowBuilder_AddNode
- type WorkflowBuilder_GetCompiledSubWorkflow
- type WorkflowBuilder_GetCoreWorkflow
- type WorkflowBuilder_GetDownstreamNodes
- type WorkflowBuilder_GetFailureNode
- type WorkflowBuilder_GetLaunchPlan
- type WorkflowBuilder_GetNode
- type WorkflowBuilder_GetNodes
- type WorkflowBuilder_GetOrCreateNodeBuilder
- type WorkflowBuilder_GetSubWorkflow
- type WorkflowBuilder_GetTask
- type WorkflowBuilder_GetTasks
- type WorkflowBuilder_GetUpstreamNodes
- type WorkflowBuilder_ValidateWorkflow
- type Workflow_GetCompiledSubWorkflow
- type Workflow_GetCoreWorkflow
- type Workflow_GetDownstreamNodes
- type Workflow_GetFailureNode
- type Workflow_GetLaunchPlan
- type Workflow_GetNode
- type Workflow_GetNodes
- type Workflow_GetSubWorkflow
- type Workflow_GetTask
- type Workflow_GetTasks
- type Workflow_GetUpstreamNodes
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:
func (*InterfaceProvider) OnGetExpectedInputs ¶
func (_m *InterfaceProvider) OnGetExpectedInputs() *InterfaceProvider_GetExpectedInputs
func (*InterfaceProvider) OnGetExpectedInputsMatch ¶
func (_m *InterfaceProvider) OnGetExpectedInputsMatch(matchers ...interface{}) *InterfaceProvider_GetExpectedInputs
func (*InterfaceProvider) OnGetExpectedOutputs ¶
func (_m *InterfaceProvider) OnGetExpectedOutputs() *InterfaceProvider_GetExpectedOutputs
func (*InterfaceProvider) OnGetExpectedOutputsMatch ¶
func (_m *InterfaceProvider) OnGetExpectedOutputsMatch(matchers ...interface{}) *InterfaceProvider_GetExpectedOutputs
func (*InterfaceProvider) OnGetID ¶
func (_m *InterfaceProvider) OnGetID() *InterfaceProvider_GetID
func (*InterfaceProvider) OnGetIDMatch ¶
func (_m *InterfaceProvider) OnGetIDMatch(matchers ...interface{}) *InterfaceProvider_GetID
type InterfaceProvider_GetExpectedInputs ¶
func (InterfaceProvider_GetExpectedInputs) Return ¶
func (_m InterfaceProvider_GetExpectedInputs) Return(_a0 *core.ParameterMap) *InterfaceProvider_GetExpectedInputs
type InterfaceProvider_GetExpectedOutputs ¶
func (InterfaceProvider_GetExpectedOutputs) Return ¶
func (_m InterfaceProvider_GetExpectedOutputs) Return(_a0 *core.VariableMap) *InterfaceProvider_GetExpectedOutputs
type InterfaceProvider_GetID ¶
func (InterfaceProvider_GetID) Return ¶
func (_m InterfaceProvider_GetID) Return(_a0 *core.Identifier) *InterfaceProvider_GetID
type Node ¶
Node is an autogenerated mock type for the Node type
func (*Node) GetArrayNode ¶
GetArrayNode provides a mock function with given fields:
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) GetGateNode ¶
GetGateNode 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:
func (*Node) OnGetArrayNode ¶
func (_m *Node) OnGetArrayNode() *Node_GetArrayNode
func (*Node) OnGetArrayNodeMatch ¶
func (_m *Node) OnGetArrayNodeMatch(matchers ...interface{}) *Node_GetArrayNode
func (*Node) OnGetBranchNode ¶
func (_m *Node) OnGetBranchNode() *Node_GetBranchNode
func (*Node) OnGetBranchNodeMatch ¶
func (_m *Node) OnGetBranchNodeMatch(matchers ...interface{}) *Node_GetBranchNode
func (*Node) OnGetCoreNode ¶
func (_m *Node) OnGetCoreNode() *Node_GetCoreNode
func (*Node) OnGetCoreNodeMatch ¶
func (_m *Node) OnGetCoreNodeMatch(matchers ...interface{}) *Node_GetCoreNode
func (*Node) OnGetGateNode ¶
func (_m *Node) OnGetGateNode() *Node_GetGateNode
func (*Node) OnGetGateNodeMatch ¶
func (_m *Node) OnGetGateNodeMatch(matchers ...interface{}) *Node_GetGateNode
func (*Node) OnGetId ¶
func (_m *Node) OnGetId() *Node_GetId
func (*Node) OnGetIdMatch ¶
func (_m *Node) OnGetIdMatch(matchers ...interface{}) *Node_GetId
func (*Node) OnGetInputs ¶
func (_m *Node) OnGetInputs() *Node_GetInputs
func (*Node) OnGetInputsMatch ¶
func (_m *Node) OnGetInputsMatch(matchers ...interface{}) *Node_GetInputs
func (*Node) OnGetInterface ¶
func (_m *Node) OnGetInterface() *Node_GetInterface
func (*Node) OnGetInterfaceMatch ¶
func (_m *Node) OnGetInterfaceMatch(matchers ...interface{}) *Node_GetInterface
func (*Node) OnGetMetadata ¶
func (_m *Node) OnGetMetadata() *Node_GetMetadata
func (*Node) OnGetMetadataMatch ¶
func (_m *Node) OnGetMetadataMatch(matchers ...interface{}) *Node_GetMetadata
func (*Node) OnGetOutputAliases ¶
func (_m *Node) OnGetOutputAliases() *Node_GetOutputAliases
func (*Node) OnGetOutputAliasesMatch ¶
func (_m *Node) OnGetOutputAliasesMatch(matchers ...interface{}) *Node_GetOutputAliases
func (*Node) OnGetSubWorkflow ¶
func (_m *Node) OnGetSubWorkflow() *Node_GetSubWorkflow
func (*Node) OnGetSubWorkflowMatch ¶
func (_m *Node) OnGetSubWorkflowMatch(matchers ...interface{}) *Node_GetSubWorkflow
func (*Node) OnGetTask ¶
func (_m *Node) OnGetTask() *Node_GetTask
func (*Node) OnGetTaskMatch ¶
func (_m *Node) OnGetTaskMatch(matchers ...interface{}) *Node_GetTask
func (*Node) OnGetTaskNode ¶
func (_m *Node) OnGetTaskNode() *Node_GetTaskNode
func (*Node) OnGetTaskNodeMatch ¶
func (_m *Node) OnGetTaskNodeMatch(matchers ...interface{}) *Node_GetTaskNode
func (*Node) OnGetUpstreamNodeIds ¶
func (_m *Node) OnGetUpstreamNodeIds() *Node_GetUpstreamNodeIds
func (*Node) OnGetUpstreamNodeIdsMatch ¶
func (_m *Node) OnGetUpstreamNodeIdsMatch(matchers ...interface{}) *Node_GetUpstreamNodeIds
func (*Node) OnGetWorkflowNode ¶
func (_m *Node) OnGetWorkflowNode() *Node_GetWorkflowNode
func (*Node) OnGetWorkflowNodeMatch ¶
func (_m *Node) OnGetWorkflowNodeMatch(matchers ...interface{}) *Node_GetWorkflowNode
type NodeBuilder ¶
NodeBuilder is an autogenerated mock type for the NodeBuilder type
func (*NodeBuilder) GetArrayNode ¶
func (_m *NodeBuilder) GetArrayNode() *core.ArrayNode
GetArrayNode provides a mock function with given fields:
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) GetGateNode ¶
func (_m *NodeBuilder) GetGateNode() *core.GateNode
GetGateNode 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) OnGetArrayNode ¶
func (_m *NodeBuilder) OnGetArrayNode() *NodeBuilder_GetArrayNode
func (*NodeBuilder) OnGetArrayNodeMatch ¶
func (_m *NodeBuilder) OnGetArrayNodeMatch(matchers ...interface{}) *NodeBuilder_GetArrayNode
func (*NodeBuilder) OnGetBranchNode ¶
func (_m *NodeBuilder) OnGetBranchNode() *NodeBuilder_GetBranchNode
func (*NodeBuilder) OnGetBranchNodeMatch ¶
func (_m *NodeBuilder) OnGetBranchNodeMatch(matchers ...interface{}) *NodeBuilder_GetBranchNode
func (*NodeBuilder) OnGetCoreNode ¶
func (_m *NodeBuilder) OnGetCoreNode() *NodeBuilder_GetCoreNode
func (*NodeBuilder) OnGetCoreNodeMatch ¶
func (_m *NodeBuilder) OnGetCoreNodeMatch(matchers ...interface{}) *NodeBuilder_GetCoreNode
func (*NodeBuilder) OnGetGateNode ¶
func (_m *NodeBuilder) OnGetGateNode() *NodeBuilder_GetGateNode
func (*NodeBuilder) OnGetGateNodeMatch ¶
func (_m *NodeBuilder) OnGetGateNodeMatch(matchers ...interface{}) *NodeBuilder_GetGateNode
func (*NodeBuilder) OnGetId ¶
func (_m *NodeBuilder) OnGetId() *NodeBuilder_GetId
func (*NodeBuilder) OnGetIdMatch ¶
func (_m *NodeBuilder) OnGetIdMatch(matchers ...interface{}) *NodeBuilder_GetId
func (*NodeBuilder) OnGetInputs ¶
func (_m *NodeBuilder) OnGetInputs() *NodeBuilder_GetInputs
func (*NodeBuilder) OnGetInputsMatch ¶
func (_m *NodeBuilder) OnGetInputsMatch(matchers ...interface{}) *NodeBuilder_GetInputs
func (*NodeBuilder) OnGetInterface ¶
func (_m *NodeBuilder) OnGetInterface() *NodeBuilder_GetInterface
func (*NodeBuilder) OnGetInterfaceMatch ¶
func (_m *NodeBuilder) OnGetInterfaceMatch(matchers ...interface{}) *NodeBuilder_GetInterface
func (*NodeBuilder) OnGetMetadata ¶
func (_m *NodeBuilder) OnGetMetadata() *NodeBuilder_GetMetadata
func (*NodeBuilder) OnGetMetadataMatch ¶
func (_m *NodeBuilder) OnGetMetadataMatch(matchers ...interface{}) *NodeBuilder_GetMetadata
func (*NodeBuilder) OnGetOutputAliases ¶
func (_m *NodeBuilder) OnGetOutputAliases() *NodeBuilder_GetOutputAliases
func (*NodeBuilder) OnGetOutputAliasesMatch ¶
func (_m *NodeBuilder) OnGetOutputAliasesMatch(matchers ...interface{}) *NodeBuilder_GetOutputAliases
func (*NodeBuilder) OnGetSubWorkflow ¶
func (_m *NodeBuilder) OnGetSubWorkflow() *NodeBuilder_GetSubWorkflow
func (*NodeBuilder) OnGetSubWorkflowMatch ¶
func (_m *NodeBuilder) OnGetSubWorkflowMatch(matchers ...interface{}) *NodeBuilder_GetSubWorkflow
func (*NodeBuilder) OnGetTask ¶
func (_m *NodeBuilder) OnGetTask() *NodeBuilder_GetTask
func (*NodeBuilder) OnGetTaskMatch ¶
func (_m *NodeBuilder) OnGetTaskMatch(matchers ...interface{}) *NodeBuilder_GetTask
func (*NodeBuilder) OnGetTaskNode ¶
func (_m *NodeBuilder) OnGetTaskNode() *NodeBuilder_GetTaskNode
func (*NodeBuilder) OnGetTaskNodeMatch ¶
func (_m *NodeBuilder) OnGetTaskNodeMatch(matchers ...interface{}) *NodeBuilder_GetTaskNode
func (*NodeBuilder) OnGetUpstreamNodeIds ¶
func (_m *NodeBuilder) OnGetUpstreamNodeIds() *NodeBuilder_GetUpstreamNodeIds
func (*NodeBuilder) OnGetUpstreamNodeIdsMatch ¶
func (_m *NodeBuilder) OnGetUpstreamNodeIdsMatch(matchers ...interface{}) *NodeBuilder_GetUpstreamNodeIds
func (*NodeBuilder) OnGetWorkflowNode ¶
func (_m *NodeBuilder) OnGetWorkflowNode() *NodeBuilder_GetWorkflowNode
func (*NodeBuilder) OnGetWorkflowNodeMatch ¶
func (_m *NodeBuilder) OnGetWorkflowNodeMatch(matchers ...interface{}) *NodeBuilder_GetWorkflowNode
func (*NodeBuilder) SetID ¶
func (_m *NodeBuilder) SetID(id string)
SetID provides a mock function with given fields: id
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 NodeBuilder_GetArrayNode ¶
func (NodeBuilder_GetArrayNode) Return ¶
func (_m NodeBuilder_GetArrayNode) Return(_a0 *core.ArrayNode) *NodeBuilder_GetArrayNode
type NodeBuilder_GetBranchNode ¶
func (NodeBuilder_GetBranchNode) Return ¶
func (_m NodeBuilder_GetBranchNode) Return(_a0 *core.BranchNode) *NodeBuilder_GetBranchNode
type NodeBuilder_GetCoreNode ¶
func (NodeBuilder_GetCoreNode) Return ¶
func (_m NodeBuilder_GetCoreNode) Return(_a0 *core.Node) *NodeBuilder_GetCoreNode
type NodeBuilder_GetGateNode ¶
func (NodeBuilder_GetGateNode) Return ¶
func (_m NodeBuilder_GetGateNode) Return(_a0 *core.GateNode) *NodeBuilder_GetGateNode
type NodeBuilder_GetId ¶
func (NodeBuilder_GetId) Return ¶
func (_m NodeBuilder_GetId) Return(_a0 string) *NodeBuilder_GetId
type NodeBuilder_GetInputs ¶
func (NodeBuilder_GetInputs) Return ¶
func (_m NodeBuilder_GetInputs) Return(_a0 []*core.Binding) *NodeBuilder_GetInputs
type NodeBuilder_GetInterface ¶
func (NodeBuilder_GetInterface) Return ¶
func (_m NodeBuilder_GetInterface) Return(_a0 *core.TypedInterface) *NodeBuilder_GetInterface
type NodeBuilder_GetMetadata ¶
func (NodeBuilder_GetMetadata) Return ¶
func (_m NodeBuilder_GetMetadata) Return(_a0 *core.NodeMetadata) *NodeBuilder_GetMetadata
type NodeBuilder_GetOutputAliases ¶
func (NodeBuilder_GetOutputAliases) Return ¶
func (_m NodeBuilder_GetOutputAliases) Return(_a0 []*core.Alias) *NodeBuilder_GetOutputAliases
type NodeBuilder_GetSubWorkflow ¶
func (NodeBuilder_GetSubWorkflow) Return ¶
func (_m NodeBuilder_GetSubWorkflow) Return(_a0 common.Workflow) *NodeBuilder_GetSubWorkflow
type NodeBuilder_GetTask ¶
func (NodeBuilder_GetTask) Return ¶
func (_m NodeBuilder_GetTask) Return(_a0 common.Task) *NodeBuilder_GetTask
type NodeBuilder_GetTaskNode ¶
func (NodeBuilder_GetTaskNode) Return ¶
func (_m NodeBuilder_GetTaskNode) Return(_a0 *core.TaskNode) *NodeBuilder_GetTaskNode
type NodeBuilder_GetUpstreamNodeIds ¶
func (NodeBuilder_GetUpstreamNodeIds) Return ¶
func (_m NodeBuilder_GetUpstreamNodeIds) Return(_a0 []string) *NodeBuilder_GetUpstreamNodeIds
type NodeBuilder_GetWorkflowNode ¶
func (NodeBuilder_GetWorkflowNode) Return ¶
func (_m NodeBuilder_GetWorkflowNode) Return(_a0 *core.WorkflowNode) *NodeBuilder_GetWorkflowNode
type Node_GetArrayNode ¶
func (Node_GetArrayNode) Return ¶
func (_m Node_GetArrayNode) Return(_a0 *core.ArrayNode) *Node_GetArrayNode
type Node_GetBranchNode ¶
func (Node_GetBranchNode) Return ¶
func (_m Node_GetBranchNode) Return(_a0 *core.BranchNode) *Node_GetBranchNode
type Node_GetCoreNode ¶
func (Node_GetCoreNode) Return ¶
func (_m Node_GetCoreNode) Return(_a0 *core.Node) *Node_GetCoreNode
type Node_GetGateNode ¶
func (Node_GetGateNode) Return ¶
func (_m Node_GetGateNode) Return(_a0 *core.GateNode) *Node_GetGateNode
type Node_GetId ¶
func (Node_GetId) Return ¶
func (_m Node_GetId) Return(_a0 string) *Node_GetId
type Node_GetInputs ¶
func (Node_GetInputs) Return ¶
func (_m Node_GetInputs) Return(_a0 []*core.Binding) *Node_GetInputs
type Node_GetInterface ¶
func (Node_GetInterface) Return ¶
func (_m Node_GetInterface) Return(_a0 *core.TypedInterface) *Node_GetInterface
type Node_GetMetadata ¶
func (Node_GetMetadata) Return ¶
func (_m Node_GetMetadata) Return(_a0 *core.NodeMetadata) *Node_GetMetadata
type Node_GetOutputAliases ¶
func (Node_GetOutputAliases) Return ¶
func (_m Node_GetOutputAliases) Return(_a0 []*core.Alias) *Node_GetOutputAliases
type Node_GetSubWorkflow ¶
func (Node_GetSubWorkflow) Return ¶
func (_m Node_GetSubWorkflow) Return(_a0 common.Workflow) *Node_GetSubWorkflow
type Node_GetTask ¶
func (Node_GetTask) Return ¶
func (_m Node_GetTask) Return(_a0 common.Task) *Node_GetTask
type Node_GetTaskNode ¶
func (Node_GetTaskNode) Return ¶
func (_m Node_GetTaskNode) Return(_a0 *core.TaskNode) *Node_GetTaskNode
type Node_GetUpstreamNodeIds ¶
func (Node_GetUpstreamNodeIds) Return ¶
func (_m Node_GetUpstreamNodeIds) Return(_a0 []string) *Node_GetUpstreamNodeIds
type Node_GetWorkflowNode ¶
func (Node_GetWorkflowNode) Return ¶
func (_m Node_GetWorkflowNode) Return(_a0 *core.WorkflowNode) *Node_GetWorkflowNode
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:
func (*Task) OnGetCoreTask ¶
func (_m *Task) OnGetCoreTask() *Task_GetCoreTask
func (*Task) OnGetCoreTaskMatch ¶
func (_m *Task) OnGetCoreTaskMatch(matchers ...interface{}) *Task_GetCoreTask
func (*Task) OnGetID ¶
func (_m *Task) OnGetID() *Task_GetID
func (*Task) OnGetIDMatch ¶
func (_m *Task) OnGetIDMatch(matchers ...interface{}) *Task_GetID
func (*Task) OnGetInterface ¶
func (_m *Task) OnGetInterface() *Task_GetInterface
func (*Task) OnGetInterfaceMatch ¶
func (_m *Task) OnGetInterfaceMatch(matchers ...interface{}) *Task_GetInterface
type Task_GetCoreTask ¶
func (Task_GetCoreTask) Return ¶
func (_m Task_GetCoreTask) Return(_a0 *core.TaskTemplate) *Task_GetCoreTask
type Task_GetID ¶
func (Task_GetID) Return ¶
func (_m Task_GetID) Return(_a0 core.Identifier) *Task_GetID
type Task_GetInterface ¶
func (Task_GetInterface) Return ¶
func (_m Task_GetInterface) Return(_a0 *core.TypedInterface) *Task_GetInterface
type Workflow ¶
Workflow is an autogenerated mock type for the Workflow type
func (*Workflow) GetCompiledSubWorkflow ¶
func (_m *Workflow) GetCompiledSubWorkflow(id core.Identifier) (*core.CompiledWorkflow, bool)
GetCompiledSubWorkflow provides a mock function with given fields: id
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:
func (*Workflow) OnGetCompiledSubWorkflow ¶
func (_m *Workflow) OnGetCompiledSubWorkflow(id core.Identifier) *Workflow_GetCompiledSubWorkflow
func (*Workflow) OnGetCompiledSubWorkflowMatch ¶
func (_m *Workflow) OnGetCompiledSubWorkflowMatch(matchers ...interface{}) *Workflow_GetCompiledSubWorkflow
func (*Workflow) OnGetCoreWorkflow ¶
func (_m *Workflow) OnGetCoreWorkflow() *Workflow_GetCoreWorkflow
func (*Workflow) OnGetCoreWorkflowMatch ¶
func (_m *Workflow) OnGetCoreWorkflowMatch(matchers ...interface{}) *Workflow_GetCoreWorkflow
func (*Workflow) OnGetDownstreamNodes ¶
func (_m *Workflow) OnGetDownstreamNodes() *Workflow_GetDownstreamNodes
func (*Workflow) OnGetDownstreamNodesMatch ¶
func (_m *Workflow) OnGetDownstreamNodesMatch(matchers ...interface{}) *Workflow_GetDownstreamNodes
func (*Workflow) OnGetFailureNode ¶
func (_m *Workflow) OnGetFailureNode() *Workflow_GetFailureNode
func (*Workflow) OnGetFailureNodeMatch ¶
func (_m *Workflow) OnGetFailureNodeMatch(matchers ...interface{}) *Workflow_GetFailureNode
func (*Workflow) OnGetLaunchPlan ¶
func (_m *Workflow) OnGetLaunchPlan(id core.Identifier) *Workflow_GetLaunchPlan
func (*Workflow) OnGetLaunchPlanMatch ¶
func (_m *Workflow) OnGetLaunchPlanMatch(matchers ...interface{}) *Workflow_GetLaunchPlan
func (*Workflow) OnGetNode ¶
func (_m *Workflow) OnGetNode(id string) *Workflow_GetNode
func (*Workflow) OnGetNodeMatch ¶
func (_m *Workflow) OnGetNodeMatch(matchers ...interface{}) *Workflow_GetNode
func (*Workflow) OnGetNodes ¶
func (_m *Workflow) OnGetNodes() *Workflow_GetNodes
func (*Workflow) OnGetNodesMatch ¶
func (_m *Workflow) OnGetNodesMatch(matchers ...interface{}) *Workflow_GetNodes
func (*Workflow) OnGetSubWorkflow ¶
func (_m *Workflow) OnGetSubWorkflow(id core.Identifier) *Workflow_GetSubWorkflow
func (*Workflow) OnGetSubWorkflowMatch ¶
func (_m *Workflow) OnGetSubWorkflowMatch(matchers ...interface{}) *Workflow_GetSubWorkflow
func (*Workflow) OnGetTask ¶
func (_m *Workflow) OnGetTask(id core.Identifier) *Workflow_GetTask
func (*Workflow) OnGetTaskMatch ¶
func (_m *Workflow) OnGetTaskMatch(matchers ...interface{}) *Workflow_GetTask
func (*Workflow) OnGetTasks ¶
func (_m *Workflow) OnGetTasks() *Workflow_GetTasks
func (*Workflow) OnGetTasksMatch ¶
func (_m *Workflow) OnGetTasksMatch(matchers ...interface{}) *Workflow_GetTasks
func (*Workflow) OnGetUpstreamNodes ¶
func (_m *Workflow) OnGetUpstreamNodes() *Workflow_GetUpstreamNodes
func (*Workflow) OnGetUpstreamNodesMatch ¶
func (_m *Workflow) OnGetUpstreamNodesMatch(matchers ...interface{}) *Workflow_GetUpstreamNodes
type WorkflowBuilder ¶
WorkflowBuilder is an autogenerated mock type for the WorkflowBuilder type
func (*WorkflowBuilder) AddDownstreamEdge ¶
func (_m *WorkflowBuilder) AddDownstreamEdge(nodeProvider string, nodeDependent string)
AddDownstreamEdge provides a mock function with given fields: nodeProvider, nodeDependent
func (*WorkflowBuilder) AddEdges ¶
func (_m *WorkflowBuilder) AddEdges(n common.NodeBuilder, edgeDirection common.EdgeDirection, errs errors.CompileErrors) bool
AddEdges provides a mock function with given fields: n, edgeDirection, errs
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) AddUpstreamEdge ¶
func (_m *WorkflowBuilder) AddUpstreamEdge(nodeProvider string, nodeDependent string)
AddUpstreamEdge provides a mock function with given fields: nodeProvider, nodeDependent
func (*WorkflowBuilder) GetCompiledSubWorkflow ¶
func (_m *WorkflowBuilder) GetCompiledSubWorkflow(id core.Identifier) (*core.CompiledWorkflow, bool)
GetCompiledSubWorkflow provides a mock function with given fields: id
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) GetOrCreateNodeBuilder ¶
func (_m *WorkflowBuilder) GetOrCreateNodeBuilder(n *core.Node) common.NodeBuilder
GetOrCreateNodeBuilder provides a mock function with given fields: n
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) OnAddEdges ¶
func (_m *WorkflowBuilder) OnAddEdges(n common.NodeBuilder, edgeDirection common.EdgeDirection, errs errors.CompileErrors) *WorkflowBuilder_AddEdges
func (*WorkflowBuilder) OnAddEdgesMatch ¶
func (_m *WorkflowBuilder) OnAddEdgesMatch(matchers ...interface{}) *WorkflowBuilder_AddEdges
func (*WorkflowBuilder) OnAddNode ¶
func (_m *WorkflowBuilder) OnAddNode(n common.NodeBuilder, errs errors.CompileErrors) *WorkflowBuilder_AddNode
func (*WorkflowBuilder) OnAddNodeMatch ¶
func (_m *WorkflowBuilder) OnAddNodeMatch(matchers ...interface{}) *WorkflowBuilder_AddNode
func (*WorkflowBuilder) OnGetCompiledSubWorkflow ¶
func (_m *WorkflowBuilder) OnGetCompiledSubWorkflow(id core.Identifier) *WorkflowBuilder_GetCompiledSubWorkflow
func (*WorkflowBuilder) OnGetCompiledSubWorkflowMatch ¶
func (_m *WorkflowBuilder) OnGetCompiledSubWorkflowMatch(matchers ...interface{}) *WorkflowBuilder_GetCompiledSubWorkflow
func (*WorkflowBuilder) OnGetCoreWorkflow ¶
func (_m *WorkflowBuilder) OnGetCoreWorkflow() *WorkflowBuilder_GetCoreWorkflow
func (*WorkflowBuilder) OnGetCoreWorkflowMatch ¶
func (_m *WorkflowBuilder) OnGetCoreWorkflowMatch(matchers ...interface{}) *WorkflowBuilder_GetCoreWorkflow
func (*WorkflowBuilder) OnGetDownstreamNodes ¶
func (_m *WorkflowBuilder) OnGetDownstreamNodes() *WorkflowBuilder_GetDownstreamNodes
func (*WorkflowBuilder) OnGetDownstreamNodesMatch ¶
func (_m *WorkflowBuilder) OnGetDownstreamNodesMatch(matchers ...interface{}) *WorkflowBuilder_GetDownstreamNodes
func (*WorkflowBuilder) OnGetFailureNode ¶
func (_m *WorkflowBuilder) OnGetFailureNode() *WorkflowBuilder_GetFailureNode
func (*WorkflowBuilder) OnGetFailureNodeMatch ¶
func (_m *WorkflowBuilder) OnGetFailureNodeMatch(matchers ...interface{}) *WorkflowBuilder_GetFailureNode
func (*WorkflowBuilder) OnGetLaunchPlan ¶
func (_m *WorkflowBuilder) OnGetLaunchPlan(id core.Identifier) *WorkflowBuilder_GetLaunchPlan
func (*WorkflowBuilder) OnGetLaunchPlanMatch ¶
func (_m *WorkflowBuilder) OnGetLaunchPlanMatch(matchers ...interface{}) *WorkflowBuilder_GetLaunchPlan
func (*WorkflowBuilder) OnGetNode ¶
func (_m *WorkflowBuilder) OnGetNode(id string) *WorkflowBuilder_GetNode
func (*WorkflowBuilder) OnGetNodeMatch ¶
func (_m *WorkflowBuilder) OnGetNodeMatch(matchers ...interface{}) *WorkflowBuilder_GetNode
func (*WorkflowBuilder) OnGetNodes ¶
func (_m *WorkflowBuilder) OnGetNodes() *WorkflowBuilder_GetNodes
func (*WorkflowBuilder) OnGetNodesMatch ¶
func (_m *WorkflowBuilder) OnGetNodesMatch(matchers ...interface{}) *WorkflowBuilder_GetNodes
func (*WorkflowBuilder) OnGetOrCreateNodeBuilder ¶
func (_m *WorkflowBuilder) OnGetOrCreateNodeBuilder(n *core.Node) *WorkflowBuilder_GetOrCreateNodeBuilder
func (*WorkflowBuilder) OnGetOrCreateNodeBuilderMatch ¶
func (_m *WorkflowBuilder) OnGetOrCreateNodeBuilderMatch(matchers ...interface{}) *WorkflowBuilder_GetOrCreateNodeBuilder
func (*WorkflowBuilder) OnGetSubWorkflow ¶
func (_m *WorkflowBuilder) OnGetSubWorkflow(id core.Identifier) *WorkflowBuilder_GetSubWorkflow
func (*WorkflowBuilder) OnGetSubWorkflowMatch ¶
func (_m *WorkflowBuilder) OnGetSubWorkflowMatch(matchers ...interface{}) *WorkflowBuilder_GetSubWorkflow
func (*WorkflowBuilder) OnGetTask ¶
func (_m *WorkflowBuilder) OnGetTask(id core.Identifier) *WorkflowBuilder_GetTask
func (*WorkflowBuilder) OnGetTaskMatch ¶
func (_m *WorkflowBuilder) OnGetTaskMatch(matchers ...interface{}) *WorkflowBuilder_GetTask
func (*WorkflowBuilder) OnGetTasks ¶
func (_m *WorkflowBuilder) OnGetTasks() *WorkflowBuilder_GetTasks
func (*WorkflowBuilder) OnGetTasksMatch ¶
func (_m *WorkflowBuilder) OnGetTasksMatch(matchers ...interface{}) *WorkflowBuilder_GetTasks
func (*WorkflowBuilder) OnGetUpstreamNodes ¶
func (_m *WorkflowBuilder) OnGetUpstreamNodes() *WorkflowBuilder_GetUpstreamNodes
func (*WorkflowBuilder) OnGetUpstreamNodesMatch ¶
func (_m *WorkflowBuilder) OnGetUpstreamNodesMatch(matchers ...interface{}) *WorkflowBuilder_GetUpstreamNodes
func (*WorkflowBuilder) OnValidateWorkflow ¶
func (_m *WorkflowBuilder) OnValidateWorkflow(fg *core.CompiledWorkflow, errs errors.CompileErrors) *WorkflowBuilder_ValidateWorkflow
func (*WorkflowBuilder) OnValidateWorkflowMatch ¶
func (_m *WorkflowBuilder) OnValidateWorkflowMatch(matchers ...interface{}) *WorkflowBuilder_ValidateWorkflow
func (*WorkflowBuilder) StoreCompiledSubWorkflow ¶
func (_m *WorkflowBuilder) StoreCompiledSubWorkflow(id core.Identifier, compiledWorkflow *core.CompiledWorkflow)
StoreCompiledSubWorkflow provides a mock function with given fields: id, compiledWorkflow
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
type WorkflowBuilder_AddEdges ¶
func (WorkflowBuilder_AddEdges) Return ¶
func (_m WorkflowBuilder_AddEdges) Return(ok bool) *WorkflowBuilder_AddEdges
type WorkflowBuilder_AddNode ¶
func (WorkflowBuilder_AddNode) Return ¶
func (_m WorkflowBuilder_AddNode) Return(node common.NodeBuilder, ok bool) *WorkflowBuilder_AddNode
type WorkflowBuilder_GetCompiledSubWorkflow ¶
func (WorkflowBuilder_GetCompiledSubWorkflow) Return ¶
func (_m WorkflowBuilder_GetCompiledSubWorkflow) Return(wf *core.CompiledWorkflow, found bool) *WorkflowBuilder_GetCompiledSubWorkflow
type WorkflowBuilder_GetCoreWorkflow ¶
func (WorkflowBuilder_GetCoreWorkflow) Return ¶
func (_m WorkflowBuilder_GetCoreWorkflow) Return(_a0 *core.CompiledWorkflow) *WorkflowBuilder_GetCoreWorkflow
type WorkflowBuilder_GetDownstreamNodes ¶
func (WorkflowBuilder_GetDownstreamNodes) Return ¶
func (_m WorkflowBuilder_GetDownstreamNodes) Return(_a0 common.StringAdjacencyList) *WorkflowBuilder_GetDownstreamNodes
type WorkflowBuilder_GetFailureNode ¶
func (WorkflowBuilder_GetFailureNode) Return ¶
func (_m WorkflowBuilder_GetFailureNode) Return(_a0 common.Node) *WorkflowBuilder_GetFailureNode
type WorkflowBuilder_GetLaunchPlan ¶
func (WorkflowBuilder_GetLaunchPlan) Return ¶
func (_m WorkflowBuilder_GetLaunchPlan) Return(wf common.InterfaceProvider, found bool) *WorkflowBuilder_GetLaunchPlan
type WorkflowBuilder_GetNode ¶
func (WorkflowBuilder_GetNode) Return ¶
func (_m WorkflowBuilder_GetNode) Return(node common.NodeBuilder, found bool) *WorkflowBuilder_GetNode
type WorkflowBuilder_GetNodes ¶
func (WorkflowBuilder_GetNodes) Return ¶
func (_m WorkflowBuilder_GetNodes) Return(_a0 common.NodeIndex) *WorkflowBuilder_GetNodes
type WorkflowBuilder_GetOrCreateNodeBuilder ¶
func (WorkflowBuilder_GetOrCreateNodeBuilder) Return ¶
func (_m WorkflowBuilder_GetOrCreateNodeBuilder) Return(_a0 common.NodeBuilder) *WorkflowBuilder_GetOrCreateNodeBuilder
type WorkflowBuilder_GetSubWorkflow ¶
func (WorkflowBuilder_GetSubWorkflow) Return ¶
func (_m WorkflowBuilder_GetSubWorkflow) Return(wf *core.CompiledWorkflow, found bool) *WorkflowBuilder_GetSubWorkflow
type WorkflowBuilder_GetTask ¶
func (WorkflowBuilder_GetTask) Return ¶
func (_m WorkflowBuilder_GetTask) Return(task common.Task, found bool) *WorkflowBuilder_GetTask
type WorkflowBuilder_GetTasks ¶
func (WorkflowBuilder_GetTasks) Return ¶
func (_m WorkflowBuilder_GetTasks) Return(_a0 common.TaskIndex) *WorkflowBuilder_GetTasks
type WorkflowBuilder_GetUpstreamNodes ¶
func (WorkflowBuilder_GetUpstreamNodes) Return ¶
func (_m WorkflowBuilder_GetUpstreamNodes) Return(_a0 common.StringAdjacencyList) *WorkflowBuilder_GetUpstreamNodes
type WorkflowBuilder_ValidateWorkflow ¶
func (WorkflowBuilder_ValidateWorkflow) Return ¶
func (_m WorkflowBuilder_ValidateWorkflow) Return(_a0 common.Workflow, _a1 bool) *WorkflowBuilder_ValidateWorkflow
type Workflow_GetCompiledSubWorkflow ¶
func (Workflow_GetCompiledSubWorkflow) Return ¶
func (_m Workflow_GetCompiledSubWorkflow) Return(wf *core.CompiledWorkflow, found bool) *Workflow_GetCompiledSubWorkflow
type Workflow_GetCoreWorkflow ¶
func (Workflow_GetCoreWorkflow) Return ¶
func (_m Workflow_GetCoreWorkflow) Return(_a0 *core.CompiledWorkflow) *Workflow_GetCoreWorkflow
type Workflow_GetDownstreamNodes ¶
func (Workflow_GetDownstreamNodes) Return ¶
func (_m Workflow_GetDownstreamNodes) Return(_a0 common.StringAdjacencyList) *Workflow_GetDownstreamNodes
type Workflow_GetFailureNode ¶
func (Workflow_GetFailureNode) Return ¶
func (_m Workflow_GetFailureNode) Return(_a0 common.Node) *Workflow_GetFailureNode
type Workflow_GetLaunchPlan ¶
func (Workflow_GetLaunchPlan) Return ¶
func (_m Workflow_GetLaunchPlan) Return(wf common.InterfaceProvider, found bool) *Workflow_GetLaunchPlan
type Workflow_GetNode ¶
func (Workflow_GetNode) Return ¶
func (_m Workflow_GetNode) Return(node common.NodeBuilder, found bool) *Workflow_GetNode
type Workflow_GetNodes ¶
func (Workflow_GetNodes) Return ¶
func (_m Workflow_GetNodes) Return(_a0 common.NodeIndex) *Workflow_GetNodes
type Workflow_GetSubWorkflow ¶
func (Workflow_GetSubWorkflow) Return ¶
func (_m Workflow_GetSubWorkflow) Return(wf *core.CompiledWorkflow, found bool) *Workflow_GetSubWorkflow
type Workflow_GetTask ¶
func (Workflow_GetTask) Return ¶
func (_m Workflow_GetTask) Return(task common.Task, found bool) *Workflow_GetTask
type Workflow_GetTasks ¶
func (Workflow_GetTasks) Return ¶
func (_m Workflow_GetTasks) Return(_a0 common.TaskIndex) *Workflow_GetTasks
type Workflow_GetUpstreamNodes ¶
func (Workflow_GetUpstreamNodes) Return ¶
func (_m Workflow_GetUpstreamNodes) Return(_a0 common.StringAdjacencyList) *Workflow_GetUpstreamNodes