Documentation ¶
Index ¶
- type Client
- func (_m *Client) GetCache() cache.Cache
- func (_m *Client) GetClient() client.Client
- func (_m *Client) OnGetCache() *Client_GetCache
- func (_m *Client) OnGetCacheMatch(matchers ...interface{}) *Client_GetCache
- func (_m *Client) OnGetClient() *Client_GetClient
- func (_m *Client) OnGetClientMatch(matchers ...interface{}) *Client_GetClient
- type Client_GetCache
- type Client_GetClient
- type DAGStructure
- func (_m *DAGStructure) FromNode(id string) ([]string, error)
- func (_m *DAGStructure) OnFromNode(id string) *DAGStructure_FromNode
- func (_m *DAGStructure) OnFromNodeMatch(matchers ...interface{}) *DAGStructure_FromNode
- func (_m *DAGStructure) OnToNode(id string) *DAGStructure_ToNode
- func (_m *DAGStructure) OnToNodeMatch(matchers ...interface{}) *DAGStructure_ToNode
- func (_m *DAGStructure) ToNode(id string) ([]string, error)
- type DAGStructureWithStartNode
- func (_m *DAGStructureWithStartNode) FromNode(id string) ([]string, error)
- func (_m *DAGStructureWithStartNode) OnFromNode(id string) *DAGStructureWithStartNode_FromNode
- func (_m *DAGStructureWithStartNode) OnFromNodeMatch(matchers ...interface{}) *DAGStructureWithStartNode_FromNode
- func (_m *DAGStructureWithStartNode) OnStartNode() *DAGStructureWithStartNode_StartNode
- func (_m *DAGStructureWithStartNode) OnStartNodeMatch(matchers ...interface{}) *DAGStructureWithStartNode_StartNode
- func (_m *DAGStructureWithStartNode) OnToNode(id string) *DAGStructureWithStartNode_ToNode
- func (_m *DAGStructureWithStartNode) OnToNodeMatch(matchers ...interface{}) *DAGStructureWithStartNode_ToNode
- func (_m *DAGStructureWithStartNode) StartNode() v1alpha1.ExecutableNode
- func (_m *DAGStructureWithStartNode) ToNode(id string) ([]string, error)
- type DAGStructureWithStartNode_FromNode
- type DAGStructureWithStartNode_StartNode
- type DAGStructureWithStartNode_ToNode
- type DAGStructure_FromNode
- type DAGStructure_ToNode
- type ExecutionContext
- func (_m *ExecutionContext) FindSubWorkflow(subID string) v1alpha1.ExecutableSubWorkflow
- func (_m *ExecutionContext) GetAnnotations() map[string]string
- func (_m *ExecutionContext) GetCreationTimestamp() v1.Time
- func (_m *ExecutionContext) GetEventVersion() v1alpha1.EventVersion
- func (_m *ExecutionContext) GetExecutionID() v1alpha1.WorkflowExecutionIdentifier
- func (_m *ExecutionContext) GetID() string
- func (_m *ExecutionContext) GetK8sWorkflowID() types.NamespacedName
- func (_m *ExecutionContext) GetLabels() map[string]string
- func (_m *ExecutionContext) GetName() string
- func (_m *ExecutionContext) GetNamespace() string
- func (_m *ExecutionContext) GetOnFailurePolicy() v1alpha1.WorkflowOnFailurePolicy
- func (_m *ExecutionContext) GetOwnerReference() v1.OwnerReference
- func (_m *ExecutionContext) GetParentInfo() executors.ImmutableParentInfo
- func (_m *ExecutionContext) GetRawOutputDataConfig() v1alpha1.RawOutputDataConfig
- func (_m *ExecutionContext) GetServiceAccountName() string
- func (_m *ExecutionContext) GetTask(id string) (v1alpha1.ExecutableTask, error)
- func (_m *ExecutionContext) IsInterruptible() bool
- func (_m *ExecutionContext) OnFindSubWorkflow(subID string) *ExecutionContext_FindSubWorkflow
- func (_m *ExecutionContext) OnFindSubWorkflowMatch(matchers ...interface{}) *ExecutionContext_FindSubWorkflow
- func (_m *ExecutionContext) OnGetAnnotations() *ExecutionContext_GetAnnotations
- func (_m *ExecutionContext) OnGetAnnotationsMatch(matchers ...interface{}) *ExecutionContext_GetAnnotations
- func (_m *ExecutionContext) OnGetCreationTimestamp() *ExecutionContext_GetCreationTimestamp
- func (_m *ExecutionContext) OnGetCreationTimestampMatch(matchers ...interface{}) *ExecutionContext_GetCreationTimestamp
- func (_m *ExecutionContext) OnGetEventVersion() *ExecutionContext_GetEventVersion
- func (_m *ExecutionContext) OnGetEventVersionMatch(matchers ...interface{}) *ExecutionContext_GetEventVersion
- func (_m *ExecutionContext) OnGetExecutionID() *ExecutionContext_GetExecutionID
- func (_m *ExecutionContext) OnGetExecutionIDMatch(matchers ...interface{}) *ExecutionContext_GetExecutionID
- func (_m *ExecutionContext) OnGetID() *ExecutionContext_GetID
- func (_m *ExecutionContext) OnGetIDMatch(matchers ...interface{}) *ExecutionContext_GetID
- func (_m *ExecutionContext) OnGetK8sWorkflowID() *ExecutionContext_GetK8sWorkflowID
- func (_m *ExecutionContext) OnGetK8sWorkflowIDMatch(matchers ...interface{}) *ExecutionContext_GetK8sWorkflowID
- func (_m *ExecutionContext) OnGetLabels() *ExecutionContext_GetLabels
- func (_m *ExecutionContext) OnGetLabelsMatch(matchers ...interface{}) *ExecutionContext_GetLabels
- func (_m *ExecutionContext) OnGetName() *ExecutionContext_GetName
- func (_m *ExecutionContext) OnGetNameMatch(matchers ...interface{}) *ExecutionContext_GetName
- func (_m *ExecutionContext) OnGetNamespace() *ExecutionContext_GetNamespace
- func (_m *ExecutionContext) OnGetNamespaceMatch(matchers ...interface{}) *ExecutionContext_GetNamespace
- func (_m *ExecutionContext) OnGetOnFailurePolicy() *ExecutionContext_GetOnFailurePolicy
- func (_m *ExecutionContext) OnGetOnFailurePolicyMatch(matchers ...interface{}) *ExecutionContext_GetOnFailurePolicy
- func (_m *ExecutionContext) OnGetOwnerReference() *ExecutionContext_GetOwnerReference
- func (_m *ExecutionContext) OnGetOwnerReferenceMatch(matchers ...interface{}) *ExecutionContext_GetOwnerReference
- func (_m *ExecutionContext) OnGetParentInfo() *ExecutionContext_GetParentInfo
- func (_m *ExecutionContext) OnGetParentInfoMatch(matchers ...interface{}) *ExecutionContext_GetParentInfo
- func (_m *ExecutionContext) OnGetRawOutputDataConfig() *ExecutionContext_GetRawOutputDataConfig
- func (_m *ExecutionContext) OnGetRawOutputDataConfigMatch(matchers ...interface{}) *ExecutionContext_GetRawOutputDataConfig
- func (_m *ExecutionContext) OnGetServiceAccountName() *ExecutionContext_GetServiceAccountName
- func (_m *ExecutionContext) OnGetServiceAccountNameMatch(matchers ...interface{}) *ExecutionContext_GetServiceAccountName
- func (_m *ExecutionContext) OnGetTask(id string) *ExecutionContext_GetTask
- func (_m *ExecutionContext) OnGetTaskMatch(matchers ...interface{}) *ExecutionContext_GetTask
- func (_m *ExecutionContext) OnIsInterruptible() *ExecutionContext_IsInterruptible
- func (_m *ExecutionContext) OnIsInterruptibleMatch(matchers ...interface{}) *ExecutionContext_IsInterruptible
- type ExecutionContext_FindSubWorkflow
- type ExecutionContext_GetAnnotations
- type ExecutionContext_GetCreationTimestamp
- type ExecutionContext_GetEventVersion
- type ExecutionContext_GetExecutionID
- type ExecutionContext_GetID
- type ExecutionContext_GetK8sWorkflowID
- type ExecutionContext_GetLabels
- type ExecutionContext_GetName
- type ExecutionContext_GetNamespace
- type ExecutionContext_GetOnFailurePolicy
- type ExecutionContext_GetOwnerReference
- type ExecutionContext_GetParentInfo
- type ExecutionContext_GetRawOutputDataConfig
- type ExecutionContext_GetServiceAccountName
- type ExecutionContext_GetTask
- type ExecutionContext_IsInterruptible
- type ImmutableExecutionContext
- func (_m *ImmutableExecutionContext) GetAnnotations() map[string]string
- func (_m *ImmutableExecutionContext) GetCreationTimestamp() v1.Time
- func (_m *ImmutableExecutionContext) GetEventVersion() v1alpha1.EventVersion
- func (_m *ImmutableExecutionContext) GetExecutionID() v1alpha1.WorkflowExecutionIdentifier
- func (_m *ImmutableExecutionContext) GetID() string
- func (_m *ImmutableExecutionContext) GetK8sWorkflowID() types.NamespacedName
- func (_m *ImmutableExecutionContext) GetLabels() map[string]string
- func (_m *ImmutableExecutionContext) GetName() string
- func (_m *ImmutableExecutionContext) GetNamespace() string
- func (_m *ImmutableExecutionContext) GetOnFailurePolicy() v1alpha1.WorkflowOnFailurePolicy
- func (_m *ImmutableExecutionContext) GetOwnerReference() v1.OwnerReference
- func (_m *ImmutableExecutionContext) GetRawOutputDataConfig() v1alpha1.RawOutputDataConfig
- func (_m *ImmutableExecutionContext) GetServiceAccountName() string
- func (_m *ImmutableExecutionContext) IsInterruptible() bool
- func (_m *ImmutableExecutionContext) OnGetAnnotations() *ImmutableExecutionContext_GetAnnotations
- func (_m *ImmutableExecutionContext) OnGetAnnotationsMatch(matchers ...interface{}) *ImmutableExecutionContext_GetAnnotations
- func (_m *ImmutableExecutionContext) OnGetCreationTimestamp() *ImmutableExecutionContext_GetCreationTimestamp
- func (_m *ImmutableExecutionContext) OnGetCreationTimestampMatch(matchers ...interface{}) *ImmutableExecutionContext_GetCreationTimestamp
- func (_m *ImmutableExecutionContext) OnGetEventVersion() *ImmutableExecutionContext_GetEventVersion
- func (_m *ImmutableExecutionContext) OnGetEventVersionMatch(matchers ...interface{}) *ImmutableExecutionContext_GetEventVersion
- func (_m *ImmutableExecutionContext) OnGetExecutionID() *ImmutableExecutionContext_GetExecutionID
- func (_m *ImmutableExecutionContext) OnGetExecutionIDMatch(matchers ...interface{}) *ImmutableExecutionContext_GetExecutionID
- func (_m *ImmutableExecutionContext) OnGetID() *ImmutableExecutionContext_GetID
- func (_m *ImmutableExecutionContext) OnGetIDMatch(matchers ...interface{}) *ImmutableExecutionContext_GetID
- func (_m *ImmutableExecutionContext) OnGetK8sWorkflowID() *ImmutableExecutionContext_GetK8sWorkflowID
- func (_m *ImmutableExecutionContext) OnGetK8sWorkflowIDMatch(matchers ...interface{}) *ImmutableExecutionContext_GetK8sWorkflowID
- func (_m *ImmutableExecutionContext) OnGetLabels() *ImmutableExecutionContext_GetLabels
- func (_m *ImmutableExecutionContext) OnGetLabelsMatch(matchers ...interface{}) *ImmutableExecutionContext_GetLabels
- func (_m *ImmutableExecutionContext) OnGetName() *ImmutableExecutionContext_GetName
- func (_m *ImmutableExecutionContext) OnGetNameMatch(matchers ...interface{}) *ImmutableExecutionContext_GetName
- func (_m *ImmutableExecutionContext) OnGetNamespace() *ImmutableExecutionContext_GetNamespace
- func (_m *ImmutableExecutionContext) OnGetNamespaceMatch(matchers ...interface{}) *ImmutableExecutionContext_GetNamespace
- func (_m *ImmutableExecutionContext) OnGetOnFailurePolicy() *ImmutableExecutionContext_GetOnFailurePolicy
- func (_m *ImmutableExecutionContext) OnGetOnFailurePolicyMatch(matchers ...interface{}) *ImmutableExecutionContext_GetOnFailurePolicy
- func (_m *ImmutableExecutionContext) OnGetOwnerReference() *ImmutableExecutionContext_GetOwnerReference
- func (_m *ImmutableExecutionContext) OnGetOwnerReferenceMatch(matchers ...interface{}) *ImmutableExecutionContext_GetOwnerReference
- func (_m *ImmutableExecutionContext) OnGetRawOutputDataConfig() *ImmutableExecutionContext_GetRawOutputDataConfig
- func (_m *ImmutableExecutionContext) OnGetRawOutputDataConfigMatch(matchers ...interface{}) *ImmutableExecutionContext_GetRawOutputDataConfig
- func (_m *ImmutableExecutionContext) OnGetServiceAccountName() *ImmutableExecutionContext_GetServiceAccountName
- func (_m *ImmutableExecutionContext) OnGetServiceAccountNameMatch(matchers ...interface{}) *ImmutableExecutionContext_GetServiceAccountName
- func (_m *ImmutableExecutionContext) OnIsInterruptible() *ImmutableExecutionContext_IsInterruptible
- func (_m *ImmutableExecutionContext) OnIsInterruptibleMatch(matchers ...interface{}) *ImmutableExecutionContext_IsInterruptible
- type ImmutableExecutionContext_GetAnnotations
- type ImmutableExecutionContext_GetCreationTimestamp
- type ImmutableExecutionContext_GetEventVersion
- type ImmutableExecutionContext_GetExecutionID
- type ImmutableExecutionContext_GetID
- type ImmutableExecutionContext_GetK8sWorkflowID
- type ImmutableExecutionContext_GetLabels
- type ImmutableExecutionContext_GetName
- type ImmutableExecutionContext_GetNamespace
- type ImmutableExecutionContext_GetOnFailurePolicy
- type ImmutableExecutionContext_GetOwnerReference
- type ImmutableExecutionContext_GetRawOutputDataConfig
- type ImmutableExecutionContext_GetServiceAccountName
- type ImmutableExecutionContext_IsInterruptible
- type ImmutableParentInfo
- func (_m *ImmutableParentInfo) CurrentAttempt() uint32
- func (_m *ImmutableParentInfo) GetUniqueID() string
- func (_m *ImmutableParentInfo) OnCurrentAttempt() *ImmutableParentInfo_CurrentAttempt
- func (_m *ImmutableParentInfo) OnCurrentAttemptMatch(matchers ...interface{}) *ImmutableParentInfo_CurrentAttempt
- func (_m *ImmutableParentInfo) OnGetUniqueID() *ImmutableParentInfo_GetUniqueID
- func (_m *ImmutableParentInfo) OnGetUniqueIDMatch(matchers ...interface{}) *ImmutableParentInfo_GetUniqueID
- type ImmutableParentInfo_CurrentAttempt
- type ImmutableParentInfo_GetUniqueID
- type Node
- func (_m *Node) AbortHandler(ctx context.Context, execContext executors.ExecutionContext, ...) error
- func (_m *Node) FinalizeHandler(ctx context.Context, execContext executors.ExecutionContext, ...) error
- func (_m *Node) Initialize(ctx context.Context) error
- func (_m *Node) OnAbortHandler(ctx context.Context, execContext executors.ExecutionContext, ...) *Node_AbortHandler
- func (_m *Node) OnAbortHandlerMatch(matchers ...interface{}) *Node_AbortHandler
- func (_m *Node) OnFinalizeHandler(ctx context.Context, execContext executors.ExecutionContext, ...) *Node_FinalizeHandler
- func (_m *Node) OnFinalizeHandlerMatch(matchers ...interface{}) *Node_FinalizeHandler
- func (_m *Node) OnInitialize(ctx context.Context) *Node_Initialize
- func (_m *Node) OnInitializeMatch(matchers ...interface{}) *Node_Initialize
- func (_m *Node) OnRecursiveNodeHandler(ctx context.Context, execContext executors.ExecutionContext, ...) *Node_RecursiveNodeHandler
- func (_m *Node) OnRecursiveNodeHandlerMatch(matchers ...interface{}) *Node_RecursiveNodeHandler
- func (_m *Node) OnSetInputsForStartNode(ctx context.Context, execContext executors.ExecutionContext, ...) *Node_SetInputsForStartNode
- func (_m *Node) OnSetInputsForStartNodeMatch(matchers ...interface{}) *Node_SetInputsForStartNode
- func (_m *Node) RecursiveNodeHandler(ctx context.Context, execContext executors.ExecutionContext, ...) (executors.NodeStatus, error)
- func (_m *Node) SetInputsForStartNode(ctx context.Context, execContext executors.ExecutionContext, ...) (executors.NodeStatus, error)
- type NodeLookup
- func (_m *NodeLookup) GetNode(nodeID string) (v1alpha1.ExecutableNode, bool)
- func (_m *NodeLookup) GetNodeExecutionStatus(ctx context.Context, id string) v1alpha1.ExecutableNodeStatus
- func (_m *NodeLookup) OnGetNode(nodeID string) *NodeLookup_GetNode
- func (_m *NodeLookup) OnGetNodeExecutionStatus(ctx context.Context, id string) *NodeLookup_GetNodeExecutionStatus
- func (_m *NodeLookup) OnGetNodeExecutionStatusMatch(matchers ...interface{}) *NodeLookup_GetNodeExecutionStatus
- func (_m *NodeLookup) OnGetNodeMatch(matchers ...interface{}) *NodeLookup_GetNode
- type NodeLookup_GetNode
- type NodeLookup_GetNodeExecutionStatus
- type Node_AbortHandler
- type Node_FinalizeHandler
- type Node_Initialize
- type Node_RecursiveNodeHandler
- type Node_SetInputsForStartNode
- type ParentInfoGetter
- type ParentInfoGetter_GetParentInfo
- type SubWorkflowGetter
- type SubWorkflowGetter_FindSubWorkflow
- type TaskDetailsGetter
- type TaskDetailsGetter_GetTask
- type Workflow
- func (_m *Workflow) HandleAbortedWorkflow(ctx context.Context, w *v1alpha1.FlyteWorkflow, maxRetries uint32) error
- func (_m *Workflow) HandleFlyteWorkflow(ctx context.Context, w *v1alpha1.FlyteWorkflow) error
- func (_m *Workflow) Initialize(ctx context.Context) error
- func (_m *Workflow) OnHandleAbortedWorkflow(ctx context.Context, w *v1alpha1.FlyteWorkflow, maxRetries uint32) *Workflow_HandleAbortedWorkflow
- func (_m *Workflow) OnHandleAbortedWorkflowMatch(matchers ...interface{}) *Workflow_HandleAbortedWorkflow
- func (_m *Workflow) OnHandleFlyteWorkflow(ctx context.Context, w *v1alpha1.FlyteWorkflow) *Workflow_HandleFlyteWorkflow
- func (_m *Workflow) OnHandleFlyteWorkflowMatch(matchers ...interface{}) *Workflow_HandleFlyteWorkflow
- func (_m *Workflow) OnInitialize(ctx context.Context) *Workflow_Initialize
- func (_m *Workflow) OnInitializeMatch(matchers ...interface{}) *Workflow_Initialize
- type Workflow_HandleAbortedWorkflow
- type Workflow_HandleFlyteWorkflow
- type Workflow_Initialize
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
Client is an autogenerated mock type for the Client type
func NewFakeKubeClient ¶
func NewFakeKubeClient() *Client
func (*Client) OnGetCache ¶ added in v0.1.13
func (_m *Client) OnGetCache() *Client_GetCache
func (*Client) OnGetCacheMatch ¶ added in v0.1.13
func (_m *Client) OnGetCacheMatch(matchers ...interface{}) *Client_GetCache
func (*Client) OnGetClient ¶ added in v0.1.13
func (_m *Client) OnGetClient() *Client_GetClient
func (*Client) OnGetClientMatch ¶ added in v0.1.13
func (_m *Client) OnGetClientMatch(matchers ...interface{}) *Client_GetClient
type Client_GetCache ¶ added in v0.1.13
func (Client_GetCache) Return ¶ added in v0.1.13
func (_m Client_GetCache) Return(_a0 cache.Cache) *Client_GetCache
type Client_GetClient ¶ added in v0.1.13
func (Client_GetClient) Return ¶ added in v0.1.13
func (_m Client_GetClient) Return(_a0 client.Client) *Client_GetClient
type DAGStructure ¶ added in v0.2.28
DAGStructure is an autogenerated mock type for the DAGStructure type
func (*DAGStructure) FromNode ¶ added in v0.2.28
func (_m *DAGStructure) FromNode(id string) ([]string, error)
FromNode provides a mock function with given fields: id
func (*DAGStructure) OnFromNode ¶ added in v0.2.28
func (_m *DAGStructure) OnFromNode(id string) *DAGStructure_FromNode
func (*DAGStructure) OnFromNodeMatch ¶ added in v0.2.28
func (_m *DAGStructure) OnFromNodeMatch(matchers ...interface{}) *DAGStructure_FromNode
func (*DAGStructure) OnToNode ¶ added in v0.2.28
func (_m *DAGStructure) OnToNode(id string) *DAGStructure_ToNode
func (*DAGStructure) OnToNodeMatch ¶ added in v0.2.28
func (_m *DAGStructure) OnToNodeMatch(matchers ...interface{}) *DAGStructure_ToNode
type DAGStructureWithStartNode ¶ added in v0.2.28
DAGStructureWithStartNode is an autogenerated mock type for the DAGStructureWithStartNode type
func (*DAGStructureWithStartNode) FromNode ¶ added in v0.2.28
func (_m *DAGStructureWithStartNode) FromNode(id string) ([]string, error)
FromNode provides a mock function with given fields: id
func (*DAGStructureWithStartNode) OnFromNode ¶ added in v0.2.28
func (_m *DAGStructureWithStartNode) OnFromNode(id string) *DAGStructureWithStartNode_FromNode
func (*DAGStructureWithStartNode) OnFromNodeMatch ¶ added in v0.2.28
func (_m *DAGStructureWithStartNode) OnFromNodeMatch(matchers ...interface{}) *DAGStructureWithStartNode_FromNode
func (*DAGStructureWithStartNode) OnStartNode ¶ added in v0.2.28
func (_m *DAGStructureWithStartNode) OnStartNode() *DAGStructureWithStartNode_StartNode
func (*DAGStructureWithStartNode) OnStartNodeMatch ¶ added in v0.2.28
func (_m *DAGStructureWithStartNode) OnStartNodeMatch(matchers ...interface{}) *DAGStructureWithStartNode_StartNode
func (*DAGStructureWithStartNode) OnToNode ¶ added in v0.2.28
func (_m *DAGStructureWithStartNode) OnToNode(id string) *DAGStructureWithStartNode_ToNode
func (*DAGStructureWithStartNode) OnToNodeMatch ¶ added in v0.2.28
func (_m *DAGStructureWithStartNode) OnToNodeMatch(matchers ...interface{}) *DAGStructureWithStartNode_ToNode
func (*DAGStructureWithStartNode) StartNode ¶ added in v0.2.28
func (_m *DAGStructureWithStartNode) StartNode() v1alpha1.ExecutableNode
StartNode provides a mock function with given fields:
type DAGStructureWithStartNode_FromNode ¶ added in v0.2.28
func (DAGStructureWithStartNode_FromNode) Return ¶ added in v0.2.28
func (_m DAGStructureWithStartNode_FromNode) Return(_a0 []string, _a1 error) *DAGStructureWithStartNode_FromNode
type DAGStructureWithStartNode_StartNode ¶ added in v0.2.28
func (DAGStructureWithStartNode_StartNode) Return ¶ added in v0.2.28
func (_m DAGStructureWithStartNode_StartNode) Return(_a0 v1alpha1.ExecutableNode) *DAGStructureWithStartNode_StartNode
type DAGStructureWithStartNode_ToNode ¶ added in v0.2.28
func (DAGStructureWithStartNode_ToNode) Return ¶ added in v0.2.28
func (_m DAGStructureWithStartNode_ToNode) Return(_a0 []string, _a1 error) *DAGStructureWithStartNode_ToNode
type DAGStructure_FromNode ¶ added in v0.2.28
func (DAGStructure_FromNode) Return ¶ added in v0.2.28
func (_m DAGStructure_FromNode) Return(_a0 []string, _a1 error) *DAGStructure_FromNode
type DAGStructure_ToNode ¶ added in v0.2.28
func (DAGStructure_ToNode) Return ¶ added in v0.2.28
func (_m DAGStructure_ToNode) Return(_a0 []string, _a1 error) *DAGStructure_ToNode
type ExecutionContext ¶ added in v0.2.28
ExecutionContext is an autogenerated mock type for the ExecutionContext type
func (*ExecutionContext) FindSubWorkflow ¶ added in v0.2.28
func (_m *ExecutionContext) FindSubWorkflow(subID string) v1alpha1.ExecutableSubWorkflow
FindSubWorkflow provides a mock function with given fields: subID
func (*ExecutionContext) GetAnnotations ¶ added in v0.2.28
func (_m *ExecutionContext) GetAnnotations() map[string]string
GetAnnotations provides a mock function with given fields:
func (*ExecutionContext) GetCreationTimestamp ¶ added in v0.2.28
func (_m *ExecutionContext) GetCreationTimestamp() v1.Time
GetCreationTimestamp provides a mock function with given fields:
func (*ExecutionContext) GetEventVersion ¶ added in v0.3.8
func (_m *ExecutionContext) GetEventVersion() v1alpha1.EventVersion
GetEventVersion provides a mock function with given fields:
func (*ExecutionContext) GetExecutionID ¶ added in v0.2.28
func (_m *ExecutionContext) GetExecutionID() v1alpha1.WorkflowExecutionIdentifier
GetExecutionID provides a mock function with given fields:
func (*ExecutionContext) GetID ¶ added in v0.2.28
func (_m *ExecutionContext) GetID() string
GetID provides a mock function with given fields:
func (*ExecutionContext) GetK8sWorkflowID ¶ added in v0.2.28
func (_m *ExecutionContext) GetK8sWorkflowID() types.NamespacedName
GetK8sWorkflowID provides a mock function with given fields:
func (*ExecutionContext) GetLabels ¶ added in v0.2.28
func (_m *ExecutionContext) GetLabels() map[string]string
GetLabels provides a mock function with given fields:
func (*ExecutionContext) GetName ¶ added in v0.2.28
func (_m *ExecutionContext) GetName() string
GetName provides a mock function with given fields:
func (*ExecutionContext) GetNamespace ¶ added in v0.2.28
func (_m *ExecutionContext) GetNamespace() string
GetNamespace provides a mock function with given fields:
func (*ExecutionContext) GetOnFailurePolicy ¶ added in v0.2.62
func (_m *ExecutionContext) GetOnFailurePolicy() v1alpha1.WorkflowOnFailurePolicy
GetOnFailurePolicy provides a mock function with given fields:
func (*ExecutionContext) GetOwnerReference ¶ added in v0.2.28
func (_m *ExecutionContext) GetOwnerReference() v1.OwnerReference
GetOwnerReference provides a mock function with given fields:
func (*ExecutionContext) GetParentInfo ¶ added in v0.3.8
func (_m *ExecutionContext) GetParentInfo() executors.ImmutableParentInfo
GetParentInfo provides a mock function with given fields:
func (*ExecutionContext) GetRawOutputDataConfig ¶ added in v0.3.7
func (_m *ExecutionContext) GetRawOutputDataConfig() v1alpha1.RawOutputDataConfig
GetRawOutputDataConfig provides a mock function with given fields:
func (*ExecutionContext) GetServiceAccountName ¶ added in v0.2.28
func (_m *ExecutionContext) GetServiceAccountName() string
GetServiceAccountName provides a mock function with given fields:
func (*ExecutionContext) GetTask ¶ added in v0.2.28
func (_m *ExecutionContext) GetTask(id string) (v1alpha1.ExecutableTask, error)
GetTask provides a mock function with given fields: id
func (*ExecutionContext) IsInterruptible ¶ added in v0.2.28
func (_m *ExecutionContext) IsInterruptible() bool
IsInterruptible provides a mock function with given fields:
func (*ExecutionContext) OnFindSubWorkflow ¶ added in v0.2.28
func (_m *ExecutionContext) OnFindSubWorkflow(subID string) *ExecutionContext_FindSubWorkflow
func (*ExecutionContext) OnFindSubWorkflowMatch ¶ added in v0.2.28
func (_m *ExecutionContext) OnFindSubWorkflowMatch(matchers ...interface{}) *ExecutionContext_FindSubWorkflow
func (*ExecutionContext) OnGetAnnotations ¶ added in v0.2.28
func (_m *ExecutionContext) OnGetAnnotations() *ExecutionContext_GetAnnotations
func (*ExecutionContext) OnGetAnnotationsMatch ¶ added in v0.2.28
func (_m *ExecutionContext) OnGetAnnotationsMatch(matchers ...interface{}) *ExecutionContext_GetAnnotations
func (*ExecutionContext) OnGetCreationTimestamp ¶ added in v0.2.28
func (_m *ExecutionContext) OnGetCreationTimestamp() *ExecutionContext_GetCreationTimestamp
func (*ExecutionContext) OnGetCreationTimestampMatch ¶ added in v0.2.28
func (_m *ExecutionContext) OnGetCreationTimestampMatch(matchers ...interface{}) *ExecutionContext_GetCreationTimestamp
func (*ExecutionContext) OnGetEventVersion ¶ added in v0.3.8
func (_m *ExecutionContext) OnGetEventVersion() *ExecutionContext_GetEventVersion
func (*ExecutionContext) OnGetEventVersionMatch ¶ added in v0.3.8
func (_m *ExecutionContext) OnGetEventVersionMatch(matchers ...interface{}) *ExecutionContext_GetEventVersion
func (*ExecutionContext) OnGetExecutionID ¶ added in v0.2.28
func (_m *ExecutionContext) OnGetExecutionID() *ExecutionContext_GetExecutionID
func (*ExecutionContext) OnGetExecutionIDMatch ¶ added in v0.2.28
func (_m *ExecutionContext) OnGetExecutionIDMatch(matchers ...interface{}) *ExecutionContext_GetExecutionID
func (*ExecutionContext) OnGetID ¶ added in v0.2.28
func (_m *ExecutionContext) OnGetID() *ExecutionContext_GetID
func (*ExecutionContext) OnGetIDMatch ¶ added in v0.2.28
func (_m *ExecutionContext) OnGetIDMatch(matchers ...interface{}) *ExecutionContext_GetID
func (*ExecutionContext) OnGetK8sWorkflowID ¶ added in v0.2.28
func (_m *ExecutionContext) OnGetK8sWorkflowID() *ExecutionContext_GetK8sWorkflowID
func (*ExecutionContext) OnGetK8sWorkflowIDMatch ¶ added in v0.2.28
func (_m *ExecutionContext) OnGetK8sWorkflowIDMatch(matchers ...interface{}) *ExecutionContext_GetK8sWorkflowID
func (*ExecutionContext) OnGetLabels ¶ added in v0.2.28
func (_m *ExecutionContext) OnGetLabels() *ExecutionContext_GetLabels
func (*ExecutionContext) OnGetLabelsMatch ¶ added in v0.2.28
func (_m *ExecutionContext) OnGetLabelsMatch(matchers ...interface{}) *ExecutionContext_GetLabels
func (*ExecutionContext) OnGetName ¶ added in v0.2.28
func (_m *ExecutionContext) OnGetName() *ExecutionContext_GetName
func (*ExecutionContext) OnGetNameMatch ¶ added in v0.2.28
func (_m *ExecutionContext) OnGetNameMatch(matchers ...interface{}) *ExecutionContext_GetName
func (*ExecutionContext) OnGetNamespace ¶ added in v0.2.28
func (_m *ExecutionContext) OnGetNamespace() *ExecutionContext_GetNamespace
func (*ExecutionContext) OnGetNamespaceMatch ¶ added in v0.2.28
func (_m *ExecutionContext) OnGetNamespaceMatch(matchers ...interface{}) *ExecutionContext_GetNamespace
func (*ExecutionContext) OnGetOnFailurePolicy ¶ added in v0.2.62
func (_m *ExecutionContext) OnGetOnFailurePolicy() *ExecutionContext_GetOnFailurePolicy
func (*ExecutionContext) OnGetOnFailurePolicyMatch ¶ added in v0.2.62
func (_m *ExecutionContext) OnGetOnFailurePolicyMatch(matchers ...interface{}) *ExecutionContext_GetOnFailurePolicy
func (*ExecutionContext) OnGetOwnerReference ¶ added in v0.2.28
func (_m *ExecutionContext) OnGetOwnerReference() *ExecutionContext_GetOwnerReference
func (*ExecutionContext) OnGetOwnerReferenceMatch ¶ added in v0.2.28
func (_m *ExecutionContext) OnGetOwnerReferenceMatch(matchers ...interface{}) *ExecutionContext_GetOwnerReference
func (*ExecutionContext) OnGetParentInfo ¶ added in v0.3.8
func (_m *ExecutionContext) OnGetParentInfo() *ExecutionContext_GetParentInfo
func (*ExecutionContext) OnGetParentInfoMatch ¶ added in v0.3.8
func (_m *ExecutionContext) OnGetParentInfoMatch(matchers ...interface{}) *ExecutionContext_GetParentInfo
func (*ExecutionContext) OnGetRawOutputDataConfig ¶ added in v0.3.7
func (_m *ExecutionContext) OnGetRawOutputDataConfig() *ExecutionContext_GetRawOutputDataConfig
func (*ExecutionContext) OnGetRawOutputDataConfigMatch ¶ added in v0.3.7
func (_m *ExecutionContext) OnGetRawOutputDataConfigMatch(matchers ...interface{}) *ExecutionContext_GetRawOutputDataConfig
func (*ExecutionContext) OnGetServiceAccountName ¶ added in v0.2.28
func (_m *ExecutionContext) OnGetServiceAccountName() *ExecutionContext_GetServiceAccountName
func (*ExecutionContext) OnGetServiceAccountNameMatch ¶ added in v0.2.28
func (_m *ExecutionContext) OnGetServiceAccountNameMatch(matchers ...interface{}) *ExecutionContext_GetServiceAccountName
func (*ExecutionContext) OnGetTask ¶ added in v0.2.28
func (_m *ExecutionContext) OnGetTask(id string) *ExecutionContext_GetTask
func (*ExecutionContext) OnGetTaskMatch ¶ added in v0.2.28
func (_m *ExecutionContext) OnGetTaskMatch(matchers ...interface{}) *ExecutionContext_GetTask
func (*ExecutionContext) OnIsInterruptible ¶ added in v0.2.28
func (_m *ExecutionContext) OnIsInterruptible() *ExecutionContext_IsInterruptible
func (*ExecutionContext) OnIsInterruptibleMatch ¶ added in v0.2.28
func (_m *ExecutionContext) OnIsInterruptibleMatch(matchers ...interface{}) *ExecutionContext_IsInterruptible
type ExecutionContext_FindSubWorkflow ¶ added in v0.2.28
func (ExecutionContext_FindSubWorkflow) Return ¶ added in v0.2.28
func (_m ExecutionContext_FindSubWorkflow) Return(_a0 v1alpha1.ExecutableSubWorkflow) *ExecutionContext_FindSubWorkflow
type ExecutionContext_GetAnnotations ¶ added in v0.2.28
func (ExecutionContext_GetAnnotations) Return ¶ added in v0.2.28
func (_m ExecutionContext_GetAnnotations) Return(_a0 map[string]string) *ExecutionContext_GetAnnotations
type ExecutionContext_GetCreationTimestamp ¶ added in v0.2.28
func (ExecutionContext_GetCreationTimestamp) Return ¶ added in v0.2.28
func (_m ExecutionContext_GetCreationTimestamp) Return(_a0 v1.Time) *ExecutionContext_GetCreationTimestamp
type ExecutionContext_GetEventVersion ¶ added in v0.3.8
func (ExecutionContext_GetEventVersion) Return ¶ added in v0.3.8
func (_m ExecutionContext_GetEventVersion) Return(_a0 v1alpha1.EventVersion) *ExecutionContext_GetEventVersion
type ExecutionContext_GetExecutionID ¶ added in v0.2.28
func (ExecutionContext_GetExecutionID) Return ¶ added in v0.2.28
func (_m ExecutionContext_GetExecutionID) Return(_a0 v1alpha1.WorkflowExecutionIdentifier) *ExecutionContext_GetExecutionID
type ExecutionContext_GetID ¶ added in v0.2.28
func (ExecutionContext_GetID) Return ¶ added in v0.2.28
func (_m ExecutionContext_GetID) Return(_a0 string) *ExecutionContext_GetID
type ExecutionContext_GetK8sWorkflowID ¶ added in v0.2.28
func (ExecutionContext_GetK8sWorkflowID) Return ¶ added in v0.2.28
func (_m ExecutionContext_GetK8sWorkflowID) Return(_a0 types.NamespacedName) *ExecutionContext_GetK8sWorkflowID
type ExecutionContext_GetLabels ¶ added in v0.2.28
func (ExecutionContext_GetLabels) Return ¶ added in v0.2.28
func (_m ExecutionContext_GetLabels) Return(_a0 map[string]string) *ExecutionContext_GetLabels
type ExecutionContext_GetName ¶ added in v0.2.28
func (ExecutionContext_GetName) Return ¶ added in v0.2.28
func (_m ExecutionContext_GetName) Return(_a0 string) *ExecutionContext_GetName
type ExecutionContext_GetNamespace ¶ added in v0.2.28
func (ExecutionContext_GetNamespace) Return ¶ added in v0.2.28
func (_m ExecutionContext_GetNamespace) Return(_a0 string) *ExecutionContext_GetNamespace
type ExecutionContext_GetOnFailurePolicy ¶ added in v0.2.62
func (ExecutionContext_GetOnFailurePolicy) Return ¶ added in v0.2.62
func (_m ExecutionContext_GetOnFailurePolicy) Return(_a0 v1alpha1.WorkflowOnFailurePolicy) *ExecutionContext_GetOnFailurePolicy
type ExecutionContext_GetOwnerReference ¶ added in v0.2.28
func (ExecutionContext_GetOwnerReference) Return ¶ added in v0.2.28
func (_m ExecutionContext_GetOwnerReference) Return(_a0 v1.OwnerReference) *ExecutionContext_GetOwnerReference
type ExecutionContext_GetParentInfo ¶ added in v0.3.8
func (ExecutionContext_GetParentInfo) Return ¶ added in v0.3.8
func (_m ExecutionContext_GetParentInfo) Return(_a0 executors.ImmutableParentInfo) *ExecutionContext_GetParentInfo
type ExecutionContext_GetRawOutputDataConfig ¶ added in v0.3.7
type ExecutionContext_GetServiceAccountName ¶ added in v0.2.28
func (ExecutionContext_GetServiceAccountName) Return ¶ added in v0.2.28
func (_m ExecutionContext_GetServiceAccountName) Return(_a0 string) *ExecutionContext_GetServiceAccountName
type ExecutionContext_GetTask ¶ added in v0.2.28
func (ExecutionContext_GetTask) Return ¶ added in v0.2.28
func (_m ExecutionContext_GetTask) Return(_a0 v1alpha1.ExecutableTask, _a1 error) *ExecutionContext_GetTask
type ExecutionContext_IsInterruptible ¶ added in v0.2.28
func (ExecutionContext_IsInterruptible) Return ¶ added in v0.2.28
func (_m ExecutionContext_IsInterruptible) Return(_a0 bool) *ExecutionContext_IsInterruptible
type ImmutableExecutionContext ¶ added in v0.2.28
ImmutableExecutionContext is an autogenerated mock type for the ImmutableExecutionContext type
func (*ImmutableExecutionContext) GetAnnotations ¶ added in v0.2.28
func (_m *ImmutableExecutionContext) GetAnnotations() map[string]string
GetAnnotations provides a mock function with given fields:
func (*ImmutableExecutionContext) GetCreationTimestamp ¶ added in v0.2.28
func (_m *ImmutableExecutionContext) GetCreationTimestamp() v1.Time
GetCreationTimestamp provides a mock function with given fields:
func (*ImmutableExecutionContext) GetEventVersion ¶ added in v0.3.8
func (_m *ImmutableExecutionContext) GetEventVersion() v1alpha1.EventVersion
GetEventVersion provides a mock function with given fields:
func (*ImmutableExecutionContext) GetExecutionID ¶ added in v0.2.28
func (_m *ImmutableExecutionContext) GetExecutionID() v1alpha1.WorkflowExecutionIdentifier
GetExecutionID provides a mock function with given fields:
func (*ImmutableExecutionContext) GetID ¶ added in v0.2.28
func (_m *ImmutableExecutionContext) GetID() string
GetID provides a mock function with given fields:
func (*ImmutableExecutionContext) GetK8sWorkflowID ¶ added in v0.2.28
func (_m *ImmutableExecutionContext) GetK8sWorkflowID() types.NamespacedName
GetK8sWorkflowID provides a mock function with given fields:
func (*ImmutableExecutionContext) GetLabels ¶ added in v0.2.28
func (_m *ImmutableExecutionContext) GetLabels() map[string]string
GetLabels provides a mock function with given fields:
func (*ImmutableExecutionContext) GetName ¶ added in v0.2.28
func (_m *ImmutableExecutionContext) GetName() string
GetName provides a mock function with given fields:
func (*ImmutableExecutionContext) GetNamespace ¶ added in v0.2.28
func (_m *ImmutableExecutionContext) GetNamespace() string
GetNamespace provides a mock function with given fields:
func (*ImmutableExecutionContext) GetOnFailurePolicy ¶ added in v0.2.62
func (_m *ImmutableExecutionContext) GetOnFailurePolicy() v1alpha1.WorkflowOnFailurePolicy
GetOnFailurePolicy provides a mock function with given fields:
func (*ImmutableExecutionContext) GetOwnerReference ¶ added in v0.2.28
func (_m *ImmutableExecutionContext) GetOwnerReference() v1.OwnerReference
GetOwnerReference provides a mock function with given fields:
func (*ImmutableExecutionContext) GetRawOutputDataConfig ¶ added in v0.3.7
func (_m *ImmutableExecutionContext) GetRawOutputDataConfig() v1alpha1.RawOutputDataConfig
GetRawOutputDataConfig provides a mock function with given fields:
func (*ImmutableExecutionContext) GetServiceAccountName ¶ added in v0.2.28
func (_m *ImmutableExecutionContext) GetServiceAccountName() string
GetServiceAccountName provides a mock function with given fields:
func (*ImmutableExecutionContext) IsInterruptible ¶ added in v0.2.28
func (_m *ImmutableExecutionContext) IsInterruptible() bool
IsInterruptible provides a mock function with given fields:
func (*ImmutableExecutionContext) OnGetAnnotations ¶ added in v0.2.28
func (_m *ImmutableExecutionContext) OnGetAnnotations() *ImmutableExecutionContext_GetAnnotations
func (*ImmutableExecutionContext) OnGetAnnotationsMatch ¶ added in v0.2.28
func (_m *ImmutableExecutionContext) OnGetAnnotationsMatch(matchers ...interface{}) *ImmutableExecutionContext_GetAnnotations
func (*ImmutableExecutionContext) OnGetCreationTimestamp ¶ added in v0.2.28
func (_m *ImmutableExecutionContext) OnGetCreationTimestamp() *ImmutableExecutionContext_GetCreationTimestamp
func (*ImmutableExecutionContext) OnGetCreationTimestampMatch ¶ added in v0.2.28
func (_m *ImmutableExecutionContext) OnGetCreationTimestampMatch(matchers ...interface{}) *ImmutableExecutionContext_GetCreationTimestamp
func (*ImmutableExecutionContext) OnGetEventVersion ¶ added in v0.3.8
func (_m *ImmutableExecutionContext) OnGetEventVersion() *ImmutableExecutionContext_GetEventVersion
func (*ImmutableExecutionContext) OnGetEventVersionMatch ¶ added in v0.3.8
func (_m *ImmutableExecutionContext) OnGetEventVersionMatch(matchers ...interface{}) *ImmutableExecutionContext_GetEventVersion
func (*ImmutableExecutionContext) OnGetExecutionID ¶ added in v0.2.28
func (_m *ImmutableExecutionContext) OnGetExecutionID() *ImmutableExecutionContext_GetExecutionID
func (*ImmutableExecutionContext) OnGetExecutionIDMatch ¶ added in v0.2.28
func (_m *ImmutableExecutionContext) OnGetExecutionIDMatch(matchers ...interface{}) *ImmutableExecutionContext_GetExecutionID
func (*ImmutableExecutionContext) OnGetID ¶ added in v0.2.28
func (_m *ImmutableExecutionContext) OnGetID() *ImmutableExecutionContext_GetID
func (*ImmutableExecutionContext) OnGetIDMatch ¶ added in v0.2.28
func (_m *ImmutableExecutionContext) OnGetIDMatch(matchers ...interface{}) *ImmutableExecutionContext_GetID
func (*ImmutableExecutionContext) OnGetK8sWorkflowID ¶ added in v0.2.28
func (_m *ImmutableExecutionContext) OnGetK8sWorkflowID() *ImmutableExecutionContext_GetK8sWorkflowID
func (*ImmutableExecutionContext) OnGetK8sWorkflowIDMatch ¶ added in v0.2.28
func (_m *ImmutableExecutionContext) OnGetK8sWorkflowIDMatch(matchers ...interface{}) *ImmutableExecutionContext_GetK8sWorkflowID
func (*ImmutableExecutionContext) OnGetLabels ¶ added in v0.2.28
func (_m *ImmutableExecutionContext) OnGetLabels() *ImmutableExecutionContext_GetLabels
func (*ImmutableExecutionContext) OnGetLabelsMatch ¶ added in v0.2.28
func (_m *ImmutableExecutionContext) OnGetLabelsMatch(matchers ...interface{}) *ImmutableExecutionContext_GetLabels
func (*ImmutableExecutionContext) OnGetName ¶ added in v0.2.28
func (_m *ImmutableExecutionContext) OnGetName() *ImmutableExecutionContext_GetName
func (*ImmutableExecutionContext) OnGetNameMatch ¶ added in v0.2.28
func (_m *ImmutableExecutionContext) OnGetNameMatch(matchers ...interface{}) *ImmutableExecutionContext_GetName
func (*ImmutableExecutionContext) OnGetNamespace ¶ added in v0.2.28
func (_m *ImmutableExecutionContext) OnGetNamespace() *ImmutableExecutionContext_GetNamespace
func (*ImmutableExecutionContext) OnGetNamespaceMatch ¶ added in v0.2.28
func (_m *ImmutableExecutionContext) OnGetNamespaceMatch(matchers ...interface{}) *ImmutableExecutionContext_GetNamespace
func (*ImmutableExecutionContext) OnGetOnFailurePolicy ¶ added in v0.2.62
func (_m *ImmutableExecutionContext) OnGetOnFailurePolicy() *ImmutableExecutionContext_GetOnFailurePolicy
func (*ImmutableExecutionContext) OnGetOnFailurePolicyMatch ¶ added in v0.2.62
func (_m *ImmutableExecutionContext) OnGetOnFailurePolicyMatch(matchers ...interface{}) *ImmutableExecutionContext_GetOnFailurePolicy
func (*ImmutableExecutionContext) OnGetOwnerReference ¶ added in v0.2.28
func (_m *ImmutableExecutionContext) OnGetOwnerReference() *ImmutableExecutionContext_GetOwnerReference
func (*ImmutableExecutionContext) OnGetOwnerReferenceMatch ¶ added in v0.2.28
func (_m *ImmutableExecutionContext) OnGetOwnerReferenceMatch(matchers ...interface{}) *ImmutableExecutionContext_GetOwnerReference
func (*ImmutableExecutionContext) OnGetRawOutputDataConfig ¶ added in v0.3.7
func (_m *ImmutableExecutionContext) OnGetRawOutputDataConfig() *ImmutableExecutionContext_GetRawOutputDataConfig
func (*ImmutableExecutionContext) OnGetRawOutputDataConfigMatch ¶ added in v0.3.7
func (_m *ImmutableExecutionContext) OnGetRawOutputDataConfigMatch(matchers ...interface{}) *ImmutableExecutionContext_GetRawOutputDataConfig
func (*ImmutableExecutionContext) OnGetServiceAccountName ¶ added in v0.2.28
func (_m *ImmutableExecutionContext) OnGetServiceAccountName() *ImmutableExecutionContext_GetServiceAccountName
func (*ImmutableExecutionContext) OnGetServiceAccountNameMatch ¶ added in v0.2.28
func (_m *ImmutableExecutionContext) OnGetServiceAccountNameMatch(matchers ...interface{}) *ImmutableExecutionContext_GetServiceAccountName
func (*ImmutableExecutionContext) OnIsInterruptible ¶ added in v0.2.28
func (_m *ImmutableExecutionContext) OnIsInterruptible() *ImmutableExecutionContext_IsInterruptible
func (*ImmutableExecutionContext) OnIsInterruptibleMatch ¶ added in v0.2.28
func (_m *ImmutableExecutionContext) OnIsInterruptibleMatch(matchers ...interface{}) *ImmutableExecutionContext_IsInterruptible
type ImmutableExecutionContext_GetAnnotations ¶ added in v0.2.28
func (ImmutableExecutionContext_GetAnnotations) Return ¶ added in v0.2.28
func (_m ImmutableExecutionContext_GetAnnotations) Return(_a0 map[string]string) *ImmutableExecutionContext_GetAnnotations
type ImmutableExecutionContext_GetCreationTimestamp ¶ added in v0.2.28
func (ImmutableExecutionContext_GetCreationTimestamp) Return ¶ added in v0.2.28
func (_m ImmutableExecutionContext_GetCreationTimestamp) Return(_a0 v1.Time) *ImmutableExecutionContext_GetCreationTimestamp
type ImmutableExecutionContext_GetEventVersion ¶ added in v0.3.8
func (ImmutableExecutionContext_GetEventVersion) Return ¶ added in v0.3.8
func (_m ImmutableExecutionContext_GetEventVersion) Return(_a0 v1alpha1.EventVersion) *ImmutableExecutionContext_GetEventVersion
type ImmutableExecutionContext_GetExecutionID ¶ added in v0.2.28
type ImmutableExecutionContext_GetID ¶ added in v0.2.28
func (ImmutableExecutionContext_GetID) Return ¶ added in v0.2.28
func (_m ImmutableExecutionContext_GetID) Return(_a0 string) *ImmutableExecutionContext_GetID
type ImmutableExecutionContext_GetK8sWorkflowID ¶ added in v0.2.28
func (ImmutableExecutionContext_GetK8sWorkflowID) Return ¶ added in v0.2.28
func (_m ImmutableExecutionContext_GetK8sWorkflowID) Return(_a0 types.NamespacedName) *ImmutableExecutionContext_GetK8sWorkflowID
type ImmutableExecutionContext_GetLabels ¶ added in v0.2.28
func (ImmutableExecutionContext_GetLabels) Return ¶ added in v0.2.28
func (_m ImmutableExecutionContext_GetLabels) Return(_a0 map[string]string) *ImmutableExecutionContext_GetLabels
type ImmutableExecutionContext_GetName ¶ added in v0.2.28
func (ImmutableExecutionContext_GetName) Return ¶ added in v0.2.28
func (_m ImmutableExecutionContext_GetName) Return(_a0 string) *ImmutableExecutionContext_GetName
type ImmutableExecutionContext_GetNamespace ¶ added in v0.2.28
func (ImmutableExecutionContext_GetNamespace) Return ¶ added in v0.2.28
func (_m ImmutableExecutionContext_GetNamespace) Return(_a0 string) *ImmutableExecutionContext_GetNamespace
type ImmutableExecutionContext_GetOnFailurePolicy ¶ added in v0.2.62
type ImmutableExecutionContext_GetOwnerReference ¶ added in v0.2.28
func (ImmutableExecutionContext_GetOwnerReference) Return ¶ added in v0.2.28
func (_m ImmutableExecutionContext_GetOwnerReference) Return(_a0 v1.OwnerReference) *ImmutableExecutionContext_GetOwnerReference
type ImmutableExecutionContext_GetRawOutputDataConfig ¶ added in v0.3.7
type ImmutableExecutionContext_GetServiceAccountName ¶ added in v0.2.28
func (ImmutableExecutionContext_GetServiceAccountName) Return ¶ added in v0.2.28
func (_m ImmutableExecutionContext_GetServiceAccountName) Return(_a0 string) *ImmutableExecutionContext_GetServiceAccountName
type ImmutableExecutionContext_IsInterruptible ¶ added in v0.2.28
func (ImmutableExecutionContext_IsInterruptible) Return ¶ added in v0.2.28
func (_m ImmutableExecutionContext_IsInterruptible) Return(_a0 bool) *ImmutableExecutionContext_IsInterruptible
type ImmutableParentInfo ¶ added in v0.3.8
ImmutableParentInfo is an autogenerated mock type for the ImmutableParentInfo type
func (*ImmutableParentInfo) CurrentAttempt ¶ added in v0.3.8
func (_m *ImmutableParentInfo) CurrentAttempt() uint32
CurrentAttempt provides a mock function with given fields:
func (*ImmutableParentInfo) GetUniqueID ¶ added in v0.3.8
func (_m *ImmutableParentInfo) GetUniqueID() string
GetUniqueID provides a mock function with given fields:
func (*ImmutableParentInfo) OnCurrentAttempt ¶ added in v0.3.8
func (_m *ImmutableParentInfo) OnCurrentAttempt() *ImmutableParentInfo_CurrentAttempt
func (*ImmutableParentInfo) OnCurrentAttemptMatch ¶ added in v0.3.8
func (_m *ImmutableParentInfo) OnCurrentAttemptMatch(matchers ...interface{}) *ImmutableParentInfo_CurrentAttempt
func (*ImmutableParentInfo) OnGetUniqueID ¶ added in v0.3.8
func (_m *ImmutableParentInfo) OnGetUniqueID() *ImmutableParentInfo_GetUniqueID
func (*ImmutableParentInfo) OnGetUniqueIDMatch ¶ added in v0.3.8
func (_m *ImmutableParentInfo) OnGetUniqueIDMatch(matchers ...interface{}) *ImmutableParentInfo_GetUniqueID
type ImmutableParentInfo_CurrentAttempt ¶ added in v0.3.8
func (ImmutableParentInfo_CurrentAttempt) Return ¶ added in v0.3.8
func (_m ImmutableParentInfo_CurrentAttempt) Return(_a0 uint32) *ImmutableParentInfo_CurrentAttempt
type ImmutableParentInfo_GetUniqueID ¶ added in v0.3.8
func (ImmutableParentInfo_GetUniqueID) Return ¶ added in v0.3.8
func (_m ImmutableParentInfo_GetUniqueID) Return(_a0 string) *ImmutableParentInfo_GetUniqueID
type Node ¶ added in v0.1.13
Node is an autogenerated mock type for the Node type
func (*Node) AbortHandler ¶ added in v0.1.13
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 ¶ added in v0.1.15
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) Initialize ¶ added in v0.1.13
Initialize provides a mock function with given fields: ctx
func (*Node) OnAbortHandler ¶ added in v0.1.13
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 ¶ added in v0.1.13
func (_m *Node) OnAbortHandlerMatch(matchers ...interface{}) *Node_AbortHandler
func (*Node) OnFinalizeHandler ¶ added in v0.1.15
func (_m *Node) OnFinalizeHandler(ctx context.Context, execContext executors.ExecutionContext, dag executors.DAGStructure, nl executors.NodeLookup, currentNode v1alpha1.ExecutableNode) *Node_FinalizeHandler
func (*Node) OnFinalizeHandlerMatch ¶ added in v0.1.15
func (_m *Node) OnFinalizeHandlerMatch(matchers ...interface{}) *Node_FinalizeHandler
func (*Node) OnInitialize ¶ added in v0.1.13
func (_m *Node) OnInitialize(ctx context.Context) *Node_Initialize
func (*Node) OnInitializeMatch ¶ added in v0.1.13
func (_m *Node) OnInitializeMatch(matchers ...interface{}) *Node_Initialize
func (*Node) OnRecursiveNodeHandler ¶ added in v0.1.13
func (_m *Node) OnRecursiveNodeHandler(ctx context.Context, execContext executors.ExecutionContext, dag executors.DAGStructure, nl executors.NodeLookup, currentNode v1alpha1.ExecutableNode) *Node_RecursiveNodeHandler
func (*Node) OnRecursiveNodeHandlerMatch ¶ added in v0.1.13
func (_m *Node) OnRecursiveNodeHandlerMatch(matchers ...interface{}) *Node_RecursiveNodeHandler
func (*Node) OnSetInputsForStartNode ¶ added in v0.1.13
func (_m *Node) OnSetInputsForStartNode(ctx context.Context, execContext executors.ExecutionContext, dag executors.DAGStructureWithStartNode, nl executors.NodeLookup, inputs *core.LiteralMap) *Node_SetInputsForStartNode
func (*Node) OnSetInputsForStartNodeMatch ¶ added in v0.1.13
func (_m *Node) OnSetInputsForStartNodeMatch(matchers ...interface{}) *Node_SetInputsForStartNode
func (*Node) RecursiveNodeHandler ¶ added in v0.1.13
func (_m *Node) RecursiveNodeHandler(ctx context.Context, execContext executors.ExecutionContext, dag executors.DAGStructure, nl executors.NodeLookup, currentNode v1alpha1.ExecutableNode) (executors.NodeStatus, error)
RecursiveNodeHandler provides a mock function with given fields: ctx, execContext, dag, nl, currentNode
func (*Node) SetInputsForStartNode ¶ added in v0.1.13
func (_m *Node) SetInputsForStartNode(ctx context.Context, execContext executors.ExecutionContext, dag executors.DAGStructureWithStartNode, nl executors.NodeLookup, inputs *core.LiteralMap) (executors.NodeStatus, error)
SetInputsForStartNode provides a mock function with given fields: ctx, execContext, dag, nl, inputs
type NodeLookup ¶ added in v0.2.28
NodeLookup is an autogenerated mock type for the NodeLookup type
func (*NodeLookup) GetNode ¶ added in v0.2.28
func (_m *NodeLookup) GetNode(nodeID string) (v1alpha1.ExecutableNode, bool)
GetNode provides a mock function with given fields: nodeID
func (*NodeLookup) GetNodeExecutionStatus ¶ added in v0.2.28
func (_m *NodeLookup) GetNodeExecutionStatus(ctx context.Context, id string) v1alpha1.ExecutableNodeStatus
GetNodeExecutionStatus provides a mock function with given fields: ctx, id
func (*NodeLookup) OnGetNode ¶ added in v0.2.28
func (_m *NodeLookup) OnGetNode(nodeID string) *NodeLookup_GetNode
func (*NodeLookup) OnGetNodeExecutionStatus ¶ added in v0.2.28
func (_m *NodeLookup) OnGetNodeExecutionStatus(ctx context.Context, id string) *NodeLookup_GetNodeExecutionStatus
func (*NodeLookup) OnGetNodeExecutionStatusMatch ¶ added in v0.2.28
func (_m *NodeLookup) OnGetNodeExecutionStatusMatch(matchers ...interface{}) *NodeLookup_GetNodeExecutionStatus
func (*NodeLookup) OnGetNodeMatch ¶ added in v0.2.28
func (_m *NodeLookup) OnGetNodeMatch(matchers ...interface{}) *NodeLookup_GetNode
type NodeLookup_GetNode ¶ added in v0.2.28
func (NodeLookup_GetNode) Return ¶ added in v0.2.28
func (_m NodeLookup_GetNode) Return(_a0 v1alpha1.ExecutableNode, _a1 bool) *NodeLookup_GetNode
type NodeLookup_GetNodeExecutionStatus ¶ added in v0.2.28
func (NodeLookup_GetNodeExecutionStatus) Return ¶ added in v0.2.28
func (_m NodeLookup_GetNodeExecutionStatus) Return(_a0 v1alpha1.ExecutableNodeStatus) *NodeLookup_GetNodeExecutionStatus
type Node_AbortHandler ¶ added in v0.1.13
func (Node_AbortHandler) Return ¶ added in v0.1.13
func (_m Node_AbortHandler) Return(_a0 error) *Node_AbortHandler
type Node_FinalizeHandler ¶ added in v0.1.15
func (Node_FinalizeHandler) Return ¶ added in v0.1.15
func (_m Node_FinalizeHandler) Return(_a0 error) *Node_FinalizeHandler
type Node_Initialize ¶ added in v0.1.13
func (Node_Initialize) Return ¶ added in v0.1.13
func (_m Node_Initialize) Return(_a0 error) *Node_Initialize
type Node_RecursiveNodeHandler ¶ added in v0.1.13
func (Node_RecursiveNodeHandler) Return ¶ added in v0.1.13
func (_m Node_RecursiveNodeHandler) Return(_a0 executors.NodeStatus, _a1 error) *Node_RecursiveNodeHandler
type Node_SetInputsForStartNode ¶ added in v0.1.13
func (Node_SetInputsForStartNode) Return ¶ added in v0.1.13
func (_m Node_SetInputsForStartNode) Return(_a0 executors.NodeStatus, _a1 error) *Node_SetInputsForStartNode
type ParentInfoGetter ¶ added in v0.3.8
ParentInfoGetter is an autogenerated mock type for the ParentInfoGetter type
func (*ParentInfoGetter) GetParentInfo ¶ added in v0.3.8
func (_m *ParentInfoGetter) GetParentInfo() executors.ImmutableParentInfo
GetParentInfo provides a mock function with given fields:
func (*ParentInfoGetter) OnGetParentInfo ¶ added in v0.3.8
func (_m *ParentInfoGetter) OnGetParentInfo() *ParentInfoGetter_GetParentInfo
func (*ParentInfoGetter) OnGetParentInfoMatch ¶ added in v0.3.8
func (_m *ParentInfoGetter) OnGetParentInfoMatch(matchers ...interface{}) *ParentInfoGetter_GetParentInfo
type ParentInfoGetter_GetParentInfo ¶ added in v0.3.8
func (ParentInfoGetter_GetParentInfo) Return ¶ added in v0.3.8
func (_m ParentInfoGetter_GetParentInfo) Return(_a0 executors.ImmutableParentInfo) *ParentInfoGetter_GetParentInfo
type SubWorkflowGetter ¶ added in v0.2.28
SubWorkflowGetter is an autogenerated mock type for the SubWorkflowGetter type
func (*SubWorkflowGetter) FindSubWorkflow ¶ added in v0.2.28
func (_m *SubWorkflowGetter) FindSubWorkflow(subID string) v1alpha1.ExecutableSubWorkflow
FindSubWorkflow provides a mock function with given fields: subID
func (*SubWorkflowGetter) OnFindSubWorkflow ¶ added in v0.2.28
func (_m *SubWorkflowGetter) OnFindSubWorkflow(subID string) *SubWorkflowGetter_FindSubWorkflow
func (*SubWorkflowGetter) OnFindSubWorkflowMatch ¶ added in v0.2.28
func (_m *SubWorkflowGetter) OnFindSubWorkflowMatch(matchers ...interface{}) *SubWorkflowGetter_FindSubWorkflow
type SubWorkflowGetter_FindSubWorkflow ¶ added in v0.2.28
func (SubWorkflowGetter_FindSubWorkflow) Return ¶ added in v0.2.28
func (_m SubWorkflowGetter_FindSubWorkflow) Return(_a0 v1alpha1.ExecutableSubWorkflow) *SubWorkflowGetter_FindSubWorkflow
type TaskDetailsGetter ¶ added in v0.2.28
TaskDetailsGetter is an autogenerated mock type for the TaskDetailsGetter type
func (*TaskDetailsGetter) GetTask ¶ added in v0.2.28
func (_m *TaskDetailsGetter) GetTask(id string) (v1alpha1.ExecutableTask, error)
GetTask provides a mock function with given fields: id
func (*TaskDetailsGetter) OnGetTask ¶ added in v0.2.28
func (_m *TaskDetailsGetter) OnGetTask(id string) *TaskDetailsGetter_GetTask
func (*TaskDetailsGetter) OnGetTaskMatch ¶ added in v0.2.28
func (_m *TaskDetailsGetter) OnGetTaskMatch(matchers ...interface{}) *TaskDetailsGetter_GetTask
type TaskDetailsGetter_GetTask ¶ added in v0.2.28
func (TaskDetailsGetter_GetTask) Return ¶ added in v0.2.28
func (_m TaskDetailsGetter_GetTask) Return(_a0 v1alpha1.ExecutableTask, _a1 error) *TaskDetailsGetter_GetTask
type Workflow ¶ added in v0.1.13
Workflow is an autogenerated mock type for the Workflow type
func (*Workflow) HandleAbortedWorkflow ¶ added in v0.1.13
func (_m *Workflow) HandleAbortedWorkflow(ctx context.Context, w *v1alpha1.FlyteWorkflow, maxRetries uint32) error
HandleAbortedWorkflow provides a mock function with given fields: ctx, w, maxRetries
func (*Workflow) HandleFlyteWorkflow ¶ added in v0.1.13
HandleFlyteWorkflow provides a mock function with given fields: ctx, w
func (*Workflow) Initialize ¶ added in v0.1.13
Initialize provides a mock function with given fields: ctx
func (*Workflow) OnHandleAbortedWorkflow ¶ added in v0.1.13
func (_m *Workflow) OnHandleAbortedWorkflow(ctx context.Context, w *v1alpha1.FlyteWorkflow, maxRetries uint32) *Workflow_HandleAbortedWorkflow
func (*Workflow) OnHandleAbortedWorkflowMatch ¶ added in v0.1.13
func (_m *Workflow) OnHandleAbortedWorkflowMatch(matchers ...interface{}) *Workflow_HandleAbortedWorkflow
func (*Workflow) OnHandleFlyteWorkflow ¶ added in v0.1.13
func (_m *Workflow) OnHandleFlyteWorkflow(ctx context.Context, w *v1alpha1.FlyteWorkflow) *Workflow_HandleFlyteWorkflow
func (*Workflow) OnHandleFlyteWorkflowMatch ¶ added in v0.1.13
func (_m *Workflow) OnHandleFlyteWorkflowMatch(matchers ...interface{}) *Workflow_HandleFlyteWorkflow
func (*Workflow) OnInitialize ¶ added in v0.1.13
func (_m *Workflow) OnInitialize(ctx context.Context) *Workflow_Initialize
func (*Workflow) OnInitializeMatch ¶ added in v0.1.13
func (_m *Workflow) OnInitializeMatch(matchers ...interface{}) *Workflow_Initialize
type Workflow_HandleAbortedWorkflow ¶ added in v0.1.13
func (Workflow_HandleAbortedWorkflow) Return ¶ added in v0.1.13
func (_m Workflow_HandleAbortedWorkflow) Return(_a0 error) *Workflow_HandleAbortedWorkflow
type Workflow_HandleFlyteWorkflow ¶ added in v0.1.13
func (Workflow_HandleFlyteWorkflow) Return ¶ added in v0.1.13
func (_m Workflow_HandleFlyteWorkflow) Return(_a0 error) *Workflow_HandleFlyteWorkflow
type Workflow_Initialize ¶ added in v0.1.13
func (Workflow_Initialize) Return ¶ added in v0.1.13
func (_m Workflow_Initialize) Return(_a0 error) *Workflow_Initialize