mocks

package
v1.9.29 Latest Latest
Warning

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

 Go to latest Published: Oct 18, 2023 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 (*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) 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 given 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) OnAbort 

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

func (*CacheableNodeHandler) OnAbortMatch 

func (_m *CacheableNodeHandler) OnAbortMatch(matchers ...interface{}) *CacheableNodeHandler_Abort

func (*CacheableNodeHandler) OnFinalize 

func (_m *CacheableNodeHandler) OnFinalize(ctx context.Context, executionContext interfaces.NodeExecutionContext) *CacheableNodeHandler_Finalize

func (*CacheableNodeHandler) OnFinalizeMatch 

func (_m *CacheableNodeHandler) OnFinalizeMatch(matchers ...interface{}) *CacheableNodeHandler_Finalize

func (*CacheableNodeHandler) OnFinalizeRequired 

func (_m *CacheableNodeHandler) OnFinalizeRequired() *CacheableNodeHandler_FinalizeRequired

func (*CacheableNodeHandler) OnFinalizeRequiredMatch 

func (_m *CacheableNodeHandler) OnFinalizeRequiredMatch(matchers ...interface{}) *CacheableNodeHandler_FinalizeRequired

func (*CacheableNodeHandler) OnGetCatalogKey 

func (_m *CacheableNodeHandler) OnGetCatalogKey(ctx context.Context, executionContext interfaces.NodeExecutionContext) *CacheableNodeHandler_GetCatalogKey

func (*CacheableNodeHandler) OnGetCatalogKeyMatch 

func (_m *CacheableNodeHandler) OnGetCatalogKeyMatch(matchers ...interface{}) *CacheableNodeHandler_GetCatalogKey

func (*CacheableNodeHandler) OnHandle 

func (_m *CacheableNodeHandler) OnHandle(ctx context.Context, executionContext interfaces.NodeExecutionContext) *CacheableNodeHandler_Handle

func (*CacheableNodeHandler) OnHandleMatch 

func (_m *CacheableNodeHandler) OnHandleMatch(matchers ...interface{}) *CacheableNodeHandler_Handle

func (*CacheableNodeHandler) OnIsCacheable 

func (_m *CacheableNodeHandler) OnIsCacheable(ctx context.Context, executionContext interfaces.NodeExecutionContext) *CacheableNodeHandler_IsCacheable

func (*CacheableNodeHandler) OnIsCacheableMatch 

func (_m *CacheableNodeHandler) OnIsCacheableMatch(matchers ...interface{}) *CacheableNodeHandler_IsCacheable

func (*CacheableNodeHandler) OnSetup 

func (_m *CacheableNodeHandler) OnSetup(ctx context.Context, setupContext interfaces.SetupContext) *CacheableNodeHandler_Setup

func (*CacheableNodeHandler) OnSetupMatch 

func (_m *CacheableNodeHandler) OnSetupMatch(matchers ...interface{}) *CacheableNodeHandler_Setup

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 

type CacheableNodeHandler_Abort struct {
	*mock.Call
}

func (CacheableNodeHandler_Abort) Return 

func (_m CacheableNodeHandler_Abort) Return(_a0 error) *CacheableNodeHandler_Abort

type CacheableNodeHandler_Finalize 

type CacheableNodeHandler_Finalize struct {
	*mock.Call
}

func (CacheableNodeHandler_Finalize) Return 

func (_m CacheableNodeHandler_Finalize) Return(_a0 error) *CacheableNodeHandler_Finalize

type CacheableNodeHandler_FinalizeRequired 

type CacheableNodeHandler_FinalizeRequired struct {
	*mock.Call
}

func (CacheableNodeHandler_FinalizeRequired) Return 

func (_m CacheableNodeHandler_FinalizeRequired) Return(_a0 bool) *CacheableNodeHandler_FinalizeRequired

type CacheableNodeHandler_GetCatalogKey 

type CacheableNodeHandler_GetCatalogKey struct {
	*mock.Call
}

func (CacheableNodeHandler_GetCatalogKey) Return 

func (_m CacheableNodeHandler_GetCatalogKey) Return(_a0 catalog.Key, _a1 error) *CacheableNodeHandler_GetCatalogKey

type CacheableNodeHandler_Handle 

type CacheableNodeHandler_Handle struct {
	*mock.Call
}

func (CacheableNodeHandler_Handle) Return 

func (_m CacheableNodeHandler_Handle) Return(_a0 handler.Transition, _a1 error) *CacheableNodeHandler_Handle

type CacheableNodeHandler_IsCacheable 

type CacheableNodeHandler_IsCacheable struct {
	*mock.Call
}

func (CacheableNodeHandler_IsCacheable) Return 

func (_m CacheableNodeHandler_IsCacheable) Return(_a0 bool, _a1 bool, _a2 error) *CacheableNodeHandler_IsCacheable

type CacheableNodeHandler_Setup 

type CacheableNodeHandler_Setup struct {
	*mock.Call
}

func (CacheableNodeHandler_Setup) Return 

func (_m CacheableNodeHandler_Setup) Return(_a0 error) *CacheableNodeHandler_Setup

type EventRecorder 

type EventRecorder struct {
	mock.Mock
}

EventRecorder is an autogenerated mock type for the EventRecorder type

func (*EventRecorder) OnRecordNodeEvent 

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

func (*EventRecorder) OnRecordNodeEventMatch 

func (_m *EventRecorder) OnRecordNodeEventMatch(matchers ...interface{}) *EventRecorder_RecordNodeEvent

func (*EventRecorder) OnRecordTaskEvent 

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

func (*EventRecorder) OnRecordTaskEventMatch 

func (_m *EventRecorder) OnRecordTaskEventMatch(matchers ...interface{}) *EventRecorder_RecordTaskEvent

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_RecordNodeEvent 

type EventRecorder_RecordNodeEvent struct {
	*mock.Call
}

func (EventRecorder_RecordNodeEvent) Return 

func (_m EventRecorder_RecordNodeEvent) Return(_a0 error) *EventRecorder_RecordNodeEvent

type EventRecorder_RecordTaskEvent 

type EventRecorder_RecordTaskEvent struct {
	*mock.Call
}

func (EventRecorder_RecordTaskEvent) Return 

func (_m EventRecorder_RecordTaskEvent) Return(_a0 error) *EventRecorder_RecordTaskEvent

type HandlerFactory 

type HandlerFactory struct {
	mock.Mock
}

HandlerFactory is an autogenerated mock type for the HandlerFactory type

func (*HandlerFactory) GetHandler 

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

GetHandler provides a mock function with given fields: kind

func (*HandlerFactory) OnGetHandler 

func (_m *HandlerFactory) OnGetHandler(kind v1alpha1.NodeKind) *HandlerFactory_GetHandler

func (*HandlerFactory) OnGetHandlerMatch 

func (_m *HandlerFactory) OnGetHandlerMatch(matchers ...interface{}) *HandlerFactory_GetHandler

func (*HandlerFactory) OnSetup 

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

func (*HandlerFactory) OnSetupMatch 

func (_m *HandlerFactory) OnSetupMatch(matchers ...interface{}) *HandlerFactory_Setup

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_GetHandler 

type HandlerFactory_GetHandler struct {
	*mock.Call
}

func (HandlerFactory_GetHandler) Return 

func (_m HandlerFactory_GetHandler) Return(_a0 interfaces.NodeHandler, _a1 error) *HandlerFactory_GetHandler

type HandlerFactory_Setup 

type HandlerFactory_Setup struct {
	*mock.Call
}

func (HandlerFactory_Setup) Return 

func (_m HandlerFactory_Setup) Return(_a0 error) *HandlerFactory_Setup

type Node 

type Node struct {
	mock.Mock
}

Node is an autogenerated mock type for the Node type

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) 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 given fields:

func (*Node) Initialize 

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

Initialize provides a mock function with given fields: ctx

func (*Node) OnAbortHandler 

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

func (*Node) OnAbortHandlerMatch 

func (_m *Node) OnAbortHandlerMatch(matchers ...interface{}) *Node_AbortHandler

func (*Node) OnFinalizeHandler 

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

func (*Node) OnFinalizeHandlerMatch 

func (_m *Node) OnFinalizeHandlerMatch(matchers ...interface{}) *Node_FinalizeHandler

func (*Node) OnGetNodeExecutionContextBuilder 

func (_m *Node) OnGetNodeExecutionContextBuilder() *Node_GetNodeExecutionContextBuilder

func (*Node) OnGetNodeExecutionContextBuilderMatch 

func (_m *Node) OnGetNodeExecutionContextBuilderMatch(matchers ...interface{}) *Node_GetNodeExecutionContextBuilder

func (*Node) OnInitialize 

func (_m *Node) OnInitialize(ctx context.Context) *Node_Initialize

func (*Node) OnInitializeMatch 

func (_m *Node) OnInitializeMatch(matchers ...interface{}) *Node_Initialize

func (*Node) OnRecursiveNodeHandler 

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

func (*Node) OnRecursiveNodeHandlerMatch 

func (_m *Node) OnRecursiveNodeHandlerMatch(matchers ...interface{}) *Node_RecursiveNodeHandler

func (*Node) OnSetInputsForStartNode 

func (_m *Node) OnSetInputsForStartNode(ctx context.Context, execContext executors.ExecutionContext, dag executors.DAGStructureWithStartNode, nl executors.NodeLookup, inputs *core.LiteralMap) *Node_SetInputsForStartNode

func (*Node) OnSetInputsForStartNodeMatch 

func (_m *Node) OnSetInputsForStartNodeMatch(matchers ...interface{}) *Node_SetInputsForStartNode

func (*Node) OnWithNodeExecutionContextBuilder 

func (_m *Node) OnWithNodeExecutionContextBuilder(_a0 interfaces.NodeExecutionContextBuilder) *Node_WithNodeExecutionContextBuilder

func (*Node) OnWithNodeExecutionContextBuilderMatch 

func (_m *Node) OnWithNodeExecutionContextBuilderMatch(matchers ...interface{}) *Node_WithNodeExecutionContextBuilder

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 (*NodeExecutionContext) ContextualNodeLookup 

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

ContextualNodeLookup provides a mock function with given fields:

func (*NodeExecutionContext) CurrentAttempt 

func (_m *NodeExecutionContext) CurrentAttempt() uint32

CurrentAttempt provides a mock function with given fields:

func (*NodeExecutionContext) DataStore 

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

DataStore provides a mock function with given fields:

func (*NodeExecutionContext) EnqueueOwnerFunc 

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

EnqueueOwnerFunc provides a mock function with given fields:

func (*NodeExecutionContext) EventsRecorder 

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

EventsRecorder provides a mock function with given fields:

func (*NodeExecutionContext) ExecutionContext 

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

ExecutionContext provides a mock function with given fields:

func (*NodeExecutionContext) InputReader 

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

InputReader provides a mock function with given fields:

func (*NodeExecutionContext) MaxDatasetSizeBytes 

func (_m *NodeExecutionContext) MaxDatasetSizeBytes() int64

MaxDatasetSizeBytes provides a mock function with given fields:

func (*NodeExecutionContext) Node 

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

Node provides a mock function with given fields:

func (*NodeExecutionContext) NodeExecutionMetadata 

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

NodeExecutionMetadata provides a mock function with given fields:

func (*NodeExecutionContext) NodeID 

func (_m *NodeExecutionContext) NodeID() string

NodeID provides a mock function with given fields:

func (*NodeExecutionContext) NodeStateReader 

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

NodeStateReader provides a mock function with given fields:

func (*NodeExecutionContext) NodeStateWriter 

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

NodeStateWriter provides a mock function with given fields:

func (*NodeExecutionContext) NodeStatus 

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

NodeStatus provides a mock function with given fields:

func (*NodeExecutionContext) OnContextualNodeLookup 

func (_m *NodeExecutionContext) OnContextualNodeLookup() *NodeExecutionContext_ContextualNodeLookup

func (*NodeExecutionContext) OnContextualNodeLookupMatch 

func (_m *NodeExecutionContext) OnContextualNodeLookupMatch(matchers ...interface{}) *NodeExecutionContext_ContextualNodeLookup

func (*NodeExecutionContext) OnCurrentAttempt 

func (_m *NodeExecutionContext) OnCurrentAttempt() *NodeExecutionContext_CurrentAttempt

func (*NodeExecutionContext) OnCurrentAttemptMatch 

func (_m *NodeExecutionContext) OnCurrentAttemptMatch(matchers ...interface{}) *NodeExecutionContext_CurrentAttempt

func (*NodeExecutionContext) OnDataStore 

func (_m *NodeExecutionContext) OnDataStore() *NodeExecutionContext_DataStore

func (*NodeExecutionContext) OnDataStoreMatch 

func (_m *NodeExecutionContext) OnDataStoreMatch(matchers ...interface{}) *NodeExecutionContext_DataStore

func (*NodeExecutionContext) OnEnqueueOwnerFunc 

func (_m *NodeExecutionContext) OnEnqueueOwnerFunc() *NodeExecutionContext_EnqueueOwnerFunc

func (*NodeExecutionContext) OnEnqueueOwnerFuncMatch 

func (_m *NodeExecutionContext) OnEnqueueOwnerFuncMatch(matchers ...interface{}) *NodeExecutionContext_EnqueueOwnerFunc

func (*NodeExecutionContext) OnEventsRecorder 

func (_m *NodeExecutionContext) OnEventsRecorder() *NodeExecutionContext_EventsRecorder

func (*NodeExecutionContext) OnEventsRecorderMatch 

func (_m *NodeExecutionContext) OnEventsRecorderMatch(matchers ...interface{}) *NodeExecutionContext_EventsRecorder

func (*NodeExecutionContext) OnExecutionContext 

func (_m *NodeExecutionContext) OnExecutionContext() *NodeExecutionContext_ExecutionContext

func (*NodeExecutionContext) OnExecutionContextMatch 

func (_m *NodeExecutionContext) OnExecutionContextMatch(matchers ...interface{}) *NodeExecutionContext_ExecutionContext

func (*NodeExecutionContext) OnInputReader 

func (_m *NodeExecutionContext) OnInputReader() *NodeExecutionContext_InputReader

func (*NodeExecutionContext) OnInputReaderMatch 

func (_m *NodeExecutionContext) OnInputReaderMatch(matchers ...interface{}) *NodeExecutionContext_InputReader

func (*NodeExecutionContext) OnMaxDatasetSizeBytes 

func (_m *NodeExecutionContext) OnMaxDatasetSizeBytes() *NodeExecutionContext_MaxDatasetSizeBytes

func (*NodeExecutionContext) OnMaxDatasetSizeBytesMatch 

func (_m *NodeExecutionContext) OnMaxDatasetSizeBytesMatch(matchers ...interface{}) *NodeExecutionContext_MaxDatasetSizeBytes

func (*NodeExecutionContext) OnNode 

func (_m *NodeExecutionContext) OnNode() *NodeExecutionContext_Node

func (*NodeExecutionContext) OnNodeExecutionMetadata 

func (_m *NodeExecutionContext) OnNodeExecutionMetadata() *NodeExecutionContext_NodeExecutionMetadata

func (*NodeExecutionContext) OnNodeExecutionMetadataMatch 

func (_m *NodeExecutionContext) OnNodeExecutionMetadataMatch(matchers ...interface{}) *NodeExecutionContext_NodeExecutionMetadata

func (*NodeExecutionContext) OnNodeID 

func (_m *NodeExecutionContext) OnNodeID() *NodeExecutionContext_NodeID

func (*NodeExecutionContext) OnNodeIDMatch 

func (_m *NodeExecutionContext) OnNodeIDMatch(matchers ...interface{}) *NodeExecutionContext_NodeID

func (*NodeExecutionContext) OnNodeMatch 

func (_m *NodeExecutionContext) OnNodeMatch(matchers ...interface{}) *NodeExecutionContext_Node

func (*NodeExecutionContext) OnNodeStateReader 

func (_m *NodeExecutionContext) OnNodeStateReader() *NodeExecutionContext_NodeStateReader

func (*NodeExecutionContext) OnNodeStateReaderMatch 

func (_m *NodeExecutionContext) OnNodeStateReaderMatch(matchers ...interface{}) *NodeExecutionContext_NodeStateReader

func (*NodeExecutionContext) OnNodeStateWriter 

func (_m *NodeExecutionContext) OnNodeStateWriter() *NodeExecutionContext_NodeStateWriter

func (*NodeExecutionContext) OnNodeStateWriterMatch 

func (_m *NodeExecutionContext) OnNodeStateWriterMatch(matchers ...interface{}) *NodeExecutionContext_NodeStateWriter

func (*NodeExecutionContext) OnNodeStatus 

func (_m *NodeExecutionContext) OnNodeStatus() *NodeExecutionContext_NodeStatus

func (*NodeExecutionContext) OnNodeStatusMatch 

func (_m *NodeExecutionContext) OnNodeStatusMatch(matchers ...interface{}) *NodeExecutionContext_NodeStatus

func (*NodeExecutionContext) OnOutputShardSelector 

func (_m *NodeExecutionContext) OnOutputShardSelector() *NodeExecutionContext_OutputShardSelector

func (*NodeExecutionContext) OnOutputShardSelectorMatch 

func (_m *NodeExecutionContext) OnOutputShardSelectorMatch(matchers ...interface{}) *NodeExecutionContext_OutputShardSelector

func (*NodeExecutionContext) OnRawOutputPrefix 

func (_m *NodeExecutionContext) OnRawOutputPrefix() *NodeExecutionContext_RawOutputPrefix

func (*NodeExecutionContext) OnRawOutputPrefixMatch 

func (_m *NodeExecutionContext) OnRawOutputPrefixMatch(matchers ...interface{}) *NodeExecutionContext_RawOutputPrefix

func (*NodeExecutionContext) OnTaskReader 

func (_m *NodeExecutionContext) OnTaskReader() *NodeExecutionContext_TaskReader

func (*NodeExecutionContext) OnTaskReaderMatch 

func (_m *NodeExecutionContext) OnTaskReaderMatch(matchers ...interface{}) *NodeExecutionContext_TaskReader

func (*NodeExecutionContext) OutputShardSelector 

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

OutputShardSelector provides a mock function with given fields:

func (*NodeExecutionContext) RawOutputPrefix 

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

RawOutputPrefix provides a mock function with given fields:

func (*NodeExecutionContext) TaskReader 

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

TaskReader provides a mock function with given fields:

type NodeExecutionContextBuilder 

type NodeExecutionContextBuilder struct {
	mock.Mock
}

NodeExecutionContextBuilder is an autogenerated mock type for the NodeExecutionContextBuilder type

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

func (_m *NodeExecutionContextBuilder) OnBuildNodeExecutionContext(ctx context.Context, executionContext executors.ExecutionContext, nl executors.NodeLookup, currentNodeID string) *NodeExecutionContextBuilder_BuildNodeExecutionContext

func (*NodeExecutionContextBuilder) OnBuildNodeExecutionContextMatch 

func (_m *NodeExecutionContextBuilder) OnBuildNodeExecutionContextMatch(matchers ...interface{}) *NodeExecutionContextBuilder_BuildNodeExecutionContext

type NodeExecutionContextBuilder_BuildNodeExecutionContext 

type NodeExecutionContextBuilder_BuildNodeExecutionContext struct {
	*mock.Call
}

func (NodeExecutionContextBuilder_BuildNodeExecutionContext) Return 

func (_m NodeExecutionContextBuilder_BuildNodeExecutionContext) Return(_a0 interfaces.NodeExecutionContext, _a1 error) *NodeExecutionContextBuilder_BuildNodeExecutionContext

type NodeExecutionContext_ContextualNodeLookup 

type NodeExecutionContext_ContextualNodeLookup struct {
	*mock.Call
}

func (NodeExecutionContext_ContextualNodeLookup) Return 

func (_m NodeExecutionContext_ContextualNodeLookup) Return(_a0 executors.NodeLookup) *NodeExecutionContext_ContextualNodeLookup

type NodeExecutionContext_CurrentAttempt 

type NodeExecutionContext_CurrentAttempt struct {
	*mock.Call
}

func (NodeExecutionContext_CurrentAttempt) Return 

func (_m NodeExecutionContext_CurrentAttempt) Return(_a0 uint32) *NodeExecutionContext_CurrentAttempt

type NodeExecutionContext_DataStore 

type NodeExecutionContext_DataStore struct {
	*mock.Call
}

func (NodeExecutionContext_DataStore) Return 

func (_m NodeExecutionContext_DataStore) Return(_a0 *storage.DataStore) *NodeExecutionContext_DataStore

type NodeExecutionContext_EnqueueOwnerFunc 

type NodeExecutionContext_EnqueueOwnerFunc struct {
	*mock.Call
}

func (NodeExecutionContext_EnqueueOwnerFunc) Return 

func (_m NodeExecutionContext_EnqueueOwnerFunc) Return(_a0 func() error) *NodeExecutionContext_EnqueueOwnerFunc

type NodeExecutionContext_EventsRecorder 

type NodeExecutionContext_EventsRecorder struct {
	*mock.Call
}

func (NodeExecutionContext_EventsRecorder) Return 

func (_m NodeExecutionContext_EventsRecorder) Return(_a0 interfaces.EventRecorder) *NodeExecutionContext_EventsRecorder

type NodeExecutionContext_ExecutionContext 

type NodeExecutionContext_ExecutionContext struct {
	*mock.Call
}

func (NodeExecutionContext_ExecutionContext) Return 

func (_m NodeExecutionContext_ExecutionContext) Return(_a0 executors.ExecutionContext) *NodeExecutionContext_ExecutionContext

type NodeExecutionContext_InputReader 

type NodeExecutionContext_InputReader struct {
	*mock.Call
}

func (NodeExecutionContext_InputReader) Return 

func (_m NodeExecutionContext_InputReader) Return(_a0 io.InputReader) *NodeExecutionContext_InputReader

type NodeExecutionContext_MaxDatasetSizeBytes 

type NodeExecutionContext_MaxDatasetSizeBytes struct {
	*mock.Call
}

func (NodeExecutionContext_MaxDatasetSizeBytes) Return 

func (_m NodeExecutionContext_MaxDatasetSizeBytes) Return(_a0 int64) *NodeExecutionContext_MaxDatasetSizeBytes

type NodeExecutionContext_Node 

type NodeExecutionContext_Node struct {
	*mock.Call
}

func (NodeExecutionContext_Node) Return 

func (_m NodeExecutionContext_Node) Return(_a0 v1alpha1.ExecutableNode) *NodeExecutionContext_Node

type NodeExecutionContext_NodeExecutionMetadata 

type NodeExecutionContext_NodeExecutionMetadata struct {
	*mock.Call
}

func (NodeExecutionContext_NodeExecutionMetadata) Return 

func (_m NodeExecutionContext_NodeExecutionMetadata) Return(_a0 interfaces.NodeExecutionMetadata) *NodeExecutionContext_NodeExecutionMetadata

type NodeExecutionContext_NodeID 

type NodeExecutionContext_NodeID struct {
	*mock.Call
}

func (NodeExecutionContext_NodeID) Return 

func (_m NodeExecutionContext_NodeID) Return(_a0 string) *NodeExecutionContext_NodeID

type NodeExecutionContext_NodeStateReader 

type NodeExecutionContext_NodeStateReader struct {
	*mock.Call
}

func (NodeExecutionContext_NodeStateReader) Return 

func (_m NodeExecutionContext_NodeStateReader) Return(_a0 interfaces.NodeStateReader) *NodeExecutionContext_NodeStateReader

type NodeExecutionContext_NodeStateWriter 

type NodeExecutionContext_NodeStateWriter struct {
	*mock.Call
}

func (NodeExecutionContext_NodeStateWriter) Return 

func (_m NodeExecutionContext_NodeStateWriter) Return(_a0 interfaces.NodeStateWriter) *NodeExecutionContext_NodeStateWriter

type NodeExecutionContext_NodeStatus 

type NodeExecutionContext_NodeStatus struct {
	*mock.Call
}

func (NodeExecutionContext_NodeStatus) Return 

func (_m NodeExecutionContext_NodeStatus) Return(_a0 v1alpha1.ExecutableNodeStatus) *NodeExecutionContext_NodeStatus

type NodeExecutionContext_OutputShardSelector 

type NodeExecutionContext_OutputShardSelector struct {
	*mock.Call
}

func (NodeExecutionContext_OutputShardSelector) Return 

func (_m NodeExecutionContext_OutputShardSelector) Return(_a0 ioutils.ShardSelector) *NodeExecutionContext_OutputShardSelector

type NodeExecutionContext_RawOutputPrefix 

type NodeExecutionContext_RawOutputPrefix struct {
	*mock.Call
}

func (NodeExecutionContext_RawOutputPrefix) Return 

func (_m NodeExecutionContext_RawOutputPrefix) Return(_a0 storage.DataReference) *NodeExecutionContext_RawOutputPrefix

type NodeExecutionContext_TaskReader 

type NodeExecutionContext_TaskReader struct {
	*mock.Call
}

func (NodeExecutionContext_TaskReader) Return 

func (_m NodeExecutionContext_TaskReader) Return(_a0 interfaces.TaskReader) *NodeExecutionContext_TaskReader

type NodeExecutionMetadata 

type NodeExecutionMetadata struct {
	mock.Mock
}

NodeExecutionMetadata is an autogenerated mock type for the NodeExecutionMetadata type

func (*NodeExecutionMetadata) GetAnnotations 

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

GetAnnotations provides a mock function with given fields:

func (*NodeExecutionMetadata) GetInterruptibleFailureThreshold 

func (_m *NodeExecutionMetadata) GetInterruptibleFailureThreshold() int32

GetInterruptibleFailureThreshold provides a mock function with given fields:

func (*NodeExecutionMetadata) GetK8sServiceAccount 

func (_m *NodeExecutionMetadata) GetK8sServiceAccount() string

GetK8sServiceAccount provides a mock function with given fields:

func (*NodeExecutionMetadata) GetLabels 

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

GetLabels provides a mock function with given fields:

func (*NodeExecutionMetadata) GetNamespace 

func (_m *NodeExecutionMetadata) GetNamespace() string

GetNamespace provides a mock function with given fields:

func (*NodeExecutionMetadata) GetNodeExecutionID 

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

GetNodeExecutionID provides a mock function with given fields:

func (*NodeExecutionMetadata) GetOwnerID 

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

GetOwnerID provides a mock function with given fields:

func (*NodeExecutionMetadata) GetOwnerReference 

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

GetOwnerReference provides a mock function with given fields:

func (*NodeExecutionMetadata) GetSecurityContext 

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

GetSecurityContext provides a mock function with given fields:

func (*NodeExecutionMetadata) IsInterruptible 

func (_m *NodeExecutionMetadata) IsInterruptible() bool

IsInterruptible provides a mock function with given fields:

func (*NodeExecutionMetadata) OnGetAnnotations 

func (_m *NodeExecutionMetadata) OnGetAnnotations() *NodeExecutionMetadata_GetAnnotations

func (*NodeExecutionMetadata) OnGetAnnotationsMatch 

func (_m *NodeExecutionMetadata) OnGetAnnotationsMatch(matchers ...interface{}) *NodeExecutionMetadata_GetAnnotations

func (*NodeExecutionMetadata) OnGetInterruptibleFailureThreshold 

func (_m *NodeExecutionMetadata) OnGetInterruptibleFailureThreshold() *NodeExecutionMetadata_GetInterruptibleFailureThreshold

func (*NodeExecutionMetadata) OnGetInterruptibleFailureThresholdMatch 

func (_m *NodeExecutionMetadata) OnGetInterruptibleFailureThresholdMatch(matchers ...interface{}) *NodeExecutionMetadata_GetInterruptibleFailureThreshold

func (*NodeExecutionMetadata) OnGetK8sServiceAccount 

func (_m *NodeExecutionMetadata) OnGetK8sServiceAccount() *NodeExecutionMetadata_GetK8sServiceAccount

func (*NodeExecutionMetadata) OnGetK8sServiceAccountMatch 

func (_m *NodeExecutionMetadata) OnGetK8sServiceAccountMatch(matchers ...interface{}) *NodeExecutionMetadata_GetK8sServiceAccount

func (*NodeExecutionMetadata) OnGetLabels 

func (_m *NodeExecutionMetadata) OnGetLabels() *NodeExecutionMetadata_GetLabels

func (*NodeExecutionMetadata) OnGetLabelsMatch 

func (_m *NodeExecutionMetadata) OnGetLabelsMatch(matchers ...interface{}) *NodeExecutionMetadata_GetLabels

func (*NodeExecutionMetadata) OnGetNamespace 

func (_m *NodeExecutionMetadata) OnGetNamespace() *NodeExecutionMetadata_GetNamespace

func (*NodeExecutionMetadata) OnGetNamespaceMatch 

func (_m *NodeExecutionMetadata) OnGetNamespaceMatch(matchers ...interface{}) *NodeExecutionMetadata_GetNamespace

func (*NodeExecutionMetadata) OnGetNodeExecutionID 

func (_m *NodeExecutionMetadata) OnGetNodeExecutionID() *NodeExecutionMetadata_GetNodeExecutionID

func (*NodeExecutionMetadata) OnGetNodeExecutionIDMatch 

func (_m *NodeExecutionMetadata) OnGetNodeExecutionIDMatch(matchers ...interface{}) *NodeExecutionMetadata_GetNodeExecutionID

func (*NodeExecutionMetadata) OnGetOwnerID 

func (_m *NodeExecutionMetadata) OnGetOwnerID() *NodeExecutionMetadata_GetOwnerID

func (*NodeExecutionMetadata) OnGetOwnerIDMatch 

func (_m *NodeExecutionMetadata) OnGetOwnerIDMatch(matchers ...interface{}) *NodeExecutionMetadata_GetOwnerID

func (*NodeExecutionMetadata) OnGetOwnerReference 

func (_m *NodeExecutionMetadata) OnGetOwnerReference() *NodeExecutionMetadata_GetOwnerReference

func (*NodeExecutionMetadata) OnGetOwnerReferenceMatch 

func (_m *NodeExecutionMetadata) OnGetOwnerReferenceMatch(matchers ...interface{}) *NodeExecutionMetadata_GetOwnerReference

func (*NodeExecutionMetadata) OnGetSecurityContext 

func (_m *NodeExecutionMetadata) OnGetSecurityContext() *NodeExecutionMetadata_GetSecurityContext

func (*NodeExecutionMetadata) OnGetSecurityContextMatch 

func (_m *NodeExecutionMetadata) OnGetSecurityContextMatch(matchers ...interface{}) *NodeExecutionMetadata_GetSecurityContext

func (*NodeExecutionMetadata) OnIsInterruptible 

func (_m *NodeExecutionMetadata) OnIsInterruptible() *NodeExecutionMetadata_IsInterruptible

func (*NodeExecutionMetadata) OnIsInterruptibleMatch 

func (_m *NodeExecutionMetadata) OnIsInterruptibleMatch(matchers ...interface{}) *NodeExecutionMetadata_IsInterruptible

type NodeExecutionMetadata_GetAnnotations 

type NodeExecutionMetadata_GetAnnotations struct {
	*mock.Call
}

func (NodeExecutionMetadata_GetAnnotations) Return 

func (_m NodeExecutionMetadata_GetAnnotations) Return(_a0 map[string]string) *NodeExecutionMetadata_GetAnnotations

type NodeExecutionMetadata_GetInterruptibleFailureThreshold 

type NodeExecutionMetadata_GetInterruptibleFailureThreshold struct {
	*mock.Call
}

func (NodeExecutionMetadata_GetInterruptibleFailureThreshold) Return 

func (_m NodeExecutionMetadata_GetInterruptibleFailureThreshold) Return(_a0 int32) *NodeExecutionMetadata_GetInterruptibleFailureThreshold

type NodeExecutionMetadata_GetK8sServiceAccount 

type NodeExecutionMetadata_GetK8sServiceAccount struct {
	*mock.Call
}

func (NodeExecutionMetadata_GetK8sServiceAccount) Return 

func (_m NodeExecutionMetadata_GetK8sServiceAccount) Return(_a0 string) *NodeExecutionMetadata_GetK8sServiceAccount

type NodeExecutionMetadata_GetLabels 

type NodeExecutionMetadata_GetLabels struct {
	*mock.Call
}

func (NodeExecutionMetadata_GetLabels) Return 

func (_m NodeExecutionMetadata_GetLabels) Return(_a0 map[string]string) *NodeExecutionMetadata_GetLabels

type NodeExecutionMetadata_GetNamespace 

type NodeExecutionMetadata_GetNamespace struct {
	*mock.Call
}

func (NodeExecutionMetadata_GetNamespace) Return 

func (_m NodeExecutionMetadata_GetNamespace) Return(_a0 string) *NodeExecutionMetadata_GetNamespace

type NodeExecutionMetadata_GetNodeExecutionID 

type NodeExecutionMetadata_GetNodeExecutionID struct {
	*mock.Call
}

func (NodeExecutionMetadata_GetNodeExecutionID) Return 

func (_m NodeExecutionMetadata_GetNodeExecutionID) Return(_a0 *core.NodeExecutionIdentifier) *NodeExecutionMetadata_GetNodeExecutionID

type NodeExecutionMetadata_GetOwnerID 

type NodeExecutionMetadata_GetOwnerID struct {
	*mock.Call
}

func (NodeExecutionMetadata_GetOwnerID) Return 

func (_m NodeExecutionMetadata_GetOwnerID) Return(_a0 types.NamespacedName) *NodeExecutionMetadata_GetOwnerID

type NodeExecutionMetadata_GetOwnerReference 

type NodeExecutionMetadata_GetOwnerReference struct {
	*mock.Call
}

func (NodeExecutionMetadata_GetOwnerReference) Return 

func (_m NodeExecutionMetadata_GetOwnerReference) Return(_a0 v1.OwnerReference) *NodeExecutionMetadata_GetOwnerReference

type NodeExecutionMetadata_GetSecurityContext 

type NodeExecutionMetadata_GetSecurityContext struct {
	*mock.Call
}

func (NodeExecutionMetadata_GetSecurityContext) Return 

func (_m NodeExecutionMetadata_GetSecurityContext) Return(_a0 core.SecurityContext) *NodeExecutionMetadata_GetSecurityContext

type NodeExecutionMetadata_IsInterruptible 

type NodeExecutionMetadata_IsInterruptible struct {
	*mock.Call
}

func (NodeExecutionMetadata_IsInterruptible) Return 

func (_m NodeExecutionMetadata_IsInterruptible) Return(_a0 bool) *NodeExecutionMetadata_IsInterruptible

type NodeExecutor 

type NodeExecutor struct {
	mock.Mock
}

NodeExecutor is an autogenerated mock type for the NodeExecutor type

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

func (*NodeExecutor) OnAbort 

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

func (*NodeExecutor) OnAbortMatch 

func (_m *NodeExecutor) OnAbortMatch(matchers ...interface{}) *NodeExecutor_Abort

func (*NodeExecutor) OnFinalize 

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

func (*NodeExecutor) OnFinalizeMatch 

func (_m *NodeExecutor) OnFinalizeMatch(matchers ...interface{}) *NodeExecutor_Finalize

func (*NodeExecutor) OnHandleNode 

func (_m *NodeExecutor) OnHandleNode(ctx context.Context, dag executors.DAGStructure, nCtx interfaces.NodeExecutionContext, h interfaces.NodeHandler) *NodeExecutor_HandleNode

func (*NodeExecutor) OnHandleNodeMatch 

func (_m *NodeExecutor) OnHandleNodeMatch(matchers ...interface{}) *NodeExecutor_HandleNode

type NodeExecutor_Abort 

type NodeExecutor_Abort struct {
	*mock.Call
}

func (NodeExecutor_Abort) Return 

func (_m NodeExecutor_Abort) Return(_a0 error) *NodeExecutor_Abort

type NodeExecutor_Finalize 

type NodeExecutor_Finalize struct {
	*mock.Call
}

func (NodeExecutor_Finalize) Return 

func (_m NodeExecutor_Finalize) Return(_a0 error) *NodeExecutor_Finalize

type NodeExecutor_HandleNode 

type NodeExecutor_HandleNode struct {
	*mock.Call
}

func (NodeExecutor_HandleNode) Return 

func (_m NodeExecutor_HandleNode) Return(_a0 interfaces.NodeStatus, _a1 error) *NodeExecutor_HandleNode

type NodeHandler 

type NodeHandler struct {
	mock.Mock
}

NodeHandler is an autogenerated mock type for the NodeHandler type

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) 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 given 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) OnAbort 

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

func (*NodeHandler) OnAbortMatch 

func (_m *NodeHandler) OnAbortMatch(matchers ...interface{}) *NodeHandler_Abort

func (*NodeHandler) OnFinalize 

func (_m *NodeHandler) OnFinalize(ctx context.Context, executionContext interfaces.NodeExecutionContext) *NodeHandler_Finalize

func (*NodeHandler) OnFinalizeMatch 

func (_m *NodeHandler) OnFinalizeMatch(matchers ...interface{}) *NodeHandler_Finalize

func (*NodeHandler) OnFinalizeRequired 

func (_m *NodeHandler) OnFinalizeRequired() *NodeHandler_FinalizeRequired

func (*NodeHandler) OnFinalizeRequiredMatch 

func (_m *NodeHandler) OnFinalizeRequiredMatch(matchers ...interface{}) *NodeHandler_FinalizeRequired

func (*NodeHandler) OnHandle 

func (_m *NodeHandler) OnHandle(ctx context.Context, executionContext interfaces.NodeExecutionContext) *NodeHandler_Handle

func (*NodeHandler) OnHandleMatch 

func (_m *NodeHandler) OnHandleMatch(matchers ...interface{}) *NodeHandler_Handle

func (*NodeHandler) OnSetup 

func (_m *NodeHandler) OnSetup(ctx context.Context, setupContext interfaces.SetupContext) *NodeHandler_Setup

func (*NodeHandler) OnSetupMatch 

func (_m *NodeHandler) OnSetupMatch(matchers ...interface{}) *NodeHandler_Setup

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 

type NodeHandler_Abort struct {
	*mock.Call
}

func (NodeHandler_Abort) Return 

func (_m NodeHandler_Abort) Return(_a0 error) *NodeHandler_Abort

type NodeHandler_Finalize 

type NodeHandler_Finalize struct {
	*mock.Call
}

func (NodeHandler_Finalize) Return 

func (_m NodeHandler_Finalize) Return(_a0 error) *NodeHandler_Finalize

type NodeHandler_FinalizeRequired 

type NodeHandler_FinalizeRequired struct {
	*mock.Call
}

func (NodeHandler_FinalizeRequired) Return 

func (_m NodeHandler_FinalizeRequired) Return(_a0 bool) *NodeHandler_FinalizeRequired

type NodeHandler_Handle 

type NodeHandler_Handle struct {
	*mock.Call
}

func (NodeHandler_Handle) Return 

func (_m NodeHandler_Handle) Return(_a0 handler.Transition, _a1 error) *NodeHandler_Handle

type NodeHandler_Setup 

type NodeHandler_Setup struct {
	*mock.Call
}

func (NodeHandler_Setup) Return 

func (_m NodeHandler_Setup) Return(_a0 error) *NodeHandler_Setup

type NodeStateReader 

type NodeStateReader struct {
	mock.Mock
}

NodeStateReader is an autogenerated mock type for the NodeStateReader type

func (*NodeStateReader) GetArrayNodeState 

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

GetArrayNodeState provides a mock function with given fields:

func (*NodeStateReader) GetBranchNodeState 

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

GetBranchNodeState provides a mock function with given fields:

func (*NodeStateReader) GetDynamicNodeState 

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

GetDynamicNodeState provides a mock function with given fields:

func (*NodeStateReader) GetGateNodeState 

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

GetGateNodeState provides a mock function with given fields:

func (*NodeStateReader) GetTaskNodeState 

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

GetTaskNodeState provides a mock function with given fields:

func (*NodeStateReader) GetWorkflowNodeState 

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

GetWorkflowNodeState provides a mock function with given fields:

func (*NodeStateReader) HasArrayNodeState 

func (_m *NodeStateReader) HasArrayNodeState() bool

HasArrayNodeState provides a mock function with given fields:

func (*NodeStateReader) HasBranchNodeState 

func (_m *NodeStateReader) HasBranchNodeState() bool

HasBranchNodeState provides a mock function with given fields:

func (*NodeStateReader) HasDynamicNodeState 

func (_m *NodeStateReader) HasDynamicNodeState() bool

HasDynamicNodeState provides a mock function with given fields:

func (*NodeStateReader) HasGateNodeState 

func (_m *NodeStateReader) HasGateNodeState() bool

HasGateNodeState provides a mock function with given fields:

func (*NodeStateReader) HasTaskNodeState 

func (_m *NodeStateReader) HasTaskNodeState() bool

HasTaskNodeState provides a mock function with given fields:

func (*NodeStateReader) HasWorkflowNodeState 

func (_m *NodeStateReader) HasWorkflowNodeState() bool

HasWorkflowNodeState provides a mock function with given fields:

func (*NodeStateReader) OnGetArrayNodeState 

func (_m *NodeStateReader) OnGetArrayNodeState() *NodeStateReader_GetArrayNodeState

func (*NodeStateReader) OnGetArrayNodeStateMatch 

func (_m *NodeStateReader) OnGetArrayNodeStateMatch(matchers ...interface{}) *NodeStateReader_GetArrayNodeState

func (*NodeStateReader) OnGetBranchNodeState 

func (_m *NodeStateReader) OnGetBranchNodeState() *NodeStateReader_GetBranchNodeState

func (*NodeStateReader) OnGetBranchNodeStateMatch 

func (_m *NodeStateReader) OnGetBranchNodeStateMatch(matchers ...interface{}) *NodeStateReader_GetBranchNodeState

func (*NodeStateReader) OnGetDynamicNodeState 

func (_m *NodeStateReader) OnGetDynamicNodeState() *NodeStateReader_GetDynamicNodeState

func (*NodeStateReader) OnGetDynamicNodeStateMatch 

func (_m *NodeStateReader) OnGetDynamicNodeStateMatch(matchers ...interface{}) *NodeStateReader_GetDynamicNodeState

func (*NodeStateReader) OnGetGateNodeState 

func (_m *NodeStateReader) OnGetGateNodeState() *NodeStateReader_GetGateNodeState

func (*NodeStateReader) OnGetGateNodeStateMatch 

func (_m *NodeStateReader) OnGetGateNodeStateMatch(matchers ...interface{}) *NodeStateReader_GetGateNodeState

func (*NodeStateReader) OnGetTaskNodeState 

func (_m *NodeStateReader) OnGetTaskNodeState() *NodeStateReader_GetTaskNodeState

func (*NodeStateReader) OnGetTaskNodeStateMatch 

func (_m *NodeStateReader) OnGetTaskNodeStateMatch(matchers ...interface{}) *NodeStateReader_GetTaskNodeState

func (*NodeStateReader) OnGetWorkflowNodeState 

func (_m *NodeStateReader) OnGetWorkflowNodeState() *NodeStateReader_GetWorkflowNodeState

func (*NodeStateReader) OnGetWorkflowNodeStateMatch 

func (_m *NodeStateReader) OnGetWorkflowNodeStateMatch(matchers ...interface{}) *NodeStateReader_GetWorkflowNodeState

func (*NodeStateReader) OnHasArrayNodeState 

func (_m *NodeStateReader) OnHasArrayNodeState() *NodeStateReader_HasArrayNodeState

func (*NodeStateReader) OnHasArrayNodeStateMatch 

func (_m *NodeStateReader) OnHasArrayNodeStateMatch(matchers ...interface{}) *NodeStateReader_HasArrayNodeState

func (*NodeStateReader) OnHasBranchNodeState 

func (_m *NodeStateReader) OnHasBranchNodeState() *NodeStateReader_HasBranchNodeState

func (*NodeStateReader) OnHasBranchNodeStateMatch 

func (_m *NodeStateReader) OnHasBranchNodeStateMatch(matchers ...interface{}) *NodeStateReader_HasBranchNodeState

func (*NodeStateReader) OnHasDynamicNodeState 

func (_m *NodeStateReader) OnHasDynamicNodeState() *NodeStateReader_HasDynamicNodeState

func (*NodeStateReader) OnHasDynamicNodeStateMatch 

func (_m *NodeStateReader) OnHasDynamicNodeStateMatch(matchers ...interface{}) *NodeStateReader_HasDynamicNodeState

func (*NodeStateReader) OnHasGateNodeState 

func (_m *NodeStateReader) OnHasGateNodeState() *NodeStateReader_HasGateNodeState

func (*NodeStateReader) OnHasGateNodeStateMatch 

func (_m *NodeStateReader) OnHasGateNodeStateMatch(matchers ...interface{}) *NodeStateReader_HasGateNodeState

func (*NodeStateReader) OnHasTaskNodeState 

func (_m *NodeStateReader) OnHasTaskNodeState() *NodeStateReader_HasTaskNodeState

func (*NodeStateReader) OnHasTaskNodeStateMatch 

func (_m *NodeStateReader) OnHasTaskNodeStateMatch(matchers ...interface{}) *NodeStateReader_HasTaskNodeState

func (*NodeStateReader) OnHasWorkflowNodeState 

func (_m *NodeStateReader) OnHasWorkflowNodeState() *NodeStateReader_HasWorkflowNodeState

func (*NodeStateReader) OnHasWorkflowNodeStateMatch 

func (_m *NodeStateReader) OnHasWorkflowNodeStateMatch(matchers ...interface{}) *NodeStateReader_HasWorkflowNodeState

type NodeStateReader_GetArrayNodeState 

type NodeStateReader_GetArrayNodeState struct {
	*mock.Call
}

func (NodeStateReader_GetArrayNodeState) Return 

func (_m NodeStateReader_GetArrayNodeState) Return(_a0 handler.ArrayNodeState) *NodeStateReader_GetArrayNodeState

type NodeStateReader_GetBranchNodeState 

type NodeStateReader_GetBranchNodeState struct {
	*mock.Call
}

func (NodeStateReader_GetBranchNodeState) Return 

func (_m NodeStateReader_GetBranchNodeState) Return(_a0 handler.BranchNodeState) *NodeStateReader_GetBranchNodeState

type NodeStateReader_GetDynamicNodeState 

type NodeStateReader_GetDynamicNodeState struct {
	*mock.Call
}

func (NodeStateReader_GetDynamicNodeState) Return 

func (_m NodeStateReader_GetDynamicNodeState) Return(_a0 handler.DynamicNodeState) *NodeStateReader_GetDynamicNodeState

type NodeStateReader_GetGateNodeState 

type NodeStateReader_GetGateNodeState struct {
	*mock.Call
}

func (NodeStateReader_GetGateNodeState) Return 

func (_m NodeStateReader_GetGateNodeState) Return(_a0 handler.GateNodeState) *NodeStateReader_GetGateNodeState

type NodeStateReader_GetTaskNodeState 

type NodeStateReader_GetTaskNodeState struct {
	*mock.Call
}

func (NodeStateReader_GetTaskNodeState) Return 

func (_m NodeStateReader_GetTaskNodeState) Return(_a0 handler.TaskNodeState) *NodeStateReader_GetTaskNodeState

type NodeStateReader_GetWorkflowNodeState 

type NodeStateReader_GetWorkflowNodeState struct {
	*mock.Call
}

func (NodeStateReader_GetWorkflowNodeState) Return 

func (_m NodeStateReader_GetWorkflowNodeState) Return(_a0 handler.WorkflowNodeState) *NodeStateReader_GetWorkflowNodeState

type NodeStateReader_HasArrayNodeState 

type NodeStateReader_HasArrayNodeState struct {
	*mock.Call
}

func (NodeStateReader_HasArrayNodeState) Return 

func (_m NodeStateReader_HasArrayNodeState) Return(_a0 bool) *NodeStateReader_HasArrayNodeState

type NodeStateReader_HasBranchNodeState 

type NodeStateReader_HasBranchNodeState struct {
	*mock.Call
}

func (NodeStateReader_HasBranchNodeState) Return 

func (_m NodeStateReader_HasBranchNodeState) Return(_a0 bool) *NodeStateReader_HasBranchNodeState

type NodeStateReader_HasDynamicNodeState 

type NodeStateReader_HasDynamicNodeState struct {
	*mock.Call
}

func (NodeStateReader_HasDynamicNodeState) Return 

func (_m NodeStateReader_HasDynamicNodeState) Return(_a0 bool) *NodeStateReader_HasDynamicNodeState

type NodeStateReader_HasGateNodeState 

type NodeStateReader_HasGateNodeState struct {
	*mock.Call
}

func (NodeStateReader_HasGateNodeState) Return 

func (_m NodeStateReader_HasGateNodeState) Return(_a0 bool) *NodeStateReader_HasGateNodeState

type NodeStateReader_HasTaskNodeState 

type NodeStateReader_HasTaskNodeState struct {
	*mock.Call
}

func (NodeStateReader_HasTaskNodeState) Return 

func (_m NodeStateReader_HasTaskNodeState) Return(_a0 bool) *NodeStateReader_HasTaskNodeState

type NodeStateReader_HasWorkflowNodeState 

type NodeStateReader_HasWorkflowNodeState struct {
	*mock.Call
}

func (NodeStateReader_HasWorkflowNodeState) Return 

func (_m NodeStateReader_HasWorkflowNodeState) Return(_a0 bool) *NodeStateReader_HasWorkflowNodeState

type NodeStateWriter 

type NodeStateWriter struct {
	mock.Mock
}

NodeStateWriter is an autogenerated mock type for the NodeStateWriter type

func (*NodeStateWriter) ClearNodeStatus 

func (_m *NodeStateWriter) ClearNodeStatus()

ClearNodeStatus provides a mock function with given fields:

func (*NodeStateWriter) OnPutArrayNodeState 

func (_m *NodeStateWriter) OnPutArrayNodeState(s handler.ArrayNodeState) *NodeStateWriter_PutArrayNodeState

func (*NodeStateWriter) OnPutArrayNodeStateMatch 

func (_m *NodeStateWriter) OnPutArrayNodeStateMatch(matchers ...interface{}) *NodeStateWriter_PutArrayNodeState

func (*NodeStateWriter) OnPutBranchNode 

func (_m *NodeStateWriter) OnPutBranchNode(s handler.BranchNodeState) *NodeStateWriter_PutBranchNode

func (*NodeStateWriter) OnPutBranchNodeMatch 

func (_m *NodeStateWriter) OnPutBranchNodeMatch(matchers ...interface{}) *NodeStateWriter_PutBranchNode

func (*NodeStateWriter) OnPutDynamicNodeState 

func (_m *NodeStateWriter) OnPutDynamicNodeState(s handler.DynamicNodeState) *NodeStateWriter_PutDynamicNodeState

func (*NodeStateWriter) OnPutDynamicNodeStateMatch 

func (_m *NodeStateWriter) OnPutDynamicNodeStateMatch(matchers ...interface{}) *NodeStateWriter_PutDynamicNodeState

func (*NodeStateWriter) OnPutGateNodeState 

func (_m *NodeStateWriter) OnPutGateNodeState(s handler.GateNodeState) *NodeStateWriter_PutGateNodeState

func (*NodeStateWriter) OnPutGateNodeStateMatch 

func (_m *NodeStateWriter) OnPutGateNodeStateMatch(matchers ...interface{}) *NodeStateWriter_PutGateNodeState

func (*NodeStateWriter) OnPutTaskNodeState 

func (_m *NodeStateWriter) OnPutTaskNodeState(s handler.TaskNodeState) *NodeStateWriter_PutTaskNodeState

func (*NodeStateWriter) OnPutTaskNodeStateMatch 

func (_m *NodeStateWriter) OnPutTaskNodeStateMatch(matchers ...interface{}) *NodeStateWriter_PutTaskNodeState

func (*NodeStateWriter) OnPutWorkflowNodeState 

func (_m *NodeStateWriter) OnPutWorkflowNodeState(s handler.WorkflowNodeState) *NodeStateWriter_PutWorkflowNodeState

func (*NodeStateWriter) OnPutWorkflowNodeStateMatch 

func (_m *NodeStateWriter) OnPutWorkflowNodeStateMatch(matchers ...interface{}) *NodeStateWriter_PutWorkflowNodeState

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_PutArrayNodeState 

type NodeStateWriter_PutArrayNodeState struct {
	*mock.Call
}

func (NodeStateWriter_PutArrayNodeState) Return 

func (_m NodeStateWriter_PutArrayNodeState) Return(_a0 error) *NodeStateWriter_PutArrayNodeState

type NodeStateWriter_PutBranchNode 

type NodeStateWriter_PutBranchNode struct {
	*mock.Call
}

func (NodeStateWriter_PutBranchNode) Return 

func (_m NodeStateWriter_PutBranchNode) Return(_a0 error) *NodeStateWriter_PutBranchNode

type NodeStateWriter_PutDynamicNodeState 

type NodeStateWriter_PutDynamicNodeState struct {
	*mock.Call
}

func (NodeStateWriter_PutDynamicNodeState) Return 

func (_m NodeStateWriter_PutDynamicNodeState) Return(_a0 error) *NodeStateWriter_PutDynamicNodeState

type NodeStateWriter_PutGateNodeState 

type NodeStateWriter_PutGateNodeState struct {
	*mock.Call
}

func (NodeStateWriter_PutGateNodeState) Return 

func (_m NodeStateWriter_PutGateNodeState) Return(_a0 error) *NodeStateWriter_PutGateNodeState

type NodeStateWriter_PutTaskNodeState 

type NodeStateWriter_PutTaskNodeState struct {
	*mock.Call
}

func (NodeStateWriter_PutTaskNodeState) Return 

func (_m NodeStateWriter_PutTaskNodeState) Return(_a0 error) *NodeStateWriter_PutTaskNodeState

type NodeStateWriter_PutWorkflowNodeState 

type NodeStateWriter_PutWorkflowNodeState struct {
	*mock.Call
}

func (NodeStateWriter_PutWorkflowNodeState) Return 

func (_m NodeStateWriter_PutWorkflowNodeState) Return(_a0 error) *NodeStateWriter_PutWorkflowNodeState

type Node_AbortHandler 

type Node_AbortHandler struct {
	*mock.Call
}

func (Node_AbortHandler) Return 

func (_m Node_AbortHandler) Return(_a0 error) *Node_AbortHandler

type Node_FinalizeHandler 

type Node_FinalizeHandler struct {
	*mock.Call
}

func (Node_FinalizeHandler) Return 

func (_m Node_FinalizeHandler) Return(_a0 error) *Node_FinalizeHandler

type Node_GetNodeExecutionContextBuilder 

type Node_GetNodeExecutionContextBuilder struct {
	*mock.Call
}

func (Node_GetNodeExecutionContextBuilder) Return 

func (_m Node_GetNodeExecutionContextBuilder) Return(_a0 interfaces.NodeExecutionContextBuilder) *Node_GetNodeExecutionContextBuilder

type Node_Initialize 

type Node_Initialize struct {
	*mock.Call
}

func (Node_Initialize) Return 

func (_m Node_Initialize) Return(_a0 error) *Node_Initialize

type Node_RecursiveNodeHandler 

type Node_RecursiveNodeHandler struct {
	*mock.Call
}

func (Node_RecursiveNodeHandler) Return 

func (_m Node_RecursiveNodeHandler) Return(_a0 interfaces.NodeStatus, _a1 error) *Node_RecursiveNodeHandler

type Node_SetInputsForStartNode 

type Node_SetInputsForStartNode struct {
	*mock.Call
}

func (Node_SetInputsForStartNode) Return 

func (_m Node_SetInputsForStartNode) Return(_a0 interfaces.NodeStatus, _a1 error) *Node_SetInputsForStartNode

type Node_WithNodeExecutionContextBuilder 

type Node_WithNodeExecutionContextBuilder struct {
	*mock.Call
}

func (Node_WithNodeExecutionContextBuilder) Return 

func (_m Node_WithNodeExecutionContextBuilder) Return(_a0 interfaces.Node) *Node_WithNodeExecutionContextBuilder

type SetupContext 

type SetupContext struct {
	mock.Mock
}

SetupContext is an autogenerated mock type for the SetupContext type

func (*SetupContext) EnqueueOwner 

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

EnqueueOwner provides a mock function with given fields:

func (*SetupContext) MetricsScope 

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

MetricsScope provides a mock function with given fields:

func (*SetupContext) OnEnqueueOwner 

func (_m *SetupContext) OnEnqueueOwner() *SetupContext_EnqueueOwner

func (*SetupContext) OnEnqueueOwnerMatch 

func (_m *SetupContext) OnEnqueueOwnerMatch(matchers ...interface{}) *SetupContext_EnqueueOwner

func (*SetupContext) OnMetricsScope 

func (_m *SetupContext) OnMetricsScope() *SetupContext_MetricsScope

func (*SetupContext) OnMetricsScopeMatch 

func (_m *SetupContext) OnMetricsScopeMatch(matchers ...interface{}) *SetupContext_MetricsScope

func (*SetupContext) OnOwnerKind 

func (_m *SetupContext) OnOwnerKind() *SetupContext_OwnerKind

func (*SetupContext) OnOwnerKindMatch 

func (_m *SetupContext) OnOwnerKindMatch(matchers ...interface{}) *SetupContext_OwnerKind

func (*SetupContext) OwnerKind 

func (_m *SetupContext) OwnerKind() string

OwnerKind provides a mock function with given fields:

type SetupContext_EnqueueOwner 

type SetupContext_EnqueueOwner struct {
	*mock.Call
}

func (SetupContext_EnqueueOwner) Return 

func (_m SetupContext_EnqueueOwner) Return(_a0 func(string)) *SetupContext_EnqueueOwner

type SetupContext_MetricsScope 

type SetupContext_MetricsScope struct {
	*mock.Call
}

func (SetupContext_MetricsScope) Return 

func (_m SetupContext_MetricsScope) Return(_a0 promutils.Scope) *SetupContext_MetricsScope

type SetupContext_OwnerKind 

type SetupContext_OwnerKind struct {
	*mock.Call
}

func (SetupContext_OwnerKind) Return 

func (_m SetupContext_OwnerKind) Return(_a0 string) *SetupContext_OwnerKind

type TaskReader 

type TaskReader struct {
	mock.Mock
}

TaskReader is an autogenerated mock type for the TaskReader type

func (*TaskReader) GetTaskID 

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

GetTaskID provides a mock function with given fields:

func (*TaskReader) GetTaskType 

func (_m *TaskReader) GetTaskType() string

GetTaskType provides a mock function with given fields:

func (*TaskReader) OnGetTaskID 

func (_m *TaskReader) OnGetTaskID() *TaskReader_GetTaskID

func (*TaskReader) OnGetTaskIDMatch 

func (_m *TaskReader) OnGetTaskIDMatch(matchers ...interface{}) *TaskReader_GetTaskID

func (*TaskReader) OnGetTaskType 

func (_m *TaskReader) OnGetTaskType() *TaskReader_GetTaskType

func (*TaskReader) OnGetTaskTypeMatch 

func (_m *TaskReader) OnGetTaskTypeMatch(matchers ...interface{}) *TaskReader_GetTaskType

func (*TaskReader) OnRead 

func (_m *TaskReader) OnRead(ctx context.Context) *TaskReader_Read

func (*TaskReader) OnReadMatch 

func (_m *TaskReader) OnReadMatch(matchers ...interface{}) *TaskReader_Read

func (*TaskReader) Read 

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

Read provides a mock function with given fields: ctx

type TaskReader_GetTaskID 

type TaskReader_GetTaskID struct {
	*mock.Call
}

func (TaskReader_GetTaskID) Return 

func (_m TaskReader_GetTaskID) Return(_a0 *core.Identifier) *TaskReader_GetTaskID

type TaskReader_GetTaskType 

type TaskReader_GetTaskType struct {
	*mock.Call
}

func (TaskReader_GetTaskType) Return 

func (_m TaskReader_GetTaskType) Return(_a0 string) *TaskReader_GetTaskType

type TaskReader_Read 

type TaskReader_Read struct {
	*mock.Call
}

func (TaskReader_Read) Return 

func (_m TaskReader_Read) Return(_a0 *core.TaskTemplate, _a1 error) *TaskReader_Read

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.