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: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CacheableNodeHandler 

type CacheableNodeHandler struct {
	mock.Mock
}

CacheableNodeHandler is an autogenerated mock type for the CacheableNodeHandler type

func NewCacheableNodeHandler added in v1.15.1 

func NewCacheableNodeHandler(t interface {
	mock.TestingT
	Cleanup(func())
}) *CacheableNodeHandler

NewCacheableNodeHandler creates a new instance of CacheableNodeHandler. 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 (*CacheableNodeHandler) Abort 

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

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

func (*CacheableNodeHandler) EXPECT added in v1.15.1 

func (_m *CacheableNodeHandler) EXPECT() *CacheableNodeHandler_Expecter

func (*CacheableNodeHandler) Finalize 

func (_m *CacheableNodeHandler) Finalize(ctx context.Context, executionContext interfaces.NodeExecutionContext) error

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

func (*CacheableNodeHandler) FinalizeRequired 

func (_m *CacheableNodeHandler) FinalizeRequired() bool

FinalizeRequired provides a mock function with no fields

func (*CacheableNodeHandler) GetCatalogKey 

func (_m *CacheableNodeHandler) GetCatalogKey(ctx context.Context, executionContext interfaces.NodeExecutionContext) (catalog.Key, error)

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

func (*CacheableNodeHandler) Handle 

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

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

func (*CacheableNodeHandler) IsCacheable 

func (_m *CacheableNodeHandler) IsCacheable(ctx context.Context, executionContext interfaces.NodeExecutionContext) (bool, bool, error)

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

func (*CacheableNodeHandler) Setup 

func (_m *CacheableNodeHandler) Setup(ctx context.Context, setupContext interfaces.SetupContext) error

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

type CacheableNodeHandler_Abort_Call added in v1.15.1 

type CacheableNodeHandler_Abort_Call struct {
	*mock.Call
}

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

func (*CacheableNodeHandler_Abort_Call) Return added in v1.15.1 

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

func (*CacheableNodeHandler_Abort_Call) Run added in v1.15.1 

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

func (*CacheableNodeHandler_Abort_Call) RunAndReturn added in v1.15.1 

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

type CacheableNodeHandler_Expecter added in v1.15.1 

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

func (*CacheableNodeHandler_Expecter) Abort added in v1.15.1 

func (_e *CacheableNodeHandler_Expecter) Abort(ctx interface{}, executionContext interface{}, reason interface{}) *CacheableNodeHandler_Abort_Call

Abort is a helper method to define mock.On call

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

func (*CacheableNodeHandler_Expecter) Finalize added in v1.15.1 

func (_e *CacheableNodeHandler_Expecter) Finalize(ctx interface{}, executionContext interface{}) *CacheableNodeHandler_Finalize_Call

Finalize is a helper method to define mock.On call

  • ctx context.Context
  • executionContext interfaces.NodeExecutionContext

func (*CacheableNodeHandler_Expecter) FinalizeRequired added in v1.15.1 

func (_e *CacheableNodeHandler_Expecter) FinalizeRequired() *CacheableNodeHandler_FinalizeRequired_Call

FinalizeRequired is a helper method to define mock.On call

func (*CacheableNodeHandler_Expecter) GetCatalogKey added in v1.15.1 

func (_e *CacheableNodeHandler_Expecter) GetCatalogKey(ctx interface{}, executionContext interface{}) *CacheableNodeHandler_GetCatalogKey_Call

GetCatalogKey is a helper method to define mock.On call

  • ctx context.Context
  • executionContext interfaces.NodeExecutionContext

func (*CacheableNodeHandler_Expecter) Handle added in v1.15.1 

func (_e *CacheableNodeHandler_Expecter) Handle(ctx interface{}, executionContext interface{}) *CacheableNodeHandler_Handle_Call

Handle is a helper method to define mock.On call

  • ctx context.Context
  • executionContext interfaces.NodeExecutionContext

func (*CacheableNodeHandler_Expecter) IsCacheable added in v1.15.1 

func (_e *CacheableNodeHandler_Expecter) IsCacheable(ctx interface{}, executionContext interface{}) *CacheableNodeHandler_IsCacheable_Call

IsCacheable is a helper method to define mock.On call

  • ctx context.Context
  • executionContext interfaces.NodeExecutionContext

func (*CacheableNodeHandler_Expecter) Setup added in v1.15.1 

func (_e *CacheableNodeHandler_Expecter) Setup(ctx interface{}, setupContext interface{}) *CacheableNodeHandler_Setup_Call

Setup is a helper method to define mock.On call

  • ctx context.Context
  • setupContext interfaces.SetupContext

type CacheableNodeHandler_FinalizeRequired_Call added in v1.15.1 

type CacheableNodeHandler_FinalizeRequired_Call struct {
	*mock.Call
}

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

func (*CacheableNodeHandler_FinalizeRequired_Call) Return added in v1.15.1 

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

func (*CacheableNodeHandler_FinalizeRequired_Call) Run added in v1.15.1 

func (_c *CacheableNodeHandler_FinalizeRequired_Call) Run(run func()) *CacheableNodeHandler_FinalizeRequired_Call

func (*CacheableNodeHandler_FinalizeRequired_Call) RunAndReturn added in v1.15.1 

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

type CacheableNodeHandler_Finalize_Call added in v1.15.1 

type CacheableNodeHandler_Finalize_Call struct {
	*mock.Call
}

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

func (*CacheableNodeHandler_Finalize_Call) Return added in v1.15.1 

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

func (*CacheableNodeHandler_Finalize_Call) Run added in v1.15.1 

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

func (*CacheableNodeHandler_Finalize_Call) RunAndReturn added in v1.15.1 

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

type CacheableNodeHandler_GetCatalogKey_Call added in v1.15.1 

type CacheableNodeHandler_GetCatalogKey_Call struct {
	*mock.Call
}

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

func (*CacheableNodeHandler_GetCatalogKey_Call) Return added in v1.15.1 

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

func (*CacheableNodeHandler_GetCatalogKey_Call) Run added in v1.15.1 

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

func (*CacheableNodeHandler_GetCatalogKey_Call) RunAndReturn added in v1.15.1 

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

type CacheableNodeHandler_Handle_Call added in v1.15.1 

type CacheableNodeHandler_Handle_Call struct {
	*mock.Call
}

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

func (*CacheableNodeHandler_Handle_Call) Return added in v1.15.1 

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

func (*CacheableNodeHandler_Handle_Call) Run added in v1.15.1 

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

func (*CacheableNodeHandler_Handle_Call) RunAndReturn added in v1.15.1 

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

type CacheableNodeHandler_IsCacheable_Call added in v1.15.1 

type CacheableNodeHandler_IsCacheable_Call struct {
	*mock.Call
}

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

func (*CacheableNodeHandler_IsCacheable_Call) Return added in v1.15.1 

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

func (*CacheableNodeHandler_IsCacheable_Call) Run added in v1.15.1 

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

func (*CacheableNodeHandler_IsCacheable_Call) RunAndReturn added in v1.15.1 

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

type CacheableNodeHandler_Setup_Call added in v1.15.1 

type CacheableNodeHandler_Setup_Call struct {
	*mock.Call
}

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

func (*CacheableNodeHandler_Setup_Call) Return added in v1.15.1 

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

func (*CacheableNodeHandler_Setup_Call) Run added in v1.15.1 

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

func (*CacheableNodeHandler_Setup_Call) RunAndReturn added in v1.15.1 

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

type EventRecorder 

type EventRecorder struct {
	mock.Mock
}

EventRecorder is an autogenerated mock type for the EventRecorder type

func NewEventRecorder added in v1.15.1 

func NewEventRecorder(t interface {
	mock.TestingT
	Cleanup(func())
}) *EventRecorder

NewEventRecorder creates a new instance of EventRecorder. 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 (*EventRecorder) EXPECT added in v1.15.1 

func (_m *EventRecorder) EXPECT() *EventRecorder_Expecter

func (*EventRecorder) RecordNodeEvent 

func (_m *EventRecorder) RecordNodeEvent(ctx context.Context, _a1 *event.NodeExecutionEvent, eventConfig *config.EventConfig) error

RecordNodeEvent provides a mock function with given fields: ctx, _a1, eventConfig

func (*EventRecorder) RecordTaskEvent 

func (_m *EventRecorder) RecordTaskEvent(ctx context.Context, _a1 *event.TaskExecutionEvent, eventConfig *config.EventConfig) error

RecordTaskEvent provides a mock function with given fields: ctx, _a1, eventConfig

type EventRecorder_Expecter added in v1.15.1 

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

func (*EventRecorder_Expecter) RecordNodeEvent added in v1.15.1 

func (_e *EventRecorder_Expecter) RecordNodeEvent(ctx interface{}, _a1 interface{}, eventConfig interface{}) *EventRecorder_RecordNodeEvent_Call

RecordNodeEvent is a helper method to define mock.On call

  • ctx context.Context
  • _a1 *event.NodeExecutionEvent
  • eventConfig *config.EventConfig

func (*EventRecorder_Expecter) RecordTaskEvent added in v1.15.1 

func (_e *EventRecorder_Expecter) RecordTaskEvent(ctx interface{}, _a1 interface{}, eventConfig interface{}) *EventRecorder_RecordTaskEvent_Call

RecordTaskEvent is a helper method to define mock.On call

  • ctx context.Context
  • _a1 *event.TaskExecutionEvent
  • eventConfig *config.EventConfig

type EventRecorder_RecordNodeEvent_Call added in v1.15.1 

type EventRecorder_RecordNodeEvent_Call struct {
	*mock.Call
}

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

func (*EventRecorder_RecordNodeEvent_Call) Return added in v1.15.1 

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

func (*EventRecorder_RecordNodeEvent_Call) Run added in v1.15.1 

func (_c *EventRecorder_RecordNodeEvent_Call) Run(run func(ctx context.Context, _a1 *event.NodeExecutionEvent, eventConfig *config.EventConfig)) *EventRecorder_RecordNodeEvent_Call

func (*EventRecorder_RecordNodeEvent_Call) RunAndReturn added in v1.15.1 

func (_c *EventRecorder_RecordNodeEvent_Call) RunAndReturn(run func(context.Context, *event.NodeExecutionEvent, *config.EventConfig) error) *EventRecorder_RecordNodeEvent_Call

type EventRecorder_RecordTaskEvent_Call added in v1.15.1 

type EventRecorder_RecordTaskEvent_Call struct {
	*mock.Call
}

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

func (*EventRecorder_RecordTaskEvent_Call) Return added in v1.15.1 

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

func (*EventRecorder_RecordTaskEvent_Call) Run added in v1.15.1 

func (_c *EventRecorder_RecordTaskEvent_Call) Run(run func(ctx context.Context, _a1 *event.TaskExecutionEvent, eventConfig *config.EventConfig)) *EventRecorder_RecordTaskEvent_Call

func (*EventRecorder_RecordTaskEvent_Call) RunAndReturn added in v1.15.1 

func (_c *EventRecorder_RecordTaskEvent_Call) RunAndReturn(run func(context.Context, *event.TaskExecutionEvent, *config.EventConfig) error) *EventRecorder_RecordTaskEvent_Call

type HandlerFactory 

type HandlerFactory struct {
	mock.Mock
}

HandlerFactory is an autogenerated mock type for the HandlerFactory type

func NewHandlerFactory added in v1.15.1 

func NewHandlerFactory(t interface {
	mock.TestingT
	Cleanup(func())
}) *HandlerFactory

NewHandlerFactory creates a new instance of HandlerFactory. 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 (*HandlerFactory) EXPECT added in v1.15.1 

func (_m *HandlerFactory) EXPECT() *HandlerFactory_Expecter

func (*HandlerFactory) GetHandler 

func (_m *HandlerFactory) GetHandler(kind v1alpha1.NodeKind) (interfaces.NodeHandler, error)

GetHandler provides a mock function with given fields: kind

func (*HandlerFactory) Setup 

func (_m *HandlerFactory) Setup(ctx context.Context, executor interfaces.Node, setup interfaces.SetupContext) error

Setup provides a mock function with given fields: ctx, executor, setup

type HandlerFactory_Expecter added in v1.15.1 

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

func (*HandlerFactory_Expecter) GetHandler added in v1.15.1 

func (_e *HandlerFactory_Expecter) GetHandler(kind interface{}) *HandlerFactory_GetHandler_Call

GetHandler is a helper method to define mock.On call

  • kind v1alpha1.NodeKind

func (*HandlerFactory_Expecter) Setup added in v1.15.1 

func (_e *HandlerFactory_Expecter) Setup(ctx interface{}, executor interface{}, setup interface{}) *HandlerFactory_Setup_Call

Setup is a helper method to define mock.On call

  • ctx context.Context
  • executor interfaces.Node
  • setup interfaces.SetupContext

type HandlerFactory_GetHandler_Call added in v1.15.1 

type HandlerFactory_GetHandler_Call struct {
	*mock.Call
}

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

func (*HandlerFactory_GetHandler_Call) Return added in v1.15.1 

func (_c *HandlerFactory_GetHandler_Call) Return(_a0 interfaces.NodeHandler, _a1 error) *HandlerFactory_GetHandler_Call

func (*HandlerFactory_GetHandler_Call) Run added in v1.15.1 

func (_c *HandlerFactory_GetHandler_Call) Run(run func(kind v1alpha1.NodeKind)) *HandlerFactory_GetHandler_Call

func (*HandlerFactory_GetHandler_Call) RunAndReturn added in v1.15.1 

func (_c *HandlerFactory_GetHandler_Call) RunAndReturn(run func(v1alpha1.NodeKind) (interfaces.NodeHandler, error)) *HandlerFactory_GetHandler_Call

type HandlerFactory_Setup_Call added in v1.15.1 

type HandlerFactory_Setup_Call struct {
	*mock.Call
}

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

func (*HandlerFactory_Setup_Call) Return added in v1.15.1 

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

func (*HandlerFactory_Setup_Call) Run added in v1.15.1 

func (_c *HandlerFactory_Setup_Call) Run(run func(ctx context.Context, executor interfaces.Node, setup interfaces.SetupContext)) *HandlerFactory_Setup_Call

func (*HandlerFactory_Setup_Call) RunAndReturn added in v1.15.1 

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

type Node 

type Node struct {
	mock.Mock
}

Node is an autogenerated mock type for the Node type

func NewNode added in v1.15.1 

func NewNode(t interface {
	mock.TestingT
	Cleanup(func())
}) *Node

NewNode creates a new instance of Node. 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 (*Node) AbortHandler 

func (_m *Node) AbortHandler(ctx context.Context, execContext executors.ExecutionContext, dag executors.DAGStructure, nl executors.NodeLookup, currentNode v1alpha1.ExecutableNode, reason string) error

AbortHandler provides a mock function with given fields: ctx, execContext, dag, nl, currentNode, reason

func (*Node) EXPECT added in v1.15.1 

func (_m *Node) EXPECT() *Node_Expecter

func (*Node) FinalizeHandler 

func (_m *Node) FinalizeHandler(ctx context.Context, execContext executors.ExecutionContext, dag executors.DAGStructure, nl executors.NodeLookup, currentNode v1alpha1.ExecutableNode) error

FinalizeHandler provides a mock function with given fields: ctx, execContext, dag, nl, currentNode

func (*Node) GetNodeExecutionContextBuilder 

func (_m *Node) GetNodeExecutionContextBuilder() interfaces.NodeExecutionContextBuilder

GetNodeExecutionContextBuilder provides a mock function with no fields

func (*Node) Initialize 

func (_m *Node) Initialize(ctx context.Context) error

Initialize provides a mock function with given fields: ctx

func (*Node) RecursiveNodeHandler 

func (_m *Node) RecursiveNodeHandler(ctx context.Context, execContext executors.ExecutionContext, dag executors.DAGStructure, nl executors.NodeLookup, currentNode v1alpha1.ExecutableNode) (interfaces.NodeStatus, error)

RecursiveNodeHandler provides a mock function with given fields: ctx, execContext, dag, nl, currentNode

func (*Node) SetInputsForStartNode 

func (_m *Node) SetInputsForStartNode(ctx context.Context, execContext executors.ExecutionContext, dag executors.DAGStructureWithStartNode, nl executors.NodeLookup, inputs *core.LiteralMap) (interfaces.NodeStatus, error)

SetInputsForStartNode provides a mock function with given fields: ctx, execContext, dag, nl, inputs

func (*Node) WithNodeExecutionContextBuilder 

func (_m *Node) WithNodeExecutionContextBuilder(_a0 interfaces.NodeExecutionContextBuilder) interfaces.Node

WithNodeExecutionContextBuilder provides a mock function with given fields: _a0

type NodeExecutionContext 

type NodeExecutionContext struct {
	mock.Mock
}

NodeExecutionContext is an autogenerated mock type for the NodeExecutionContext type

func NewNodeExecutionContext added in v1.15.1 

func NewNodeExecutionContext(t interface {
	mock.TestingT
	Cleanup(func())
}) *NodeExecutionContext

NewNodeExecutionContext creates a new instance of NodeExecutionContext. 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 (*NodeExecutionContext) ContextualNodeLookup 

func (_m *NodeExecutionContext) ContextualNodeLookup() executors.NodeLookup

ContextualNodeLookup provides a mock function with no fields

func (*NodeExecutionContext) CurrentAttempt 

func (_m *NodeExecutionContext) CurrentAttempt() uint32

CurrentAttempt provides a mock function with no fields

func (*NodeExecutionContext) DataStore 

func (_m *NodeExecutionContext) DataStore() *storage.DataStore

DataStore provides a mock function with no fields

func (*NodeExecutionContext) EXPECT added in v1.15.1 

func (_m *NodeExecutionContext) EXPECT() *NodeExecutionContext_Expecter

func (*NodeExecutionContext) EnqueueOwnerFunc 

func (_m *NodeExecutionContext) EnqueueOwnerFunc() func() error

EnqueueOwnerFunc provides a mock function with no fields

func (*NodeExecutionContext) EventsRecorder 

func (_m *NodeExecutionContext) EventsRecorder() interfaces.EventRecorder

EventsRecorder provides a mock function with no fields

func (*NodeExecutionContext) ExecutionContext 

func (_m *NodeExecutionContext) ExecutionContext() executors.ExecutionContext

ExecutionContext provides a mock function with no fields

func (*NodeExecutionContext) InputReader 

func (_m *NodeExecutionContext) InputReader() io.InputReader

InputReader provides a mock function with no fields

func (*NodeExecutionContext) Node 

func (_m *NodeExecutionContext) Node() v1alpha1.ExecutableNode

Node provides a mock function with no fields

func (*NodeExecutionContext) NodeExecutionMetadata 

func (_m *NodeExecutionContext) NodeExecutionMetadata() interfaces.NodeExecutionMetadata

NodeExecutionMetadata provides a mock function with no fields

func (*NodeExecutionContext) NodeID 

func (_m *NodeExecutionContext) NodeID() string

NodeID provides a mock function with no fields

func (*NodeExecutionContext) NodeStateReader 

func (_m *NodeExecutionContext) NodeStateReader() interfaces.NodeStateReader

NodeStateReader provides a mock function with no fields

func (*NodeExecutionContext) NodeStateWriter 

func (_m *NodeExecutionContext) NodeStateWriter() interfaces.NodeStateWriter

NodeStateWriter provides a mock function with no fields

func (*NodeExecutionContext) NodeStatus 

func (_m *NodeExecutionContext) NodeStatus() v1alpha1.ExecutableNodeStatus

NodeStatus provides a mock function with no fields

func (*NodeExecutionContext) OutputShardSelector 

func (_m *NodeExecutionContext) OutputShardSelector() ioutils.ShardSelector

OutputShardSelector provides a mock function with no fields

func (*NodeExecutionContext) RawOutputPrefix 

func (_m *NodeExecutionContext) RawOutputPrefix() storage.DataReference

RawOutputPrefix provides a mock function with no fields

func (*NodeExecutionContext) TaskReader 

func (_m *NodeExecutionContext) TaskReader() interfaces.TaskReader

TaskReader provides a mock function with no fields

type NodeExecutionContextBuilder 

type NodeExecutionContextBuilder struct {
	mock.Mock
}

NodeExecutionContextBuilder is an autogenerated mock type for the NodeExecutionContextBuilder type

func NewNodeExecutionContextBuilder added in v1.15.1 

func NewNodeExecutionContextBuilder(t interface {
	mock.TestingT
	Cleanup(func())
}) *NodeExecutionContextBuilder

NewNodeExecutionContextBuilder creates a new instance of NodeExecutionContextBuilder. 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 (*NodeExecutionContextBuilder) BuildNodeExecutionContext 

func (_m *NodeExecutionContextBuilder) BuildNodeExecutionContext(ctx context.Context, executionContext executors.ExecutionContext, nl executors.NodeLookup, currentNodeID string) (interfaces.NodeExecutionContext, error)

BuildNodeExecutionContext provides a mock function with given fields: ctx, executionContext, nl, currentNodeID

func (*NodeExecutionContextBuilder) EXPECT added in v1.15.1 

func (_m *NodeExecutionContextBuilder) EXPECT() *NodeExecutionContextBuilder_Expecter

type NodeExecutionContextBuilder_BuildNodeExecutionContext_Call added in v1.15.1 

type NodeExecutionContextBuilder_BuildNodeExecutionContext_Call struct {
	*mock.Call
}

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

func (*NodeExecutionContextBuilder_BuildNodeExecutionContext_Call) Return added in v1.15.1 

func (_c *NodeExecutionContextBuilder_BuildNodeExecutionContext_Call) Return(_a0 interfaces.NodeExecutionContext, _a1 error) *NodeExecutionContextBuilder_BuildNodeExecutionContext_Call

func (*NodeExecutionContextBuilder_BuildNodeExecutionContext_Call) Run added in v1.15.1 

func (_c *NodeExecutionContextBuilder_BuildNodeExecutionContext_Call) Run(run func(ctx context.Context, executionContext executors.ExecutionContext, nl executors.NodeLookup, currentNodeID string)) *NodeExecutionContextBuilder_BuildNodeExecutionContext_Call

func (*NodeExecutionContextBuilder_BuildNodeExecutionContext_Call) RunAndReturn added in v1.15.1 

func (_c *NodeExecutionContextBuilder_BuildNodeExecutionContext_Call) RunAndReturn(run func(context.Context, executors.ExecutionContext, executors.NodeLookup, string) (interfaces.NodeExecutionContext, error)) *NodeExecutionContextBuilder_BuildNodeExecutionContext_Call

type NodeExecutionContextBuilder_Expecter added in v1.15.1 

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

func (*NodeExecutionContextBuilder_Expecter) BuildNodeExecutionContext added in v1.15.1 

func (_e *NodeExecutionContextBuilder_Expecter) BuildNodeExecutionContext(ctx interface{}, executionContext interface{}, nl interface{}, currentNodeID interface{}) *NodeExecutionContextBuilder_BuildNodeExecutionContext_Call

BuildNodeExecutionContext is a helper method to define mock.On call

  • ctx context.Context
  • executionContext executors.ExecutionContext
  • nl executors.NodeLookup
  • currentNodeID string

type NodeExecutionContext_ContextualNodeLookup_Call added in v1.15.1 

type NodeExecutionContext_ContextualNodeLookup_Call struct {
	*mock.Call
}

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

func (*NodeExecutionContext_ContextualNodeLookup_Call) Return added in v1.15.1 

func (_c *NodeExecutionContext_ContextualNodeLookup_Call) Return(_a0 executors.NodeLookup) *NodeExecutionContext_ContextualNodeLookup_Call

func (*NodeExecutionContext_ContextualNodeLookup_Call) Run added in v1.15.1 

func (_c *NodeExecutionContext_ContextualNodeLookup_Call) Run(run func()) *NodeExecutionContext_ContextualNodeLookup_Call

func (*NodeExecutionContext_ContextualNodeLookup_Call) RunAndReturn added in v1.15.1 

func (_c *NodeExecutionContext_ContextualNodeLookup_Call) RunAndReturn(run func() executors.NodeLookup) *NodeExecutionContext_ContextualNodeLookup_Call

type NodeExecutionContext_CurrentAttempt_Call added in v1.15.1 

type NodeExecutionContext_CurrentAttempt_Call struct {
	*mock.Call
}

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

func (*NodeExecutionContext_CurrentAttempt_Call) Return added in v1.15.1 

func (_c *NodeExecutionContext_CurrentAttempt_Call) Return(_a0 uint32) *NodeExecutionContext_CurrentAttempt_Call

func (*NodeExecutionContext_CurrentAttempt_Call) Run added in v1.15.1 

func (_c *NodeExecutionContext_CurrentAttempt_Call) Run(run func()) *NodeExecutionContext_CurrentAttempt_Call

func (*NodeExecutionContext_CurrentAttempt_Call) RunAndReturn added in v1.15.1 

func (_c *NodeExecutionContext_CurrentAttempt_Call) RunAndReturn(run func() uint32) *NodeExecutionContext_CurrentAttempt_Call

type NodeExecutionContext_DataStore_Call added in v1.15.1 

type NodeExecutionContext_DataStore_Call struct {
	*mock.Call
}

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

func (*NodeExecutionContext_DataStore_Call) Return added in v1.15.1 

func (_c *NodeExecutionContext_DataStore_Call) Return(_a0 *storage.DataStore) *NodeExecutionContext_DataStore_Call

func (*NodeExecutionContext_DataStore_Call) Run added in v1.15.1 

func (_c *NodeExecutionContext_DataStore_Call) Run(run func()) *NodeExecutionContext_DataStore_Call

func (*NodeExecutionContext_DataStore_Call) RunAndReturn added in v1.15.1 

func (_c *NodeExecutionContext_DataStore_Call) RunAndReturn(run func() *storage.DataStore) *NodeExecutionContext_DataStore_Call

type NodeExecutionContext_EnqueueOwnerFunc_Call added in v1.15.1 

type NodeExecutionContext_EnqueueOwnerFunc_Call struct {
	*mock.Call
}

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

func (*NodeExecutionContext_EnqueueOwnerFunc_Call) Return added in v1.15.1 

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

func (*NodeExecutionContext_EnqueueOwnerFunc_Call) Run added in v1.15.1 

func (_c *NodeExecutionContext_EnqueueOwnerFunc_Call) Run(run func()) *NodeExecutionContext_EnqueueOwnerFunc_Call

func (*NodeExecutionContext_EnqueueOwnerFunc_Call) RunAndReturn added in v1.15.1 

func (_c *NodeExecutionContext_EnqueueOwnerFunc_Call) RunAndReturn(run func() func() error) *NodeExecutionContext_EnqueueOwnerFunc_Call

type NodeExecutionContext_EventsRecorder_Call added in v1.15.1 

type NodeExecutionContext_EventsRecorder_Call struct {
	*mock.Call
}

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

func (*NodeExecutionContext_EventsRecorder_Call) Return added in v1.15.1 

func (_c *NodeExecutionContext_EventsRecorder_Call) Return(_a0 interfaces.EventRecorder) *NodeExecutionContext_EventsRecorder_Call

func (*NodeExecutionContext_EventsRecorder_Call) Run added in v1.15.1 

func (_c *NodeExecutionContext_EventsRecorder_Call) Run(run func()) *NodeExecutionContext_EventsRecorder_Call

func (*NodeExecutionContext_EventsRecorder_Call) RunAndReturn added in v1.15.1 

func (_c *NodeExecutionContext_EventsRecorder_Call) RunAndReturn(run func() interfaces.EventRecorder) *NodeExecutionContext_EventsRecorder_Call

type NodeExecutionContext_ExecutionContext_Call added in v1.15.1 

type NodeExecutionContext_ExecutionContext_Call struct {
	*mock.Call
}

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

func (*NodeExecutionContext_ExecutionContext_Call) Return added in v1.15.1 

func (_c *NodeExecutionContext_ExecutionContext_Call) Return(_a0 executors.ExecutionContext) *NodeExecutionContext_ExecutionContext_Call

func (*NodeExecutionContext_ExecutionContext_Call) Run added in v1.15.1 

func (_c *NodeExecutionContext_ExecutionContext_Call) Run(run func()) *NodeExecutionContext_ExecutionContext_Call

func (*NodeExecutionContext_ExecutionContext_Call) RunAndReturn added in v1.15.1 

func (_c *NodeExecutionContext_ExecutionContext_Call) RunAndReturn(run func() executors.ExecutionContext) *NodeExecutionContext_ExecutionContext_Call

type NodeExecutionContext_Expecter added in v1.15.1 

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

func (*NodeExecutionContext_Expecter) ContextualNodeLookup added in v1.15.1 

func (_e *NodeExecutionContext_Expecter) ContextualNodeLookup() *NodeExecutionContext_ContextualNodeLookup_Call

ContextualNodeLookup is a helper method to define mock.On call

func (*NodeExecutionContext_Expecter) CurrentAttempt added in v1.15.1 

func (_e *NodeExecutionContext_Expecter) CurrentAttempt() *NodeExecutionContext_CurrentAttempt_Call

CurrentAttempt is a helper method to define mock.On call

func (*NodeExecutionContext_Expecter) DataStore added in v1.15.1 

func (_e *NodeExecutionContext_Expecter) DataStore() *NodeExecutionContext_DataStore_Call

DataStore is a helper method to define mock.On call

func (*NodeExecutionContext_Expecter) EnqueueOwnerFunc added in v1.15.1 

func (_e *NodeExecutionContext_Expecter) EnqueueOwnerFunc() *NodeExecutionContext_EnqueueOwnerFunc_Call

EnqueueOwnerFunc is a helper method to define mock.On call

func (*NodeExecutionContext_Expecter) EventsRecorder added in v1.15.1 

func (_e *NodeExecutionContext_Expecter) EventsRecorder() *NodeExecutionContext_EventsRecorder_Call

EventsRecorder is a helper method to define mock.On call

func (*NodeExecutionContext_Expecter) ExecutionContext added in v1.15.1 

func (_e *NodeExecutionContext_Expecter) ExecutionContext() *NodeExecutionContext_ExecutionContext_Call

ExecutionContext is a helper method to define mock.On call

func (*NodeExecutionContext_Expecter) InputReader added in v1.15.1 

func (_e *NodeExecutionContext_Expecter) InputReader() *NodeExecutionContext_InputReader_Call

InputReader is a helper method to define mock.On call

func (*NodeExecutionContext_Expecter) Node added in v1.15.1 

func (_e *NodeExecutionContext_Expecter) Node() *NodeExecutionContext_Node_Call

Node is a helper method to define mock.On call

func (*NodeExecutionContext_Expecter) NodeExecutionMetadata added in v1.15.1 

func (_e *NodeExecutionContext_Expecter) NodeExecutionMetadata() *NodeExecutionContext_NodeExecutionMetadata_Call

NodeExecutionMetadata is a helper method to define mock.On call

func (*NodeExecutionContext_Expecter) NodeID added in v1.15.1 

func (_e *NodeExecutionContext_Expecter) NodeID() *NodeExecutionContext_NodeID_Call

NodeID is a helper method to define mock.On call

func (*NodeExecutionContext_Expecter) NodeStateReader added in v1.15.1 

func (_e *NodeExecutionContext_Expecter) NodeStateReader() *NodeExecutionContext_NodeStateReader_Call

NodeStateReader is a helper method to define mock.On call

func (*NodeExecutionContext_Expecter) NodeStateWriter added in v1.15.1 

func (_e *NodeExecutionContext_Expecter) NodeStateWriter() *NodeExecutionContext_NodeStateWriter_Call

NodeStateWriter is a helper method to define mock.On call

func (*NodeExecutionContext_Expecter) NodeStatus added in v1.15.1 

func (_e *NodeExecutionContext_Expecter) NodeStatus() *NodeExecutionContext_NodeStatus_Call

NodeStatus is a helper method to define mock.On call

func (*NodeExecutionContext_Expecter) OutputShardSelector added in v1.15.1 

func (_e *NodeExecutionContext_Expecter) OutputShardSelector() *NodeExecutionContext_OutputShardSelector_Call

OutputShardSelector is a helper method to define mock.On call

func (*NodeExecutionContext_Expecter) RawOutputPrefix added in v1.15.1 

func (_e *NodeExecutionContext_Expecter) RawOutputPrefix() *NodeExecutionContext_RawOutputPrefix_Call

RawOutputPrefix is a helper method to define mock.On call

func (*NodeExecutionContext_Expecter) TaskReader added in v1.15.1 

func (_e *NodeExecutionContext_Expecter) TaskReader() *NodeExecutionContext_TaskReader_Call

TaskReader is a helper method to define mock.On call

type NodeExecutionContext_InputReader_Call added in v1.15.1 

type NodeExecutionContext_InputReader_Call struct {
	*mock.Call
}

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

func (*NodeExecutionContext_InputReader_Call) Return added in v1.15.1 

func (_c *NodeExecutionContext_InputReader_Call) Return(_a0 io.InputReader) *NodeExecutionContext_InputReader_Call

func (*NodeExecutionContext_InputReader_Call) Run added in v1.15.1 

func (_c *NodeExecutionContext_InputReader_Call) Run(run func()) *NodeExecutionContext_InputReader_Call

func (*NodeExecutionContext_InputReader_Call) RunAndReturn added in v1.15.1 

func (_c *NodeExecutionContext_InputReader_Call) RunAndReturn(run func() io.InputReader) *NodeExecutionContext_InputReader_Call

type NodeExecutionContext_NodeExecutionMetadata_Call added in v1.15.1 

type NodeExecutionContext_NodeExecutionMetadata_Call struct {
	*mock.Call
}

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

func (*NodeExecutionContext_NodeExecutionMetadata_Call) Return added in v1.15.1 

func (_c *NodeExecutionContext_NodeExecutionMetadata_Call) Return(_a0 interfaces.NodeExecutionMetadata) *NodeExecutionContext_NodeExecutionMetadata_Call

func (*NodeExecutionContext_NodeExecutionMetadata_Call) Run added in v1.15.1 

func (_c *NodeExecutionContext_NodeExecutionMetadata_Call) Run(run func()) *NodeExecutionContext_NodeExecutionMetadata_Call

func (*NodeExecutionContext_NodeExecutionMetadata_Call) RunAndReturn added in v1.15.1 

func (_c *NodeExecutionContext_NodeExecutionMetadata_Call) RunAndReturn(run func() interfaces.NodeExecutionMetadata) *NodeExecutionContext_NodeExecutionMetadata_Call

type NodeExecutionContext_NodeID_Call added in v1.15.1 

type NodeExecutionContext_NodeID_Call struct {
	*mock.Call
}

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

func (*NodeExecutionContext_NodeID_Call) Return added in v1.15.1 

func (_c *NodeExecutionContext_NodeID_Call) Return(_a0 string) *NodeExecutionContext_NodeID_Call

func (*NodeExecutionContext_NodeID_Call) Run added in v1.15.1 

func (_c *NodeExecutionContext_NodeID_Call) Run(run func()) *NodeExecutionContext_NodeID_Call

func (*NodeExecutionContext_NodeID_Call) RunAndReturn added in v1.15.1 

func (_c *NodeExecutionContext_NodeID_Call) RunAndReturn(run func() string) *NodeExecutionContext_NodeID_Call

type NodeExecutionContext_NodeStateReader_Call added in v1.15.1 

type NodeExecutionContext_NodeStateReader_Call struct {
	*mock.Call
}

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

func (*NodeExecutionContext_NodeStateReader_Call) Return added in v1.15.1 

func (_c *NodeExecutionContext_NodeStateReader_Call) Return(_a0 interfaces.NodeStateReader) *NodeExecutionContext_NodeStateReader_Call

func (*NodeExecutionContext_NodeStateReader_Call) Run added in v1.15.1 

func (_c *NodeExecutionContext_NodeStateReader_Call) Run(run func()) *NodeExecutionContext_NodeStateReader_Call

func (*NodeExecutionContext_NodeStateReader_Call) RunAndReturn added in v1.15.1 

func (_c *NodeExecutionContext_NodeStateReader_Call) RunAndReturn(run func() interfaces.NodeStateReader) *NodeExecutionContext_NodeStateReader_Call

type NodeExecutionContext_NodeStateWriter_Call added in v1.15.1 

type NodeExecutionContext_NodeStateWriter_Call struct {
	*mock.Call
}

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

func (*NodeExecutionContext_NodeStateWriter_Call) Return added in v1.15.1 

func (_c *NodeExecutionContext_NodeStateWriter_Call) Return(_a0 interfaces.NodeStateWriter) *NodeExecutionContext_NodeStateWriter_Call

func (*NodeExecutionContext_NodeStateWriter_Call) Run added in v1.15.1 

func (_c *NodeExecutionContext_NodeStateWriter_Call) Run(run func()) *NodeExecutionContext_NodeStateWriter_Call

func (*NodeExecutionContext_NodeStateWriter_Call) RunAndReturn added in v1.15.1 

func (_c *NodeExecutionContext_NodeStateWriter_Call) RunAndReturn(run func() interfaces.NodeStateWriter) *NodeExecutionContext_NodeStateWriter_Call

type NodeExecutionContext_NodeStatus_Call added in v1.15.1 

type NodeExecutionContext_NodeStatus_Call struct {
	*mock.Call
}

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

func (*NodeExecutionContext_NodeStatus_Call) Return added in v1.15.1 

func (_c *NodeExecutionContext_NodeStatus_Call) Return(_a0 v1alpha1.ExecutableNodeStatus) *NodeExecutionContext_NodeStatus_Call

func (*NodeExecutionContext_NodeStatus_Call) Run added in v1.15.1 

func (_c *NodeExecutionContext_NodeStatus_Call) Run(run func()) *NodeExecutionContext_NodeStatus_Call

func (*NodeExecutionContext_NodeStatus_Call) RunAndReturn added in v1.15.1 

func (_c *NodeExecutionContext_NodeStatus_Call) RunAndReturn(run func() v1alpha1.ExecutableNodeStatus) *NodeExecutionContext_NodeStatus_Call

type NodeExecutionContext_Node_Call added in v1.15.1 

type NodeExecutionContext_Node_Call struct {
	*mock.Call
}

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

func (*NodeExecutionContext_Node_Call) Return added in v1.15.1 

func (_c *NodeExecutionContext_Node_Call) Return(_a0 v1alpha1.ExecutableNode) *NodeExecutionContext_Node_Call

func (*NodeExecutionContext_Node_Call) Run added in v1.15.1 

func (_c *NodeExecutionContext_Node_Call) Run(run func()) *NodeExecutionContext_Node_Call

func (*NodeExecutionContext_Node_Call) RunAndReturn added in v1.15.1 

func (_c *NodeExecutionContext_Node_Call) RunAndReturn(run func() v1alpha1.ExecutableNode) *NodeExecutionContext_Node_Call

type NodeExecutionContext_OutputShardSelector_Call added in v1.15.1 

type NodeExecutionContext_OutputShardSelector_Call struct {
	*mock.Call
}

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

func (*NodeExecutionContext_OutputShardSelector_Call) Return added in v1.15.1 

func (_c *NodeExecutionContext_OutputShardSelector_Call) Return(_a0 ioutils.ShardSelector) *NodeExecutionContext_OutputShardSelector_Call

func (*NodeExecutionContext_OutputShardSelector_Call) Run added in v1.15.1 

func (_c *NodeExecutionContext_OutputShardSelector_Call) Run(run func()) *NodeExecutionContext_OutputShardSelector_Call

func (*NodeExecutionContext_OutputShardSelector_Call) RunAndReturn added in v1.15.1 

func (_c *NodeExecutionContext_OutputShardSelector_Call) RunAndReturn(run func() ioutils.ShardSelector) *NodeExecutionContext_OutputShardSelector_Call

type NodeExecutionContext_RawOutputPrefix_Call added in v1.15.1 

type NodeExecutionContext_RawOutputPrefix_Call struct {
	*mock.Call
}

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

func (*NodeExecutionContext_RawOutputPrefix_Call) Return added in v1.15.1 

func (_c *NodeExecutionContext_RawOutputPrefix_Call) Return(_a0 storage.DataReference) *NodeExecutionContext_RawOutputPrefix_Call

func (*NodeExecutionContext_RawOutputPrefix_Call) Run added in v1.15.1 

func (_c *NodeExecutionContext_RawOutputPrefix_Call) Run(run func()) *NodeExecutionContext_RawOutputPrefix_Call

func (*NodeExecutionContext_RawOutputPrefix_Call) RunAndReturn added in v1.15.1 

func (_c *NodeExecutionContext_RawOutputPrefix_Call) RunAndReturn(run func() storage.DataReference) *NodeExecutionContext_RawOutputPrefix_Call

type NodeExecutionContext_TaskReader_Call added in v1.15.1 

type NodeExecutionContext_TaskReader_Call struct {
	*mock.Call
}

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

func (*NodeExecutionContext_TaskReader_Call) Return added in v1.15.1 

func (_c *NodeExecutionContext_TaskReader_Call) Return(_a0 interfaces.TaskReader) *NodeExecutionContext_TaskReader_Call

func (*NodeExecutionContext_TaskReader_Call) Run added in v1.15.1 

func (_c *NodeExecutionContext_TaskReader_Call) Run(run func()) *NodeExecutionContext_TaskReader_Call

func (*NodeExecutionContext_TaskReader_Call) RunAndReturn added in v1.15.1 

func (_c *NodeExecutionContext_TaskReader_Call) RunAndReturn(run func() interfaces.TaskReader) *NodeExecutionContext_TaskReader_Call

type NodeExecutionMetadata 

type NodeExecutionMetadata struct {
	mock.Mock
}

NodeExecutionMetadata is an autogenerated mock type for the NodeExecutionMetadata type

func NewNodeExecutionMetadata added in v1.15.1 

func NewNodeExecutionMetadata(t interface {
	mock.TestingT
	Cleanup(func())
}) *NodeExecutionMetadata

NewNodeExecutionMetadata creates a new instance of NodeExecutionMetadata. 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 (*NodeExecutionMetadata) EXPECT added in v1.15.1 

func (_m *NodeExecutionMetadata) EXPECT() *NodeExecutionMetadata_Expecter

func (*NodeExecutionMetadata) GetAnnotations 

func (_m *NodeExecutionMetadata) GetAnnotations() map[string]string

GetAnnotations provides a mock function with no fields

func (*NodeExecutionMetadata) GetConsoleURL added in v1.13.0 

func (_m *NodeExecutionMetadata) GetConsoleURL() string

GetConsoleURL provides a mock function with no fields

func (*NodeExecutionMetadata) GetInterruptibleFailureThreshold 

func (_m *NodeExecutionMetadata) GetInterruptibleFailureThreshold() int32

GetInterruptibleFailureThreshold provides a mock function with no fields

func (*NodeExecutionMetadata) GetK8sServiceAccount 

func (_m *NodeExecutionMetadata) GetK8sServiceAccount() string

GetK8sServiceAccount provides a mock function with no fields

func (*NodeExecutionMetadata) GetLabels 

func (_m *NodeExecutionMetadata) GetLabels() map[string]string

GetLabels provides a mock function with no fields

func (*NodeExecutionMetadata) GetNamespace 

func (_m *NodeExecutionMetadata) GetNamespace() string

GetNamespace provides a mock function with no fields

func (*NodeExecutionMetadata) GetNodeExecutionID 

func (_m *NodeExecutionMetadata) GetNodeExecutionID() *core.NodeExecutionIdentifier

GetNodeExecutionID provides a mock function with no fields

func (*NodeExecutionMetadata) GetOwnerID 

func (_m *NodeExecutionMetadata) GetOwnerID() types.NamespacedName

GetOwnerID provides a mock function with no fields

func (*NodeExecutionMetadata) GetOwnerReference 

func (_m *NodeExecutionMetadata) GetOwnerReference() v1.OwnerReference

GetOwnerReference provides a mock function with no fields

func (*NodeExecutionMetadata) GetSecurityContext 

func (_m *NodeExecutionMetadata) GetSecurityContext() core.SecurityContext

GetSecurityContext provides a mock function with no fields

func (*NodeExecutionMetadata) IsInterruptible 

func (_m *NodeExecutionMetadata) IsInterruptible() bool

IsInterruptible provides a mock function with no fields

type NodeExecutionMetadata_Expecter added in v1.15.1 

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

func (*NodeExecutionMetadata_Expecter) GetAnnotations added in v1.15.1 

func (_e *NodeExecutionMetadata_Expecter) GetAnnotations() *NodeExecutionMetadata_GetAnnotations_Call

GetAnnotations is a helper method to define mock.On call

func (*NodeExecutionMetadata_Expecter) GetConsoleURL added in v1.15.1 

func (_e *NodeExecutionMetadata_Expecter) GetConsoleURL() *NodeExecutionMetadata_GetConsoleURL_Call

GetConsoleURL is a helper method to define mock.On call

func (*NodeExecutionMetadata_Expecter) GetInterruptibleFailureThreshold added in v1.15.1 

func (_e *NodeExecutionMetadata_Expecter) GetInterruptibleFailureThreshold() *NodeExecutionMetadata_GetInterruptibleFailureThreshold_Call

GetInterruptibleFailureThreshold is a helper method to define mock.On call

func (*NodeExecutionMetadata_Expecter) GetK8sServiceAccount added in v1.15.1 

func (_e *NodeExecutionMetadata_Expecter) GetK8sServiceAccount() *NodeExecutionMetadata_GetK8sServiceAccount_Call

GetK8sServiceAccount is a helper method to define mock.On call

func (*NodeExecutionMetadata_Expecter) GetLabels added in v1.15.1 

func (_e *NodeExecutionMetadata_Expecter) GetLabels() *NodeExecutionMetadata_GetLabels_Call

GetLabels is a helper method to define mock.On call

func (*NodeExecutionMetadata_Expecter) GetNamespace added in v1.15.1 

func (_e *NodeExecutionMetadata_Expecter) GetNamespace() *NodeExecutionMetadata_GetNamespace_Call

GetNamespace is a helper method to define mock.On call

func (*NodeExecutionMetadata_Expecter) GetNodeExecutionID added in v1.15.1 

func (_e *NodeExecutionMetadata_Expecter) GetNodeExecutionID() *NodeExecutionMetadata_GetNodeExecutionID_Call

GetNodeExecutionID is a helper method to define mock.On call

func (*NodeExecutionMetadata_Expecter) GetOwnerID added in v1.15.1 

func (_e *NodeExecutionMetadata_Expecter) GetOwnerID() *NodeExecutionMetadata_GetOwnerID_Call

GetOwnerID is a helper method to define mock.On call

func (*NodeExecutionMetadata_Expecter) GetOwnerReference added in v1.15.1 

func (_e *NodeExecutionMetadata_Expecter) GetOwnerReference() *NodeExecutionMetadata_GetOwnerReference_Call

GetOwnerReference is a helper method to define mock.On call

func (*NodeExecutionMetadata_Expecter) GetSecurityContext added in v1.15.1 

func (_e *NodeExecutionMetadata_Expecter) GetSecurityContext() *NodeExecutionMetadata_GetSecurityContext_Call

GetSecurityContext is a helper method to define mock.On call

func (*NodeExecutionMetadata_Expecter) IsInterruptible added in v1.15.1 

func (_e *NodeExecutionMetadata_Expecter) IsInterruptible() *NodeExecutionMetadata_IsInterruptible_Call

IsInterruptible is a helper method to define mock.On call

type NodeExecutionMetadata_GetAnnotations_Call added in v1.15.1 

type NodeExecutionMetadata_GetAnnotations_Call struct {
	*mock.Call
}

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

func (*NodeExecutionMetadata_GetAnnotations_Call) Return added in v1.15.1 

func (_c *NodeExecutionMetadata_GetAnnotations_Call) Return(_a0 map[string]string) *NodeExecutionMetadata_GetAnnotations_Call

func (*NodeExecutionMetadata_GetAnnotations_Call) Run added in v1.15.1 

func (_c *NodeExecutionMetadata_GetAnnotations_Call) Run(run func()) *NodeExecutionMetadata_GetAnnotations_Call

func (*NodeExecutionMetadata_GetAnnotations_Call) RunAndReturn added in v1.15.1 

func (_c *NodeExecutionMetadata_GetAnnotations_Call) RunAndReturn(run func() map[string]string) *NodeExecutionMetadata_GetAnnotations_Call

type NodeExecutionMetadata_GetConsoleURL_Call added in v1.15.1 

type NodeExecutionMetadata_GetConsoleURL_Call struct {
	*mock.Call
}

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

func (*NodeExecutionMetadata_GetConsoleURL_Call) Return added in v1.15.1 

func (_c *NodeExecutionMetadata_GetConsoleURL_Call) Return(_a0 string) *NodeExecutionMetadata_GetConsoleURL_Call

func (*NodeExecutionMetadata_GetConsoleURL_Call) Run added in v1.15.1 

func (_c *NodeExecutionMetadata_GetConsoleURL_Call) Run(run func()) *NodeExecutionMetadata_GetConsoleURL_Call

func (*NodeExecutionMetadata_GetConsoleURL_Call) RunAndReturn added in v1.15.1 

func (_c *NodeExecutionMetadata_GetConsoleURL_Call) RunAndReturn(run func() string) *NodeExecutionMetadata_GetConsoleURL_Call

type NodeExecutionMetadata_GetInterruptibleFailureThreshold_Call added in v1.15.1 

type NodeExecutionMetadata_GetInterruptibleFailureThreshold_Call struct {
	*mock.Call
}

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

func (*NodeExecutionMetadata_GetInterruptibleFailureThreshold_Call) Return added in v1.15.1 

func (_c *NodeExecutionMetadata_GetInterruptibleFailureThreshold_Call) Return(_a0 int32) *NodeExecutionMetadata_GetInterruptibleFailureThreshold_Call

func (*NodeExecutionMetadata_GetInterruptibleFailureThreshold_Call) Run added in v1.15.1 

func (_c *NodeExecutionMetadata_GetInterruptibleFailureThreshold_Call) Run(run func()) *NodeExecutionMetadata_GetInterruptibleFailureThreshold_Call

func (*NodeExecutionMetadata_GetInterruptibleFailureThreshold_Call) RunAndReturn added in v1.15.1 

func (_c *NodeExecutionMetadata_GetInterruptibleFailureThreshold_Call) RunAndReturn(run func() int32) *NodeExecutionMetadata_GetInterruptibleFailureThreshold_Call

type NodeExecutionMetadata_GetK8sServiceAccount_Call added in v1.15.1 

type NodeExecutionMetadata_GetK8sServiceAccount_Call struct {
	*mock.Call
}

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

func (*NodeExecutionMetadata_GetK8sServiceAccount_Call) Return added in v1.15.1 

func (_c *NodeExecutionMetadata_GetK8sServiceAccount_Call) Return(_a0 string) *NodeExecutionMetadata_GetK8sServiceAccount_Call

func (*NodeExecutionMetadata_GetK8sServiceAccount_Call) Run added in v1.15.1 

func (_c *NodeExecutionMetadata_GetK8sServiceAccount_Call) Run(run func()) *NodeExecutionMetadata_GetK8sServiceAccount_Call

func (*NodeExecutionMetadata_GetK8sServiceAccount_Call) RunAndReturn added in v1.15.1 

func (_c *NodeExecutionMetadata_GetK8sServiceAccount_Call) RunAndReturn(run func() string) *NodeExecutionMetadata_GetK8sServiceAccount_Call

type NodeExecutionMetadata_GetLabels_Call added in v1.15.1 

type NodeExecutionMetadata_GetLabels_Call struct {
	*mock.Call
}

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

func (*NodeExecutionMetadata_GetLabels_Call) Return added in v1.15.1 

func (_c *NodeExecutionMetadata_GetLabels_Call) Return(_a0 map[string]string) *NodeExecutionMetadata_GetLabels_Call

func (*NodeExecutionMetadata_GetLabels_Call) Run added in v1.15.1 

func (_c *NodeExecutionMetadata_GetLabels_Call) Run(run func()) *NodeExecutionMetadata_GetLabels_Call

func (*NodeExecutionMetadata_GetLabels_Call) RunAndReturn added in v1.15.1 

func (_c *NodeExecutionMetadata_GetLabels_Call) RunAndReturn(run func() map[string]string) *NodeExecutionMetadata_GetLabels_Call

type NodeExecutionMetadata_GetNamespace_Call added in v1.15.1 

type NodeExecutionMetadata_GetNamespace_Call struct {
	*mock.Call
}

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

func (*NodeExecutionMetadata_GetNamespace_Call) Return added in v1.15.1 

func (_c *NodeExecutionMetadata_GetNamespace_Call) Return(_a0 string) *NodeExecutionMetadata_GetNamespace_Call

func (*NodeExecutionMetadata_GetNamespace_Call) Run added in v1.15.1 

func (_c *NodeExecutionMetadata_GetNamespace_Call) Run(run func()) *NodeExecutionMetadata_GetNamespace_Call

func (*NodeExecutionMetadata_GetNamespace_Call) RunAndReturn added in v1.15.1 

func (_c *NodeExecutionMetadata_GetNamespace_Call) RunAndReturn(run func() string) *NodeExecutionMetadata_GetNamespace_Call

type NodeExecutionMetadata_GetNodeExecutionID_Call added in v1.15.1 

type NodeExecutionMetadata_GetNodeExecutionID_Call struct {
	*mock.Call
}

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

func (*NodeExecutionMetadata_GetNodeExecutionID_Call) Return added in v1.15.1 

func (_c *NodeExecutionMetadata_GetNodeExecutionID_Call) Return(_a0 *core.NodeExecutionIdentifier) *NodeExecutionMetadata_GetNodeExecutionID_Call

func (*NodeExecutionMetadata_GetNodeExecutionID_Call) Run added in v1.15.1 

func (_c *NodeExecutionMetadata_GetNodeExecutionID_Call) Run(run func()) *NodeExecutionMetadata_GetNodeExecutionID_Call

func (*NodeExecutionMetadata_GetNodeExecutionID_Call) RunAndReturn added in v1.15.1 

func (_c *NodeExecutionMetadata_GetNodeExecutionID_Call) RunAndReturn(run func() *core.NodeExecutionIdentifier) *NodeExecutionMetadata_GetNodeExecutionID_Call

type NodeExecutionMetadata_GetOwnerID_Call added in v1.15.1 

type NodeExecutionMetadata_GetOwnerID_Call struct {
	*mock.Call
}

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

func (*NodeExecutionMetadata_GetOwnerID_Call) Return added in v1.15.1 

func (_c *NodeExecutionMetadata_GetOwnerID_Call) Return(_a0 types.NamespacedName) *NodeExecutionMetadata_GetOwnerID_Call

func (*NodeExecutionMetadata_GetOwnerID_Call) Run added in v1.15.1 

func (_c *NodeExecutionMetadata_GetOwnerID_Call) Run(run func()) *NodeExecutionMetadata_GetOwnerID_Call

func (*NodeExecutionMetadata_GetOwnerID_Call) RunAndReturn added in v1.15.1 

func (_c *NodeExecutionMetadata_GetOwnerID_Call) RunAndReturn(run func() types.NamespacedName) *NodeExecutionMetadata_GetOwnerID_Call

type NodeExecutionMetadata_GetOwnerReference_Call added in v1.15.1 

type NodeExecutionMetadata_GetOwnerReference_Call struct {
	*mock.Call
}

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

func (*NodeExecutionMetadata_GetOwnerReference_Call) Return added in v1.15.1 

func (_c *NodeExecutionMetadata_GetOwnerReference_Call) Return(_a0 v1.OwnerReference) *NodeExecutionMetadata_GetOwnerReference_Call

func (*NodeExecutionMetadata_GetOwnerReference_Call) Run added in v1.15.1 

func (_c *NodeExecutionMetadata_GetOwnerReference_Call) Run(run func()) *NodeExecutionMetadata_GetOwnerReference_Call

func (*NodeExecutionMetadata_GetOwnerReference_Call) RunAndReturn added in v1.15.1 

func (_c *NodeExecutionMetadata_GetOwnerReference_Call) RunAndReturn(run func() v1.OwnerReference) *NodeExecutionMetadata_GetOwnerReference_Call

type NodeExecutionMetadata_GetSecurityContext_Call added in v1.15.1 

type NodeExecutionMetadata_GetSecurityContext_Call struct {
	*mock.Call
}

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

func (*NodeExecutionMetadata_GetSecurityContext_Call) Return added in v1.15.1 

func (_c *NodeExecutionMetadata_GetSecurityContext_Call) Return(_a0 core.SecurityContext) *NodeExecutionMetadata_GetSecurityContext_Call

func (*NodeExecutionMetadata_GetSecurityContext_Call) Run added in v1.15.1 

func (_c *NodeExecutionMetadata_GetSecurityContext_Call) Run(run func()) *NodeExecutionMetadata_GetSecurityContext_Call

func (*NodeExecutionMetadata_GetSecurityContext_Call) RunAndReturn added in v1.15.1 

func (_c *NodeExecutionMetadata_GetSecurityContext_Call) RunAndReturn(run func() core.SecurityContext) *NodeExecutionMetadata_GetSecurityContext_Call

type NodeExecutionMetadata_IsInterruptible_Call added in v1.15.1 

type NodeExecutionMetadata_IsInterruptible_Call struct {
	*mock.Call
}

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

func (*NodeExecutionMetadata_IsInterruptible_Call) Return added in v1.15.1 

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

func (*NodeExecutionMetadata_IsInterruptible_Call) Run added in v1.15.1 

func (_c *NodeExecutionMetadata_IsInterruptible_Call) Run(run func()) *NodeExecutionMetadata_IsInterruptible_Call

func (*NodeExecutionMetadata_IsInterruptible_Call) RunAndReturn added in v1.15.1 

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

type NodeExecutor 

type NodeExecutor struct {
	mock.Mock
}

NodeExecutor is an autogenerated mock type for the NodeExecutor type

func NewNodeExecutor added in v1.15.1 

func NewNodeExecutor(t interface {
	mock.TestingT
	Cleanup(func())
}) *NodeExecutor

NewNodeExecutor creates a new instance of NodeExecutor. 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 (*NodeExecutor) Abort 

func (_m *NodeExecutor) Abort(ctx context.Context, h interfaces.NodeHandler, nCtx interfaces.NodeExecutionContext, reason string, finalTransition bool) error

Abort provides a mock function with given fields: ctx, h, nCtx, reason, finalTransition

func (*NodeExecutor) EXPECT added in v1.15.1 

func (_m *NodeExecutor) EXPECT() *NodeExecutor_Expecter

func (*NodeExecutor) Finalize 

func (_m *NodeExecutor) Finalize(ctx context.Context, h interfaces.NodeHandler, nCtx interfaces.NodeExecutionContext) error

Finalize provides a mock function with given fields: ctx, h, nCtx

func (*NodeExecutor) HandleNode 

func (_m *NodeExecutor) HandleNode(ctx context.Context, dag executors.DAGStructure, nCtx interfaces.NodeExecutionContext, h interfaces.NodeHandler) (interfaces.NodeStatus, error)

HandleNode provides a mock function with given fields: ctx, dag, nCtx, h

type NodeExecutor_Abort_Call added in v1.15.1 

type NodeExecutor_Abort_Call struct {
	*mock.Call
}

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

func (*NodeExecutor_Abort_Call) Return added in v1.15.1 

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

func (*NodeExecutor_Abort_Call) Run added in v1.15.1 

func (_c *NodeExecutor_Abort_Call) Run(run func(ctx context.Context, h interfaces.NodeHandler, nCtx interfaces.NodeExecutionContext, reason string, finalTransition bool)) *NodeExecutor_Abort_Call

func (*NodeExecutor_Abort_Call) RunAndReturn added in v1.15.1 

func (_c *NodeExecutor_Abort_Call) RunAndReturn(run func(context.Context, interfaces.NodeHandler, interfaces.NodeExecutionContext, string, bool) error) *NodeExecutor_Abort_Call

type NodeExecutor_Expecter added in v1.15.1 

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

func (*NodeExecutor_Expecter) Abort added in v1.15.1 

func (_e *NodeExecutor_Expecter) Abort(ctx interface{}, h interface{}, nCtx interface{}, reason interface{}, finalTransition interface{}) *NodeExecutor_Abort_Call

Abort is a helper method to define mock.On call

  • ctx context.Context
  • h interfaces.NodeHandler
  • nCtx interfaces.NodeExecutionContext
  • reason string
  • finalTransition bool

func (*NodeExecutor_Expecter) Finalize added in v1.15.1 

func (_e *NodeExecutor_Expecter) Finalize(ctx interface{}, h interface{}, nCtx interface{}) *NodeExecutor_Finalize_Call

Finalize is a helper method to define mock.On call

  • ctx context.Context
  • h interfaces.NodeHandler
  • nCtx interfaces.NodeExecutionContext

func (*NodeExecutor_Expecter) HandleNode added in v1.15.1 

func (_e *NodeExecutor_Expecter) HandleNode(ctx interface{}, dag interface{}, nCtx interface{}, h interface{}) *NodeExecutor_HandleNode_Call

HandleNode is a helper method to define mock.On call

  • ctx context.Context
  • dag executors.DAGStructure
  • nCtx interfaces.NodeExecutionContext
  • h interfaces.NodeHandler

type NodeExecutor_Finalize_Call added in v1.15.1 

type NodeExecutor_Finalize_Call struct {
	*mock.Call
}

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

func (*NodeExecutor_Finalize_Call) Return added in v1.15.1 

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

func (*NodeExecutor_Finalize_Call) Run added in v1.15.1 

func (_c *NodeExecutor_Finalize_Call) Run(run func(ctx context.Context, h interfaces.NodeHandler, nCtx interfaces.NodeExecutionContext)) *NodeExecutor_Finalize_Call

func (*NodeExecutor_Finalize_Call) RunAndReturn added in v1.15.1 

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

type NodeExecutor_HandleNode_Call added in v1.15.1 

type NodeExecutor_HandleNode_Call struct {
	*mock.Call
}

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

func (*NodeExecutor_HandleNode_Call) Return added in v1.15.1 

func (_c *NodeExecutor_HandleNode_Call) Return(_a0 interfaces.NodeStatus, _a1 error) *NodeExecutor_HandleNode_Call

func (*NodeExecutor_HandleNode_Call) Run added in v1.15.1 

func (_c *NodeExecutor_HandleNode_Call) Run(run func(ctx context.Context, dag executors.DAGStructure, nCtx interfaces.NodeExecutionContext, h interfaces.NodeHandler)) *NodeExecutor_HandleNode_Call

func (*NodeExecutor_HandleNode_Call) RunAndReturn added in v1.15.1 

func (_c *NodeExecutor_HandleNode_Call) RunAndReturn(run func(context.Context, executors.DAGStructure, interfaces.NodeExecutionContext, interfaces.NodeHandler) (interfaces.NodeStatus, error)) *NodeExecutor_HandleNode_Call

type NodeHandler 

type NodeHandler struct {
	mock.Mock
}

NodeHandler is an autogenerated mock type for the NodeHandler type

func NewNodeHandler added in v1.15.1 

func NewNodeHandler(t interface {
	mock.TestingT
	Cleanup(func())
}) *NodeHandler

NewNodeHandler creates a new instance of NodeHandler. 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 (*NodeHandler) Abort 

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

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

func (*NodeHandler) EXPECT added in v1.15.1 

func (_m *NodeHandler) EXPECT() *NodeHandler_Expecter

func (*NodeHandler) Finalize 

func (_m *NodeHandler) Finalize(ctx context.Context, executionContext interfaces.NodeExecutionContext) error

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

func (*NodeHandler) FinalizeRequired 

func (_m *NodeHandler) FinalizeRequired() bool

FinalizeRequired provides a mock function with no fields

func (*NodeHandler) Handle 

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

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

func (*NodeHandler) Setup 

func (_m *NodeHandler) Setup(ctx context.Context, setupContext interfaces.SetupContext) error

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

type NodeHandler_Abort_Call added in v1.15.1 

type NodeHandler_Abort_Call struct {
	*mock.Call
}

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

func (*NodeHandler_Abort_Call) Return added in v1.15.1 

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

func (*NodeHandler_Abort_Call) Run added in v1.15.1 

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

func (*NodeHandler_Abort_Call) RunAndReturn added in v1.15.1 

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

type NodeHandler_Expecter added in v1.15.1 

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

func (*NodeHandler_Expecter) Abort added in v1.15.1 

func (_e *NodeHandler_Expecter) Abort(ctx interface{}, executionContext interface{}, reason interface{}) *NodeHandler_Abort_Call

Abort is a helper method to define mock.On call

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

func (*NodeHandler_Expecter) Finalize added in v1.15.1 

func (_e *NodeHandler_Expecter) Finalize(ctx interface{}, executionContext interface{}) *NodeHandler_Finalize_Call

Finalize is a helper method to define mock.On call

  • ctx context.Context
  • executionContext interfaces.NodeExecutionContext

func (*NodeHandler_Expecter) FinalizeRequired added in v1.15.1 

func (_e *NodeHandler_Expecter) FinalizeRequired() *NodeHandler_FinalizeRequired_Call

FinalizeRequired is a helper method to define mock.On call

func (*NodeHandler_Expecter) Handle added in v1.15.1 

func (_e *NodeHandler_Expecter) Handle(ctx interface{}, executionContext interface{}) *NodeHandler_Handle_Call

Handle is a helper method to define mock.On call

  • ctx context.Context
  • executionContext interfaces.NodeExecutionContext

func (*NodeHandler_Expecter) Setup added in v1.15.1 

func (_e *NodeHandler_Expecter) Setup(ctx interface{}, setupContext interface{}) *NodeHandler_Setup_Call

Setup is a helper method to define mock.On call

  • ctx context.Context
  • setupContext interfaces.SetupContext

type NodeHandler_FinalizeRequired_Call added in v1.15.1 

type NodeHandler_FinalizeRequired_Call struct {
	*mock.Call
}

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

func (*NodeHandler_FinalizeRequired_Call) Return added in v1.15.1 

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

func (*NodeHandler_FinalizeRequired_Call) Run added in v1.15.1 

func (_c *NodeHandler_FinalizeRequired_Call) Run(run func()) *NodeHandler_FinalizeRequired_Call

func (*NodeHandler_FinalizeRequired_Call) RunAndReturn added in v1.15.1 

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

type NodeHandler_Finalize_Call added in v1.15.1 

type NodeHandler_Finalize_Call struct {
	*mock.Call
}

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

func (*NodeHandler_Finalize_Call) Return added in v1.15.1 

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

func (*NodeHandler_Finalize_Call) Run added in v1.15.1 

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

func (*NodeHandler_Finalize_Call) RunAndReturn added in v1.15.1 

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

type NodeHandler_Handle_Call added in v1.15.1 

type NodeHandler_Handle_Call struct {
	*mock.Call
}

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

func (*NodeHandler_Handle_Call) Return added in v1.15.1 

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

func (*NodeHandler_Handle_Call) Run added in v1.15.1 

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

func (*NodeHandler_Handle_Call) RunAndReturn added in v1.15.1 

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

type NodeHandler_Setup_Call added in v1.15.1 

type NodeHandler_Setup_Call struct {
	*mock.Call
}

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

func (*NodeHandler_Setup_Call) Return added in v1.15.1 

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

func (*NodeHandler_Setup_Call) Run added in v1.15.1 

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

func (*NodeHandler_Setup_Call) RunAndReturn added in v1.15.1 

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

type NodeStateReader 

type NodeStateReader struct {
	mock.Mock
}

NodeStateReader is an autogenerated mock type for the NodeStateReader type

func NewNodeStateReader added in v1.15.1 

func NewNodeStateReader(t interface {
	mock.TestingT
	Cleanup(func())
}) *NodeStateReader

NewNodeStateReader creates a new instance of NodeStateReader. 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 (*NodeStateReader) EXPECT added in v1.15.1 

func (_m *NodeStateReader) EXPECT() *NodeStateReader_Expecter

func (*NodeStateReader) GetArrayNodeState 

func (_m *NodeStateReader) GetArrayNodeState() handler.ArrayNodeState

GetArrayNodeState provides a mock function with no fields

func (*NodeStateReader) GetBranchNodeState 

func (_m *NodeStateReader) GetBranchNodeState() handler.BranchNodeState

GetBranchNodeState provides a mock function with no fields

func (*NodeStateReader) GetDynamicNodeState 

func (_m *NodeStateReader) GetDynamicNodeState() handler.DynamicNodeState

GetDynamicNodeState provides a mock function with no fields

func (*NodeStateReader) GetGateNodeState 

func (_m *NodeStateReader) GetGateNodeState() handler.GateNodeState

GetGateNodeState provides a mock function with no fields

func (*NodeStateReader) GetTaskNodeState 

func (_m *NodeStateReader) GetTaskNodeState() handler.TaskNodeState

GetTaskNodeState provides a mock function with no fields

func (*NodeStateReader) GetWorkflowNodeState 

func (_m *NodeStateReader) GetWorkflowNodeState() handler.WorkflowNodeState

GetWorkflowNodeState provides a mock function with no fields

func (*NodeStateReader) HasArrayNodeState 

func (_m *NodeStateReader) HasArrayNodeState() bool

HasArrayNodeState provides a mock function with no fields

func (*NodeStateReader) HasBranchNodeState 

func (_m *NodeStateReader) HasBranchNodeState() bool

HasBranchNodeState provides a mock function with no fields

func (*NodeStateReader) HasDynamicNodeState 

func (_m *NodeStateReader) HasDynamicNodeState() bool

HasDynamicNodeState provides a mock function with no fields

func (*NodeStateReader) HasGateNodeState 

func (_m *NodeStateReader) HasGateNodeState() bool

HasGateNodeState provides a mock function with no fields

func (*NodeStateReader) HasTaskNodeState 

func (_m *NodeStateReader) HasTaskNodeState() bool

HasTaskNodeState provides a mock function with no fields

func (*NodeStateReader) HasWorkflowNodeState 

func (_m *NodeStateReader) HasWorkflowNodeState() bool

HasWorkflowNodeState provides a mock function with no fields

type NodeStateReader_Expecter added in v1.15.1 

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

func (*NodeStateReader_Expecter) GetArrayNodeState added in v1.15.1 

func (_e *NodeStateReader_Expecter) GetArrayNodeState() *NodeStateReader_GetArrayNodeState_Call

GetArrayNodeState is a helper method to define mock.On call

func (*NodeStateReader_Expecter) GetBranchNodeState added in v1.15.1 

func (_e *NodeStateReader_Expecter) GetBranchNodeState() *NodeStateReader_GetBranchNodeState_Call

GetBranchNodeState is a helper method to define mock.On call

func (*NodeStateReader_Expecter) GetDynamicNodeState added in v1.15.1 

func (_e *NodeStateReader_Expecter) GetDynamicNodeState() *NodeStateReader_GetDynamicNodeState_Call

GetDynamicNodeState is a helper method to define mock.On call

func (*NodeStateReader_Expecter) GetGateNodeState added in v1.15.1 

func (_e *NodeStateReader_Expecter) GetGateNodeState() *NodeStateReader_GetGateNodeState_Call

GetGateNodeState is a helper method to define mock.On call

func (*NodeStateReader_Expecter) GetTaskNodeState added in v1.15.1 

func (_e *NodeStateReader_Expecter) GetTaskNodeState() *NodeStateReader_GetTaskNodeState_Call

GetTaskNodeState is a helper method to define mock.On call

func (*NodeStateReader_Expecter) GetWorkflowNodeState added in v1.15.1 

func (_e *NodeStateReader_Expecter) GetWorkflowNodeState() *NodeStateReader_GetWorkflowNodeState_Call

GetWorkflowNodeState is a helper method to define mock.On call

func (*NodeStateReader_Expecter) HasArrayNodeState added in v1.15.1 

func (_e *NodeStateReader_Expecter) HasArrayNodeState() *NodeStateReader_HasArrayNodeState_Call

HasArrayNodeState is a helper method to define mock.On call

func (*NodeStateReader_Expecter) HasBranchNodeState added in v1.15.1 

func (_e *NodeStateReader_Expecter) HasBranchNodeState() *NodeStateReader_HasBranchNodeState_Call

HasBranchNodeState is a helper method to define mock.On call

func (*NodeStateReader_Expecter) HasDynamicNodeState added in v1.15.1 

func (_e *NodeStateReader_Expecter) HasDynamicNodeState() *NodeStateReader_HasDynamicNodeState_Call

HasDynamicNodeState is a helper method to define mock.On call

func (*NodeStateReader_Expecter) HasGateNodeState added in v1.15.1 

func (_e *NodeStateReader_Expecter) HasGateNodeState() *NodeStateReader_HasGateNodeState_Call

HasGateNodeState is a helper method to define mock.On call

func (*NodeStateReader_Expecter) HasTaskNodeState added in v1.15.1 

func (_e *NodeStateReader_Expecter) HasTaskNodeState() *NodeStateReader_HasTaskNodeState_Call

HasTaskNodeState is a helper method to define mock.On call

func (*NodeStateReader_Expecter) HasWorkflowNodeState added in v1.15.1 

func (_e *NodeStateReader_Expecter) HasWorkflowNodeState() *NodeStateReader_HasWorkflowNodeState_Call

HasWorkflowNodeState is a helper method to define mock.On call

type NodeStateReader_GetArrayNodeState_Call added in v1.15.1 

type NodeStateReader_GetArrayNodeState_Call struct {
	*mock.Call
}

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

func (*NodeStateReader_GetArrayNodeState_Call) Return added in v1.15.1 

func (_c *NodeStateReader_GetArrayNodeState_Call) Return(_a0 handler.ArrayNodeState) *NodeStateReader_GetArrayNodeState_Call

func (*NodeStateReader_GetArrayNodeState_Call) Run added in v1.15.1 

func (_c *NodeStateReader_GetArrayNodeState_Call) Run(run func()) *NodeStateReader_GetArrayNodeState_Call

func (*NodeStateReader_GetArrayNodeState_Call) RunAndReturn added in v1.15.1 

func (_c *NodeStateReader_GetArrayNodeState_Call) RunAndReturn(run func() handler.ArrayNodeState) *NodeStateReader_GetArrayNodeState_Call

type NodeStateReader_GetBranchNodeState_Call added in v1.15.1 

type NodeStateReader_GetBranchNodeState_Call struct {
	*mock.Call
}

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

func (*NodeStateReader_GetBranchNodeState_Call) Return added in v1.15.1 

func (_c *NodeStateReader_GetBranchNodeState_Call) Return(_a0 handler.BranchNodeState) *NodeStateReader_GetBranchNodeState_Call

func (*NodeStateReader_GetBranchNodeState_Call) Run added in v1.15.1 

func (_c *NodeStateReader_GetBranchNodeState_Call) Run(run func()) *NodeStateReader_GetBranchNodeState_Call

func (*NodeStateReader_GetBranchNodeState_Call) RunAndReturn added in v1.15.1 

func (_c *NodeStateReader_GetBranchNodeState_Call) RunAndReturn(run func() handler.BranchNodeState) *NodeStateReader_GetBranchNodeState_Call

type NodeStateReader_GetDynamicNodeState_Call added in v1.15.1 

type NodeStateReader_GetDynamicNodeState_Call struct {
	*mock.Call
}

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

func (*NodeStateReader_GetDynamicNodeState_Call) Return added in v1.15.1 

func (_c *NodeStateReader_GetDynamicNodeState_Call) Return(_a0 handler.DynamicNodeState) *NodeStateReader_GetDynamicNodeState_Call

func (*NodeStateReader_GetDynamicNodeState_Call) Run added in v1.15.1 

func (_c *NodeStateReader_GetDynamicNodeState_Call) Run(run func()) *NodeStateReader_GetDynamicNodeState_Call

func (*NodeStateReader_GetDynamicNodeState_Call) RunAndReturn added in v1.15.1 

func (_c *NodeStateReader_GetDynamicNodeState_Call) RunAndReturn(run func() handler.DynamicNodeState) *NodeStateReader_GetDynamicNodeState_Call

type NodeStateReader_GetGateNodeState_Call added in v1.15.1 

type NodeStateReader_GetGateNodeState_Call struct {
	*mock.Call
}

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

func (*NodeStateReader_GetGateNodeState_Call) Return added in v1.15.1 

func (_c *NodeStateReader_GetGateNodeState_Call) Return(_a0 handler.GateNodeState) *NodeStateReader_GetGateNodeState_Call

func (*NodeStateReader_GetGateNodeState_Call) Run added in v1.15.1 

func (_c *NodeStateReader_GetGateNodeState_Call) Run(run func()) *NodeStateReader_GetGateNodeState_Call

func (*NodeStateReader_GetGateNodeState_Call) RunAndReturn added in v1.15.1 

func (_c *NodeStateReader_GetGateNodeState_Call) RunAndReturn(run func() handler.GateNodeState) *NodeStateReader_GetGateNodeState_Call

type NodeStateReader_GetTaskNodeState_Call added in v1.15.1 

type NodeStateReader_GetTaskNodeState_Call struct {
	*mock.Call
}

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

func (*NodeStateReader_GetTaskNodeState_Call) Return added in v1.15.1 

func (_c *NodeStateReader_GetTaskNodeState_Call) Return(_a0 handler.TaskNodeState) *NodeStateReader_GetTaskNodeState_Call

func (*NodeStateReader_GetTaskNodeState_Call) Run added in v1.15.1 

func (_c *NodeStateReader_GetTaskNodeState_Call) Run(run func()) *NodeStateReader_GetTaskNodeState_Call

func (*NodeStateReader_GetTaskNodeState_Call) RunAndReturn added in v1.15.1 

func (_c *NodeStateReader_GetTaskNodeState_Call) RunAndReturn(run func() handler.TaskNodeState) *NodeStateReader_GetTaskNodeState_Call

type NodeStateReader_GetWorkflowNodeState_Call added in v1.15.1 

type NodeStateReader_GetWorkflowNodeState_Call struct {
	*mock.Call
}

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

func (*NodeStateReader_GetWorkflowNodeState_Call) Return added in v1.15.1 

func (_c *NodeStateReader_GetWorkflowNodeState_Call) Return(_a0 handler.WorkflowNodeState) *NodeStateReader_GetWorkflowNodeState_Call

func (*NodeStateReader_GetWorkflowNodeState_Call) Run added in v1.15.1 

func (_c *NodeStateReader_GetWorkflowNodeState_Call) Run(run func()) *NodeStateReader_GetWorkflowNodeState_Call

func (*NodeStateReader_GetWorkflowNodeState_Call) RunAndReturn added in v1.15.1 

func (_c *NodeStateReader_GetWorkflowNodeState_Call) RunAndReturn(run func() handler.WorkflowNodeState) *NodeStateReader_GetWorkflowNodeState_Call

type NodeStateReader_HasArrayNodeState_Call added in v1.15.1 

type NodeStateReader_HasArrayNodeState_Call struct {
	*mock.Call
}

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

func (*NodeStateReader_HasArrayNodeState_Call) Return added in v1.15.1 

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

func (*NodeStateReader_HasArrayNodeState_Call) Run added in v1.15.1 

func (_c *NodeStateReader_HasArrayNodeState_Call) Run(run func()) *NodeStateReader_HasArrayNodeState_Call

func (*NodeStateReader_HasArrayNodeState_Call) RunAndReturn added in v1.15.1 

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

type NodeStateReader_HasBranchNodeState_Call added in v1.15.1 

type NodeStateReader_HasBranchNodeState_Call struct {
	*mock.Call
}

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

func (*NodeStateReader_HasBranchNodeState_Call) Return added in v1.15.1 

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

func (*NodeStateReader_HasBranchNodeState_Call) Run added in v1.15.1 

func (_c *NodeStateReader_HasBranchNodeState_Call) Run(run func()) *NodeStateReader_HasBranchNodeState_Call

func (*NodeStateReader_HasBranchNodeState_Call) RunAndReturn added in v1.15.1 

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

type NodeStateReader_HasDynamicNodeState_Call added in v1.15.1 

type NodeStateReader_HasDynamicNodeState_Call struct {
	*mock.Call
}

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

func (*NodeStateReader_HasDynamicNodeState_Call) Return added in v1.15.1 

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

func (*NodeStateReader_HasDynamicNodeState_Call) Run added in v1.15.1 

func (_c *NodeStateReader_HasDynamicNodeState_Call) Run(run func()) *NodeStateReader_HasDynamicNodeState_Call

func (*NodeStateReader_HasDynamicNodeState_Call) RunAndReturn added in v1.15.1 

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

type NodeStateReader_HasGateNodeState_Call added in v1.15.1 

type NodeStateReader_HasGateNodeState_Call struct {
	*mock.Call
}

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

func (*NodeStateReader_HasGateNodeState_Call) Return added in v1.15.1 

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

func (*NodeStateReader_HasGateNodeState_Call) Run added in v1.15.1 

func (_c *NodeStateReader_HasGateNodeState_Call) Run(run func()) *NodeStateReader_HasGateNodeState_Call

func (*NodeStateReader_HasGateNodeState_Call) RunAndReturn added in v1.15.1 

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

type NodeStateReader_HasTaskNodeState_Call added in v1.15.1 

type NodeStateReader_HasTaskNodeState_Call struct {
	*mock.Call
}

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

func (*NodeStateReader_HasTaskNodeState_Call) Return added in v1.15.1 

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

func (*NodeStateReader_HasTaskNodeState_Call) Run added in v1.15.1 

func (_c *NodeStateReader_HasTaskNodeState_Call) Run(run func()) *NodeStateReader_HasTaskNodeState_Call

func (*NodeStateReader_HasTaskNodeState_Call) RunAndReturn added in v1.15.1 

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

type NodeStateReader_HasWorkflowNodeState_Call added in v1.15.1 

type NodeStateReader_HasWorkflowNodeState_Call struct {
	*mock.Call
}

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

func (*NodeStateReader_HasWorkflowNodeState_Call) Return added in v1.15.1 

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

func (*NodeStateReader_HasWorkflowNodeState_Call) Run added in v1.15.1 

func (_c *NodeStateReader_HasWorkflowNodeState_Call) Run(run func()) *NodeStateReader_HasWorkflowNodeState_Call

func (*NodeStateReader_HasWorkflowNodeState_Call) RunAndReturn added in v1.15.1 

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

type NodeStateWriter 

type NodeStateWriter struct {
	mock.Mock
}

NodeStateWriter is an autogenerated mock type for the NodeStateWriter type

func NewNodeStateWriter added in v1.15.1 

func NewNodeStateWriter(t interface {
	mock.TestingT
	Cleanup(func())
}) *NodeStateWriter

NewNodeStateWriter creates a new instance of NodeStateWriter. 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 (*NodeStateWriter) ClearNodeStatus 

func (_m *NodeStateWriter) ClearNodeStatus()

ClearNodeStatus provides a mock function with no fields

func (*NodeStateWriter) EXPECT added in v1.15.1 

func (_m *NodeStateWriter) EXPECT() *NodeStateWriter_Expecter

func (*NodeStateWriter) PutArrayNodeState 

func (_m *NodeStateWriter) PutArrayNodeState(s handler.ArrayNodeState) error

PutArrayNodeState provides a mock function with given fields: s

func (*NodeStateWriter) PutBranchNode 

func (_m *NodeStateWriter) PutBranchNode(s handler.BranchNodeState) error

PutBranchNode provides a mock function with given fields: s

func (*NodeStateWriter) PutDynamicNodeState 

func (_m *NodeStateWriter) PutDynamicNodeState(s handler.DynamicNodeState) error

PutDynamicNodeState provides a mock function with given fields: s

func (*NodeStateWriter) PutGateNodeState 

func (_m *NodeStateWriter) PutGateNodeState(s handler.GateNodeState) error

PutGateNodeState provides a mock function with given fields: s

func (*NodeStateWriter) PutTaskNodeState 

func (_m *NodeStateWriter) PutTaskNodeState(s handler.TaskNodeState) error

PutTaskNodeState provides a mock function with given fields: s

func (*NodeStateWriter) PutWorkflowNodeState 

func (_m *NodeStateWriter) PutWorkflowNodeState(s handler.WorkflowNodeState) error

PutWorkflowNodeState provides a mock function with given fields: s

type NodeStateWriter_ClearNodeStatus_Call added in v1.15.1 

type NodeStateWriter_ClearNodeStatus_Call struct {
	*mock.Call
}

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

func (*NodeStateWriter_ClearNodeStatus_Call) Return added in v1.15.1 

func (_c *NodeStateWriter_ClearNodeStatus_Call) Return() *NodeStateWriter_ClearNodeStatus_Call

func (*NodeStateWriter_ClearNodeStatus_Call) Run added in v1.15.1 

func (_c *NodeStateWriter_ClearNodeStatus_Call) Run(run func()) *NodeStateWriter_ClearNodeStatus_Call

func (*NodeStateWriter_ClearNodeStatus_Call) RunAndReturn added in v1.15.1 

func (_c *NodeStateWriter_ClearNodeStatus_Call) RunAndReturn(run func()) *NodeStateWriter_ClearNodeStatus_Call

type NodeStateWriter_Expecter added in v1.15.1 

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

func (*NodeStateWriter_Expecter) ClearNodeStatus added in v1.15.1 

func (_e *NodeStateWriter_Expecter) ClearNodeStatus() *NodeStateWriter_ClearNodeStatus_Call

ClearNodeStatus is a helper method to define mock.On call

func (*NodeStateWriter_Expecter) PutArrayNodeState added in v1.15.1 

func (_e *NodeStateWriter_Expecter) PutArrayNodeState(s interface{}) *NodeStateWriter_PutArrayNodeState_Call

PutArrayNodeState is a helper method to define mock.On call

  • s handler.ArrayNodeState

func (*NodeStateWriter_Expecter) PutBranchNode added in v1.15.1 

func (_e *NodeStateWriter_Expecter) PutBranchNode(s interface{}) *NodeStateWriter_PutBranchNode_Call

PutBranchNode is a helper method to define mock.On call

  • s handler.BranchNodeState

func (*NodeStateWriter_Expecter) PutDynamicNodeState added in v1.15.1 

func (_e *NodeStateWriter_Expecter) PutDynamicNodeState(s interface{}) *NodeStateWriter_PutDynamicNodeState_Call

PutDynamicNodeState is a helper method to define mock.On call

  • s handler.DynamicNodeState

func (*NodeStateWriter_Expecter) PutGateNodeState added in v1.15.1 

func (_e *NodeStateWriter_Expecter) PutGateNodeState(s interface{}) *NodeStateWriter_PutGateNodeState_Call

PutGateNodeState is a helper method to define mock.On call

  • s handler.GateNodeState

func (*NodeStateWriter_Expecter) PutTaskNodeState added in v1.15.1 

func (_e *NodeStateWriter_Expecter) PutTaskNodeState(s interface{}) *NodeStateWriter_PutTaskNodeState_Call

PutTaskNodeState is a helper method to define mock.On call

  • s handler.TaskNodeState

func (*NodeStateWriter_Expecter) PutWorkflowNodeState added in v1.15.1 

func (_e *NodeStateWriter_Expecter) PutWorkflowNodeState(s interface{}) *NodeStateWriter_PutWorkflowNodeState_Call

PutWorkflowNodeState is a helper method to define mock.On call

  • s handler.WorkflowNodeState

type NodeStateWriter_PutArrayNodeState_Call added in v1.15.1 

type NodeStateWriter_PutArrayNodeState_Call struct {
	*mock.Call
}

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

func (*NodeStateWriter_PutArrayNodeState_Call) Return added in v1.15.1 

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

func (*NodeStateWriter_PutArrayNodeState_Call) Run added in v1.15.1 

func (_c *NodeStateWriter_PutArrayNodeState_Call) Run(run func(s handler.ArrayNodeState)) *NodeStateWriter_PutArrayNodeState_Call

func (*NodeStateWriter_PutArrayNodeState_Call) RunAndReturn added in v1.15.1 

func (_c *NodeStateWriter_PutArrayNodeState_Call) RunAndReturn(run func(handler.ArrayNodeState) error) *NodeStateWriter_PutArrayNodeState_Call

type NodeStateWriter_PutBranchNode_Call added in v1.15.1 

type NodeStateWriter_PutBranchNode_Call struct {
	*mock.Call
}

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

func (*NodeStateWriter_PutBranchNode_Call) Return added in v1.15.1 

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

func (*NodeStateWriter_PutBranchNode_Call) Run added in v1.15.1 

func (_c *NodeStateWriter_PutBranchNode_Call) Run(run func(s handler.BranchNodeState)) *NodeStateWriter_PutBranchNode_Call

func (*NodeStateWriter_PutBranchNode_Call) RunAndReturn added in v1.15.1 

func (_c *NodeStateWriter_PutBranchNode_Call) RunAndReturn(run func(handler.BranchNodeState) error) *NodeStateWriter_PutBranchNode_Call

type NodeStateWriter_PutDynamicNodeState_Call added in v1.15.1 

type NodeStateWriter_PutDynamicNodeState_Call struct {
	*mock.Call
}

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

func (*NodeStateWriter_PutDynamicNodeState_Call) Return added in v1.15.1 

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

func (*NodeStateWriter_PutDynamicNodeState_Call) Run added in v1.15.1 

func (_c *NodeStateWriter_PutDynamicNodeState_Call) Run(run func(s handler.DynamicNodeState)) *NodeStateWriter_PutDynamicNodeState_Call

func (*NodeStateWriter_PutDynamicNodeState_Call) RunAndReturn added in v1.15.1 

func (_c *NodeStateWriter_PutDynamicNodeState_Call) RunAndReturn(run func(handler.DynamicNodeState) error) *NodeStateWriter_PutDynamicNodeState_Call

type NodeStateWriter_PutGateNodeState_Call added in v1.15.1 

type NodeStateWriter_PutGateNodeState_Call struct {
	*mock.Call
}

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

func (*NodeStateWriter_PutGateNodeState_Call) Return added in v1.15.1 

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

func (*NodeStateWriter_PutGateNodeState_Call) Run added in v1.15.1 

func (_c *NodeStateWriter_PutGateNodeState_Call) Run(run func(s handler.GateNodeState)) *NodeStateWriter_PutGateNodeState_Call

func (*NodeStateWriter_PutGateNodeState_Call) RunAndReturn added in v1.15.1 

func (_c *NodeStateWriter_PutGateNodeState_Call) RunAndReturn(run func(handler.GateNodeState) error) *NodeStateWriter_PutGateNodeState_Call

type NodeStateWriter_PutTaskNodeState_Call added in v1.15.1 

type NodeStateWriter_PutTaskNodeState_Call struct {
	*mock.Call
}

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

func (*NodeStateWriter_PutTaskNodeState_Call) Return added in v1.15.1 

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

func (*NodeStateWriter_PutTaskNodeState_Call) Run added in v1.15.1 

func (_c *NodeStateWriter_PutTaskNodeState_Call) Run(run func(s handler.TaskNodeState)) *NodeStateWriter_PutTaskNodeState_Call

func (*NodeStateWriter_PutTaskNodeState_Call) RunAndReturn added in v1.15.1 

func (_c *NodeStateWriter_PutTaskNodeState_Call) RunAndReturn(run func(handler.TaskNodeState) error) *NodeStateWriter_PutTaskNodeState_Call

type NodeStateWriter_PutWorkflowNodeState_Call added in v1.15.1 

type NodeStateWriter_PutWorkflowNodeState_Call struct {
	*mock.Call
}

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

func (*NodeStateWriter_PutWorkflowNodeState_Call) Return added in v1.15.1 

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

func (*NodeStateWriter_PutWorkflowNodeState_Call) Run added in v1.15.1 

func (_c *NodeStateWriter_PutWorkflowNodeState_Call) Run(run func(s handler.WorkflowNodeState)) *NodeStateWriter_PutWorkflowNodeState_Call

func (*NodeStateWriter_PutWorkflowNodeState_Call) RunAndReturn added in v1.15.1 

func (_c *NodeStateWriter_PutWorkflowNodeState_Call) RunAndReturn(run func(handler.WorkflowNodeState) error) *NodeStateWriter_PutWorkflowNodeState_Call

type Node_AbortHandler_Call added in v1.15.1 

type Node_AbortHandler_Call struct {
	*mock.Call
}

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

func (*Node_AbortHandler_Call) Return added in v1.15.1 

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

func (*Node_AbortHandler_Call) Run added in v1.15.1 

func (_c *Node_AbortHandler_Call) Run(run func(ctx context.Context, execContext executors.ExecutionContext, dag executors.DAGStructure, nl executors.NodeLookup, currentNode v1alpha1.ExecutableNode, reason string)) *Node_AbortHandler_Call

func (*Node_AbortHandler_Call) RunAndReturn added in v1.15.1 

func (_c *Node_AbortHandler_Call) RunAndReturn(run func(context.Context, executors.ExecutionContext, executors.DAGStructure, executors.NodeLookup, v1alpha1.ExecutableNode, string) error) *Node_AbortHandler_Call

type Node_Expecter added in v1.15.1 

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

func (*Node_Expecter) AbortHandler added in v1.15.1 

func (_e *Node_Expecter) AbortHandler(ctx interface{}, execContext interface{}, dag interface{}, nl interface{}, currentNode interface{}, reason interface{}) *Node_AbortHandler_Call

AbortHandler is a helper method to define mock.On call

  • ctx context.Context
  • execContext executors.ExecutionContext
  • dag executors.DAGStructure
  • nl executors.NodeLookup
  • currentNode v1alpha1.ExecutableNode
  • reason string

func (*Node_Expecter) FinalizeHandler added in v1.15.1 

func (_e *Node_Expecter) FinalizeHandler(ctx interface{}, execContext interface{}, dag interface{}, nl interface{}, currentNode interface{}) *Node_FinalizeHandler_Call

FinalizeHandler is a helper method to define mock.On call

  • ctx context.Context
  • execContext executors.ExecutionContext
  • dag executors.DAGStructure
  • nl executors.NodeLookup
  • currentNode v1alpha1.ExecutableNode

func (*Node_Expecter) GetNodeExecutionContextBuilder added in v1.15.1 

func (_e *Node_Expecter) GetNodeExecutionContextBuilder() *Node_GetNodeExecutionContextBuilder_Call

GetNodeExecutionContextBuilder is a helper method to define mock.On call

func (*Node_Expecter) Initialize added in v1.15.1 

func (_e *Node_Expecter) Initialize(ctx interface{}) *Node_Initialize_Call

Initialize is a helper method to define mock.On call

  • ctx context.Context

func (*Node_Expecter) RecursiveNodeHandler added in v1.15.1 

func (_e *Node_Expecter) RecursiveNodeHandler(ctx interface{}, execContext interface{}, dag interface{}, nl interface{}, currentNode interface{}) *Node_RecursiveNodeHandler_Call

RecursiveNodeHandler is a helper method to define mock.On call

  • ctx context.Context
  • execContext executors.ExecutionContext
  • dag executors.DAGStructure
  • nl executors.NodeLookup
  • currentNode v1alpha1.ExecutableNode

func (*Node_Expecter) SetInputsForStartNode added in v1.15.1 

func (_e *Node_Expecter) SetInputsForStartNode(ctx interface{}, execContext interface{}, dag interface{}, nl interface{}, inputs interface{}) *Node_SetInputsForStartNode_Call

SetInputsForStartNode is a helper method to define mock.On call

  • ctx context.Context
  • execContext executors.ExecutionContext
  • dag executors.DAGStructureWithStartNode
  • nl executors.NodeLookup
  • inputs *core.LiteralMap

func (*Node_Expecter) WithNodeExecutionContextBuilder added in v1.15.1 

func (_e *Node_Expecter) WithNodeExecutionContextBuilder(_a0 interface{}) *Node_WithNodeExecutionContextBuilder_Call

WithNodeExecutionContextBuilder is a helper method to define mock.On call

  • _a0 interfaces.NodeExecutionContextBuilder

type Node_FinalizeHandler_Call added in v1.15.1 

type Node_FinalizeHandler_Call struct {
	*mock.Call
}

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

func (*Node_FinalizeHandler_Call) Return added in v1.15.1 

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

func (*Node_FinalizeHandler_Call) Run added in v1.15.1 

func (_c *Node_FinalizeHandler_Call) Run(run func(ctx context.Context, execContext executors.ExecutionContext, dag executors.DAGStructure, nl executors.NodeLookup, currentNode v1alpha1.ExecutableNode)) *Node_FinalizeHandler_Call

func (*Node_FinalizeHandler_Call) RunAndReturn added in v1.15.1 

func (_c *Node_FinalizeHandler_Call) RunAndReturn(run func(context.Context, executors.ExecutionContext, executors.DAGStructure, executors.NodeLookup, v1alpha1.ExecutableNode) error) *Node_FinalizeHandler_Call

type Node_GetNodeExecutionContextBuilder_Call added in v1.15.1 

type Node_GetNodeExecutionContextBuilder_Call struct {
	*mock.Call
}

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

func (*Node_GetNodeExecutionContextBuilder_Call) Return added in v1.15.1 

func (_c *Node_GetNodeExecutionContextBuilder_Call) Return(_a0 interfaces.NodeExecutionContextBuilder) *Node_GetNodeExecutionContextBuilder_Call

func (*Node_GetNodeExecutionContextBuilder_Call) Run added in v1.15.1 

func (_c *Node_GetNodeExecutionContextBuilder_Call) Run(run func()) *Node_GetNodeExecutionContextBuilder_Call

func (*Node_GetNodeExecutionContextBuilder_Call) RunAndReturn added in v1.15.1 

func (_c *Node_GetNodeExecutionContextBuilder_Call) RunAndReturn(run func() interfaces.NodeExecutionContextBuilder) *Node_GetNodeExecutionContextBuilder_Call

type Node_Initialize_Call added in v1.15.1 

type Node_Initialize_Call struct {
	*mock.Call
}

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

func (*Node_Initialize_Call) Return added in v1.15.1 

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

func (*Node_Initialize_Call) Run added in v1.15.1 

func (_c *Node_Initialize_Call) Run(run func(ctx context.Context)) *Node_Initialize_Call

func (*Node_Initialize_Call) RunAndReturn added in v1.15.1 

func (_c *Node_Initialize_Call) RunAndReturn(run func(context.Context) error) *Node_Initialize_Call

type Node_RecursiveNodeHandler_Call added in v1.15.1 

type Node_RecursiveNodeHandler_Call struct {
	*mock.Call
}

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

func (*Node_RecursiveNodeHandler_Call) Return added in v1.15.1 

func (_c *Node_RecursiveNodeHandler_Call) Return(_a0 interfaces.NodeStatus, _a1 error) *Node_RecursiveNodeHandler_Call

func (*Node_RecursiveNodeHandler_Call) Run added in v1.15.1 

func (_c *Node_RecursiveNodeHandler_Call) Run(run func(ctx context.Context, execContext executors.ExecutionContext, dag executors.DAGStructure, nl executors.NodeLookup, currentNode v1alpha1.ExecutableNode)) *Node_RecursiveNodeHandler_Call

func (*Node_RecursiveNodeHandler_Call) RunAndReturn added in v1.15.1 

func (_c *Node_RecursiveNodeHandler_Call) RunAndReturn(run func(context.Context, executors.ExecutionContext, executors.DAGStructure, executors.NodeLookup, v1alpha1.ExecutableNode) (interfaces.NodeStatus, error)) *Node_RecursiveNodeHandler_Call

type Node_SetInputsForStartNode_Call added in v1.15.1 

type Node_SetInputsForStartNode_Call struct {
	*mock.Call
}

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

func (*Node_SetInputsForStartNode_Call) Return added in v1.15.1 

func (_c *Node_SetInputsForStartNode_Call) Return(_a0 interfaces.NodeStatus, _a1 error) *Node_SetInputsForStartNode_Call

func (*Node_SetInputsForStartNode_Call) Run added in v1.15.1 

func (_c *Node_SetInputsForStartNode_Call) Run(run func(ctx context.Context, execContext executors.ExecutionContext, dag executors.DAGStructureWithStartNode, nl executors.NodeLookup, inputs *core.LiteralMap)) *Node_SetInputsForStartNode_Call

func (*Node_SetInputsForStartNode_Call) RunAndReturn added in v1.15.1 

func (_c *Node_SetInputsForStartNode_Call) RunAndReturn(run func(context.Context, executors.ExecutionContext, executors.DAGStructureWithStartNode, executors.NodeLookup, *core.LiteralMap) (interfaces.NodeStatus, error)) *Node_SetInputsForStartNode_Call

type Node_WithNodeExecutionContextBuilder_Call added in v1.15.1 

type Node_WithNodeExecutionContextBuilder_Call struct {
	*mock.Call
}

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

func (*Node_WithNodeExecutionContextBuilder_Call) Return added in v1.15.1 

func (_c *Node_WithNodeExecutionContextBuilder_Call) Return(_a0 interfaces.Node) *Node_WithNodeExecutionContextBuilder_Call

func (*Node_WithNodeExecutionContextBuilder_Call) Run added in v1.15.1 

func (_c *Node_WithNodeExecutionContextBuilder_Call) Run(run func(_a0 interfaces.NodeExecutionContextBuilder)) *Node_WithNodeExecutionContextBuilder_Call

func (*Node_WithNodeExecutionContextBuilder_Call) RunAndReturn added in v1.15.1 

func (_c *Node_WithNodeExecutionContextBuilder_Call) RunAndReturn(run func(interfaces.NodeExecutionContextBuilder) interfaces.Node) *Node_WithNodeExecutionContextBuilder_Call

type SetupContext 

type SetupContext struct {
	mock.Mock
}

SetupContext is an autogenerated mock type for the SetupContext type

func NewSetupContext added in v1.15.1 

func NewSetupContext(t interface {
	mock.TestingT
	Cleanup(func())
}) *SetupContext

NewSetupContext creates a new instance of SetupContext. 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 (*SetupContext) EXPECT added in v1.15.1 

func (_m *SetupContext) EXPECT() *SetupContext_Expecter

func (*SetupContext) EnqueueOwner 

func (_m *SetupContext) EnqueueOwner() func(string)

EnqueueOwner provides a mock function with no fields

func (*SetupContext) MetricsScope 

func (_m *SetupContext) MetricsScope() promutils.Scope

MetricsScope provides a mock function with no fields

func (*SetupContext) OwnerKind 

func (_m *SetupContext) OwnerKind() string

OwnerKind provides a mock function with no fields

type SetupContext_EnqueueOwner_Call added in v1.15.1 

type SetupContext_EnqueueOwner_Call struct {
	*mock.Call
}

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

func (*SetupContext_EnqueueOwner_Call) Return added in v1.15.1 

func (_c *SetupContext_EnqueueOwner_Call) Return(_a0 func(string)) *SetupContext_EnqueueOwner_Call

func (*SetupContext_EnqueueOwner_Call) Run added in v1.15.1 

func (_c *SetupContext_EnqueueOwner_Call) Run(run func()) *SetupContext_EnqueueOwner_Call

func (*SetupContext_EnqueueOwner_Call) RunAndReturn added in v1.15.1 

func (_c *SetupContext_EnqueueOwner_Call) RunAndReturn(run func() func(string)) *SetupContext_EnqueueOwner_Call

type SetupContext_Expecter added in v1.15.1 

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

func (*SetupContext_Expecter) EnqueueOwner added in v1.15.1 

func (_e *SetupContext_Expecter) EnqueueOwner() *SetupContext_EnqueueOwner_Call

EnqueueOwner is a helper method to define mock.On call

func (*SetupContext_Expecter) MetricsScope added in v1.15.1 

func (_e *SetupContext_Expecter) MetricsScope() *SetupContext_MetricsScope_Call

MetricsScope is a helper method to define mock.On call

func (*SetupContext_Expecter) OwnerKind added in v1.15.1 

func (_e *SetupContext_Expecter) OwnerKind() *SetupContext_OwnerKind_Call

OwnerKind is a helper method to define mock.On call

type SetupContext_MetricsScope_Call added in v1.15.1 

type SetupContext_MetricsScope_Call struct {
	*mock.Call
}

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

func (*SetupContext_MetricsScope_Call) Return added in v1.15.1 

func (_c *SetupContext_MetricsScope_Call) Return(_a0 promutils.Scope) *SetupContext_MetricsScope_Call

func (*SetupContext_MetricsScope_Call) Run added in v1.15.1 

func (_c *SetupContext_MetricsScope_Call) Run(run func()) *SetupContext_MetricsScope_Call

func (*SetupContext_MetricsScope_Call) RunAndReturn added in v1.15.1 

func (_c *SetupContext_MetricsScope_Call) RunAndReturn(run func() promutils.Scope) *SetupContext_MetricsScope_Call

type SetupContext_OwnerKind_Call added in v1.15.1 

type SetupContext_OwnerKind_Call struct {
	*mock.Call
}

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

func (*SetupContext_OwnerKind_Call) Return added in v1.15.1 

func (_c *SetupContext_OwnerKind_Call) Return(_a0 string) *SetupContext_OwnerKind_Call

func (*SetupContext_OwnerKind_Call) Run added in v1.15.1 

func (_c *SetupContext_OwnerKind_Call) Run(run func()) *SetupContext_OwnerKind_Call

func (*SetupContext_OwnerKind_Call) RunAndReturn added in v1.15.1 

func (_c *SetupContext_OwnerKind_Call) RunAndReturn(run func() string) *SetupContext_OwnerKind_Call

type TaskReader 

type TaskReader struct {
	mock.Mock
}

TaskReader is an autogenerated mock type for the TaskReader type

func NewTaskReader added in v1.15.1 

func NewTaskReader(t interface {
	mock.TestingT
	Cleanup(func())
}) *TaskReader

NewTaskReader creates a new instance of TaskReader. 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 (*TaskReader) EXPECT added in v1.15.1 

func (_m *TaskReader) EXPECT() *TaskReader_Expecter

func (*TaskReader) GetTaskID 

func (_m *TaskReader) GetTaskID() *core.Identifier

GetTaskID provides a mock function with no fields

func (*TaskReader) GetTaskType 

func (_m *TaskReader) GetTaskType() string

GetTaskType provides a mock function with no fields

func (*TaskReader) Read 

func (_m *TaskReader) Read(ctx context.Context) (*core.TaskTemplate, error)

Read provides a mock function with given fields: ctx

type TaskReader_Expecter added in v1.15.1 

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

func (*TaskReader_Expecter) GetTaskID added in v1.15.1 

func (_e *TaskReader_Expecter) GetTaskID() *TaskReader_GetTaskID_Call

GetTaskID is a helper method to define mock.On call

func (*TaskReader_Expecter) GetTaskType added in v1.15.1 

func (_e *TaskReader_Expecter) GetTaskType() *TaskReader_GetTaskType_Call

GetTaskType is a helper method to define mock.On call

func (*TaskReader_Expecter) Read added in v1.15.1 

func (_e *TaskReader_Expecter) Read(ctx interface{}) *TaskReader_Read_Call

Read is a helper method to define mock.On call

  • ctx context.Context

type TaskReader_GetTaskID_Call added in v1.15.1 

type TaskReader_GetTaskID_Call struct {
	*mock.Call
}

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

func (*TaskReader_GetTaskID_Call) Return added in v1.15.1 

func (_c *TaskReader_GetTaskID_Call) Return(_a0 *core.Identifier) *TaskReader_GetTaskID_Call

func (*TaskReader_GetTaskID_Call) Run added in v1.15.1 

func (_c *TaskReader_GetTaskID_Call) Run(run func()) *TaskReader_GetTaskID_Call

func (*TaskReader_GetTaskID_Call) RunAndReturn added in v1.15.1 

func (_c *TaskReader_GetTaskID_Call) RunAndReturn(run func() *core.Identifier) *TaskReader_GetTaskID_Call

type TaskReader_GetTaskType_Call added in v1.15.1 

type TaskReader_GetTaskType_Call struct {
	*mock.Call
}

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

func (*TaskReader_GetTaskType_Call) Return added in v1.15.1 

func (_c *TaskReader_GetTaskType_Call) Return(_a0 string) *TaskReader_GetTaskType_Call

func (*TaskReader_GetTaskType_Call) Run added in v1.15.1 

func (_c *TaskReader_GetTaskType_Call) Run(run func()) *TaskReader_GetTaskType_Call

func (*TaskReader_GetTaskType_Call) RunAndReturn added in v1.15.1 

func (_c *TaskReader_GetTaskType_Call) RunAndReturn(run func() string) *TaskReader_GetTaskType_Call

type TaskReader_Read_Call added in v1.15.1 

type TaskReader_Read_Call struct {
	*mock.Call
}

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

func (*TaskReader_Read_Call) Return added in v1.15.1 

func (_c *TaskReader_Read_Call) Return(_a0 *core.TaskTemplate, _a1 error) *TaskReader_Read_Call

func (*TaskReader_Read_Call) Run added in v1.15.1 

func (_c *TaskReader_Read_Call) Run(run func(ctx context.Context)) *TaskReader_Read_Call

func (*TaskReader_Read_Call) RunAndReturn added in v1.15.1 

func (_c *TaskReader_Read_Call) RunAndReturn(run func(context.Context) (*core.TaskTemplate, error)) *TaskReader_Read_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.