mocks

Mar 24, 2023

Changes in this version

type NodeLookup

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

+ func (_m *NodeLookup) OnFromNode(id string) *NodeLookup_FromNode

+ func (_m *NodeLookup) OnFromNodeMatch(matchers ...interface{}) *NodeLookup_FromNode

+ func (_m *NodeLookup) OnToNode(id string) *NodeLookup_ToNode

+ func (_m *NodeLookup) OnToNodeMatch(matchers ...interface{}) *NodeLookup_ToNode

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

+ type NodeLookup_FromNode struct

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

+ type NodeLookup_ToNode struct

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

Sep 9, 2022

Changes in this version

type ExecutionContext

+ func (_m *ExecutionContext) GetDefinitionVersion() v1alpha1.WorkflowDefinitionVersion

+ func (_m *ExecutionContext) OnGetDefinitionVersion() *ExecutionContext_GetDefinitionVersion

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

+ type ExecutionContext_GetDefinitionVersion struct

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

type ImmutableExecutionContext

+ func (_m *ImmutableExecutionContext) GetDefinitionVersion() v1alpha1.WorkflowDefinitionVersion

+ func (_m *ImmutableExecutionContext) OnGetDefinitionVersion() *ImmutableExecutionContext_GetDefinitionVersion

+ func (_m *ImmutableExecutionContext) OnGetDefinitionVersionMatch(matchers ...interface{}) *ImmutableExecutionContext_GetDefinitionVersion

+ type ImmutableExecutionContext_GetDefinitionVersion struct

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

Aug 15, 2022

Changes in this version

+ type ClientBuilder struct

+ func (_m *ClientBuilder) Build(_a0 cache.Cache, config *rest.Config, options client.Options) (client.Client, error)

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

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

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

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

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

+ type ClientBuilder_Build struct

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

+ type ClientBuilder_WithUncached struct

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

+ type FakeInformers struct

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

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

+ func (f *FakeInformers) GetInformerForKind(ctx context.Context, gvk schema.GroupVersionKind) (cache.Informer, error)

+ func (f *FakeInformers) IndexField(ctx context.Context, obj client.Object, field string, ...) error

+ func (f *FakeInformers) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error

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

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

Mar 18, 2021

Changes in this version

type ExecutionContext

+ func (_m *ExecutionContext) GetSecurityContext() core.SecurityContext

+ func (_m *ExecutionContext) OnGetSecurityContext() *ExecutionContext_GetSecurityContext

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

+ type ExecutionContext_GetSecurityContext struct

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

type ImmutableExecutionContext

+ func (_m *ImmutableExecutionContext) GetSecurityContext() core.SecurityContext

+ func (_m *ImmutableExecutionContext) OnGetSecurityContext() *ImmutableExecutionContext_GetSecurityContext

+ func (_m *ImmutableExecutionContext) OnGetSecurityContextMatch(matchers ...interface{}) *ImmutableExecutionContext_GetSecurityContext

+ type ImmutableExecutionContext_GetSecurityContext struct

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

Mar 18, 2021

Changes in this version

+ type ControlFlow struct

+ func (_m *ControlFlow) CurrentParallelism() uint32

+ func (_m *ControlFlow) IncrementParallelism() uint32

+ func (_m *ControlFlow) OnCurrentParallelism() *ControlFlow_CurrentParallelism

+ func (_m *ControlFlow) OnCurrentParallelismMatch(matchers ...interface{}) *ControlFlow_CurrentParallelism

+ func (_m *ControlFlow) OnIncrementParallelism() *ControlFlow_IncrementParallelism

+ func (_m *ControlFlow) OnIncrementParallelismMatch(matchers ...interface{}) *ControlFlow_IncrementParallelism

+ type ControlFlow_CurrentParallelism struct

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

+ type ControlFlow_IncrementParallelism struct

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

type ExecutionContext

+ func (_m *ExecutionContext) CurrentParallelism() uint32

+ func (_m *ExecutionContext) IncrementParallelism() uint32

+ func (_m *ExecutionContext) OnCurrentParallelism() *ExecutionContext_CurrentParallelism

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

+ func (_m *ExecutionContext) OnIncrementParallelism() *ExecutionContext_IncrementParallelism

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

+ type ExecutionContext_CurrentParallelism struct

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

+ type ExecutionContext_IncrementParallelism struct

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

Mar 10, 2021

Changes in this version

+ type DAGStructure struct

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

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

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

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

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

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

+ type DAGStructureWithStartNode struct

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

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

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

+ func (_m *DAGStructureWithStartNode) OnStartNode() *DAGStructureWithStartNode_StartNode

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

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

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

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

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

+ type DAGStructureWithStartNode_FromNode struct

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

+ type DAGStructureWithStartNode_StartNode struct

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

+ type DAGStructureWithStartNode_ToNode struct

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

+ type DAGStructure_FromNode struct

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

+ type DAGStructure_ToNode struct

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

+ type ExecutionContext struct

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

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

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

+ func (_m *ExecutionContext) GetEventVersion() v1alpha1.EventVersion

+ func (_m *ExecutionContext) GetExecutionConfig() v1alpha1.ExecutionConfig

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

+ func (_m *ExecutionContext) GetID() string

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

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

+ func (_m *ExecutionContext) GetName() string

+ func (_m *ExecutionContext) GetNamespace() string

+ func (_m *ExecutionContext) GetOnFailurePolicy() v1alpha1.WorkflowOnFailurePolicy

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

+ func (_m *ExecutionContext) GetParentInfo() executors.ImmutableParentInfo

+ func (_m *ExecutionContext) GetRawOutputDataConfig() v1alpha1.RawOutputDataConfig

+ func (_m *ExecutionContext) GetServiceAccountName() string

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

+ func (_m *ExecutionContext) IsInterruptible() bool

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

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

+ func (_m *ExecutionContext) OnGetAnnotations() *ExecutionContext_GetAnnotations

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

+ func (_m *ExecutionContext) OnGetCreationTimestamp() *ExecutionContext_GetCreationTimestamp

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

+ func (_m *ExecutionContext) OnGetEventVersion() *ExecutionContext_GetEventVersion

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

+ func (_m *ExecutionContext) OnGetExecutionConfig() *ExecutionContext_GetExecutionConfig

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

+ func (_m *ExecutionContext) OnGetExecutionID() *ExecutionContext_GetExecutionID

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

+ func (_m *ExecutionContext) OnGetID() *ExecutionContext_GetID

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

+ func (_m *ExecutionContext) OnGetK8sWorkflowID() *ExecutionContext_GetK8sWorkflowID

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

+ func (_m *ExecutionContext) OnGetLabels() *ExecutionContext_GetLabels

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

+ func (_m *ExecutionContext) OnGetName() *ExecutionContext_GetName

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

+ func (_m *ExecutionContext) OnGetNamespace() *ExecutionContext_GetNamespace

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

+ func (_m *ExecutionContext) OnGetOnFailurePolicy() *ExecutionContext_GetOnFailurePolicy

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

+ func (_m *ExecutionContext) OnGetOwnerReference() *ExecutionContext_GetOwnerReference

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

+ func (_m *ExecutionContext) OnGetParentInfo() *ExecutionContext_GetParentInfo

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

+ func (_m *ExecutionContext) OnGetRawOutputDataConfig() *ExecutionContext_GetRawOutputDataConfig

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

+ func (_m *ExecutionContext) OnGetServiceAccountName() *ExecutionContext_GetServiceAccountName

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

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

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

+ func (_m *ExecutionContext) OnIsInterruptible() *ExecutionContext_IsInterruptible

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

+ type ExecutionContext_FindSubWorkflow struct

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

+ type ExecutionContext_GetAnnotations struct

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

+ type ExecutionContext_GetCreationTimestamp struct

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

+ type ExecutionContext_GetEventVersion struct

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

+ type ExecutionContext_GetExecutionConfig struct

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

+ type ExecutionContext_GetExecutionID struct

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

+ type ExecutionContext_GetID struct

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

+ type ExecutionContext_GetK8sWorkflowID struct

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

+ type ExecutionContext_GetLabels struct

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

+ type ExecutionContext_GetName struct

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

+ type ExecutionContext_GetNamespace struct

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

+ type ExecutionContext_GetOnFailurePolicy struct

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

+ type ExecutionContext_GetOwnerReference struct

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

+ type ExecutionContext_GetParentInfo struct

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

+ type ExecutionContext_GetRawOutputDataConfig struct

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

+ type ExecutionContext_GetServiceAccountName struct

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

+ type ExecutionContext_GetTask struct

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

+ type ExecutionContext_IsInterruptible struct

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

+ type ImmutableExecutionContext struct

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

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

+ func (_m *ImmutableExecutionContext) GetEventVersion() v1alpha1.EventVersion

+ func (_m *ImmutableExecutionContext) GetExecutionConfig() v1alpha1.ExecutionConfig

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

+ func (_m *ImmutableExecutionContext) GetID() string

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

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

+ func (_m *ImmutableExecutionContext) GetName() string

+ func (_m *ImmutableExecutionContext) GetNamespace() string

+ func (_m *ImmutableExecutionContext) GetOnFailurePolicy() v1alpha1.WorkflowOnFailurePolicy

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

+ func (_m *ImmutableExecutionContext) GetRawOutputDataConfig() v1alpha1.RawOutputDataConfig

+ func (_m *ImmutableExecutionContext) GetServiceAccountName() string

+ func (_m *ImmutableExecutionContext) IsInterruptible() bool

+ func (_m *ImmutableExecutionContext) OnGetAnnotations() *ImmutableExecutionContext_GetAnnotations

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

+ func (_m *ImmutableExecutionContext) OnGetCreationTimestamp() *ImmutableExecutionContext_GetCreationTimestamp

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

+ func (_m *ImmutableExecutionContext) OnGetEventVersion() *ImmutableExecutionContext_GetEventVersion

+ func (_m *ImmutableExecutionContext) OnGetEventVersionMatch(matchers ...interface{}) *ImmutableExecutionContext_GetEventVersion

+ func (_m *ImmutableExecutionContext) OnGetExecutionConfig() *ImmutableExecutionContext_GetExecutionConfig

+ func (_m *ImmutableExecutionContext) OnGetExecutionConfigMatch(matchers ...interface{}) *ImmutableExecutionContext_GetExecutionConfig

+ func (_m *ImmutableExecutionContext) OnGetExecutionID() *ImmutableExecutionContext_GetExecutionID

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

+ func (_m *ImmutableExecutionContext) OnGetID() *ImmutableExecutionContext_GetID

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

+ func (_m *ImmutableExecutionContext) OnGetK8sWorkflowID() *ImmutableExecutionContext_GetK8sWorkflowID

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

+ func (_m *ImmutableExecutionContext) OnGetLabels() *ImmutableExecutionContext_GetLabels

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

+ func (_m *ImmutableExecutionContext) OnGetName() *ImmutableExecutionContext_GetName

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

+ func (_m *ImmutableExecutionContext) OnGetNamespace() *ImmutableExecutionContext_GetNamespace

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

+ func (_m *ImmutableExecutionContext) OnGetOnFailurePolicy() *ImmutableExecutionContext_GetOnFailurePolicy

+ func (_m *ImmutableExecutionContext) OnGetOnFailurePolicyMatch(matchers ...interface{}) *ImmutableExecutionContext_GetOnFailurePolicy

+ func (_m *ImmutableExecutionContext) OnGetOwnerReference() *ImmutableExecutionContext_GetOwnerReference

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

+ func (_m *ImmutableExecutionContext) OnGetRawOutputDataConfig() *ImmutableExecutionContext_GetRawOutputDataConfig

+ func (_m *ImmutableExecutionContext) OnGetRawOutputDataConfigMatch(matchers ...interface{}) *ImmutableExecutionContext_GetRawOutputDataConfig

+ func (_m *ImmutableExecutionContext) OnGetServiceAccountName() *ImmutableExecutionContext_GetServiceAccountName

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

+ func (_m *ImmutableExecutionContext) OnIsInterruptible() *ImmutableExecutionContext_IsInterruptible

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

+ type ImmutableExecutionContext_GetAnnotations struct

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

+ type ImmutableExecutionContext_GetCreationTimestamp struct

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

+ type ImmutableExecutionContext_GetEventVersion struct

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

+ type ImmutableExecutionContext_GetExecutionConfig struct

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

+ type ImmutableExecutionContext_GetExecutionID struct

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

+ type ImmutableExecutionContext_GetID struct

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

+ type ImmutableExecutionContext_GetK8sWorkflowID struct

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

+ type ImmutableExecutionContext_GetLabels struct

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

+ type ImmutableExecutionContext_GetName struct

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

+ type ImmutableExecutionContext_GetNamespace struct

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

+ type ImmutableExecutionContext_GetOnFailurePolicy struct

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

+ type ImmutableExecutionContext_GetOwnerReference struct

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

+ type ImmutableExecutionContext_GetRawOutputDataConfig struct

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

+ type ImmutableExecutionContext_GetServiceAccountName struct

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

+ type ImmutableExecutionContext_IsInterruptible struct

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

+ type ImmutableParentInfo struct

+ func (_m *ImmutableParentInfo) CurrentAttempt() uint32

+ func (_m *ImmutableParentInfo) GetUniqueID() string

+ func (_m *ImmutableParentInfo) OnCurrentAttempt() *ImmutableParentInfo_CurrentAttempt

+ func (_m *ImmutableParentInfo) OnCurrentAttemptMatch(matchers ...interface{}) *ImmutableParentInfo_CurrentAttempt

+ func (_m *ImmutableParentInfo) OnGetUniqueID() *ImmutableParentInfo_GetUniqueID

+ func (_m *ImmutableParentInfo) OnGetUniqueIDMatch(matchers ...interface{}) *ImmutableParentInfo_GetUniqueID

+ type ImmutableParentInfo_CurrentAttempt struct

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

+ type ImmutableParentInfo_GetUniqueID struct

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

+ type NodeLookup struct

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

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

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

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

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

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

+ type NodeLookup_GetNode struct

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

+ type NodeLookup_GetNodeExecutionStatus struct

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

+ type ParentInfoGetter struct

+ func (_m *ParentInfoGetter) GetParentInfo() executors.ImmutableParentInfo

+ func (_m *ParentInfoGetter) OnGetParentInfo() *ParentInfoGetter_GetParentInfo

+ func (_m *ParentInfoGetter) OnGetParentInfoMatch(matchers ...interface{}) *ParentInfoGetter_GetParentInfo

+ type ParentInfoGetter_GetParentInfo struct

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

+ type SubWorkflowGetter struct

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

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

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

+ type SubWorkflowGetter_FindSubWorkflow struct

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

+ type TaskDetailsGetter struct

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

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

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

+ type TaskDetailsGetter_GetTask struct

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

Dec 3, 2019

Changes in this version

type Node

+ func (_m *Node) FinalizeHandler(ctx context.Context, w v1alpha1.ExecutableWorkflow, ...) error

+ func (_m *Node) OnFinalizeHandler(ctx context.Context, w v1alpha1.ExecutableWorkflow, ...) *Node_FinalizeHandler

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

+ type Node_FinalizeHandler struct

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

Nov 12, 2019

Changes in this version

type Client

+ func (_m *Client) OnGetCache() *Client_GetCache

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

+ func (_m *Client) OnGetClient() *Client_GetClient

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

+ type Client_GetCache struct

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

+ type Client_GetClient struct

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

+ type Node struct

+ func (_m *Node) AbortHandler(ctx context.Context, w v1alpha1.ExecutableWorkflow, ...) error

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

+ func (_m *Node) OnAbortHandler(ctx context.Context, w v1alpha1.ExecutableWorkflow, ...) *Node_AbortHandler

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

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

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

+ func (_m *Node) OnRecursiveNodeHandler(ctx context.Context, w v1alpha1.ExecutableWorkflow, ...) *Node_RecursiveNodeHandler

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

+ func (_m *Node) OnSetInputsForStartNode(ctx context.Context, w v1alpha1.BaseWorkflowWithStatus, ...) *Node_SetInputsForStartNode

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

+ func (_m *Node) RecursiveNodeHandler(ctx context.Context, w v1alpha1.ExecutableWorkflow, ...) (executors.NodeStatus, error)

+ func (_m *Node) SetInputsForStartNode(ctx context.Context, w v1alpha1.BaseWorkflowWithStatus, ...) (executors.NodeStatus, error)

+ type Node_AbortHandler struct

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

+ type Node_Initialize struct

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

+ type Node_RecursiveNodeHandler struct

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

+ type Node_SetInputsForStartNode struct

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

+ type Workflow struct

+ func (_m *Workflow) HandleAbortedWorkflow(ctx context.Context, w *v1alpha1.FlyteWorkflow, maxRetries uint32) error

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

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

+ func (_m *Workflow) OnHandleAbortedWorkflow(ctx context.Context, w *v1alpha1.FlyteWorkflow, maxRetries uint32) *Workflow_HandleAbortedWorkflow

+ func (_m *Workflow) OnHandleAbortedWorkflowMatch(matchers ...interface{}) *Workflow_HandleAbortedWorkflow

+ func (_m *Workflow) OnHandleFlyteWorkflow(ctx context.Context, w *v1alpha1.FlyteWorkflow) *Workflow_HandleFlyteWorkflow

+ func (_m *Workflow) OnHandleFlyteWorkflowMatch(matchers ...interface{}) *Workflow_HandleFlyteWorkflow

+ func (_m *Workflow) OnInitialize(ctx context.Context) *Workflow_Initialize

+ func (_m *Workflow) OnInitializeMatch(matchers ...interface{}) *Workflow_Initialize

+ type Workflow_HandleAbortedWorkflow struct

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

+ type Workflow_HandleFlyteWorkflow struct

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

+ type Workflow_Initialize struct

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

Sep 6, 2019

Changes in this version

+ type Client struct

+ func NewFakeKubeClient() *Client

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

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