mocks

package
v0.6.3 Latest Latest
Warning

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

 Go to latest Published: Mar 4, 2021 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Node added in v0.1.13 

type Node struct {
	mock.Mock
}

Node is an autogenerated mock type for the Node type

func (*Node) Abort added in v0.1.13 

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

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

func (*Node) Finalize added in v0.1.13 

func (_m *Node) Finalize(ctx context.Context, executionContext handler.NodeExecutionContext) error

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

func (*Node) FinalizeRequired added in v0.1.13 

func (_m *Node) FinalizeRequired() bool

FinalizeRequired provides a mock function with given fields:

func (*Node) Handle added in v0.1.13 

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

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

func (*Node) OnAbort added in v0.1.13 

func (_m *Node) OnAbort(ctx context.Context, executionContext handler.NodeExecutionContext, reason string) *Node_Abort

func (*Node) OnAbortMatch added in v0.1.13 

func (_m *Node) OnAbortMatch(matchers ...interface{}) *Node_Abort

func (*Node) OnFinalize added in v0.1.13 

func (_m *Node) OnFinalize(ctx context.Context, executionContext handler.NodeExecutionContext) *Node_Finalize

func (*Node) OnFinalizeMatch added in v0.1.13 

func (_m *Node) OnFinalizeMatch(matchers ...interface{}) *Node_Finalize

func (*Node) OnFinalizeRequired added in v0.1.13 

func (_m *Node) OnFinalizeRequired() *Node_FinalizeRequired

func (*Node) OnFinalizeRequiredMatch added in v0.1.13 

func (_m *Node) OnFinalizeRequiredMatch(matchers ...interface{}) *Node_FinalizeRequired

func (*Node) OnHandle added in v0.1.13 

func (_m *Node) OnHandle(ctx context.Context, executionContext handler.NodeExecutionContext) *Node_Handle

func (*Node) OnHandleMatch added in v0.1.13 

func (_m *Node) OnHandleMatch(matchers ...interface{}) *Node_Handle

func (*Node) OnSetup added in v0.1.13 

func (_m *Node) OnSetup(ctx context.Context, setupContext handler.SetupContext) *Node_Setup

func (*Node) OnSetupMatch added in v0.1.13 

func (_m *Node) OnSetupMatch(matchers ...interface{}) *Node_Setup

func (*Node) Setup added in v0.1.13 

func (_m *Node) Setup(ctx context.Context, setupContext handler.SetupContext) error

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

type NodeExecutionContext added in v0.1.13 

type NodeExecutionContext struct {
	mock.Mock
}

NodeExecutionContext is an autogenerated mock type for the NodeExecutionContext type

func (*NodeExecutionContext) ContextualNodeLookup added in v0.2.28 

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

ContextualNodeLookup provides a mock function with given fields:

func (*NodeExecutionContext) CurrentAttempt added in v0.1.13 

func (_m *NodeExecutionContext) CurrentAttempt() uint32

CurrentAttempt provides a mock function with given fields:

func (*NodeExecutionContext) DataStore added in v0.1.13 

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

DataStore provides a mock function with given fields:

func (*NodeExecutionContext) EnqueueOwnerFunc added in v0.1.13 

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

EnqueueOwnerFunc provides a mock function with given fields:

func (*NodeExecutionContext) EventsRecorder added in v0.1.13 

func (_m *NodeExecutionContext) EventsRecorder() events.TaskEventRecorder

EventsRecorder provides a mock function with given fields:

func (*NodeExecutionContext) ExecutionContext added in v0.2.28 

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

ExecutionContext provides a mock function with given fields:

func (*NodeExecutionContext) InputReader added in v0.1.13 

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

InputReader provides a mock function with given fields:

func (*NodeExecutionContext) MaxDatasetSizeBytes added in v0.1.13 

func (_m *NodeExecutionContext) MaxDatasetSizeBytes() int64

MaxDatasetSizeBytes provides a mock function with given fields:

func (*NodeExecutionContext) Node added in v0.1.13 

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

Node provides a mock function with given fields:

func (*NodeExecutionContext) NodeExecutionMetadata added in v0.1.13 

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

NodeExecutionMetadata provides a mock function with given fields:

func (*NodeExecutionContext) NodeID added in v0.1.13 

func (_m *NodeExecutionContext) NodeID() string

NodeID provides a mock function with given fields:

func (*NodeExecutionContext) NodeStateReader added in v0.1.13 

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

NodeStateReader provides a mock function with given fields:

func (*NodeExecutionContext) NodeStateWriter added in v0.1.13 

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

NodeStateWriter provides a mock function with given fields:

func (*NodeExecutionContext) NodeStatus added in v0.1.13 

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

NodeStatus provides a mock function with given fields:

func (*NodeExecutionContext) OnContextualNodeLookup added in v0.2.28 

func (_m *NodeExecutionContext) OnContextualNodeLookup() *NodeExecutionContext_ContextualNodeLookup

func (*NodeExecutionContext) OnContextualNodeLookupMatch added in v0.2.28 

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

func (*NodeExecutionContext) OnCurrentAttempt added in v0.1.13 

func (_m *NodeExecutionContext) OnCurrentAttempt() *NodeExecutionContext_CurrentAttempt

func (*NodeExecutionContext) OnCurrentAttemptMatch added in v0.1.13 

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

func (*NodeExecutionContext) OnDataStore added in v0.1.13 

func (_m *NodeExecutionContext) OnDataStore() *NodeExecutionContext_DataStore

func (*NodeExecutionContext) OnDataStoreMatch added in v0.1.13 

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

func (*NodeExecutionContext) OnEnqueueOwnerFunc added in v0.1.13 

func (_m *NodeExecutionContext) OnEnqueueOwnerFunc() *NodeExecutionContext_EnqueueOwnerFunc

func (*NodeExecutionContext) OnEnqueueOwnerFuncMatch added in v0.1.13 

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

func (*NodeExecutionContext) OnEventsRecorder added in v0.1.13 

func (_m *NodeExecutionContext) OnEventsRecorder() *NodeExecutionContext_EventsRecorder

func (*NodeExecutionContext) OnEventsRecorderMatch added in v0.1.13 

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

func (*NodeExecutionContext) OnExecutionContext added in v0.2.28 

func (_m *NodeExecutionContext) OnExecutionContext() *NodeExecutionContext_ExecutionContext

func (*NodeExecutionContext) OnExecutionContextMatch added in v0.2.28 

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

func (*NodeExecutionContext) OnInputReader added in v0.1.13 

func (_m *NodeExecutionContext) OnInputReader() *NodeExecutionContext_InputReader

func (*NodeExecutionContext) OnInputReaderMatch added in v0.1.13 

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

func (*NodeExecutionContext) OnMaxDatasetSizeBytes added in v0.1.13 

func (_m *NodeExecutionContext) OnMaxDatasetSizeBytes() *NodeExecutionContext_MaxDatasetSizeBytes

func (*NodeExecutionContext) OnMaxDatasetSizeBytesMatch added in v0.1.13 

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

func (*NodeExecutionContext) OnNode added in v0.1.13 

func (_m *NodeExecutionContext) OnNode() *NodeExecutionContext_Node

func (*NodeExecutionContext) OnNodeExecutionMetadata added in v0.1.13 

func (_m *NodeExecutionContext) OnNodeExecutionMetadata() *NodeExecutionContext_NodeExecutionMetadata

func (*NodeExecutionContext) OnNodeExecutionMetadataMatch added in v0.1.13 

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

func (*NodeExecutionContext) OnNodeID added in v0.1.13 

func (_m *NodeExecutionContext) OnNodeID() *NodeExecutionContext_NodeID

func (*NodeExecutionContext) OnNodeIDMatch added in v0.1.13 

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

func (*NodeExecutionContext) OnNodeMatch added in v0.1.13 

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

func (*NodeExecutionContext) OnNodeStateReader added in v0.1.13 

func (_m *NodeExecutionContext) OnNodeStateReader() *NodeExecutionContext_NodeStateReader

func (*NodeExecutionContext) OnNodeStateReaderMatch added in v0.1.13 

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

func (*NodeExecutionContext) OnNodeStateWriter added in v0.1.13 

func (_m *NodeExecutionContext) OnNodeStateWriter() *NodeExecutionContext_NodeStateWriter

func (*NodeExecutionContext) OnNodeStateWriterMatch added in v0.1.13 

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

func (*NodeExecutionContext) OnNodeStatus added in v0.1.13 

func (_m *NodeExecutionContext) OnNodeStatus() *NodeExecutionContext_NodeStatus

func (*NodeExecutionContext) OnNodeStatusMatch added in v0.1.13 

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

func (*NodeExecutionContext) OnOutputShardSelector added in v0.2.20 

func (_m *NodeExecutionContext) OnOutputShardSelector() *NodeExecutionContext_OutputShardSelector

func (*NodeExecutionContext) OnOutputShardSelectorMatch added in v0.2.20 

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

func (*NodeExecutionContext) OnRawOutputPrefix added in v0.2.20 

func (_m *NodeExecutionContext) OnRawOutputPrefix() *NodeExecutionContext_RawOutputPrefix

func (*NodeExecutionContext) OnRawOutputPrefixMatch added in v0.2.20 

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

func (*NodeExecutionContext) OnTaskReader added in v0.1.13 

func (_m *NodeExecutionContext) OnTaskReader() *NodeExecutionContext_TaskReader

func (*NodeExecutionContext) OnTaskReaderMatch added in v0.1.13 

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

func (*NodeExecutionContext) OutputShardSelector added in v0.2.20 

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

OutputShardSelector provides a mock function with given fields:

func (*NodeExecutionContext) RawOutputPrefix added in v0.2.20 

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

RawOutputPrefix provides a mock function with given fields:

func (*NodeExecutionContext) TaskReader added in v0.1.13 

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

TaskReader provides a mock function with given fields:

type NodeExecutionContext_ContextualNodeLookup added in v0.2.28 

type NodeExecutionContext_ContextualNodeLookup struct {
	*mock.Call
}

func (NodeExecutionContext_ContextualNodeLookup) Return added in v0.2.28 

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

type NodeExecutionContext_CurrentAttempt added in v0.1.13 

type NodeExecutionContext_CurrentAttempt struct {
	*mock.Call
}

func (NodeExecutionContext_CurrentAttempt) Return added in v0.1.13 

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

type NodeExecutionContext_DataStore added in v0.1.13 

type NodeExecutionContext_DataStore struct {
	*mock.Call
}

func (NodeExecutionContext_DataStore) Return added in v0.1.13 

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

type NodeExecutionContext_EnqueueOwnerFunc added in v0.1.13 

type NodeExecutionContext_EnqueueOwnerFunc struct {
	*mock.Call
}

func (NodeExecutionContext_EnqueueOwnerFunc) Return added in v0.1.13 

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

type NodeExecutionContext_EventsRecorder added in v0.1.13 

type NodeExecutionContext_EventsRecorder struct {
	*mock.Call
}

func (NodeExecutionContext_EventsRecorder) Return added in v0.1.13 

func (_m NodeExecutionContext_EventsRecorder) Return(_a0 events.TaskEventRecorder) *NodeExecutionContext_EventsRecorder

type NodeExecutionContext_ExecutionContext added in v0.2.28 

type NodeExecutionContext_ExecutionContext struct {
	*mock.Call
}

func (NodeExecutionContext_ExecutionContext) Return added in v0.2.28 

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

type NodeExecutionContext_InputReader added in v0.1.13 

type NodeExecutionContext_InputReader struct {
	*mock.Call
}

func (NodeExecutionContext_InputReader) Return added in v0.1.13 

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

type NodeExecutionContext_MaxDatasetSizeBytes added in v0.1.13 

type NodeExecutionContext_MaxDatasetSizeBytes struct {
	*mock.Call
}

func (NodeExecutionContext_MaxDatasetSizeBytes) Return added in v0.1.13 

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

type NodeExecutionContext_Node added in v0.1.13 

type NodeExecutionContext_Node struct {
	*mock.Call
}

func (NodeExecutionContext_Node) Return added in v0.1.13 

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

type NodeExecutionContext_NodeExecutionMetadata added in v0.1.13 

type NodeExecutionContext_NodeExecutionMetadata struct {
	*mock.Call
}

func (NodeExecutionContext_NodeExecutionMetadata) Return added in v0.1.13 

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

type NodeExecutionContext_NodeID added in v0.1.13 

type NodeExecutionContext_NodeID struct {
	*mock.Call
}

func (NodeExecutionContext_NodeID) Return added in v0.1.13 

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

type NodeExecutionContext_NodeStateReader added in v0.1.13 

type NodeExecutionContext_NodeStateReader struct {
	*mock.Call
}

func (NodeExecutionContext_NodeStateReader) Return added in v0.1.13 

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

type NodeExecutionContext_NodeStateWriter added in v0.1.13 

type NodeExecutionContext_NodeStateWriter struct {
	*mock.Call
}

func (NodeExecutionContext_NodeStateWriter) Return added in v0.1.13 

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

type NodeExecutionContext_NodeStatus added in v0.1.13 

type NodeExecutionContext_NodeStatus struct {
	*mock.Call
}

func (NodeExecutionContext_NodeStatus) Return added in v0.1.13 

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

type NodeExecutionContext_OutputShardSelector added in v0.2.20 

type NodeExecutionContext_OutputShardSelector struct {
	*mock.Call
}

func (NodeExecutionContext_OutputShardSelector) Return added in v0.2.20 

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

type NodeExecutionContext_RawOutputPrefix added in v0.2.20 

type NodeExecutionContext_RawOutputPrefix struct {
	*mock.Call
}

func (NodeExecutionContext_RawOutputPrefix) Return added in v0.2.20 

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

type NodeExecutionContext_TaskReader added in v0.1.13 

type NodeExecutionContext_TaskReader struct {
	*mock.Call
}

func (NodeExecutionContext_TaskReader) Return added in v0.1.13 

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

type NodeExecutionMetadata added in v0.1.13 

type NodeExecutionMetadata struct {
	mock.Mock
}

NodeExecutionMetadata is an autogenerated mock type for the NodeExecutionMetadata type

func (*NodeExecutionMetadata) GetAnnotations added in v0.1.13 

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

GetAnnotations provides a mock function with given fields:

func (*NodeExecutionMetadata) GetK8sServiceAccount added in v0.1.13 

func (_m *NodeExecutionMetadata) GetK8sServiceAccount() string

GetK8sServiceAccount provides a mock function with given fields:

func (*NodeExecutionMetadata) GetLabels added in v0.1.13 

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

GetLabels provides a mock function with given fields:

func (*NodeExecutionMetadata) GetNamespace added in v0.1.13 

func (_m *NodeExecutionMetadata) GetNamespace() string

GetNamespace provides a mock function with given fields:

func (*NodeExecutionMetadata) GetNodeExecutionID added in v0.2.28 

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

GetNodeExecutionID provides a mock function with given fields:

func (*NodeExecutionMetadata) GetOwnerID added in v0.1.13 

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

GetOwnerID provides a mock function with given fields:

func (*NodeExecutionMetadata) GetOwnerReference added in v0.1.13 

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

GetOwnerReference provides a mock function with given fields:

func (*NodeExecutionMetadata) IsInterruptible added in v0.2.15 

func (_m *NodeExecutionMetadata) IsInterruptible() bool

IsInterruptible provides a mock function with given fields:

func (*NodeExecutionMetadata) OnGetAnnotations added in v0.1.13 

func (_m *NodeExecutionMetadata) OnGetAnnotations() *NodeExecutionMetadata_GetAnnotations

func (*NodeExecutionMetadata) OnGetAnnotationsMatch added in v0.1.13 

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

func (*NodeExecutionMetadata) OnGetK8sServiceAccount added in v0.1.13 

func (_m *NodeExecutionMetadata) OnGetK8sServiceAccount() *NodeExecutionMetadata_GetK8sServiceAccount

func (*NodeExecutionMetadata) OnGetK8sServiceAccountMatch added in v0.1.13 

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

func (*NodeExecutionMetadata) OnGetLabels added in v0.1.13 

func (_m *NodeExecutionMetadata) OnGetLabels() *NodeExecutionMetadata_GetLabels

func (*NodeExecutionMetadata) OnGetLabelsMatch added in v0.1.13 

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

func (*NodeExecutionMetadata) OnGetNamespace added in v0.1.13 

func (_m *NodeExecutionMetadata) OnGetNamespace() *NodeExecutionMetadata_GetNamespace

func (*NodeExecutionMetadata) OnGetNamespaceMatch added in v0.1.13 

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

func (*NodeExecutionMetadata) OnGetNodeExecutionID added in v0.2.28 

func (_m *NodeExecutionMetadata) OnGetNodeExecutionID() *NodeExecutionMetadata_GetNodeExecutionID

func (*NodeExecutionMetadata) OnGetNodeExecutionIDMatch added in v0.2.28 

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

func (*NodeExecutionMetadata) OnGetOwnerID added in v0.1.13 

func (_m *NodeExecutionMetadata) OnGetOwnerID() *NodeExecutionMetadata_GetOwnerID

func (*NodeExecutionMetadata) OnGetOwnerIDMatch added in v0.1.13 

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

func (*NodeExecutionMetadata) OnGetOwnerReference added in v0.1.13 

func (_m *NodeExecutionMetadata) OnGetOwnerReference() *NodeExecutionMetadata_GetOwnerReference

func (*NodeExecutionMetadata) OnGetOwnerReferenceMatch added in v0.1.13 

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

func (*NodeExecutionMetadata) OnIsInterruptible added in v0.2.15 

func (_m *NodeExecutionMetadata) OnIsInterruptible() *NodeExecutionMetadata_IsInterruptible

func (*NodeExecutionMetadata) OnIsInterruptibleMatch added in v0.2.15 

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

type NodeExecutionMetadata_GetAnnotations added in v0.1.13 

type NodeExecutionMetadata_GetAnnotations struct {
	*mock.Call
}

func (NodeExecutionMetadata_GetAnnotations) Return added in v0.1.13 

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

type NodeExecutionMetadata_GetK8sServiceAccount added in v0.1.13 

type NodeExecutionMetadata_GetK8sServiceAccount struct {
	*mock.Call
}

func (NodeExecutionMetadata_GetK8sServiceAccount) Return added in v0.1.13 

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

type NodeExecutionMetadata_GetLabels added in v0.1.13 

type NodeExecutionMetadata_GetLabels struct {
	*mock.Call
}

func (NodeExecutionMetadata_GetLabels) Return added in v0.1.13 

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

type NodeExecutionMetadata_GetNamespace added in v0.1.13 

type NodeExecutionMetadata_GetNamespace struct {
	*mock.Call
}

func (NodeExecutionMetadata_GetNamespace) Return added in v0.1.13 

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

type NodeExecutionMetadata_GetNodeExecutionID added in v0.2.28 

type NodeExecutionMetadata_GetNodeExecutionID struct {
	*mock.Call
}

func (NodeExecutionMetadata_GetNodeExecutionID) Return added in v0.2.28 

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

type NodeExecutionMetadata_GetOwnerID added in v0.1.13 

type NodeExecutionMetadata_GetOwnerID struct {
	*mock.Call
}

func (NodeExecutionMetadata_GetOwnerID) Return added in v0.1.13 

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

type NodeExecutionMetadata_GetOwnerReference added in v0.1.13 

type NodeExecutionMetadata_GetOwnerReference struct {
	*mock.Call
}

func (NodeExecutionMetadata_GetOwnerReference) Return added in v0.1.13 

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

type NodeExecutionMetadata_IsInterruptible added in v0.2.15 

type NodeExecutionMetadata_IsInterruptible struct {
	*mock.Call
}

func (NodeExecutionMetadata_IsInterruptible) Return added in v0.2.15 

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

type NodeStateReader added in v0.1.13 

type NodeStateReader struct {
	mock.Mock
}

NodeStateReader is an autogenerated mock type for the NodeStateReader type

func (*NodeStateReader) GetBranchNode added in v0.1.13 

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

GetBranchNode provides a mock function with given fields:

func (*NodeStateReader) GetDynamicNodeState added in v0.1.13 

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

GetDynamicNodeState provides a mock function with given fields:

func (*NodeStateReader) GetTaskNodeState added in v0.1.13 

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

GetTaskNodeState provides a mock function with given fields:

func (*NodeStateReader) GetWorkflowNodeState added in v0.1.13 

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

GetWorkflowNodeState provides a mock function with given fields:

func (*NodeStateReader) OnGetBranchNode added in v0.1.13 

func (_m *NodeStateReader) OnGetBranchNode() *NodeStateReader_GetBranchNode

func (*NodeStateReader) OnGetBranchNodeMatch added in v0.1.13 

func (_m *NodeStateReader) OnGetBranchNodeMatch(matchers ...interface{}) *NodeStateReader_GetBranchNode

func (*NodeStateReader) OnGetDynamicNodeState added in v0.1.13 

func (_m *NodeStateReader) OnGetDynamicNodeState() *NodeStateReader_GetDynamicNodeState

func (*NodeStateReader) OnGetDynamicNodeStateMatch added in v0.1.13 

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

func (*NodeStateReader) OnGetTaskNodeState added in v0.1.13 

func (_m *NodeStateReader) OnGetTaskNodeState() *NodeStateReader_GetTaskNodeState

func (*NodeStateReader) OnGetTaskNodeStateMatch added in v0.1.13 

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

func (*NodeStateReader) OnGetWorkflowNodeState added in v0.1.13 

func (_m *NodeStateReader) OnGetWorkflowNodeState() *NodeStateReader_GetWorkflowNodeState

func (*NodeStateReader) OnGetWorkflowNodeStateMatch added in v0.1.13 

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

type NodeStateReader_GetBranchNode added in v0.1.13 

type NodeStateReader_GetBranchNode struct {
	*mock.Call
}

func (NodeStateReader_GetBranchNode) Return added in v0.1.13 

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

type NodeStateReader_GetDynamicNodeState added in v0.1.13 

type NodeStateReader_GetDynamicNodeState struct {
	*mock.Call
}

func (NodeStateReader_GetDynamicNodeState) Return added in v0.1.13 

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

type NodeStateReader_GetTaskNodeState added in v0.1.13 

type NodeStateReader_GetTaskNodeState struct {
	*mock.Call
}

func (NodeStateReader_GetTaskNodeState) Return added in v0.1.13 

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

type NodeStateReader_GetWorkflowNodeState added in v0.1.13 

type NodeStateReader_GetWorkflowNodeState struct {
	*mock.Call
}

func (NodeStateReader_GetWorkflowNodeState) Return added in v0.1.13 

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

type NodeStateWriter added in v0.1.13 

type NodeStateWriter struct {
	mock.Mock
}

NodeStateWriter is an autogenerated mock type for the NodeStateWriter type

func (*NodeStateWriter) OnPutBranchNode added in v0.1.13 

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

func (*NodeStateWriter) OnPutBranchNodeMatch added in v0.1.13 

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

func (*NodeStateWriter) OnPutDynamicNodeState added in v0.1.13 

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

func (*NodeStateWriter) OnPutDynamicNodeStateMatch added in v0.1.13 

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

func (*NodeStateWriter) OnPutTaskNodeState added in v0.1.13 

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

func (*NodeStateWriter) OnPutTaskNodeStateMatch added in v0.1.13 

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

func (*NodeStateWriter) OnPutWorkflowNodeState added in v0.1.13 

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

func (*NodeStateWriter) OnPutWorkflowNodeStateMatch added in v0.1.13 

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

func (*NodeStateWriter) PutBranchNode added in v0.1.13 

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

PutBranchNode provides a mock function with given fields: s

func (*NodeStateWriter) PutDynamicNodeState added in v0.1.13 

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

PutDynamicNodeState provides a mock function with given fields: s

func (*NodeStateWriter) PutTaskNodeState added in v0.1.13 

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

PutTaskNodeState provides a mock function with given fields: s

func (*NodeStateWriter) PutWorkflowNodeState added in v0.1.13 

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

PutWorkflowNodeState provides a mock function with given fields: s

type NodeStateWriter_PutBranchNode added in v0.1.13 

type NodeStateWriter_PutBranchNode struct {
	*mock.Call
}

func (NodeStateWriter_PutBranchNode) Return added in v0.1.13 

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

type NodeStateWriter_PutDynamicNodeState added in v0.1.13 

type NodeStateWriter_PutDynamicNodeState struct {
	*mock.Call
}

func (NodeStateWriter_PutDynamicNodeState) Return added in v0.1.13 

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

type NodeStateWriter_PutTaskNodeState added in v0.1.13 

type NodeStateWriter_PutTaskNodeState struct {
	*mock.Call
}

func (NodeStateWriter_PutTaskNodeState) Return added in v0.1.13 

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

type NodeStateWriter_PutWorkflowNodeState added in v0.1.13 

type NodeStateWriter_PutWorkflowNodeState struct {
	*mock.Call
}

func (NodeStateWriter_PutWorkflowNodeState) Return added in v0.1.13 

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

type Node_Abort added in v0.1.13 

type Node_Abort struct {
	*mock.Call
}

func (Node_Abort) Return added in v0.1.13 

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

type Node_Finalize added in v0.1.13 

type Node_Finalize struct {
	*mock.Call
}

func (Node_Finalize) Return added in v0.1.13 

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

type Node_FinalizeRequired added in v0.1.13 

type Node_FinalizeRequired struct {
	*mock.Call
}

func (Node_FinalizeRequired) Return added in v0.1.13 

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

type Node_Handle added in v0.1.13 

type Node_Handle struct {
	*mock.Call
}

func (Node_Handle) Return added in v0.1.13 

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

type Node_Setup added in v0.1.13 

type Node_Setup struct {
	*mock.Call
}

func (Node_Setup) Return added in v0.1.13 

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

type SetupContext added in v0.1.13 

type SetupContext struct {
	mock.Mock
}

SetupContext is an autogenerated mock type for the SetupContext type

func (*SetupContext) EnqueueOwner added in v0.1.13 

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

EnqueueOwner provides a mock function with given fields:

func (*SetupContext) MetricsScope added in v0.1.13 

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

MetricsScope provides a mock function with given fields:

func (*SetupContext) OnEnqueueOwner added in v0.1.13 

func (_m *SetupContext) OnEnqueueOwner() *SetupContext_EnqueueOwner

func (*SetupContext) OnEnqueueOwnerMatch added in v0.1.13 

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

func (*SetupContext) OnMetricsScope added in v0.1.13 

func (_m *SetupContext) OnMetricsScope() *SetupContext_MetricsScope

func (*SetupContext) OnMetricsScopeMatch added in v0.1.13 

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

func (*SetupContext) OnOwnerKind added in v0.1.13 

func (_m *SetupContext) OnOwnerKind() *SetupContext_OwnerKind

func (*SetupContext) OnOwnerKindMatch added in v0.1.13 

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

func (*SetupContext) OwnerKind added in v0.1.13 

func (_m *SetupContext) OwnerKind() string

OwnerKind provides a mock function with given fields:

type SetupContext_EnqueueOwner added in v0.1.13 

type SetupContext_EnqueueOwner struct {
	*mock.Call
}

func (SetupContext_EnqueueOwner) Return added in v0.1.13 

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

type SetupContext_MetricsScope added in v0.1.13 

type SetupContext_MetricsScope struct {
	*mock.Call
}

func (SetupContext_MetricsScope) Return added in v0.1.13 

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

type SetupContext_OwnerKind added in v0.1.13 

type SetupContext_OwnerKind struct {
	*mock.Call
}

func (SetupContext_OwnerKind) Return added in v0.1.13 

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

type TaskReader added in v0.1.13 

type TaskReader struct {
	mock.Mock
}

TaskReader is an autogenerated mock type for the TaskReader type

func (*TaskReader) GetTaskID added in v0.1.13 

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

GetTaskID provides a mock function with given fields:

func (*TaskReader) GetTaskType added in v0.1.13 

func (_m *TaskReader) GetTaskType() string

GetTaskType provides a mock function with given fields:

func (*TaskReader) OnGetTaskID added in v0.1.13 

func (_m *TaskReader) OnGetTaskID() *TaskReader_GetTaskID

func (*TaskReader) OnGetTaskIDMatch added in v0.1.13 

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

func (*TaskReader) OnGetTaskType added in v0.1.13 

func (_m *TaskReader) OnGetTaskType() *TaskReader_GetTaskType

func (*TaskReader) OnGetTaskTypeMatch added in v0.1.13 

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

func (*TaskReader) OnRead added in v0.1.13 

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

func (*TaskReader) OnReadMatch added in v0.1.13 

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

func (*TaskReader) Read added in v0.1.13 

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

Read provides a mock function with given fields: ctx

type TaskReader_GetTaskID added in v0.1.13 

type TaskReader_GetTaskID struct {
	*mock.Call
}

func (TaskReader_GetTaskID) Return added in v0.1.13 

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

type TaskReader_GetTaskType added in v0.1.13 

type TaskReader_GetTaskType struct {
	*mock.Call
}

func (TaskReader_GetTaskType) Return added in v0.1.13 

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

type TaskReader_Read added in v0.1.13 

type TaskReader_Read struct {
	*mock.Call
}

func (TaskReader_Read) Return added in v0.1.13 

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.