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 ClientBuilder
- func (_m *ClientBuilder) Build(_a0 cache.Cache, config *rest.Config, options client.Options) (client.Client, error)
- func (_m *ClientBuilder) OnBuild(_a0 cache.Cache, config *rest.Config, options client.Options) *ClientBuilder_Build
- func (_m *ClientBuilder) OnBuildMatch(matchers ...interface{}) *ClientBuilder_Build
- func (_m *ClientBuilder) OnWithUncached(objs ...client.Object) *ClientBuilder_WithUncached
- func (_m *ClientBuilder) OnWithUncachedMatch(matchers ...interface{}) *ClientBuilder_WithUncached
- func (_m *ClientBuilder) WithUncached(objs ...client.Object) executors.ClientBuilder
- type ClientBuilder_Build
- type ClientBuilder_WithUncached
- 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) CurrentParallelism() uint32
- func (_m *ExecutionContext) FindSubWorkflow(subID string) v1alpha1.ExecutableSubWorkflow
- func (_m *ExecutionContext) GetAnnotations() map[string]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) IncrementParallelism() uint32
- func (_m *ExecutionContext) IsInterruptible() bool
- func (_m *ExecutionContext) OnCurrentParallelism() *ExecutionContext_CurrentParallelism
- func (_m *ExecutionContext) OnCurrentParallelismMatch(matchers ...interface{}) *ExecutionContext_CurrentParallelism
- 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) OnGetDefinitionVersion() *ExecutionContext_GetDefinitionVersion
- func (_m *ExecutionContext) OnGetDefinitionVersionMatch(matchers ...interface{}) *ExecutionContext_GetDefinitionVersion
- func (_m *ExecutionContext) OnGetEventVersion() *ExecutionContext_GetEventVersion
- func (_m *ExecutionContext) OnGetEventVersionMatch(matchers ...interface{}) *ExecutionContext_GetEventVersion
- func (_m *ExecutionContext) OnGetExecutionConfig() *ExecutionContext_GetExecutionConfig
- func (_m *ExecutionContext) OnGetExecutionConfigMatch(matchers ...interface{}) *ExecutionContext_GetExecutionConfig
- 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) OnGetSecurityContext() *ExecutionContext_GetSecurityContext
- func (_m *ExecutionContext) OnGetSecurityContextMatch(matchers ...interface{}) *ExecutionContext_GetSecurityContext
- 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) OnIncrementParallelism() *ExecutionContext_IncrementParallelism
- func (_m *ExecutionContext) OnIncrementParallelismMatch(matchers ...interface{}) *ExecutionContext_IncrementParallelism
- func (_m *ExecutionContext) OnIsInterruptible() *ExecutionContext_IsInterruptible
- func (_m *ExecutionContext) OnIsInterruptibleMatch(matchers ...interface{}) *ExecutionContext_IsInterruptible
- type ExecutionContext_CurrentParallelism
- type ExecutionContext_FindSubWorkflow
- type ExecutionContext_GetAnnotations
- type ExecutionContext_GetCreationTimestamp
- type ExecutionContext_GetDefinitionVersion
- type ExecutionContext_GetEventVersion
- type ExecutionContext_GetExecutionConfig
- 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_GetSecurityContext
- type ExecutionContext_GetServiceAccountName
- type ExecutionContext_GetTask
- type ExecutionContext_IncrementParallelism
- type ExecutionContext_IsInterruptible
- 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) (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) 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 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 ¶ 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 ClientBuilder ¶ added in v1.1.26
ClientBuilder is an autogenerated mock type for the ClientBuilder type
func (*ClientBuilder) Build ¶ added in v1.1.26
func (_m *ClientBuilder) Build(_a0 cache.Cache, config *rest.Config, options client.Options) (client.Client, error)
Build provides a mock function with given fields: _a0, config, options
func (*ClientBuilder) OnBuild ¶ added in v1.1.26
func (_m *ClientBuilder) OnBuild(_a0 cache.Cache, config *rest.Config, options client.Options) *ClientBuilder_Build
func (*ClientBuilder) OnBuildMatch ¶ added in v1.1.26
func (_m *ClientBuilder) OnBuildMatch(matchers ...interface{}) *ClientBuilder_Build
func (*ClientBuilder) OnWithUncached ¶ added in v1.1.26
func (_m *ClientBuilder) OnWithUncached(objs ...client.Object) *ClientBuilder_WithUncached
func (*ClientBuilder) OnWithUncachedMatch ¶ added in v1.1.26
func (_m *ClientBuilder) OnWithUncachedMatch(matchers ...interface{}) *ClientBuilder_WithUncached
func (*ClientBuilder) WithUncached ¶ added in v1.1.26
func (_m *ClientBuilder) WithUncached(objs ...client.Object) executors.ClientBuilder
WithUncached provides a mock function with given fields: objs
type ClientBuilder_Build ¶ added in v1.1.26
func (ClientBuilder_Build) Return ¶ added in v1.1.26
func (_m ClientBuilder_Build) Return(_a0 client.Client, _a1 error) *ClientBuilder_Build
type ClientBuilder_WithUncached ¶ added in v1.1.26
func (ClientBuilder_WithUncached) Return ¶ added in v1.1.26
func (_m ClientBuilder_WithUncached) Return(_a0 executors.ClientBuilder) *ClientBuilder_WithUncached
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 ControlFlow ¶ added in v0.7.5
ControlFlow is an autogenerated mock type for the ControlFlow type
func (*ControlFlow) CurrentParallelism ¶ added in v0.7.5
func (_m *ControlFlow) CurrentParallelism() uint32
CurrentParallelism provides a mock function with given fields:
func (*ControlFlow) IncrementParallelism ¶ added in v0.7.5
func (_m *ControlFlow) IncrementParallelism() uint32
IncrementParallelism provides a mock function with given fields:
func (*ControlFlow) OnCurrentParallelism ¶ added in v0.7.5
func (_m *ControlFlow) OnCurrentParallelism() *ControlFlow_CurrentParallelism
func (*ControlFlow) OnCurrentParallelismMatch ¶ added in v0.7.5
func (_m *ControlFlow) OnCurrentParallelismMatch(matchers ...interface{}) *ControlFlow_CurrentParallelism
func (*ControlFlow) OnIncrementParallelism ¶ added in v0.7.5
func (_m *ControlFlow) OnIncrementParallelism() *ControlFlow_IncrementParallelism
func (*ControlFlow) OnIncrementParallelismMatch ¶ added in v0.7.5
func (_m *ControlFlow) OnIncrementParallelismMatch(matchers ...interface{}) *ControlFlow_IncrementParallelism
type ControlFlow_CurrentParallelism ¶ added in v0.7.5
func (ControlFlow_CurrentParallelism) Return ¶ added in v0.7.5
func (_m ControlFlow_CurrentParallelism) Return(_a0 uint32) *ControlFlow_CurrentParallelism
type ControlFlow_IncrementParallelism ¶ added in v0.7.5
func (ControlFlow_IncrementParallelism) Return ¶ added in v0.7.5
func (_m ControlFlow_IncrementParallelism) Return(_a0 uint32) *ControlFlow_IncrementParallelism
type DAGStructure ¶ added in v0.7.0
DAGStructure is an autogenerated mock type for the DAGStructure type
func (*DAGStructure) FromNode ¶ added in v0.7.0
func (_m *DAGStructure) FromNode(id string) ([]string, error)
FromNode provides a mock function with given fields: id
func (*DAGStructure) OnFromNode ¶ added in v0.7.0
func (_m *DAGStructure) OnFromNode(id string) *DAGStructure_FromNode
func (*DAGStructure) OnFromNodeMatch ¶ added in v0.7.0
func (_m *DAGStructure) OnFromNodeMatch(matchers ...interface{}) *DAGStructure_FromNode
func (*DAGStructure) OnToNode ¶ added in v0.7.0
func (_m *DAGStructure) OnToNode(id string) *DAGStructure_ToNode
func (*DAGStructure) OnToNodeMatch ¶ added in v0.7.0
func (_m *DAGStructure) OnToNodeMatch(matchers ...interface{}) *DAGStructure_ToNode
type DAGStructureWithStartNode ¶ added in v0.7.0
DAGStructureWithStartNode is an autogenerated mock type for the DAGStructureWithStartNode type
func (*DAGStructureWithStartNode) FromNode ¶ added in v0.7.0
func (_m *DAGStructureWithStartNode) FromNode(id string) ([]string, error)
FromNode provides a mock function with given fields: id
func (*DAGStructureWithStartNode) OnFromNode ¶ added in v0.7.0
func (_m *DAGStructureWithStartNode) OnFromNode(id string) *DAGStructureWithStartNode_FromNode
func (*DAGStructureWithStartNode) OnFromNodeMatch ¶ added in v0.7.0
func (_m *DAGStructureWithStartNode) OnFromNodeMatch(matchers ...interface{}) *DAGStructureWithStartNode_FromNode
func (*DAGStructureWithStartNode) OnStartNode ¶ added in v0.7.0
func (_m *DAGStructureWithStartNode) OnStartNode() *DAGStructureWithStartNode_StartNode
func (*DAGStructureWithStartNode) OnStartNodeMatch ¶ added in v0.7.0
func (_m *DAGStructureWithStartNode) OnStartNodeMatch(matchers ...interface{}) *DAGStructureWithStartNode_StartNode
func (*DAGStructureWithStartNode) OnToNode ¶ added in v0.7.0
func (_m *DAGStructureWithStartNode) OnToNode(id string) *DAGStructureWithStartNode_ToNode
func (*DAGStructureWithStartNode) OnToNodeMatch ¶ added in v0.7.0
func (_m *DAGStructureWithStartNode) OnToNodeMatch(matchers ...interface{}) *DAGStructureWithStartNode_ToNode
func (*DAGStructureWithStartNode) StartNode ¶ added in v0.7.0
func (_m *DAGStructureWithStartNode) StartNode() v1alpha1.ExecutableNode
StartNode provides a mock function with given fields:
type DAGStructureWithStartNode_FromNode ¶ added in v0.7.0
func (DAGStructureWithStartNode_FromNode) Return ¶ added in v0.7.0
func (_m DAGStructureWithStartNode_FromNode) Return(_a0 []string, _a1 error) *DAGStructureWithStartNode_FromNode
type DAGStructureWithStartNode_StartNode ¶ added in v0.7.0
func (DAGStructureWithStartNode_StartNode) Return ¶ added in v0.7.0
func (_m DAGStructureWithStartNode_StartNode) Return(_a0 v1alpha1.ExecutableNode) *DAGStructureWithStartNode_StartNode
type DAGStructureWithStartNode_ToNode ¶ added in v0.7.0
func (DAGStructureWithStartNode_ToNode) Return ¶ added in v0.7.0
func (_m DAGStructureWithStartNode_ToNode) Return(_a0 []string, _a1 error) *DAGStructureWithStartNode_ToNode
type DAGStructure_FromNode ¶ added in v0.7.0
func (DAGStructure_FromNode) Return ¶ added in v0.7.0
func (_m DAGStructure_FromNode) Return(_a0 []string, _a1 error) *DAGStructure_FromNode
type DAGStructure_ToNode ¶ added in v0.7.0
func (DAGStructure_ToNode) Return ¶ added in v0.7.0
func (_m DAGStructure_ToNode) Return(_a0 []string, _a1 error) *DAGStructure_ToNode
type ExecutionContext ¶ added in v0.7.0
ExecutionContext is an autogenerated mock type for the ExecutionContext type
func (*ExecutionContext) CurrentParallelism ¶ added in v0.7.5
func (_m *ExecutionContext) CurrentParallelism() uint32
CurrentParallelism provides a mock function with given fields:
func (*ExecutionContext) FindSubWorkflow ¶ added in v0.7.0
func (_m *ExecutionContext) FindSubWorkflow(subID string) v1alpha1.ExecutableSubWorkflow
FindSubWorkflow provides a mock function with given fields: subID
func (*ExecutionContext) GetAnnotations ¶ added in v0.7.0
func (_m *ExecutionContext) GetAnnotations() map[string]string
GetAnnotations provides a mock function with given fields:
func (*ExecutionContext) GetCreationTimestamp ¶ added in v0.7.0
func (_m *ExecutionContext) GetCreationTimestamp() v1.Time
GetCreationTimestamp provides a mock function with given fields:
func (*ExecutionContext) GetDefinitionVersion ¶ added in v1.1.33
func (_m *ExecutionContext) GetDefinitionVersion() v1alpha1.WorkflowDefinitionVersion
GetDefinitionVersion provides a mock function with given fields:
func (*ExecutionContext) GetEventVersion ¶ added in v0.7.0
func (_m *ExecutionContext) GetEventVersion() v1alpha1.EventVersion
GetEventVersion provides a mock function with given fields:
func (*ExecutionContext) GetExecutionConfig ¶ added in v0.7.0
func (_m *ExecutionContext) GetExecutionConfig() v1alpha1.ExecutionConfig
GetExecutionConfig provides a mock function with given fields:
func (*ExecutionContext) GetExecutionID ¶ added in v0.7.0
func (_m *ExecutionContext) GetExecutionID() v1alpha1.WorkflowExecutionIdentifier
GetExecutionID provides a mock function with given fields:
func (*ExecutionContext) GetID ¶ added in v0.7.0
func (_m *ExecutionContext) GetID() string
GetID provides a mock function with given fields:
func (*ExecutionContext) GetK8sWorkflowID ¶ added in v0.7.0
func (_m *ExecutionContext) GetK8sWorkflowID() types.NamespacedName
GetK8sWorkflowID provides a mock function with given fields:
func (*ExecutionContext) GetLabels ¶ added in v0.7.0
func (_m *ExecutionContext) GetLabels() map[string]string
GetLabels provides a mock function with given fields:
func (*ExecutionContext) GetName ¶ added in v0.7.0
func (_m *ExecutionContext) GetName() string
GetName provides a mock function with given fields:
func (*ExecutionContext) GetNamespace ¶ added in v0.7.0
func (_m *ExecutionContext) GetNamespace() string
GetNamespace provides a mock function with given fields:
func (*ExecutionContext) GetOnFailurePolicy ¶ added in v0.7.0
func (_m *ExecutionContext) GetOnFailurePolicy() v1alpha1.WorkflowOnFailurePolicy
GetOnFailurePolicy provides a mock function with given fields:
func (*ExecutionContext) GetOwnerReference ¶ added in v0.7.0
func (_m *ExecutionContext) GetOwnerReference() v1.OwnerReference
GetOwnerReference provides a mock function with given fields:
func (*ExecutionContext) GetParentInfo ¶ added in v0.7.0
func (_m *ExecutionContext) GetParentInfo() executors.ImmutableParentInfo
GetParentInfo provides a mock function with given fields:
func (*ExecutionContext) GetRawOutputDataConfig ¶ added in v0.7.0
func (_m *ExecutionContext) GetRawOutputDataConfig() v1alpha1.RawOutputDataConfig
GetRawOutputDataConfig provides a mock function with given fields:
func (*ExecutionContext) GetSecurityContext ¶ added in v0.7.6
func (_m *ExecutionContext) GetSecurityContext() core.SecurityContext
GetSecurityContext provides a mock function with given fields:
func (*ExecutionContext) GetServiceAccountName ¶ added in v0.7.0
func (_m *ExecutionContext) GetServiceAccountName() string
GetServiceAccountName provides a mock function with given fields:
func (*ExecutionContext) GetTask ¶ added in v0.7.0
func (_m *ExecutionContext) GetTask(id string) (v1alpha1.ExecutableTask, error)
GetTask provides a mock function with given fields: id
func (*ExecutionContext) IncrementParallelism ¶ added in v0.7.5
func (_m *ExecutionContext) IncrementParallelism() uint32
IncrementParallelism provides a mock function with given fields:
func (*ExecutionContext) IsInterruptible ¶ added in v0.7.0
func (_m *ExecutionContext) IsInterruptible() bool
IsInterruptible provides a mock function with given fields:
func (*ExecutionContext) OnCurrentParallelism ¶ added in v0.7.5
func (_m *ExecutionContext) OnCurrentParallelism() *ExecutionContext_CurrentParallelism
func (*ExecutionContext) OnCurrentParallelismMatch ¶ added in v0.7.5
func (_m *ExecutionContext) OnCurrentParallelismMatch(matchers ...interface{}) *ExecutionContext_CurrentParallelism
func (*ExecutionContext) OnFindSubWorkflow ¶ added in v0.7.0
func (_m *ExecutionContext) OnFindSubWorkflow(subID string) *ExecutionContext_FindSubWorkflow
func (*ExecutionContext) OnFindSubWorkflowMatch ¶ added in v0.7.0
func (_m *ExecutionContext) OnFindSubWorkflowMatch(matchers ...interface{}) *ExecutionContext_FindSubWorkflow
func (*ExecutionContext) OnGetAnnotations ¶ added in v0.7.0
func (_m *ExecutionContext) OnGetAnnotations() *ExecutionContext_GetAnnotations
func (*ExecutionContext) OnGetAnnotationsMatch ¶ added in v0.7.0
func (_m *ExecutionContext) OnGetAnnotationsMatch(matchers ...interface{}) *ExecutionContext_GetAnnotations
func (*ExecutionContext) OnGetCreationTimestamp ¶ added in v0.7.0
func (_m *ExecutionContext) OnGetCreationTimestamp() *ExecutionContext_GetCreationTimestamp
func (*ExecutionContext) OnGetCreationTimestampMatch ¶ added in v0.7.0
func (_m *ExecutionContext) OnGetCreationTimestampMatch(matchers ...interface{}) *ExecutionContext_GetCreationTimestamp
func (*ExecutionContext) OnGetDefinitionVersion ¶ added in v1.1.33
func (_m *ExecutionContext) OnGetDefinitionVersion() *ExecutionContext_GetDefinitionVersion
func (*ExecutionContext) OnGetDefinitionVersionMatch ¶ added in v1.1.33
func (_m *ExecutionContext) OnGetDefinitionVersionMatch(matchers ...interface{}) *ExecutionContext_GetDefinitionVersion
func (*ExecutionContext) OnGetEventVersion ¶ added in v0.7.0
func (_m *ExecutionContext) OnGetEventVersion() *ExecutionContext_GetEventVersion
func (*ExecutionContext) OnGetEventVersionMatch ¶ added in v0.7.0
func (_m *ExecutionContext) OnGetEventVersionMatch(matchers ...interface{}) *ExecutionContext_GetEventVersion
func (*ExecutionContext) OnGetExecutionConfig ¶ added in v0.7.0
func (_m *ExecutionContext) OnGetExecutionConfig() *ExecutionContext_GetExecutionConfig
func (*ExecutionContext) OnGetExecutionConfigMatch ¶ added in v0.7.0
func (_m *ExecutionContext) OnGetExecutionConfigMatch(matchers ...interface{}) *ExecutionContext_GetExecutionConfig
func (*ExecutionContext) OnGetExecutionID ¶ added in v0.7.0
func (_m *ExecutionContext) OnGetExecutionID() *ExecutionContext_GetExecutionID
func (*ExecutionContext) OnGetExecutionIDMatch ¶ added in v0.7.0
func (_m *ExecutionContext) OnGetExecutionIDMatch(matchers ...interface{}) *ExecutionContext_GetExecutionID
func (*ExecutionContext) OnGetID ¶ added in v0.7.0
func (_m *ExecutionContext) OnGetID() *ExecutionContext_GetID
func (*ExecutionContext) OnGetIDMatch ¶ added in v0.7.0
func (_m *ExecutionContext) OnGetIDMatch(matchers ...interface{}) *ExecutionContext_GetID
func (*ExecutionContext) OnGetK8sWorkflowID ¶ added in v0.7.0
func (_m *ExecutionContext) OnGetK8sWorkflowID() *ExecutionContext_GetK8sWorkflowID
func (*ExecutionContext) OnGetK8sWorkflowIDMatch ¶ added in v0.7.0
func (_m *ExecutionContext) OnGetK8sWorkflowIDMatch(matchers ...interface{}) *ExecutionContext_GetK8sWorkflowID
func (*ExecutionContext) OnGetLabels ¶ added in v0.7.0
func (_m *ExecutionContext) OnGetLabels() *ExecutionContext_GetLabels
func (*ExecutionContext) OnGetLabelsMatch ¶ added in v0.7.0
func (_m *ExecutionContext) OnGetLabelsMatch(matchers ...interface{}) *ExecutionContext_GetLabels
func (*ExecutionContext) OnGetName ¶ added in v0.7.0
func (_m *ExecutionContext) OnGetName() *ExecutionContext_GetName
func (*ExecutionContext) OnGetNameMatch ¶ added in v0.7.0
func (_m *ExecutionContext) OnGetNameMatch(matchers ...interface{}) *ExecutionContext_GetName
func (*ExecutionContext) OnGetNamespace ¶ added in v0.7.0
func (_m *ExecutionContext) OnGetNamespace() *ExecutionContext_GetNamespace
func (*ExecutionContext) OnGetNamespaceMatch ¶ added in v0.7.0
func (_m *ExecutionContext) OnGetNamespaceMatch(matchers ...interface{}) *ExecutionContext_GetNamespace
func (*ExecutionContext) OnGetOnFailurePolicy ¶ added in v0.7.0
func (_m *ExecutionContext) OnGetOnFailurePolicy() *ExecutionContext_GetOnFailurePolicy
func (*ExecutionContext) OnGetOnFailurePolicyMatch ¶ added in v0.7.0
func (_m *ExecutionContext) OnGetOnFailurePolicyMatch(matchers ...interface{}) *ExecutionContext_GetOnFailurePolicy
func (*ExecutionContext) OnGetOwnerReference ¶ added in v0.7.0
func (_m *ExecutionContext) OnGetOwnerReference() *ExecutionContext_GetOwnerReference
func (*ExecutionContext) OnGetOwnerReferenceMatch ¶ added in v0.7.0
func (_m *ExecutionContext) OnGetOwnerReferenceMatch(matchers ...interface{}) *ExecutionContext_GetOwnerReference
func (*ExecutionContext) OnGetParentInfo ¶ added in v0.7.0
func (_m *ExecutionContext) OnGetParentInfo() *ExecutionContext_GetParentInfo
func (*ExecutionContext) OnGetParentInfoMatch ¶ added in v0.7.0
func (_m *ExecutionContext) OnGetParentInfoMatch(matchers ...interface{}) *ExecutionContext_GetParentInfo
func (*ExecutionContext) OnGetRawOutputDataConfig ¶ added in v0.7.0
func (_m *ExecutionContext) OnGetRawOutputDataConfig() *ExecutionContext_GetRawOutputDataConfig
func (*ExecutionContext) OnGetRawOutputDataConfigMatch ¶ added in v0.7.0
func (_m *ExecutionContext) OnGetRawOutputDataConfigMatch(matchers ...interface{}) *ExecutionContext_GetRawOutputDataConfig
func (*ExecutionContext) OnGetSecurityContext ¶ added in v0.7.6
func (_m *ExecutionContext) OnGetSecurityContext() *ExecutionContext_GetSecurityContext
func (*ExecutionContext) OnGetSecurityContextMatch ¶ added in v0.7.6
func (_m *ExecutionContext) OnGetSecurityContextMatch(matchers ...interface{}) *ExecutionContext_GetSecurityContext
func (*ExecutionContext) OnGetServiceAccountName ¶ added in v0.7.0
func (_m *ExecutionContext) OnGetServiceAccountName() *ExecutionContext_GetServiceAccountName
func (*ExecutionContext) OnGetServiceAccountNameMatch ¶ added in v0.7.0
func (_m *ExecutionContext) OnGetServiceAccountNameMatch(matchers ...interface{}) *ExecutionContext_GetServiceAccountName
func (*ExecutionContext) OnGetTask ¶ added in v0.7.0
func (_m *ExecutionContext) OnGetTask(id string) *ExecutionContext_GetTask
func (*ExecutionContext) OnGetTaskMatch ¶ added in v0.7.0
func (_m *ExecutionContext) OnGetTaskMatch(matchers ...interface{}) *ExecutionContext_GetTask
func (*ExecutionContext) OnIncrementParallelism ¶ added in v0.7.5
func (_m *ExecutionContext) OnIncrementParallelism() *ExecutionContext_IncrementParallelism
func (*ExecutionContext) OnIncrementParallelismMatch ¶ added in v0.7.5
func (_m *ExecutionContext) OnIncrementParallelismMatch(matchers ...interface{}) *ExecutionContext_IncrementParallelism
func (*ExecutionContext) OnIsInterruptible ¶ added in v0.7.0
func (_m *ExecutionContext) OnIsInterruptible() *ExecutionContext_IsInterruptible
func (*ExecutionContext) OnIsInterruptibleMatch ¶ added in v0.7.0
func (_m *ExecutionContext) OnIsInterruptibleMatch(matchers ...interface{}) *ExecutionContext_IsInterruptible
type ExecutionContext_CurrentParallelism ¶ added in v0.7.5
func (ExecutionContext_CurrentParallelism) Return ¶ added in v0.7.5
func (_m ExecutionContext_CurrentParallelism) Return(_a0 uint32) *ExecutionContext_CurrentParallelism
type ExecutionContext_FindSubWorkflow ¶ added in v0.7.0
func (ExecutionContext_FindSubWorkflow) Return ¶ added in v0.7.0
func (_m ExecutionContext_FindSubWorkflow) Return(_a0 v1alpha1.ExecutableSubWorkflow) *ExecutionContext_FindSubWorkflow
type ExecutionContext_GetAnnotations ¶ added in v0.7.0
func (ExecutionContext_GetAnnotations) Return ¶ added in v0.7.0
func (_m ExecutionContext_GetAnnotations) Return(_a0 map[string]string) *ExecutionContext_GetAnnotations
type ExecutionContext_GetCreationTimestamp ¶ added in v0.7.0
func (ExecutionContext_GetCreationTimestamp) Return ¶ added in v0.7.0
func (_m ExecutionContext_GetCreationTimestamp) Return(_a0 v1.Time) *ExecutionContext_GetCreationTimestamp
type ExecutionContext_GetDefinitionVersion ¶ added in v1.1.33
type ExecutionContext_GetEventVersion ¶ added in v0.7.0
func (ExecutionContext_GetEventVersion) Return ¶ added in v0.7.0
func (_m ExecutionContext_GetEventVersion) Return(_a0 v1alpha1.EventVersion) *ExecutionContext_GetEventVersion
type ExecutionContext_GetExecutionConfig ¶ added in v0.7.0
func (ExecutionContext_GetExecutionConfig) Return ¶ added in v0.7.0
func (_m ExecutionContext_GetExecutionConfig) Return(_a0 v1alpha1.ExecutionConfig) *ExecutionContext_GetExecutionConfig
type ExecutionContext_GetExecutionID ¶ added in v0.7.0
func (ExecutionContext_GetExecutionID) Return ¶ added in v0.7.0
func (_m ExecutionContext_GetExecutionID) Return(_a0 v1alpha1.WorkflowExecutionIdentifier) *ExecutionContext_GetExecutionID
type ExecutionContext_GetID ¶ added in v0.7.0
func (ExecutionContext_GetID) Return ¶ added in v0.7.0
func (_m ExecutionContext_GetID) Return(_a0 string) *ExecutionContext_GetID
type ExecutionContext_GetK8sWorkflowID ¶ added in v0.7.0
func (ExecutionContext_GetK8sWorkflowID) Return ¶ added in v0.7.0
func (_m ExecutionContext_GetK8sWorkflowID) Return(_a0 types.NamespacedName) *ExecutionContext_GetK8sWorkflowID
type ExecutionContext_GetLabels ¶ added in v0.7.0
func (ExecutionContext_GetLabels) Return ¶ added in v0.7.0
func (_m ExecutionContext_GetLabels) Return(_a0 map[string]string) *ExecutionContext_GetLabels
type ExecutionContext_GetName ¶ added in v0.7.0
func (ExecutionContext_GetName) Return ¶ added in v0.7.0
func (_m ExecutionContext_GetName) Return(_a0 string) *ExecutionContext_GetName
type ExecutionContext_GetNamespace ¶ added in v0.7.0
func (ExecutionContext_GetNamespace) Return ¶ added in v0.7.0
func (_m ExecutionContext_GetNamespace) Return(_a0 string) *ExecutionContext_GetNamespace
type ExecutionContext_GetOnFailurePolicy ¶ added in v0.7.0
func (ExecutionContext_GetOnFailurePolicy) Return ¶ added in v0.7.0
func (_m ExecutionContext_GetOnFailurePolicy) Return(_a0 v1alpha1.WorkflowOnFailurePolicy) *ExecutionContext_GetOnFailurePolicy
type ExecutionContext_GetOwnerReference ¶ added in v0.7.0
func (ExecutionContext_GetOwnerReference) Return ¶ added in v0.7.0
func (_m ExecutionContext_GetOwnerReference) Return(_a0 v1.OwnerReference) *ExecutionContext_GetOwnerReference
type ExecutionContext_GetParentInfo ¶ added in v0.7.0
func (ExecutionContext_GetParentInfo) Return ¶ added in v0.7.0
func (_m ExecutionContext_GetParentInfo) Return(_a0 executors.ImmutableParentInfo) *ExecutionContext_GetParentInfo
type ExecutionContext_GetRawOutputDataConfig ¶ added in v0.7.0
type ExecutionContext_GetSecurityContext ¶ added in v0.7.6
func (ExecutionContext_GetSecurityContext) Return ¶ added in v0.7.6
func (_m ExecutionContext_GetSecurityContext) Return(_a0 core.SecurityContext) *ExecutionContext_GetSecurityContext
type ExecutionContext_GetServiceAccountName ¶ added in v0.7.0
func (ExecutionContext_GetServiceAccountName) Return ¶ added in v0.7.0
func (_m ExecutionContext_GetServiceAccountName) Return(_a0 string) *ExecutionContext_GetServiceAccountName
type ExecutionContext_GetTask ¶ added in v0.7.0
func (ExecutionContext_GetTask) Return ¶ added in v0.7.0
func (_m ExecutionContext_GetTask) Return(_a0 v1alpha1.ExecutableTask, _a1 error) *ExecutionContext_GetTask
type ExecutionContext_IncrementParallelism ¶ added in v0.7.5
func (ExecutionContext_IncrementParallelism) Return ¶ added in v0.7.5
func (_m ExecutionContext_IncrementParallelism) Return(_a0 uint32) *ExecutionContext_IncrementParallelism
type ExecutionContext_IsInterruptible ¶ added in v0.7.0
func (ExecutionContext_IsInterruptible) Return ¶ added in v0.7.0
func (_m ExecutionContext_IsInterruptible) Return(_a0 bool) *ExecutionContext_IsInterruptible
type FakeInformers ¶ added in v1.1.26
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 ¶ added in v1.1.26
func (*FakeInformers) GetInformerForKind ¶ added in v1.1.26
func (f *FakeInformers) GetInformerForKind(ctx context.Context, gvk schema.GroupVersionKind) (cache.Informer, error)
func (*FakeInformers) IndexField ¶ added in v1.1.26
func (f *FakeInformers) IndexField(ctx context.Context, obj client.Object, field string, extractValue client.IndexerFunc) error
func (*FakeInformers) List ¶ added in v1.1.26
func (f *FakeInformers) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error
func (*FakeInformers) Start ¶ added in v1.1.26
func (f *FakeInformers) Start(ctx context.Context) error
func (*FakeInformers) WaitForCacheSync ¶ added in v1.1.26
func (f *FakeInformers) WaitForCacheSync(ctx context.Context) bool
type ImmutableExecutionContext ¶ added in v0.7.0
ImmutableExecutionContext is an autogenerated mock type for the ImmutableExecutionContext type
func (*ImmutableExecutionContext) GetAnnotations ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) GetAnnotations() map[string]string
GetAnnotations provides a mock function with given fields:
func (*ImmutableExecutionContext) GetCreationTimestamp ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) GetCreationTimestamp() v1.Time
GetCreationTimestamp provides a mock function with given fields:
func (*ImmutableExecutionContext) GetDefinitionVersion ¶ added in v1.1.33
func (_m *ImmutableExecutionContext) GetDefinitionVersion() v1alpha1.WorkflowDefinitionVersion
GetDefinitionVersion provides a mock function with given fields:
func (*ImmutableExecutionContext) GetEventVersion ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) GetEventVersion() v1alpha1.EventVersion
GetEventVersion provides a mock function with given fields:
func (*ImmutableExecutionContext) GetExecutionConfig ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) GetExecutionConfig() v1alpha1.ExecutionConfig
GetExecutionConfig provides a mock function with given fields:
func (*ImmutableExecutionContext) GetExecutionID ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) GetExecutionID() v1alpha1.WorkflowExecutionIdentifier
GetExecutionID provides a mock function with given fields:
func (*ImmutableExecutionContext) GetID ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) GetID() string
GetID provides a mock function with given fields:
func (*ImmutableExecutionContext) GetK8sWorkflowID ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) GetK8sWorkflowID() types.NamespacedName
GetK8sWorkflowID provides a mock function with given fields:
func (*ImmutableExecutionContext) GetLabels ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) GetLabels() map[string]string
GetLabels provides a mock function with given fields:
func (*ImmutableExecutionContext) GetName ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) GetName() string
GetName provides a mock function with given fields:
func (*ImmutableExecutionContext) GetNamespace ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) GetNamespace() string
GetNamespace provides a mock function with given fields:
func (*ImmutableExecutionContext) GetOnFailurePolicy ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) GetOnFailurePolicy() v1alpha1.WorkflowOnFailurePolicy
GetOnFailurePolicy provides a mock function with given fields:
func (*ImmutableExecutionContext) GetOwnerReference ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) GetOwnerReference() v1.OwnerReference
GetOwnerReference provides a mock function with given fields:
func (*ImmutableExecutionContext) GetRawOutputDataConfig ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) GetRawOutputDataConfig() v1alpha1.RawOutputDataConfig
GetRawOutputDataConfig provides a mock function with given fields:
func (*ImmutableExecutionContext) GetSecurityContext ¶ added in v0.7.6
func (_m *ImmutableExecutionContext) GetSecurityContext() core.SecurityContext
GetSecurityContext provides a mock function with given fields:
func (*ImmutableExecutionContext) GetServiceAccountName ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) GetServiceAccountName() string
GetServiceAccountName provides a mock function with given fields:
func (*ImmutableExecutionContext) IsInterruptible ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) IsInterruptible() bool
IsInterruptible provides a mock function with given fields:
func (*ImmutableExecutionContext) OnGetAnnotations ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) OnGetAnnotations() *ImmutableExecutionContext_GetAnnotations
func (*ImmutableExecutionContext) OnGetAnnotationsMatch ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) OnGetAnnotationsMatch(matchers ...interface{}) *ImmutableExecutionContext_GetAnnotations
func (*ImmutableExecutionContext) OnGetCreationTimestamp ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) OnGetCreationTimestamp() *ImmutableExecutionContext_GetCreationTimestamp
func (*ImmutableExecutionContext) OnGetCreationTimestampMatch ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) OnGetCreationTimestampMatch(matchers ...interface{}) *ImmutableExecutionContext_GetCreationTimestamp
func (*ImmutableExecutionContext) OnGetDefinitionVersion ¶ added in v1.1.33
func (_m *ImmutableExecutionContext) OnGetDefinitionVersion() *ImmutableExecutionContext_GetDefinitionVersion
func (*ImmutableExecutionContext) OnGetDefinitionVersionMatch ¶ added in v1.1.33
func (_m *ImmutableExecutionContext) OnGetDefinitionVersionMatch(matchers ...interface{}) *ImmutableExecutionContext_GetDefinitionVersion
func (*ImmutableExecutionContext) OnGetEventVersion ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) OnGetEventVersion() *ImmutableExecutionContext_GetEventVersion
func (*ImmutableExecutionContext) OnGetEventVersionMatch ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) OnGetEventVersionMatch(matchers ...interface{}) *ImmutableExecutionContext_GetEventVersion
func (*ImmutableExecutionContext) OnGetExecutionConfig ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) OnGetExecutionConfig() *ImmutableExecutionContext_GetExecutionConfig
func (*ImmutableExecutionContext) OnGetExecutionConfigMatch ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) OnGetExecutionConfigMatch(matchers ...interface{}) *ImmutableExecutionContext_GetExecutionConfig
func (*ImmutableExecutionContext) OnGetExecutionID ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) OnGetExecutionID() *ImmutableExecutionContext_GetExecutionID
func (*ImmutableExecutionContext) OnGetExecutionIDMatch ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) OnGetExecutionIDMatch(matchers ...interface{}) *ImmutableExecutionContext_GetExecutionID
func (*ImmutableExecutionContext) OnGetID ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) OnGetID() *ImmutableExecutionContext_GetID
func (*ImmutableExecutionContext) OnGetIDMatch ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) OnGetIDMatch(matchers ...interface{}) *ImmutableExecutionContext_GetID
func (*ImmutableExecutionContext) OnGetK8sWorkflowID ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) OnGetK8sWorkflowID() *ImmutableExecutionContext_GetK8sWorkflowID
func (*ImmutableExecutionContext) OnGetK8sWorkflowIDMatch ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) OnGetK8sWorkflowIDMatch(matchers ...interface{}) *ImmutableExecutionContext_GetK8sWorkflowID
func (*ImmutableExecutionContext) OnGetLabels ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) OnGetLabels() *ImmutableExecutionContext_GetLabels
func (*ImmutableExecutionContext) OnGetLabelsMatch ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) OnGetLabelsMatch(matchers ...interface{}) *ImmutableExecutionContext_GetLabels
func (*ImmutableExecutionContext) OnGetName ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) OnGetName() *ImmutableExecutionContext_GetName
func (*ImmutableExecutionContext) OnGetNameMatch ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) OnGetNameMatch(matchers ...interface{}) *ImmutableExecutionContext_GetName
func (*ImmutableExecutionContext) OnGetNamespace ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) OnGetNamespace() *ImmutableExecutionContext_GetNamespace
func (*ImmutableExecutionContext) OnGetNamespaceMatch ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) OnGetNamespaceMatch(matchers ...interface{}) *ImmutableExecutionContext_GetNamespace
func (*ImmutableExecutionContext) OnGetOnFailurePolicy ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) OnGetOnFailurePolicy() *ImmutableExecutionContext_GetOnFailurePolicy
func (*ImmutableExecutionContext) OnGetOnFailurePolicyMatch ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) OnGetOnFailurePolicyMatch(matchers ...interface{}) *ImmutableExecutionContext_GetOnFailurePolicy
func (*ImmutableExecutionContext) OnGetOwnerReference ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) OnGetOwnerReference() *ImmutableExecutionContext_GetOwnerReference
func (*ImmutableExecutionContext) OnGetOwnerReferenceMatch ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) OnGetOwnerReferenceMatch(matchers ...interface{}) *ImmutableExecutionContext_GetOwnerReference
func (*ImmutableExecutionContext) OnGetRawOutputDataConfig ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) OnGetRawOutputDataConfig() *ImmutableExecutionContext_GetRawOutputDataConfig
func (*ImmutableExecutionContext) OnGetRawOutputDataConfigMatch ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) OnGetRawOutputDataConfigMatch(matchers ...interface{}) *ImmutableExecutionContext_GetRawOutputDataConfig
func (*ImmutableExecutionContext) OnGetSecurityContext ¶ added in v0.7.6
func (_m *ImmutableExecutionContext) OnGetSecurityContext() *ImmutableExecutionContext_GetSecurityContext
func (*ImmutableExecutionContext) OnGetSecurityContextMatch ¶ added in v0.7.6
func (_m *ImmutableExecutionContext) OnGetSecurityContextMatch(matchers ...interface{}) *ImmutableExecutionContext_GetSecurityContext
func (*ImmutableExecutionContext) OnGetServiceAccountName ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) OnGetServiceAccountName() *ImmutableExecutionContext_GetServiceAccountName
func (*ImmutableExecutionContext) OnGetServiceAccountNameMatch ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) OnGetServiceAccountNameMatch(matchers ...interface{}) *ImmutableExecutionContext_GetServiceAccountName
func (*ImmutableExecutionContext) OnIsInterruptible ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) OnIsInterruptible() *ImmutableExecutionContext_IsInterruptible
func (*ImmutableExecutionContext) OnIsInterruptibleMatch ¶ added in v0.7.0
func (_m *ImmutableExecutionContext) OnIsInterruptibleMatch(matchers ...interface{}) *ImmutableExecutionContext_IsInterruptible
type ImmutableExecutionContext_GetAnnotations ¶ added in v0.7.0
func (ImmutableExecutionContext_GetAnnotations) Return ¶ added in v0.7.0
func (_m ImmutableExecutionContext_GetAnnotations) Return(_a0 map[string]string) *ImmutableExecutionContext_GetAnnotations
type ImmutableExecutionContext_GetCreationTimestamp ¶ added in v0.7.0
func (ImmutableExecutionContext_GetCreationTimestamp) Return ¶ added in v0.7.0
func (_m ImmutableExecutionContext_GetCreationTimestamp) Return(_a0 v1.Time) *ImmutableExecutionContext_GetCreationTimestamp
type ImmutableExecutionContext_GetDefinitionVersion ¶ added in v1.1.33
type ImmutableExecutionContext_GetEventVersion ¶ added in v0.7.0
func (ImmutableExecutionContext_GetEventVersion) Return ¶ added in v0.7.0
func (_m ImmutableExecutionContext_GetEventVersion) Return(_a0 v1alpha1.EventVersion) *ImmutableExecutionContext_GetEventVersion
type ImmutableExecutionContext_GetExecutionConfig ¶ added in v0.7.0
type ImmutableExecutionContext_GetExecutionID ¶ added in v0.7.0
type ImmutableExecutionContext_GetID ¶ added in v0.7.0
func (ImmutableExecutionContext_GetID) Return ¶ added in v0.7.0
func (_m ImmutableExecutionContext_GetID) Return(_a0 string) *ImmutableExecutionContext_GetID
type ImmutableExecutionContext_GetK8sWorkflowID ¶ added in v0.7.0
func (ImmutableExecutionContext_GetK8sWorkflowID) Return ¶ added in v0.7.0
func (_m ImmutableExecutionContext_GetK8sWorkflowID) Return(_a0 types.NamespacedName) *ImmutableExecutionContext_GetK8sWorkflowID
type ImmutableExecutionContext_GetLabels ¶ added in v0.7.0
func (ImmutableExecutionContext_GetLabels) Return ¶ added in v0.7.0
func (_m ImmutableExecutionContext_GetLabels) Return(_a0 map[string]string) *ImmutableExecutionContext_GetLabels
type ImmutableExecutionContext_GetName ¶ added in v0.7.0
func (ImmutableExecutionContext_GetName) Return ¶ added in v0.7.0
func (_m ImmutableExecutionContext_GetName) Return(_a0 string) *ImmutableExecutionContext_GetName
type ImmutableExecutionContext_GetNamespace ¶ added in v0.7.0
func (ImmutableExecutionContext_GetNamespace) Return ¶ added in v0.7.0
func (_m ImmutableExecutionContext_GetNamespace) Return(_a0 string) *ImmutableExecutionContext_GetNamespace
type ImmutableExecutionContext_GetOnFailurePolicy ¶ added in v0.7.0
type ImmutableExecutionContext_GetOwnerReference ¶ added in v0.7.0
func (ImmutableExecutionContext_GetOwnerReference) Return ¶ added in v0.7.0
func (_m ImmutableExecutionContext_GetOwnerReference) Return(_a0 v1.OwnerReference) *ImmutableExecutionContext_GetOwnerReference
type ImmutableExecutionContext_GetRawOutputDataConfig ¶ added in v0.7.0
type ImmutableExecutionContext_GetSecurityContext ¶ added in v0.7.6
type ImmutableExecutionContext_GetServiceAccountName ¶ added in v0.7.0
func (ImmutableExecutionContext_GetServiceAccountName) Return ¶ added in v0.7.0
func (_m ImmutableExecutionContext_GetServiceAccountName) Return(_a0 string) *ImmutableExecutionContext_GetServiceAccountName
type ImmutableExecutionContext_IsInterruptible ¶ added in v0.7.0
func (ImmutableExecutionContext_IsInterruptible) Return ¶ added in v0.7.0
func (_m ImmutableExecutionContext_IsInterruptible) Return(_a0 bool) *ImmutableExecutionContext_IsInterruptible
type ImmutableParentInfo ¶ added in v0.7.0
ImmutableParentInfo is an autogenerated mock type for the ImmutableParentInfo type
func (*ImmutableParentInfo) CurrentAttempt ¶ added in v0.7.0
func (_m *ImmutableParentInfo) CurrentAttempt() uint32
CurrentAttempt provides a mock function with given fields:
func (*ImmutableParentInfo) GetUniqueID ¶ added in v0.7.0
func (_m *ImmutableParentInfo) GetUniqueID() string
GetUniqueID provides a mock function with given fields:
func (*ImmutableParentInfo) OnCurrentAttempt ¶ added in v0.7.0
func (_m *ImmutableParentInfo) OnCurrentAttempt() *ImmutableParentInfo_CurrentAttempt
func (*ImmutableParentInfo) OnCurrentAttemptMatch ¶ added in v0.7.0
func (_m *ImmutableParentInfo) OnCurrentAttemptMatch(matchers ...interface{}) *ImmutableParentInfo_CurrentAttempt
func (*ImmutableParentInfo) OnGetUniqueID ¶ added in v0.7.0
func (_m *ImmutableParentInfo) OnGetUniqueID() *ImmutableParentInfo_GetUniqueID
func (*ImmutableParentInfo) OnGetUniqueIDMatch ¶ added in v0.7.0
func (_m *ImmutableParentInfo) OnGetUniqueIDMatch(matchers ...interface{}) *ImmutableParentInfo_GetUniqueID
type ImmutableParentInfo_CurrentAttempt ¶ added in v0.7.0
func (ImmutableParentInfo_CurrentAttempt) Return ¶ added in v0.7.0
func (_m ImmutableParentInfo_CurrentAttempt) Return(_a0 uint32) *ImmutableParentInfo_CurrentAttempt
type ImmutableParentInfo_GetUniqueID ¶ added in v0.7.0
func (ImmutableParentInfo_GetUniqueID) Return ¶ added in v0.7.0
func (_m ImmutableParentInfo_GetUniqueID) Return(_a0 string) *ImmutableParentInfo_GetUniqueID
type NodeLookup ¶ added in v0.7.0
NodeLookup is an autogenerated mock type for the NodeLookup type
func (*NodeLookup) FromNode ¶ added in v1.1.73
func (_m *NodeLookup) FromNode(id string) ([]string, error)
FromNode provides a mock function with given fields: id
func (*NodeLookup) GetNode ¶ added in v0.7.0
func (_m *NodeLookup) GetNode(nodeID string) (v1alpha1.ExecutableNode, bool)
GetNode provides a mock function with given fields: nodeID
func (*NodeLookup) GetNodeExecutionStatus ¶ added in v0.7.0
func (_m *NodeLookup) GetNodeExecutionStatus(ctx context.Context, id string) v1alpha1.ExecutableNodeStatus
GetNodeExecutionStatus provides a mock function with given fields: ctx, id
func (*NodeLookup) OnFromNode ¶ added in v1.1.73
func (_m *NodeLookup) OnFromNode(id string) *NodeLookup_FromNode
func (*NodeLookup) OnFromNodeMatch ¶ added in v1.1.73
func (_m *NodeLookup) OnFromNodeMatch(matchers ...interface{}) *NodeLookup_FromNode
func (*NodeLookup) OnGetNode ¶ added in v0.7.0
func (_m *NodeLookup) OnGetNode(nodeID string) *NodeLookup_GetNode
func (*NodeLookup) OnGetNodeExecutionStatus ¶ added in v0.7.0
func (_m *NodeLookup) OnGetNodeExecutionStatus(ctx context.Context, id string) *NodeLookup_GetNodeExecutionStatus
func (*NodeLookup) OnGetNodeExecutionStatusMatch ¶ added in v0.7.0
func (_m *NodeLookup) OnGetNodeExecutionStatusMatch(matchers ...interface{}) *NodeLookup_GetNodeExecutionStatus
func (*NodeLookup) OnGetNodeMatch ¶ added in v0.7.0
func (_m *NodeLookup) OnGetNodeMatch(matchers ...interface{}) *NodeLookup_GetNode
func (*NodeLookup) OnToNode ¶ added in v1.1.73
func (_m *NodeLookup) OnToNode(id string) *NodeLookup_ToNode
func (*NodeLookup) OnToNodeMatch ¶ added in v1.1.73
func (_m *NodeLookup) OnToNodeMatch(matchers ...interface{}) *NodeLookup_ToNode
type NodeLookup_FromNode ¶ added in v1.1.73
func (NodeLookup_FromNode) Return ¶ added in v1.1.73
func (_m NodeLookup_FromNode) Return(_a0 []string, _a1 error) *NodeLookup_FromNode
type NodeLookup_GetNode ¶ added in v0.7.0
func (NodeLookup_GetNode) Return ¶ added in v0.7.0
func (_m NodeLookup_GetNode) Return(_a0 v1alpha1.ExecutableNode, _a1 bool) *NodeLookup_GetNode
type NodeLookup_GetNodeExecutionStatus ¶ added in v0.7.0
func (NodeLookup_GetNodeExecutionStatus) Return ¶ added in v0.7.0
func (_m NodeLookup_GetNodeExecutionStatus) Return(_a0 v1alpha1.ExecutableNodeStatus) *NodeLookup_GetNodeExecutionStatus
type NodeLookup_ToNode ¶ added in v1.1.73
func (NodeLookup_ToNode) Return ¶ added in v1.1.73
func (_m NodeLookup_ToNode) Return(_a0 []string, _a1 error) *NodeLookup_ToNode
type ParentInfoGetter ¶ added in v0.7.0
ParentInfoGetter is an autogenerated mock type for the ParentInfoGetter type
func (*ParentInfoGetter) GetParentInfo ¶ added in v0.7.0
func (_m *ParentInfoGetter) GetParentInfo() executors.ImmutableParentInfo
GetParentInfo provides a mock function with given fields:
func (*ParentInfoGetter) OnGetParentInfo ¶ added in v0.7.0
func (_m *ParentInfoGetter) OnGetParentInfo() *ParentInfoGetter_GetParentInfo
func (*ParentInfoGetter) OnGetParentInfoMatch ¶ added in v0.7.0
func (_m *ParentInfoGetter) OnGetParentInfoMatch(matchers ...interface{}) *ParentInfoGetter_GetParentInfo
type ParentInfoGetter_GetParentInfo ¶ added in v0.7.0
func (ParentInfoGetter_GetParentInfo) Return ¶ added in v0.7.0
func (_m ParentInfoGetter_GetParentInfo) Return(_a0 executors.ImmutableParentInfo) *ParentInfoGetter_GetParentInfo
type SubWorkflowGetter ¶ added in v0.7.0
SubWorkflowGetter is an autogenerated mock type for the SubWorkflowGetter type
func (*SubWorkflowGetter) FindSubWorkflow ¶ added in v0.7.0
func (_m *SubWorkflowGetter) FindSubWorkflow(subID string) v1alpha1.ExecutableSubWorkflow
FindSubWorkflow provides a mock function with given fields: subID
func (*SubWorkflowGetter) OnFindSubWorkflow ¶ added in v0.7.0
func (_m *SubWorkflowGetter) OnFindSubWorkflow(subID string) *SubWorkflowGetter_FindSubWorkflow
func (*SubWorkflowGetter) OnFindSubWorkflowMatch ¶ added in v0.7.0
func (_m *SubWorkflowGetter) OnFindSubWorkflowMatch(matchers ...interface{}) *SubWorkflowGetter_FindSubWorkflow
type SubWorkflowGetter_FindSubWorkflow ¶ added in v0.7.0
func (SubWorkflowGetter_FindSubWorkflow) Return ¶ added in v0.7.0
func (_m SubWorkflowGetter_FindSubWorkflow) Return(_a0 v1alpha1.ExecutableSubWorkflow) *SubWorkflowGetter_FindSubWorkflow
type TaskDetailsGetter ¶ added in v0.7.0
TaskDetailsGetter is an autogenerated mock type for the TaskDetailsGetter type
func (*TaskDetailsGetter) GetTask ¶ added in v0.7.0
func (_m *TaskDetailsGetter) GetTask(id string) (v1alpha1.ExecutableTask, error)
GetTask provides a mock function with given fields: id
func (*TaskDetailsGetter) OnGetTask ¶ added in v0.7.0
func (_m *TaskDetailsGetter) OnGetTask(id string) *TaskDetailsGetter_GetTask
func (*TaskDetailsGetter) OnGetTaskMatch ¶ added in v0.7.0
func (_m *TaskDetailsGetter) OnGetTaskMatch(matchers ...interface{}) *TaskDetailsGetter_GetTask
type TaskDetailsGetter_GetTask ¶ added in v0.7.0
func (TaskDetailsGetter_GetTask) Return ¶ added in v0.7.0
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