Documentation ¶
Index ¶
- type Node
- func (_m *Node) Abort(ctx context.Context, executionContext handler.NodeExecutionContext, ...) error
- func (_m *Node) Finalize(ctx context.Context, executionContext handler.NodeExecutionContext) error
- func (_m *Node) FinalizeRequired() bool
- func (_m *Node) Handle(ctx context.Context, executionContext handler.NodeExecutionContext) (handler.Transition, error)
- func (_m *Node) OnAbort(ctx context.Context, executionContext handler.NodeExecutionContext, ...) *Node_Abort
- func (_m *Node) OnAbortMatch(matchers ...interface{}) *Node_Abort
- func (_m *Node) OnFinalize(ctx context.Context, executionContext handler.NodeExecutionContext) *Node_Finalize
- func (_m *Node) OnFinalizeMatch(matchers ...interface{}) *Node_Finalize
- func (_m *Node) OnFinalizeRequired() *Node_FinalizeRequired
- func (_m *Node) OnFinalizeRequiredMatch(matchers ...interface{}) *Node_FinalizeRequired
- func (_m *Node) OnHandle(ctx context.Context, executionContext handler.NodeExecutionContext) *Node_Handle
- func (_m *Node) OnHandleMatch(matchers ...interface{}) *Node_Handle
- func (_m *Node) OnSetup(ctx context.Context, setupContext handler.SetupContext) *Node_Setup
- func (_m *Node) OnSetupMatch(matchers ...interface{}) *Node_Setup
- func (_m *Node) Setup(ctx context.Context, setupContext handler.SetupContext) error
- type NodeExecutionContext
- func (_m *NodeExecutionContext) CurrentAttempt() uint32
- func (_m *NodeExecutionContext) DataStore() *storage.DataStore
- func (_m *NodeExecutionContext) EnqueueOwnerFunc() func() error
- func (_m *NodeExecutionContext) EventsRecorder() events.TaskEventRecorder
- func (_m *NodeExecutionContext) InputReader() io.InputReader
- func (_m *NodeExecutionContext) MaxDatasetSizeBytes() int64
- func (_m *NodeExecutionContext) Node() v1alpha1.ExecutableNode
- func (_m *NodeExecutionContext) NodeExecutionMetadata() handler.NodeExecutionMetadata
- func (_m *NodeExecutionContext) NodeID() string
- func (_m *NodeExecutionContext) NodeStateReader() handler.NodeStateReader
- func (_m *NodeExecutionContext) NodeStateWriter() handler.NodeStateWriter
- func (_m *NodeExecutionContext) NodeStatus() v1alpha1.ExecutableNodeStatus
- func (_m *NodeExecutionContext) OnCurrentAttempt() *NodeExecutionContext_CurrentAttempt
- func (_m *NodeExecutionContext) OnCurrentAttemptMatch(matchers ...interface{}) *NodeExecutionContext_CurrentAttempt
- func (_m *NodeExecutionContext) OnDataStore() *NodeExecutionContext_DataStore
- func (_m *NodeExecutionContext) OnDataStoreMatch(matchers ...interface{}) *NodeExecutionContext_DataStore
- func (_m *NodeExecutionContext) OnEnqueueOwnerFunc() *NodeExecutionContext_EnqueueOwnerFunc
- func (_m *NodeExecutionContext) OnEnqueueOwnerFuncMatch(matchers ...interface{}) *NodeExecutionContext_EnqueueOwnerFunc
- func (_m *NodeExecutionContext) OnEventsRecorder() *NodeExecutionContext_EventsRecorder
- func (_m *NodeExecutionContext) OnEventsRecorderMatch(matchers ...interface{}) *NodeExecutionContext_EventsRecorder
- func (_m *NodeExecutionContext) OnInputReader() *NodeExecutionContext_InputReader
- func (_m *NodeExecutionContext) OnInputReaderMatch(matchers ...interface{}) *NodeExecutionContext_InputReader
- func (_m *NodeExecutionContext) OnMaxDatasetSizeBytes() *NodeExecutionContext_MaxDatasetSizeBytes
- func (_m *NodeExecutionContext) OnMaxDatasetSizeBytesMatch(matchers ...interface{}) *NodeExecutionContext_MaxDatasetSizeBytes
- func (_m *NodeExecutionContext) OnNode() *NodeExecutionContext_Node
- func (_m *NodeExecutionContext) OnNodeExecutionMetadata() *NodeExecutionContext_NodeExecutionMetadata
- func (_m *NodeExecutionContext) OnNodeExecutionMetadataMatch(matchers ...interface{}) *NodeExecutionContext_NodeExecutionMetadata
- func (_m *NodeExecutionContext) OnNodeID() *NodeExecutionContext_NodeID
- func (_m *NodeExecutionContext) OnNodeIDMatch(matchers ...interface{}) *NodeExecutionContext_NodeID
- func (_m *NodeExecutionContext) OnNodeMatch(matchers ...interface{}) *NodeExecutionContext_Node
- func (_m *NodeExecutionContext) OnNodeStateReader() *NodeExecutionContext_NodeStateReader
- func (_m *NodeExecutionContext) OnNodeStateReaderMatch(matchers ...interface{}) *NodeExecutionContext_NodeStateReader
- func (_m *NodeExecutionContext) OnNodeStateWriter() *NodeExecutionContext_NodeStateWriter
- func (_m *NodeExecutionContext) OnNodeStateWriterMatch(matchers ...interface{}) *NodeExecutionContext_NodeStateWriter
- func (_m *NodeExecutionContext) OnNodeStatus() *NodeExecutionContext_NodeStatus
- func (_m *NodeExecutionContext) OnNodeStatusMatch(matchers ...interface{}) *NodeExecutionContext_NodeStatus
- func (_m *NodeExecutionContext) OnTaskReader() *NodeExecutionContext_TaskReader
- func (_m *NodeExecutionContext) OnTaskReaderMatch(matchers ...interface{}) *NodeExecutionContext_TaskReader
- func (_m *NodeExecutionContext) OnWorkflow() *NodeExecutionContext_Workflow
- func (_m *NodeExecutionContext) OnWorkflowMatch(matchers ...interface{}) *NodeExecutionContext_Workflow
- func (_m *NodeExecutionContext) TaskReader() handler.TaskReader
- func (_m *NodeExecutionContext) Workflow() v1alpha1.ExecutableWorkflow
- type NodeExecutionContext_CurrentAttempt
- type NodeExecutionContext_DataStore
- type NodeExecutionContext_EnqueueOwnerFunc
- type NodeExecutionContext_EventsRecorder
- type NodeExecutionContext_InputReader
- type NodeExecutionContext_MaxDatasetSizeBytes
- type NodeExecutionContext_Node
- type NodeExecutionContext_NodeExecutionMetadata
- type NodeExecutionContext_NodeID
- type NodeExecutionContext_NodeStateReader
- type NodeExecutionContext_NodeStateWriter
- type NodeExecutionContext_NodeStatus
- type NodeExecutionContext_TaskReader
- type NodeExecutionContext_Workflow
- type NodeExecutionMetadata
- func (_m *NodeExecutionMetadata) GetAnnotations() map[string]string
- func (_m *NodeExecutionMetadata) GetExecutionID() v1alpha1.WorkflowExecutionIdentifier
- func (_m *NodeExecutionMetadata) GetK8sServiceAccount() string
- func (_m *NodeExecutionMetadata) GetLabels() map[string]string
- func (_m *NodeExecutionMetadata) GetNamespace() string
- func (_m *NodeExecutionMetadata) GetOwnerID() types.NamespacedName
- func (_m *NodeExecutionMetadata) GetOwnerReference() v1.OwnerReference
- func (_m *NodeExecutionMetadata) IsInterruptible() bool
- func (_m *NodeExecutionMetadata) OnGetAnnotations() *NodeExecutionMetadata_GetAnnotations
- func (_m *NodeExecutionMetadata) OnGetAnnotationsMatch(matchers ...interface{}) *NodeExecutionMetadata_GetAnnotations
- func (_m *NodeExecutionMetadata) OnGetExecutionID() *NodeExecutionMetadata_GetExecutionID
- func (_m *NodeExecutionMetadata) OnGetExecutionIDMatch(matchers ...interface{}) *NodeExecutionMetadata_GetExecutionID
- func (_m *NodeExecutionMetadata) OnGetK8sServiceAccount() *NodeExecutionMetadata_GetK8sServiceAccount
- func (_m *NodeExecutionMetadata) OnGetK8sServiceAccountMatch(matchers ...interface{}) *NodeExecutionMetadata_GetK8sServiceAccount
- func (_m *NodeExecutionMetadata) OnGetLabels() *NodeExecutionMetadata_GetLabels
- func (_m *NodeExecutionMetadata) OnGetLabelsMatch(matchers ...interface{}) *NodeExecutionMetadata_GetLabels
- func (_m *NodeExecutionMetadata) OnGetNamespace() *NodeExecutionMetadata_GetNamespace
- func (_m *NodeExecutionMetadata) OnGetNamespaceMatch(matchers ...interface{}) *NodeExecutionMetadata_GetNamespace
- func (_m *NodeExecutionMetadata) OnGetOwnerID() *NodeExecutionMetadata_GetOwnerID
- func (_m *NodeExecutionMetadata) OnGetOwnerIDMatch(matchers ...interface{}) *NodeExecutionMetadata_GetOwnerID
- func (_m *NodeExecutionMetadata) OnGetOwnerReference() *NodeExecutionMetadata_GetOwnerReference
- func (_m *NodeExecutionMetadata) OnGetOwnerReferenceMatch(matchers ...interface{}) *NodeExecutionMetadata_GetOwnerReference
- func (_m *NodeExecutionMetadata) OnIsInterruptible() *NodeExecutionMetadata_IsInterruptible
- func (_m *NodeExecutionMetadata) OnIsInterruptibleMatch(matchers ...interface{}) *NodeExecutionMetadata_IsInterruptible
- type NodeExecutionMetadata_GetAnnotations
- type NodeExecutionMetadata_GetExecutionID
- type NodeExecutionMetadata_GetK8sServiceAccount
- type NodeExecutionMetadata_GetLabels
- type NodeExecutionMetadata_GetNamespace
- type NodeExecutionMetadata_GetOwnerID
- type NodeExecutionMetadata_GetOwnerReference
- type NodeExecutionMetadata_IsInterruptible
- type NodeStateReader
- func (_m *NodeStateReader) GetBranchNode() handler.BranchNodeState
- func (_m *NodeStateReader) GetDynamicNodeState() handler.DynamicNodeState
- func (_m *NodeStateReader) GetTaskNodeState() handler.TaskNodeState
- func (_m *NodeStateReader) GetWorkflowNodeState() handler.WorkflowNodeState
- func (_m *NodeStateReader) OnGetBranchNode() *NodeStateReader_GetBranchNode
- func (_m *NodeStateReader) OnGetBranchNodeMatch(matchers ...interface{}) *NodeStateReader_GetBranchNode
- func (_m *NodeStateReader) OnGetDynamicNodeState() *NodeStateReader_GetDynamicNodeState
- func (_m *NodeStateReader) OnGetDynamicNodeStateMatch(matchers ...interface{}) *NodeStateReader_GetDynamicNodeState
- func (_m *NodeStateReader) OnGetTaskNodeState() *NodeStateReader_GetTaskNodeState
- func (_m *NodeStateReader) OnGetTaskNodeStateMatch(matchers ...interface{}) *NodeStateReader_GetTaskNodeState
- func (_m *NodeStateReader) OnGetWorkflowNodeState() *NodeStateReader_GetWorkflowNodeState
- func (_m *NodeStateReader) OnGetWorkflowNodeStateMatch(matchers ...interface{}) *NodeStateReader_GetWorkflowNodeState
- type NodeStateReader_GetBranchNode
- type NodeStateReader_GetDynamicNodeState
- type NodeStateReader_GetTaskNodeState
- type NodeStateReader_GetWorkflowNodeState
- type NodeStateWriter
- func (_m *NodeStateWriter) OnPutBranchNode(s handler.BranchNodeState) *NodeStateWriter_PutBranchNode
- func (_m *NodeStateWriter) OnPutBranchNodeMatch(matchers ...interface{}) *NodeStateWriter_PutBranchNode
- func (_m *NodeStateWriter) OnPutDynamicNodeState(s handler.DynamicNodeState) *NodeStateWriter_PutDynamicNodeState
- func (_m *NodeStateWriter) OnPutDynamicNodeStateMatch(matchers ...interface{}) *NodeStateWriter_PutDynamicNodeState
- func (_m *NodeStateWriter) OnPutTaskNodeState(s handler.TaskNodeState) *NodeStateWriter_PutTaskNodeState
- func (_m *NodeStateWriter) OnPutTaskNodeStateMatch(matchers ...interface{}) *NodeStateWriter_PutTaskNodeState
- func (_m *NodeStateWriter) OnPutWorkflowNodeState(s handler.WorkflowNodeState) *NodeStateWriter_PutWorkflowNodeState
- func (_m *NodeStateWriter) OnPutWorkflowNodeStateMatch(matchers ...interface{}) *NodeStateWriter_PutWorkflowNodeState
- func (_m *NodeStateWriter) PutBranchNode(s handler.BranchNodeState) error
- func (_m *NodeStateWriter) PutDynamicNodeState(s handler.DynamicNodeState) error
- func (_m *NodeStateWriter) PutTaskNodeState(s handler.TaskNodeState) error
- func (_m *NodeStateWriter) PutWorkflowNodeState(s handler.WorkflowNodeState) error
- type NodeStateWriter_PutBranchNode
- type NodeStateWriter_PutDynamicNodeState
- type NodeStateWriter_PutTaskNodeState
- type NodeStateWriter_PutWorkflowNodeState
- type Node_Abort
- type Node_Finalize
- type Node_FinalizeRequired
- type Node_Handle
- type Node_Setup
- type SetupContext
- func (_m *SetupContext) EnqueueOwner() func(string)
- func (_m *SetupContext) MetricsScope() promutils.Scope
- func (_m *SetupContext) OnEnqueueOwner() *SetupContext_EnqueueOwner
- func (_m *SetupContext) OnEnqueueOwnerMatch(matchers ...interface{}) *SetupContext_EnqueueOwner
- func (_m *SetupContext) OnMetricsScope() *SetupContext_MetricsScope
- func (_m *SetupContext) OnMetricsScopeMatch(matchers ...interface{}) *SetupContext_MetricsScope
- func (_m *SetupContext) OnOwnerKind() *SetupContext_OwnerKind
- func (_m *SetupContext) OnOwnerKindMatch(matchers ...interface{}) *SetupContext_OwnerKind
- func (_m *SetupContext) OwnerKind() string
- type SetupContext_EnqueueOwner
- type SetupContext_MetricsScope
- type SetupContext_OwnerKind
- type TaskReader
- func (_m *TaskReader) GetTaskID() *core.Identifier
- func (_m *TaskReader) GetTaskType() string
- func (_m *TaskReader) OnGetTaskID() *TaskReader_GetTaskID
- func (_m *TaskReader) OnGetTaskIDMatch(matchers ...interface{}) *TaskReader_GetTaskID
- func (_m *TaskReader) OnGetTaskType() *TaskReader_GetTaskType
- func (_m *TaskReader) OnGetTaskTypeMatch(matchers ...interface{}) *TaskReader_GetTaskType
- func (_m *TaskReader) OnRead(ctx context.Context) *TaskReader_Read
- func (_m *TaskReader) OnReadMatch(matchers ...interface{}) *TaskReader_Read
- func (_m *TaskReader) Read(ctx context.Context) (*core.TaskTemplate, error)
- type TaskReader_GetTaskID
- type TaskReader_GetTaskType
- type TaskReader_Read
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Node ¶ added in v0.1.13
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
Finalize provides a mock function with given fields: ctx, executionContext
func (*Node) FinalizeRequired ¶ added in v0.1.13
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
type NodeExecutionContext ¶ added in v0.1.13
NodeExecutionContext is an autogenerated mock type for the NodeExecutionContext type
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) 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) 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) 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) 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) OnWorkflow ¶ added in v0.1.13
func (_m *NodeExecutionContext) OnWorkflow() *NodeExecutionContext_Workflow
func (*NodeExecutionContext) OnWorkflowMatch ¶ added in v0.1.13
func (_m *NodeExecutionContext) OnWorkflowMatch(matchers ...interface{}) *NodeExecutionContext_Workflow
func (*NodeExecutionContext) TaskReader ¶ added in v0.1.13
func (_m *NodeExecutionContext) TaskReader() handler.TaskReader
TaskReader provides a mock function with given fields:
func (*NodeExecutionContext) Workflow ¶ added in v0.1.13
func (_m *NodeExecutionContext) Workflow() v1alpha1.ExecutableWorkflow
Workflow provides a mock function with given fields:
type NodeExecutionContext_CurrentAttempt ¶ added in v0.1.13
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
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
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
func (NodeExecutionContext_EventsRecorder) Return ¶ added in v0.1.13
func (_m NodeExecutionContext_EventsRecorder) Return(_a0 events.TaskEventRecorder) *NodeExecutionContext_EventsRecorder
type NodeExecutionContext_InputReader ¶ added in v0.1.13
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
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
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_NodeID ¶ added in v0.1.13
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
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
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
func (NodeExecutionContext_NodeStatus) Return ¶ added in v0.1.13
func (_m NodeExecutionContext_NodeStatus) Return(_a0 v1alpha1.ExecutableNodeStatus) *NodeExecutionContext_NodeStatus
type NodeExecutionContext_TaskReader ¶ added in v0.1.13
func (NodeExecutionContext_TaskReader) Return ¶ added in v0.1.13
func (_m NodeExecutionContext_TaskReader) Return(_a0 handler.TaskReader) *NodeExecutionContext_TaskReader
type NodeExecutionContext_Workflow ¶ added in v0.1.13
func (NodeExecutionContext_Workflow) Return ¶ added in v0.1.13
func (_m NodeExecutionContext_Workflow) Return(_a0 v1alpha1.ExecutableWorkflow) *NodeExecutionContext_Workflow
type NodeExecutionMetadata ¶ added in v0.1.13
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) GetExecutionID ¶ added in v0.1.13
func (_m *NodeExecutionMetadata) GetExecutionID() v1alpha1.WorkflowExecutionIdentifier
GetExecutionID 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) 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) OnGetExecutionID ¶ added in v0.1.13
func (_m *NodeExecutionMetadata) OnGetExecutionID() *NodeExecutionMetadata_GetExecutionID
func (*NodeExecutionMetadata) OnGetExecutionIDMatch ¶ added in v0.1.13
func (_m *NodeExecutionMetadata) OnGetExecutionIDMatch(matchers ...interface{}) *NodeExecutionMetadata_GetExecutionID
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) 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
func (NodeExecutionMetadata_GetAnnotations) Return ¶ added in v0.1.13
func (_m NodeExecutionMetadata_GetAnnotations) Return(_a0 map[string]string) *NodeExecutionMetadata_GetAnnotations
type NodeExecutionMetadata_GetExecutionID ¶ added in v0.1.13
type NodeExecutionMetadata_GetK8sServiceAccount ¶ added in v0.1.13
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
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
func (NodeExecutionMetadata_GetNamespace) Return ¶ added in v0.1.13
func (_m NodeExecutionMetadata_GetNamespace) Return(_a0 string) *NodeExecutionMetadata_GetNamespace
type NodeExecutionMetadata_GetOwnerID ¶ added in v0.1.13
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
func (TaskReader_Read) Return ¶ added in v0.1.13
func (_m TaskReader_Read) Return(_a0 *core.TaskTemplate, _a1 error) *TaskReader_Read