mocks

package
v0.2.39 Latest Latest
Warning

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

 Go to latest Published: May 5, 2020 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 DAGStructure added in v0.2.28 

type DAGStructure struct {
	mock.Mock
}

DAGStructure is an autogenerated mock type for the DAGStructure type

func (*DAGStructure) FromNode added in v0.2.28 

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

FromNode provides a mock function with given fields: id

func (*DAGStructure) OnFromNode added in v0.2.28 

func (_m *DAGStructure) OnFromNode(id string) *DAGStructure_FromNode

func (*DAGStructure) OnFromNodeMatch added in v0.2.28 

func (_m *DAGStructure) OnFromNodeMatch(matchers ...interface{}) *DAGStructure_FromNode

func (*DAGStructure) OnToNode added in v0.2.28 

func (_m *DAGStructure) OnToNode(id string) *DAGStructure_ToNode

func (*DAGStructure) OnToNodeMatch added in v0.2.28 

func (_m *DAGStructure) OnToNodeMatch(matchers ...interface{}) *DAGStructure_ToNode

func (*DAGStructure) ToNode added in v0.2.28 

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

ToNode provides a mock function with given fields: id

type DAGStructureWithStartNode added in v0.2.28 

type DAGStructureWithStartNode struct {
	mock.Mock
}

DAGStructureWithStartNode is an autogenerated mock type for the DAGStructureWithStartNode type

func (*DAGStructureWithStartNode) FromNode added in v0.2.28 

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

FromNode provides a mock function with given fields: id

func (*DAGStructureWithStartNode) OnFromNode added in v0.2.28 

func (_m *DAGStructureWithStartNode) OnFromNode(id string) *DAGStructureWithStartNode_FromNode

func (*DAGStructureWithStartNode) OnFromNodeMatch added in v0.2.28 

func (_m *DAGStructureWithStartNode) OnFromNodeMatch(matchers ...interface{}) *DAGStructureWithStartNode_FromNode

func (*DAGStructureWithStartNode) OnStartNode added in v0.2.28 

func (_m *DAGStructureWithStartNode) OnStartNode() *DAGStructureWithStartNode_StartNode

func (*DAGStructureWithStartNode) OnStartNodeMatch added in v0.2.28 

func (_m *DAGStructureWithStartNode) OnStartNodeMatch(matchers ...interface{}) *DAGStructureWithStartNode_StartNode

func (*DAGStructureWithStartNode) OnToNode added in v0.2.28 

func (_m *DAGStructureWithStartNode) OnToNode(id string) *DAGStructureWithStartNode_ToNode

func (*DAGStructureWithStartNode) OnToNodeMatch added in v0.2.28 

func (_m *DAGStructureWithStartNode) OnToNodeMatch(matchers ...interface{}) *DAGStructureWithStartNode_ToNode

func (*DAGStructureWithStartNode) StartNode added in v0.2.28 

func (_m *DAGStructureWithStartNode) StartNode() v1alpha1.ExecutableNode

StartNode provides a mock function with given fields:

func (*DAGStructureWithStartNode) ToNode added in v0.2.28 

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

ToNode provides a mock function with given fields: id

type DAGStructureWithStartNode_FromNode added in v0.2.28 

type DAGStructureWithStartNode_FromNode struct {
	*mock.Call
}

func (DAGStructureWithStartNode_FromNode) Return added in v0.2.28 

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

type DAGStructureWithStartNode_StartNode added in v0.2.28 

type DAGStructureWithStartNode_StartNode struct {
	*mock.Call
}

func (DAGStructureWithStartNode_StartNode) Return added in v0.2.28 

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

type DAGStructureWithStartNode_ToNode added in v0.2.28 

type DAGStructureWithStartNode_ToNode struct {
	*mock.Call
}

func (DAGStructureWithStartNode_ToNode) Return added in v0.2.28 

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

type DAGStructure_FromNode added in v0.2.28 

type DAGStructure_FromNode struct {
	*mock.Call
}

func (DAGStructure_FromNode) Return added in v0.2.28 

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

type DAGStructure_ToNode added in v0.2.28 

type DAGStructure_ToNode struct {
	*mock.Call
}

func (DAGStructure_ToNode) Return added in v0.2.28 

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

type ExecutionContext added in v0.2.28 

type ExecutionContext struct {
	mock.Mock
}

ExecutionContext is an autogenerated mock type for the ExecutionContext type

func (*ExecutionContext) FindSubWorkflow added in v0.2.28 

func (_m *ExecutionContext) FindSubWorkflow(subID string) v1alpha1.ExecutableSubWorkflow

FindSubWorkflow provides a mock function with given fields: subID

func (*ExecutionContext) GetAnnotations added in v0.2.28 

func (_m *ExecutionContext) GetAnnotations() map[string]string

GetAnnotations provides a mock function with given fields:

func (*ExecutionContext) GetCreationTimestamp added in v0.2.28 

func (_m *ExecutionContext) GetCreationTimestamp() v1.Time

GetCreationTimestamp provides a mock function with given fields:

func (*ExecutionContext) GetExecutionID added in v0.2.28 

func (_m *ExecutionContext) GetExecutionID() v1alpha1.WorkflowExecutionIdentifier

GetExecutionID provides a mock function with given fields:

func (*ExecutionContext) GetID added in v0.2.28 

func (_m *ExecutionContext) GetID() string

GetID provides a mock function with given fields:

func (*ExecutionContext) GetK8sWorkflowID added in v0.2.28 

func (_m *ExecutionContext) GetK8sWorkflowID() types.NamespacedName

GetK8sWorkflowID provides a mock function with given fields:

func (*ExecutionContext) GetLabels added in v0.2.28 

func (_m *ExecutionContext) GetLabels() map[string]string

GetLabels provides a mock function with given fields:

func (*ExecutionContext) GetName added in v0.2.28 

func (_m *ExecutionContext) GetName() string

GetName provides a mock function with given fields:

func (*ExecutionContext) GetNamespace added in v0.2.28 

func (_m *ExecutionContext) GetNamespace() string

GetNamespace provides a mock function with given fields:

func (*ExecutionContext) GetOwnerReference added in v0.2.28 

func (_m *ExecutionContext) GetOwnerReference() v1.OwnerReference

GetOwnerReference provides a mock function with given fields:

func (*ExecutionContext) GetServiceAccountName added in v0.2.28 

func (_m *ExecutionContext) GetServiceAccountName() string

GetServiceAccountName provides a mock function with given fields:

func (*ExecutionContext) GetTask added in v0.2.28 

func (_m *ExecutionContext) GetTask(id string) (v1alpha1.ExecutableTask, error)

GetTask provides a mock function with given fields: id

func (*ExecutionContext) IsInterruptible added in v0.2.28 

func (_m *ExecutionContext) IsInterruptible() bool

IsInterruptible provides a mock function with given fields:

func (*ExecutionContext) OnFindSubWorkflow added in v0.2.28 

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

func (*ExecutionContext) OnFindSubWorkflowMatch added in v0.2.28 

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

func (*ExecutionContext) OnGetAnnotations added in v0.2.28 

func (_m *ExecutionContext) OnGetAnnotations() *ExecutionContext_GetAnnotations

func (*ExecutionContext) OnGetAnnotationsMatch added in v0.2.28 

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

func (*ExecutionContext) OnGetCreationTimestamp added in v0.2.28 

func (_m *ExecutionContext) OnGetCreationTimestamp() *ExecutionContext_GetCreationTimestamp

func (*ExecutionContext) OnGetCreationTimestampMatch added in v0.2.28 

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

func (*ExecutionContext) OnGetExecutionID added in v0.2.28 

func (_m *ExecutionContext) OnGetExecutionID() *ExecutionContext_GetExecutionID

func (*ExecutionContext) OnGetExecutionIDMatch added in v0.2.28 

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

func (*ExecutionContext) OnGetID added in v0.2.28 

func (_m *ExecutionContext) OnGetID() *ExecutionContext_GetID

func (*ExecutionContext) OnGetIDMatch added in v0.2.28 

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

func (*ExecutionContext) OnGetK8sWorkflowID added in v0.2.28 

func (_m *ExecutionContext) OnGetK8sWorkflowID() *ExecutionContext_GetK8sWorkflowID

func (*ExecutionContext) OnGetK8sWorkflowIDMatch added in v0.2.28 

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

func (*ExecutionContext) OnGetLabels added in v0.2.28 

func (_m *ExecutionContext) OnGetLabels() *ExecutionContext_GetLabels

func (*ExecutionContext) OnGetLabelsMatch added in v0.2.28 

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

func (*ExecutionContext) OnGetName added in v0.2.28 

func (_m *ExecutionContext) OnGetName() *ExecutionContext_GetName

func (*ExecutionContext) OnGetNameMatch added in v0.2.28 

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

func (*ExecutionContext) OnGetNamespace added in v0.2.28 

func (_m *ExecutionContext) OnGetNamespace() *ExecutionContext_GetNamespace

func (*ExecutionContext) OnGetNamespaceMatch added in v0.2.28 

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

func (*ExecutionContext) OnGetOwnerReference added in v0.2.28 

func (_m *ExecutionContext) OnGetOwnerReference() *ExecutionContext_GetOwnerReference

func (*ExecutionContext) OnGetOwnerReferenceMatch added in v0.2.28 

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

func (*ExecutionContext) OnGetServiceAccountName added in v0.2.28 

func (_m *ExecutionContext) OnGetServiceAccountName() *ExecutionContext_GetServiceAccountName

func (*ExecutionContext) OnGetServiceAccountNameMatch added in v0.2.28 

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

func (*ExecutionContext) OnGetTask added in v0.2.28 

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

func (*ExecutionContext) OnGetTaskMatch added in v0.2.28 

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

func (*ExecutionContext) OnIsInterruptible added in v0.2.28 

func (_m *ExecutionContext) OnIsInterruptible() *ExecutionContext_IsInterruptible

func (*ExecutionContext) OnIsInterruptibleMatch added in v0.2.28 

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

type ExecutionContext_FindSubWorkflow added in v0.2.28 

type ExecutionContext_FindSubWorkflow struct {
	*mock.Call
}

func (ExecutionContext_FindSubWorkflow) Return added in v0.2.28 

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

type ExecutionContext_GetAnnotations added in v0.2.28 

type ExecutionContext_GetAnnotations struct {
	*mock.Call
}

func (ExecutionContext_GetAnnotations) Return added in v0.2.28 

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

type ExecutionContext_GetCreationTimestamp added in v0.2.28 

type ExecutionContext_GetCreationTimestamp struct {
	*mock.Call
}

func (ExecutionContext_GetCreationTimestamp) Return added in v0.2.28 

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

type ExecutionContext_GetExecutionID added in v0.2.28 

type ExecutionContext_GetExecutionID struct {
	*mock.Call
}

func (ExecutionContext_GetExecutionID) Return added in v0.2.28 

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

type ExecutionContext_GetID added in v0.2.28 

type ExecutionContext_GetID struct {
	*mock.Call
}

func (ExecutionContext_GetID) Return added in v0.2.28 

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

type ExecutionContext_GetK8sWorkflowID added in v0.2.28 

type ExecutionContext_GetK8sWorkflowID struct {
	*mock.Call
}

func (ExecutionContext_GetK8sWorkflowID) Return added in v0.2.28 

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

type ExecutionContext_GetLabels added in v0.2.28 

type ExecutionContext_GetLabels struct {
	*mock.Call
}

func (ExecutionContext_GetLabels) Return added in v0.2.28 

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

type ExecutionContext_GetName added in v0.2.28 

type ExecutionContext_GetName struct {
	*mock.Call
}

func (ExecutionContext_GetName) Return added in v0.2.28 

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

type ExecutionContext_GetNamespace added in v0.2.28 

type ExecutionContext_GetNamespace struct {
	*mock.Call
}

func (ExecutionContext_GetNamespace) Return added in v0.2.28 

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

type ExecutionContext_GetOwnerReference added in v0.2.28 

type ExecutionContext_GetOwnerReference struct {
	*mock.Call
}

func (ExecutionContext_GetOwnerReference) Return added in v0.2.28 

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

type ExecutionContext_GetServiceAccountName added in v0.2.28 

type ExecutionContext_GetServiceAccountName struct {
	*mock.Call
}

func (ExecutionContext_GetServiceAccountName) Return added in v0.2.28 

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

type ExecutionContext_GetTask added in v0.2.28 

type ExecutionContext_GetTask struct {
	*mock.Call
}

func (ExecutionContext_GetTask) Return added in v0.2.28 

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

type ExecutionContext_IsInterruptible added in v0.2.28 

type ExecutionContext_IsInterruptible struct {
	*mock.Call
}

func (ExecutionContext_IsInterruptible) Return added in v0.2.28 

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

type ImmutableExecutionContext added in v0.2.28 

type ImmutableExecutionContext struct {
	mock.Mock
}

ImmutableExecutionContext is an autogenerated mock type for the ImmutableExecutionContext type

func (*ImmutableExecutionContext) GetAnnotations added in v0.2.28 

func (_m *ImmutableExecutionContext) GetAnnotations() map[string]string

GetAnnotations provides a mock function with given fields:

func (*ImmutableExecutionContext) GetCreationTimestamp added in v0.2.28 

func (_m *ImmutableExecutionContext) GetCreationTimestamp() v1.Time

GetCreationTimestamp provides a mock function with given fields:

func (*ImmutableExecutionContext) GetExecutionID added in v0.2.28 

func (_m *ImmutableExecutionContext) GetExecutionID() v1alpha1.WorkflowExecutionIdentifier

GetExecutionID provides a mock function with given fields:

func (*ImmutableExecutionContext) GetID added in v0.2.28 

func (_m *ImmutableExecutionContext) GetID() string

GetID provides a mock function with given fields:

func (*ImmutableExecutionContext) GetK8sWorkflowID added in v0.2.28 

func (_m *ImmutableExecutionContext) GetK8sWorkflowID() types.NamespacedName

GetK8sWorkflowID provides a mock function with given fields:

func (*ImmutableExecutionContext) GetLabels added in v0.2.28 

func (_m *ImmutableExecutionContext) GetLabels() map[string]string

GetLabels provides a mock function with given fields:

func (*ImmutableExecutionContext) GetName added in v0.2.28 

func (_m *ImmutableExecutionContext) GetName() string

GetName provides a mock function with given fields:

func (*ImmutableExecutionContext) GetNamespace added in v0.2.28 

func (_m *ImmutableExecutionContext) GetNamespace() string

GetNamespace provides a mock function with given fields:

func (*ImmutableExecutionContext) GetOwnerReference added in v0.2.28 

func (_m *ImmutableExecutionContext) GetOwnerReference() v1.OwnerReference

GetOwnerReference provides a mock function with given fields:

func (*ImmutableExecutionContext) GetServiceAccountName added in v0.2.28 

func (_m *ImmutableExecutionContext) GetServiceAccountName() string

GetServiceAccountName provides a mock function with given fields:

func (*ImmutableExecutionContext) IsInterruptible added in v0.2.28 

func (_m *ImmutableExecutionContext) IsInterruptible() bool

IsInterruptible provides a mock function with given fields:

func (*ImmutableExecutionContext) OnGetAnnotations added in v0.2.28 

func (_m *ImmutableExecutionContext) OnGetAnnotations() *ImmutableExecutionContext_GetAnnotations

func (*ImmutableExecutionContext) OnGetAnnotationsMatch added in v0.2.28 

func (_m *ImmutableExecutionContext) OnGetAnnotationsMatch(matchers ...interface{}) *ImmutableExecutionContext_GetAnnotations

func (*ImmutableExecutionContext) OnGetCreationTimestamp added in v0.2.28 

func (_m *ImmutableExecutionContext) OnGetCreationTimestamp() *ImmutableExecutionContext_GetCreationTimestamp

func (*ImmutableExecutionContext) OnGetCreationTimestampMatch added in v0.2.28 

func (_m *ImmutableExecutionContext) OnGetCreationTimestampMatch(matchers ...interface{}) *ImmutableExecutionContext_GetCreationTimestamp

func (*ImmutableExecutionContext) OnGetExecutionID added in v0.2.28 

func (_m *ImmutableExecutionContext) OnGetExecutionID() *ImmutableExecutionContext_GetExecutionID

func (*ImmutableExecutionContext) OnGetExecutionIDMatch added in v0.2.28 

func (_m *ImmutableExecutionContext) OnGetExecutionIDMatch(matchers ...interface{}) *ImmutableExecutionContext_GetExecutionID

func (*ImmutableExecutionContext) OnGetID added in v0.2.28 

func (_m *ImmutableExecutionContext) OnGetID() *ImmutableExecutionContext_GetID

func (*ImmutableExecutionContext) OnGetIDMatch added in v0.2.28 

func (_m *ImmutableExecutionContext) OnGetIDMatch(matchers ...interface{}) *ImmutableExecutionContext_GetID

func (*ImmutableExecutionContext) OnGetK8sWorkflowID added in v0.2.28 

func (_m *ImmutableExecutionContext) OnGetK8sWorkflowID() *ImmutableExecutionContext_GetK8sWorkflowID

func (*ImmutableExecutionContext) OnGetK8sWorkflowIDMatch added in v0.2.28 

func (_m *ImmutableExecutionContext) OnGetK8sWorkflowIDMatch(matchers ...interface{}) *ImmutableExecutionContext_GetK8sWorkflowID

func (*ImmutableExecutionContext) OnGetLabels added in v0.2.28 

func (_m *ImmutableExecutionContext) OnGetLabels() *ImmutableExecutionContext_GetLabels

func (*ImmutableExecutionContext) OnGetLabelsMatch added in v0.2.28 

func (_m *ImmutableExecutionContext) OnGetLabelsMatch(matchers ...interface{}) *ImmutableExecutionContext_GetLabels

func (*ImmutableExecutionContext) OnGetName added in v0.2.28 

func (_m *ImmutableExecutionContext) OnGetName() *ImmutableExecutionContext_GetName

func (*ImmutableExecutionContext) OnGetNameMatch added in v0.2.28 

func (_m *ImmutableExecutionContext) OnGetNameMatch(matchers ...interface{}) *ImmutableExecutionContext_GetName

func (*ImmutableExecutionContext) OnGetNamespace added in v0.2.28 

func (_m *ImmutableExecutionContext) OnGetNamespace() *ImmutableExecutionContext_GetNamespace

func (*ImmutableExecutionContext) OnGetNamespaceMatch added in v0.2.28 

func (_m *ImmutableExecutionContext) OnGetNamespaceMatch(matchers ...interface{}) *ImmutableExecutionContext_GetNamespace

func (*ImmutableExecutionContext) OnGetOwnerReference added in v0.2.28 

func (_m *ImmutableExecutionContext) OnGetOwnerReference() *ImmutableExecutionContext_GetOwnerReference

func (*ImmutableExecutionContext) OnGetOwnerReferenceMatch added in v0.2.28 

func (_m *ImmutableExecutionContext) OnGetOwnerReferenceMatch(matchers ...interface{}) *ImmutableExecutionContext_GetOwnerReference

func (*ImmutableExecutionContext) OnGetServiceAccountName added in v0.2.28 

func (_m *ImmutableExecutionContext) OnGetServiceAccountName() *ImmutableExecutionContext_GetServiceAccountName

func (*ImmutableExecutionContext) OnGetServiceAccountNameMatch added in v0.2.28 

func (_m *ImmutableExecutionContext) OnGetServiceAccountNameMatch(matchers ...interface{}) *ImmutableExecutionContext_GetServiceAccountName

func (*ImmutableExecutionContext) OnIsInterruptible added in v0.2.28 

func (_m *ImmutableExecutionContext) OnIsInterruptible() *ImmutableExecutionContext_IsInterruptible

func (*ImmutableExecutionContext) OnIsInterruptibleMatch added in v0.2.28 

func (_m *ImmutableExecutionContext) OnIsInterruptibleMatch(matchers ...interface{}) *ImmutableExecutionContext_IsInterruptible

type ImmutableExecutionContext_GetAnnotations added in v0.2.28 

type ImmutableExecutionContext_GetAnnotations struct {
	*mock.Call
}

func (ImmutableExecutionContext_GetAnnotations) Return added in v0.2.28 

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

type ImmutableExecutionContext_GetCreationTimestamp added in v0.2.28 

type ImmutableExecutionContext_GetCreationTimestamp struct {
	*mock.Call
}

func (ImmutableExecutionContext_GetCreationTimestamp) Return added in v0.2.28 

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

type ImmutableExecutionContext_GetExecutionID added in v0.2.28 

type ImmutableExecutionContext_GetExecutionID struct {
	*mock.Call
}

func (ImmutableExecutionContext_GetExecutionID) Return added in v0.2.28 

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

type ImmutableExecutionContext_GetID added in v0.2.28 

type ImmutableExecutionContext_GetID struct {
	*mock.Call
}

func (ImmutableExecutionContext_GetID) Return added in v0.2.28 

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

type ImmutableExecutionContext_GetK8sWorkflowID added in v0.2.28 

type ImmutableExecutionContext_GetK8sWorkflowID struct {
	*mock.Call
}

func (ImmutableExecutionContext_GetK8sWorkflowID) Return added in v0.2.28 

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

type ImmutableExecutionContext_GetLabels added in v0.2.28 

type ImmutableExecutionContext_GetLabels struct {
	*mock.Call
}

func (ImmutableExecutionContext_GetLabels) Return added in v0.2.28 

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

type ImmutableExecutionContext_GetName added in v0.2.28 

type ImmutableExecutionContext_GetName struct {
	*mock.Call
}

func (ImmutableExecutionContext_GetName) Return added in v0.2.28 

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

type ImmutableExecutionContext_GetNamespace added in v0.2.28 

type ImmutableExecutionContext_GetNamespace struct {
	*mock.Call
}

func (ImmutableExecutionContext_GetNamespace) Return added in v0.2.28 

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

type ImmutableExecutionContext_GetOwnerReference added in v0.2.28 

type ImmutableExecutionContext_GetOwnerReference struct {
	*mock.Call
}

func (ImmutableExecutionContext_GetOwnerReference) Return added in v0.2.28 

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

type ImmutableExecutionContext_GetServiceAccountName added in v0.2.28 

type ImmutableExecutionContext_GetServiceAccountName struct {
	*mock.Call
}

func (ImmutableExecutionContext_GetServiceAccountName) Return added in v0.2.28 

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

type ImmutableExecutionContext_IsInterruptible added in v0.2.28 

type ImmutableExecutionContext_IsInterruptible struct {
	*mock.Call
}

func (ImmutableExecutionContext_IsInterruptible) Return added in v0.2.28 

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

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.2.28 

type NodeLookup struct {
	mock.Mock
}

NodeLookup is an autogenerated mock type for the NodeLookup type

func (*NodeLookup) GetNode added in v0.2.28 

func (_m *NodeLookup) GetNode(nodeID string) (v1alpha1.ExecutableNode, bool)

GetNode provides a mock function with given fields: nodeID

func (*NodeLookup) GetNodeExecutionStatus added in v0.2.28 

func (_m *NodeLookup) GetNodeExecutionStatus(ctx context.Context, id string) v1alpha1.ExecutableNodeStatus

GetNodeExecutionStatus provides a mock function with given fields: ctx, id

func (*NodeLookup) OnGetNode added in v0.2.28 

func (_m *NodeLookup) OnGetNode(nodeID string) *NodeLookup_GetNode

func (*NodeLookup) OnGetNodeExecutionStatus added in v0.2.28 

func (_m *NodeLookup) OnGetNodeExecutionStatus(ctx context.Context, id string) *NodeLookup_GetNodeExecutionStatus

func (*NodeLookup) OnGetNodeExecutionStatusMatch added in v0.2.28 

func (_m *NodeLookup) OnGetNodeExecutionStatusMatch(matchers ...interface{}) *NodeLookup_GetNodeExecutionStatus

func (*NodeLookup) OnGetNodeMatch added in v0.2.28 

func (_m *NodeLookup) OnGetNodeMatch(matchers ...interface{}) *NodeLookup_GetNode

type NodeLookup_GetNode added in v0.2.28 

type NodeLookup_GetNode struct {
	*mock.Call
}

func (NodeLookup_GetNode) Return added in v0.2.28 

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

type NodeLookup_GetNodeExecutionStatus added in v0.2.28 

type NodeLookup_GetNodeExecutionStatus struct {
	*mock.Call
}

func (NodeLookup_GetNodeExecutionStatus) Return added in v0.2.28 

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

type Node_AbortHandler added in v0.1.13 

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 SubWorkflowGetter added in v0.2.28 

type SubWorkflowGetter struct {
	mock.Mock
}

SubWorkflowGetter is an autogenerated mock type for the SubWorkflowGetter type

func (*SubWorkflowGetter) FindSubWorkflow added in v0.2.28 

func (_m *SubWorkflowGetter) FindSubWorkflow(subID string) v1alpha1.ExecutableSubWorkflow

FindSubWorkflow provides a mock function with given fields: subID

func (*SubWorkflowGetter) OnFindSubWorkflow added in v0.2.28 

func (_m *SubWorkflowGetter) OnFindSubWorkflow(subID string) *SubWorkflowGetter_FindSubWorkflow

func (*SubWorkflowGetter) OnFindSubWorkflowMatch added in v0.2.28 

func (_m *SubWorkflowGetter) OnFindSubWorkflowMatch(matchers ...interface{}) *SubWorkflowGetter_FindSubWorkflow

type SubWorkflowGetter_FindSubWorkflow added in v0.2.28 

type SubWorkflowGetter_FindSubWorkflow struct {
	*mock.Call
}

func (SubWorkflowGetter_FindSubWorkflow) Return added in v0.2.28 

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

type TaskDetailsGetter added in v0.2.28 

type TaskDetailsGetter struct {
	mock.Mock
}

TaskDetailsGetter is an autogenerated mock type for the TaskDetailsGetter type

func (*TaskDetailsGetter) GetTask added in v0.2.28 

func (_m *TaskDetailsGetter) GetTask(id string) (v1alpha1.ExecutableTask, error)

GetTask provides a mock function with given fields: id

func (*TaskDetailsGetter) OnGetTask added in v0.2.28 

func (_m *TaskDetailsGetter) OnGetTask(id string) *TaskDetailsGetter_GetTask

func (*TaskDetailsGetter) OnGetTaskMatch added in v0.2.28 

func (_m *TaskDetailsGetter) OnGetTaskMatch(matchers ...interface{}) *TaskDetailsGetter_GetTask

type TaskDetailsGetter_GetTask added in v0.2.28 

type TaskDetailsGetter_GetTask struct {
	*mock.Call
}

func (TaskDetailsGetter_GetTask) Return added in v0.2.28 

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

type Workflow added in v0.1.13 

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.