Documentation ¶
Index ¶
- type TaskNodeHandler
- func (_m *TaskNodeHandler) Abort(ctx context.Context, executionContext interfaces.NodeExecutionContext, ...) error
- func (_m *TaskNodeHandler) Finalize(ctx context.Context, executionContext interfaces.NodeExecutionContext) error
- func (_m *TaskNodeHandler) FinalizeRequired() bool
- func (_m *TaskNodeHandler) Handle(ctx context.Context, executionContext interfaces.NodeExecutionContext) (handler.Transition, error)
- func (_m *TaskNodeHandler) OnAbort(ctx context.Context, executionContext interfaces.NodeExecutionContext, ...) *TaskNodeHandler_Abort
- func (_m *TaskNodeHandler) OnAbortMatch(matchers ...interface{}) *TaskNodeHandler_Abort
- func (_m *TaskNodeHandler) OnFinalize(ctx context.Context, executionContext interfaces.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 interfaces.NodeExecutionContext) *TaskNodeHandler_Handle
- func (_m *TaskNodeHandler) OnHandleMatch(matchers ...interface{}) *TaskNodeHandler_Handle
- func (_m *TaskNodeHandler) OnSetup(ctx context.Context, setupContext interfaces.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 interfaces.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
- type TaskNodeHandler_Finalize
- type TaskNodeHandler_FinalizeRequired
- type TaskNodeHandler_Handle
- type TaskNodeHandler_Setup
- type TaskNodeHandler_ValidateOutputAndCacheAdd
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type TaskNodeHandler ¶
TaskNodeHandler is an autogenerated mock type for the TaskNodeHandler type
func (*TaskNodeHandler) Abort ¶
func (_m *TaskNodeHandler) Abort(ctx context.Context, executionContext interfaces.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 interfaces.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 interfaces.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 interfaces.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 interfaces.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 interfaces.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 interfaces.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, executionConfig v1alpha1.ExecutionConfig, tr ioutils.SimpleTaskReader, 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 interfaces.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, executionConfig v1alpha1.ExecutionConfig, tr ioutils.SimpleTaskReader, m catalog.Metadata) (catalog.Status, *io.ExecutionError, error)
ValidateOutputAndCacheAdd provides a mock function with given fields: ctx, nodeID, i, r, outputCommitter, executionConfig, tr, m
type TaskNodeHandler_Abort ¶
func (TaskNodeHandler_Abort) Return ¶
func (_m TaskNodeHandler_Abort) Return(_a0 error) *TaskNodeHandler_Abort
type TaskNodeHandler_Finalize ¶
func (TaskNodeHandler_Finalize) Return ¶
func (_m TaskNodeHandler_Finalize) Return(_a0 error) *TaskNodeHandler_Finalize
type TaskNodeHandler_FinalizeRequired ¶
func (TaskNodeHandler_FinalizeRequired) Return ¶
func (_m TaskNodeHandler_FinalizeRequired) Return(_a0 bool) *TaskNodeHandler_FinalizeRequired
type TaskNodeHandler_Handle ¶
func (TaskNodeHandler_Handle) Return ¶
func (_m TaskNodeHandler_Handle) Return(_a0 handler.Transition, _a1 error) *TaskNodeHandler_Handle
type TaskNodeHandler_Setup ¶
func (TaskNodeHandler_Setup) Return ¶
func (_m TaskNodeHandler_Setup) Return(_a0 error) *TaskNodeHandler_Setup
type TaskNodeHandler_ValidateOutputAndCacheAdd ¶
func (TaskNodeHandler_ValidateOutputAndCacheAdd) Return ¶
func (_m TaskNodeHandler_ValidateOutputAndCacheAdd) Return(_a0 catalog.Status, _a1 *io.ExecutionError, _a2 error) *TaskNodeHandler_ValidateOutputAndCacheAdd
Click to show internal directories.
Click to hide internal directories.