Documentation
¶
Index ¶
- func NewMockCompiler() interfaces.Compiler
- func NewMockExecutor() interfaces.Executor
- type CreateExecutionFunc
- type MockCompiler
- func (c *MockCompiler) AddCompileTaskCallback(callback func(task *core.TaskTemplate) (*core.CompiledTask, error))
- func (c *MockCompiler) AddCompileWorkflowCallback(...)
- func (c *MockCompiler) AddGetRequirementCallback(...)
- func (c *MockCompiler) CompileTask(task *core.TaskTemplate) (*core.CompiledTask, error)
- func (c *MockCompiler) CompileWorkflow(primaryWf *core.WorkflowTemplate, subworkflows []*core.WorkflowTemplate, ...) (*core.CompiledWorkflowClosure, error)
- func (c *MockCompiler) GetRequirements(fg *core.WorkflowTemplate, subWfs []*core.WorkflowTemplate) (reqs compiler.WorkflowExecutionRequirements, err error)
- type MockExecutor
- func (c *MockExecutor) ExecuteWorkflow(ctx context.Context, inputs interfaces.ExecuteWorkflowInputs) error
- func (c *MockExecutor) SetExecuteWorkflowCallback(callback CreateExecutionFunc)
- func (c *MockExecutor) SetTerminateExecutionCallback(callback TerminateWorkflowExecutionFunc)
- func (c *MockExecutor) TerminateWorkflowExecution(ctx context.Context, executionID *core.WorkflowExecutionIdentifier) error
- type TerminateWorkflowExecutionFunc
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewMockCompiler ¶
func NewMockCompiler() interfaces.Compiler
func NewMockExecutor ¶
func NewMockExecutor() interfaces.Executor
Types ¶
type CreateExecutionFunc ¶
type CreateExecutionFunc func(inputs interfaces.ExecuteWorkflowInputs) error
type MockCompiler ¶
type MockCompiler struct {
// contains filtered or unexported fields
}
func (*MockCompiler) AddCompileTaskCallback ¶
func (c *MockCompiler) AddCompileTaskCallback( callback func(task *core.TaskTemplate) (*core.CompiledTask, error))
func (*MockCompiler) AddCompileWorkflowCallback ¶
func (c *MockCompiler) AddCompileWorkflowCallback(callback func( primaryWf *core.WorkflowTemplate, subworkflows []*core.WorkflowTemplate, tasks []*core.CompiledTask, launchPlans []common.InterfaceProvider) (*core.CompiledWorkflowClosure, error))
func (*MockCompiler) AddGetRequirementCallback ¶
func (c *MockCompiler) AddGetRequirementCallback( callback func(fg *core.WorkflowTemplate, subWfs []*core.WorkflowTemplate) ( reqs compiler.WorkflowExecutionRequirements, err error))
func (*MockCompiler) CompileTask ¶
func (c *MockCompiler) CompileTask(task *core.TaskTemplate) (*core.CompiledTask, error)
func (*MockCompiler) CompileWorkflow ¶
func (c *MockCompiler) CompileWorkflow( primaryWf *core.WorkflowTemplate, subworkflows []*core.WorkflowTemplate, tasks []*core.CompiledTask, launchPlans []common.InterfaceProvider) (*core.CompiledWorkflowClosure, error)
func (*MockCompiler) GetRequirements ¶
func (c *MockCompiler) GetRequirements(fg *core.WorkflowTemplate, subWfs []*core.WorkflowTemplate) ( reqs compiler.WorkflowExecutionRequirements, err error)
type MockExecutor ¶
type MockExecutor struct {
// contains filtered or unexported fields
}
func (*MockExecutor) ExecuteWorkflow ¶
func (c *MockExecutor) ExecuteWorkflow( ctx context.Context, inputs interfaces.ExecuteWorkflowInputs) error
func (*MockExecutor) SetExecuteWorkflowCallback ¶
func (c *MockExecutor) SetExecuteWorkflowCallback(callback CreateExecutionFunc)
func (*MockExecutor) SetTerminateExecutionCallback ¶
func (c *MockExecutor) SetTerminateExecutionCallback(callback TerminateWorkflowExecutionFunc)
func (*MockExecutor) TerminateWorkflowExecution ¶
func (c *MockExecutor) TerminateWorkflowExecution(ctx context.Context, executionID *core.WorkflowExecutionIdentifier) error
Source Files
¶
- mock_compiler.go
- mock_executor.go
Click to show internal directories.
Click to hide internal directories.