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) GetCatalogKey(ctx context.Context, executionContext interfaces.NodeExecutionContext) (catalog.Key, error)
- func (_m *TaskNodeHandler) Handle(ctx context.Context, executionContext interfaces.NodeExecutionContext) (handler.Transition, error)
- func (_m *TaskNodeHandler) IsCacheable(ctx context.Context, executionContext interfaces.NodeExecutionContext) (bool, bool, 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) OnGetCatalogKey(ctx context.Context, executionContext interfaces.NodeExecutionContext) *TaskNodeHandler_GetCatalogKey
- func (_m *TaskNodeHandler) OnGetCatalogKeyMatch(matchers ...interface{}) *TaskNodeHandler_GetCatalogKey
- func (_m *TaskNodeHandler) OnHandle(ctx context.Context, executionContext interfaces.NodeExecutionContext) *TaskNodeHandler_Handle
- func (_m *TaskNodeHandler) OnHandleMatch(matchers ...interface{}) *TaskNodeHandler_Handle
- func (_m *TaskNodeHandler) OnIsCacheable(ctx context.Context, executionContext interfaces.NodeExecutionContext) *TaskNodeHandler_IsCacheable
- func (_m *TaskNodeHandler) OnIsCacheableMatch(matchers ...interface{}) *TaskNodeHandler_IsCacheable
- func (_m *TaskNodeHandler) OnSetup(ctx context.Context, setupContext interfaces.SetupContext) *TaskNodeHandler_Setup
- func (_m *TaskNodeHandler) OnSetupMatch(matchers ...interface{}) *TaskNodeHandler_Setup
- func (_m *TaskNodeHandler) OnValidateOutput(ctx context.Context, nodeID string, i io.InputReader, r io.OutputReader, ...) *TaskNodeHandler_ValidateOutput
- func (_m *TaskNodeHandler) OnValidateOutputMatch(matchers ...interface{}) *TaskNodeHandler_ValidateOutput
- func (_m *TaskNodeHandler) Setup(ctx context.Context, setupContext interfaces.SetupContext) error
- func (_m *TaskNodeHandler) ValidateOutput(ctx context.Context, nodeID string, i io.InputReader, r io.OutputReader, ...) (*io.ExecutionError, error)
- type TaskNodeHandler_Abort
- type TaskNodeHandler_Finalize
- type TaskNodeHandler_FinalizeRequired
- type TaskNodeHandler_GetCatalogKey
- type TaskNodeHandler_Handle
- type TaskNodeHandler_IsCacheable
- type TaskNodeHandler_Setup
- type TaskNodeHandler_ValidateOutput
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) GetCatalogKey ¶
func (_m *TaskNodeHandler) GetCatalogKey(ctx context.Context, executionContext interfaces.NodeExecutionContext) (catalog.Key, error)
GetCatalogKey provides a mock function with given fields: ctx, executionContext
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) IsCacheable ¶
func (_m *TaskNodeHandler) IsCacheable(ctx context.Context, executionContext interfaces.NodeExecutionContext) (bool, bool, error)
IsCacheable 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) OnGetCatalogKey ¶
func (_m *TaskNodeHandler) OnGetCatalogKey(ctx context.Context, executionContext interfaces.NodeExecutionContext) *TaskNodeHandler_GetCatalogKey
func (*TaskNodeHandler) OnGetCatalogKeyMatch ¶
func (_m *TaskNodeHandler) OnGetCatalogKeyMatch(matchers ...interface{}) *TaskNodeHandler_GetCatalogKey
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) OnIsCacheable ¶
func (_m *TaskNodeHandler) OnIsCacheable(ctx context.Context, executionContext interfaces.NodeExecutionContext) *TaskNodeHandler_IsCacheable
func (*TaskNodeHandler) OnIsCacheableMatch ¶
func (_m *TaskNodeHandler) OnIsCacheableMatch(matchers ...interface{}) *TaskNodeHandler_IsCacheable
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) OnValidateOutput ¶
func (_m *TaskNodeHandler) OnValidateOutput(ctx context.Context, nodeID string, i io.InputReader, r io.OutputReader, outputCommitter io.OutputWriter, executionConfig v1alpha1.ExecutionConfig, tr ioutils.SimpleTaskReader) *TaskNodeHandler_ValidateOutput
func (*TaskNodeHandler) OnValidateOutputMatch ¶
func (_m *TaskNodeHandler) OnValidateOutputMatch(matchers ...interface{}) *TaskNodeHandler_ValidateOutput
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) ValidateOutput ¶
func (_m *TaskNodeHandler) ValidateOutput(ctx context.Context, nodeID string, i io.InputReader, r io.OutputReader, outputCommitter io.OutputWriter, executionConfig v1alpha1.ExecutionConfig, tr ioutils.SimpleTaskReader) (*io.ExecutionError, error)
ValidateOutput provides a mock function with given fields: ctx, nodeID, i, r, outputCommitter, executionConfig, tr
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_GetCatalogKey ¶
func (TaskNodeHandler_GetCatalogKey) Return ¶
func (_m TaskNodeHandler_GetCatalogKey) Return(_a0 catalog.Key, _a1 error) *TaskNodeHandler_GetCatalogKey
type TaskNodeHandler_Handle ¶
func (TaskNodeHandler_Handle) Return ¶
func (_m TaskNodeHandler_Handle) Return(_a0 handler.Transition, _a1 error) *TaskNodeHandler_Handle
type TaskNodeHandler_IsCacheable ¶
func (TaskNodeHandler_IsCacheable) Return ¶
func (_m TaskNodeHandler_IsCacheable) Return(_a0 bool, _a1 bool, _a2 error) *TaskNodeHandler_IsCacheable
type TaskNodeHandler_Setup ¶
func (TaskNodeHandler_Setup) Return ¶
func (_m TaskNodeHandler_Setup) Return(_a0 error) *TaskNodeHandler_Setup
type TaskNodeHandler_ValidateOutput ¶
func (TaskNodeHandler_ValidateOutput) Return ¶
func (_m TaskNodeHandler_ValidateOutput) Return(_a0 *io.ExecutionError, _a1 error) *TaskNodeHandler_ValidateOutput