mocks

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

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

type TerminateWorkflowExecutionFunc

type TerminateWorkflowExecutionFunc func(ctx context.Context, executionID *core.WorkflowExecutionIdentifier) error