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 ControlFlow
- func (_m *ControlFlow) CurrentParallelism() uint32
- func (_m *ControlFlow) IncrementParallelism() uint32
- func (_m *ControlFlow) OnCurrentParallelism() *ControlFlow_CurrentParallelism
- func (_m *ControlFlow) OnCurrentParallelismMatch(matchers ...interface{}) *ControlFlow_CurrentParallelism
- func (_m *ControlFlow) OnIncrementParallelism() *ControlFlow_IncrementParallelism
- func (_m *ControlFlow) OnIncrementParallelismMatch(matchers ...interface{}) *ControlFlow_IncrementParallelism
- type ControlFlow_CurrentParallelism
- type ControlFlow_IncrementParallelism
- 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) CurrentNodeExecutionCount() uint32
- func (_m *ExecutionContext) CurrentParallelism() uint32
- func (_m *ExecutionContext) CurrentTaskExecutionCount() uint32
- func (_m *ExecutionContext) EXPECT() *ExecutionContext_Expecter
- func (_m *ExecutionContext) FindSubWorkflow(subID string) v1alpha1.ExecutableSubWorkflow
- func (_m *ExecutionContext) GetAnnotations() map[string]string
- func (_m *ExecutionContext) GetConsoleURL() string
- func (_m *ExecutionContext) GetCreationTimestamp() v1.Time
- func (_m *ExecutionContext) GetDefinitionVersion() v1alpha1.WorkflowDefinitionVersion
- func (_m *ExecutionContext) GetEventVersion() v1alpha1.EventVersion
- func (_m *ExecutionContext) GetExecutionConfig() v1alpha1.ExecutionConfig
- 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) GetSecurityContext() core.SecurityContext
- func (_m *ExecutionContext) GetServiceAccountName() string
- func (_m *ExecutionContext) GetTask(id string) (v1alpha1.ExecutableTask, error)
- func (_m *ExecutionContext) IncrementNodeExecutionCount() uint32
- func (_m *ExecutionContext) IncrementParallelism() uint32
- func (_m *ExecutionContext) IncrementTaskExecutionCount() uint32
- func (_m *ExecutionContext) IsInterruptible() bool
- type ExecutionContext_CurrentNodeExecutionCount_Call
- func (_c *ExecutionContext_CurrentNodeExecutionCount_Call) Return(_a0 uint32) *ExecutionContext_CurrentNodeExecutionCount_Call
- func (_c *ExecutionContext_CurrentNodeExecutionCount_Call) Run(run func()) *ExecutionContext_CurrentNodeExecutionCount_Call
- func (_c *ExecutionContext_CurrentNodeExecutionCount_Call) RunAndReturn(run func() uint32) *ExecutionContext_CurrentNodeExecutionCount_Call
- type ExecutionContext_CurrentParallelism_Call
- func (_c *ExecutionContext_CurrentParallelism_Call) Return(_a0 uint32) *ExecutionContext_CurrentParallelism_Call
- func (_c *ExecutionContext_CurrentParallelism_Call) Run(run func()) *ExecutionContext_CurrentParallelism_Call
- func (_c *ExecutionContext_CurrentParallelism_Call) RunAndReturn(run func() uint32) *ExecutionContext_CurrentParallelism_Call
- type ExecutionContext_CurrentTaskExecutionCount_Call
- func (_c *ExecutionContext_CurrentTaskExecutionCount_Call) Return(_a0 uint32) *ExecutionContext_CurrentTaskExecutionCount_Call
- func (_c *ExecutionContext_CurrentTaskExecutionCount_Call) Run(run func()) *ExecutionContext_CurrentTaskExecutionCount_Call
- func (_c *ExecutionContext_CurrentTaskExecutionCount_Call) RunAndReturn(run func() uint32) *ExecutionContext_CurrentTaskExecutionCount_Call
- type ExecutionContext_Expecter
- func (_e *ExecutionContext_Expecter) CurrentNodeExecutionCount() *ExecutionContext_CurrentNodeExecutionCount_Call
- func (_e *ExecutionContext_Expecter) CurrentParallelism() *ExecutionContext_CurrentParallelism_Call
- func (_e *ExecutionContext_Expecter) CurrentTaskExecutionCount() *ExecutionContext_CurrentTaskExecutionCount_Call
- func (_e *ExecutionContext_Expecter) FindSubWorkflow(subID interface{}) *ExecutionContext_FindSubWorkflow_Call
- func (_e *ExecutionContext_Expecter) GetAnnotations() *ExecutionContext_GetAnnotations_Call
- func (_e *ExecutionContext_Expecter) GetConsoleURL() *ExecutionContext_GetConsoleURL_Call
- func (_e *ExecutionContext_Expecter) GetCreationTimestamp() *ExecutionContext_GetCreationTimestamp_Call
- func (_e *ExecutionContext_Expecter) GetDefinitionVersion() *ExecutionContext_GetDefinitionVersion_Call
- func (_e *ExecutionContext_Expecter) GetEventVersion() *ExecutionContext_GetEventVersion_Call
- func (_e *ExecutionContext_Expecter) GetExecutionConfig() *ExecutionContext_GetExecutionConfig_Call
- func (_e *ExecutionContext_Expecter) GetExecutionID() *ExecutionContext_GetExecutionID_Call
- func (_e *ExecutionContext_Expecter) GetID() *ExecutionContext_GetID_Call
- func (_e *ExecutionContext_Expecter) GetK8sWorkflowID() *ExecutionContext_GetK8sWorkflowID_Call
- func (_e *ExecutionContext_Expecter) GetLabels() *ExecutionContext_GetLabels_Call
- func (_e *ExecutionContext_Expecter) GetName() *ExecutionContext_GetName_Call
- func (_e *ExecutionContext_Expecter) GetNamespace() *ExecutionContext_GetNamespace_Call
- func (_e *ExecutionContext_Expecter) GetOnFailurePolicy() *ExecutionContext_GetOnFailurePolicy_Call
- func (_e *ExecutionContext_Expecter) GetOwnerReference() *ExecutionContext_GetOwnerReference_Call
- func (_e *ExecutionContext_Expecter) GetParentInfo() *ExecutionContext_GetParentInfo_Call
- func (_e *ExecutionContext_Expecter) GetRawOutputDataConfig() *ExecutionContext_GetRawOutputDataConfig_Call
- func (_e *ExecutionContext_Expecter) GetSecurityContext() *ExecutionContext_GetSecurityContext_Call
- func (_e *ExecutionContext_Expecter) GetServiceAccountName() *ExecutionContext_GetServiceAccountName_Call
- func (_e *ExecutionContext_Expecter) GetTask(id interface{}) *ExecutionContext_GetTask_Call
- func (_e *ExecutionContext_Expecter) IncrementNodeExecutionCount() *ExecutionContext_IncrementNodeExecutionCount_Call
- func (_e *ExecutionContext_Expecter) IncrementParallelism() *ExecutionContext_IncrementParallelism_Call
- func (_e *ExecutionContext_Expecter) IncrementTaskExecutionCount() *ExecutionContext_IncrementTaskExecutionCount_Call
- func (_e *ExecutionContext_Expecter) IsInterruptible() *ExecutionContext_IsInterruptible_Call
- type ExecutionContext_FindSubWorkflow_Call
- func (_c *ExecutionContext_FindSubWorkflow_Call) Return(_a0 v1alpha1.ExecutableSubWorkflow) *ExecutionContext_FindSubWorkflow_Call
- func (_c *ExecutionContext_FindSubWorkflow_Call) Run(run func(subID string)) *ExecutionContext_FindSubWorkflow_Call
- func (_c *ExecutionContext_FindSubWorkflow_Call) RunAndReturn(run func(string) v1alpha1.ExecutableSubWorkflow) *ExecutionContext_FindSubWorkflow_Call
- type ExecutionContext_GetAnnotations_Call
- func (_c *ExecutionContext_GetAnnotations_Call) Return(_a0 map[string]string) *ExecutionContext_GetAnnotations_Call
- func (_c *ExecutionContext_GetAnnotations_Call) Run(run func()) *ExecutionContext_GetAnnotations_Call
- func (_c *ExecutionContext_GetAnnotations_Call) RunAndReturn(run func() map[string]string) *ExecutionContext_GetAnnotations_Call
- type ExecutionContext_GetConsoleURL_Call
- func (_c *ExecutionContext_GetConsoleURL_Call) Return(_a0 string) *ExecutionContext_GetConsoleURL_Call
- func (_c *ExecutionContext_GetConsoleURL_Call) Run(run func()) *ExecutionContext_GetConsoleURL_Call
- func (_c *ExecutionContext_GetConsoleURL_Call) RunAndReturn(run func() string) *ExecutionContext_GetConsoleURL_Call
- type ExecutionContext_GetCreationTimestamp_Call
- func (_c *ExecutionContext_GetCreationTimestamp_Call) Return(_a0 v1.Time) *ExecutionContext_GetCreationTimestamp_Call
- func (_c *ExecutionContext_GetCreationTimestamp_Call) Run(run func()) *ExecutionContext_GetCreationTimestamp_Call
- func (_c *ExecutionContext_GetCreationTimestamp_Call) RunAndReturn(run func() v1.Time) *ExecutionContext_GetCreationTimestamp_Call
- type ExecutionContext_GetDefinitionVersion_Call
- func (_c *ExecutionContext_GetDefinitionVersion_Call) Return(_a0 v1alpha1.WorkflowDefinitionVersion) *ExecutionContext_GetDefinitionVersion_Call
- func (_c *ExecutionContext_GetDefinitionVersion_Call) Run(run func()) *ExecutionContext_GetDefinitionVersion_Call
- func (_c *ExecutionContext_GetDefinitionVersion_Call) RunAndReturn(run func() v1alpha1.WorkflowDefinitionVersion) *ExecutionContext_GetDefinitionVersion_Call
- type ExecutionContext_GetEventVersion_Call
- func (_c *ExecutionContext_GetEventVersion_Call) Return(_a0 v1alpha1.EventVersion) *ExecutionContext_GetEventVersion_Call
- func (_c *ExecutionContext_GetEventVersion_Call) Run(run func()) *ExecutionContext_GetEventVersion_Call
- func (_c *ExecutionContext_GetEventVersion_Call) RunAndReturn(run func() v1alpha1.EventVersion) *ExecutionContext_GetEventVersion_Call
- type ExecutionContext_GetExecutionConfig_Call
- func (_c *ExecutionContext_GetExecutionConfig_Call) Return(_a0 v1alpha1.ExecutionConfig) *ExecutionContext_GetExecutionConfig_Call
- func (_c *ExecutionContext_GetExecutionConfig_Call) Run(run func()) *ExecutionContext_GetExecutionConfig_Call
- func (_c *ExecutionContext_GetExecutionConfig_Call) RunAndReturn(run func() v1alpha1.ExecutionConfig) *ExecutionContext_GetExecutionConfig_Call
- type ExecutionContext_GetExecutionID_Call
- func (_c *ExecutionContext_GetExecutionID_Call) Return(_a0 v1alpha1.WorkflowExecutionIdentifier) *ExecutionContext_GetExecutionID_Call
- func (_c *ExecutionContext_GetExecutionID_Call) Run(run func()) *ExecutionContext_GetExecutionID_Call
- func (_c *ExecutionContext_GetExecutionID_Call) RunAndReturn(run func() v1alpha1.WorkflowExecutionIdentifier) *ExecutionContext_GetExecutionID_Call
- type ExecutionContext_GetID_Call
- type ExecutionContext_GetK8sWorkflowID_Call
- func (_c *ExecutionContext_GetK8sWorkflowID_Call) Return(_a0 types.NamespacedName) *ExecutionContext_GetK8sWorkflowID_Call
- func (_c *ExecutionContext_GetK8sWorkflowID_Call) Run(run func()) *ExecutionContext_GetK8sWorkflowID_Call
- func (_c *ExecutionContext_GetK8sWorkflowID_Call) RunAndReturn(run func() types.NamespacedName) *ExecutionContext_GetK8sWorkflowID_Call
- type ExecutionContext_GetLabels_Call
- func (_c *ExecutionContext_GetLabels_Call) Return(_a0 map[string]string) *ExecutionContext_GetLabels_Call
- func (_c *ExecutionContext_GetLabels_Call) Run(run func()) *ExecutionContext_GetLabels_Call
- func (_c *ExecutionContext_GetLabels_Call) RunAndReturn(run func() map[string]string) *ExecutionContext_GetLabels_Call
- type ExecutionContext_GetName_Call
- type ExecutionContext_GetNamespace_Call
- func (_c *ExecutionContext_GetNamespace_Call) Return(_a0 string) *ExecutionContext_GetNamespace_Call
- func (_c *ExecutionContext_GetNamespace_Call) Run(run func()) *ExecutionContext_GetNamespace_Call
- func (_c *ExecutionContext_GetNamespace_Call) RunAndReturn(run func() string) *ExecutionContext_GetNamespace_Call
- type ExecutionContext_GetOnFailurePolicy_Call
- func (_c *ExecutionContext_GetOnFailurePolicy_Call) Return(_a0 v1alpha1.WorkflowOnFailurePolicy) *ExecutionContext_GetOnFailurePolicy_Call
- func (_c *ExecutionContext_GetOnFailurePolicy_Call) Run(run func()) *ExecutionContext_GetOnFailurePolicy_Call
- func (_c *ExecutionContext_GetOnFailurePolicy_Call) RunAndReturn(run func() v1alpha1.WorkflowOnFailurePolicy) *ExecutionContext_GetOnFailurePolicy_Call
- type ExecutionContext_GetOwnerReference_Call
- func (_c *ExecutionContext_GetOwnerReference_Call) Return(_a0 v1.OwnerReference) *ExecutionContext_GetOwnerReference_Call
- func (_c *ExecutionContext_GetOwnerReference_Call) Run(run func()) *ExecutionContext_GetOwnerReference_Call
- func (_c *ExecutionContext_GetOwnerReference_Call) RunAndReturn(run func() v1.OwnerReference) *ExecutionContext_GetOwnerReference_Call
- type ExecutionContext_GetParentInfo_Call
- func (_c *ExecutionContext_GetParentInfo_Call) Return(_a0 executors.ImmutableParentInfo) *ExecutionContext_GetParentInfo_Call
- func (_c *ExecutionContext_GetParentInfo_Call) Run(run func()) *ExecutionContext_GetParentInfo_Call
- func (_c *ExecutionContext_GetParentInfo_Call) RunAndReturn(run func() executors.ImmutableParentInfo) *ExecutionContext_GetParentInfo_Call
- type ExecutionContext_GetRawOutputDataConfig_Call
- func (_c *ExecutionContext_GetRawOutputDataConfig_Call) Return(_a0 v1alpha1.RawOutputDataConfig) *ExecutionContext_GetRawOutputDataConfig_Call
- func (_c *ExecutionContext_GetRawOutputDataConfig_Call) Run(run func()) *ExecutionContext_GetRawOutputDataConfig_Call
- func (_c *ExecutionContext_GetRawOutputDataConfig_Call) RunAndReturn(run func() v1alpha1.RawOutputDataConfig) *ExecutionContext_GetRawOutputDataConfig_Call
- type ExecutionContext_GetSecurityContext_Call
- func (_c *ExecutionContext_GetSecurityContext_Call) Return(_a0 core.SecurityContext) *ExecutionContext_GetSecurityContext_Call
- func (_c *ExecutionContext_GetSecurityContext_Call) Run(run func()) *ExecutionContext_GetSecurityContext_Call
- func (_c *ExecutionContext_GetSecurityContext_Call) RunAndReturn(run func() core.SecurityContext) *ExecutionContext_GetSecurityContext_Call
- type ExecutionContext_GetServiceAccountName_Call
- func (_c *ExecutionContext_GetServiceAccountName_Call) Return(_a0 string) *ExecutionContext_GetServiceAccountName_Call
- func (_c *ExecutionContext_GetServiceAccountName_Call) Run(run func()) *ExecutionContext_GetServiceAccountName_Call
- func (_c *ExecutionContext_GetServiceAccountName_Call) RunAndReturn(run func() string) *ExecutionContext_GetServiceAccountName_Call
- type ExecutionContext_GetTask_Call
- func (_c *ExecutionContext_GetTask_Call) Return(_a0 v1alpha1.ExecutableTask, _a1 error) *ExecutionContext_GetTask_Call
- func (_c *ExecutionContext_GetTask_Call) Run(run func(id string)) *ExecutionContext_GetTask_Call
- func (_c *ExecutionContext_GetTask_Call) RunAndReturn(run func(string) (v1alpha1.ExecutableTask, error)) *ExecutionContext_GetTask_Call
- type ExecutionContext_IncrementNodeExecutionCount_Call
- func (_c *ExecutionContext_IncrementNodeExecutionCount_Call) Return(_a0 uint32) *ExecutionContext_IncrementNodeExecutionCount_Call
- func (_c *ExecutionContext_IncrementNodeExecutionCount_Call) Run(run func()) *ExecutionContext_IncrementNodeExecutionCount_Call
- func (_c *ExecutionContext_IncrementNodeExecutionCount_Call) RunAndReturn(run func() uint32) *ExecutionContext_IncrementNodeExecutionCount_Call
- type ExecutionContext_IncrementParallelism_Call
- func (_c *ExecutionContext_IncrementParallelism_Call) Return(_a0 uint32) *ExecutionContext_IncrementParallelism_Call
- func (_c *ExecutionContext_IncrementParallelism_Call) Run(run func()) *ExecutionContext_IncrementParallelism_Call
- func (_c *ExecutionContext_IncrementParallelism_Call) RunAndReturn(run func() uint32) *ExecutionContext_IncrementParallelism_Call
- type ExecutionContext_IncrementTaskExecutionCount_Call
- func (_c *ExecutionContext_IncrementTaskExecutionCount_Call) Return(_a0 uint32) *ExecutionContext_IncrementTaskExecutionCount_Call
- func (_c *ExecutionContext_IncrementTaskExecutionCount_Call) Run(run func()) *ExecutionContext_IncrementTaskExecutionCount_Call
- func (_c *ExecutionContext_IncrementTaskExecutionCount_Call) RunAndReturn(run func() uint32) *ExecutionContext_IncrementTaskExecutionCount_Call
- type ExecutionContext_IsInterruptible_Call
- func (_c *ExecutionContext_IsInterruptible_Call) Return(_a0 bool) *ExecutionContext_IsInterruptible_Call
- func (_c *ExecutionContext_IsInterruptible_Call) Run(run func()) *ExecutionContext_IsInterruptible_Call
- func (_c *ExecutionContext_IsInterruptible_Call) RunAndReturn(run func() bool) *ExecutionContext_IsInterruptible_Call
- type FakeInformers
- func (f *FakeInformers) Get(ctx context.Context, key client.ObjectKey, obj client.Object, ...) error
- func (f *FakeInformers) GetInformer(ctx context.Context, obj client.Object, opts ...cache.InformerGetOption) (cache.Informer, error)
- func (f *FakeInformers) GetInformerForKind(ctx context.Context, gvk schema.GroupVersionKind, ...) (cache.Informer, error)
- func (f *FakeInformers) IndexField(ctx context.Context, obj client.Object, field string, ...) error
- func (f *FakeInformers) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error
- func (f *FakeInformers) Start(ctx context.Context) error
- func (f *FakeInformers) WaitForCacheSync(ctx context.Context) bool
- type ImmutableExecutionContext
- func (_m *ImmutableExecutionContext) GetAnnotations() map[string]string
- func (_m *ImmutableExecutionContext) GetCreationTimestamp() v1.Time
- func (_m *ImmutableExecutionContext) GetDefinitionVersion() v1alpha1.WorkflowDefinitionVersion
- func (_m *ImmutableExecutionContext) GetEventVersion() v1alpha1.EventVersion
- func (_m *ImmutableExecutionContext) GetExecutionConfig() v1alpha1.ExecutionConfig
- 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) GetSecurityContext() core.SecurityContext
- 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) OnGetDefinitionVersion() *ImmutableExecutionContext_GetDefinitionVersion
- func (_m *ImmutableExecutionContext) OnGetDefinitionVersionMatch(matchers ...interface{}) *ImmutableExecutionContext_GetDefinitionVersion
- func (_m *ImmutableExecutionContext) OnGetEventVersion() *ImmutableExecutionContext_GetEventVersion
- func (_m *ImmutableExecutionContext) OnGetEventVersionMatch(matchers ...interface{}) *ImmutableExecutionContext_GetEventVersion
- func (_m *ImmutableExecutionContext) OnGetExecutionConfig() *ImmutableExecutionContext_GetExecutionConfig
- func (_m *ImmutableExecutionContext) OnGetExecutionConfigMatch(matchers ...interface{}) *ImmutableExecutionContext_GetExecutionConfig
- 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) OnGetSecurityContext() *ImmutableExecutionContext_GetSecurityContext
- func (_m *ImmutableExecutionContext) OnGetSecurityContextMatch(matchers ...interface{}) *ImmutableExecutionContext_GetSecurityContext
- 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_GetDefinitionVersion
- type ImmutableExecutionContext_GetEventVersion
- type ImmutableExecutionContext_GetExecutionConfig
- 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_GetSecurityContext
- type ImmutableExecutionContext_GetServiceAccountName
- type ImmutableExecutionContext_IsInterruptible
- type ImmutableParentInfo
- func (_m *ImmutableParentInfo) CurrentAttempt() uint32
- func (_m *ImmutableParentInfo) GetUniqueID() string
- func (_m *ImmutableParentInfo) IsInDynamicChain() bool
- 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
- func (_m *ImmutableParentInfo) OnIsInDynamicChain() *ImmutableParentInfo_IsInDynamicChain
- func (_m *ImmutableParentInfo) OnIsInDynamicChainMatch(matchers ...interface{}) *ImmutableParentInfo_IsInDynamicChain
- type ImmutableParentInfo_CurrentAttempt
- type ImmutableParentInfo_GetUniqueID
- type ImmutableParentInfo_IsInDynamicChain
- type NodeLookup
- func (_m *NodeLookup) FromNode(id string) ([]string, error)
- func (_m *NodeLookup) GetNode(nodeID string) (v1alpha1.ExecutableNode, bool)
- func (_m *NodeLookup) GetNodeExecutionStatus(ctx context.Context, id string) v1alpha1.ExecutableNodeStatus
- func (_m *NodeLookup) OnFromNode(id string) *NodeLookup_FromNode
- func (_m *NodeLookup) OnFromNodeMatch(matchers ...interface{}) *NodeLookup_FromNode
- 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
- func (_m *NodeLookup) OnToNode(id string) *NodeLookup_ToNode
- func (_m *NodeLookup) OnToNodeMatch(matchers ...interface{}) *NodeLookup_ToNode
- func (_m *NodeLookup) ToNode(id string) ([]string, error)
- type NodeLookup_FromNode
- type NodeLookup_GetNode
- type NodeLookup_GetNodeExecutionStatus
- type NodeLookup_ToNode
- 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 ¶
func (_m *Client) OnGetCache() *Client_GetCache
func (*Client) OnGetCacheMatch ¶
func (_m *Client) OnGetCacheMatch(matchers ...interface{}) *Client_GetCache
func (*Client) OnGetClient ¶
func (_m *Client) OnGetClient() *Client_GetClient
func (*Client) OnGetClientMatch ¶
func (_m *Client) OnGetClientMatch(matchers ...interface{}) *Client_GetClient
type Client_GetCache ¶
func (Client_GetCache) Return ¶
func (_m Client_GetCache) Return(_a0 cache.Cache) *Client_GetCache
type Client_GetClient ¶
func (Client_GetClient) Return ¶
func (_m Client_GetClient) Return(_a0 client.Client) *Client_GetClient
type ControlFlow ¶
ControlFlow is an autogenerated mock type for the ControlFlow type
func (*ControlFlow) CurrentParallelism ¶
func (_m *ControlFlow) CurrentParallelism() uint32
CurrentParallelism provides a mock function with given fields:
func (*ControlFlow) IncrementParallelism ¶
func (_m *ControlFlow) IncrementParallelism() uint32
IncrementParallelism provides a mock function with given fields:
func (*ControlFlow) OnCurrentParallelism ¶
func (_m *ControlFlow) OnCurrentParallelism() *ControlFlow_CurrentParallelism
func (*ControlFlow) OnCurrentParallelismMatch ¶
func (_m *ControlFlow) OnCurrentParallelismMatch(matchers ...interface{}) *ControlFlow_CurrentParallelism
func (*ControlFlow) OnIncrementParallelism ¶
func (_m *ControlFlow) OnIncrementParallelism() *ControlFlow_IncrementParallelism
func (*ControlFlow) OnIncrementParallelismMatch ¶
func (_m *ControlFlow) OnIncrementParallelismMatch(matchers ...interface{}) *ControlFlow_IncrementParallelism
type ControlFlow_CurrentParallelism ¶
func (ControlFlow_CurrentParallelism) Return ¶
func (_m ControlFlow_CurrentParallelism) Return(_a0 uint32) *ControlFlow_CurrentParallelism
type ControlFlow_IncrementParallelism ¶
func (ControlFlow_IncrementParallelism) Return ¶
func (_m ControlFlow_IncrementParallelism) Return(_a0 uint32) *ControlFlow_IncrementParallelism
type DAGStructure ¶
DAGStructure is an autogenerated mock type for the DAGStructure type
func (*DAGStructure) FromNode ¶
func (_m *DAGStructure) FromNode(id string) ([]string, error)
FromNode provides a mock function with given fields: id
func (*DAGStructure) OnFromNode ¶
func (_m *DAGStructure) OnFromNode(id string) *DAGStructure_FromNode
func (*DAGStructure) OnFromNodeMatch ¶
func (_m *DAGStructure) OnFromNodeMatch(matchers ...interface{}) *DAGStructure_FromNode
func (*DAGStructure) OnToNode ¶
func (_m *DAGStructure) OnToNode(id string) *DAGStructure_ToNode
func (*DAGStructure) OnToNodeMatch ¶
func (_m *DAGStructure) OnToNodeMatch(matchers ...interface{}) *DAGStructure_ToNode
type DAGStructureWithStartNode ¶
DAGStructureWithStartNode is an autogenerated mock type for the DAGStructureWithStartNode type
func (*DAGStructureWithStartNode) FromNode ¶
func (_m *DAGStructureWithStartNode) FromNode(id string) ([]string, error)
FromNode provides a mock function with given fields: id
func (*DAGStructureWithStartNode) OnFromNode ¶
func (_m *DAGStructureWithStartNode) OnFromNode(id string) *DAGStructureWithStartNode_FromNode
func (*DAGStructureWithStartNode) OnFromNodeMatch ¶
func (_m *DAGStructureWithStartNode) OnFromNodeMatch(matchers ...interface{}) *DAGStructureWithStartNode_FromNode
func (*DAGStructureWithStartNode) OnStartNode ¶
func (_m *DAGStructureWithStartNode) OnStartNode() *DAGStructureWithStartNode_StartNode
func (*DAGStructureWithStartNode) OnStartNodeMatch ¶
func (_m *DAGStructureWithStartNode) OnStartNodeMatch(matchers ...interface{}) *DAGStructureWithStartNode_StartNode
func (*DAGStructureWithStartNode) OnToNode ¶
func (_m *DAGStructureWithStartNode) OnToNode(id string) *DAGStructureWithStartNode_ToNode
func (*DAGStructureWithStartNode) OnToNodeMatch ¶
func (_m *DAGStructureWithStartNode) OnToNodeMatch(matchers ...interface{}) *DAGStructureWithStartNode_ToNode
func (*DAGStructureWithStartNode) StartNode ¶
func (_m *DAGStructureWithStartNode) StartNode() v1alpha1.ExecutableNode
StartNode provides a mock function with given fields:
type DAGStructureWithStartNode_FromNode ¶
func (DAGStructureWithStartNode_FromNode) Return ¶
func (_m DAGStructureWithStartNode_FromNode) Return(_a0 []string, _a1 error) *DAGStructureWithStartNode_FromNode
type DAGStructureWithStartNode_StartNode ¶
func (DAGStructureWithStartNode_StartNode) Return ¶
func (_m DAGStructureWithStartNode_StartNode) Return(_a0 v1alpha1.ExecutableNode) *DAGStructureWithStartNode_StartNode
type DAGStructureWithStartNode_ToNode ¶
func (DAGStructureWithStartNode_ToNode) Return ¶
func (_m DAGStructureWithStartNode_ToNode) Return(_a0 []string, _a1 error) *DAGStructureWithStartNode_ToNode
type DAGStructure_FromNode ¶
func (DAGStructure_FromNode) Return ¶
func (_m DAGStructure_FromNode) Return(_a0 []string, _a1 error) *DAGStructure_FromNode
type DAGStructure_ToNode ¶
func (DAGStructure_ToNode) Return ¶
func (_m DAGStructure_ToNode) Return(_a0 []string, _a1 error) *DAGStructure_ToNode
type ExecutionContext ¶
ExecutionContext is an autogenerated mock type for the ExecutionContext type
func NewExecutionContext ¶ added in v1.13.0
func NewExecutionContext(t interface {
mock.TestingT
Cleanup(func())
}) *ExecutionContext
NewExecutionContext creates a new instance of ExecutionContext. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*ExecutionContext) CurrentNodeExecutionCount ¶ added in v1.12.0
func (_m *ExecutionContext) CurrentNodeExecutionCount() uint32
CurrentNodeExecutionCount provides a mock function with given fields:
func (*ExecutionContext) CurrentParallelism ¶
func (_m *ExecutionContext) CurrentParallelism() uint32
CurrentParallelism provides a mock function with given fields:
func (*ExecutionContext) CurrentTaskExecutionCount ¶ added in v1.12.0
func (_m *ExecutionContext) CurrentTaskExecutionCount() uint32
CurrentTaskExecutionCount provides a mock function with given fields:
func (*ExecutionContext) EXPECT ¶ added in v1.13.0
func (_m *ExecutionContext) EXPECT() *ExecutionContext_Expecter
func (*ExecutionContext) FindSubWorkflow ¶
func (_m *ExecutionContext) FindSubWorkflow(subID string) v1alpha1.ExecutableSubWorkflow
FindSubWorkflow provides a mock function with given fields: subID
func (*ExecutionContext) GetAnnotations ¶
func (_m *ExecutionContext) GetAnnotations() map[string]string
GetAnnotations provides a mock function with given fields:
func (*ExecutionContext) GetConsoleURL ¶ added in v1.13.0
func (_m *ExecutionContext) GetConsoleURL() string
GetConsoleURL provides a mock function with given fields:
func (*ExecutionContext) GetCreationTimestamp ¶
func (_m *ExecutionContext) GetCreationTimestamp() v1.Time
GetCreationTimestamp provides a mock function with given fields:
func (*ExecutionContext) GetDefinitionVersion ¶
func (_m *ExecutionContext) GetDefinitionVersion() v1alpha1.WorkflowDefinitionVersion
GetDefinitionVersion provides a mock function with given fields:
func (*ExecutionContext) GetEventVersion ¶
func (_m *ExecutionContext) GetEventVersion() v1alpha1.EventVersion
GetEventVersion provides a mock function with given fields:
func (*ExecutionContext) GetExecutionConfig ¶
func (_m *ExecutionContext) GetExecutionConfig() v1alpha1.ExecutionConfig
GetExecutionConfig provides a mock function with given fields:
func (*ExecutionContext) GetExecutionID ¶
func (_m *ExecutionContext) GetExecutionID() v1alpha1.WorkflowExecutionIdentifier
GetExecutionID provides a mock function with given fields:
func (*ExecutionContext) GetID ¶
func (_m *ExecutionContext) GetID() string
GetID provides a mock function with given fields:
func (*ExecutionContext) GetK8sWorkflowID ¶
func (_m *ExecutionContext) GetK8sWorkflowID() types.NamespacedName
GetK8sWorkflowID provides a mock function with given fields:
func (*ExecutionContext) GetLabels ¶
func (_m *ExecutionContext) GetLabels() map[string]string
GetLabels provides a mock function with given fields:
func (*ExecutionContext) GetName ¶
func (_m *ExecutionContext) GetName() string
GetName provides a mock function with given fields:
func (*ExecutionContext) GetNamespace ¶
func (_m *ExecutionContext) GetNamespace() string
GetNamespace provides a mock function with given fields:
func (*ExecutionContext) GetOnFailurePolicy ¶
func (_m *ExecutionContext) GetOnFailurePolicy() v1alpha1.WorkflowOnFailurePolicy
GetOnFailurePolicy provides a mock function with given fields:
func (*ExecutionContext) GetOwnerReference ¶
func (_m *ExecutionContext) GetOwnerReference() v1.OwnerReference
GetOwnerReference provides a mock function with given fields:
func (*ExecutionContext) GetParentInfo ¶
func (_m *ExecutionContext) GetParentInfo() executors.ImmutableParentInfo
GetParentInfo provides a mock function with given fields:
func (*ExecutionContext) GetRawOutputDataConfig ¶
func (_m *ExecutionContext) GetRawOutputDataConfig() v1alpha1.RawOutputDataConfig
GetRawOutputDataConfig provides a mock function with given fields:
func (*ExecutionContext) GetSecurityContext ¶
func (_m *ExecutionContext) GetSecurityContext() core.SecurityContext
GetSecurityContext provides a mock function with given fields:
func (*ExecutionContext) GetServiceAccountName ¶
func (_m *ExecutionContext) GetServiceAccountName() string
GetServiceAccountName provides a mock function with given fields:
func (*ExecutionContext) GetTask ¶
func (_m *ExecutionContext) GetTask(id string) (v1alpha1.ExecutableTask, error)
GetTask provides a mock function with given fields: id
func (*ExecutionContext) IncrementNodeExecutionCount ¶ added in v1.12.0
func (_m *ExecutionContext) IncrementNodeExecutionCount() uint32
IncrementNodeExecutionCount provides a mock function with given fields:
func (*ExecutionContext) IncrementParallelism ¶
func (_m *ExecutionContext) IncrementParallelism() uint32
IncrementParallelism provides a mock function with given fields:
func (*ExecutionContext) IncrementTaskExecutionCount ¶ added in v1.12.0
func (_m *ExecutionContext) IncrementTaskExecutionCount() uint32
IncrementTaskExecutionCount provides a mock function with given fields:
func (*ExecutionContext) IsInterruptible ¶
func (_m *ExecutionContext) IsInterruptible() bool
IsInterruptible provides a mock function with given fields:
type ExecutionContext_CurrentNodeExecutionCount_Call ¶ added in v1.13.0
ExecutionContext_CurrentNodeExecutionCount_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CurrentNodeExecutionCount'
func (*ExecutionContext_CurrentNodeExecutionCount_Call) Return ¶ added in v1.13.0
func (_c *ExecutionContext_CurrentNodeExecutionCount_Call) Return(_a0 uint32) *ExecutionContext_CurrentNodeExecutionCount_Call
func (*ExecutionContext_CurrentNodeExecutionCount_Call) Run ¶ added in v1.13.0
func (_c *ExecutionContext_CurrentNodeExecutionCount_Call) Run(run func()) *ExecutionContext_CurrentNodeExecutionCount_Call
func (*ExecutionContext_CurrentNodeExecutionCount_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ExecutionContext_CurrentNodeExecutionCount_Call) RunAndReturn(run func() uint32) *ExecutionContext_CurrentNodeExecutionCount_Call
type ExecutionContext_CurrentParallelism_Call ¶ added in v1.13.0
ExecutionContext_CurrentParallelism_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CurrentParallelism'
func (*ExecutionContext_CurrentParallelism_Call) Return ¶ added in v1.13.0
func (_c *ExecutionContext_CurrentParallelism_Call) Return(_a0 uint32) *ExecutionContext_CurrentParallelism_Call
func (*ExecutionContext_CurrentParallelism_Call) Run ¶ added in v1.13.0
func (_c *ExecutionContext_CurrentParallelism_Call) Run(run func()) *ExecutionContext_CurrentParallelism_Call
func (*ExecutionContext_CurrentParallelism_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ExecutionContext_CurrentParallelism_Call) RunAndReturn(run func() uint32) *ExecutionContext_CurrentParallelism_Call
type ExecutionContext_CurrentTaskExecutionCount_Call ¶ added in v1.13.0
ExecutionContext_CurrentTaskExecutionCount_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CurrentTaskExecutionCount'
func (*ExecutionContext_CurrentTaskExecutionCount_Call) Return ¶ added in v1.13.0
func (_c *ExecutionContext_CurrentTaskExecutionCount_Call) Return(_a0 uint32) *ExecutionContext_CurrentTaskExecutionCount_Call
func (*ExecutionContext_CurrentTaskExecutionCount_Call) Run ¶ added in v1.13.0
func (_c *ExecutionContext_CurrentTaskExecutionCount_Call) Run(run func()) *ExecutionContext_CurrentTaskExecutionCount_Call
func (*ExecutionContext_CurrentTaskExecutionCount_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ExecutionContext_CurrentTaskExecutionCount_Call) RunAndReturn(run func() uint32) *ExecutionContext_CurrentTaskExecutionCount_Call
type ExecutionContext_Expecter ¶ added in v1.13.0
type ExecutionContext_Expecter struct {
// contains filtered or unexported fields
}
func (*ExecutionContext_Expecter) CurrentNodeExecutionCount ¶ added in v1.13.0
func (_e *ExecutionContext_Expecter) CurrentNodeExecutionCount() *ExecutionContext_CurrentNodeExecutionCount_Call
CurrentNodeExecutionCount is a helper method to define mock.On call
func (*ExecutionContext_Expecter) CurrentParallelism ¶ added in v1.13.0
func (_e *ExecutionContext_Expecter) CurrentParallelism() *ExecutionContext_CurrentParallelism_Call
CurrentParallelism is a helper method to define mock.On call
func (*ExecutionContext_Expecter) CurrentTaskExecutionCount ¶ added in v1.13.0
func (_e *ExecutionContext_Expecter) CurrentTaskExecutionCount() *ExecutionContext_CurrentTaskExecutionCount_Call
CurrentTaskExecutionCount is a helper method to define mock.On call
func (*ExecutionContext_Expecter) FindSubWorkflow ¶ added in v1.13.0
func (_e *ExecutionContext_Expecter) FindSubWorkflow(subID interface{}) *ExecutionContext_FindSubWorkflow_Call
FindSubWorkflow is a helper method to define mock.On call
- subID string
func (*ExecutionContext_Expecter) GetAnnotations ¶ added in v1.13.0
func (_e *ExecutionContext_Expecter) GetAnnotations() *ExecutionContext_GetAnnotations_Call
GetAnnotations is a helper method to define mock.On call
func (*ExecutionContext_Expecter) GetConsoleURL ¶ added in v1.13.0
func (_e *ExecutionContext_Expecter) GetConsoleURL() *ExecutionContext_GetConsoleURL_Call
GetConsoleURL is a helper method to define mock.On call
func (*ExecutionContext_Expecter) GetCreationTimestamp ¶ added in v1.13.0
func (_e *ExecutionContext_Expecter) GetCreationTimestamp() *ExecutionContext_GetCreationTimestamp_Call
GetCreationTimestamp is a helper method to define mock.On call
func (*ExecutionContext_Expecter) GetDefinitionVersion ¶ added in v1.13.0
func (_e *ExecutionContext_Expecter) GetDefinitionVersion() *ExecutionContext_GetDefinitionVersion_Call
GetDefinitionVersion is a helper method to define mock.On call
func (*ExecutionContext_Expecter) GetEventVersion ¶ added in v1.13.0
func (_e *ExecutionContext_Expecter) GetEventVersion() *ExecutionContext_GetEventVersion_Call
GetEventVersion is a helper method to define mock.On call
func (*ExecutionContext_Expecter) GetExecutionConfig ¶ added in v1.13.0
func (_e *ExecutionContext_Expecter) GetExecutionConfig() *ExecutionContext_GetExecutionConfig_Call
GetExecutionConfig is a helper method to define mock.On call
func (*ExecutionContext_Expecter) GetExecutionID ¶ added in v1.13.0
func (_e *ExecutionContext_Expecter) GetExecutionID() *ExecutionContext_GetExecutionID_Call
GetExecutionID is a helper method to define mock.On call
func (*ExecutionContext_Expecter) GetID ¶ added in v1.13.0
func (_e *ExecutionContext_Expecter) GetID() *ExecutionContext_GetID_Call
GetID is a helper method to define mock.On call
func (*ExecutionContext_Expecter) GetK8sWorkflowID ¶ added in v1.13.0
func (_e *ExecutionContext_Expecter) GetK8sWorkflowID() *ExecutionContext_GetK8sWorkflowID_Call
GetK8sWorkflowID is a helper method to define mock.On call
func (*ExecutionContext_Expecter) GetLabels ¶ added in v1.13.0
func (_e *ExecutionContext_Expecter) GetLabels() *ExecutionContext_GetLabels_Call
GetLabels is a helper method to define mock.On call
func (*ExecutionContext_Expecter) GetName ¶ added in v1.13.0
func (_e *ExecutionContext_Expecter) GetName() *ExecutionContext_GetName_Call
GetName is a helper method to define mock.On call
func (*ExecutionContext_Expecter) GetNamespace ¶ added in v1.13.0
func (_e *ExecutionContext_Expecter) GetNamespace() *ExecutionContext_GetNamespace_Call
GetNamespace is a helper method to define mock.On call
func (*ExecutionContext_Expecter) GetOnFailurePolicy ¶ added in v1.13.0
func (_e *ExecutionContext_Expecter) GetOnFailurePolicy() *ExecutionContext_GetOnFailurePolicy_Call
GetOnFailurePolicy is a helper method to define mock.On call
func (*ExecutionContext_Expecter) GetOwnerReference ¶ added in v1.13.0
func (_e *ExecutionContext_Expecter) GetOwnerReference() *ExecutionContext_GetOwnerReference_Call
GetOwnerReference is a helper method to define mock.On call
func (*ExecutionContext_Expecter) GetParentInfo ¶ added in v1.13.0
func (_e *ExecutionContext_Expecter) GetParentInfo() *ExecutionContext_GetParentInfo_Call
GetParentInfo is a helper method to define mock.On call
func (*ExecutionContext_Expecter) GetRawOutputDataConfig ¶ added in v1.13.0
func (_e *ExecutionContext_Expecter) GetRawOutputDataConfig() *ExecutionContext_GetRawOutputDataConfig_Call
GetRawOutputDataConfig is a helper method to define mock.On call
func (*ExecutionContext_Expecter) GetSecurityContext ¶ added in v1.13.0
func (_e *ExecutionContext_Expecter) GetSecurityContext() *ExecutionContext_GetSecurityContext_Call
GetSecurityContext is a helper method to define mock.On call
func (*ExecutionContext_Expecter) GetServiceAccountName ¶ added in v1.13.0
func (_e *ExecutionContext_Expecter) GetServiceAccountName() *ExecutionContext_GetServiceAccountName_Call
GetServiceAccountName is a helper method to define mock.On call
func (*ExecutionContext_Expecter) GetTask ¶ added in v1.13.0
func (_e *ExecutionContext_Expecter) GetTask(id interface{}) *ExecutionContext_GetTask_Call
GetTask is a helper method to define mock.On call
- id string
func (*ExecutionContext_Expecter) IncrementNodeExecutionCount ¶ added in v1.13.0
func (_e *ExecutionContext_Expecter) IncrementNodeExecutionCount() *ExecutionContext_IncrementNodeExecutionCount_Call
IncrementNodeExecutionCount is a helper method to define mock.On call
func (*ExecutionContext_Expecter) IncrementParallelism ¶ added in v1.13.0
func (_e *ExecutionContext_Expecter) IncrementParallelism() *ExecutionContext_IncrementParallelism_Call
IncrementParallelism is a helper method to define mock.On call
func (*ExecutionContext_Expecter) IncrementTaskExecutionCount ¶ added in v1.13.0
func (_e *ExecutionContext_Expecter) IncrementTaskExecutionCount() *ExecutionContext_IncrementTaskExecutionCount_Call
IncrementTaskExecutionCount is a helper method to define mock.On call
func (*ExecutionContext_Expecter) IsInterruptible ¶ added in v1.13.0
func (_e *ExecutionContext_Expecter) IsInterruptible() *ExecutionContext_IsInterruptible_Call
IsInterruptible is a helper method to define mock.On call
type ExecutionContext_FindSubWorkflow_Call ¶ added in v1.13.0
ExecutionContext_FindSubWorkflow_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FindSubWorkflow'
func (*ExecutionContext_FindSubWorkflow_Call) Return ¶ added in v1.13.0
func (_c *ExecutionContext_FindSubWorkflow_Call) Return(_a0 v1alpha1.ExecutableSubWorkflow) *ExecutionContext_FindSubWorkflow_Call
func (*ExecutionContext_FindSubWorkflow_Call) Run ¶ added in v1.13.0
func (_c *ExecutionContext_FindSubWorkflow_Call) Run(run func(subID string)) *ExecutionContext_FindSubWorkflow_Call
func (*ExecutionContext_FindSubWorkflow_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ExecutionContext_FindSubWorkflow_Call) RunAndReturn(run func(string) v1alpha1.ExecutableSubWorkflow) *ExecutionContext_FindSubWorkflow_Call
type ExecutionContext_GetAnnotations_Call ¶ added in v1.13.0
ExecutionContext_GetAnnotations_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetAnnotations'
func (*ExecutionContext_GetAnnotations_Call) Return ¶ added in v1.13.0
func (_c *ExecutionContext_GetAnnotations_Call) Return(_a0 map[string]string) *ExecutionContext_GetAnnotations_Call
func (*ExecutionContext_GetAnnotations_Call) Run ¶ added in v1.13.0
func (_c *ExecutionContext_GetAnnotations_Call) Run(run func()) *ExecutionContext_GetAnnotations_Call
func (*ExecutionContext_GetAnnotations_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ExecutionContext_GetAnnotations_Call) RunAndReturn(run func() map[string]string) *ExecutionContext_GetAnnotations_Call
type ExecutionContext_GetConsoleURL_Call ¶ added in v1.13.0
ExecutionContext_GetConsoleURL_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetConsoleURL'
func (*ExecutionContext_GetConsoleURL_Call) Return ¶ added in v1.13.0
func (_c *ExecutionContext_GetConsoleURL_Call) Return(_a0 string) *ExecutionContext_GetConsoleURL_Call
func (*ExecutionContext_GetConsoleURL_Call) Run ¶ added in v1.13.0
func (_c *ExecutionContext_GetConsoleURL_Call) Run(run func()) *ExecutionContext_GetConsoleURL_Call
func (*ExecutionContext_GetConsoleURL_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ExecutionContext_GetConsoleURL_Call) RunAndReturn(run func() string) *ExecutionContext_GetConsoleURL_Call
type ExecutionContext_GetCreationTimestamp_Call ¶ added in v1.13.0
ExecutionContext_GetCreationTimestamp_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetCreationTimestamp'
func (*ExecutionContext_GetCreationTimestamp_Call) Return ¶ added in v1.13.0
func (_c *ExecutionContext_GetCreationTimestamp_Call) Return(_a0 v1.Time) *ExecutionContext_GetCreationTimestamp_Call
func (*ExecutionContext_GetCreationTimestamp_Call) Run ¶ added in v1.13.0
func (_c *ExecutionContext_GetCreationTimestamp_Call) Run(run func()) *ExecutionContext_GetCreationTimestamp_Call
func (*ExecutionContext_GetCreationTimestamp_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ExecutionContext_GetCreationTimestamp_Call) RunAndReturn(run func() v1.Time) *ExecutionContext_GetCreationTimestamp_Call
type ExecutionContext_GetDefinitionVersion_Call ¶ added in v1.13.0
ExecutionContext_GetDefinitionVersion_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetDefinitionVersion'
func (*ExecutionContext_GetDefinitionVersion_Call) Run ¶ added in v1.13.0
func (_c *ExecutionContext_GetDefinitionVersion_Call) Run(run func()) *ExecutionContext_GetDefinitionVersion_Call
func (*ExecutionContext_GetDefinitionVersion_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ExecutionContext_GetDefinitionVersion_Call) RunAndReturn(run func() v1alpha1.WorkflowDefinitionVersion) *ExecutionContext_GetDefinitionVersion_Call
type ExecutionContext_GetEventVersion_Call ¶ added in v1.13.0
ExecutionContext_GetEventVersion_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetEventVersion'
func (*ExecutionContext_GetEventVersion_Call) Return ¶ added in v1.13.0
func (_c *ExecutionContext_GetEventVersion_Call) Return(_a0 v1alpha1.EventVersion) *ExecutionContext_GetEventVersion_Call
func (*ExecutionContext_GetEventVersion_Call) Run ¶ added in v1.13.0
func (_c *ExecutionContext_GetEventVersion_Call) Run(run func()) *ExecutionContext_GetEventVersion_Call
func (*ExecutionContext_GetEventVersion_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ExecutionContext_GetEventVersion_Call) RunAndReturn(run func() v1alpha1.EventVersion) *ExecutionContext_GetEventVersion_Call
type ExecutionContext_GetExecutionConfig_Call ¶ added in v1.13.0
ExecutionContext_GetExecutionConfig_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetExecutionConfig'
func (*ExecutionContext_GetExecutionConfig_Call) Return ¶ added in v1.13.0
func (_c *ExecutionContext_GetExecutionConfig_Call) Return(_a0 v1alpha1.ExecutionConfig) *ExecutionContext_GetExecutionConfig_Call
func (*ExecutionContext_GetExecutionConfig_Call) Run ¶ added in v1.13.0
func (_c *ExecutionContext_GetExecutionConfig_Call) Run(run func()) *ExecutionContext_GetExecutionConfig_Call
func (*ExecutionContext_GetExecutionConfig_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ExecutionContext_GetExecutionConfig_Call) RunAndReturn(run func() v1alpha1.ExecutionConfig) *ExecutionContext_GetExecutionConfig_Call
type ExecutionContext_GetExecutionID_Call ¶ added in v1.13.0
ExecutionContext_GetExecutionID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetExecutionID'
func (*ExecutionContext_GetExecutionID_Call) Return ¶ added in v1.13.0
func (_c *ExecutionContext_GetExecutionID_Call) Return(_a0 v1alpha1.WorkflowExecutionIdentifier) *ExecutionContext_GetExecutionID_Call
func (*ExecutionContext_GetExecutionID_Call) Run ¶ added in v1.13.0
func (_c *ExecutionContext_GetExecutionID_Call) Run(run func()) *ExecutionContext_GetExecutionID_Call
func (*ExecutionContext_GetExecutionID_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ExecutionContext_GetExecutionID_Call) RunAndReturn(run func() v1alpha1.WorkflowExecutionIdentifier) *ExecutionContext_GetExecutionID_Call
type ExecutionContext_GetID_Call ¶ added in v1.13.0
ExecutionContext_GetID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetID'
func (*ExecutionContext_GetID_Call) Return ¶ added in v1.13.0
func (_c *ExecutionContext_GetID_Call) Return(_a0 string) *ExecutionContext_GetID_Call
func (*ExecutionContext_GetID_Call) Run ¶ added in v1.13.0
func (_c *ExecutionContext_GetID_Call) Run(run func()) *ExecutionContext_GetID_Call
func (*ExecutionContext_GetID_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ExecutionContext_GetID_Call) RunAndReturn(run func() string) *ExecutionContext_GetID_Call
type ExecutionContext_GetK8sWorkflowID_Call ¶ added in v1.13.0
ExecutionContext_GetK8sWorkflowID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetK8sWorkflowID'
func (*ExecutionContext_GetK8sWorkflowID_Call) Return ¶ added in v1.13.0
func (_c *ExecutionContext_GetK8sWorkflowID_Call) Return(_a0 types.NamespacedName) *ExecutionContext_GetK8sWorkflowID_Call
func (*ExecutionContext_GetK8sWorkflowID_Call) Run ¶ added in v1.13.0
func (_c *ExecutionContext_GetK8sWorkflowID_Call) Run(run func()) *ExecutionContext_GetK8sWorkflowID_Call
func (*ExecutionContext_GetK8sWorkflowID_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ExecutionContext_GetK8sWorkflowID_Call) RunAndReturn(run func() types.NamespacedName) *ExecutionContext_GetK8sWorkflowID_Call
type ExecutionContext_GetLabels_Call ¶ added in v1.13.0
ExecutionContext_GetLabels_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetLabels'
func (*ExecutionContext_GetLabels_Call) Return ¶ added in v1.13.0
func (_c *ExecutionContext_GetLabels_Call) Return(_a0 map[string]string) *ExecutionContext_GetLabels_Call
func (*ExecutionContext_GetLabels_Call) Run ¶ added in v1.13.0
func (_c *ExecutionContext_GetLabels_Call) Run(run func()) *ExecutionContext_GetLabels_Call
func (*ExecutionContext_GetLabels_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ExecutionContext_GetLabels_Call) RunAndReturn(run func() map[string]string) *ExecutionContext_GetLabels_Call
type ExecutionContext_GetName_Call ¶ added in v1.13.0
ExecutionContext_GetName_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetName'
func (*ExecutionContext_GetName_Call) Return ¶ added in v1.13.0
func (_c *ExecutionContext_GetName_Call) Return(_a0 string) *ExecutionContext_GetName_Call
func (*ExecutionContext_GetName_Call) Run ¶ added in v1.13.0
func (_c *ExecutionContext_GetName_Call) Run(run func()) *ExecutionContext_GetName_Call
func (*ExecutionContext_GetName_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ExecutionContext_GetName_Call) RunAndReturn(run func() string) *ExecutionContext_GetName_Call
type ExecutionContext_GetNamespace_Call ¶ added in v1.13.0
ExecutionContext_GetNamespace_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetNamespace'
func (*ExecutionContext_GetNamespace_Call) Return ¶ added in v1.13.0
func (_c *ExecutionContext_GetNamespace_Call) Return(_a0 string) *ExecutionContext_GetNamespace_Call
func (*ExecutionContext_GetNamespace_Call) Run ¶ added in v1.13.0
func (_c *ExecutionContext_GetNamespace_Call) Run(run func()) *ExecutionContext_GetNamespace_Call
func (*ExecutionContext_GetNamespace_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ExecutionContext_GetNamespace_Call) RunAndReturn(run func() string) *ExecutionContext_GetNamespace_Call
type ExecutionContext_GetOnFailurePolicy_Call ¶ added in v1.13.0
ExecutionContext_GetOnFailurePolicy_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetOnFailurePolicy'
func (*ExecutionContext_GetOnFailurePolicy_Call) Run ¶ added in v1.13.0
func (_c *ExecutionContext_GetOnFailurePolicy_Call) Run(run func()) *ExecutionContext_GetOnFailurePolicy_Call
func (*ExecutionContext_GetOnFailurePolicy_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ExecutionContext_GetOnFailurePolicy_Call) RunAndReturn(run func() v1alpha1.WorkflowOnFailurePolicy) *ExecutionContext_GetOnFailurePolicy_Call
type ExecutionContext_GetOwnerReference_Call ¶ added in v1.13.0
ExecutionContext_GetOwnerReference_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetOwnerReference'
func (*ExecutionContext_GetOwnerReference_Call) Return ¶ added in v1.13.0
func (_c *ExecutionContext_GetOwnerReference_Call) Return(_a0 v1.OwnerReference) *ExecutionContext_GetOwnerReference_Call
func (*ExecutionContext_GetOwnerReference_Call) Run ¶ added in v1.13.0
func (_c *ExecutionContext_GetOwnerReference_Call) Run(run func()) *ExecutionContext_GetOwnerReference_Call
func (*ExecutionContext_GetOwnerReference_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ExecutionContext_GetOwnerReference_Call) RunAndReturn(run func() v1.OwnerReference) *ExecutionContext_GetOwnerReference_Call
type ExecutionContext_GetParentInfo_Call ¶ added in v1.13.0
ExecutionContext_GetParentInfo_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetParentInfo'
func (*ExecutionContext_GetParentInfo_Call) Return ¶ added in v1.13.0
func (_c *ExecutionContext_GetParentInfo_Call) Return(_a0 executors.ImmutableParentInfo) *ExecutionContext_GetParentInfo_Call
func (*ExecutionContext_GetParentInfo_Call) Run ¶ added in v1.13.0
func (_c *ExecutionContext_GetParentInfo_Call) Run(run func()) *ExecutionContext_GetParentInfo_Call
func (*ExecutionContext_GetParentInfo_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ExecutionContext_GetParentInfo_Call) RunAndReturn(run func() executors.ImmutableParentInfo) *ExecutionContext_GetParentInfo_Call
type ExecutionContext_GetRawOutputDataConfig_Call ¶ added in v1.13.0
ExecutionContext_GetRawOutputDataConfig_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetRawOutputDataConfig'
func (*ExecutionContext_GetRawOutputDataConfig_Call) Run ¶ added in v1.13.0
func (_c *ExecutionContext_GetRawOutputDataConfig_Call) Run(run func()) *ExecutionContext_GetRawOutputDataConfig_Call
func (*ExecutionContext_GetRawOutputDataConfig_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ExecutionContext_GetRawOutputDataConfig_Call) RunAndReturn(run func() v1alpha1.RawOutputDataConfig) *ExecutionContext_GetRawOutputDataConfig_Call
type ExecutionContext_GetSecurityContext_Call ¶ added in v1.13.0
ExecutionContext_GetSecurityContext_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetSecurityContext'
func (*ExecutionContext_GetSecurityContext_Call) Return ¶ added in v1.13.0
func (_c *ExecutionContext_GetSecurityContext_Call) Return(_a0 core.SecurityContext) *ExecutionContext_GetSecurityContext_Call
func (*ExecutionContext_GetSecurityContext_Call) Run ¶ added in v1.13.0
func (_c *ExecutionContext_GetSecurityContext_Call) Run(run func()) *ExecutionContext_GetSecurityContext_Call
func (*ExecutionContext_GetSecurityContext_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ExecutionContext_GetSecurityContext_Call) RunAndReturn(run func() core.SecurityContext) *ExecutionContext_GetSecurityContext_Call
type ExecutionContext_GetServiceAccountName_Call ¶ added in v1.13.0
ExecutionContext_GetServiceAccountName_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetServiceAccountName'
func (*ExecutionContext_GetServiceAccountName_Call) Return ¶ added in v1.13.0
func (_c *ExecutionContext_GetServiceAccountName_Call) Return(_a0 string) *ExecutionContext_GetServiceAccountName_Call
func (*ExecutionContext_GetServiceAccountName_Call) Run ¶ added in v1.13.0
func (_c *ExecutionContext_GetServiceAccountName_Call) Run(run func()) *ExecutionContext_GetServiceAccountName_Call
func (*ExecutionContext_GetServiceAccountName_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ExecutionContext_GetServiceAccountName_Call) RunAndReturn(run func() string) *ExecutionContext_GetServiceAccountName_Call
type ExecutionContext_GetTask_Call ¶ added in v1.13.0
ExecutionContext_GetTask_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetTask'
func (*ExecutionContext_GetTask_Call) Return ¶ added in v1.13.0
func (_c *ExecutionContext_GetTask_Call) Return(_a0 v1alpha1.ExecutableTask, _a1 error) *ExecutionContext_GetTask_Call
func (*ExecutionContext_GetTask_Call) Run ¶ added in v1.13.0
func (_c *ExecutionContext_GetTask_Call) Run(run func(id string)) *ExecutionContext_GetTask_Call
func (*ExecutionContext_GetTask_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ExecutionContext_GetTask_Call) RunAndReturn(run func(string) (v1alpha1.ExecutableTask, error)) *ExecutionContext_GetTask_Call
type ExecutionContext_IncrementNodeExecutionCount_Call ¶ added in v1.13.0
ExecutionContext_IncrementNodeExecutionCount_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IncrementNodeExecutionCount'
func (*ExecutionContext_IncrementNodeExecutionCount_Call) Return ¶ added in v1.13.0
func (_c *ExecutionContext_IncrementNodeExecutionCount_Call) Return(_a0 uint32) *ExecutionContext_IncrementNodeExecutionCount_Call
func (*ExecutionContext_IncrementNodeExecutionCount_Call) Run ¶ added in v1.13.0
func (_c *ExecutionContext_IncrementNodeExecutionCount_Call) Run(run func()) *ExecutionContext_IncrementNodeExecutionCount_Call
func (*ExecutionContext_IncrementNodeExecutionCount_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ExecutionContext_IncrementNodeExecutionCount_Call) RunAndReturn(run func() uint32) *ExecutionContext_IncrementNodeExecutionCount_Call
type ExecutionContext_IncrementParallelism_Call ¶ added in v1.13.0
ExecutionContext_IncrementParallelism_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IncrementParallelism'
func (*ExecutionContext_IncrementParallelism_Call) Return ¶ added in v1.13.0
func (_c *ExecutionContext_IncrementParallelism_Call) Return(_a0 uint32) *ExecutionContext_IncrementParallelism_Call
func (*ExecutionContext_IncrementParallelism_Call) Run ¶ added in v1.13.0
func (_c *ExecutionContext_IncrementParallelism_Call) Run(run func()) *ExecutionContext_IncrementParallelism_Call
func (*ExecutionContext_IncrementParallelism_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ExecutionContext_IncrementParallelism_Call) RunAndReturn(run func() uint32) *ExecutionContext_IncrementParallelism_Call
type ExecutionContext_IncrementTaskExecutionCount_Call ¶ added in v1.13.0
ExecutionContext_IncrementTaskExecutionCount_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IncrementTaskExecutionCount'
func (*ExecutionContext_IncrementTaskExecutionCount_Call) Return ¶ added in v1.13.0
func (_c *ExecutionContext_IncrementTaskExecutionCount_Call) Return(_a0 uint32) *ExecutionContext_IncrementTaskExecutionCount_Call
func (*ExecutionContext_IncrementTaskExecutionCount_Call) Run ¶ added in v1.13.0
func (_c *ExecutionContext_IncrementTaskExecutionCount_Call) Run(run func()) *ExecutionContext_IncrementTaskExecutionCount_Call
func (*ExecutionContext_IncrementTaskExecutionCount_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ExecutionContext_IncrementTaskExecutionCount_Call) RunAndReturn(run func() uint32) *ExecutionContext_IncrementTaskExecutionCount_Call
type ExecutionContext_IsInterruptible_Call ¶ added in v1.13.0
ExecutionContext_IsInterruptible_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IsInterruptible'
func (*ExecutionContext_IsInterruptible_Call) Return ¶ added in v1.13.0
func (_c *ExecutionContext_IsInterruptible_Call) Return(_a0 bool) *ExecutionContext_IsInterruptible_Call
func (*ExecutionContext_IsInterruptible_Call) Run ¶ added in v1.13.0
func (_c *ExecutionContext_IsInterruptible_Call) Run(run func()) *ExecutionContext_IsInterruptible_Call
func (*ExecutionContext_IsInterruptible_Call) RunAndReturn ¶ added in v1.13.0
func (_c *ExecutionContext_IsInterruptible_Call) RunAndReturn(run func() bool) *ExecutionContext_IsInterruptible_Call
type FakeInformers ¶
type FakeInformers struct {
}
FakeInformers is a fake implementation of Informers. Implement a fake informer cache to avoid race condition in informertest.FakeInformers
func (*FakeInformers) GetInformer ¶
func (f *FakeInformers) GetInformer(ctx context.Context, obj client.Object, opts ...cache.InformerGetOption) (cache.Informer, error)
func (*FakeInformers) GetInformerForKind ¶
func (f *FakeInformers) GetInformerForKind(ctx context.Context, gvk schema.GroupVersionKind, opts ...cache.InformerGetOption) (cache.Informer, error)
func (*FakeInformers) IndexField ¶
func (f *FakeInformers) IndexField(ctx context.Context, obj client.Object, field string, extractValue client.IndexerFunc) error
func (*FakeInformers) List ¶
func (f *FakeInformers) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error
func (*FakeInformers) WaitForCacheSync ¶
func (f *FakeInformers) WaitForCacheSync(ctx context.Context) bool
type ImmutableExecutionContext ¶
ImmutableExecutionContext is an autogenerated mock type for the ImmutableExecutionContext type
func (*ImmutableExecutionContext) GetAnnotations ¶
func (_m *ImmutableExecutionContext) GetAnnotations() map[string]string
GetAnnotations provides a mock function with given fields:
func (*ImmutableExecutionContext) GetCreationTimestamp ¶
func (_m *ImmutableExecutionContext) GetCreationTimestamp() v1.Time
GetCreationTimestamp provides a mock function with given fields:
func (*ImmutableExecutionContext) GetDefinitionVersion ¶
func (_m *ImmutableExecutionContext) GetDefinitionVersion() v1alpha1.WorkflowDefinitionVersion
GetDefinitionVersion provides a mock function with given fields:
func (*ImmutableExecutionContext) GetEventVersion ¶
func (_m *ImmutableExecutionContext) GetEventVersion() v1alpha1.EventVersion
GetEventVersion provides a mock function with given fields:
func (*ImmutableExecutionContext) GetExecutionConfig ¶
func (_m *ImmutableExecutionContext) GetExecutionConfig() v1alpha1.ExecutionConfig
GetExecutionConfig provides a mock function with given fields:
func (*ImmutableExecutionContext) GetExecutionID ¶
func (_m *ImmutableExecutionContext) GetExecutionID() v1alpha1.WorkflowExecutionIdentifier
GetExecutionID provides a mock function with given fields:
func (*ImmutableExecutionContext) GetID ¶
func (_m *ImmutableExecutionContext) GetID() string
GetID provides a mock function with given fields:
func (*ImmutableExecutionContext) GetK8sWorkflowID ¶
func (_m *ImmutableExecutionContext) GetK8sWorkflowID() types.NamespacedName
GetK8sWorkflowID provides a mock function with given fields:
func (*ImmutableExecutionContext) GetLabels ¶
func (_m *ImmutableExecutionContext) GetLabels() map[string]string
GetLabels provides a mock function with given fields:
func (*ImmutableExecutionContext) GetName ¶
func (_m *ImmutableExecutionContext) GetName() string
GetName provides a mock function with given fields:
func (*ImmutableExecutionContext) GetNamespace ¶
func (_m *ImmutableExecutionContext) GetNamespace() string
GetNamespace provides a mock function with given fields:
func (*ImmutableExecutionContext) GetOnFailurePolicy ¶
func (_m *ImmutableExecutionContext) GetOnFailurePolicy() v1alpha1.WorkflowOnFailurePolicy
GetOnFailurePolicy provides a mock function with given fields:
func (*ImmutableExecutionContext) GetOwnerReference ¶
func (_m *ImmutableExecutionContext) GetOwnerReference() v1.OwnerReference
GetOwnerReference provides a mock function with given fields:
func (*ImmutableExecutionContext) GetRawOutputDataConfig ¶
func (_m *ImmutableExecutionContext) GetRawOutputDataConfig() v1alpha1.RawOutputDataConfig
GetRawOutputDataConfig provides a mock function with given fields:
func (*ImmutableExecutionContext) GetSecurityContext ¶
func (_m *ImmutableExecutionContext) GetSecurityContext() core.SecurityContext
GetSecurityContext provides a mock function with given fields:
func (*ImmutableExecutionContext) GetServiceAccountName ¶
func (_m *ImmutableExecutionContext) GetServiceAccountName() string
GetServiceAccountName provides a mock function with given fields:
func (*ImmutableExecutionContext) IsInterruptible ¶
func (_m *ImmutableExecutionContext) IsInterruptible() bool
IsInterruptible provides a mock function with given fields:
func (*ImmutableExecutionContext) OnGetAnnotations ¶
func (_m *ImmutableExecutionContext) OnGetAnnotations() *ImmutableExecutionContext_GetAnnotations
func (*ImmutableExecutionContext) OnGetAnnotationsMatch ¶
func (_m *ImmutableExecutionContext) OnGetAnnotationsMatch(matchers ...interface{}) *ImmutableExecutionContext_GetAnnotations
func (*ImmutableExecutionContext) OnGetCreationTimestamp ¶
func (_m *ImmutableExecutionContext) OnGetCreationTimestamp() *ImmutableExecutionContext_GetCreationTimestamp
func (*ImmutableExecutionContext) OnGetCreationTimestampMatch ¶
func (_m *ImmutableExecutionContext) OnGetCreationTimestampMatch(matchers ...interface{}) *ImmutableExecutionContext_GetCreationTimestamp
func (*ImmutableExecutionContext) OnGetDefinitionVersion ¶
func (_m *ImmutableExecutionContext) OnGetDefinitionVersion() *ImmutableExecutionContext_GetDefinitionVersion
func (*ImmutableExecutionContext) OnGetDefinitionVersionMatch ¶
func (_m *ImmutableExecutionContext) OnGetDefinitionVersionMatch(matchers ...interface{}) *ImmutableExecutionContext_GetDefinitionVersion
func (*ImmutableExecutionContext) OnGetEventVersion ¶
func (_m *ImmutableExecutionContext) OnGetEventVersion() *ImmutableExecutionContext_GetEventVersion
func (*ImmutableExecutionContext) OnGetEventVersionMatch ¶
func (_m *ImmutableExecutionContext) OnGetEventVersionMatch(matchers ...interface{}) *ImmutableExecutionContext_GetEventVersion
func (*ImmutableExecutionContext) OnGetExecutionConfig ¶
func (_m *ImmutableExecutionContext) OnGetExecutionConfig() *ImmutableExecutionContext_GetExecutionConfig
func (*ImmutableExecutionContext) OnGetExecutionConfigMatch ¶
func (_m *ImmutableExecutionContext) OnGetExecutionConfigMatch(matchers ...interface{}) *ImmutableExecutionContext_GetExecutionConfig
func (*ImmutableExecutionContext) OnGetExecutionID ¶
func (_m *ImmutableExecutionContext) OnGetExecutionID() *ImmutableExecutionContext_GetExecutionID
func (*ImmutableExecutionContext) OnGetExecutionIDMatch ¶
func (_m *ImmutableExecutionContext) OnGetExecutionIDMatch(matchers ...interface{}) *ImmutableExecutionContext_GetExecutionID
func (*ImmutableExecutionContext) OnGetID ¶
func (_m *ImmutableExecutionContext) OnGetID() *ImmutableExecutionContext_GetID
func (*ImmutableExecutionContext) OnGetIDMatch ¶
func (_m *ImmutableExecutionContext) OnGetIDMatch(matchers ...interface{}) *ImmutableExecutionContext_GetID
func (*ImmutableExecutionContext) OnGetK8sWorkflowID ¶
func (_m *ImmutableExecutionContext) OnGetK8sWorkflowID() *ImmutableExecutionContext_GetK8sWorkflowID
func (*ImmutableExecutionContext) OnGetK8sWorkflowIDMatch ¶
func (_m *ImmutableExecutionContext) OnGetK8sWorkflowIDMatch(matchers ...interface{}) *ImmutableExecutionContext_GetK8sWorkflowID
func (*ImmutableExecutionContext) OnGetLabels ¶
func (_m *ImmutableExecutionContext) OnGetLabels() *ImmutableExecutionContext_GetLabels
func (*ImmutableExecutionContext) OnGetLabelsMatch ¶
func (_m *ImmutableExecutionContext) OnGetLabelsMatch(matchers ...interface{}) *ImmutableExecutionContext_GetLabels
func (*ImmutableExecutionContext) OnGetName ¶
func (_m *ImmutableExecutionContext) OnGetName() *ImmutableExecutionContext_GetName
func (*ImmutableExecutionContext) OnGetNameMatch ¶
func (_m *ImmutableExecutionContext) OnGetNameMatch(matchers ...interface{}) *ImmutableExecutionContext_GetName
func (*ImmutableExecutionContext) OnGetNamespace ¶
func (_m *ImmutableExecutionContext) OnGetNamespace() *ImmutableExecutionContext_GetNamespace
func (*ImmutableExecutionContext) OnGetNamespaceMatch ¶
func (_m *ImmutableExecutionContext) OnGetNamespaceMatch(matchers ...interface{}) *ImmutableExecutionContext_GetNamespace
func (*ImmutableExecutionContext) OnGetOnFailurePolicy ¶
func (_m *ImmutableExecutionContext) OnGetOnFailurePolicy() *ImmutableExecutionContext_GetOnFailurePolicy
func (*ImmutableExecutionContext) OnGetOnFailurePolicyMatch ¶
func (_m *ImmutableExecutionContext) OnGetOnFailurePolicyMatch(matchers ...interface{}) *ImmutableExecutionContext_GetOnFailurePolicy
func (*ImmutableExecutionContext) OnGetOwnerReference ¶
func (_m *ImmutableExecutionContext) OnGetOwnerReference() *ImmutableExecutionContext_GetOwnerReference
func (*ImmutableExecutionContext) OnGetOwnerReferenceMatch ¶
func (_m *ImmutableExecutionContext) OnGetOwnerReferenceMatch(matchers ...interface{}) *ImmutableExecutionContext_GetOwnerReference
func (*ImmutableExecutionContext) OnGetRawOutputDataConfig ¶
func (_m *ImmutableExecutionContext) OnGetRawOutputDataConfig() *ImmutableExecutionContext_GetRawOutputDataConfig
func (*ImmutableExecutionContext) OnGetRawOutputDataConfigMatch ¶
func (_m *ImmutableExecutionContext) OnGetRawOutputDataConfigMatch(matchers ...interface{}) *ImmutableExecutionContext_GetRawOutputDataConfig
func (*ImmutableExecutionContext) OnGetSecurityContext ¶
func (_m *ImmutableExecutionContext) OnGetSecurityContext() *ImmutableExecutionContext_GetSecurityContext
func (*ImmutableExecutionContext) OnGetSecurityContextMatch ¶
func (_m *ImmutableExecutionContext) OnGetSecurityContextMatch(matchers ...interface{}) *ImmutableExecutionContext_GetSecurityContext
func (*ImmutableExecutionContext) OnGetServiceAccountName ¶
func (_m *ImmutableExecutionContext) OnGetServiceAccountName() *ImmutableExecutionContext_GetServiceAccountName
func (*ImmutableExecutionContext) OnGetServiceAccountNameMatch ¶
func (_m *ImmutableExecutionContext) OnGetServiceAccountNameMatch(matchers ...interface{}) *ImmutableExecutionContext_GetServiceAccountName
func (*ImmutableExecutionContext) OnIsInterruptible ¶
func (_m *ImmutableExecutionContext) OnIsInterruptible() *ImmutableExecutionContext_IsInterruptible
func (*ImmutableExecutionContext) OnIsInterruptibleMatch ¶
func (_m *ImmutableExecutionContext) OnIsInterruptibleMatch(matchers ...interface{}) *ImmutableExecutionContext_IsInterruptible
type ImmutableExecutionContext_GetAnnotations ¶
func (ImmutableExecutionContext_GetAnnotations) Return ¶
func (_m ImmutableExecutionContext_GetAnnotations) Return(_a0 map[string]string) *ImmutableExecutionContext_GetAnnotations
type ImmutableExecutionContext_GetCreationTimestamp ¶
func (ImmutableExecutionContext_GetCreationTimestamp) Return ¶
func (_m ImmutableExecutionContext_GetCreationTimestamp) Return(_a0 v1.Time) *ImmutableExecutionContext_GetCreationTimestamp
type ImmutableExecutionContext_GetDefinitionVersion ¶
type ImmutableExecutionContext_GetEventVersion ¶
func (ImmutableExecutionContext_GetEventVersion) Return ¶
func (_m ImmutableExecutionContext_GetEventVersion) Return(_a0 v1alpha1.EventVersion) *ImmutableExecutionContext_GetEventVersion
type ImmutableExecutionContext_GetExecutionConfig ¶
type ImmutableExecutionContext_GetExecutionID ¶
type ImmutableExecutionContext_GetID ¶
func (ImmutableExecutionContext_GetID) Return ¶
func (_m ImmutableExecutionContext_GetID) Return(_a0 string) *ImmutableExecutionContext_GetID
type ImmutableExecutionContext_GetK8sWorkflowID ¶
func (ImmutableExecutionContext_GetK8sWorkflowID) Return ¶
func (_m ImmutableExecutionContext_GetK8sWorkflowID) Return(_a0 types.NamespacedName) *ImmutableExecutionContext_GetK8sWorkflowID
type ImmutableExecutionContext_GetLabels ¶
func (ImmutableExecutionContext_GetLabels) Return ¶
func (_m ImmutableExecutionContext_GetLabels) Return(_a0 map[string]string) *ImmutableExecutionContext_GetLabels
type ImmutableExecutionContext_GetName ¶
func (ImmutableExecutionContext_GetName) Return ¶
func (_m ImmutableExecutionContext_GetName) Return(_a0 string) *ImmutableExecutionContext_GetName
type ImmutableExecutionContext_GetNamespace ¶
func (ImmutableExecutionContext_GetNamespace) Return ¶
func (_m ImmutableExecutionContext_GetNamespace) Return(_a0 string) *ImmutableExecutionContext_GetNamespace
type ImmutableExecutionContext_GetOnFailurePolicy ¶
type ImmutableExecutionContext_GetOwnerReference ¶
func (ImmutableExecutionContext_GetOwnerReference) Return ¶
func (_m ImmutableExecutionContext_GetOwnerReference) Return(_a0 v1.OwnerReference) *ImmutableExecutionContext_GetOwnerReference
type ImmutableExecutionContext_GetRawOutputDataConfig ¶
type ImmutableExecutionContext_GetSecurityContext ¶
type ImmutableExecutionContext_GetServiceAccountName ¶
func (ImmutableExecutionContext_GetServiceAccountName) Return ¶
func (_m ImmutableExecutionContext_GetServiceAccountName) Return(_a0 string) *ImmutableExecutionContext_GetServiceAccountName
type ImmutableExecutionContext_IsInterruptible ¶
func (ImmutableExecutionContext_IsInterruptible) Return ¶
func (_m ImmutableExecutionContext_IsInterruptible) Return(_a0 bool) *ImmutableExecutionContext_IsInterruptible
type ImmutableParentInfo ¶
ImmutableParentInfo is an autogenerated mock type for the ImmutableParentInfo type
func (*ImmutableParentInfo) CurrentAttempt ¶
func (_m *ImmutableParentInfo) CurrentAttempt() uint32
CurrentAttempt provides a mock function with given fields:
func (*ImmutableParentInfo) GetUniqueID ¶
func (_m *ImmutableParentInfo) GetUniqueID() string
GetUniqueID provides a mock function with given fields:
func (*ImmutableParentInfo) IsInDynamicChain ¶ added in v1.13.0
func (_m *ImmutableParentInfo) IsInDynamicChain() bool
IsInDynamicChain provides a mock function with given fields:
func (*ImmutableParentInfo) OnCurrentAttempt ¶
func (_m *ImmutableParentInfo) OnCurrentAttempt() *ImmutableParentInfo_CurrentAttempt
func (*ImmutableParentInfo) OnCurrentAttemptMatch ¶
func (_m *ImmutableParentInfo) OnCurrentAttemptMatch(matchers ...interface{}) *ImmutableParentInfo_CurrentAttempt
func (*ImmutableParentInfo) OnGetUniqueID ¶
func (_m *ImmutableParentInfo) OnGetUniqueID() *ImmutableParentInfo_GetUniqueID
func (*ImmutableParentInfo) OnGetUniqueIDMatch ¶
func (_m *ImmutableParentInfo) OnGetUniqueIDMatch(matchers ...interface{}) *ImmutableParentInfo_GetUniqueID
func (*ImmutableParentInfo) OnIsInDynamicChain ¶ added in v1.13.0
func (_m *ImmutableParentInfo) OnIsInDynamicChain() *ImmutableParentInfo_IsInDynamicChain
func (*ImmutableParentInfo) OnIsInDynamicChainMatch ¶ added in v1.13.0
func (_m *ImmutableParentInfo) OnIsInDynamicChainMatch(matchers ...interface{}) *ImmutableParentInfo_IsInDynamicChain
type ImmutableParentInfo_CurrentAttempt ¶
func (ImmutableParentInfo_CurrentAttempt) Return ¶
func (_m ImmutableParentInfo_CurrentAttempt) Return(_a0 uint32) *ImmutableParentInfo_CurrentAttempt
type ImmutableParentInfo_GetUniqueID ¶
func (ImmutableParentInfo_GetUniqueID) Return ¶
func (_m ImmutableParentInfo_GetUniqueID) Return(_a0 string) *ImmutableParentInfo_GetUniqueID
type ImmutableParentInfo_IsInDynamicChain ¶ added in v1.13.0
func (ImmutableParentInfo_IsInDynamicChain) Return ¶ added in v1.13.0
func (_m ImmutableParentInfo_IsInDynamicChain) Return(_a0 bool) *ImmutableParentInfo_IsInDynamicChain
type NodeLookup ¶
NodeLookup is an autogenerated mock type for the NodeLookup type
func (*NodeLookup) FromNode ¶
func (_m *NodeLookup) FromNode(id string) ([]string, error)
FromNode provides a mock function with given fields: id
func (*NodeLookup) GetNode ¶
func (_m *NodeLookup) GetNode(nodeID string) (v1alpha1.ExecutableNode, bool)
GetNode provides a mock function with given fields: nodeID
func (*NodeLookup) GetNodeExecutionStatus ¶
func (_m *NodeLookup) GetNodeExecutionStatus(ctx context.Context, id string) v1alpha1.ExecutableNodeStatus
GetNodeExecutionStatus provides a mock function with given fields: ctx, id
func (*NodeLookup) OnFromNode ¶
func (_m *NodeLookup) OnFromNode(id string) *NodeLookup_FromNode
func (*NodeLookup) OnFromNodeMatch ¶
func (_m *NodeLookup) OnFromNodeMatch(matchers ...interface{}) *NodeLookup_FromNode
func (*NodeLookup) OnGetNode ¶
func (_m *NodeLookup) OnGetNode(nodeID string) *NodeLookup_GetNode
func (*NodeLookup) OnGetNodeExecutionStatus ¶
func (_m *NodeLookup) OnGetNodeExecutionStatus(ctx context.Context, id string) *NodeLookup_GetNodeExecutionStatus
func (*NodeLookup) OnGetNodeExecutionStatusMatch ¶
func (_m *NodeLookup) OnGetNodeExecutionStatusMatch(matchers ...interface{}) *NodeLookup_GetNodeExecutionStatus
func (*NodeLookup) OnGetNodeMatch ¶
func (_m *NodeLookup) OnGetNodeMatch(matchers ...interface{}) *NodeLookup_GetNode
func (*NodeLookup) OnToNode ¶
func (_m *NodeLookup) OnToNode(id string) *NodeLookup_ToNode
func (*NodeLookup) OnToNodeMatch ¶
func (_m *NodeLookup) OnToNodeMatch(matchers ...interface{}) *NodeLookup_ToNode
type NodeLookup_FromNode ¶
func (NodeLookup_FromNode) Return ¶
func (_m NodeLookup_FromNode) Return(_a0 []string, _a1 error) *NodeLookup_FromNode
type NodeLookup_GetNode ¶
func (NodeLookup_GetNode) Return ¶
func (_m NodeLookup_GetNode) Return(_a0 v1alpha1.ExecutableNode, _a1 bool) *NodeLookup_GetNode
type NodeLookup_GetNodeExecutionStatus ¶
func (NodeLookup_GetNodeExecutionStatus) Return ¶
func (_m NodeLookup_GetNodeExecutionStatus) Return(_a0 v1alpha1.ExecutableNodeStatus) *NodeLookup_GetNodeExecutionStatus
type NodeLookup_ToNode ¶
func (NodeLookup_ToNode) Return ¶
func (_m NodeLookup_ToNode) Return(_a0 []string, _a1 error) *NodeLookup_ToNode
type ParentInfoGetter ¶
ParentInfoGetter is an autogenerated mock type for the ParentInfoGetter type
func (*ParentInfoGetter) GetParentInfo ¶
func (_m *ParentInfoGetter) GetParentInfo() executors.ImmutableParentInfo
GetParentInfo provides a mock function with given fields:
func (*ParentInfoGetter) OnGetParentInfo ¶
func (_m *ParentInfoGetter) OnGetParentInfo() *ParentInfoGetter_GetParentInfo
func (*ParentInfoGetter) OnGetParentInfoMatch ¶
func (_m *ParentInfoGetter) OnGetParentInfoMatch(matchers ...interface{}) *ParentInfoGetter_GetParentInfo
type ParentInfoGetter_GetParentInfo ¶
func (ParentInfoGetter_GetParentInfo) Return ¶
func (_m ParentInfoGetter_GetParentInfo) Return(_a0 executors.ImmutableParentInfo) *ParentInfoGetter_GetParentInfo
type SubWorkflowGetter ¶
SubWorkflowGetter is an autogenerated mock type for the SubWorkflowGetter type
func (*SubWorkflowGetter) FindSubWorkflow ¶
func (_m *SubWorkflowGetter) FindSubWorkflow(subID string) v1alpha1.ExecutableSubWorkflow
FindSubWorkflow provides a mock function with given fields: subID
func (*SubWorkflowGetter) OnFindSubWorkflow ¶
func (_m *SubWorkflowGetter) OnFindSubWorkflow(subID string) *SubWorkflowGetter_FindSubWorkflow
func (*SubWorkflowGetter) OnFindSubWorkflowMatch ¶
func (_m *SubWorkflowGetter) OnFindSubWorkflowMatch(matchers ...interface{}) *SubWorkflowGetter_FindSubWorkflow
type SubWorkflowGetter_FindSubWorkflow ¶
func (SubWorkflowGetter_FindSubWorkflow) Return ¶
func (_m SubWorkflowGetter_FindSubWorkflow) Return(_a0 v1alpha1.ExecutableSubWorkflow) *SubWorkflowGetter_FindSubWorkflow
type TaskDetailsGetter ¶
TaskDetailsGetter is an autogenerated mock type for the TaskDetailsGetter type
func (*TaskDetailsGetter) GetTask ¶
func (_m *TaskDetailsGetter) GetTask(id string) (v1alpha1.ExecutableTask, error)
GetTask provides a mock function with given fields: id
func (*TaskDetailsGetter) OnGetTask ¶
func (_m *TaskDetailsGetter) OnGetTask(id string) *TaskDetailsGetter_GetTask
func (*TaskDetailsGetter) OnGetTaskMatch ¶
func (_m *TaskDetailsGetter) OnGetTaskMatch(matchers ...interface{}) *TaskDetailsGetter_GetTask
type TaskDetailsGetter_GetTask ¶
func (TaskDetailsGetter_GetTask) Return ¶
func (_m TaskDetailsGetter_GetTask) Return(_a0 v1alpha1.ExecutableTask, _a1 error) *TaskDetailsGetter_GetTask
type Workflow ¶
Workflow is an autogenerated mock type for the Workflow type
func (*Workflow) HandleAbortedWorkflow ¶
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 ¶
HandleFlyteWorkflow provides a mock function with given fields: ctx, w
func (*Workflow) Initialize ¶
Initialize provides a mock function with given fields: ctx
func (*Workflow) OnHandleAbortedWorkflow ¶
func (_m *Workflow) OnHandleAbortedWorkflow(ctx context.Context, w *v1alpha1.FlyteWorkflow, maxRetries uint32) *Workflow_HandleAbortedWorkflow
func (*Workflow) OnHandleAbortedWorkflowMatch ¶
func (_m *Workflow) OnHandleAbortedWorkflowMatch(matchers ...interface{}) *Workflow_HandleAbortedWorkflow
func (*Workflow) OnHandleFlyteWorkflow ¶
func (_m *Workflow) OnHandleFlyteWorkflow(ctx context.Context, w *v1alpha1.FlyteWorkflow) *Workflow_HandleFlyteWorkflow
func (*Workflow) OnHandleFlyteWorkflowMatch ¶
func (_m *Workflow) OnHandleFlyteWorkflowMatch(matchers ...interface{}) *Workflow_HandleFlyteWorkflow
func (*Workflow) OnInitialize ¶
func (_m *Workflow) OnInitialize(ctx context.Context) *Workflow_Initialize
func (*Workflow) OnInitializeMatch ¶
func (_m *Workflow) OnInitializeMatch(matchers ...interface{}) *Workflow_Initialize
type Workflow_HandleAbortedWorkflow ¶
func (Workflow_HandleAbortedWorkflow) Return ¶
func (_m Workflow_HandleAbortedWorkflow) Return(_a0 error) *Workflow_HandleAbortedWorkflow
type Workflow_HandleFlyteWorkflow ¶
func (Workflow_HandleFlyteWorkflow) Return ¶
func (_m Workflow_HandleFlyteWorkflow) Return(_a0 error) *Workflow_HandleFlyteWorkflow
type Workflow_Initialize ¶
func (Workflow_Initialize) Return ¶
func (_m Workflow_Initialize) Return(_a0 error) *Workflow_Initialize