mocks

package
v1.16.4 Latest Latest
Warning

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

 Go to latest Published: Feb 12, 2026 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 NewTaskNodeHandler added in v1.15.1 

func NewTaskNodeHandler(t interface {
	mock.TestingT
	Cleanup(func())
}) *TaskNodeHandler

NewTaskNodeHandler creates a new instance of TaskNodeHandler. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

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) EXPECT added in v1.15.1 

func (_m *TaskNodeHandler) EXPECT() *TaskNodeHandler_Expecter

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 no 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) 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_Call added in v1.15.1 

type TaskNodeHandler_Abort_Call struct {
	*mock.Call
}

TaskNodeHandler_Abort_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Abort'

func (*TaskNodeHandler_Abort_Call) Return added in v1.15.1 

func (_c *TaskNodeHandler_Abort_Call) Return(_a0 error) *TaskNodeHandler_Abort_Call

func (*TaskNodeHandler_Abort_Call) Run added in v1.15.1 

func (_c *TaskNodeHandler_Abort_Call) Run(run func(ctx context.Context, executionContext interfaces.NodeExecutionContext, reason string)) *TaskNodeHandler_Abort_Call

func (*TaskNodeHandler_Abort_Call) RunAndReturn added in v1.15.1 

func (_c *TaskNodeHandler_Abort_Call) RunAndReturn(run func(context.Context, interfaces.NodeExecutionContext, string) error) *TaskNodeHandler_Abort_Call

type TaskNodeHandler_Expecter added in v1.15.1 

type TaskNodeHandler_Expecter struct {
	// contains filtered or unexported fields
}

func (*TaskNodeHandler_Expecter) Abort added in v1.15.1 

func (_e *TaskNodeHandler_Expecter) Abort(ctx interface{}, executionContext interface{}, reason interface{}) *TaskNodeHandler_Abort_Call

Abort is a helper method to define mock.On call

  • ctx context.Context
  • executionContext interfaces.NodeExecutionContext
  • reason string

func (*TaskNodeHandler_Expecter) Finalize added in v1.15.1 

func (_e *TaskNodeHandler_Expecter) Finalize(ctx interface{}, executionContext interface{}) *TaskNodeHandler_Finalize_Call

Finalize is a helper method to define mock.On call

  • ctx context.Context
  • executionContext interfaces.NodeExecutionContext

func (*TaskNodeHandler_Expecter) FinalizeRequired added in v1.15.1 

func (_e *TaskNodeHandler_Expecter) FinalizeRequired() *TaskNodeHandler_FinalizeRequired_Call

FinalizeRequired is a helper method to define mock.On call

func (*TaskNodeHandler_Expecter) GetCatalogKey added in v1.15.1 

func (_e *TaskNodeHandler_Expecter) GetCatalogKey(ctx interface{}, executionContext interface{}) *TaskNodeHandler_GetCatalogKey_Call

GetCatalogKey is a helper method to define mock.On call

  • ctx context.Context
  • executionContext interfaces.NodeExecutionContext

func (*TaskNodeHandler_Expecter) Handle added in v1.15.1 

func (_e *TaskNodeHandler_Expecter) Handle(ctx interface{}, executionContext interface{}) *TaskNodeHandler_Handle_Call

Handle is a helper method to define mock.On call

  • ctx context.Context
  • executionContext interfaces.NodeExecutionContext

func (*TaskNodeHandler_Expecter) IsCacheable added in v1.15.1 

func (_e *TaskNodeHandler_Expecter) IsCacheable(ctx interface{}, executionContext interface{}) *TaskNodeHandler_IsCacheable_Call

IsCacheable is a helper method to define mock.On call

  • ctx context.Context
  • executionContext interfaces.NodeExecutionContext

func (*TaskNodeHandler_Expecter) Setup added in v1.15.1 

func (_e *TaskNodeHandler_Expecter) Setup(ctx interface{}, setupContext interface{}) *TaskNodeHandler_Setup_Call

Setup is a helper method to define mock.On call

  • ctx context.Context
  • setupContext interfaces.SetupContext

func (*TaskNodeHandler_Expecter) ValidateOutput added in v1.15.1 

func (_e *TaskNodeHandler_Expecter) ValidateOutput(ctx interface{}, nodeID interface{}, i interface{}, r interface{}, outputCommitter interface{}, executionConfig interface{}, tr interface{}) *TaskNodeHandler_ValidateOutput_Call

ValidateOutput is a helper method to define mock.On call

  • ctx context.Context
  • nodeID string
  • i io.InputReader
  • r io.OutputReader
  • outputCommitter io.OutputWriter
  • executionConfig v1alpha1.ExecutionConfig
  • tr ioutils.SimpleTaskReader

type TaskNodeHandler_FinalizeRequired_Call added in v1.15.1 

type TaskNodeHandler_FinalizeRequired_Call struct {
	*mock.Call
}

TaskNodeHandler_FinalizeRequired_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FinalizeRequired'

func (*TaskNodeHandler_FinalizeRequired_Call) Return added in v1.15.1 

func (_c *TaskNodeHandler_FinalizeRequired_Call) Return(_a0 bool) *TaskNodeHandler_FinalizeRequired_Call

func (*TaskNodeHandler_FinalizeRequired_Call) Run added in v1.15.1 

func (_c *TaskNodeHandler_FinalizeRequired_Call) Run(run func()) *TaskNodeHandler_FinalizeRequired_Call

func (*TaskNodeHandler_FinalizeRequired_Call) RunAndReturn added in v1.15.1 

func (_c *TaskNodeHandler_FinalizeRequired_Call) RunAndReturn(run func() bool) *TaskNodeHandler_FinalizeRequired_Call

type TaskNodeHandler_Finalize_Call added in v1.15.1 

type TaskNodeHandler_Finalize_Call struct {
	*mock.Call
}

TaskNodeHandler_Finalize_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Finalize'

func (*TaskNodeHandler_Finalize_Call) Return added in v1.15.1 

func (_c *TaskNodeHandler_Finalize_Call) Return(_a0 error) *TaskNodeHandler_Finalize_Call

func (*TaskNodeHandler_Finalize_Call) Run added in v1.15.1 

func (_c *TaskNodeHandler_Finalize_Call) Run(run func(ctx context.Context, executionContext interfaces.NodeExecutionContext)) *TaskNodeHandler_Finalize_Call

func (*TaskNodeHandler_Finalize_Call) RunAndReturn added in v1.15.1 

func (_c *TaskNodeHandler_Finalize_Call) RunAndReturn(run func(context.Context, interfaces.NodeExecutionContext) error) *TaskNodeHandler_Finalize_Call

type TaskNodeHandler_GetCatalogKey_Call added in v1.15.1 

type TaskNodeHandler_GetCatalogKey_Call struct {
	*mock.Call
}

TaskNodeHandler_GetCatalogKey_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetCatalogKey'

func (*TaskNodeHandler_GetCatalogKey_Call) Return added in v1.15.1 

func (_c *TaskNodeHandler_GetCatalogKey_Call) Return(_a0 catalog.Key, _a1 error) *TaskNodeHandler_GetCatalogKey_Call

func (*TaskNodeHandler_GetCatalogKey_Call) Run added in v1.15.1 

func (_c *TaskNodeHandler_GetCatalogKey_Call) Run(run func(ctx context.Context, executionContext interfaces.NodeExecutionContext)) *TaskNodeHandler_GetCatalogKey_Call

func (*TaskNodeHandler_GetCatalogKey_Call) RunAndReturn added in v1.15.1 

func (_c *TaskNodeHandler_GetCatalogKey_Call) RunAndReturn(run func(context.Context, interfaces.NodeExecutionContext) (catalog.Key, error)) *TaskNodeHandler_GetCatalogKey_Call

type TaskNodeHandler_Handle_Call added in v1.15.1 

type TaskNodeHandler_Handle_Call struct {
	*mock.Call
}

TaskNodeHandler_Handle_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Handle'

func (*TaskNodeHandler_Handle_Call) Return added in v1.15.1 

func (_c *TaskNodeHandler_Handle_Call) Return(_a0 handler.Transition, _a1 error) *TaskNodeHandler_Handle_Call

func (*TaskNodeHandler_Handle_Call) Run added in v1.15.1 

func (_c *TaskNodeHandler_Handle_Call) Run(run func(ctx context.Context, executionContext interfaces.NodeExecutionContext)) *TaskNodeHandler_Handle_Call

func (*TaskNodeHandler_Handle_Call) RunAndReturn added in v1.15.1 

func (_c *TaskNodeHandler_Handle_Call) RunAndReturn(run func(context.Context, interfaces.NodeExecutionContext) (handler.Transition, error)) *TaskNodeHandler_Handle_Call

type TaskNodeHandler_IsCacheable_Call added in v1.15.1 

type TaskNodeHandler_IsCacheable_Call struct {
	*mock.Call
}

TaskNodeHandler_IsCacheable_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IsCacheable'

func (*TaskNodeHandler_IsCacheable_Call) Return added in v1.15.1 

func (_c *TaskNodeHandler_IsCacheable_Call) Return(_a0 bool, _a1 bool, _a2 error) *TaskNodeHandler_IsCacheable_Call

func (*TaskNodeHandler_IsCacheable_Call) Run added in v1.15.1 

func (_c *TaskNodeHandler_IsCacheable_Call) Run(run func(ctx context.Context, executionContext interfaces.NodeExecutionContext)) *TaskNodeHandler_IsCacheable_Call

func (*TaskNodeHandler_IsCacheable_Call) RunAndReturn added in v1.15.1 

func (_c *TaskNodeHandler_IsCacheable_Call) RunAndReturn(run func(context.Context, interfaces.NodeExecutionContext) (bool, bool, error)) *TaskNodeHandler_IsCacheable_Call

type TaskNodeHandler_Setup_Call added in v1.15.1 

type TaskNodeHandler_Setup_Call struct {
	*mock.Call
}

TaskNodeHandler_Setup_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Setup'

func (*TaskNodeHandler_Setup_Call) Return added in v1.15.1 

func (_c *TaskNodeHandler_Setup_Call) Return(_a0 error) *TaskNodeHandler_Setup_Call

func (*TaskNodeHandler_Setup_Call) Run added in v1.15.1 

func (_c *TaskNodeHandler_Setup_Call) Run(run func(ctx context.Context, setupContext interfaces.SetupContext)) *TaskNodeHandler_Setup_Call

func (*TaskNodeHandler_Setup_Call) RunAndReturn added in v1.15.1 

func (_c *TaskNodeHandler_Setup_Call) RunAndReturn(run func(context.Context, interfaces.SetupContext) error) *TaskNodeHandler_Setup_Call

type TaskNodeHandler_ValidateOutput_Call added in v1.15.1 

type TaskNodeHandler_ValidateOutput_Call struct {
	*mock.Call
}

TaskNodeHandler_ValidateOutput_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ValidateOutput'

func (*TaskNodeHandler_ValidateOutput_Call) Return added in v1.15.1 

func (_c *TaskNodeHandler_ValidateOutput_Call) Return(_a0 *io.ExecutionError, _a1 error) *TaskNodeHandler_ValidateOutput_Call

func (*TaskNodeHandler_ValidateOutput_Call) Run added in v1.15.1 

func (_c *TaskNodeHandler_ValidateOutput_Call) Run(run func(ctx context.Context, nodeID string, i io.InputReader, r io.OutputReader, outputCommitter io.OutputWriter, executionConfig v1alpha1.ExecutionConfig, tr ioutils.SimpleTaskReader)) *TaskNodeHandler_ValidateOutput_Call

func (*TaskNodeHandler_ValidateOutput_Call) RunAndReturn added in v1.15.1 

func (_c *TaskNodeHandler_ValidateOutput_Call) RunAndReturn(run func(context.Context, string, io.InputReader, io.OutputReader, io.OutputWriter, v1alpha1.ExecutionConfig, ioutils.SimpleTaskReader) (*io.ExecutionError, error)) *TaskNodeHandler_ValidateOutput_Call

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.