mocks

package
v0.2.5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 7, 2020 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

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 ExecuteWorkflowFunc added in v0.1.1

type ExecuteWorkflowFunc func(input interfaces.ExecuteWorkflowInput) (*interfaces.ExecutionInfo, 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 (*MockExecutor) SetExecuteWorkflowCallback

func (c *MockExecutor) SetExecuteWorkflowCallback(callback ExecuteWorkflowFunc)

func (*MockExecutor) SetTerminateExecutionCallback

func (c *MockExecutor) SetTerminateExecutionCallback(callback TerminateWorkflowExecutionFunc)

func (*MockExecutor) TerminateWorkflowExecution

func (c *MockExecutor) TerminateWorkflowExecution(ctx context.Context, input interfaces.TerminateWorkflowInput) error

type TerminateWorkflowExecutionFunc

type TerminateWorkflowExecutionFunc func(ctx context.Context, input interfaces.TerminateWorkflowInput) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL