mocks

Documentation

Index

• type TaskNodeHandler
  • func (_m *TaskNodeHandler) Abort(ctx context.Context, executionContext handler.NodeExecutionContext, ...) error
  • func (_m *TaskNodeHandler) Finalize(ctx context.Context, executionContext handler.NodeExecutionContext) error
  • func (_m *TaskNodeHandler) FinalizeRequired() bool
  • func (_m *TaskNodeHandler) Handle(ctx context.Context, executionContext handler.NodeExecutionContext) (handler.Transition, error)
  • func (_m *TaskNodeHandler) OnAbort(ctx context.Context, executionContext handler.NodeExecutionContext, ...) *TaskNodeHandler_Abort
  • func (_m *TaskNodeHandler) OnAbortMatch(matchers ...interface{}) *TaskNodeHandler_Abort
  • func (_m *TaskNodeHandler) OnFinalize(ctx context.Context, executionContext handler.NodeExecutionContext) *TaskNodeHandler_Finalize
  • func (_m *TaskNodeHandler) OnFinalizeMatch(matchers ...interface{}) *TaskNodeHandler_Finalize
  • func (_m *TaskNodeHandler) OnFinalizeRequired() *TaskNodeHandler_FinalizeRequired
  • func (_m *TaskNodeHandler) OnFinalizeRequiredMatch(matchers ...interface{}) *TaskNodeHandler_FinalizeRequired
  • func (_m *TaskNodeHandler) OnHandle(ctx context.Context, executionContext handler.NodeExecutionContext) *TaskNodeHandler_Handle
  • func (_m *TaskNodeHandler) OnHandleMatch(matchers ...interface{}) *TaskNodeHandler_Handle
  • func (_m *TaskNodeHandler) OnSetup(ctx context.Context, setupContext handler.SetupContext) *TaskNodeHandler_Setup
  • func (_m *TaskNodeHandler) OnSetupMatch(matchers ...interface{}) *TaskNodeHandler_Setup
  • func (_m *TaskNodeHandler) OnValidateOutputAndCacheAdd(ctx context.Context, nodeID string, i io.InputReader, r io.OutputReader, ...) *TaskNodeHandler_ValidateOutputAndCacheAdd
  • func (_m *TaskNodeHandler) OnValidateOutputAndCacheAddMatch(matchers ...interface{}) *TaskNodeHandler_ValidateOutputAndCacheAdd
  • func (_m *TaskNodeHandler) Setup(ctx context.Context, setupContext handler.SetupContext) error
  • func (_m *TaskNodeHandler) ValidateOutputAndCacheAdd(ctx context.Context, nodeID string, i io.InputReader, r io.OutputReader, ...) (catalog.Status, *io.ExecutionError, error)
• type TaskNodeHandler_Abort
  • func (_m TaskNodeHandler_Abort) Return(_a0 error) *TaskNodeHandler_Abort
• type TaskNodeHandler_Finalize
  • func (_m TaskNodeHandler_Finalize) Return(_a0 error) *TaskNodeHandler_Finalize
• type TaskNodeHandler_FinalizeRequired
  • func (_m TaskNodeHandler_FinalizeRequired) Return(_a0 bool) *TaskNodeHandler_FinalizeRequired
• type TaskNodeHandler_Handle
  • func (_m TaskNodeHandler_Handle) Return(_a0 handler.Transition, _a1 error) *TaskNodeHandler_Handle
• type TaskNodeHandler_Setup
  • func (_m TaskNodeHandler_Setup) Return(_a0 error) *TaskNodeHandler_Setup
• type TaskNodeHandler_ValidateOutputAndCacheAdd
  • func (_m TaskNodeHandler_ValidateOutputAndCacheAdd) Return(_a0 catalog.Status, _a1 *io.ExecutionError, _a2 error) *TaskNodeHandler_ValidateOutputAndCacheAdd

Types

type TaskNodeHandler

type TaskNodeHandler struct {
	mock.Mock
}

TaskNodeHandler is an autogenerated mock type for the TaskNodeHandler type

func (*TaskNodeHandler) Abort

func (_m *TaskNodeHandler) Abort(ctx context.Context, executionContext handler.NodeExecutionContext, reason string) error

Abort provides a mock function with given fields: ctx, executionContext, reason

func (*TaskNodeHandler) Finalize

func (_m *TaskNodeHandler) Finalize(ctx context.Context, executionContext handler.NodeExecutionContext) error

Finalize provides a mock function with given fields: ctx, executionContext

func (*TaskNodeHandler) FinalizeRequired

func (_m *TaskNodeHandler) FinalizeRequired() bool

FinalizeRequired provides a mock function with given fields:

func (*TaskNodeHandler) Handle

func (_m *TaskNodeHandler) Handle(ctx context.Context, executionContext handler.NodeExecutionContext) (handler.Transition, error)

Handle provides a mock function with given fields: ctx, executionContext

func (*TaskNodeHandler) OnAbort

func (_m *TaskNodeHandler) OnAbort(ctx context.Context, executionContext handler.NodeExecutionContext, reason string) *TaskNodeHandler_Abort

func (*TaskNodeHandler) OnAbortMatch

func (_m *TaskNodeHandler) OnAbortMatch(matchers ...interface{}) *TaskNodeHandler_Abort

func (*TaskNodeHandler) OnFinalize

func (_m *TaskNodeHandler) OnFinalize(ctx context.Context, executionContext handler.NodeExecutionContext) *TaskNodeHandler_Finalize

func (*TaskNodeHandler) OnFinalizeMatch

func (_m *TaskNodeHandler) OnFinalizeMatch(matchers ...interface{}) *TaskNodeHandler_Finalize

func (*TaskNodeHandler) OnFinalizeRequired

func (_m *TaskNodeHandler) OnFinalizeRequired() *TaskNodeHandler_FinalizeRequired

func (*TaskNodeHandler) OnFinalizeRequiredMatch

func (_m *TaskNodeHandler) OnFinalizeRequiredMatch(matchers ...interface{}) *TaskNodeHandler_FinalizeRequired

func (*TaskNodeHandler) OnHandle

func (_m *TaskNodeHandler) OnHandle(ctx context.Context, executionContext handler.NodeExecutionContext) *TaskNodeHandler_Handle

func (*TaskNodeHandler) OnHandleMatch

func (_m *TaskNodeHandler) OnHandleMatch(matchers ...interface{}) *TaskNodeHandler_Handle

func (*TaskNodeHandler) OnSetup

func (_m *TaskNodeHandler) OnSetup(ctx context.Context, setupContext handler.SetupContext) *TaskNodeHandler_Setup

func (*TaskNodeHandler) OnSetupMatch

func (_m *TaskNodeHandler) OnSetupMatch(matchers ...interface{}) *TaskNodeHandler_Setup

func (*TaskNodeHandler) OnValidateOutputAndCacheAdd

func (_m *TaskNodeHandler) OnValidateOutputAndCacheAdd(ctx context.Context, nodeID string, i io.InputReader, r io.OutputReader, outputCommitter io.OutputWriter, tr core.TaskReader, m catalog.Metadata) *TaskNodeHandler_ValidateOutputAndCacheAdd

func (*TaskNodeHandler) OnValidateOutputAndCacheAddMatch

func (_m *TaskNodeHandler) OnValidateOutputAndCacheAddMatch(matchers ...interface{}) *TaskNodeHandler_ValidateOutputAndCacheAdd

func (*TaskNodeHandler) Setup

func (_m *TaskNodeHandler) Setup(ctx context.Context, setupContext handler.SetupContext) error

Setup provides a mock function with given fields: ctx, setupContext

func (*TaskNodeHandler) ValidateOutputAndCacheAdd

func (_m *TaskNodeHandler) ValidateOutputAndCacheAdd(ctx context.Context, nodeID string, i io.InputReader, r io.OutputReader, outputCommitter io.OutputWriter, tr core.TaskReader, m catalog.Metadata) (catalog.Status, *io.ExecutionError, error)

ValidateOutputAndCacheAdd provides a mock function with given fields: ctx, nodeID, i, r, outputCommitter, tr, m

type TaskNodeHandler_Abort

type TaskNodeHandler_Abort struct {
	*mock.Call
}

func (TaskNodeHandler_Abort) Return

func (_m TaskNodeHandler_Abort) Return(_a0 error) *TaskNodeHandler_Abort

type TaskNodeHandler_Finalize

type TaskNodeHandler_Finalize struct {
	*mock.Call
}

func (TaskNodeHandler_Finalize) Return

func (_m TaskNodeHandler_Finalize) Return(_a0 error) *TaskNodeHandler_Finalize

type TaskNodeHandler_FinalizeRequired

type TaskNodeHandler_FinalizeRequired struct {
	*mock.Call
}

func (TaskNodeHandler_FinalizeRequired) Return

func (_m TaskNodeHandler_FinalizeRequired) Return(_a0 bool) *TaskNodeHandler_FinalizeRequired

type TaskNodeHandler_Handle

type TaskNodeHandler_Handle struct {
	*mock.Call
}

func (TaskNodeHandler_Handle) Return

func (_m TaskNodeHandler_Handle) Return(_a0 handler.Transition, _a1 error) *TaskNodeHandler_Handle

type TaskNodeHandler_Setup

type TaskNodeHandler_Setup struct {
	*mock.Call
}

func (TaskNodeHandler_Setup) Return

func (_m TaskNodeHandler_Setup) Return(_a0 error) *TaskNodeHandler_Setup

type TaskNodeHandler_ValidateOutputAndCacheAdd

type TaskNodeHandler_ValidateOutputAndCacheAdd struct {
	*mock.Call
}

func (TaskNodeHandler_ValidateOutputAndCacheAdd) Return

func (_m TaskNodeHandler_ValidateOutputAndCacheAdd) Return(_a0 catalog.Status, _a1 *io.ExecutionError, _a2 error) *TaskNodeHandler_ValidateOutputAndCacheAdd