mocks

package
v1.9.10 Latest Latest
Warning

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

 Go to latest Published: Oct 5, 2023 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Client 

type Client struct {
	mock.Mock
}

Client is an autogenerated mock type for the Client type

func NewFakeKubeClient 

func NewFakeKubeClient() *Client

func (*Client) GetCache 

func (_m *Client) GetCache() cache.Cache

GetCache provides a mock function with given fields:

func (*Client) GetClient 

func (_m *Client) GetClient() client.Client

GetClient provides a mock function with given fields:

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 ClientBuilder 

type ClientBuilder struct {
	mock.Mock
}

ClientBuilder is an autogenerated mock type for the ClientBuilder type

func (*ClientBuilder) Build 

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 

func (_m *ClientBuilder) OnBuild(_a0 cache.Cache, config *rest.Config, options client.Options) *ClientBuilder_Build

func (*ClientBuilder) OnBuildMatch 

func (_m *ClientBuilder) OnBuildMatch(matchers ...interface{}) *ClientBuilder_Build

func (*ClientBuilder) OnWithUncached 

func (_m *ClientBuilder) OnWithUncached(objs ...client.Object) *ClientBuilder_WithUncached

func (*ClientBuilder) OnWithUncachedMatch 

func (_m *ClientBuilder) OnWithUncachedMatch(matchers ...interface{}) *ClientBuilder_WithUncached

func (*ClientBuilder) WithUncached 

func (_m *ClientBuilder) WithUncached(objs ...client.Object) executors.ClientBuilder

WithUncached provides a mock function with given fields: objs

type ClientBuilder_Build 

type ClientBuilder_Build struct {
	*mock.Call
}

func (ClientBuilder_Build) Return 

func (_m ClientBuilder_Build) Return(_a0 client.Client, _a1 error) *ClientBuilder_Build

type ClientBuilder_WithUncached 

type ClientBuilder_WithUncached struct {
	*mock.Call
}

func (ClientBuilder_WithUncached) Return 

func (_m ClientBuilder_WithUncached) Return(_a0 executors.ClientBuilder) *ClientBuilder_WithUncached

type Client_GetCache 

type Client_GetCache struct {
	*mock.Call
}

func (Client_GetCache) Return 

func (_m Client_GetCache) Return(_a0 cache.Cache) *Client_GetCache

type Client_GetClient 

type Client_GetClient struct {
	*mock.Call
}

func (Client_GetClient) Return 

func (_m Client_GetClient) Return(_a0 client.Client) *Client_GetClient

type ControlFlow 

type ControlFlow struct {
	mock.Mock
}

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 

type ControlFlow_CurrentParallelism struct {
	*mock.Call
}

func (ControlFlow_CurrentParallelism) Return 

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

type ControlFlow_IncrementParallelism 

type ControlFlow_IncrementParallelism struct {
	*mock.Call
}

func (ControlFlow_IncrementParallelism) Return 

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

type DAGStructure 

type DAGStructure struct {
	mock.Mock
}

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

func (*DAGStructure) ToNode 

func (_m *DAGStructure) ToNode(id string) ([]string, error)

ToNode provides a mock function with given fields: id

type DAGStructureWithStartNode 

type DAGStructureWithStartNode struct {
	mock.Mock
}

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:

func (*DAGStructureWithStartNode) ToNode 

func (_m *DAGStructureWithStartNode) ToNode(id string) ([]string, error)

ToNode provides a mock function with given fields: id

type DAGStructureWithStartNode_FromNode 

type DAGStructureWithStartNode_FromNode struct {
	*mock.Call
}

func (DAGStructureWithStartNode_FromNode) Return 

func (_m DAGStructureWithStartNode_FromNode) Return(_a0 []string, _a1 error) *DAGStructureWithStartNode_FromNode

type DAGStructureWithStartNode_StartNode 

type DAGStructureWithStartNode_StartNode struct {
	*mock.Call
}

func (DAGStructureWithStartNode_StartNode) Return 

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

type DAGStructureWithStartNode_ToNode 

type DAGStructureWithStartNode_ToNode struct {
	*mock.Call
}

func (DAGStructureWithStartNode_ToNode) Return 

func (_m DAGStructureWithStartNode_ToNode) Return(_a0 []string, _a1 error) *DAGStructureWithStartNode_ToNode

type DAGStructure_FromNode 

type DAGStructure_FromNode struct {
	*mock.Call
}

func (DAGStructure_FromNode) Return 

func (_m DAGStructure_FromNode) Return(_a0 []string, _a1 error) *DAGStructure_FromNode

type DAGStructure_ToNode 

type DAGStructure_ToNode struct {
	*mock.Call
}

func (DAGStructure_ToNode) Return 

func (_m DAGStructure_ToNode) Return(_a0 []string, _a1 error) *DAGStructure_ToNode

type ExecutionContext 

type ExecutionContext struct {
	mock.Mock
}

ExecutionContext is an autogenerated mock type for the ExecutionContext type

func (*ExecutionContext) CurrentParallelism 

func (_m *ExecutionContext) CurrentParallelism() uint32

CurrentParallelism provides a mock function with given fields:

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) 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) IncrementParallelism 

func (_m *ExecutionContext) IncrementParallelism() uint32

IncrementParallelism provides a mock function with given fields:

func (*ExecutionContext) IsInterruptible 

func (_m *ExecutionContext) IsInterruptible() bool

IsInterruptible provides a mock function with given fields:

func (*ExecutionContext) OnCurrentParallelism 

func (_m *ExecutionContext) OnCurrentParallelism() *ExecutionContext_CurrentParallelism

func (*ExecutionContext) OnCurrentParallelismMatch 

func (_m *ExecutionContext) OnCurrentParallelismMatch(matchers ...interface{}) *ExecutionContext_CurrentParallelism

func (*ExecutionContext) OnFindSubWorkflow 

func (_m *ExecutionContext) OnFindSubWorkflow(subID string) *ExecutionContext_FindSubWorkflow

func (*ExecutionContext) OnFindSubWorkflowMatch 

func (_m *ExecutionContext) OnFindSubWorkflowMatch(matchers ...interface{}) *ExecutionContext_FindSubWorkflow

func (*ExecutionContext) OnGetAnnotations 

func (_m *ExecutionContext) OnGetAnnotations() *ExecutionContext_GetAnnotations

func (*ExecutionContext) OnGetAnnotationsMatch 

func (_m *ExecutionContext) OnGetAnnotationsMatch(matchers ...interface{}) *ExecutionContext_GetAnnotations

func (*ExecutionContext) OnGetCreationTimestamp 

func (_m *ExecutionContext) OnGetCreationTimestamp() *ExecutionContext_GetCreationTimestamp

func (*ExecutionContext) OnGetCreationTimestampMatch 

func (_m *ExecutionContext) OnGetCreationTimestampMatch(matchers ...interface{}) *ExecutionContext_GetCreationTimestamp

func (*ExecutionContext) OnGetDefinitionVersion 

func (_m *ExecutionContext) OnGetDefinitionVersion() *ExecutionContext_GetDefinitionVersion

func (*ExecutionContext) OnGetDefinitionVersionMatch 

func (_m *ExecutionContext) OnGetDefinitionVersionMatch(matchers ...interface{}) *ExecutionContext_GetDefinitionVersion

func (*ExecutionContext) OnGetEventVersion 

func (_m *ExecutionContext) OnGetEventVersion() *ExecutionContext_GetEventVersion

func (*ExecutionContext) OnGetEventVersionMatch 

func (_m *ExecutionContext) OnGetEventVersionMatch(matchers ...interface{}) *ExecutionContext_GetEventVersion

func (*ExecutionContext) OnGetExecutionConfig 

func (_m *ExecutionContext) OnGetExecutionConfig() *ExecutionContext_GetExecutionConfig

func (*ExecutionContext) OnGetExecutionConfigMatch 

func (_m *ExecutionContext) OnGetExecutionConfigMatch(matchers ...interface{}) *ExecutionContext_GetExecutionConfig

func (*ExecutionContext) OnGetExecutionID 

func (_m *ExecutionContext) OnGetExecutionID() *ExecutionContext_GetExecutionID

func (*ExecutionContext) OnGetExecutionIDMatch 

func (_m *ExecutionContext) OnGetExecutionIDMatch(matchers ...interface{}) *ExecutionContext_GetExecutionID

func (*ExecutionContext) OnGetID 

func (_m *ExecutionContext) OnGetID() *ExecutionContext_GetID

func (*ExecutionContext) OnGetIDMatch 

func (_m *ExecutionContext) OnGetIDMatch(matchers ...interface{}) *ExecutionContext_GetID

func (*ExecutionContext) OnGetK8sWorkflowID 

func (_m *ExecutionContext) OnGetK8sWorkflowID() *ExecutionContext_GetK8sWorkflowID

func (*ExecutionContext) OnGetK8sWorkflowIDMatch 

func (_m *ExecutionContext) OnGetK8sWorkflowIDMatch(matchers ...interface{}) *ExecutionContext_GetK8sWorkflowID

func (*ExecutionContext) OnGetLabels 

func (_m *ExecutionContext) OnGetLabels() *ExecutionContext_GetLabels

func (*ExecutionContext) OnGetLabelsMatch 

func (_m *ExecutionContext) OnGetLabelsMatch(matchers ...interface{}) *ExecutionContext_GetLabels

func (*ExecutionContext) OnGetName 

func (_m *ExecutionContext) OnGetName() *ExecutionContext_GetName

func (*ExecutionContext) OnGetNameMatch 

func (_m *ExecutionContext) OnGetNameMatch(matchers ...interface{}) *ExecutionContext_GetName

func (*ExecutionContext) OnGetNamespace 

func (_m *ExecutionContext) OnGetNamespace() *ExecutionContext_GetNamespace

func (*ExecutionContext) OnGetNamespaceMatch 

func (_m *ExecutionContext) OnGetNamespaceMatch(matchers ...interface{}) *ExecutionContext_GetNamespace

func (*ExecutionContext) OnGetOnFailurePolicy 

func (_m *ExecutionContext) OnGetOnFailurePolicy() *ExecutionContext_GetOnFailurePolicy

func (*ExecutionContext) OnGetOnFailurePolicyMatch 

func (_m *ExecutionContext) OnGetOnFailurePolicyMatch(matchers ...interface{}) *ExecutionContext_GetOnFailurePolicy

func (*ExecutionContext) OnGetOwnerReference 

func (_m *ExecutionContext) OnGetOwnerReference() *ExecutionContext_GetOwnerReference

func (*ExecutionContext) OnGetOwnerReferenceMatch 

func (_m *ExecutionContext) OnGetOwnerReferenceMatch(matchers ...interface{}) *ExecutionContext_GetOwnerReference

func (*ExecutionContext) OnGetParentInfo 

func (_m *ExecutionContext) OnGetParentInfo() *ExecutionContext_GetParentInfo

func (*ExecutionContext) OnGetParentInfoMatch 

func (_m *ExecutionContext) OnGetParentInfoMatch(matchers ...interface{}) *ExecutionContext_GetParentInfo

func (*ExecutionContext) OnGetRawOutputDataConfig 

func (_m *ExecutionContext) OnGetRawOutputDataConfig() *ExecutionContext_GetRawOutputDataConfig

func (*ExecutionContext) OnGetRawOutputDataConfigMatch 

func (_m *ExecutionContext) OnGetRawOutputDataConfigMatch(matchers ...interface{}) *ExecutionContext_GetRawOutputDataConfig

func (*ExecutionContext) OnGetSecurityContext 

func (_m *ExecutionContext) OnGetSecurityContext() *ExecutionContext_GetSecurityContext

func (*ExecutionContext) OnGetSecurityContextMatch 

func (_m *ExecutionContext) OnGetSecurityContextMatch(matchers ...interface{}) *ExecutionContext_GetSecurityContext

func (*ExecutionContext) OnGetServiceAccountName 

func (_m *ExecutionContext) OnGetServiceAccountName() *ExecutionContext_GetServiceAccountName

func (*ExecutionContext) OnGetServiceAccountNameMatch 

func (_m *ExecutionContext) OnGetServiceAccountNameMatch(matchers ...interface{}) *ExecutionContext_GetServiceAccountName

func (*ExecutionContext) OnGetTask 

func (_m *ExecutionContext) OnGetTask(id string) *ExecutionContext_GetTask

func (*ExecutionContext) OnGetTaskMatch 

func (_m *ExecutionContext) OnGetTaskMatch(matchers ...interface{}) *ExecutionContext_GetTask

func (*ExecutionContext) OnIncrementParallelism 

func (_m *ExecutionContext) OnIncrementParallelism() *ExecutionContext_IncrementParallelism

func (*ExecutionContext) OnIncrementParallelismMatch 

func (_m *ExecutionContext) OnIncrementParallelismMatch(matchers ...interface{}) *ExecutionContext_IncrementParallelism

func (*ExecutionContext) OnIsInterruptible 

func (_m *ExecutionContext) OnIsInterruptible() *ExecutionContext_IsInterruptible

func (*ExecutionContext) OnIsInterruptibleMatch 

func (_m *ExecutionContext) OnIsInterruptibleMatch(matchers ...interface{}) *ExecutionContext_IsInterruptible

type ExecutionContext_CurrentParallelism 

type ExecutionContext_CurrentParallelism struct {
	*mock.Call
}

func (ExecutionContext_CurrentParallelism) Return 

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

type ExecutionContext_FindSubWorkflow 

type ExecutionContext_FindSubWorkflow struct {
	*mock.Call
}

func (ExecutionContext_FindSubWorkflow) Return 

func (_m ExecutionContext_FindSubWorkflow) Return(_a0 v1alpha1.ExecutableSubWorkflow) *ExecutionContext_FindSubWorkflow

type ExecutionContext_GetAnnotations 

type ExecutionContext_GetAnnotations struct {
	*mock.Call
}

func (ExecutionContext_GetAnnotations) Return 

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

type ExecutionContext_GetCreationTimestamp 

type ExecutionContext_GetCreationTimestamp struct {
	*mock.Call
}

func (ExecutionContext_GetCreationTimestamp) Return 

func (_m ExecutionContext_GetCreationTimestamp) Return(_a0 v1.Time) *ExecutionContext_GetCreationTimestamp

type ExecutionContext_GetDefinitionVersion 

type ExecutionContext_GetDefinitionVersion struct {
	*mock.Call
}

func (ExecutionContext_GetDefinitionVersion) Return 

func (_m ExecutionContext_GetDefinitionVersion) Return(_a0 v1alpha1.WorkflowDefinitionVersion) *ExecutionContext_GetDefinitionVersion

type ExecutionContext_GetEventVersion 

type ExecutionContext_GetEventVersion struct {
	*mock.Call
}

func (ExecutionContext_GetEventVersion) Return 

func (_m ExecutionContext_GetEventVersion) Return(_a0 v1alpha1.EventVersion) *ExecutionContext_GetEventVersion

type ExecutionContext_GetExecutionConfig 

type ExecutionContext_GetExecutionConfig struct {
	*mock.Call
}

func (ExecutionContext_GetExecutionConfig) Return 

func (_m ExecutionContext_GetExecutionConfig) Return(_a0 v1alpha1.ExecutionConfig) *ExecutionContext_GetExecutionConfig

type ExecutionContext_GetExecutionID 

type ExecutionContext_GetExecutionID struct {
	*mock.Call
}

func (ExecutionContext_GetExecutionID) Return 

func (_m ExecutionContext_GetExecutionID) Return(_a0 v1alpha1.WorkflowExecutionIdentifier) *ExecutionContext_GetExecutionID

type ExecutionContext_GetID 

type ExecutionContext_GetID struct {
	*mock.Call
}

func (ExecutionContext_GetID) Return 

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

type ExecutionContext_GetK8sWorkflowID 

type ExecutionContext_GetK8sWorkflowID struct {
	*mock.Call
}

func (ExecutionContext_GetK8sWorkflowID) Return 

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

type ExecutionContext_GetLabels 

type ExecutionContext_GetLabels struct {
	*mock.Call
}

func (ExecutionContext_GetLabels) Return 

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

type ExecutionContext_GetName 

type ExecutionContext_GetName struct {
	*mock.Call
}

func (ExecutionContext_GetName) Return 

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

type ExecutionContext_GetNamespace 

type ExecutionContext_GetNamespace struct {
	*mock.Call
}

func (ExecutionContext_GetNamespace) Return 

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

type ExecutionContext_GetOnFailurePolicy 

type ExecutionContext_GetOnFailurePolicy struct {
	*mock.Call
}

func (ExecutionContext_GetOnFailurePolicy) Return 

func (_m ExecutionContext_GetOnFailurePolicy) Return(_a0 v1alpha1.WorkflowOnFailurePolicy) *ExecutionContext_GetOnFailurePolicy

type ExecutionContext_GetOwnerReference 

type ExecutionContext_GetOwnerReference struct {
	*mock.Call
}

func (ExecutionContext_GetOwnerReference) Return 

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

type ExecutionContext_GetParentInfo 

type ExecutionContext_GetParentInfo struct {
	*mock.Call
}

func (ExecutionContext_GetParentInfo) Return 

func (_m ExecutionContext_GetParentInfo) Return(_a0 executors.ImmutableParentInfo) *ExecutionContext_GetParentInfo

type ExecutionContext_GetRawOutputDataConfig 

type ExecutionContext_GetRawOutputDataConfig struct {
	*mock.Call
}

func (ExecutionContext_GetRawOutputDataConfig) Return 

func (_m ExecutionContext_GetRawOutputDataConfig) Return(_a0 v1alpha1.RawOutputDataConfig) *ExecutionContext_GetRawOutputDataConfig

type ExecutionContext_GetSecurityContext 

type ExecutionContext_GetSecurityContext struct {
	*mock.Call
}

func (ExecutionContext_GetSecurityContext) Return 

func (_m ExecutionContext_GetSecurityContext) Return(_a0 core.SecurityContext) *ExecutionContext_GetSecurityContext

type ExecutionContext_GetServiceAccountName 

type ExecutionContext_GetServiceAccountName struct {
	*mock.Call
}

func (ExecutionContext_GetServiceAccountName) Return 

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

type ExecutionContext_GetTask 

type ExecutionContext_GetTask struct {
	*mock.Call
}

func (ExecutionContext_GetTask) Return 

func (_m ExecutionContext_GetTask) Return(_a0 v1alpha1.ExecutableTask, _a1 error) *ExecutionContext_GetTask

type ExecutionContext_IncrementParallelism 

type ExecutionContext_IncrementParallelism struct {
	*mock.Call
}

func (ExecutionContext_IncrementParallelism) Return 

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

type ExecutionContext_IsInterruptible 

type ExecutionContext_IsInterruptible struct {
	*mock.Call
}

func (ExecutionContext_IsInterruptible) Return 

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

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) Get 

func (f *FakeInformers) Get(ctx context.Context, key client.ObjectKey, obj client.Object) error

func (*FakeInformers) GetInformer 

func (f *FakeInformers) GetInformer(ctx context.Context, obj client.Object) (cache.Informer, error)

func (*FakeInformers) GetInformerForKind 

func (f *FakeInformers) GetInformerForKind(ctx context.Context, gvk schema.GroupVersionKind) (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) Start 

func (f *FakeInformers) Start(ctx context.Context) error

func (*FakeInformers) WaitForCacheSync 

func (f *FakeInformers) WaitForCacheSync(ctx context.Context) bool

type ImmutableExecutionContext 

type ImmutableExecutionContext struct {
	mock.Mock
}

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 

type ImmutableExecutionContext_GetAnnotations struct {
	*mock.Call
}

func (ImmutableExecutionContext_GetAnnotations) Return 

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

type ImmutableExecutionContext_GetCreationTimestamp 

type ImmutableExecutionContext_GetCreationTimestamp struct {
	*mock.Call
}

func (ImmutableExecutionContext_GetCreationTimestamp) Return 

func (_m ImmutableExecutionContext_GetCreationTimestamp) Return(_a0 v1.Time) *ImmutableExecutionContext_GetCreationTimestamp

type ImmutableExecutionContext_GetDefinitionVersion 

type ImmutableExecutionContext_GetDefinitionVersion struct {
	*mock.Call
}

func (ImmutableExecutionContext_GetDefinitionVersion) Return 

func (_m ImmutableExecutionContext_GetDefinitionVersion) Return(_a0 v1alpha1.WorkflowDefinitionVersion) *ImmutableExecutionContext_GetDefinitionVersion

type ImmutableExecutionContext_GetEventVersion 

type ImmutableExecutionContext_GetEventVersion struct {
	*mock.Call
}

func (ImmutableExecutionContext_GetEventVersion) Return 

func (_m ImmutableExecutionContext_GetEventVersion) Return(_a0 v1alpha1.EventVersion) *ImmutableExecutionContext_GetEventVersion

type ImmutableExecutionContext_GetExecutionConfig 

type ImmutableExecutionContext_GetExecutionConfig struct {
	*mock.Call
}

func (ImmutableExecutionContext_GetExecutionConfig) Return 

func (_m ImmutableExecutionContext_GetExecutionConfig) Return(_a0 v1alpha1.ExecutionConfig) *ImmutableExecutionContext_GetExecutionConfig

type ImmutableExecutionContext_GetExecutionID 

type ImmutableExecutionContext_GetExecutionID struct {
	*mock.Call
}

func (ImmutableExecutionContext_GetExecutionID) Return 

func (_m ImmutableExecutionContext_GetExecutionID) Return(_a0 v1alpha1.WorkflowExecutionIdentifier) *ImmutableExecutionContext_GetExecutionID

type ImmutableExecutionContext_GetID 

type ImmutableExecutionContext_GetID struct {
	*mock.Call
}

func (ImmutableExecutionContext_GetID) Return 

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

type ImmutableExecutionContext_GetK8sWorkflowID 

type ImmutableExecutionContext_GetK8sWorkflowID struct {
	*mock.Call
}

func (ImmutableExecutionContext_GetK8sWorkflowID) Return 

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

type ImmutableExecutionContext_GetLabels 

type ImmutableExecutionContext_GetLabels struct {
	*mock.Call
}

func (ImmutableExecutionContext_GetLabels) Return 

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

type ImmutableExecutionContext_GetName 

type ImmutableExecutionContext_GetName struct {
	*mock.Call
}

func (ImmutableExecutionContext_GetName) Return 

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

type ImmutableExecutionContext_GetNamespace 

type ImmutableExecutionContext_GetNamespace struct {
	*mock.Call
}

func (ImmutableExecutionContext_GetNamespace) Return 

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

type ImmutableExecutionContext_GetOnFailurePolicy 

type ImmutableExecutionContext_GetOnFailurePolicy struct {
	*mock.Call
}

func (ImmutableExecutionContext_GetOnFailurePolicy) Return 

func (_m ImmutableExecutionContext_GetOnFailurePolicy) Return(_a0 v1alpha1.WorkflowOnFailurePolicy) *ImmutableExecutionContext_GetOnFailurePolicy

type ImmutableExecutionContext_GetOwnerReference 

type ImmutableExecutionContext_GetOwnerReference struct {
	*mock.Call
}

func (ImmutableExecutionContext_GetOwnerReference) Return 

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

type ImmutableExecutionContext_GetRawOutputDataConfig 

type ImmutableExecutionContext_GetRawOutputDataConfig struct {
	*mock.Call
}

func (ImmutableExecutionContext_GetRawOutputDataConfig) Return 

func (_m ImmutableExecutionContext_GetRawOutputDataConfig) Return(_a0 v1alpha1.RawOutputDataConfig) *ImmutableExecutionContext_GetRawOutputDataConfig

type ImmutableExecutionContext_GetSecurityContext 

type ImmutableExecutionContext_GetSecurityContext struct {
	*mock.Call
}

func (ImmutableExecutionContext_GetSecurityContext) Return 

func (_m ImmutableExecutionContext_GetSecurityContext) Return(_a0 core.SecurityContext) *ImmutableExecutionContext_GetSecurityContext

type ImmutableExecutionContext_GetServiceAccountName 

type ImmutableExecutionContext_GetServiceAccountName struct {
	*mock.Call
}

func (ImmutableExecutionContext_GetServiceAccountName) Return 

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

type ImmutableExecutionContext_IsInterruptible 

type ImmutableExecutionContext_IsInterruptible struct {
	*mock.Call
}

func (ImmutableExecutionContext_IsInterruptible) Return 

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

type ImmutableParentInfo 

type ImmutableParentInfo struct {
	mock.Mock
}

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) 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

type ImmutableParentInfo_CurrentAttempt 

type ImmutableParentInfo_CurrentAttempt struct {
	*mock.Call
}

func (ImmutableParentInfo_CurrentAttempt) Return 

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

type ImmutableParentInfo_GetUniqueID 

type ImmutableParentInfo_GetUniqueID struct {
	*mock.Call
}

func (ImmutableParentInfo_GetUniqueID) Return 

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

type NodeLookup 

type NodeLookup struct {
	mock.Mock
}

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

func (*NodeLookup) ToNode 

func (_m *NodeLookup) ToNode(id string) ([]string, error)

ToNode provides a mock function with given fields: id

type NodeLookup_FromNode 

type NodeLookup_FromNode struct {
	*mock.Call
}

func (NodeLookup_FromNode) Return 

func (_m NodeLookup_FromNode) Return(_a0 []string, _a1 error) *NodeLookup_FromNode

type NodeLookup_GetNode 

type NodeLookup_GetNode struct {
	*mock.Call
}

func (NodeLookup_GetNode) Return 

func (_m NodeLookup_GetNode) Return(_a0 v1alpha1.ExecutableNode, _a1 bool) *NodeLookup_GetNode

type NodeLookup_GetNodeExecutionStatus 

type NodeLookup_GetNodeExecutionStatus struct {
	*mock.Call
}

func (NodeLookup_GetNodeExecutionStatus) Return 

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

type NodeLookup_ToNode 

type NodeLookup_ToNode struct {
	*mock.Call
}

func (NodeLookup_ToNode) Return 

func (_m NodeLookup_ToNode) Return(_a0 []string, _a1 error) *NodeLookup_ToNode

type ParentInfoGetter 

type ParentInfoGetter struct {
	mock.Mock
}

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 

type ParentInfoGetter_GetParentInfo struct {
	*mock.Call
}

func (ParentInfoGetter_GetParentInfo) Return 

func (_m ParentInfoGetter_GetParentInfo) Return(_a0 executors.ImmutableParentInfo) *ParentInfoGetter_GetParentInfo

type SubWorkflowGetter 

type SubWorkflowGetter struct {
	mock.Mock
}

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 

type SubWorkflowGetter_FindSubWorkflow struct {
	*mock.Call
}

func (SubWorkflowGetter_FindSubWorkflow) Return 

func (_m SubWorkflowGetter_FindSubWorkflow) Return(_a0 v1alpha1.ExecutableSubWorkflow) *SubWorkflowGetter_FindSubWorkflow

type TaskDetailsGetter 

type TaskDetailsGetter struct {
	mock.Mock
}

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 

type TaskDetailsGetter_GetTask struct {
	*mock.Call
}

func (TaskDetailsGetter_GetTask) Return 

func (_m TaskDetailsGetter_GetTask) Return(_a0 v1alpha1.ExecutableTask, _a1 error) *TaskDetailsGetter_GetTask

type Workflow 

type Workflow struct {
	mock.Mock
}

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 

func (_m *Workflow) HandleFlyteWorkflow(ctx context.Context, w *v1alpha1.FlyteWorkflow) error

HandleFlyteWorkflow provides a mock function with given fields: ctx, w

func (*Workflow) Initialize 

func (_m *Workflow) Initialize(ctx context.Context) error

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 

type Workflow_HandleAbortedWorkflow struct {
	*mock.Call
}

func (Workflow_HandleAbortedWorkflow) Return 

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

type Workflow_HandleFlyteWorkflow 

type Workflow_HandleFlyteWorkflow struct {
	*mock.Call
}

func (Workflow_HandleFlyteWorkflow) Return 

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

type Workflow_Initialize 

type Workflow_Initialize struct {
	*mock.Call
}

func (Workflow_Initialize) Return 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.