mocks

package
v1.0.1 Latest Latest
Warning

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

Go to latest
Published: Feb 21, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 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

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 (*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 (*TaskNodeHandler) OnGetCatalogKeyMatch

func (_m *TaskNodeHandler) OnGetCatalogKeyMatch(matchers ...interface{}) *TaskNodeHandler_GetCatalogKey

func (*TaskNodeHandler) OnHandle

func (*TaskNodeHandler) OnHandleMatch

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

func (*TaskNodeHandler) OnIsCacheable

func (*TaskNodeHandler) OnIsCacheableMatch

func (_m *TaskNodeHandler) OnIsCacheableMatch(matchers ...interface{}) *TaskNodeHandler_IsCacheable

func (*TaskNodeHandler) OnSetup

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

type TaskNodeHandler_Abort struct {
	*mock.Call
}

func (TaskNodeHandler_Abort) Return

type TaskNodeHandler_Finalize

type TaskNodeHandler_Finalize struct {
	*mock.Call
}

func (TaskNodeHandler_Finalize) Return

type TaskNodeHandler_FinalizeRequired

type TaskNodeHandler_FinalizeRequired struct {
	*mock.Call
}

func (TaskNodeHandler_FinalizeRequired) Return

type TaskNodeHandler_GetCatalogKey

type TaskNodeHandler_GetCatalogKey struct {
	*mock.Call
}

func (TaskNodeHandler_GetCatalogKey) Return

type TaskNodeHandler_Handle

type TaskNodeHandler_Handle struct {
	*mock.Call
}

func (TaskNodeHandler_Handle) Return

type TaskNodeHandler_IsCacheable

type TaskNodeHandler_IsCacheable struct {
	*mock.Call
}

func (TaskNodeHandler_IsCacheable) Return

type TaskNodeHandler_Setup

type TaskNodeHandler_Setup struct {
	*mock.Call
}

func (TaskNodeHandler_Setup) Return

type TaskNodeHandler_ValidateOutput

type TaskNodeHandler_ValidateOutput struct {
	*mock.Call
}

func (TaskNodeHandler_ValidateOutput) Return

Jump to

Keyboard shortcuts

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