mocks

package
v0.13.10 Latest Latest
Warning

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

 Go to latest Published: Aug 13, 2021 License: Apache-2.0 Imports: 11 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 added in v0.1.13 

func (_m *Client) OnGetCache() *Client_GetCache

func (*Client) OnGetCacheMatch added in v0.1.13 

func (_m *Client) OnGetCacheMatch(matchers ...interface{}) *Client_GetCache

func (*Client) OnGetClient added in v0.1.13 

func (_m *Client) OnGetClient() *Client_GetClient

func (*Client) OnGetClientMatch added in v0.1.13 

func (_m *Client) OnGetClientMatch(matchers ...interface{}) *Client_GetClient

type Client_GetCache added in v0.1.13 

type Client_GetCache struct {
	*mock.Call
}

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 

type Client_GetClient struct {
	*mock.Call
}

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 

type ControlFlow struct {
	mock.Mock
}

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 

type ControlFlow_CurrentParallelism struct {
	*mock.Call
}

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 

type ControlFlow_IncrementParallelism struct {
	*mock.Call
}

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 

type DAGStructure struct {
	mock.Mock
}

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

func (*DAGStructure) ToNode added in v0.7.0 

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

ToNode provides a mock function with given fields: id

type DAGStructureWithStartNode added in v0.7.0 

type DAGStructureWithStartNode struct {
	mock.Mock
}

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:

func (*DAGStructureWithStartNode) ToNode added in v0.7.0 

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

ToNode provides a mock function with given fields: id

type DAGStructureWithStartNode_FromNode added in v0.7.0 

type DAGStructureWithStartNode_FromNode struct {
	*mock.Call
}

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 

type DAGStructureWithStartNode_StartNode struct {
	*mock.Call
}

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 

type DAGStructureWithStartNode_ToNode struct {
	*mock.Call
}

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 

type DAGStructure_FromNode struct {
	*mock.Call
}

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 

type DAGStructure_ToNode struct {
	*mock.Call
}

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 

type ExecutionContext struct {
	mock.Mock
}

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

type ExecutionContext_CurrentParallelism struct {
	*mock.Call
}

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 

type ExecutionContext_FindSubWorkflow struct {
	*mock.Call
}

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 

type ExecutionContext_GetAnnotations struct {
	*mock.Call
}

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 

type ExecutionContext_GetCreationTimestamp struct {
	*mock.Call
}

func (ExecutionContext_GetCreationTimestamp) Return added in v0.7.0 

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

type ExecutionContext_GetEventVersion added in v0.7.0 

type ExecutionContext_GetEventVersion struct {
	*mock.Call
}

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 

type ExecutionContext_GetExecutionConfig struct {
	*mock.Call
}

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 

type ExecutionContext_GetExecutionID struct {
	*mock.Call
}

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 

type ExecutionContext_GetID struct {
	*mock.Call
}

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 

type ExecutionContext_GetK8sWorkflowID struct {
	*mock.Call
}

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 

type ExecutionContext_GetLabels struct {
	*mock.Call
}

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 

type ExecutionContext_GetName struct {
	*mock.Call
}

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 

type ExecutionContext_GetNamespace struct {
	*mock.Call
}

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 

type ExecutionContext_GetOnFailurePolicy struct {
	*mock.Call
}

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 

type ExecutionContext_GetOwnerReference struct {
	*mock.Call
}

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 

type ExecutionContext_GetParentInfo struct {
	*mock.Call
}

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_GetRawOutputDataConfig struct {
	*mock.Call
}

func (ExecutionContext_GetRawOutputDataConfig) Return added in v0.7.0 

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

type ExecutionContext_GetSecurityContext added in v0.7.6 

type ExecutionContext_GetSecurityContext struct {
	*mock.Call
}

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 

type ExecutionContext_GetServiceAccountName struct {
	*mock.Call
}

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 

type ExecutionContext_GetTask struct {
	*mock.Call
}

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 

type ExecutionContext_IncrementParallelism struct {
	*mock.Call
}

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 

type ExecutionContext_IsInterruptible struct {
	*mock.Call
}

func (ExecutionContext_IsInterruptible) Return added in v0.7.0 

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

type ImmutableExecutionContext added in v0.7.0 

type ImmutableExecutionContext struct {
	mock.Mock
}

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

type ImmutableExecutionContext_GetAnnotations struct {
	*mock.Call
}

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 

type ImmutableExecutionContext_GetCreationTimestamp struct {
	*mock.Call
}

func (ImmutableExecutionContext_GetCreationTimestamp) Return added in v0.7.0 

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

type ImmutableExecutionContext_GetEventVersion added in v0.7.0 

type ImmutableExecutionContext_GetEventVersion struct {
	*mock.Call
}

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_GetExecutionConfig struct {
	*mock.Call
}

func (ImmutableExecutionContext_GetExecutionConfig) Return added in v0.7.0 

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

type ImmutableExecutionContext_GetExecutionID added in v0.7.0 

type ImmutableExecutionContext_GetExecutionID struct {
	*mock.Call
}

func (ImmutableExecutionContext_GetExecutionID) Return added in v0.7.0 

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

type ImmutableExecutionContext_GetID added in v0.7.0 

type ImmutableExecutionContext_GetID struct {
	*mock.Call
}

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 

type ImmutableExecutionContext_GetK8sWorkflowID struct {
	*mock.Call
}

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 

type ImmutableExecutionContext_GetLabels struct {
	*mock.Call
}

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 

type ImmutableExecutionContext_GetName struct {
	*mock.Call
}

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 

type ImmutableExecutionContext_GetNamespace struct {
	*mock.Call
}

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_GetOnFailurePolicy struct {
	*mock.Call
}

func (ImmutableExecutionContext_GetOnFailurePolicy) Return added in v0.7.0 

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

type ImmutableExecutionContext_GetOwnerReference added in v0.7.0 

type ImmutableExecutionContext_GetOwnerReference struct {
	*mock.Call
}

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_GetRawOutputDataConfig struct {
	*mock.Call
}

func (ImmutableExecutionContext_GetRawOutputDataConfig) Return added in v0.7.0 

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

type ImmutableExecutionContext_GetSecurityContext added in v0.7.6 

type ImmutableExecutionContext_GetSecurityContext struct {
	*mock.Call
}

func (ImmutableExecutionContext_GetSecurityContext) Return added in v0.7.6 

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

type ImmutableExecutionContext_GetServiceAccountName added in v0.7.0 

type ImmutableExecutionContext_GetServiceAccountName struct {
	*mock.Call
}

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 

type ImmutableExecutionContext_IsInterruptible struct {
	*mock.Call
}

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 

type ImmutableParentInfo struct {
	mock.Mock
}

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 

type ImmutableParentInfo_CurrentAttempt struct {
	*mock.Call
}

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 

type ImmutableParentInfo_GetUniqueID struct {
	*mock.Call
}

func (ImmutableParentInfo_GetUniqueID) Return added in v0.7.0 

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

type Node added in v0.1.13 

type Node struct {
	mock.Mock
}

Node is an autogenerated mock type for the Node type

func (*Node) AbortHandler added in v0.1.13 

func (_m *Node) AbortHandler(ctx context.Context, execContext executors.ExecutionContext, dag executors.DAGStructure, nl executors.NodeLookup, currentNode v1alpha1.ExecutableNode, reason string) error

AbortHandler provides a mock function with given fields: ctx, execContext, dag, nl, currentNode, reason

func (*Node) FinalizeHandler added in v0.1.15 

func (_m *Node) FinalizeHandler(ctx context.Context, execContext executors.ExecutionContext, dag executors.DAGStructure, nl executors.NodeLookup, currentNode v1alpha1.ExecutableNode) error

FinalizeHandler provides a mock function with given fields: ctx, execContext, dag, nl, currentNode

func (*Node) Initialize added in v0.1.13 

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

Initialize provides a mock function with given fields: ctx

func (*Node) OnAbortHandler added in v0.1.13 

func (_m *Node) OnAbortHandler(ctx context.Context, execContext executors.ExecutionContext, dag executors.DAGStructure, nl executors.NodeLookup, currentNode v1alpha1.ExecutableNode, reason string) *Node_AbortHandler

func (*Node) OnAbortHandlerMatch added in v0.1.13 

func (_m *Node) OnAbortHandlerMatch(matchers ...interface{}) *Node_AbortHandler

func (*Node) OnFinalizeHandler added in v0.1.15 

func (_m *Node) OnFinalizeHandler(ctx context.Context, execContext executors.ExecutionContext, dag executors.DAGStructure, nl executors.NodeLookup, currentNode v1alpha1.ExecutableNode) *Node_FinalizeHandler

func (*Node) OnFinalizeHandlerMatch added in v0.1.15 

func (_m *Node) OnFinalizeHandlerMatch(matchers ...interface{}) *Node_FinalizeHandler

func (*Node) OnInitialize added in v0.1.13 

func (_m *Node) OnInitialize(ctx context.Context) *Node_Initialize

func (*Node) OnInitializeMatch added in v0.1.13 

func (_m *Node) OnInitializeMatch(matchers ...interface{}) *Node_Initialize

func (*Node) OnRecursiveNodeHandler added in v0.1.13 

func (_m *Node) OnRecursiveNodeHandler(ctx context.Context, execContext executors.ExecutionContext, dag executors.DAGStructure, nl executors.NodeLookup, currentNode v1alpha1.ExecutableNode) *Node_RecursiveNodeHandler

func (*Node) OnRecursiveNodeHandlerMatch added in v0.1.13 

func (_m *Node) OnRecursiveNodeHandlerMatch(matchers ...interface{}) *Node_RecursiveNodeHandler

func (*Node) OnSetInputsForStartNode added in v0.1.13 

func (_m *Node) OnSetInputsForStartNode(ctx context.Context, execContext executors.ExecutionContext, dag executors.DAGStructureWithStartNode, nl executors.NodeLookup, inputs *core.LiteralMap) *Node_SetInputsForStartNode

func (*Node) OnSetInputsForStartNodeMatch added in v0.1.13 

func (_m *Node) OnSetInputsForStartNodeMatch(matchers ...interface{}) *Node_SetInputsForStartNode

func (*Node) RecursiveNodeHandler added in v0.1.13 

func (_m *Node) RecursiveNodeHandler(ctx context.Context, execContext executors.ExecutionContext, dag executors.DAGStructure, nl executors.NodeLookup, currentNode v1alpha1.ExecutableNode) (executors.NodeStatus, error)

RecursiveNodeHandler provides a mock function with given fields: ctx, execContext, dag, nl, currentNode

func (*Node) SetInputsForStartNode added in v0.1.13 

func (_m *Node) SetInputsForStartNode(ctx context.Context, execContext executors.ExecutionContext, dag executors.DAGStructureWithStartNode, nl executors.NodeLookup, inputs *core.LiteralMap) (executors.NodeStatus, error)

SetInputsForStartNode provides a mock function with given fields: ctx, execContext, dag, nl, inputs

type NodeLookup added in v0.7.0 

type NodeLookup struct {
	mock.Mock
}

NodeLookup is an autogenerated mock type for the NodeLookup type

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

type NodeLookup_GetNode added in v0.7.0 

type NodeLookup_GetNode struct {
	*mock.Call
}

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 

type NodeLookup_GetNodeExecutionStatus struct {
	*mock.Call
}

func (NodeLookup_GetNodeExecutionStatus) Return added in v0.7.0 

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

type Node_AbortHandler added in v0.1.13 

type Node_AbortHandler struct {
	*mock.Call
}

func (Node_AbortHandler) Return added in v0.1.13 

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

type Node_FinalizeHandler added in v0.1.15 

type Node_FinalizeHandler struct {
	*mock.Call
}

func (Node_FinalizeHandler) Return added in v0.1.15 

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

type Node_Initialize added in v0.1.13 

type Node_Initialize struct {
	*mock.Call
}

func (Node_Initialize) Return added in v0.1.13 

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

type Node_RecursiveNodeHandler added in v0.1.13 

type Node_RecursiveNodeHandler struct {
	*mock.Call
}

func (Node_RecursiveNodeHandler) Return added in v0.1.13 

func (_m Node_RecursiveNodeHandler) Return(_a0 executors.NodeStatus, _a1 error) *Node_RecursiveNodeHandler

type Node_SetInputsForStartNode added in v0.1.13 

type Node_SetInputsForStartNode struct {
	*mock.Call
}

func (Node_SetInputsForStartNode) Return added in v0.1.13 

func (_m Node_SetInputsForStartNode) Return(_a0 executors.NodeStatus, _a1 error) *Node_SetInputsForStartNode

type ParentInfoGetter added in v0.7.0 

type ParentInfoGetter struct {
	mock.Mock
}

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 

type ParentInfoGetter_GetParentInfo struct {
	*mock.Call
}

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 

type SubWorkflowGetter struct {
	mock.Mock
}

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 

type SubWorkflowGetter_FindSubWorkflow struct {
	*mock.Call
}

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 

type TaskDetailsGetter struct {
	mock.Mock
}

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 

type TaskDetailsGetter_GetTask struct {
	*mock.Call
}

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 

type Workflow struct {
	mock.Mock
}

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 

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

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

func (*Workflow) Initialize added in v0.1.13 

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

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 

type Workflow_HandleAbortedWorkflow struct {
	*mock.Call
}

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 

type Workflow_HandleFlyteWorkflow struct {
	*mock.Call
}

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 

type Workflow_Initialize struct {
	*mock.Call
}

func (Workflow_Initialize) Return added in v0.1.13 

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.