mocks

Documentation

Index

• type BaseNode
  • func (_m *BaseNode) GetID() string
  • func (_m *BaseNode) GetKind() v1alpha1.NodeKind
  • func (_m *BaseNode) OnGetID() *BaseNode_GetID
  • func (_m *BaseNode) OnGetIDMatch(matchers ...interface{}) *BaseNode_GetID
  • func (_m *BaseNode) OnGetKind() *BaseNode_GetKind
  • func (_m *BaseNode) OnGetKindMatch(matchers ...interface{}) *BaseNode_GetKind
• type BaseNode_GetID
  • func (_m BaseNode_GetID) Return(_a0 string) *BaseNode_GetID
• type BaseNode_GetKind
  • func (_m BaseNode_GetKind) Return(_a0 v1alpha1.NodeKind) *BaseNode_GetKind
• type BaseWorkflow
  • func (_m *BaseWorkflow) FromNode(name string) ([]string, error)
  • func (_m *BaseWorkflow) GetID() string
  • func (_m *BaseWorkflow) GetNode(nodeID string) (v1alpha1.ExecutableNode, bool)
  • func (_m *BaseWorkflow) OnFromNode(name string) *BaseWorkflow_FromNode
  • func (_m *BaseWorkflow) OnFromNodeMatch(matchers ...interface{}) *BaseWorkflow_FromNode
  • func (_m *BaseWorkflow) OnGetID() *BaseWorkflow_GetID
  • func (_m *BaseWorkflow) OnGetIDMatch(matchers ...interface{}) *BaseWorkflow_GetID
  • func (_m *BaseWorkflow) OnGetNode(nodeID string) *BaseWorkflow_GetNode
  • func (_m *BaseWorkflow) OnGetNodeMatch(matchers ...interface{}) *BaseWorkflow_GetNode
  • func (_m *BaseWorkflow) OnStartNode() *BaseWorkflow_StartNode
  • func (_m *BaseWorkflow) OnStartNodeMatch(matchers ...interface{}) *BaseWorkflow_StartNode
  • func (_m *BaseWorkflow) StartNode() v1alpha1.ExecutableNode
• type BaseWorkflowWithStatus
  • func (_m *BaseWorkflowWithStatus) FromNode(name string) ([]string, error)
  • func (_m *BaseWorkflowWithStatus) GetID() string
  • func (_m *BaseWorkflowWithStatus) GetNode(nodeID string) (v1alpha1.ExecutableNode, bool)
  • func (_m *BaseWorkflowWithStatus) GetNodeExecutionStatus(ctx context.Context, id string) v1alpha1.ExecutableNodeStatus
  • func (_m *BaseWorkflowWithStatus) OnFromNode(name string) *BaseWorkflowWithStatus_FromNode
  • func (_m *BaseWorkflowWithStatus) OnFromNodeMatch(matchers ...interface{}) *BaseWorkflowWithStatus_FromNode
  • func (_m *BaseWorkflowWithStatus) OnGetID() *BaseWorkflowWithStatus_GetID
  • func (_m *BaseWorkflowWithStatus) OnGetIDMatch(matchers ...interface{}) *BaseWorkflowWithStatus_GetID
  • func (_m *BaseWorkflowWithStatus) OnGetNode(nodeID string) *BaseWorkflowWithStatus_GetNode
  • func (_m *BaseWorkflowWithStatus) OnGetNodeExecutionStatus(ctx context.Context, id string) *BaseWorkflowWithStatus_GetNodeExecutionStatus
  • func (_m *BaseWorkflowWithStatus) OnGetNodeExecutionStatusMatch(matchers ...interface{}) *BaseWorkflowWithStatus_GetNodeExecutionStatus
  • func (_m *BaseWorkflowWithStatus) OnGetNodeMatch(matchers ...interface{}) *BaseWorkflowWithStatus_GetNode
  • func (_m *BaseWorkflowWithStatus) OnStartNode() *BaseWorkflowWithStatus_StartNode
  • func (_m *BaseWorkflowWithStatus) OnStartNodeMatch(matchers ...interface{}) *BaseWorkflowWithStatus_StartNode
  • func (_m *BaseWorkflowWithStatus) StartNode() v1alpha1.ExecutableNode
• type BaseWorkflowWithStatus_FromNode
  • func (_m BaseWorkflowWithStatus_FromNode) Return(_a0 []string, _a1 error) *BaseWorkflowWithStatus_FromNode
• type BaseWorkflowWithStatus_GetID
  • func (_m BaseWorkflowWithStatus_GetID) Return(_a0 string) *BaseWorkflowWithStatus_GetID
• type BaseWorkflowWithStatus_GetNode
  • func (_m BaseWorkflowWithStatus_GetNode) Return(_a0 v1alpha1.ExecutableNode, _a1 bool) *BaseWorkflowWithStatus_GetNode
• type BaseWorkflowWithStatus_GetNodeExecutionStatus
  • func (_m BaseWorkflowWithStatus_GetNodeExecutionStatus) Return(_a0 v1alpha1.ExecutableNodeStatus) *BaseWorkflowWithStatus_GetNodeExecutionStatus
• type BaseWorkflowWithStatus_StartNode
  • func (_m BaseWorkflowWithStatus_StartNode) Return(_a0 v1alpha1.ExecutableNode) *BaseWorkflowWithStatus_StartNode
• type BaseWorkflow_FromNode
  • func (_m BaseWorkflow_FromNode) Return(_a0 []string, _a1 error) *BaseWorkflow_FromNode
• type BaseWorkflow_GetID
  • func (_m BaseWorkflow_GetID) Return(_a0 string) *BaseWorkflow_GetID
• type BaseWorkflow_GetNode
  • func (_m BaseWorkflow_GetNode) Return(_a0 v1alpha1.ExecutableNode, _a1 bool) *BaseWorkflow_GetNode
• type BaseWorkflow_StartNode
  • func (_m BaseWorkflow_StartNode) Return(_a0 v1alpha1.ExecutableNode) *BaseWorkflow_StartNode
• type ExecutableBranchNode
  • func (_m *ExecutableBranchNode) GetElse() *string
  • func (_m *ExecutableBranchNode) GetElseFail() *core.Error
  • func (_m *ExecutableBranchNode) GetElseIf() []v1alpha1.ExecutableIfBlock
  • func (_m *ExecutableBranchNode) GetIf() v1alpha1.ExecutableIfBlock
  • func (_m *ExecutableBranchNode) OnGetElse() *ExecutableBranchNode_GetElse
  • func (_m *ExecutableBranchNode) OnGetElseFail() *ExecutableBranchNode_GetElseFail
  • func (_m *ExecutableBranchNode) OnGetElseFailMatch(matchers ...interface{}) *ExecutableBranchNode_GetElseFail
  • func (_m *ExecutableBranchNode) OnGetElseIf() *ExecutableBranchNode_GetElseIf
  • func (_m *ExecutableBranchNode) OnGetElseIfMatch(matchers ...interface{}) *ExecutableBranchNode_GetElseIf
  • func (_m *ExecutableBranchNode) OnGetElseMatch(matchers ...interface{}) *ExecutableBranchNode_GetElse
  • func (_m *ExecutableBranchNode) OnGetIf() *ExecutableBranchNode_GetIf
  • func (_m *ExecutableBranchNode) OnGetIfMatch(matchers ...interface{}) *ExecutableBranchNode_GetIf
• type ExecutableBranchNodeStatus
  • func (_m *ExecutableBranchNodeStatus) GetFinalizedNode() *string
  • func (_m *ExecutableBranchNodeStatus) GetPhase() v1alpha1.BranchNodePhase
  • func (_m *ExecutableBranchNodeStatus) OnGetFinalizedNode() *ExecutableBranchNodeStatus_GetFinalizedNode
  • func (_m *ExecutableBranchNodeStatus) OnGetFinalizedNodeMatch(matchers ...interface{}) *ExecutableBranchNodeStatus_GetFinalizedNode
  • func (_m *ExecutableBranchNodeStatus) OnGetPhase() *ExecutableBranchNodeStatus_GetPhase
  • func (_m *ExecutableBranchNodeStatus) OnGetPhaseMatch(matchers ...interface{}) *ExecutableBranchNodeStatus_GetPhase
• type ExecutableBranchNodeStatus_GetFinalizedNode
  • func (_m ExecutableBranchNodeStatus_GetFinalizedNode) Return(_a0 *string) *ExecutableBranchNodeStatus_GetFinalizedNode
• type ExecutableBranchNodeStatus_GetPhase
  • func (_m ExecutableBranchNodeStatus_GetPhase) Return(_a0 v1alpha1.BranchNodePhase) *ExecutableBranchNodeStatus_GetPhase
• type ExecutableBranchNode_GetElse
  • func (_m ExecutableBranchNode_GetElse) Return(_a0 *string) *ExecutableBranchNode_GetElse
• type ExecutableBranchNode_GetElseFail
  • func (_m ExecutableBranchNode_GetElseFail) Return(_a0 *core.Error) *ExecutableBranchNode_GetElseFail
• type ExecutableBranchNode_GetElseIf
  • func (_m ExecutableBranchNode_GetElseIf) Return(_a0 []v1alpha1.ExecutableIfBlock) *ExecutableBranchNode_GetElseIf
• type ExecutableBranchNode_GetIf
  • func (_m ExecutableBranchNode_GetIf) Return(_a0 v1alpha1.ExecutableIfBlock) *ExecutableBranchNode_GetIf
• type ExecutableDynamicNodeStatus
  • func (_m *ExecutableDynamicNodeStatus) GetDynamicNodePhase() v1alpha1.DynamicNodePhase
  • func (_m *ExecutableDynamicNodeStatus) GetDynamicNodeReason() string
  • func (_m *ExecutableDynamicNodeStatus) OnGetDynamicNodePhase() *ExecutableDynamicNodeStatus_GetDynamicNodePhase
  • func (_m *ExecutableDynamicNodeStatus) OnGetDynamicNodePhaseMatch(matchers ...interface{}) *ExecutableDynamicNodeStatus_GetDynamicNodePhase
  • func (_m *ExecutableDynamicNodeStatus) OnGetDynamicNodeReason() *ExecutableDynamicNodeStatus_GetDynamicNodeReason
  • func (_m *ExecutableDynamicNodeStatus) OnGetDynamicNodeReasonMatch(matchers ...interface{}) *ExecutableDynamicNodeStatus_GetDynamicNodeReason
• type ExecutableDynamicNodeStatus_GetDynamicNodePhase
  • func (_m ExecutableDynamicNodeStatus_GetDynamicNodePhase) Return(_a0 v1alpha1.DynamicNodePhase) *ExecutableDynamicNodeStatus_GetDynamicNodePhase
• type ExecutableDynamicNodeStatus_GetDynamicNodeReason
  • func (_m ExecutableDynamicNodeStatus_GetDynamicNodeReason) Return(_a0 string) *ExecutableDynamicNodeStatus_GetDynamicNodeReason
• type ExecutableIfBlock
  • func (_m *ExecutableIfBlock) GetCondition() *core.BooleanExpression
  • func (_m *ExecutableIfBlock) GetThenNode() *string
  • func (_m *ExecutableIfBlock) OnGetCondition() *ExecutableIfBlock_GetCondition
  • func (_m *ExecutableIfBlock) OnGetConditionMatch(matchers ...interface{}) *ExecutableIfBlock_GetCondition
  • func (_m *ExecutableIfBlock) OnGetThenNode() *ExecutableIfBlock_GetThenNode
  • func (_m *ExecutableIfBlock) OnGetThenNodeMatch(matchers ...interface{}) *ExecutableIfBlock_GetThenNode
• type ExecutableIfBlock_GetCondition
  • func (_m ExecutableIfBlock_GetCondition) Return(_a0 *core.BooleanExpression) *ExecutableIfBlock_GetCondition
• type ExecutableIfBlock_GetThenNode
  • func (_m ExecutableIfBlock_GetThenNode) Return(_a0 *string) *ExecutableIfBlock_GetThenNode
• type ExecutableNode
  • func (_m *ExecutableNode) GetActiveDeadline() *time.Duration
  • func (_m *ExecutableNode) GetBranchNode() v1alpha1.ExecutableBranchNode
  • func (_m *ExecutableNode) GetConfig() *v1.ConfigMap
  • func (_m *ExecutableNode) GetExecutionDeadline() *time.Duration
  • func (_m *ExecutableNode) GetID() string
  • func (_m *ExecutableNode) GetInputBindings() []*v1alpha1.Binding
  • func (_m *ExecutableNode) GetKind() v1alpha1.NodeKind
  • func (_m *ExecutableNode) GetOutputAlias() []v1alpha1.Alias
  • func (_m *ExecutableNode) GetResources() *v1.ResourceRequirements
  • func (_m *ExecutableNode) GetRetryStrategy() *v1alpha1.RetryStrategy
  • func (_m *ExecutableNode) GetTaskID() *string
  • func (_m *ExecutableNode) GetWorkflowNode() v1alpha1.ExecutableWorkflowNode
  • func (_m *ExecutableNode) IsEndNode() bool
  • func (_m *ExecutableNode) IsStartNode() bool
  • func (_m *ExecutableNode) OnGetActiveDeadline() *ExecutableNode_GetActiveDeadline
  • func (_m *ExecutableNode) OnGetActiveDeadlineMatch(matchers ...interface{}) *ExecutableNode_GetActiveDeadline
  • func (_m *ExecutableNode) OnGetBranchNode() *ExecutableNode_GetBranchNode
  • func (_m *ExecutableNode) OnGetBranchNodeMatch(matchers ...interface{}) *ExecutableNode_GetBranchNode
  • func (_m *ExecutableNode) OnGetConfig() *ExecutableNode_GetConfig
  • func (_m *ExecutableNode) OnGetConfigMatch(matchers ...interface{}) *ExecutableNode_GetConfig
  • func (_m *ExecutableNode) OnGetExecutionDeadline() *ExecutableNode_GetExecutionDeadline
  • func (_m *ExecutableNode) OnGetExecutionDeadlineMatch(matchers ...interface{}) *ExecutableNode_GetExecutionDeadline
  • func (_m *ExecutableNode) OnGetID() *ExecutableNode_GetID
  • func (_m *ExecutableNode) OnGetIDMatch(matchers ...interface{}) *ExecutableNode_GetID
  • func (_m *ExecutableNode) OnGetInputBindings() *ExecutableNode_GetInputBindings
  • func (_m *ExecutableNode) OnGetInputBindingsMatch(matchers ...interface{}) *ExecutableNode_GetInputBindings
  • func (_m *ExecutableNode) OnGetKind() *ExecutableNode_GetKind
  • func (_m *ExecutableNode) OnGetKindMatch(matchers ...interface{}) *ExecutableNode_GetKind
  • func (_m *ExecutableNode) OnGetOutputAlias() *ExecutableNode_GetOutputAlias
  • func (_m *ExecutableNode) OnGetOutputAliasMatch(matchers ...interface{}) *ExecutableNode_GetOutputAlias
  • func (_m *ExecutableNode) OnGetResources() *ExecutableNode_GetResources
  • func (_m *ExecutableNode) OnGetResourcesMatch(matchers ...interface{}) *ExecutableNode_GetResources
  • func (_m *ExecutableNode) OnGetRetryStrategy() *ExecutableNode_GetRetryStrategy
  • func (_m *ExecutableNode) OnGetRetryStrategyMatch(matchers ...interface{}) *ExecutableNode_GetRetryStrategy
  • func (_m *ExecutableNode) OnGetTaskID() *ExecutableNode_GetTaskID
  • func (_m *ExecutableNode) OnGetTaskIDMatch(matchers ...interface{}) *ExecutableNode_GetTaskID
  • func (_m *ExecutableNode) OnGetWorkflowNode() *ExecutableNode_GetWorkflowNode
  • func (_m *ExecutableNode) OnGetWorkflowNodeMatch(matchers ...interface{}) *ExecutableNode_GetWorkflowNode
  • func (_m *ExecutableNode) OnIsEndNode() *ExecutableNode_IsEndNode
  • func (_m *ExecutableNode) OnIsEndNodeMatch(matchers ...interface{}) *ExecutableNode_IsEndNode
  • func (_m *ExecutableNode) OnIsStartNode() *ExecutableNode_IsStartNode
  • func (_m *ExecutableNode) OnIsStartNodeMatch(matchers ...interface{}) *ExecutableNode_IsStartNode
• type ExecutableNodeStatus
  • func (_m *ExecutableNodeStatus) ClearDynamicNodeStatus()
  • func (_m *ExecutableNodeStatus) ClearLastAttemptStartedAt()
  • func (_m *ExecutableNodeStatus) ClearSubNodeStatus()
  • func (_m *ExecutableNodeStatus) ClearTaskStatus()
  • func (_m *ExecutableNodeStatus) ClearWorkflowStatus()
  • func (_m *ExecutableNodeStatus) GetAttempts() uint32
  • func (_m *ExecutableNodeStatus) GetBranchStatus() v1alpha1.MutableBranchNodeStatus
  • func (_m *ExecutableNodeStatus) GetDataDir() storage.DataReference
  • func (_m *ExecutableNodeStatus) GetDynamicNodeStatus() v1alpha1.MutableDynamicNodeStatus
  • func (_m *ExecutableNodeStatus) GetLastAttemptStartedAt() *v1.Time
  • func (_m *ExecutableNodeStatus) GetLastUpdatedAt() *v1.Time
  • func (_m *ExecutableNodeStatus) GetMessage() string
  • func (_m *ExecutableNodeStatus) GetNodeExecutionStatus(ctx context.Context, id string) v1alpha1.ExecutableNodeStatus
  • func (_m *ExecutableNodeStatus) GetOrCreateBranchStatus() v1alpha1.MutableBranchNodeStatus
  • func (_m *ExecutableNodeStatus) GetOrCreateDynamicNodeStatus() v1alpha1.MutableDynamicNodeStatus
  • func (_m *ExecutableNodeStatus) GetOrCreateTaskStatus() v1alpha1.MutableTaskNodeStatus
  • func (_m *ExecutableNodeStatus) GetOrCreateWorkflowStatus() v1alpha1.MutableWorkflowNodeStatus
  • func (_m *ExecutableNodeStatus) GetOutputDir() storage.DataReference
  • func (_m *ExecutableNodeStatus) GetParentNodeID() *string
  • func (_m *ExecutableNodeStatus) GetParentTaskID() *core.TaskExecutionIdentifier
  • func (_m *ExecutableNodeStatus) GetPhase() v1alpha1.NodePhase
  • func (_m *ExecutableNodeStatus) GetQueuedAt() *v1.Time
  • func (_m *ExecutableNodeStatus) GetStartedAt() *v1.Time
  • func (_m *ExecutableNodeStatus) GetStoppedAt() *v1.Time
  • func (_m *ExecutableNodeStatus) GetTaskNodeStatus() v1alpha1.ExecutableTaskNodeStatus
  • func (_m *ExecutableNodeStatus) GetTaskStatus() v1alpha1.MutableTaskNodeStatus
  • func (_m *ExecutableNodeStatus) GetWorkflowNodeStatus() v1alpha1.ExecutableWorkflowNodeStatus
  • func (_m *ExecutableNodeStatus) GetWorkflowStatus() v1alpha1.MutableWorkflowNodeStatus
  • func (_m *ExecutableNodeStatus) IncrementAttempts() uint32
  • func (_m *ExecutableNodeStatus) IsCached() bool
  • func (_m *ExecutableNodeStatus) IsDirty() bool
  • func (_m *ExecutableNodeStatus) OnGetAttempts() *ExecutableNodeStatus_GetAttempts
  • func (_m *ExecutableNodeStatus) OnGetAttemptsMatch(matchers ...interface{}) *ExecutableNodeStatus_GetAttempts
  • func (_m *ExecutableNodeStatus) OnGetBranchStatus() *ExecutableNodeStatus_GetBranchStatus
  • func (_m *ExecutableNodeStatus) OnGetBranchStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetBranchStatus
  • func (_m *ExecutableNodeStatus) OnGetDataDir() *ExecutableNodeStatus_GetDataDir
  • func (_m *ExecutableNodeStatus) OnGetDataDirMatch(matchers ...interface{}) *ExecutableNodeStatus_GetDataDir
  • func (_m *ExecutableNodeStatus) OnGetDynamicNodeStatus() *ExecutableNodeStatus_GetDynamicNodeStatus
  • func (_m *ExecutableNodeStatus) OnGetDynamicNodeStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetDynamicNodeStatus
  • func (_m *ExecutableNodeStatus) OnGetLastAttemptStartedAt() *ExecutableNodeStatus_GetLastAttemptStartedAt
  • func (_m *ExecutableNodeStatus) OnGetLastAttemptStartedAtMatch(matchers ...interface{}) *ExecutableNodeStatus_GetLastAttemptStartedAt
  • func (_m *ExecutableNodeStatus) OnGetLastUpdatedAt() *ExecutableNodeStatus_GetLastUpdatedAt
  • func (_m *ExecutableNodeStatus) OnGetLastUpdatedAtMatch(matchers ...interface{}) *ExecutableNodeStatus_GetLastUpdatedAt
  • func (_m *ExecutableNodeStatus) OnGetMessage() *ExecutableNodeStatus_GetMessage
  • func (_m *ExecutableNodeStatus) OnGetMessageMatch(matchers ...interface{}) *ExecutableNodeStatus_GetMessage
  • func (_m *ExecutableNodeStatus) OnGetNodeExecutionStatus(ctx context.Context, id string) *ExecutableNodeStatus_GetNodeExecutionStatus
  • func (_m *ExecutableNodeStatus) OnGetNodeExecutionStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetNodeExecutionStatus
  • func (_m *ExecutableNodeStatus) OnGetOrCreateBranchStatus() *ExecutableNodeStatus_GetOrCreateBranchStatus
  • func (_m *ExecutableNodeStatus) OnGetOrCreateBranchStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetOrCreateBranchStatus
  • func (_m *ExecutableNodeStatus) OnGetOrCreateDynamicNodeStatus() *ExecutableNodeStatus_GetOrCreateDynamicNodeStatus
  • func (_m *ExecutableNodeStatus) OnGetOrCreateDynamicNodeStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetOrCreateDynamicNodeStatus
  • func (_m *ExecutableNodeStatus) OnGetOrCreateTaskStatus() *ExecutableNodeStatus_GetOrCreateTaskStatus
  • func (_m *ExecutableNodeStatus) OnGetOrCreateTaskStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetOrCreateTaskStatus
  • func (_m *ExecutableNodeStatus) OnGetOrCreateWorkflowStatus() *ExecutableNodeStatus_GetOrCreateWorkflowStatus
  • func (_m *ExecutableNodeStatus) OnGetOrCreateWorkflowStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetOrCreateWorkflowStatus
  • func (_m *ExecutableNodeStatus) OnGetOutputDir() *ExecutableNodeStatus_GetOutputDir
  • func (_m *ExecutableNodeStatus) OnGetOutputDirMatch(matchers ...interface{}) *ExecutableNodeStatus_GetOutputDir
  • func (_m *ExecutableNodeStatus) OnGetParentNodeID() *ExecutableNodeStatus_GetParentNodeID
  • func (_m *ExecutableNodeStatus) OnGetParentNodeIDMatch(matchers ...interface{}) *ExecutableNodeStatus_GetParentNodeID
  • func (_m *ExecutableNodeStatus) OnGetParentTaskID() *ExecutableNodeStatus_GetParentTaskID
  • func (_m *ExecutableNodeStatus) OnGetParentTaskIDMatch(matchers ...interface{}) *ExecutableNodeStatus_GetParentTaskID
  • func (_m *ExecutableNodeStatus) OnGetPhase() *ExecutableNodeStatus_GetPhase
  • func (_m *ExecutableNodeStatus) OnGetPhaseMatch(matchers ...interface{}) *ExecutableNodeStatus_GetPhase
  • func (_m *ExecutableNodeStatus) OnGetQueuedAt() *ExecutableNodeStatus_GetQueuedAt
  • func (_m *ExecutableNodeStatus) OnGetQueuedAtMatch(matchers ...interface{}) *ExecutableNodeStatus_GetQueuedAt
  • func (_m *ExecutableNodeStatus) OnGetStartedAt() *ExecutableNodeStatus_GetStartedAt
  • func (_m *ExecutableNodeStatus) OnGetStartedAtMatch(matchers ...interface{}) *ExecutableNodeStatus_GetStartedAt
  • func (_m *ExecutableNodeStatus) OnGetStoppedAt() *ExecutableNodeStatus_GetStoppedAt
  • func (_m *ExecutableNodeStatus) OnGetStoppedAtMatch(matchers ...interface{}) *ExecutableNodeStatus_GetStoppedAt
  • func (_m *ExecutableNodeStatus) OnGetTaskNodeStatus() *ExecutableNodeStatus_GetTaskNodeStatus
  • func (_m *ExecutableNodeStatus) OnGetTaskNodeStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetTaskNodeStatus
  • func (_m *ExecutableNodeStatus) OnGetTaskStatus() *ExecutableNodeStatus_GetTaskStatus
  • func (_m *ExecutableNodeStatus) OnGetTaskStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetTaskStatus
  • func (_m *ExecutableNodeStatus) OnGetWorkflowNodeStatus() *ExecutableNodeStatus_GetWorkflowNodeStatus
  • func (_m *ExecutableNodeStatus) OnGetWorkflowNodeStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetWorkflowNodeStatus
  • func (_m *ExecutableNodeStatus) OnGetWorkflowStatus() *ExecutableNodeStatus_GetWorkflowStatus
  • func (_m *ExecutableNodeStatus) OnGetWorkflowStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetWorkflowStatus
  • func (_m *ExecutableNodeStatus) OnIncrementAttempts() *ExecutableNodeStatus_IncrementAttempts
  • func (_m *ExecutableNodeStatus) OnIncrementAttemptsMatch(matchers ...interface{}) *ExecutableNodeStatus_IncrementAttempts
  • func (_m *ExecutableNodeStatus) OnIsCached() *ExecutableNodeStatus_IsCached
  • func (_m *ExecutableNodeStatus) OnIsCachedMatch(matchers ...interface{}) *ExecutableNodeStatus_IsCached
  • func (_m *ExecutableNodeStatus) OnIsDirty() *ExecutableNodeStatus_IsDirty
  • func (_m *ExecutableNodeStatus) OnIsDirtyMatch(matchers ...interface{}) *ExecutableNodeStatus_IsDirty
  • func (_m *ExecutableNodeStatus) ResetDirty()
  • func (_m *ExecutableNodeStatus) SetCached()
  • func (_m *ExecutableNodeStatus) SetDataDir(_a0 storage.DataReference)
  • func (_m *ExecutableNodeStatus) SetOutputDir(d storage.DataReference)
  • func (_m *ExecutableNodeStatus) SetParentNodeID(n *string)
  • func (_m *ExecutableNodeStatus) SetParentTaskID(t *core.TaskExecutionIdentifier)
  • func (_m *ExecutableNodeStatus) UpdatePhase(phase v1alpha1.NodePhase, occurredAt v1.Time, reason string)
  • func (_m *ExecutableNodeStatus) VisitNodeStatuses(visitor func(string, v1alpha1.ExecutableNodeStatus))
• type ExecutableNodeStatus_GetAttempts
  • func (_m ExecutableNodeStatus_GetAttempts) Return(_a0 uint32) *ExecutableNodeStatus_GetAttempts
• type ExecutableNodeStatus_GetBranchStatus
  • func (_m ExecutableNodeStatus_GetBranchStatus) Return(_a0 v1alpha1.MutableBranchNodeStatus) *ExecutableNodeStatus_GetBranchStatus
• type ExecutableNodeStatus_GetDataDir
  • func (_m ExecutableNodeStatus_GetDataDir) Return(_a0 storage.DataReference) *ExecutableNodeStatus_GetDataDir
• type ExecutableNodeStatus_GetDynamicNodeStatus
  • func (_m ExecutableNodeStatus_GetDynamicNodeStatus) Return(_a0 v1alpha1.MutableDynamicNodeStatus) *ExecutableNodeStatus_GetDynamicNodeStatus
• type ExecutableNodeStatus_GetLastAttemptStartedAt
  • func (_m ExecutableNodeStatus_GetLastAttemptStartedAt) Return(_a0 *v1.Time) *ExecutableNodeStatus_GetLastAttemptStartedAt
• type ExecutableNodeStatus_GetLastUpdatedAt
  • func (_m ExecutableNodeStatus_GetLastUpdatedAt) Return(_a0 *v1.Time) *ExecutableNodeStatus_GetLastUpdatedAt
• type ExecutableNodeStatus_GetMessage
  • func (_m ExecutableNodeStatus_GetMessage) Return(_a0 string) *ExecutableNodeStatus_GetMessage
• type ExecutableNodeStatus_GetNodeExecutionStatus
  • func (_m ExecutableNodeStatus_GetNodeExecutionStatus) Return(_a0 v1alpha1.ExecutableNodeStatus) *ExecutableNodeStatus_GetNodeExecutionStatus
• type ExecutableNodeStatus_GetOrCreateBranchStatus
  • func (_m ExecutableNodeStatus_GetOrCreateBranchStatus) Return(_a0 v1alpha1.MutableBranchNodeStatus) *ExecutableNodeStatus_GetOrCreateBranchStatus
• type ExecutableNodeStatus_GetOrCreateDynamicNodeStatus
  • func (_m ExecutableNodeStatus_GetOrCreateDynamicNodeStatus) Return(_a0 v1alpha1.MutableDynamicNodeStatus) *ExecutableNodeStatus_GetOrCreateDynamicNodeStatus
• type ExecutableNodeStatus_GetOrCreateTaskStatus
  • func (_m ExecutableNodeStatus_GetOrCreateTaskStatus) Return(_a0 v1alpha1.MutableTaskNodeStatus) *ExecutableNodeStatus_GetOrCreateTaskStatus
• type ExecutableNodeStatus_GetOrCreateWorkflowStatus
  • func (_m ExecutableNodeStatus_GetOrCreateWorkflowStatus) Return(_a0 v1alpha1.MutableWorkflowNodeStatus) *ExecutableNodeStatus_GetOrCreateWorkflowStatus
• type ExecutableNodeStatus_GetOutputDir
  • func (_m ExecutableNodeStatus_GetOutputDir) Return(_a0 storage.DataReference) *ExecutableNodeStatus_GetOutputDir
• type ExecutableNodeStatus_GetParentNodeID
  • func (_m ExecutableNodeStatus_GetParentNodeID) Return(_a0 *string) *ExecutableNodeStatus_GetParentNodeID
• type ExecutableNodeStatus_GetParentTaskID
  • func (_m ExecutableNodeStatus_GetParentTaskID) Return(_a0 *core.TaskExecutionIdentifier) *ExecutableNodeStatus_GetParentTaskID
• type ExecutableNodeStatus_GetPhase
  • func (_m ExecutableNodeStatus_GetPhase) Return(_a0 v1alpha1.NodePhase) *ExecutableNodeStatus_GetPhase
• type ExecutableNodeStatus_GetQueuedAt
  • func (_m ExecutableNodeStatus_GetQueuedAt) Return(_a0 *v1.Time) *ExecutableNodeStatus_GetQueuedAt
• type ExecutableNodeStatus_GetStartedAt
  • func (_m ExecutableNodeStatus_GetStartedAt) Return(_a0 *v1.Time) *ExecutableNodeStatus_GetStartedAt
• type ExecutableNodeStatus_GetStoppedAt
  • func (_m ExecutableNodeStatus_GetStoppedAt) Return(_a0 *v1.Time) *ExecutableNodeStatus_GetStoppedAt
• type ExecutableNodeStatus_GetTaskNodeStatus
  • func (_m ExecutableNodeStatus_GetTaskNodeStatus) Return(_a0 v1alpha1.ExecutableTaskNodeStatus) *ExecutableNodeStatus_GetTaskNodeStatus
• type ExecutableNodeStatus_GetTaskStatus
  • func (_m ExecutableNodeStatus_GetTaskStatus) Return(_a0 v1alpha1.MutableTaskNodeStatus) *ExecutableNodeStatus_GetTaskStatus
• type ExecutableNodeStatus_GetWorkflowNodeStatus
  • func (_m ExecutableNodeStatus_GetWorkflowNodeStatus) Return(_a0 v1alpha1.ExecutableWorkflowNodeStatus) *ExecutableNodeStatus_GetWorkflowNodeStatus
• type ExecutableNodeStatus_GetWorkflowStatus
  • func (_m ExecutableNodeStatus_GetWorkflowStatus) Return(_a0 v1alpha1.MutableWorkflowNodeStatus) *ExecutableNodeStatus_GetWorkflowStatus
• type ExecutableNodeStatus_IncrementAttempts
  • func (_m ExecutableNodeStatus_IncrementAttempts) Return(_a0 uint32) *ExecutableNodeStatus_IncrementAttempts
• type ExecutableNodeStatus_IsCached
  • func (_m ExecutableNodeStatus_IsCached) Return(_a0 bool) *ExecutableNodeStatus_IsCached
• type ExecutableNodeStatus_IsDirty
  • func (_m ExecutableNodeStatus_IsDirty) Return(_a0 bool) *ExecutableNodeStatus_IsDirty
• type ExecutableNode_GetActiveDeadline
  • func (_m ExecutableNode_GetActiveDeadline) Return(_a0 *time.Duration) *ExecutableNode_GetActiveDeadline
• type ExecutableNode_GetBranchNode
  • func (_m ExecutableNode_GetBranchNode) Return(_a0 v1alpha1.ExecutableBranchNode) *ExecutableNode_GetBranchNode
• type ExecutableNode_GetConfig
  • func (_m ExecutableNode_GetConfig) Return(_a0 *v1.ConfigMap) *ExecutableNode_GetConfig
• type ExecutableNode_GetExecutionDeadline
  • func (_m ExecutableNode_GetExecutionDeadline) Return(_a0 *time.Duration) *ExecutableNode_GetExecutionDeadline
• type ExecutableNode_GetID
  • func (_m ExecutableNode_GetID) Return(_a0 string) *ExecutableNode_GetID
• type ExecutableNode_GetInputBindings
  • func (_m ExecutableNode_GetInputBindings) Return(_a0 []*v1alpha1.Binding) *ExecutableNode_GetInputBindings
• type ExecutableNode_GetKind
  • func (_m ExecutableNode_GetKind) Return(_a0 v1alpha1.NodeKind) *ExecutableNode_GetKind
• type ExecutableNode_GetOutputAlias
  • func (_m ExecutableNode_GetOutputAlias) Return(_a0 []v1alpha1.Alias) *ExecutableNode_GetOutputAlias
• type ExecutableNode_GetResources
  • func (_m ExecutableNode_GetResources) Return(_a0 *v1.ResourceRequirements) *ExecutableNode_GetResources
• type ExecutableNode_GetRetryStrategy
  • func (_m ExecutableNode_GetRetryStrategy) Return(_a0 *v1alpha1.RetryStrategy) *ExecutableNode_GetRetryStrategy
• type ExecutableNode_GetTaskID
  • func (_m ExecutableNode_GetTaskID) Return(_a0 *string) *ExecutableNode_GetTaskID
• type ExecutableNode_GetWorkflowNode
  • func (_m ExecutableNode_GetWorkflowNode) Return(_a0 v1alpha1.ExecutableWorkflowNode) *ExecutableNode_GetWorkflowNode
• type ExecutableNode_IsEndNode
  • func (_m ExecutableNode_IsEndNode) Return(_a0 bool) *ExecutableNode_IsEndNode
• type ExecutableNode_IsStartNode
  • func (_m ExecutableNode_IsStartNode) Return(_a0 bool) *ExecutableNode_IsStartNode
• type ExecutableSubWorkflow
  • func (_m *ExecutableSubWorkflow) FromNode(name string) ([]string, error)
  • func (_m *ExecutableSubWorkflow) GetConnections() *v1alpha1.Connections
  • func (_m *ExecutableSubWorkflow) GetID() string
  • func (_m *ExecutableSubWorkflow) GetNode(nodeID string) (v1alpha1.ExecutableNode, bool)
  • func (_m *ExecutableSubWorkflow) GetNodes() []string
  • func (_m *ExecutableSubWorkflow) GetOnFailureNode() v1alpha1.ExecutableNode
  • func (_m *ExecutableSubWorkflow) GetOutputBindings() []*v1alpha1.Binding
  • func (_m *ExecutableSubWorkflow) GetOutputs() *v1alpha1.OutputVarMap
  • func (_m *ExecutableSubWorkflow) OnFromNode(name string) *ExecutableSubWorkflow_FromNode
  • func (_m *ExecutableSubWorkflow) OnFromNodeMatch(matchers ...interface{}) *ExecutableSubWorkflow_FromNode
  • func (_m *ExecutableSubWorkflow) OnGetConnections() *ExecutableSubWorkflow_GetConnections
  • func (_m *ExecutableSubWorkflow) OnGetConnectionsMatch(matchers ...interface{}) *ExecutableSubWorkflow_GetConnections
  • func (_m *ExecutableSubWorkflow) OnGetID() *ExecutableSubWorkflow_GetID
  • func (_m *ExecutableSubWorkflow) OnGetIDMatch(matchers ...interface{}) *ExecutableSubWorkflow_GetID
  • func (_m *ExecutableSubWorkflow) OnGetNode(nodeID string) *ExecutableSubWorkflow_GetNode
  • func (_m *ExecutableSubWorkflow) OnGetNodeMatch(matchers ...interface{}) *ExecutableSubWorkflow_GetNode
  • func (_m *ExecutableSubWorkflow) OnGetNodes() *ExecutableSubWorkflow_GetNodes
  • func (_m *ExecutableSubWorkflow) OnGetNodesMatch(matchers ...interface{}) *ExecutableSubWorkflow_GetNodes
  • func (_m *ExecutableSubWorkflow) OnGetOnFailureNode() *ExecutableSubWorkflow_GetOnFailureNode
  • func (_m *ExecutableSubWorkflow) OnGetOnFailureNodeMatch(matchers ...interface{}) *ExecutableSubWorkflow_GetOnFailureNode
  • func (_m *ExecutableSubWorkflow) OnGetOutputBindings() *ExecutableSubWorkflow_GetOutputBindings
  • func (_m *ExecutableSubWorkflow) OnGetOutputBindingsMatch(matchers ...interface{}) *ExecutableSubWorkflow_GetOutputBindings
  • func (_m *ExecutableSubWorkflow) OnGetOutputs() *ExecutableSubWorkflow_GetOutputs
  • func (_m *ExecutableSubWorkflow) OnGetOutputsMatch(matchers ...interface{}) *ExecutableSubWorkflow_GetOutputs
  • func (_m *ExecutableSubWorkflow) OnStartNode() *ExecutableSubWorkflow_StartNode
  • func (_m *ExecutableSubWorkflow) OnStartNodeMatch(matchers ...interface{}) *ExecutableSubWorkflow_StartNode
  • func (_m *ExecutableSubWorkflow) StartNode() v1alpha1.ExecutableNode
• type ExecutableSubWorkflowNodeStatus
  • func (_m *ExecutableSubWorkflowNodeStatus) GetPhase() v1alpha1.WorkflowPhase
  • func (_m *ExecutableSubWorkflowNodeStatus) OnGetPhase() *ExecutableSubWorkflowNodeStatus_GetPhase
  • func (_m *ExecutableSubWorkflowNodeStatus) OnGetPhaseMatch(matchers ...interface{}) *ExecutableSubWorkflowNodeStatus_GetPhase
• type ExecutableSubWorkflowNodeStatus_GetPhase
  • func (_m ExecutableSubWorkflowNodeStatus_GetPhase) Return(_a0 v1alpha1.WorkflowPhase) *ExecutableSubWorkflowNodeStatus_GetPhase
• type ExecutableSubWorkflow_FromNode
  • func (_m ExecutableSubWorkflow_FromNode) Return(_a0 []string, _a1 error) *ExecutableSubWorkflow_FromNode
• type ExecutableSubWorkflow_GetConnections
  • func (_m ExecutableSubWorkflow_GetConnections) Return(_a0 *v1alpha1.Connections) *ExecutableSubWorkflow_GetConnections
• type ExecutableSubWorkflow_GetID
  • func (_m ExecutableSubWorkflow_GetID) Return(_a0 string) *ExecutableSubWorkflow_GetID
• type ExecutableSubWorkflow_GetNode
  • func (_m ExecutableSubWorkflow_GetNode) Return(_a0 v1alpha1.ExecutableNode, _a1 bool) *ExecutableSubWorkflow_GetNode
• type ExecutableSubWorkflow_GetNodes
  • func (_m ExecutableSubWorkflow_GetNodes) Return(_a0 []string) *ExecutableSubWorkflow_GetNodes
• type ExecutableSubWorkflow_GetOnFailureNode
  • func (_m ExecutableSubWorkflow_GetOnFailureNode) Return(_a0 v1alpha1.ExecutableNode) *ExecutableSubWorkflow_GetOnFailureNode
• type ExecutableSubWorkflow_GetOutputBindings
  • func (_m ExecutableSubWorkflow_GetOutputBindings) Return(_a0 []*v1alpha1.Binding) *ExecutableSubWorkflow_GetOutputBindings
• type ExecutableSubWorkflow_GetOutputs
  • func (_m ExecutableSubWorkflow_GetOutputs) Return(_a0 *v1alpha1.OutputVarMap) *ExecutableSubWorkflow_GetOutputs
• type ExecutableSubWorkflow_StartNode
  • func (_m ExecutableSubWorkflow_StartNode) Return(_a0 v1alpha1.ExecutableNode) *ExecutableSubWorkflow_StartNode
• type ExecutableTask
  • func (_m *ExecutableTask) CoreTask() *core.TaskTemplate
  • func (_m *ExecutableTask) OnCoreTask() *ExecutableTask_CoreTask
  • func (_m *ExecutableTask) OnCoreTaskMatch(matchers ...interface{}) *ExecutableTask_CoreTask
  • func (_m *ExecutableTask) OnTaskType() *ExecutableTask_TaskType
  • func (_m *ExecutableTask) OnTaskTypeMatch(matchers ...interface{}) *ExecutableTask_TaskType
  • func (_m *ExecutableTask) TaskType() string
• type ExecutableTaskNodeStatus
  • func (_m *ExecutableTaskNodeStatus) GetBarrierClockTick() uint32
  • func (_m *ExecutableTaskNodeStatus) GetLastPhaseUpdatedAt() time.Time
  • func (_m *ExecutableTaskNodeStatus) GetPhase() int
  • func (_m *ExecutableTaskNodeStatus) GetPhaseVersion() uint32
  • func (_m *ExecutableTaskNodeStatus) GetPluginState() []byte
  • func (_m *ExecutableTaskNodeStatus) GetPluginStateVersion() uint32
  • func (_m *ExecutableTaskNodeStatus) OnGetBarrierClockTick() *ExecutableTaskNodeStatus_GetBarrierClockTick
  • func (_m *ExecutableTaskNodeStatus) OnGetBarrierClockTickMatch(matchers ...interface{}) *ExecutableTaskNodeStatus_GetBarrierClockTick
  • func (_m *ExecutableTaskNodeStatus) OnGetLastPhaseUpdatedAt() *ExecutableTaskNodeStatus_GetLastPhaseUpdatedAt
  • func (_m *ExecutableTaskNodeStatus) OnGetLastPhaseUpdatedAtMatch(matchers ...interface{}) *ExecutableTaskNodeStatus_GetLastPhaseUpdatedAt
  • func (_m *ExecutableTaskNodeStatus) OnGetPhase() *ExecutableTaskNodeStatus_GetPhase
  • func (_m *ExecutableTaskNodeStatus) OnGetPhaseMatch(matchers ...interface{}) *ExecutableTaskNodeStatus_GetPhase
  • func (_m *ExecutableTaskNodeStatus) OnGetPhaseVersion() *ExecutableTaskNodeStatus_GetPhaseVersion
  • func (_m *ExecutableTaskNodeStatus) OnGetPhaseVersionMatch(matchers ...interface{}) *ExecutableTaskNodeStatus_GetPhaseVersion
  • func (_m *ExecutableTaskNodeStatus) OnGetPluginState() *ExecutableTaskNodeStatus_GetPluginState
  • func (_m *ExecutableTaskNodeStatus) OnGetPluginStateMatch(matchers ...interface{}) *ExecutableTaskNodeStatus_GetPluginState
  • func (_m *ExecutableTaskNodeStatus) OnGetPluginStateVersion() *ExecutableTaskNodeStatus_GetPluginStateVersion
  • func (_m *ExecutableTaskNodeStatus) OnGetPluginStateVersionMatch(matchers ...interface{}) *ExecutableTaskNodeStatus_GetPluginStateVersion
• type ExecutableTaskNodeStatus_GetBarrierClockTick
  • func (_m ExecutableTaskNodeStatus_GetBarrierClockTick) Return(_a0 uint32) *ExecutableTaskNodeStatus_GetBarrierClockTick
• type ExecutableTaskNodeStatus_GetLastPhaseUpdatedAt
  • func (_m ExecutableTaskNodeStatus_GetLastPhaseUpdatedAt) Return(_a0 time.Time) *ExecutableTaskNodeStatus_GetLastPhaseUpdatedAt
• type ExecutableTaskNodeStatus_GetPhase
  • func (_m ExecutableTaskNodeStatus_GetPhase) Return(_a0 int) *ExecutableTaskNodeStatus_GetPhase
• type ExecutableTaskNodeStatus_GetPhaseVersion
  • func (_m ExecutableTaskNodeStatus_GetPhaseVersion) Return(_a0 uint32) *ExecutableTaskNodeStatus_GetPhaseVersion
• type ExecutableTaskNodeStatus_GetPluginState
  • func (_m ExecutableTaskNodeStatus_GetPluginState) Return(_a0 []byte) *ExecutableTaskNodeStatus_GetPluginState
• type ExecutableTaskNodeStatus_GetPluginStateVersion
  • func (_m ExecutableTaskNodeStatus_GetPluginStateVersion) Return(_a0 uint32) *ExecutableTaskNodeStatus_GetPluginStateVersion
• type ExecutableTask_CoreTask
  • func (_m ExecutableTask_CoreTask) Return(_a0 *core.TaskTemplate) *ExecutableTask_CoreTask
• type ExecutableTask_TaskType
  • func (_m ExecutableTask_TaskType) Return(_a0 string) *ExecutableTask_TaskType
• type ExecutableWorkflow
  • func (_m *ExecutableWorkflow) FindSubWorkflow(subID string) v1alpha1.ExecutableSubWorkflow
  • func (_m *ExecutableWorkflow) FromNode(name string) ([]string, error)
  • func (_m *ExecutableWorkflow) GetAnnotations() map[string]string
  • func (_m *ExecutableWorkflow) GetConnections() *v1alpha1.Connections
  • func (_m *ExecutableWorkflow) GetCreationTimestamp() v1.Time
  • func (_m *ExecutableWorkflow) GetExecutionID() v1alpha1.WorkflowExecutionIdentifier
  • func (_m *ExecutableWorkflow) GetExecutionStatus() v1alpha1.ExecutableWorkflowStatus
  • func (_m *ExecutableWorkflow) GetID() string
  • func (_m *ExecutableWorkflow) GetK8sWorkflowID() types.NamespacedName
  • func (_m *ExecutableWorkflow) GetLabels() map[string]string
  • func (_m *ExecutableWorkflow) GetName() string
  • func (_m *ExecutableWorkflow) GetNamespace() string
  • func (_m *ExecutableWorkflow) GetNode(nodeID string) (v1alpha1.ExecutableNode, bool)
  • func (_m *ExecutableWorkflow) GetNodeExecutionStatus(ctx context.Context, id string) v1alpha1.ExecutableNodeStatus
  • func (_m *ExecutableWorkflow) GetNodes() []string
  • func (_m *ExecutableWorkflow) GetOnFailureNode() v1alpha1.ExecutableNode
  • func (_m *ExecutableWorkflow) GetOutputBindings() []*v1alpha1.Binding
  • func (_m *ExecutableWorkflow) GetOutputs() *v1alpha1.OutputVarMap
  • func (_m *ExecutableWorkflow) GetOwnerReference() v1.OwnerReference
  • func (_m *ExecutableWorkflow) GetServiceAccountName() string
  • func (_m *ExecutableWorkflow) GetTask(id string) (v1alpha1.ExecutableTask, error)
  • func (_m *ExecutableWorkflow) OnFindSubWorkflow(subID string) *ExecutableWorkflow_FindSubWorkflow
  • func (_m *ExecutableWorkflow) OnFindSubWorkflowMatch(matchers ...interface{}) *ExecutableWorkflow_FindSubWorkflow
  • func (_m *ExecutableWorkflow) OnFromNode(name string) *ExecutableWorkflow_FromNode
  • func (_m *ExecutableWorkflow) OnFromNodeMatch(matchers ...interface{}) *ExecutableWorkflow_FromNode
  • func (_m *ExecutableWorkflow) OnGetAnnotations() *ExecutableWorkflow_GetAnnotations
  • func (_m *ExecutableWorkflow) OnGetAnnotationsMatch(matchers ...interface{}) *ExecutableWorkflow_GetAnnotations
  • func (_m *ExecutableWorkflow) OnGetConnections() *ExecutableWorkflow_GetConnections
  • func (_m *ExecutableWorkflow) OnGetConnectionsMatch(matchers ...interface{}) *ExecutableWorkflow_GetConnections
  • func (_m *ExecutableWorkflow) OnGetCreationTimestamp() *ExecutableWorkflow_GetCreationTimestamp
  • func (_m *ExecutableWorkflow) OnGetCreationTimestampMatch(matchers ...interface{}) *ExecutableWorkflow_GetCreationTimestamp
  • func (_m *ExecutableWorkflow) OnGetExecutionID() *ExecutableWorkflow_GetExecutionID
  • func (_m *ExecutableWorkflow) OnGetExecutionIDMatch(matchers ...interface{}) *ExecutableWorkflow_GetExecutionID
  • func (_m *ExecutableWorkflow) OnGetExecutionStatus() *ExecutableWorkflow_GetExecutionStatus
  • func (_m *ExecutableWorkflow) OnGetExecutionStatusMatch(matchers ...interface{}) *ExecutableWorkflow_GetExecutionStatus
  • func (_m *ExecutableWorkflow) OnGetID() *ExecutableWorkflow_GetID
  • func (_m *ExecutableWorkflow) OnGetIDMatch(matchers ...interface{}) *ExecutableWorkflow_GetID
  • func (_m *ExecutableWorkflow) OnGetK8sWorkflowID() *ExecutableWorkflow_GetK8sWorkflowID
  • func (_m *ExecutableWorkflow) OnGetK8sWorkflowIDMatch(matchers ...interface{}) *ExecutableWorkflow_GetK8sWorkflowID
  • func (_m *ExecutableWorkflow) OnGetLabels() *ExecutableWorkflow_GetLabels
  • func (_m *ExecutableWorkflow) OnGetLabelsMatch(matchers ...interface{}) *ExecutableWorkflow_GetLabels
  • func (_m *ExecutableWorkflow) OnGetName() *ExecutableWorkflow_GetName
  • func (_m *ExecutableWorkflow) OnGetNameMatch(matchers ...interface{}) *ExecutableWorkflow_GetName
  • func (_m *ExecutableWorkflow) OnGetNamespace() *ExecutableWorkflow_GetNamespace
  • func (_m *ExecutableWorkflow) OnGetNamespaceMatch(matchers ...interface{}) *ExecutableWorkflow_GetNamespace
  • func (_m *ExecutableWorkflow) OnGetNode(nodeID string) *ExecutableWorkflow_GetNode
  • func (_m *ExecutableWorkflow) OnGetNodeExecutionStatus(ctx context.Context, id string) *ExecutableWorkflow_GetNodeExecutionStatus
  • func (_m *ExecutableWorkflow) OnGetNodeExecutionStatusMatch(matchers ...interface{}) *ExecutableWorkflow_GetNodeExecutionStatus
  • func (_m *ExecutableWorkflow) OnGetNodeMatch(matchers ...interface{}) *ExecutableWorkflow_GetNode
  • func (_m *ExecutableWorkflow) OnGetNodes() *ExecutableWorkflow_GetNodes
  • func (_m *ExecutableWorkflow) OnGetNodesMatch(matchers ...interface{}) *ExecutableWorkflow_GetNodes
  • func (_m *ExecutableWorkflow) OnGetOnFailureNode() *ExecutableWorkflow_GetOnFailureNode
  • func (_m *ExecutableWorkflow) OnGetOnFailureNodeMatch(matchers ...interface{}) *ExecutableWorkflow_GetOnFailureNode
  • func (_m *ExecutableWorkflow) OnGetOutputBindings() *ExecutableWorkflow_GetOutputBindings
  • func (_m *ExecutableWorkflow) OnGetOutputBindingsMatch(matchers ...interface{}) *ExecutableWorkflow_GetOutputBindings
  • func (_m *ExecutableWorkflow) OnGetOutputs() *ExecutableWorkflow_GetOutputs
  • func (_m *ExecutableWorkflow) OnGetOutputsMatch(matchers ...interface{}) *ExecutableWorkflow_GetOutputs
  • func (_m *ExecutableWorkflow) OnGetOwnerReference() *ExecutableWorkflow_GetOwnerReference
  • func (_m *ExecutableWorkflow) OnGetOwnerReferenceMatch(matchers ...interface{}) *ExecutableWorkflow_GetOwnerReference
  • func (_m *ExecutableWorkflow) OnGetServiceAccountName() *ExecutableWorkflow_GetServiceAccountName
  • func (_m *ExecutableWorkflow) OnGetServiceAccountNameMatch(matchers ...interface{}) *ExecutableWorkflow_GetServiceAccountName
  • func (_m *ExecutableWorkflow) OnGetTask(id string) *ExecutableWorkflow_GetTask
  • func (_m *ExecutableWorkflow) OnGetTaskMatch(matchers ...interface{}) *ExecutableWorkflow_GetTask
  • func (_m *ExecutableWorkflow) OnStartNode() *ExecutableWorkflow_StartNode
  • func (_m *ExecutableWorkflow) OnStartNodeMatch(matchers ...interface{}) *ExecutableWorkflow_StartNode
  • func (_m *ExecutableWorkflow) StartNode() v1alpha1.ExecutableNode
• type ExecutableWorkflowNode
  • func (_m *ExecutableWorkflowNode) GetLaunchPlanRefID() *v1alpha1.Identifier
  • func (_m *ExecutableWorkflowNode) GetSubWorkflowRef() *string
  • func (_m *ExecutableWorkflowNode) OnGetLaunchPlanRefID() *ExecutableWorkflowNode_GetLaunchPlanRefID
  • func (_m *ExecutableWorkflowNode) OnGetLaunchPlanRefIDMatch(matchers ...interface{}) *ExecutableWorkflowNode_GetLaunchPlanRefID
  • func (_m *ExecutableWorkflowNode) OnGetSubWorkflowRef() *ExecutableWorkflowNode_GetSubWorkflowRef
  • func (_m *ExecutableWorkflowNode) OnGetSubWorkflowRefMatch(matchers ...interface{}) *ExecutableWorkflowNode_GetSubWorkflowRef
• type ExecutableWorkflowNodeStatus
  • func (_m *ExecutableWorkflowNodeStatus) GetWorkflowNodePhase() v1alpha1.WorkflowNodePhase
  • func (_m *ExecutableWorkflowNodeStatus) OnGetWorkflowNodePhase() *ExecutableWorkflowNodeStatus_GetWorkflowNodePhase
  • func (_m *ExecutableWorkflowNodeStatus) OnGetWorkflowNodePhaseMatch(matchers ...interface{}) *ExecutableWorkflowNodeStatus_GetWorkflowNodePhase
• type ExecutableWorkflowNodeStatus_GetWorkflowNodePhase
  • func (_m ExecutableWorkflowNodeStatus_GetWorkflowNodePhase) Return(_a0 v1alpha1.WorkflowNodePhase) *ExecutableWorkflowNodeStatus_GetWorkflowNodePhase
• type ExecutableWorkflowNode_GetLaunchPlanRefID
  • func (_m ExecutableWorkflowNode_GetLaunchPlanRefID) Return(_a0 *v1alpha1.Identifier) *ExecutableWorkflowNode_GetLaunchPlanRefID
• type ExecutableWorkflowNode_GetSubWorkflowRef
  • func (_m ExecutableWorkflowNode_GetSubWorkflowRef) Return(_a0 *string) *ExecutableWorkflowNode_GetSubWorkflowRef
• type ExecutableWorkflowStatus
  • func (_m *ExecutableWorkflowStatus) ConstructNodeDataDir(ctx context.Context, name string) (storage.DataReference, error)
  • func (_m *ExecutableWorkflowStatus) GetDataDir() storage.DataReference
  • func (_m *ExecutableWorkflowStatus) GetLastUpdatedAt() *v1.Time
  • func (_m *ExecutableWorkflowStatus) GetMessage() string
  • func (_m *ExecutableWorkflowStatus) GetNodeExecutionStatus(ctx context.Context, id string) v1alpha1.ExecutableNodeStatus
  • func (_m *ExecutableWorkflowStatus) GetOutputReference() storage.DataReference
  • func (_m *ExecutableWorkflowStatus) GetPhase() v1alpha1.WorkflowPhase
  • func (_m *ExecutableWorkflowStatus) GetStartedAt() *v1.Time
  • func (_m *ExecutableWorkflowStatus) GetStoppedAt() *v1.Time
  • func (_m *ExecutableWorkflowStatus) IncFailedAttempts()
  • func (_m *ExecutableWorkflowStatus) IsTerminated() bool
  • func (_m *ExecutableWorkflowStatus) OnConstructNodeDataDir(ctx context.Context, name string) *ExecutableWorkflowStatus_ConstructNodeDataDir
  • func (_m *ExecutableWorkflowStatus) OnConstructNodeDataDirMatch(matchers ...interface{}) *ExecutableWorkflowStatus_ConstructNodeDataDir
  • func (_m *ExecutableWorkflowStatus) OnGetDataDir() *ExecutableWorkflowStatus_GetDataDir
  • func (_m *ExecutableWorkflowStatus) OnGetDataDirMatch(matchers ...interface{}) *ExecutableWorkflowStatus_GetDataDir
  • func (_m *ExecutableWorkflowStatus) OnGetLastUpdatedAt() *ExecutableWorkflowStatus_GetLastUpdatedAt
  • func (_m *ExecutableWorkflowStatus) OnGetLastUpdatedAtMatch(matchers ...interface{}) *ExecutableWorkflowStatus_GetLastUpdatedAt
  • func (_m *ExecutableWorkflowStatus) OnGetMessage() *ExecutableWorkflowStatus_GetMessage
  • func (_m *ExecutableWorkflowStatus) OnGetMessageMatch(matchers ...interface{}) *ExecutableWorkflowStatus_GetMessage
  • func (_m *ExecutableWorkflowStatus) OnGetNodeExecutionStatus(ctx context.Context, id string) *ExecutableWorkflowStatus_GetNodeExecutionStatus
  • func (_m *ExecutableWorkflowStatus) OnGetNodeExecutionStatusMatch(matchers ...interface{}) *ExecutableWorkflowStatus_GetNodeExecutionStatus
  • func (_m *ExecutableWorkflowStatus) OnGetOutputReference() *ExecutableWorkflowStatus_GetOutputReference
  • func (_m *ExecutableWorkflowStatus) OnGetOutputReferenceMatch(matchers ...interface{}) *ExecutableWorkflowStatus_GetOutputReference
  • func (_m *ExecutableWorkflowStatus) OnGetPhase() *ExecutableWorkflowStatus_GetPhase
  • func (_m *ExecutableWorkflowStatus) OnGetPhaseMatch(matchers ...interface{}) *ExecutableWorkflowStatus_GetPhase
  • func (_m *ExecutableWorkflowStatus) OnGetStartedAt() *ExecutableWorkflowStatus_GetStartedAt
  • func (_m *ExecutableWorkflowStatus) OnGetStartedAtMatch(matchers ...interface{}) *ExecutableWorkflowStatus_GetStartedAt
  • func (_m *ExecutableWorkflowStatus) OnGetStoppedAt() *ExecutableWorkflowStatus_GetStoppedAt
  • func (_m *ExecutableWorkflowStatus) OnGetStoppedAtMatch(matchers ...interface{}) *ExecutableWorkflowStatus_GetStoppedAt
  • func (_m *ExecutableWorkflowStatus) OnIsTerminated() *ExecutableWorkflowStatus_IsTerminated
  • func (_m *ExecutableWorkflowStatus) OnIsTerminatedMatch(matchers ...interface{}) *ExecutableWorkflowStatus_IsTerminated
  • func (_m *ExecutableWorkflowStatus) SetDataDir(_a0 storage.DataReference)
  • func (_m *ExecutableWorkflowStatus) SetMessage(msg string)
  • func (_m *ExecutableWorkflowStatus) SetOutputReference(reference storage.DataReference)
  • func (_m *ExecutableWorkflowStatus) UpdatePhase(p v1alpha1.WorkflowPhase, msg string)
• type ExecutableWorkflowStatus_ConstructNodeDataDir
  • func (_m ExecutableWorkflowStatus_ConstructNodeDataDir) Return(_a0 storage.DataReference, _a1 error) *ExecutableWorkflowStatus_ConstructNodeDataDir
• type ExecutableWorkflowStatus_GetDataDir
  • func (_m ExecutableWorkflowStatus_GetDataDir) Return(_a0 storage.DataReference) *ExecutableWorkflowStatus_GetDataDir
• type ExecutableWorkflowStatus_GetLastUpdatedAt
  • func (_m ExecutableWorkflowStatus_GetLastUpdatedAt) Return(_a0 *v1.Time) *ExecutableWorkflowStatus_GetLastUpdatedAt
• type ExecutableWorkflowStatus_GetMessage
  • func (_m ExecutableWorkflowStatus_GetMessage) Return(_a0 string) *ExecutableWorkflowStatus_GetMessage
• type ExecutableWorkflowStatus_GetNodeExecutionStatus
  • func (_m ExecutableWorkflowStatus_GetNodeExecutionStatus) Return(_a0 v1alpha1.ExecutableNodeStatus) *ExecutableWorkflowStatus_GetNodeExecutionStatus
• type ExecutableWorkflowStatus_GetOutputReference
  • func (_m ExecutableWorkflowStatus_GetOutputReference) Return(_a0 storage.DataReference) *ExecutableWorkflowStatus_GetOutputReference
• type ExecutableWorkflowStatus_GetPhase
  • func (_m ExecutableWorkflowStatus_GetPhase) Return(_a0 v1alpha1.WorkflowPhase) *ExecutableWorkflowStatus_GetPhase
• type ExecutableWorkflowStatus_GetStartedAt
  • func (_m ExecutableWorkflowStatus_GetStartedAt) Return(_a0 *v1.Time) *ExecutableWorkflowStatus_GetStartedAt
• type ExecutableWorkflowStatus_GetStoppedAt
  • func (_m ExecutableWorkflowStatus_GetStoppedAt) Return(_a0 *v1.Time) *ExecutableWorkflowStatus_GetStoppedAt
• type ExecutableWorkflowStatus_IsTerminated
  • func (_m ExecutableWorkflowStatus_IsTerminated) Return(_a0 bool) *ExecutableWorkflowStatus_IsTerminated
• type ExecutableWorkflow_FindSubWorkflow
  • func (_m ExecutableWorkflow_FindSubWorkflow) Return(_a0 v1alpha1.ExecutableSubWorkflow) *ExecutableWorkflow_FindSubWorkflow
• type ExecutableWorkflow_FromNode
  • func (_m ExecutableWorkflow_FromNode) Return(_a0 []string, _a1 error) *ExecutableWorkflow_FromNode
• type ExecutableWorkflow_GetAnnotations
  • func (_m ExecutableWorkflow_GetAnnotations) Return(_a0 map[string]string) *ExecutableWorkflow_GetAnnotations
• type ExecutableWorkflow_GetConnections
  • func (_m ExecutableWorkflow_GetConnections) Return(_a0 *v1alpha1.Connections) *ExecutableWorkflow_GetConnections
• type ExecutableWorkflow_GetCreationTimestamp
  • func (_m ExecutableWorkflow_GetCreationTimestamp) Return(_a0 v1.Time) *ExecutableWorkflow_GetCreationTimestamp
• type ExecutableWorkflow_GetExecutionID
  • func (_m ExecutableWorkflow_GetExecutionID) Return(_a0 v1alpha1.WorkflowExecutionIdentifier) *ExecutableWorkflow_GetExecutionID
• type ExecutableWorkflow_GetExecutionStatus
  • func (_m ExecutableWorkflow_GetExecutionStatus) Return(_a0 v1alpha1.ExecutableWorkflowStatus) *ExecutableWorkflow_GetExecutionStatus
• type ExecutableWorkflow_GetID
  • func (_m ExecutableWorkflow_GetID) Return(_a0 string) *ExecutableWorkflow_GetID
• type ExecutableWorkflow_GetK8sWorkflowID
  • func (_m ExecutableWorkflow_GetK8sWorkflowID) Return(_a0 types.NamespacedName) *ExecutableWorkflow_GetK8sWorkflowID
• type ExecutableWorkflow_GetLabels
  • func (_m ExecutableWorkflow_GetLabels) Return(_a0 map[string]string) *ExecutableWorkflow_GetLabels
• type ExecutableWorkflow_GetName
  • func (_m ExecutableWorkflow_GetName) Return(_a0 string) *ExecutableWorkflow_GetName
• type ExecutableWorkflow_GetNamespace
  • func (_m ExecutableWorkflow_GetNamespace) Return(_a0 string) *ExecutableWorkflow_GetNamespace
• type ExecutableWorkflow_GetNode
  • func (_m ExecutableWorkflow_GetNode) Return(_a0 v1alpha1.ExecutableNode, _a1 bool) *ExecutableWorkflow_GetNode
• type ExecutableWorkflow_GetNodeExecutionStatus
  • func (_m ExecutableWorkflow_GetNodeExecutionStatus) Return(_a0 v1alpha1.ExecutableNodeStatus) *ExecutableWorkflow_GetNodeExecutionStatus
• type ExecutableWorkflow_GetNodes
  • func (_m ExecutableWorkflow_GetNodes) Return(_a0 []string) *ExecutableWorkflow_GetNodes
• type ExecutableWorkflow_GetOnFailureNode
  • func (_m ExecutableWorkflow_GetOnFailureNode) Return(_a0 v1alpha1.ExecutableNode) *ExecutableWorkflow_GetOnFailureNode
• type ExecutableWorkflow_GetOutputBindings
  • func (_m ExecutableWorkflow_GetOutputBindings) Return(_a0 []*v1alpha1.Binding) *ExecutableWorkflow_GetOutputBindings
• type ExecutableWorkflow_GetOutputs
  • func (_m ExecutableWorkflow_GetOutputs) Return(_a0 *v1alpha1.OutputVarMap) *ExecutableWorkflow_GetOutputs
• type ExecutableWorkflow_GetOwnerReference
  • func (_m ExecutableWorkflow_GetOwnerReference) Return(_a0 v1.OwnerReference) *ExecutableWorkflow_GetOwnerReference
• type ExecutableWorkflow_GetServiceAccountName
  • func (_m ExecutableWorkflow_GetServiceAccountName) Return(_a0 string) *ExecutableWorkflow_GetServiceAccountName
• type ExecutableWorkflow_GetTask
  • func (_m ExecutableWorkflow_GetTask) Return(_a0 v1alpha1.ExecutableTask, _a1 error) *ExecutableWorkflow_GetTask
• type ExecutableWorkflow_StartNode
  • func (_m ExecutableWorkflow_StartNode) Return(_a0 v1alpha1.ExecutableNode) *ExecutableWorkflow_StartNode
• type Mutable
  • func (_m *Mutable) IsDirty() bool
  • func (_m *Mutable) OnIsDirty() *Mutable_IsDirty
  • func (_m *Mutable) OnIsDirtyMatch(matchers ...interface{}) *Mutable_IsDirty
• type MutableBranchNodeStatus
  • func (_m *MutableBranchNodeStatus) GetFinalizedNode() *string
  • func (_m *MutableBranchNodeStatus) GetPhase() v1alpha1.BranchNodePhase
  • func (_m *MutableBranchNodeStatus) IsDirty() bool
  • func (_m *MutableBranchNodeStatus) OnGetFinalizedNode() *MutableBranchNodeStatus_GetFinalizedNode
  • func (_m *MutableBranchNodeStatus) OnGetFinalizedNodeMatch(matchers ...interface{}) *MutableBranchNodeStatus_GetFinalizedNode
  • func (_m *MutableBranchNodeStatus) OnGetPhase() *MutableBranchNodeStatus_GetPhase
  • func (_m *MutableBranchNodeStatus) OnGetPhaseMatch(matchers ...interface{}) *MutableBranchNodeStatus_GetPhase
  • func (_m *MutableBranchNodeStatus) OnIsDirty() *MutableBranchNodeStatus_IsDirty
  • func (_m *MutableBranchNodeStatus) OnIsDirtyMatch(matchers ...interface{}) *MutableBranchNodeStatus_IsDirty
  • func (_m *MutableBranchNodeStatus) SetBranchNodeError()
  • func (_m *MutableBranchNodeStatus) SetBranchNodeSuccess(id string)
• type MutableBranchNodeStatus_GetFinalizedNode
  • func (_m MutableBranchNodeStatus_GetFinalizedNode) Return(_a0 *string) *MutableBranchNodeStatus_GetFinalizedNode
• type MutableBranchNodeStatus_GetPhase
  • func (_m MutableBranchNodeStatus_GetPhase) Return(_a0 v1alpha1.BranchNodePhase) *MutableBranchNodeStatus_GetPhase
• type MutableBranchNodeStatus_IsDirty
  • func (_m MutableBranchNodeStatus_IsDirty) Return(_a0 bool) *MutableBranchNodeStatus_IsDirty
• type MutableDynamicNodeStatus
  • func (_m *MutableDynamicNodeStatus) GetDynamicNodePhase() v1alpha1.DynamicNodePhase
  • func (_m *MutableDynamicNodeStatus) GetDynamicNodeReason() string
  • func (_m *MutableDynamicNodeStatus) IsDirty() bool
  • func (_m *MutableDynamicNodeStatus) OnGetDynamicNodePhase() *MutableDynamicNodeStatus_GetDynamicNodePhase
  • func (_m *MutableDynamicNodeStatus) OnGetDynamicNodePhaseMatch(matchers ...interface{}) *MutableDynamicNodeStatus_GetDynamicNodePhase
  • func (_m *MutableDynamicNodeStatus) OnGetDynamicNodeReason() *MutableDynamicNodeStatus_GetDynamicNodeReason
  • func (_m *MutableDynamicNodeStatus) OnGetDynamicNodeReasonMatch(matchers ...interface{}) *MutableDynamicNodeStatus_GetDynamicNodeReason
  • func (_m *MutableDynamicNodeStatus) OnIsDirty() *MutableDynamicNodeStatus_IsDirty
  • func (_m *MutableDynamicNodeStatus) OnIsDirtyMatch(matchers ...interface{}) *MutableDynamicNodeStatus_IsDirty
  • func (_m *MutableDynamicNodeStatus) SetDynamicNodePhase(phase v1alpha1.DynamicNodePhase)
  • func (_m *MutableDynamicNodeStatus) SetDynamicNodeReason(reason string)
• type MutableDynamicNodeStatus_GetDynamicNodePhase
  • func (_m MutableDynamicNodeStatus_GetDynamicNodePhase) Return(_a0 v1alpha1.DynamicNodePhase) *MutableDynamicNodeStatus_GetDynamicNodePhase
• type MutableDynamicNodeStatus_GetDynamicNodeReason
  • func (_m MutableDynamicNodeStatus_GetDynamicNodeReason) Return(_a0 string) *MutableDynamicNodeStatus_GetDynamicNodeReason
• type MutableDynamicNodeStatus_IsDirty
  • func (_m MutableDynamicNodeStatus_IsDirty) Return(_a0 bool) *MutableDynamicNodeStatus_IsDirty
• type MutableNodeStatus
  • func (_m *MutableNodeStatus) ClearDynamicNodeStatus()
  • func (_m *MutableNodeStatus) ClearLastAttemptStartedAt()
  • func (_m *MutableNodeStatus) ClearSubNodeStatus()
  • func (_m *MutableNodeStatus) ClearTaskStatus()
  • func (_m *MutableNodeStatus) ClearWorkflowStatus()
  • func (_m *MutableNodeStatus) GetBranchStatus() v1alpha1.MutableBranchNodeStatus
  • func (_m *MutableNodeStatus) GetDynamicNodeStatus() v1alpha1.MutableDynamicNodeStatus
  • func (_m *MutableNodeStatus) GetOrCreateBranchStatus() v1alpha1.MutableBranchNodeStatus
  • func (_m *MutableNodeStatus) GetOrCreateDynamicNodeStatus() v1alpha1.MutableDynamicNodeStatus
  • func (_m *MutableNodeStatus) GetOrCreateTaskStatus() v1alpha1.MutableTaskNodeStatus
  • func (_m *MutableNodeStatus) GetOrCreateWorkflowStatus() v1alpha1.MutableWorkflowNodeStatus
  • func (_m *MutableNodeStatus) GetTaskStatus() v1alpha1.MutableTaskNodeStatus
  • func (_m *MutableNodeStatus) GetWorkflowStatus() v1alpha1.MutableWorkflowNodeStatus
  • func (_m *MutableNodeStatus) IncrementAttempts() uint32
  • func (_m *MutableNodeStatus) IsDirty() bool
  • func (_m *MutableNodeStatus) OnGetBranchStatus() *MutableNodeStatus_GetBranchStatus
  • func (_m *MutableNodeStatus) OnGetBranchStatusMatch(matchers ...interface{}) *MutableNodeStatus_GetBranchStatus
  • func (_m *MutableNodeStatus) OnGetDynamicNodeStatus() *MutableNodeStatus_GetDynamicNodeStatus
  • func (_m *MutableNodeStatus) OnGetDynamicNodeStatusMatch(matchers ...interface{}) *MutableNodeStatus_GetDynamicNodeStatus
  • func (_m *MutableNodeStatus) OnGetOrCreateBranchStatus() *MutableNodeStatus_GetOrCreateBranchStatus
  • func (_m *MutableNodeStatus) OnGetOrCreateBranchStatusMatch(matchers ...interface{}) *MutableNodeStatus_GetOrCreateBranchStatus
  • func (_m *MutableNodeStatus) OnGetOrCreateDynamicNodeStatus() *MutableNodeStatus_GetOrCreateDynamicNodeStatus
  • func (_m *MutableNodeStatus) OnGetOrCreateDynamicNodeStatusMatch(matchers ...interface{}) *MutableNodeStatus_GetOrCreateDynamicNodeStatus
  • func (_m *MutableNodeStatus) OnGetOrCreateTaskStatus() *MutableNodeStatus_GetOrCreateTaskStatus
  • func (_m *MutableNodeStatus) OnGetOrCreateTaskStatusMatch(matchers ...interface{}) *MutableNodeStatus_GetOrCreateTaskStatus
  • func (_m *MutableNodeStatus) OnGetOrCreateWorkflowStatus() *MutableNodeStatus_GetOrCreateWorkflowStatus
  • func (_m *MutableNodeStatus) OnGetOrCreateWorkflowStatusMatch(matchers ...interface{}) *MutableNodeStatus_GetOrCreateWorkflowStatus
  • func (_m *MutableNodeStatus) OnGetTaskStatus() *MutableNodeStatus_GetTaskStatus
  • func (_m *MutableNodeStatus) OnGetTaskStatusMatch(matchers ...interface{}) *MutableNodeStatus_GetTaskStatus
  • func (_m *MutableNodeStatus) OnGetWorkflowStatus() *MutableNodeStatus_GetWorkflowStatus
  • func (_m *MutableNodeStatus) OnGetWorkflowStatusMatch(matchers ...interface{}) *MutableNodeStatus_GetWorkflowStatus
  • func (_m *MutableNodeStatus) OnIncrementAttempts() *MutableNodeStatus_IncrementAttempts
  • func (_m *MutableNodeStatus) OnIncrementAttemptsMatch(matchers ...interface{}) *MutableNodeStatus_IncrementAttempts
  • func (_m *MutableNodeStatus) OnIsDirty() *MutableNodeStatus_IsDirty
  • func (_m *MutableNodeStatus) OnIsDirtyMatch(matchers ...interface{}) *MutableNodeStatus_IsDirty
  • func (_m *MutableNodeStatus) ResetDirty()
  • func (_m *MutableNodeStatus) SetCached()
  • func (_m *MutableNodeStatus) SetDataDir(_a0 storage.DataReference)
  • func (_m *MutableNodeStatus) SetOutputDir(d storage.DataReference)
  • func (_m *MutableNodeStatus) SetParentNodeID(n *string)
  • func (_m *MutableNodeStatus) SetParentTaskID(t *core.TaskExecutionIdentifier)
  • func (_m *MutableNodeStatus) UpdatePhase(phase v1alpha1.NodePhase, occurredAt v1.Time, reason string)
• type MutableNodeStatus_GetBranchStatus
  • func (_m MutableNodeStatus_GetBranchStatus) Return(_a0 v1alpha1.MutableBranchNodeStatus) *MutableNodeStatus_GetBranchStatus
• type MutableNodeStatus_GetDynamicNodeStatus
  • func (_m MutableNodeStatus_GetDynamicNodeStatus) Return(_a0 v1alpha1.MutableDynamicNodeStatus) *MutableNodeStatus_GetDynamicNodeStatus
• type MutableNodeStatus_GetOrCreateBranchStatus
  • func (_m MutableNodeStatus_GetOrCreateBranchStatus) Return(_a0 v1alpha1.MutableBranchNodeStatus) *MutableNodeStatus_GetOrCreateBranchStatus
• type MutableNodeStatus_GetOrCreateDynamicNodeStatus
  • func (_m MutableNodeStatus_GetOrCreateDynamicNodeStatus) Return(_a0 v1alpha1.MutableDynamicNodeStatus) *MutableNodeStatus_GetOrCreateDynamicNodeStatus
• type MutableNodeStatus_GetOrCreateTaskStatus
  • func (_m MutableNodeStatus_GetOrCreateTaskStatus) Return(_a0 v1alpha1.MutableTaskNodeStatus) *MutableNodeStatus_GetOrCreateTaskStatus
• type MutableNodeStatus_GetOrCreateWorkflowStatus
  • func (_m MutableNodeStatus_GetOrCreateWorkflowStatus) Return(_a0 v1alpha1.MutableWorkflowNodeStatus) *MutableNodeStatus_GetOrCreateWorkflowStatus
• type MutableNodeStatus_GetTaskStatus
  • func (_m MutableNodeStatus_GetTaskStatus) Return(_a0 v1alpha1.MutableTaskNodeStatus) *MutableNodeStatus_GetTaskStatus
• type MutableNodeStatus_GetWorkflowStatus
  • func (_m MutableNodeStatus_GetWorkflowStatus) Return(_a0 v1alpha1.MutableWorkflowNodeStatus) *MutableNodeStatus_GetWorkflowStatus
• type MutableNodeStatus_IncrementAttempts
  • func (_m MutableNodeStatus_IncrementAttempts) Return(_a0 uint32) *MutableNodeStatus_IncrementAttempts
• type MutableNodeStatus_IsDirty
  • func (_m MutableNodeStatus_IsDirty) Return(_a0 bool) *MutableNodeStatus_IsDirty
• type MutableSubWorkflowNodeStatus
  • func (_m *MutableSubWorkflowNodeStatus) GetPhase() v1alpha1.WorkflowPhase
  • func (_m *MutableSubWorkflowNodeStatus) IsDirty() bool
  • func (_m *MutableSubWorkflowNodeStatus) OnGetPhase() *MutableSubWorkflowNodeStatus_GetPhase
  • func (_m *MutableSubWorkflowNodeStatus) OnGetPhaseMatch(matchers ...interface{}) *MutableSubWorkflowNodeStatus_GetPhase
  • func (_m *MutableSubWorkflowNodeStatus) OnIsDirty() *MutableSubWorkflowNodeStatus_IsDirty
  • func (_m *MutableSubWorkflowNodeStatus) OnIsDirtyMatch(matchers ...interface{}) *MutableSubWorkflowNodeStatus_IsDirty
  • func (_m *MutableSubWorkflowNodeStatus) SetPhase(phase v1alpha1.WorkflowPhase)
• type MutableSubWorkflowNodeStatus_GetPhase
  • func (_m MutableSubWorkflowNodeStatus_GetPhase) Return(_a0 v1alpha1.WorkflowPhase) *MutableSubWorkflowNodeStatus_GetPhase
• type MutableSubWorkflowNodeStatus_IsDirty
  • func (_m MutableSubWorkflowNodeStatus_IsDirty) Return(_a0 bool) *MutableSubWorkflowNodeStatus_IsDirty
• type MutableTaskNodeStatus
  • func (_m *MutableTaskNodeStatus) GetBarrierClockTick() uint32
  • func (_m *MutableTaskNodeStatus) GetLastPhaseUpdatedAt() time.Time
  • func (_m *MutableTaskNodeStatus) GetPhase() int
  • func (_m *MutableTaskNodeStatus) GetPhaseVersion() uint32
  • func (_m *MutableTaskNodeStatus) GetPluginState() []byte
  • func (_m *MutableTaskNodeStatus) GetPluginStateVersion() uint32
  • func (_m *MutableTaskNodeStatus) IsDirty() bool
  • func (_m *MutableTaskNodeStatus) OnGetBarrierClockTick() *MutableTaskNodeStatus_GetBarrierClockTick
  • func (_m *MutableTaskNodeStatus) OnGetBarrierClockTickMatch(matchers ...interface{}) *MutableTaskNodeStatus_GetBarrierClockTick
  • func (_m *MutableTaskNodeStatus) OnGetLastPhaseUpdatedAt() *MutableTaskNodeStatus_GetLastPhaseUpdatedAt
  • func (_m *MutableTaskNodeStatus) OnGetLastPhaseUpdatedAtMatch(matchers ...interface{}) *MutableTaskNodeStatus_GetLastPhaseUpdatedAt
  • func (_m *MutableTaskNodeStatus) OnGetPhase() *MutableTaskNodeStatus_GetPhase
  • func (_m *MutableTaskNodeStatus) OnGetPhaseMatch(matchers ...interface{}) *MutableTaskNodeStatus_GetPhase
  • func (_m *MutableTaskNodeStatus) OnGetPhaseVersion() *MutableTaskNodeStatus_GetPhaseVersion
  • func (_m *MutableTaskNodeStatus) OnGetPhaseVersionMatch(matchers ...interface{}) *MutableTaskNodeStatus_GetPhaseVersion
  • func (_m *MutableTaskNodeStatus) OnGetPluginState() *MutableTaskNodeStatus_GetPluginState
  • func (_m *MutableTaskNodeStatus) OnGetPluginStateMatch(matchers ...interface{}) *MutableTaskNodeStatus_GetPluginState
  • func (_m *MutableTaskNodeStatus) OnGetPluginStateVersion() *MutableTaskNodeStatus_GetPluginStateVersion
  • func (_m *MutableTaskNodeStatus) OnGetPluginStateVersionMatch(matchers ...interface{}) *MutableTaskNodeStatus_GetPluginStateVersion
  • func (_m *MutableTaskNodeStatus) OnIsDirty() *MutableTaskNodeStatus_IsDirty
  • func (_m *MutableTaskNodeStatus) OnIsDirtyMatch(matchers ...interface{}) *MutableTaskNodeStatus_IsDirty
  • func (_m *MutableTaskNodeStatus) SetBarrierClockTick(tick uint32)
  • func (_m *MutableTaskNodeStatus) SetLastPhaseUpdatedAt(updatedAt time.Time)
  • func (_m *MutableTaskNodeStatus) SetPhase(phase int)
  • func (_m *MutableTaskNodeStatus) SetPhaseVersion(version uint32)
  • func (_m *MutableTaskNodeStatus) SetPluginState(_a0 []byte)
  • func (_m *MutableTaskNodeStatus) SetPluginStateVersion(_a0 uint32)
• type MutableTaskNodeStatus_GetBarrierClockTick
  • func (_m MutableTaskNodeStatus_GetBarrierClockTick) Return(_a0 uint32) *MutableTaskNodeStatus_GetBarrierClockTick
• type MutableTaskNodeStatus_GetLastPhaseUpdatedAt
  • func (_m MutableTaskNodeStatus_GetLastPhaseUpdatedAt) Return(_a0 time.Time) *MutableTaskNodeStatus_GetLastPhaseUpdatedAt
• type MutableTaskNodeStatus_GetPhase
  • func (_m MutableTaskNodeStatus_GetPhase) Return(_a0 int) *MutableTaskNodeStatus_GetPhase
• type MutableTaskNodeStatus_GetPhaseVersion
  • func (_m MutableTaskNodeStatus_GetPhaseVersion) Return(_a0 uint32) *MutableTaskNodeStatus_GetPhaseVersion
• type MutableTaskNodeStatus_GetPluginState
  • func (_m MutableTaskNodeStatus_GetPluginState) Return(_a0 []byte) *MutableTaskNodeStatus_GetPluginState
• type MutableTaskNodeStatus_GetPluginStateVersion
  • func (_m MutableTaskNodeStatus_GetPluginStateVersion) Return(_a0 uint32) *MutableTaskNodeStatus_GetPluginStateVersion
• type MutableTaskNodeStatus_IsDirty
  • func (_m MutableTaskNodeStatus_IsDirty) Return(_a0 bool) *MutableTaskNodeStatus_IsDirty
• type MutableWorkflowNodeStatus
  • func (_m *MutableWorkflowNodeStatus) GetWorkflowNodePhase() v1alpha1.WorkflowNodePhase
  • func (_m *MutableWorkflowNodeStatus) IsDirty() bool
  • func (_m *MutableWorkflowNodeStatus) OnGetWorkflowNodePhase() *MutableWorkflowNodeStatus_GetWorkflowNodePhase
  • func (_m *MutableWorkflowNodeStatus) OnGetWorkflowNodePhaseMatch(matchers ...interface{}) *MutableWorkflowNodeStatus_GetWorkflowNodePhase
  • func (_m *MutableWorkflowNodeStatus) OnIsDirty() *MutableWorkflowNodeStatus_IsDirty
  • func (_m *MutableWorkflowNodeStatus) OnIsDirtyMatch(matchers ...interface{}) *MutableWorkflowNodeStatus_IsDirty
  • func (_m *MutableWorkflowNodeStatus) SetWorkflowNodePhase(phase v1alpha1.WorkflowNodePhase)
• type MutableWorkflowNodeStatus_GetWorkflowNodePhase
  • func (_m MutableWorkflowNodeStatus_GetWorkflowNodePhase) Return(_a0 v1alpha1.WorkflowNodePhase) *MutableWorkflowNodeStatus_GetWorkflowNodePhase
• type MutableWorkflowNodeStatus_IsDirty
  • func (_m MutableWorkflowNodeStatus_IsDirty) Return(_a0 bool) *MutableWorkflowNodeStatus_IsDirty
• type Mutable_IsDirty
  • func (_m Mutable_IsDirty) Return(_a0 bool) *Mutable_IsDirty
• type NodeStatusGetter
  • func (_m *NodeStatusGetter) GetNodeExecutionStatus(ctx context.Context, id string) v1alpha1.ExecutableNodeStatus
  • func (_m *NodeStatusGetter) OnGetNodeExecutionStatus(ctx context.Context, id string) *NodeStatusGetter_GetNodeExecutionStatus
  • func (_m *NodeStatusGetter) OnGetNodeExecutionStatusMatch(matchers ...interface{}) *NodeStatusGetter_GetNodeExecutionStatus
• type NodeStatusGetter_GetNodeExecutionStatus
  • func (_m NodeStatusGetter_GetNodeExecutionStatus) Return(_a0 v1alpha1.ExecutableNodeStatus) *NodeStatusGetter_GetNodeExecutionStatus
• type NodeStatusVisitor
  • func (_m *NodeStatusVisitor) VisitNodeStatuses(visitor func(string, v1alpha1.ExecutableNodeStatus))
• type TaskDetailsGetter
  • 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
  • func (_m TaskDetailsGetter_GetTask) Return(_a0 v1alpha1.ExecutableTask, _a1 error) *TaskDetailsGetter_GetTask
• type WorkflowMeta
  • func (_m *WorkflowMeta) GetAnnotations() map[string]string
  • func (_m *WorkflowMeta) GetCreationTimestamp() v1.Time
  • func (_m *WorkflowMeta) GetExecutionID() v1alpha1.WorkflowExecutionIdentifier
  • func (_m *WorkflowMeta) GetK8sWorkflowID() types.NamespacedName
  • func (_m *WorkflowMeta) GetLabels() map[string]string
  • func (_m *WorkflowMeta) GetName() string
  • func (_m *WorkflowMeta) GetNamespace() string
  • func (_m *WorkflowMeta) GetOwnerReference() v1.OwnerReference
  • func (_m *WorkflowMeta) GetServiceAccountName() string
  • func (_m *WorkflowMeta) OnGetAnnotations() *WorkflowMeta_GetAnnotations
  • func (_m *WorkflowMeta) OnGetAnnotationsMatch(matchers ...interface{}) *WorkflowMeta_GetAnnotations
  • func (_m *WorkflowMeta) OnGetCreationTimestamp() *WorkflowMeta_GetCreationTimestamp
  • func (_m *WorkflowMeta) OnGetCreationTimestampMatch(matchers ...interface{}) *WorkflowMeta_GetCreationTimestamp
  • func (_m *WorkflowMeta) OnGetExecutionID() *WorkflowMeta_GetExecutionID
  • func (_m *WorkflowMeta) OnGetExecutionIDMatch(matchers ...interface{}) *WorkflowMeta_GetExecutionID
  • func (_m *WorkflowMeta) OnGetK8sWorkflowID() *WorkflowMeta_GetK8sWorkflowID
  • func (_m *WorkflowMeta) OnGetK8sWorkflowIDMatch(matchers ...interface{}) *WorkflowMeta_GetK8sWorkflowID
  • func (_m *WorkflowMeta) OnGetLabels() *WorkflowMeta_GetLabels
  • func (_m *WorkflowMeta) OnGetLabelsMatch(matchers ...interface{}) *WorkflowMeta_GetLabels
  • func (_m *WorkflowMeta) OnGetName() *WorkflowMeta_GetName
  • func (_m *WorkflowMeta) OnGetNameMatch(matchers ...interface{}) *WorkflowMeta_GetName
  • func (_m *WorkflowMeta) OnGetNamespace() *WorkflowMeta_GetNamespace
  • func (_m *WorkflowMeta) OnGetNamespaceMatch(matchers ...interface{}) *WorkflowMeta_GetNamespace
  • func (_m *WorkflowMeta) OnGetOwnerReference() *WorkflowMeta_GetOwnerReference
  • func (_m *WorkflowMeta) OnGetOwnerReferenceMatch(matchers ...interface{}) *WorkflowMeta_GetOwnerReference
  • func (_m *WorkflowMeta) OnGetServiceAccountName() *WorkflowMeta_GetServiceAccountName
  • func (_m *WorkflowMeta) OnGetServiceAccountNameMatch(matchers ...interface{}) *WorkflowMeta_GetServiceAccountName
• type WorkflowMetaExtended
  • func (_m *WorkflowMetaExtended) FindSubWorkflow(subID string) v1alpha1.ExecutableSubWorkflow
  • func (_m *WorkflowMetaExtended) GetAnnotations() map[string]string
  • func (_m *WorkflowMetaExtended) GetCreationTimestamp() v1.Time
  • func (_m *WorkflowMetaExtended) GetExecutionID() v1alpha1.WorkflowExecutionIdentifier
  • func (_m *WorkflowMetaExtended) GetExecutionStatus() v1alpha1.ExecutableWorkflowStatus
  • func (_m *WorkflowMetaExtended) GetK8sWorkflowID() types.NamespacedName
  • func (_m *WorkflowMetaExtended) GetLabels() map[string]string
  • func (_m *WorkflowMetaExtended) GetName() string
  • func (_m *WorkflowMetaExtended) GetNamespace() string
  • func (_m *WorkflowMetaExtended) GetOwnerReference() v1.OwnerReference
  • func (_m *WorkflowMetaExtended) GetServiceAccountName() string
  • func (_m *WorkflowMetaExtended) GetTask(id string) (v1alpha1.ExecutableTask, error)
  • func (_m *WorkflowMetaExtended) OnFindSubWorkflow(subID string) *WorkflowMetaExtended_FindSubWorkflow
  • func (_m *WorkflowMetaExtended) OnFindSubWorkflowMatch(matchers ...interface{}) *WorkflowMetaExtended_FindSubWorkflow
  • func (_m *WorkflowMetaExtended) OnGetAnnotations() *WorkflowMetaExtended_GetAnnotations
  • func (_m *WorkflowMetaExtended) OnGetAnnotationsMatch(matchers ...interface{}) *WorkflowMetaExtended_GetAnnotations
  • func (_m *WorkflowMetaExtended) OnGetCreationTimestamp() *WorkflowMetaExtended_GetCreationTimestamp
  • func (_m *WorkflowMetaExtended) OnGetCreationTimestampMatch(matchers ...interface{}) *WorkflowMetaExtended_GetCreationTimestamp
  • func (_m *WorkflowMetaExtended) OnGetExecutionID() *WorkflowMetaExtended_GetExecutionID
  • func (_m *WorkflowMetaExtended) OnGetExecutionIDMatch(matchers ...interface{}) *WorkflowMetaExtended_GetExecutionID
  • func (_m *WorkflowMetaExtended) OnGetExecutionStatus() *WorkflowMetaExtended_GetExecutionStatus
  • func (_m *WorkflowMetaExtended) OnGetExecutionStatusMatch(matchers ...interface{}) *WorkflowMetaExtended_GetExecutionStatus
  • func (_m *WorkflowMetaExtended) OnGetK8sWorkflowID() *WorkflowMetaExtended_GetK8sWorkflowID
  • func (_m *WorkflowMetaExtended) OnGetK8sWorkflowIDMatch(matchers ...interface{}) *WorkflowMetaExtended_GetK8sWorkflowID
  • func (_m *WorkflowMetaExtended) OnGetLabels() *WorkflowMetaExtended_GetLabels
  • func (_m *WorkflowMetaExtended) OnGetLabelsMatch(matchers ...interface{}) *WorkflowMetaExtended_GetLabels
  • func (_m *WorkflowMetaExtended) OnGetName() *WorkflowMetaExtended_GetName
  • func (_m *WorkflowMetaExtended) OnGetNameMatch(matchers ...interface{}) *WorkflowMetaExtended_GetName
  • func (_m *WorkflowMetaExtended) OnGetNamespace() *WorkflowMetaExtended_GetNamespace
  • func (_m *WorkflowMetaExtended) OnGetNamespaceMatch(matchers ...interface{}) *WorkflowMetaExtended_GetNamespace
  • func (_m *WorkflowMetaExtended) OnGetOwnerReference() *WorkflowMetaExtended_GetOwnerReference
  • func (_m *WorkflowMetaExtended) OnGetOwnerReferenceMatch(matchers ...interface{}) *WorkflowMetaExtended_GetOwnerReference
  • func (_m *WorkflowMetaExtended) OnGetServiceAccountName() *WorkflowMetaExtended_GetServiceAccountName
  • func (_m *WorkflowMetaExtended) OnGetServiceAccountNameMatch(matchers ...interface{}) *WorkflowMetaExtended_GetServiceAccountName
  • func (_m *WorkflowMetaExtended) OnGetTask(id string) *WorkflowMetaExtended_GetTask
  • func (_m *WorkflowMetaExtended) OnGetTaskMatch(matchers ...interface{}) *WorkflowMetaExtended_GetTask
• type WorkflowMetaExtended_FindSubWorkflow
  • func (_m WorkflowMetaExtended_FindSubWorkflow) Return(_a0 v1alpha1.ExecutableSubWorkflow) *WorkflowMetaExtended_FindSubWorkflow
• type WorkflowMetaExtended_GetAnnotations
  • func (_m WorkflowMetaExtended_GetAnnotations) Return(_a0 map[string]string) *WorkflowMetaExtended_GetAnnotations
• type WorkflowMetaExtended_GetCreationTimestamp
  • func (_m WorkflowMetaExtended_GetCreationTimestamp) Return(_a0 v1.Time) *WorkflowMetaExtended_GetCreationTimestamp
• type WorkflowMetaExtended_GetExecutionID
  • func (_m WorkflowMetaExtended_GetExecutionID) Return(_a0 v1alpha1.WorkflowExecutionIdentifier) *WorkflowMetaExtended_GetExecutionID
• type WorkflowMetaExtended_GetExecutionStatus
  • func (_m WorkflowMetaExtended_GetExecutionStatus) Return(_a0 v1alpha1.ExecutableWorkflowStatus) *WorkflowMetaExtended_GetExecutionStatus
• type WorkflowMetaExtended_GetK8sWorkflowID
  • func (_m WorkflowMetaExtended_GetK8sWorkflowID) Return(_a0 types.NamespacedName) *WorkflowMetaExtended_GetK8sWorkflowID
• type WorkflowMetaExtended_GetLabels
  • func (_m WorkflowMetaExtended_GetLabels) Return(_a0 map[string]string) *WorkflowMetaExtended_GetLabels
• type WorkflowMetaExtended_GetName
  • func (_m WorkflowMetaExtended_GetName) Return(_a0 string) *WorkflowMetaExtended_GetName
• type WorkflowMetaExtended_GetNamespace
  • func (_m WorkflowMetaExtended_GetNamespace) Return(_a0 string) *WorkflowMetaExtended_GetNamespace
• type WorkflowMetaExtended_GetOwnerReference
  • func (_m WorkflowMetaExtended_GetOwnerReference) Return(_a0 v1.OwnerReference) *WorkflowMetaExtended_GetOwnerReference
• type WorkflowMetaExtended_GetServiceAccountName
  • func (_m WorkflowMetaExtended_GetServiceAccountName) Return(_a0 string) *WorkflowMetaExtended_GetServiceAccountName
• type WorkflowMetaExtended_GetTask
  • func (_m WorkflowMetaExtended_GetTask) Return(_a0 v1alpha1.ExecutableTask, _a1 error) *WorkflowMetaExtended_GetTask
• type WorkflowMeta_GetAnnotations
  • func (_m WorkflowMeta_GetAnnotations) Return(_a0 map[string]string) *WorkflowMeta_GetAnnotations
• type WorkflowMeta_GetCreationTimestamp
  • func (_m WorkflowMeta_GetCreationTimestamp) Return(_a0 v1.Time) *WorkflowMeta_GetCreationTimestamp
• type WorkflowMeta_GetExecutionID
  • func (_m WorkflowMeta_GetExecutionID) Return(_a0 v1alpha1.WorkflowExecutionIdentifier) *WorkflowMeta_GetExecutionID
• type WorkflowMeta_GetK8sWorkflowID
  • func (_m WorkflowMeta_GetK8sWorkflowID) Return(_a0 types.NamespacedName) *WorkflowMeta_GetK8sWorkflowID
• type WorkflowMeta_GetLabels
  • func (_m WorkflowMeta_GetLabels) Return(_a0 map[string]string) *WorkflowMeta_GetLabels
• type WorkflowMeta_GetName
  • func (_m WorkflowMeta_GetName) Return(_a0 string) *WorkflowMeta_GetName
• type WorkflowMeta_GetNamespace
  • func (_m WorkflowMeta_GetNamespace) Return(_a0 string) *WorkflowMeta_GetNamespace
• type WorkflowMeta_GetOwnerReference
  • func (_m WorkflowMeta_GetOwnerReference) Return(_a0 v1.OwnerReference) *WorkflowMeta_GetOwnerReference
• type WorkflowMeta_GetServiceAccountName
  • func (_m WorkflowMeta_GetServiceAccountName) Return(_a0 string) *WorkflowMeta_GetServiceAccountName

Types

type BaseNode

type BaseNode struct {
	mock.Mock
}

BaseNode is an autogenerated mock type for the BaseNode type

func (*BaseNode) GetID

func (_m *BaseNode) GetID() string

GetID provides a mock function with given fields:

func (*BaseNode) GetKind

func (_m *BaseNode) GetKind() v1alpha1.NodeKind

GetKind provides a mock function with given fields:

func (*BaseNode) OnGetID

func (_m *BaseNode) OnGetID() *BaseNode_GetID

func (*BaseNode) OnGetIDMatch

func (_m *BaseNode) OnGetIDMatch(matchers ...interface{}) *BaseNode_GetID

func (*BaseNode) OnGetKind

func (_m *BaseNode) OnGetKind() *BaseNode_GetKind

func (*BaseNode) OnGetKindMatch

func (_m *BaseNode) OnGetKindMatch(matchers ...interface{}) *BaseNode_GetKind

type BaseNode_GetID

type BaseNode_GetID struct {
	*mock.Call
}

func (BaseNode_GetID) Return

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

type BaseNode_GetKind

type BaseNode_GetKind struct {
	*mock.Call
}

func (BaseNode_GetKind) Return

func (_m BaseNode_GetKind) Return(_a0 v1alpha1.NodeKind) *BaseNode_GetKind

type BaseWorkflow

type BaseWorkflow struct {
	mock.Mock
}

BaseWorkflow is an autogenerated mock type for the BaseWorkflow type

func (*BaseWorkflow) FromNode

func (_m *BaseWorkflow) FromNode(name string) ([]string, error)

FromNode provides a mock function with given fields: name

func (*BaseWorkflow) GetID

func (_m *BaseWorkflow) GetID() string

GetID provides a mock function with given fields:

func (*BaseWorkflow) GetNode

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

GetNode provides a mock function with given fields: nodeID

func (*BaseWorkflow) OnFromNode

func (_m *BaseWorkflow) OnFromNode(name string) *BaseWorkflow_FromNode

func (*BaseWorkflow) OnFromNodeMatch

func (_m *BaseWorkflow) OnFromNodeMatch(matchers ...interface{}) *BaseWorkflow_FromNode

func (*BaseWorkflow) OnGetID

func (_m *BaseWorkflow) OnGetID() *BaseWorkflow_GetID

func (*BaseWorkflow) OnGetIDMatch

func (_m *BaseWorkflow) OnGetIDMatch(matchers ...interface{}) *BaseWorkflow_GetID

func (*BaseWorkflow) OnGetNode

func (_m *BaseWorkflow) OnGetNode(nodeID string) *BaseWorkflow_GetNode

func (*BaseWorkflow) OnGetNodeMatch

func (_m *BaseWorkflow) OnGetNodeMatch(matchers ...interface{}) *BaseWorkflow_GetNode

func (*BaseWorkflow) OnStartNode

func (_m *BaseWorkflow) OnStartNode() *BaseWorkflow_StartNode

func (*BaseWorkflow) OnStartNodeMatch

func (_m *BaseWorkflow) OnStartNodeMatch(matchers ...interface{}) *BaseWorkflow_StartNode

func (*BaseWorkflow) StartNode

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

StartNode provides a mock function with given fields:

type BaseWorkflowWithStatus

type BaseWorkflowWithStatus struct {
	mock.Mock
}

BaseWorkflowWithStatus is an autogenerated mock type for the BaseWorkflowWithStatus type

func (*BaseWorkflowWithStatus) FromNode

func (_m *BaseWorkflowWithStatus) FromNode(name string) ([]string, error)

FromNode provides a mock function with given fields: name

func (*BaseWorkflowWithStatus) GetID

func (_m *BaseWorkflowWithStatus) GetID() string

GetID provides a mock function with given fields:

func (*BaseWorkflowWithStatus) GetNode

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

GetNode provides a mock function with given fields: nodeID

func (*BaseWorkflowWithStatus) GetNodeExecutionStatus

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

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

func (*BaseWorkflowWithStatus) OnFromNode

func (_m *BaseWorkflowWithStatus) OnFromNode(name string) *BaseWorkflowWithStatus_FromNode

func (*BaseWorkflowWithStatus) OnFromNodeMatch

func (_m *BaseWorkflowWithStatus) OnFromNodeMatch(matchers ...interface{}) *BaseWorkflowWithStatus_FromNode

func (*BaseWorkflowWithStatus) OnGetID

func (_m *BaseWorkflowWithStatus) OnGetID() *BaseWorkflowWithStatus_GetID

func (*BaseWorkflowWithStatus) OnGetIDMatch

func (_m *BaseWorkflowWithStatus) OnGetIDMatch(matchers ...interface{}) *BaseWorkflowWithStatus_GetID

func (*BaseWorkflowWithStatus) OnGetNode

func (_m *BaseWorkflowWithStatus) OnGetNode(nodeID string) *BaseWorkflowWithStatus_GetNode

func (*BaseWorkflowWithStatus) OnGetNodeExecutionStatus

func (_m *BaseWorkflowWithStatus) OnGetNodeExecutionStatus(ctx context.Context, id string) *BaseWorkflowWithStatus_GetNodeExecutionStatus

func (*BaseWorkflowWithStatus) OnGetNodeExecutionStatusMatch

func (_m *BaseWorkflowWithStatus) OnGetNodeExecutionStatusMatch(matchers ...interface{}) *BaseWorkflowWithStatus_GetNodeExecutionStatus

func (*BaseWorkflowWithStatus) OnGetNodeMatch

func (_m *BaseWorkflowWithStatus) OnGetNodeMatch(matchers ...interface{}) *BaseWorkflowWithStatus_GetNode

func (*BaseWorkflowWithStatus) OnStartNode

func (_m *BaseWorkflowWithStatus) OnStartNode() *BaseWorkflowWithStatus_StartNode

func (*BaseWorkflowWithStatus) OnStartNodeMatch

func (_m *BaseWorkflowWithStatus) OnStartNodeMatch(matchers ...interface{}) *BaseWorkflowWithStatus_StartNode

func (*BaseWorkflowWithStatus) StartNode

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

StartNode provides a mock function with given fields:

type BaseWorkflowWithStatus_FromNode

type BaseWorkflowWithStatus_FromNode struct {
	*mock.Call
}

func (BaseWorkflowWithStatus_FromNode) Return

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

type BaseWorkflowWithStatus_GetID

type BaseWorkflowWithStatus_GetID struct {
	*mock.Call
}

func (BaseWorkflowWithStatus_GetID) Return

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

type BaseWorkflowWithStatus_GetNode

type BaseWorkflowWithStatus_GetNode struct {
	*mock.Call
}

func (BaseWorkflowWithStatus_GetNode) Return

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

type BaseWorkflowWithStatus_GetNodeExecutionStatus

type BaseWorkflowWithStatus_GetNodeExecutionStatus struct {
	*mock.Call
}

func (BaseWorkflowWithStatus_GetNodeExecutionStatus) Return

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

type BaseWorkflowWithStatus_StartNode

type BaseWorkflowWithStatus_StartNode struct {
	*mock.Call
}

func (BaseWorkflowWithStatus_StartNode) Return

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

type BaseWorkflow_FromNode

type BaseWorkflow_FromNode struct {
	*mock.Call
}

func (BaseWorkflow_FromNode) Return

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

type BaseWorkflow_GetID

type BaseWorkflow_GetID struct {
	*mock.Call
}

func (BaseWorkflow_GetID) Return

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

type BaseWorkflow_GetNode

type BaseWorkflow_GetNode struct {
	*mock.Call
}

func (BaseWorkflow_GetNode) Return

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

type BaseWorkflow_StartNode

type BaseWorkflow_StartNode struct {
	*mock.Call
}

func (BaseWorkflow_StartNode) Return

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

type ExecutableBranchNode

type ExecutableBranchNode struct {
	mock.Mock
}

ExecutableBranchNode is an autogenerated mock type for the ExecutableBranchNode type

func (*ExecutableBranchNode) GetElse

func (_m *ExecutableBranchNode) GetElse() *string

GetElse provides a mock function with given fields:

func (*ExecutableBranchNode) GetElseFail

func (_m *ExecutableBranchNode) GetElseFail() *core.Error

GetElseFail provides a mock function with given fields:

func (*ExecutableBranchNode) GetElseIf

func (_m *ExecutableBranchNode) GetElseIf() []v1alpha1.ExecutableIfBlock

GetElseIf provides a mock function with given fields:

func (*ExecutableBranchNode) GetIf

func (_m *ExecutableBranchNode) GetIf() v1alpha1.ExecutableIfBlock

GetIf provides a mock function with given fields:

func (*ExecutableBranchNode) OnGetElse

func (_m *ExecutableBranchNode) OnGetElse() *ExecutableBranchNode_GetElse

func (*ExecutableBranchNode) OnGetElseFail

func (_m *ExecutableBranchNode) OnGetElseFail() *ExecutableBranchNode_GetElseFail

func (*ExecutableBranchNode) OnGetElseFailMatch

func (_m *ExecutableBranchNode) OnGetElseFailMatch(matchers ...interface{}) *ExecutableBranchNode_GetElseFail

func (*ExecutableBranchNode) OnGetElseIf

func (_m *ExecutableBranchNode) OnGetElseIf() *ExecutableBranchNode_GetElseIf

func (*ExecutableBranchNode) OnGetElseIfMatch

func (_m *ExecutableBranchNode) OnGetElseIfMatch(matchers ...interface{}) *ExecutableBranchNode_GetElseIf

func (*ExecutableBranchNode) OnGetElseMatch

func (_m *ExecutableBranchNode) OnGetElseMatch(matchers ...interface{}) *ExecutableBranchNode_GetElse

func (*ExecutableBranchNode) OnGetIf

func (_m *ExecutableBranchNode) OnGetIf() *ExecutableBranchNode_GetIf

func (*ExecutableBranchNode) OnGetIfMatch

func (_m *ExecutableBranchNode) OnGetIfMatch(matchers ...interface{}) *ExecutableBranchNode_GetIf

type ExecutableBranchNodeStatus

type ExecutableBranchNodeStatus struct {
	mock.Mock
}

ExecutableBranchNodeStatus is an autogenerated mock type for the ExecutableBranchNodeStatus type

func (*ExecutableBranchNodeStatus) GetFinalizedNode

func (_m *ExecutableBranchNodeStatus) GetFinalizedNode() *string

GetFinalizedNode provides a mock function with given fields:

func (*ExecutableBranchNodeStatus) GetPhase

func (_m *ExecutableBranchNodeStatus) GetPhase() v1alpha1.BranchNodePhase

GetPhase provides a mock function with given fields:

func (*ExecutableBranchNodeStatus) OnGetFinalizedNode

func (_m *ExecutableBranchNodeStatus) OnGetFinalizedNode() *ExecutableBranchNodeStatus_GetFinalizedNode

func (*ExecutableBranchNodeStatus) OnGetFinalizedNodeMatch

func (_m *ExecutableBranchNodeStatus) OnGetFinalizedNodeMatch(matchers ...interface{}) *ExecutableBranchNodeStatus_GetFinalizedNode

func (*ExecutableBranchNodeStatus) OnGetPhase

func (_m *ExecutableBranchNodeStatus) OnGetPhase() *ExecutableBranchNodeStatus_GetPhase

func (*ExecutableBranchNodeStatus) OnGetPhaseMatch

func (_m *ExecutableBranchNodeStatus) OnGetPhaseMatch(matchers ...interface{}) *ExecutableBranchNodeStatus_GetPhase

type ExecutableBranchNodeStatus_GetFinalizedNode

type ExecutableBranchNodeStatus_GetFinalizedNode struct {
	*mock.Call
}

func (ExecutableBranchNodeStatus_GetFinalizedNode) Return

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

type ExecutableBranchNodeStatus_GetPhase

type ExecutableBranchNodeStatus_GetPhase struct {
	*mock.Call
}

func (ExecutableBranchNodeStatus_GetPhase) Return

func (_m ExecutableBranchNodeStatus_GetPhase) Return(_a0 v1alpha1.BranchNodePhase) *ExecutableBranchNodeStatus_GetPhase

type ExecutableBranchNode_GetElse

type ExecutableBranchNode_GetElse struct {
	*mock.Call
}

func (ExecutableBranchNode_GetElse) Return

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

type ExecutableBranchNode_GetElseFail

type ExecutableBranchNode_GetElseFail struct {
	*mock.Call
}

func (ExecutableBranchNode_GetElseFail) Return

func (_m ExecutableBranchNode_GetElseFail) Return(_a0 *core.Error) *ExecutableBranchNode_GetElseFail

type ExecutableBranchNode_GetElseIf

type ExecutableBranchNode_GetElseIf struct {
	*mock.Call
}

func (ExecutableBranchNode_GetElseIf) Return

func (_m ExecutableBranchNode_GetElseIf) Return(_a0 []v1alpha1.ExecutableIfBlock) *ExecutableBranchNode_GetElseIf

type ExecutableBranchNode_GetIf

type ExecutableBranchNode_GetIf struct {
	*mock.Call
}

func (ExecutableBranchNode_GetIf) Return

func (_m ExecutableBranchNode_GetIf) Return(_a0 v1alpha1.ExecutableIfBlock) *ExecutableBranchNode_GetIf

type ExecutableDynamicNodeStatus

type ExecutableDynamicNodeStatus struct {
	mock.Mock
}

ExecutableDynamicNodeStatus is an autogenerated mock type for the ExecutableDynamicNodeStatus type

func (*ExecutableDynamicNodeStatus) GetDynamicNodePhase

func (_m *ExecutableDynamicNodeStatus) GetDynamicNodePhase() v1alpha1.DynamicNodePhase

GetDynamicNodePhase provides a mock function with given fields:

func (*ExecutableDynamicNodeStatus) GetDynamicNodeReason

func (_m *ExecutableDynamicNodeStatus) GetDynamicNodeReason() string

GetDynamicNodeReason provides a mock function with given fields:

func (*ExecutableDynamicNodeStatus) OnGetDynamicNodePhase

func (_m *ExecutableDynamicNodeStatus) OnGetDynamicNodePhase() *ExecutableDynamicNodeStatus_GetDynamicNodePhase

func (*ExecutableDynamicNodeStatus) OnGetDynamicNodePhaseMatch

func (_m *ExecutableDynamicNodeStatus) OnGetDynamicNodePhaseMatch(matchers ...interface{}) *ExecutableDynamicNodeStatus_GetDynamicNodePhase

func (*ExecutableDynamicNodeStatus) OnGetDynamicNodeReason

func (_m *ExecutableDynamicNodeStatus) OnGetDynamicNodeReason() *ExecutableDynamicNodeStatus_GetDynamicNodeReason

func (*ExecutableDynamicNodeStatus) OnGetDynamicNodeReasonMatch

func (_m *ExecutableDynamicNodeStatus) OnGetDynamicNodeReasonMatch(matchers ...interface{}) *ExecutableDynamicNodeStatus_GetDynamicNodeReason

type ExecutableDynamicNodeStatus_GetDynamicNodePhase

type ExecutableDynamicNodeStatus_GetDynamicNodePhase struct {
	*mock.Call
}

func (ExecutableDynamicNodeStatus_GetDynamicNodePhase) Return

func (_m ExecutableDynamicNodeStatus_GetDynamicNodePhase) Return(_a0 v1alpha1.DynamicNodePhase) *ExecutableDynamicNodeStatus_GetDynamicNodePhase

type ExecutableDynamicNodeStatus_GetDynamicNodeReason

type ExecutableDynamicNodeStatus_GetDynamicNodeReason struct {
	*mock.Call
}

func (ExecutableDynamicNodeStatus_GetDynamicNodeReason) Return

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

type ExecutableIfBlock

type ExecutableIfBlock struct {
	mock.Mock
}

ExecutableIfBlock is an autogenerated mock type for the ExecutableIfBlock type

func (*ExecutableIfBlock) GetCondition

func (_m *ExecutableIfBlock) GetCondition() *core.BooleanExpression

GetCondition provides a mock function with given fields:

func (*ExecutableIfBlock) GetThenNode

func (_m *ExecutableIfBlock) GetThenNode() *string

GetThenNode provides a mock function with given fields:

func (*ExecutableIfBlock) OnGetCondition

func (_m *ExecutableIfBlock) OnGetCondition() *ExecutableIfBlock_GetCondition

func (*ExecutableIfBlock) OnGetConditionMatch

func (_m *ExecutableIfBlock) OnGetConditionMatch(matchers ...interface{}) *ExecutableIfBlock_GetCondition

func (*ExecutableIfBlock) OnGetThenNode

func (_m *ExecutableIfBlock) OnGetThenNode() *ExecutableIfBlock_GetThenNode

func (*ExecutableIfBlock) OnGetThenNodeMatch

func (_m *ExecutableIfBlock) OnGetThenNodeMatch(matchers ...interface{}) *ExecutableIfBlock_GetThenNode

type ExecutableIfBlock_GetCondition

type ExecutableIfBlock_GetCondition struct {
	*mock.Call
}

func (ExecutableIfBlock_GetCondition) Return

func (_m ExecutableIfBlock_GetCondition) Return(_a0 *core.BooleanExpression) *ExecutableIfBlock_GetCondition

type ExecutableIfBlock_GetThenNode

type ExecutableIfBlock_GetThenNode struct {
	*mock.Call
}

func (ExecutableIfBlock_GetThenNode) Return

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

type ExecutableNode

type ExecutableNode struct {
	mock.Mock
}

ExecutableNode is an autogenerated mock type for the ExecutableNode type

func (*ExecutableNode) GetActiveDeadline

func (_m *ExecutableNode) GetActiveDeadline() *time.Duration

GetActiveDeadline provides a mock function with given fields:

func (*ExecutableNode) GetBranchNode

func (_m *ExecutableNode) GetBranchNode() v1alpha1.ExecutableBranchNode

GetBranchNode provides a mock function with given fields:

func (*ExecutableNode) GetConfig

func (_m *ExecutableNode) GetConfig() *v1.ConfigMap

GetConfig provides a mock function with given fields:

func (*ExecutableNode) GetExecutionDeadline

func (_m *ExecutableNode) GetExecutionDeadline() *time.Duration

GetExecutionDeadline provides a mock function with given fields:

func (*ExecutableNode) GetID

func (_m *ExecutableNode) GetID() string

GetID provides a mock function with given fields:

func (*ExecutableNode) GetInputBindings

func (_m *ExecutableNode) GetInputBindings() []*v1alpha1.Binding

GetInputBindings provides a mock function with given fields:

func (*ExecutableNode) GetKind

func (_m *ExecutableNode) GetKind() v1alpha1.NodeKind

GetKind provides a mock function with given fields:

func (*ExecutableNode) GetOutputAlias

func (_m *ExecutableNode) GetOutputAlias() []v1alpha1.Alias

GetOutputAlias provides a mock function with given fields:

func (*ExecutableNode) GetResources

func (_m *ExecutableNode) GetResources() *v1.ResourceRequirements

GetResources provides a mock function with given fields:

func (*ExecutableNode) GetRetryStrategy

func (_m *ExecutableNode) GetRetryStrategy() *v1alpha1.RetryStrategy

GetRetryStrategy provides a mock function with given fields:

func (*ExecutableNode) GetTaskID

func (_m *ExecutableNode) GetTaskID() *string

GetTaskID provides a mock function with given fields:

func (*ExecutableNode) GetWorkflowNode

func (_m *ExecutableNode) GetWorkflowNode() v1alpha1.ExecutableWorkflowNode

GetWorkflowNode provides a mock function with given fields:

func (*ExecutableNode) IsEndNode

func (_m *ExecutableNode) IsEndNode() bool

IsEndNode provides a mock function with given fields:

func (*ExecutableNode) IsStartNode

func (_m *ExecutableNode) IsStartNode() bool

IsStartNode provides a mock function with given fields:

func (*ExecutableNode) OnGetActiveDeadline

func (_m *ExecutableNode) OnGetActiveDeadline() *ExecutableNode_GetActiveDeadline

func (*ExecutableNode) OnGetActiveDeadlineMatch

func (_m *ExecutableNode) OnGetActiveDeadlineMatch(matchers ...interface{}) *ExecutableNode_GetActiveDeadline

func (*ExecutableNode) OnGetBranchNode

func (_m *ExecutableNode) OnGetBranchNode() *ExecutableNode_GetBranchNode

func (*ExecutableNode) OnGetBranchNodeMatch

func (_m *ExecutableNode) OnGetBranchNodeMatch(matchers ...interface{}) *ExecutableNode_GetBranchNode

func (*ExecutableNode) OnGetConfig

func (_m *ExecutableNode) OnGetConfig() *ExecutableNode_GetConfig

func (*ExecutableNode) OnGetConfigMatch

func (_m *ExecutableNode) OnGetConfigMatch(matchers ...interface{}) *ExecutableNode_GetConfig

func (*ExecutableNode) OnGetExecutionDeadline

func (_m *ExecutableNode) OnGetExecutionDeadline() *ExecutableNode_GetExecutionDeadline

func (*ExecutableNode) OnGetExecutionDeadlineMatch

func (_m *ExecutableNode) OnGetExecutionDeadlineMatch(matchers ...interface{}) *ExecutableNode_GetExecutionDeadline

func (*ExecutableNode) OnGetID

func (_m *ExecutableNode) OnGetID() *ExecutableNode_GetID

func (*ExecutableNode) OnGetIDMatch

func (_m *ExecutableNode) OnGetIDMatch(matchers ...interface{}) *ExecutableNode_GetID

func (*ExecutableNode) OnGetInputBindings

func (_m *ExecutableNode) OnGetInputBindings() *ExecutableNode_GetInputBindings

func (*ExecutableNode) OnGetInputBindingsMatch

func (_m *ExecutableNode) OnGetInputBindingsMatch(matchers ...interface{}) *ExecutableNode_GetInputBindings

func (*ExecutableNode) OnGetKind

func (_m *ExecutableNode) OnGetKind() *ExecutableNode_GetKind

func (*ExecutableNode) OnGetKindMatch

func (_m *ExecutableNode) OnGetKindMatch(matchers ...interface{}) *ExecutableNode_GetKind

func (*ExecutableNode) OnGetOutputAlias

func (_m *ExecutableNode) OnGetOutputAlias() *ExecutableNode_GetOutputAlias

func (*ExecutableNode) OnGetOutputAliasMatch

func (_m *ExecutableNode) OnGetOutputAliasMatch(matchers ...interface{}) *ExecutableNode_GetOutputAlias

func (*ExecutableNode) OnGetResources

func (_m *ExecutableNode) OnGetResources() *ExecutableNode_GetResources

func (*ExecutableNode) OnGetResourcesMatch

func (_m *ExecutableNode) OnGetResourcesMatch(matchers ...interface{}) *ExecutableNode_GetResources

func (*ExecutableNode) OnGetRetryStrategy

func (_m *ExecutableNode) OnGetRetryStrategy() *ExecutableNode_GetRetryStrategy

func (*ExecutableNode) OnGetRetryStrategyMatch

func (_m *ExecutableNode) OnGetRetryStrategyMatch(matchers ...interface{}) *ExecutableNode_GetRetryStrategy

func (*ExecutableNode) OnGetTaskID

func (_m *ExecutableNode) OnGetTaskID() *ExecutableNode_GetTaskID

func (*ExecutableNode) OnGetTaskIDMatch

func (_m *ExecutableNode) OnGetTaskIDMatch(matchers ...interface{}) *ExecutableNode_GetTaskID

func (*ExecutableNode) OnGetWorkflowNode

func (_m *ExecutableNode) OnGetWorkflowNode() *ExecutableNode_GetWorkflowNode

func (*ExecutableNode) OnGetWorkflowNodeMatch

func (_m *ExecutableNode) OnGetWorkflowNodeMatch(matchers ...interface{}) *ExecutableNode_GetWorkflowNode

func (*ExecutableNode) OnIsEndNode

func (_m *ExecutableNode) OnIsEndNode() *ExecutableNode_IsEndNode

func (*ExecutableNode) OnIsEndNodeMatch

func (_m *ExecutableNode) OnIsEndNodeMatch(matchers ...interface{}) *ExecutableNode_IsEndNode

func (*ExecutableNode) OnIsStartNode

func (_m *ExecutableNode) OnIsStartNode() *ExecutableNode_IsStartNode

func (*ExecutableNode) OnIsStartNodeMatch

func (_m *ExecutableNode) OnIsStartNodeMatch(matchers ...interface{}) *ExecutableNode_IsStartNode

type ExecutableNodeStatus

type ExecutableNodeStatus struct {
	mock.Mock
}

ExecutableNodeStatus is an autogenerated mock type for the ExecutableNodeStatus type

func (*ExecutableNodeStatus) ClearDynamicNodeStatus

func (_m *ExecutableNodeStatus) ClearDynamicNodeStatus()

ClearDynamicNodeStatus provides a mock function with given fields:

func (*ExecutableNodeStatus) ClearLastAttemptStartedAt

func (_m *ExecutableNodeStatus) ClearLastAttemptStartedAt()

ClearLastAttemptStartedAt provides a mock function with given fields:

func (*ExecutableNodeStatus) ClearSubNodeStatus

func (_m *ExecutableNodeStatus) ClearSubNodeStatus()

ClearSubNodeStatus provides a mock function with given fields:

func (*ExecutableNodeStatus) ClearTaskStatus

func (_m *ExecutableNodeStatus) ClearTaskStatus()

ClearTaskStatus provides a mock function with given fields:

func (*ExecutableNodeStatus) ClearWorkflowStatus

func (_m *ExecutableNodeStatus) ClearWorkflowStatus()

ClearWorkflowStatus provides a mock function with given fields:

func (*ExecutableNodeStatus) GetAttempts

func (_m *ExecutableNodeStatus) GetAttempts() uint32

GetAttempts provides a mock function with given fields:

func (*ExecutableNodeStatus) GetBranchStatus

func (_m *ExecutableNodeStatus) GetBranchStatus() v1alpha1.MutableBranchNodeStatus

GetBranchStatus provides a mock function with given fields:

func (*ExecutableNodeStatus) GetDataDir

func (_m *ExecutableNodeStatus) GetDataDir() storage.DataReference

GetDataDir provides a mock function with given fields:

func (*ExecutableNodeStatus) GetDynamicNodeStatus

func (_m *ExecutableNodeStatus) GetDynamicNodeStatus() v1alpha1.MutableDynamicNodeStatus

GetDynamicNodeStatus provides a mock function with given fields:

func (*ExecutableNodeStatus) GetLastAttemptStartedAt

func (_m *ExecutableNodeStatus) GetLastAttemptStartedAt() *v1.Time

GetLastAttemptStartedAt provides a mock function with given fields:

func (*ExecutableNodeStatus) GetLastUpdatedAt

func (_m *ExecutableNodeStatus) GetLastUpdatedAt() *v1.Time

GetLastUpdatedAt provides a mock function with given fields:

func (*ExecutableNodeStatus) GetMessage

func (_m *ExecutableNodeStatus) GetMessage() string

GetMessage provides a mock function with given fields:

func (*ExecutableNodeStatus) GetNodeExecutionStatus

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

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

func (*ExecutableNodeStatus) GetOrCreateBranchStatus

func (_m *ExecutableNodeStatus) GetOrCreateBranchStatus() v1alpha1.MutableBranchNodeStatus

GetOrCreateBranchStatus provides a mock function with given fields:

func (*ExecutableNodeStatus) GetOrCreateDynamicNodeStatus

func (_m *ExecutableNodeStatus) GetOrCreateDynamicNodeStatus() v1alpha1.MutableDynamicNodeStatus

GetOrCreateDynamicNodeStatus provides a mock function with given fields:

func (*ExecutableNodeStatus) GetOrCreateTaskStatus

func (_m *ExecutableNodeStatus) GetOrCreateTaskStatus() v1alpha1.MutableTaskNodeStatus

GetOrCreateTaskStatus provides a mock function with given fields:

func (*ExecutableNodeStatus) GetOrCreateWorkflowStatus

func (_m *ExecutableNodeStatus) GetOrCreateWorkflowStatus() v1alpha1.MutableWorkflowNodeStatus

GetOrCreateWorkflowStatus provides a mock function with given fields:

func (*ExecutableNodeStatus) GetOutputDir

func (_m *ExecutableNodeStatus) GetOutputDir() storage.DataReference

GetOutputDir provides a mock function with given fields:

func (*ExecutableNodeStatus) GetParentNodeID

func (_m *ExecutableNodeStatus) GetParentNodeID() *string

GetParentNodeID provides a mock function with given fields:

func (*ExecutableNodeStatus) GetParentTaskID

func (_m *ExecutableNodeStatus) GetParentTaskID() *core.TaskExecutionIdentifier

GetParentTaskID provides a mock function with given fields:

func (*ExecutableNodeStatus) GetPhase

func (_m *ExecutableNodeStatus) GetPhase() v1alpha1.NodePhase

GetPhase provides a mock function with given fields:

func (*ExecutableNodeStatus) GetQueuedAt

func (_m *ExecutableNodeStatus) GetQueuedAt() *v1.Time

GetQueuedAt provides a mock function with given fields:

func (*ExecutableNodeStatus) GetStartedAt

func (_m *ExecutableNodeStatus) GetStartedAt() *v1.Time

GetStartedAt provides a mock function with given fields:

func (*ExecutableNodeStatus) GetStoppedAt

func (_m *ExecutableNodeStatus) GetStoppedAt() *v1.Time

GetStoppedAt provides a mock function with given fields:

func (*ExecutableNodeStatus) GetTaskNodeStatus

func (_m *ExecutableNodeStatus) GetTaskNodeStatus() v1alpha1.ExecutableTaskNodeStatus

GetTaskNodeStatus provides a mock function with given fields:

func (*ExecutableNodeStatus) GetTaskStatus

func (_m *ExecutableNodeStatus) GetTaskStatus() v1alpha1.MutableTaskNodeStatus

GetTaskStatus provides a mock function with given fields:

func (*ExecutableNodeStatus) GetWorkflowNodeStatus

func (_m *ExecutableNodeStatus) GetWorkflowNodeStatus() v1alpha1.ExecutableWorkflowNodeStatus

GetWorkflowNodeStatus provides a mock function with given fields:

func (*ExecutableNodeStatus) GetWorkflowStatus

func (_m *ExecutableNodeStatus) GetWorkflowStatus() v1alpha1.MutableWorkflowNodeStatus

GetWorkflowStatus provides a mock function with given fields:

func (*ExecutableNodeStatus) IncrementAttempts

func (_m *ExecutableNodeStatus) IncrementAttempts() uint32

IncrementAttempts provides a mock function with given fields:

func (*ExecutableNodeStatus) IsCached

func (_m *ExecutableNodeStatus) IsCached() bool

IsCached provides a mock function with given fields:

func (*ExecutableNodeStatus) IsDirty

func (_m *ExecutableNodeStatus) IsDirty() bool

IsDirty provides a mock function with given fields:

func (*ExecutableNodeStatus) OnGetAttempts

func (_m *ExecutableNodeStatus) OnGetAttempts() *ExecutableNodeStatus_GetAttempts

func (*ExecutableNodeStatus) OnGetAttemptsMatch

func (_m *ExecutableNodeStatus) OnGetAttemptsMatch(matchers ...interface{}) *ExecutableNodeStatus_GetAttempts

func (*ExecutableNodeStatus) OnGetBranchStatus

func (_m *ExecutableNodeStatus) OnGetBranchStatus() *ExecutableNodeStatus_GetBranchStatus

func (*ExecutableNodeStatus) OnGetBranchStatusMatch

func (_m *ExecutableNodeStatus) OnGetBranchStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetBranchStatus

func (*ExecutableNodeStatus) OnGetDataDir

func (_m *ExecutableNodeStatus) OnGetDataDir() *ExecutableNodeStatus_GetDataDir

func (*ExecutableNodeStatus) OnGetDataDirMatch

func (_m *ExecutableNodeStatus) OnGetDataDirMatch(matchers ...interface{}) *ExecutableNodeStatus_GetDataDir

func (*ExecutableNodeStatus) OnGetDynamicNodeStatus

func (_m *ExecutableNodeStatus) OnGetDynamicNodeStatus() *ExecutableNodeStatus_GetDynamicNodeStatus

func (*ExecutableNodeStatus) OnGetDynamicNodeStatusMatch

func (_m *ExecutableNodeStatus) OnGetDynamicNodeStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetDynamicNodeStatus

func (*ExecutableNodeStatus) OnGetLastAttemptStartedAt

func (_m *ExecutableNodeStatus) OnGetLastAttemptStartedAt() *ExecutableNodeStatus_GetLastAttemptStartedAt

func (*ExecutableNodeStatus) OnGetLastAttemptStartedAtMatch

func (_m *ExecutableNodeStatus) OnGetLastAttemptStartedAtMatch(matchers ...interface{}) *ExecutableNodeStatus_GetLastAttemptStartedAt

func (*ExecutableNodeStatus) OnGetLastUpdatedAt

func (_m *ExecutableNodeStatus) OnGetLastUpdatedAt() *ExecutableNodeStatus_GetLastUpdatedAt

func (*ExecutableNodeStatus) OnGetLastUpdatedAtMatch

func (_m *ExecutableNodeStatus) OnGetLastUpdatedAtMatch(matchers ...interface{}) *ExecutableNodeStatus_GetLastUpdatedAt

func (*ExecutableNodeStatus) OnGetMessage

func (_m *ExecutableNodeStatus) OnGetMessage() *ExecutableNodeStatus_GetMessage

func (*ExecutableNodeStatus) OnGetMessageMatch

func (_m *ExecutableNodeStatus) OnGetMessageMatch(matchers ...interface{}) *ExecutableNodeStatus_GetMessage

func (*ExecutableNodeStatus) OnGetNodeExecutionStatus

func (_m *ExecutableNodeStatus) OnGetNodeExecutionStatus(ctx context.Context, id string) *ExecutableNodeStatus_GetNodeExecutionStatus

func (*ExecutableNodeStatus) OnGetNodeExecutionStatusMatch

func (_m *ExecutableNodeStatus) OnGetNodeExecutionStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetNodeExecutionStatus

func (*ExecutableNodeStatus) OnGetOrCreateBranchStatus

func (_m *ExecutableNodeStatus) OnGetOrCreateBranchStatus() *ExecutableNodeStatus_GetOrCreateBranchStatus

func (*ExecutableNodeStatus) OnGetOrCreateBranchStatusMatch

func (_m *ExecutableNodeStatus) OnGetOrCreateBranchStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetOrCreateBranchStatus

func (*ExecutableNodeStatus) OnGetOrCreateDynamicNodeStatus

func (_m *ExecutableNodeStatus) OnGetOrCreateDynamicNodeStatus() *ExecutableNodeStatus_GetOrCreateDynamicNodeStatus

func (*ExecutableNodeStatus) OnGetOrCreateDynamicNodeStatusMatch

func (_m *ExecutableNodeStatus) OnGetOrCreateDynamicNodeStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetOrCreateDynamicNodeStatus

func (*ExecutableNodeStatus) OnGetOrCreateTaskStatus

func (_m *ExecutableNodeStatus) OnGetOrCreateTaskStatus() *ExecutableNodeStatus_GetOrCreateTaskStatus

func (*ExecutableNodeStatus) OnGetOrCreateTaskStatusMatch

func (_m *ExecutableNodeStatus) OnGetOrCreateTaskStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetOrCreateTaskStatus

func (*ExecutableNodeStatus) OnGetOrCreateWorkflowStatus

func (_m *ExecutableNodeStatus) OnGetOrCreateWorkflowStatus() *ExecutableNodeStatus_GetOrCreateWorkflowStatus

func (*ExecutableNodeStatus) OnGetOrCreateWorkflowStatusMatch

func (_m *ExecutableNodeStatus) OnGetOrCreateWorkflowStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetOrCreateWorkflowStatus

func (*ExecutableNodeStatus) OnGetOutputDir

func (_m *ExecutableNodeStatus) OnGetOutputDir() *ExecutableNodeStatus_GetOutputDir

func (*ExecutableNodeStatus) OnGetOutputDirMatch

func (_m *ExecutableNodeStatus) OnGetOutputDirMatch(matchers ...interface{}) *ExecutableNodeStatus_GetOutputDir

func (*ExecutableNodeStatus) OnGetParentNodeID

func (_m *ExecutableNodeStatus) OnGetParentNodeID() *ExecutableNodeStatus_GetParentNodeID

func (*ExecutableNodeStatus) OnGetParentNodeIDMatch

func (_m *ExecutableNodeStatus) OnGetParentNodeIDMatch(matchers ...interface{}) *ExecutableNodeStatus_GetParentNodeID

func (*ExecutableNodeStatus) OnGetParentTaskID

func (_m *ExecutableNodeStatus) OnGetParentTaskID() *ExecutableNodeStatus_GetParentTaskID

func (*ExecutableNodeStatus) OnGetParentTaskIDMatch

func (_m *ExecutableNodeStatus) OnGetParentTaskIDMatch(matchers ...interface{}) *ExecutableNodeStatus_GetParentTaskID

func (*ExecutableNodeStatus) OnGetPhase

func (_m *ExecutableNodeStatus) OnGetPhase() *ExecutableNodeStatus_GetPhase

func (*ExecutableNodeStatus) OnGetPhaseMatch

func (_m *ExecutableNodeStatus) OnGetPhaseMatch(matchers ...interface{}) *ExecutableNodeStatus_GetPhase

func (*ExecutableNodeStatus) OnGetQueuedAt

func (_m *ExecutableNodeStatus) OnGetQueuedAt() *ExecutableNodeStatus_GetQueuedAt

func (*ExecutableNodeStatus) OnGetQueuedAtMatch

func (_m *ExecutableNodeStatus) OnGetQueuedAtMatch(matchers ...interface{}) *ExecutableNodeStatus_GetQueuedAt

func (*ExecutableNodeStatus) OnGetStartedAt

func (_m *ExecutableNodeStatus) OnGetStartedAt() *ExecutableNodeStatus_GetStartedAt

func (*ExecutableNodeStatus) OnGetStartedAtMatch

func (_m *ExecutableNodeStatus) OnGetStartedAtMatch(matchers ...interface{}) *ExecutableNodeStatus_GetStartedAt

func (*ExecutableNodeStatus) OnGetStoppedAt

func (_m *ExecutableNodeStatus) OnGetStoppedAt() *ExecutableNodeStatus_GetStoppedAt

func (*ExecutableNodeStatus) OnGetStoppedAtMatch

func (_m *ExecutableNodeStatus) OnGetStoppedAtMatch(matchers ...interface{}) *ExecutableNodeStatus_GetStoppedAt

func (*ExecutableNodeStatus) OnGetTaskNodeStatus

func (_m *ExecutableNodeStatus) OnGetTaskNodeStatus() *ExecutableNodeStatus_GetTaskNodeStatus

func (*ExecutableNodeStatus) OnGetTaskNodeStatusMatch

func (_m *ExecutableNodeStatus) OnGetTaskNodeStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetTaskNodeStatus

func (*ExecutableNodeStatus) OnGetTaskStatus

func (_m *ExecutableNodeStatus) OnGetTaskStatus() *ExecutableNodeStatus_GetTaskStatus

func (*ExecutableNodeStatus) OnGetTaskStatusMatch

func (_m *ExecutableNodeStatus) OnGetTaskStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetTaskStatus

func (*ExecutableNodeStatus) OnGetWorkflowNodeStatus

func (_m *ExecutableNodeStatus) OnGetWorkflowNodeStatus() *ExecutableNodeStatus_GetWorkflowNodeStatus

func (*ExecutableNodeStatus) OnGetWorkflowNodeStatusMatch

func (_m *ExecutableNodeStatus) OnGetWorkflowNodeStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetWorkflowNodeStatus

func (*ExecutableNodeStatus) OnGetWorkflowStatus

func (_m *ExecutableNodeStatus) OnGetWorkflowStatus() *ExecutableNodeStatus_GetWorkflowStatus

func (*ExecutableNodeStatus) OnGetWorkflowStatusMatch

func (_m *ExecutableNodeStatus) OnGetWorkflowStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetWorkflowStatus

func (*ExecutableNodeStatus) OnIncrementAttempts

func (_m *ExecutableNodeStatus) OnIncrementAttempts() *ExecutableNodeStatus_IncrementAttempts

func (*ExecutableNodeStatus) OnIncrementAttemptsMatch

func (_m *ExecutableNodeStatus) OnIncrementAttemptsMatch(matchers ...interface{}) *ExecutableNodeStatus_IncrementAttempts

func (*ExecutableNodeStatus) OnIsCached

func (_m *ExecutableNodeStatus) OnIsCached() *ExecutableNodeStatus_IsCached

func (*ExecutableNodeStatus) OnIsCachedMatch

func (_m *ExecutableNodeStatus) OnIsCachedMatch(matchers ...interface{}) *ExecutableNodeStatus_IsCached

func (*ExecutableNodeStatus) OnIsDirty

func (_m *ExecutableNodeStatus) OnIsDirty() *ExecutableNodeStatus_IsDirty

func (*ExecutableNodeStatus) OnIsDirtyMatch

func (_m *ExecutableNodeStatus) OnIsDirtyMatch(matchers ...interface{}) *ExecutableNodeStatus_IsDirty

func (*ExecutableNodeStatus) ResetDirty

func (_m *ExecutableNodeStatus) ResetDirty()

ResetDirty provides a mock function with given fields:

func (*ExecutableNodeStatus) SetCached

func (_m *ExecutableNodeStatus) SetCached()

SetCached provides a mock function with given fields:

func (*ExecutableNodeStatus) SetDataDir

func (_m *ExecutableNodeStatus) SetDataDir(_a0 storage.DataReference)

SetDataDir provides a mock function with given fields: _a0

func (*ExecutableNodeStatus) SetOutputDir

func (_m *ExecutableNodeStatus) SetOutputDir(d storage.DataReference)

SetOutputDir provides a mock function with given fields: d

func (*ExecutableNodeStatus) SetParentNodeID

func (_m *ExecutableNodeStatus) SetParentNodeID(n *string)

SetParentNodeID provides a mock function with given fields: n

func (*ExecutableNodeStatus) SetParentTaskID

func (_m *ExecutableNodeStatus) SetParentTaskID(t *core.TaskExecutionIdentifier)

SetParentTaskID provides a mock function with given fields: t

func (*ExecutableNodeStatus) UpdatePhase

func (_m *ExecutableNodeStatus) UpdatePhase(phase v1alpha1.NodePhase, occurredAt v1.Time, reason string)

UpdatePhase provides a mock function with given fields: phase, occurredAt, reason

func (*ExecutableNodeStatus) VisitNodeStatuses

func (_m *ExecutableNodeStatus) VisitNodeStatuses(visitor func(string, v1alpha1.ExecutableNodeStatus))

VisitNodeStatuses provides a mock function with given fields: visitor

type ExecutableNodeStatus_GetAttempts

type ExecutableNodeStatus_GetAttempts struct {
	*mock.Call
}

func (ExecutableNodeStatus_GetAttempts) Return

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

type ExecutableNodeStatus_GetBranchStatus

type ExecutableNodeStatus_GetBranchStatus struct {
	*mock.Call
}

func (ExecutableNodeStatus_GetBranchStatus) Return

func (_m ExecutableNodeStatus_GetBranchStatus) Return(_a0 v1alpha1.MutableBranchNodeStatus) *ExecutableNodeStatus_GetBranchStatus

type ExecutableNodeStatus_GetDataDir

type ExecutableNodeStatus_GetDataDir struct {
	*mock.Call
}

func (ExecutableNodeStatus_GetDataDir) Return

func (_m ExecutableNodeStatus_GetDataDir) Return(_a0 storage.DataReference) *ExecutableNodeStatus_GetDataDir

type ExecutableNodeStatus_GetDynamicNodeStatus

type ExecutableNodeStatus_GetDynamicNodeStatus struct {
	*mock.Call
}

func (ExecutableNodeStatus_GetDynamicNodeStatus) Return

func (_m ExecutableNodeStatus_GetDynamicNodeStatus) Return(_a0 v1alpha1.MutableDynamicNodeStatus) *ExecutableNodeStatus_GetDynamicNodeStatus

type ExecutableNodeStatus_GetLastAttemptStartedAt

type ExecutableNodeStatus_GetLastAttemptStartedAt struct {
	*mock.Call
}

func (ExecutableNodeStatus_GetLastAttemptStartedAt) Return

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

type ExecutableNodeStatus_GetLastUpdatedAt

type ExecutableNodeStatus_GetLastUpdatedAt struct {
	*mock.Call
}

func (ExecutableNodeStatus_GetLastUpdatedAt) Return

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

type ExecutableNodeStatus_GetMessage

type ExecutableNodeStatus_GetMessage struct {
	*mock.Call
}

func (ExecutableNodeStatus_GetMessage) Return

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

type ExecutableNodeStatus_GetNodeExecutionStatus

type ExecutableNodeStatus_GetNodeExecutionStatus struct {
	*mock.Call
}

func (ExecutableNodeStatus_GetNodeExecutionStatus) Return

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

type ExecutableNodeStatus_GetOrCreateBranchStatus

type ExecutableNodeStatus_GetOrCreateBranchStatus struct {
	*mock.Call
}

func (ExecutableNodeStatus_GetOrCreateBranchStatus) Return

func (_m ExecutableNodeStatus_GetOrCreateBranchStatus) Return(_a0 v1alpha1.MutableBranchNodeStatus) *ExecutableNodeStatus_GetOrCreateBranchStatus

type ExecutableNodeStatus_GetOrCreateDynamicNodeStatus

type ExecutableNodeStatus_GetOrCreateDynamicNodeStatus struct {
	*mock.Call
}

func (ExecutableNodeStatus_GetOrCreateDynamicNodeStatus) Return

func (_m ExecutableNodeStatus_GetOrCreateDynamicNodeStatus) Return(_a0 v1alpha1.MutableDynamicNodeStatus) *ExecutableNodeStatus_GetOrCreateDynamicNodeStatus

type ExecutableNodeStatus_GetOrCreateTaskStatus

type ExecutableNodeStatus_GetOrCreateTaskStatus struct {
	*mock.Call
}

func (ExecutableNodeStatus_GetOrCreateTaskStatus) Return

func (_m ExecutableNodeStatus_GetOrCreateTaskStatus) Return(_a0 v1alpha1.MutableTaskNodeStatus) *ExecutableNodeStatus_GetOrCreateTaskStatus

type ExecutableNodeStatus_GetOrCreateWorkflowStatus

type ExecutableNodeStatus_GetOrCreateWorkflowStatus struct {
	*mock.Call
}

func (ExecutableNodeStatus_GetOrCreateWorkflowStatus) Return

func (_m ExecutableNodeStatus_GetOrCreateWorkflowStatus) Return(_a0 v1alpha1.MutableWorkflowNodeStatus) *ExecutableNodeStatus_GetOrCreateWorkflowStatus

type ExecutableNodeStatus_GetOutputDir

type ExecutableNodeStatus_GetOutputDir struct {
	*mock.Call
}

func (ExecutableNodeStatus_GetOutputDir) Return

func (_m ExecutableNodeStatus_GetOutputDir) Return(_a0 storage.DataReference) *ExecutableNodeStatus_GetOutputDir

type ExecutableNodeStatus_GetParentNodeID

type ExecutableNodeStatus_GetParentNodeID struct {
	*mock.Call
}

func (ExecutableNodeStatus_GetParentNodeID) Return

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

type ExecutableNodeStatus_GetParentTaskID

type ExecutableNodeStatus_GetParentTaskID struct {
	*mock.Call
}

func (ExecutableNodeStatus_GetParentTaskID) Return

func (_m ExecutableNodeStatus_GetParentTaskID) Return(_a0 *core.TaskExecutionIdentifier) *ExecutableNodeStatus_GetParentTaskID

type ExecutableNodeStatus_GetPhase

type ExecutableNodeStatus_GetPhase struct {
	*mock.Call
}

func (ExecutableNodeStatus_GetPhase) Return

func (_m ExecutableNodeStatus_GetPhase) Return(_a0 v1alpha1.NodePhase) *ExecutableNodeStatus_GetPhase

type ExecutableNodeStatus_GetQueuedAt

type ExecutableNodeStatus_GetQueuedAt struct {
	*mock.Call
}

func (ExecutableNodeStatus_GetQueuedAt) Return

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

type ExecutableNodeStatus_GetStartedAt

type ExecutableNodeStatus_GetStartedAt struct {
	*mock.Call
}

func (ExecutableNodeStatus_GetStartedAt) Return

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

type ExecutableNodeStatus_GetStoppedAt

type ExecutableNodeStatus_GetStoppedAt struct {
	*mock.Call
}

func (ExecutableNodeStatus_GetStoppedAt) Return

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

type ExecutableNodeStatus_GetTaskNodeStatus

type ExecutableNodeStatus_GetTaskNodeStatus struct {
	*mock.Call
}

func (ExecutableNodeStatus_GetTaskNodeStatus) Return

func (_m ExecutableNodeStatus_GetTaskNodeStatus) Return(_a0 v1alpha1.ExecutableTaskNodeStatus) *ExecutableNodeStatus_GetTaskNodeStatus

type ExecutableNodeStatus_GetTaskStatus

type ExecutableNodeStatus_GetTaskStatus struct {
	*mock.Call
}

func (ExecutableNodeStatus_GetTaskStatus) Return

func (_m ExecutableNodeStatus_GetTaskStatus) Return(_a0 v1alpha1.MutableTaskNodeStatus) *ExecutableNodeStatus_GetTaskStatus

type ExecutableNodeStatus_GetWorkflowNodeStatus

type ExecutableNodeStatus_GetWorkflowNodeStatus struct {
	*mock.Call
}

func (ExecutableNodeStatus_GetWorkflowNodeStatus) Return

func (_m ExecutableNodeStatus_GetWorkflowNodeStatus) Return(_a0 v1alpha1.ExecutableWorkflowNodeStatus) *ExecutableNodeStatus_GetWorkflowNodeStatus

type ExecutableNodeStatus_GetWorkflowStatus

type ExecutableNodeStatus_GetWorkflowStatus struct {
	*mock.Call
}

func (ExecutableNodeStatus_GetWorkflowStatus) Return

func (_m ExecutableNodeStatus_GetWorkflowStatus) Return(_a0 v1alpha1.MutableWorkflowNodeStatus) *ExecutableNodeStatus_GetWorkflowStatus

type ExecutableNodeStatus_IncrementAttempts

type ExecutableNodeStatus_IncrementAttempts struct {
	*mock.Call
}

func (ExecutableNodeStatus_IncrementAttempts) Return

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

type ExecutableNodeStatus_IsCached

type ExecutableNodeStatus_IsCached struct {
	*mock.Call
}

func (ExecutableNodeStatus_IsCached) Return

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

type ExecutableNodeStatus_IsDirty

type ExecutableNodeStatus_IsDirty struct {
	*mock.Call
}

func (ExecutableNodeStatus_IsDirty) Return

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

type ExecutableNode_GetActiveDeadline

type ExecutableNode_GetActiveDeadline struct {
	*mock.Call
}

func (ExecutableNode_GetActiveDeadline) Return

func (_m ExecutableNode_GetActiveDeadline) Return(_a0 *time.Duration) *ExecutableNode_GetActiveDeadline

type ExecutableNode_GetBranchNode

type ExecutableNode_GetBranchNode struct {
	*mock.Call
}

func (ExecutableNode_GetBranchNode) Return

func (_m ExecutableNode_GetBranchNode) Return(_a0 v1alpha1.ExecutableBranchNode) *ExecutableNode_GetBranchNode

type ExecutableNode_GetConfig

type ExecutableNode_GetConfig struct {
	*mock.Call
}

func (ExecutableNode_GetConfig) Return

func (_m ExecutableNode_GetConfig) Return(_a0 *v1.ConfigMap) *ExecutableNode_GetConfig

type ExecutableNode_GetExecutionDeadline

type ExecutableNode_GetExecutionDeadline struct {
	*mock.Call
}

func (ExecutableNode_GetExecutionDeadline) Return

func (_m ExecutableNode_GetExecutionDeadline) Return(_a0 *time.Duration) *ExecutableNode_GetExecutionDeadline

type ExecutableNode_GetID

type ExecutableNode_GetID struct {
	*mock.Call
}

func (ExecutableNode_GetID) Return

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

type ExecutableNode_GetInputBindings

type ExecutableNode_GetInputBindings struct {
	*mock.Call
}

func (ExecutableNode_GetInputBindings) Return

func (_m ExecutableNode_GetInputBindings) Return(_a0 []*v1alpha1.Binding) *ExecutableNode_GetInputBindings

type ExecutableNode_GetKind

type ExecutableNode_GetKind struct {
	*mock.Call
}

func (ExecutableNode_GetKind) Return

func (_m ExecutableNode_GetKind) Return(_a0 v1alpha1.NodeKind) *ExecutableNode_GetKind

type ExecutableNode_GetOutputAlias

type ExecutableNode_GetOutputAlias struct {
	*mock.Call
}

func (ExecutableNode_GetOutputAlias) Return

func (_m ExecutableNode_GetOutputAlias) Return(_a0 []v1alpha1.Alias) *ExecutableNode_GetOutputAlias

type ExecutableNode_GetResources

type ExecutableNode_GetResources struct {
	*mock.Call
}

func (ExecutableNode_GetResources) Return

func (_m ExecutableNode_GetResources) Return(_a0 *v1.ResourceRequirements) *ExecutableNode_GetResources

type ExecutableNode_GetRetryStrategy

type ExecutableNode_GetRetryStrategy struct {
	*mock.Call
}

func (ExecutableNode_GetRetryStrategy) Return

func (_m ExecutableNode_GetRetryStrategy) Return(_a0 *v1alpha1.RetryStrategy) *ExecutableNode_GetRetryStrategy

type ExecutableNode_GetTaskID

type ExecutableNode_GetTaskID struct {
	*mock.Call
}

func (ExecutableNode_GetTaskID) Return

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

type ExecutableNode_GetWorkflowNode

type ExecutableNode_GetWorkflowNode struct {
	*mock.Call
}

func (ExecutableNode_GetWorkflowNode) Return

func (_m ExecutableNode_GetWorkflowNode) Return(_a0 v1alpha1.ExecutableWorkflowNode) *ExecutableNode_GetWorkflowNode

type ExecutableNode_IsEndNode

type ExecutableNode_IsEndNode struct {
	*mock.Call
}

func (ExecutableNode_IsEndNode) Return

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

type ExecutableNode_IsStartNode

type ExecutableNode_IsStartNode struct {
	*mock.Call
}

func (ExecutableNode_IsStartNode) Return

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

type ExecutableSubWorkflow

type ExecutableSubWorkflow struct {
	mock.Mock
}

ExecutableSubWorkflow is an autogenerated mock type for the ExecutableSubWorkflow type

func (*ExecutableSubWorkflow) FromNode

func (_m *ExecutableSubWorkflow) FromNode(name string) ([]string, error)

FromNode provides a mock function with given fields: name

func (*ExecutableSubWorkflow) GetConnections

func (_m *ExecutableSubWorkflow) GetConnections() *v1alpha1.Connections

GetConnections provides a mock function with given fields:

func (*ExecutableSubWorkflow) GetID

func (_m *ExecutableSubWorkflow) GetID() string

GetID provides a mock function with given fields:

func (*ExecutableSubWorkflow) GetNode

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

GetNode provides a mock function with given fields: nodeID

func (*ExecutableSubWorkflow) GetNodes

func (_m *ExecutableSubWorkflow) GetNodes() []string

GetNodes provides a mock function with given fields:

func (*ExecutableSubWorkflow) GetOnFailureNode

func (_m *ExecutableSubWorkflow) GetOnFailureNode() v1alpha1.ExecutableNode

GetOnFailureNode provides a mock function with given fields:

func (*ExecutableSubWorkflow) GetOutputBindings

func (_m *ExecutableSubWorkflow) GetOutputBindings() []*v1alpha1.Binding

GetOutputBindings provides a mock function with given fields:

func (*ExecutableSubWorkflow) GetOutputs

func (_m *ExecutableSubWorkflow) GetOutputs() *v1alpha1.OutputVarMap

GetOutputs provides a mock function with given fields:

func (*ExecutableSubWorkflow) OnFromNode

func (_m *ExecutableSubWorkflow) OnFromNode(name string) *ExecutableSubWorkflow_FromNode

func (*ExecutableSubWorkflow) OnFromNodeMatch

func (_m *ExecutableSubWorkflow) OnFromNodeMatch(matchers ...interface{}) *ExecutableSubWorkflow_FromNode

func (*ExecutableSubWorkflow) OnGetConnections

func (_m *ExecutableSubWorkflow) OnGetConnections() *ExecutableSubWorkflow_GetConnections

func (*ExecutableSubWorkflow) OnGetConnectionsMatch

func (_m *ExecutableSubWorkflow) OnGetConnectionsMatch(matchers ...interface{}) *ExecutableSubWorkflow_GetConnections

func (*ExecutableSubWorkflow) OnGetID

func (_m *ExecutableSubWorkflow) OnGetID() *ExecutableSubWorkflow_GetID

func (*ExecutableSubWorkflow) OnGetIDMatch

func (_m *ExecutableSubWorkflow) OnGetIDMatch(matchers ...interface{}) *ExecutableSubWorkflow_GetID

func (*ExecutableSubWorkflow) OnGetNode

func (_m *ExecutableSubWorkflow) OnGetNode(nodeID string) *ExecutableSubWorkflow_GetNode

func (*ExecutableSubWorkflow) OnGetNodeMatch

func (_m *ExecutableSubWorkflow) OnGetNodeMatch(matchers ...interface{}) *ExecutableSubWorkflow_GetNode

func (*ExecutableSubWorkflow) OnGetNodes

func (_m *ExecutableSubWorkflow) OnGetNodes() *ExecutableSubWorkflow_GetNodes

func (*ExecutableSubWorkflow) OnGetNodesMatch

func (_m *ExecutableSubWorkflow) OnGetNodesMatch(matchers ...interface{}) *ExecutableSubWorkflow_GetNodes

func (*ExecutableSubWorkflow) OnGetOnFailureNode

func (_m *ExecutableSubWorkflow) OnGetOnFailureNode() *ExecutableSubWorkflow_GetOnFailureNode

func (*ExecutableSubWorkflow) OnGetOnFailureNodeMatch

func (_m *ExecutableSubWorkflow) OnGetOnFailureNodeMatch(matchers ...interface{}) *ExecutableSubWorkflow_GetOnFailureNode

func (*ExecutableSubWorkflow) OnGetOutputBindings

func (_m *ExecutableSubWorkflow) OnGetOutputBindings() *ExecutableSubWorkflow_GetOutputBindings

func (*ExecutableSubWorkflow) OnGetOutputBindingsMatch

func (_m *ExecutableSubWorkflow) OnGetOutputBindingsMatch(matchers ...interface{}) *ExecutableSubWorkflow_GetOutputBindings

func (*ExecutableSubWorkflow) OnGetOutputs

func (_m *ExecutableSubWorkflow) OnGetOutputs() *ExecutableSubWorkflow_GetOutputs

func (*ExecutableSubWorkflow) OnGetOutputsMatch

func (_m *ExecutableSubWorkflow) OnGetOutputsMatch(matchers ...interface{}) *ExecutableSubWorkflow_GetOutputs

func (*ExecutableSubWorkflow) OnStartNode

func (_m *ExecutableSubWorkflow) OnStartNode() *ExecutableSubWorkflow_StartNode

func (*ExecutableSubWorkflow) OnStartNodeMatch

func (_m *ExecutableSubWorkflow) OnStartNodeMatch(matchers ...interface{}) *ExecutableSubWorkflow_StartNode

func (*ExecutableSubWorkflow) StartNode

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

StartNode provides a mock function with given fields:

type ExecutableSubWorkflowNodeStatus

type ExecutableSubWorkflowNodeStatus struct {
	mock.Mock
}

ExecutableSubWorkflowNodeStatus is an autogenerated mock type for the ExecutableSubWorkflowNodeStatus type

func (*ExecutableSubWorkflowNodeStatus) GetPhase

func (_m *ExecutableSubWorkflowNodeStatus) GetPhase() v1alpha1.WorkflowPhase

GetPhase provides a mock function with given fields:

func (*ExecutableSubWorkflowNodeStatus) OnGetPhase

func (_m *ExecutableSubWorkflowNodeStatus) OnGetPhase() *ExecutableSubWorkflowNodeStatus_GetPhase

func (*ExecutableSubWorkflowNodeStatus) OnGetPhaseMatch

func (_m *ExecutableSubWorkflowNodeStatus) OnGetPhaseMatch(matchers ...interface{}) *ExecutableSubWorkflowNodeStatus_GetPhase

type ExecutableSubWorkflowNodeStatus_GetPhase

type ExecutableSubWorkflowNodeStatus_GetPhase struct {
	*mock.Call
}

func (ExecutableSubWorkflowNodeStatus_GetPhase) Return

func (_m ExecutableSubWorkflowNodeStatus_GetPhase) Return(_a0 v1alpha1.WorkflowPhase) *ExecutableSubWorkflowNodeStatus_GetPhase

type ExecutableSubWorkflow_FromNode

type ExecutableSubWorkflow_FromNode struct {
	*mock.Call
}

func (ExecutableSubWorkflow_FromNode) Return

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

type ExecutableSubWorkflow_GetConnections

type ExecutableSubWorkflow_GetConnections struct {
	*mock.Call
}

func (ExecutableSubWorkflow_GetConnections) Return

func (_m ExecutableSubWorkflow_GetConnections) Return(_a0 *v1alpha1.Connections) *ExecutableSubWorkflow_GetConnections

type ExecutableSubWorkflow_GetID

type ExecutableSubWorkflow_GetID struct {
	*mock.Call
}

func (ExecutableSubWorkflow_GetID) Return

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

type ExecutableSubWorkflow_GetNode

type ExecutableSubWorkflow_GetNode struct {
	*mock.Call
}

func (ExecutableSubWorkflow_GetNode) Return

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

type ExecutableSubWorkflow_GetNodes

type ExecutableSubWorkflow_GetNodes struct {
	*mock.Call
}

func (ExecutableSubWorkflow_GetNodes) Return

func (_m ExecutableSubWorkflow_GetNodes) Return(_a0 []string) *ExecutableSubWorkflow_GetNodes

type ExecutableSubWorkflow_GetOnFailureNode

type ExecutableSubWorkflow_GetOnFailureNode struct {
	*mock.Call
}

func (ExecutableSubWorkflow_GetOnFailureNode) Return

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

type ExecutableSubWorkflow_GetOutputBindings

type ExecutableSubWorkflow_GetOutputBindings struct {
	*mock.Call
}

func (ExecutableSubWorkflow_GetOutputBindings) Return

func (_m ExecutableSubWorkflow_GetOutputBindings) Return(_a0 []*v1alpha1.Binding) *ExecutableSubWorkflow_GetOutputBindings

type ExecutableSubWorkflow_GetOutputs

type ExecutableSubWorkflow_GetOutputs struct {
	*mock.Call
}

func (ExecutableSubWorkflow_GetOutputs) Return

func (_m ExecutableSubWorkflow_GetOutputs) Return(_a0 *v1alpha1.OutputVarMap) *ExecutableSubWorkflow_GetOutputs

type ExecutableSubWorkflow_StartNode

type ExecutableSubWorkflow_StartNode struct {
	*mock.Call
}

func (ExecutableSubWorkflow_StartNode) Return

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

type ExecutableTask

type ExecutableTask struct {
	mock.Mock
}

ExecutableTask is an autogenerated mock type for the ExecutableTask type

func (*ExecutableTask) CoreTask

func (_m *ExecutableTask) CoreTask() *core.TaskTemplate

CoreTask provides a mock function with given fields:

func (*ExecutableTask) OnCoreTask

func (_m *ExecutableTask) OnCoreTask() *ExecutableTask_CoreTask

func (*ExecutableTask) OnCoreTaskMatch

func (_m *ExecutableTask) OnCoreTaskMatch(matchers ...interface{}) *ExecutableTask_CoreTask

func (*ExecutableTask) OnTaskType

func (_m *ExecutableTask) OnTaskType() *ExecutableTask_TaskType

func (*ExecutableTask) OnTaskTypeMatch

func (_m *ExecutableTask) OnTaskTypeMatch(matchers ...interface{}) *ExecutableTask_TaskType

func (*ExecutableTask) TaskType

func (_m *ExecutableTask) TaskType() string

TaskType provides a mock function with given fields:

type ExecutableTaskNodeStatus

type ExecutableTaskNodeStatus struct {
	mock.Mock
}

ExecutableTaskNodeStatus is an autogenerated mock type for the ExecutableTaskNodeStatus type

func (*ExecutableTaskNodeStatus) GetBarrierClockTick

func (_m *ExecutableTaskNodeStatus) GetBarrierClockTick() uint32

GetBarrierClockTick provides a mock function with given fields:

func (*ExecutableTaskNodeStatus) GetLastPhaseUpdatedAt

func (_m *ExecutableTaskNodeStatus) GetLastPhaseUpdatedAt() time.Time

GetLastPhaseUpdatedAt provides a mock function with given fields:

func (*ExecutableTaskNodeStatus) GetPhase

func (_m *ExecutableTaskNodeStatus) GetPhase() int

GetPhase provides a mock function with given fields:

func (*ExecutableTaskNodeStatus) GetPhaseVersion

func (_m *ExecutableTaskNodeStatus) GetPhaseVersion() uint32

GetPhaseVersion provides a mock function with given fields:

func (*ExecutableTaskNodeStatus) GetPluginState

func (_m *ExecutableTaskNodeStatus) GetPluginState() []byte

GetPluginState provides a mock function with given fields:

func (*ExecutableTaskNodeStatus) GetPluginStateVersion

func (_m *ExecutableTaskNodeStatus) GetPluginStateVersion() uint32

GetPluginStateVersion provides a mock function with given fields:

func (*ExecutableTaskNodeStatus) OnGetBarrierClockTick

func (_m *ExecutableTaskNodeStatus) OnGetBarrierClockTick() *ExecutableTaskNodeStatus_GetBarrierClockTick

func (*ExecutableTaskNodeStatus) OnGetBarrierClockTickMatch

func (_m *ExecutableTaskNodeStatus) OnGetBarrierClockTickMatch(matchers ...interface{}) *ExecutableTaskNodeStatus_GetBarrierClockTick

func (*ExecutableTaskNodeStatus) OnGetLastPhaseUpdatedAt

func (_m *ExecutableTaskNodeStatus) OnGetLastPhaseUpdatedAt() *ExecutableTaskNodeStatus_GetLastPhaseUpdatedAt

func (*ExecutableTaskNodeStatus) OnGetLastPhaseUpdatedAtMatch

func (_m *ExecutableTaskNodeStatus) OnGetLastPhaseUpdatedAtMatch(matchers ...interface{}) *ExecutableTaskNodeStatus_GetLastPhaseUpdatedAt

func (*ExecutableTaskNodeStatus) OnGetPhase

func (_m *ExecutableTaskNodeStatus) OnGetPhase() *ExecutableTaskNodeStatus_GetPhase

func (*ExecutableTaskNodeStatus) OnGetPhaseMatch

func (_m *ExecutableTaskNodeStatus) OnGetPhaseMatch(matchers ...interface{}) *ExecutableTaskNodeStatus_GetPhase

func (*ExecutableTaskNodeStatus) OnGetPhaseVersion

func (_m *ExecutableTaskNodeStatus) OnGetPhaseVersion() *ExecutableTaskNodeStatus_GetPhaseVersion

func (*ExecutableTaskNodeStatus) OnGetPhaseVersionMatch

func (_m *ExecutableTaskNodeStatus) OnGetPhaseVersionMatch(matchers ...interface{}) *ExecutableTaskNodeStatus_GetPhaseVersion

func (*ExecutableTaskNodeStatus) OnGetPluginState

func (_m *ExecutableTaskNodeStatus) OnGetPluginState() *ExecutableTaskNodeStatus_GetPluginState

func (*ExecutableTaskNodeStatus) OnGetPluginStateMatch

func (_m *ExecutableTaskNodeStatus) OnGetPluginStateMatch(matchers ...interface{}) *ExecutableTaskNodeStatus_GetPluginState

func (*ExecutableTaskNodeStatus) OnGetPluginStateVersion

func (_m *ExecutableTaskNodeStatus) OnGetPluginStateVersion() *ExecutableTaskNodeStatus_GetPluginStateVersion

func (*ExecutableTaskNodeStatus) OnGetPluginStateVersionMatch

func (_m *ExecutableTaskNodeStatus) OnGetPluginStateVersionMatch(matchers ...interface{}) *ExecutableTaskNodeStatus_GetPluginStateVersion

type ExecutableTaskNodeStatus_GetBarrierClockTick

type ExecutableTaskNodeStatus_GetBarrierClockTick struct {
	*mock.Call
}

func (ExecutableTaskNodeStatus_GetBarrierClockTick) Return

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

type ExecutableTaskNodeStatus_GetLastPhaseUpdatedAt

type ExecutableTaskNodeStatus_GetLastPhaseUpdatedAt struct {
	*mock.Call
}

func (ExecutableTaskNodeStatus_GetLastPhaseUpdatedAt) Return

func (_m ExecutableTaskNodeStatus_GetLastPhaseUpdatedAt) Return(_a0 time.Time) *ExecutableTaskNodeStatus_GetLastPhaseUpdatedAt

type ExecutableTaskNodeStatus_GetPhase

type ExecutableTaskNodeStatus_GetPhase struct {
	*mock.Call
}

func (ExecutableTaskNodeStatus_GetPhase) Return

func (_m ExecutableTaskNodeStatus_GetPhase) Return(_a0 int) *ExecutableTaskNodeStatus_GetPhase

type ExecutableTaskNodeStatus_GetPhaseVersion

type ExecutableTaskNodeStatus_GetPhaseVersion struct {
	*mock.Call
}

func (ExecutableTaskNodeStatus_GetPhaseVersion) Return

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

type ExecutableTaskNodeStatus_GetPluginState

type ExecutableTaskNodeStatus_GetPluginState struct {
	*mock.Call
}

func (ExecutableTaskNodeStatus_GetPluginState) Return

func (_m ExecutableTaskNodeStatus_GetPluginState) Return(_a0 []byte) *ExecutableTaskNodeStatus_GetPluginState

type ExecutableTaskNodeStatus_GetPluginStateVersion

type ExecutableTaskNodeStatus_GetPluginStateVersion struct {
	*mock.Call
}

func (ExecutableTaskNodeStatus_GetPluginStateVersion) Return

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

type ExecutableTask_CoreTask

type ExecutableTask_CoreTask struct {
	*mock.Call
}

func (ExecutableTask_CoreTask) Return

func (_m ExecutableTask_CoreTask) Return(_a0 *core.TaskTemplate) *ExecutableTask_CoreTask

type ExecutableTask_TaskType

type ExecutableTask_TaskType struct {
	*mock.Call
}

func (ExecutableTask_TaskType) Return

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

type ExecutableWorkflow

type ExecutableWorkflow struct {
	mock.Mock
}

ExecutableWorkflow is an autogenerated mock type for the ExecutableWorkflow type

func (*ExecutableWorkflow) FindSubWorkflow

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

FindSubWorkflow provides a mock function with given fields: subID

func (*ExecutableWorkflow) FromNode

func (_m *ExecutableWorkflow) FromNode(name string) ([]string, error)

FromNode provides a mock function with given fields: name

func (*ExecutableWorkflow) GetAnnotations

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

GetAnnotations provides a mock function with given fields:

func (*ExecutableWorkflow) GetConnections

func (_m *ExecutableWorkflow) GetConnections() *v1alpha1.Connections

GetConnections provides a mock function with given fields:

func (*ExecutableWorkflow) GetCreationTimestamp

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

GetCreationTimestamp provides a mock function with given fields:

func (*ExecutableWorkflow) GetExecutionID

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

GetExecutionID provides a mock function with given fields:

func (*ExecutableWorkflow) GetExecutionStatus

func (_m *ExecutableWorkflow) GetExecutionStatus() v1alpha1.ExecutableWorkflowStatus

GetExecutionStatus provides a mock function with given fields:

func (*ExecutableWorkflow) GetID

func (_m *ExecutableWorkflow) GetID() string

GetID provides a mock function with given fields:

func (*ExecutableWorkflow) GetK8sWorkflowID

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

GetK8sWorkflowID provides a mock function with given fields:

func (*ExecutableWorkflow) GetLabels

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

GetLabels provides a mock function with given fields:

func (*ExecutableWorkflow) GetName

func (_m *ExecutableWorkflow) GetName() string

GetName provides a mock function with given fields:

func (*ExecutableWorkflow) GetNamespace

func (_m *ExecutableWorkflow) GetNamespace() string

GetNamespace provides a mock function with given fields:

func (*ExecutableWorkflow) GetNode

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

GetNode provides a mock function with given fields: nodeID

func (*ExecutableWorkflow) GetNodeExecutionStatus

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

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

func (*ExecutableWorkflow) GetNodes

func (_m *ExecutableWorkflow) GetNodes() []string

GetNodes provides a mock function with given fields:

func (*ExecutableWorkflow) GetOnFailureNode

func (_m *ExecutableWorkflow) GetOnFailureNode() v1alpha1.ExecutableNode

GetOnFailureNode provides a mock function with given fields:

func (*ExecutableWorkflow) GetOutputBindings

func (_m *ExecutableWorkflow) GetOutputBindings() []*v1alpha1.Binding

GetOutputBindings provides a mock function with given fields:

func (*ExecutableWorkflow) GetOutputs

func (_m *ExecutableWorkflow) GetOutputs() *v1alpha1.OutputVarMap

GetOutputs provides a mock function with given fields:

func (*ExecutableWorkflow) GetOwnerReference

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

GetOwnerReference provides a mock function with given fields:

func (*ExecutableWorkflow) GetServiceAccountName

func (_m *ExecutableWorkflow) GetServiceAccountName() string

GetServiceAccountName provides a mock function with given fields:

func (*ExecutableWorkflow) GetTask

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

GetTask provides a mock function with given fields: id

func (*ExecutableWorkflow) OnFindSubWorkflow

func (_m *ExecutableWorkflow) OnFindSubWorkflow(subID string) *ExecutableWorkflow_FindSubWorkflow

func (*ExecutableWorkflow) OnFindSubWorkflowMatch

func (_m *ExecutableWorkflow) OnFindSubWorkflowMatch(matchers ...interface{}) *ExecutableWorkflow_FindSubWorkflow

func (*ExecutableWorkflow) OnFromNode

func (_m *ExecutableWorkflow) OnFromNode(name string) *ExecutableWorkflow_FromNode

func (*ExecutableWorkflow) OnFromNodeMatch

func (_m *ExecutableWorkflow) OnFromNodeMatch(matchers ...interface{}) *ExecutableWorkflow_FromNode

func (*ExecutableWorkflow) OnGetAnnotations

func (_m *ExecutableWorkflow) OnGetAnnotations() *ExecutableWorkflow_GetAnnotations

func (*ExecutableWorkflow) OnGetAnnotationsMatch

func (_m *ExecutableWorkflow) OnGetAnnotationsMatch(matchers ...interface{}) *ExecutableWorkflow_GetAnnotations

func (*ExecutableWorkflow) OnGetConnections

func (_m *ExecutableWorkflow) OnGetConnections() *ExecutableWorkflow_GetConnections

func (*ExecutableWorkflow) OnGetConnectionsMatch

func (_m *ExecutableWorkflow) OnGetConnectionsMatch(matchers ...interface{}) *ExecutableWorkflow_GetConnections

func (*ExecutableWorkflow) OnGetCreationTimestamp

func (_m *ExecutableWorkflow) OnGetCreationTimestamp() *ExecutableWorkflow_GetCreationTimestamp

func (*ExecutableWorkflow) OnGetCreationTimestampMatch

func (_m *ExecutableWorkflow) OnGetCreationTimestampMatch(matchers ...interface{}) *ExecutableWorkflow_GetCreationTimestamp

func (*ExecutableWorkflow) OnGetExecutionID

func (_m *ExecutableWorkflow) OnGetExecutionID() *ExecutableWorkflow_GetExecutionID

func (*ExecutableWorkflow) OnGetExecutionIDMatch

func (_m *ExecutableWorkflow) OnGetExecutionIDMatch(matchers ...interface{}) *ExecutableWorkflow_GetExecutionID

func (*ExecutableWorkflow) OnGetExecutionStatus

func (_m *ExecutableWorkflow) OnGetExecutionStatus() *ExecutableWorkflow_GetExecutionStatus

func (*ExecutableWorkflow) OnGetExecutionStatusMatch

func (_m *ExecutableWorkflow) OnGetExecutionStatusMatch(matchers ...interface{}) *ExecutableWorkflow_GetExecutionStatus

func (*ExecutableWorkflow) OnGetID

func (_m *ExecutableWorkflow) OnGetID() *ExecutableWorkflow_GetID

func (*ExecutableWorkflow) OnGetIDMatch

func (_m *ExecutableWorkflow) OnGetIDMatch(matchers ...interface{}) *ExecutableWorkflow_GetID

func (*ExecutableWorkflow) OnGetK8sWorkflowID

func (_m *ExecutableWorkflow) OnGetK8sWorkflowID() *ExecutableWorkflow_GetK8sWorkflowID

func (*ExecutableWorkflow) OnGetK8sWorkflowIDMatch

func (_m *ExecutableWorkflow) OnGetK8sWorkflowIDMatch(matchers ...interface{}) *ExecutableWorkflow_GetK8sWorkflowID

func (*ExecutableWorkflow) OnGetLabels

func (_m *ExecutableWorkflow) OnGetLabels() *ExecutableWorkflow_GetLabels

func (*ExecutableWorkflow) OnGetLabelsMatch

func (_m *ExecutableWorkflow) OnGetLabelsMatch(matchers ...interface{}) *ExecutableWorkflow_GetLabels

func (*ExecutableWorkflow) OnGetName

func (_m *ExecutableWorkflow) OnGetName() *ExecutableWorkflow_GetName

func (*ExecutableWorkflow) OnGetNameMatch

func (_m *ExecutableWorkflow) OnGetNameMatch(matchers ...interface{}) *ExecutableWorkflow_GetName

func (*ExecutableWorkflow) OnGetNamespace

func (_m *ExecutableWorkflow) OnGetNamespace() *ExecutableWorkflow_GetNamespace

func (*ExecutableWorkflow) OnGetNamespaceMatch

func (_m *ExecutableWorkflow) OnGetNamespaceMatch(matchers ...interface{}) *ExecutableWorkflow_GetNamespace

func (*ExecutableWorkflow) OnGetNode

func (_m *ExecutableWorkflow) OnGetNode(nodeID string) *ExecutableWorkflow_GetNode

func (*ExecutableWorkflow) OnGetNodeExecutionStatus

func (_m *ExecutableWorkflow) OnGetNodeExecutionStatus(ctx context.Context, id string) *ExecutableWorkflow_GetNodeExecutionStatus

func (*ExecutableWorkflow) OnGetNodeExecutionStatusMatch

func (_m *ExecutableWorkflow) OnGetNodeExecutionStatusMatch(matchers ...interface{}) *ExecutableWorkflow_GetNodeExecutionStatus

func (*ExecutableWorkflow) OnGetNodeMatch

func (_m *ExecutableWorkflow) OnGetNodeMatch(matchers ...interface{}) *ExecutableWorkflow_GetNode

func (*ExecutableWorkflow) OnGetNodes

func (_m *ExecutableWorkflow) OnGetNodes() *ExecutableWorkflow_GetNodes

func (*ExecutableWorkflow) OnGetNodesMatch

func (_m *ExecutableWorkflow) OnGetNodesMatch(matchers ...interface{}) *ExecutableWorkflow_GetNodes

func (*ExecutableWorkflow) OnGetOnFailureNode

func (_m *ExecutableWorkflow) OnGetOnFailureNode() *ExecutableWorkflow_GetOnFailureNode

func (*ExecutableWorkflow) OnGetOnFailureNodeMatch

func (_m *ExecutableWorkflow) OnGetOnFailureNodeMatch(matchers ...interface{}) *ExecutableWorkflow_GetOnFailureNode

func (*ExecutableWorkflow) OnGetOutputBindings

func (_m *ExecutableWorkflow) OnGetOutputBindings() *ExecutableWorkflow_GetOutputBindings

func (*ExecutableWorkflow) OnGetOutputBindingsMatch

func (_m *ExecutableWorkflow) OnGetOutputBindingsMatch(matchers ...interface{}) *ExecutableWorkflow_GetOutputBindings

func (*ExecutableWorkflow) OnGetOutputs

func (_m *ExecutableWorkflow) OnGetOutputs() *ExecutableWorkflow_GetOutputs

func (*ExecutableWorkflow) OnGetOutputsMatch

func (_m *ExecutableWorkflow) OnGetOutputsMatch(matchers ...interface{}) *ExecutableWorkflow_GetOutputs

func (*ExecutableWorkflow) OnGetOwnerReference

func (_m *ExecutableWorkflow) OnGetOwnerReference() *ExecutableWorkflow_GetOwnerReference

func (*ExecutableWorkflow) OnGetOwnerReferenceMatch

func (_m *ExecutableWorkflow) OnGetOwnerReferenceMatch(matchers ...interface{}) *ExecutableWorkflow_GetOwnerReference

func (*ExecutableWorkflow) OnGetServiceAccountName

func (_m *ExecutableWorkflow) OnGetServiceAccountName() *ExecutableWorkflow_GetServiceAccountName

func (*ExecutableWorkflow) OnGetServiceAccountNameMatch

func (_m *ExecutableWorkflow) OnGetServiceAccountNameMatch(matchers ...interface{}) *ExecutableWorkflow_GetServiceAccountName

func (*ExecutableWorkflow) OnGetTask

func (_m *ExecutableWorkflow) OnGetTask(id string) *ExecutableWorkflow_GetTask

func (*ExecutableWorkflow) OnGetTaskMatch

func (_m *ExecutableWorkflow) OnGetTaskMatch(matchers ...interface{}) *ExecutableWorkflow_GetTask

func (*ExecutableWorkflow) OnStartNode

func (_m *ExecutableWorkflow) OnStartNode() *ExecutableWorkflow_StartNode

func (*ExecutableWorkflow) OnStartNodeMatch

func (_m *ExecutableWorkflow) OnStartNodeMatch(matchers ...interface{}) *ExecutableWorkflow_StartNode

func (*ExecutableWorkflow) StartNode

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

StartNode provides a mock function with given fields:

type ExecutableWorkflowNode

type ExecutableWorkflowNode struct {
	mock.Mock
}

ExecutableWorkflowNode is an autogenerated mock type for the ExecutableWorkflowNode type

func (*ExecutableWorkflowNode) GetLaunchPlanRefID

func (_m *ExecutableWorkflowNode) GetLaunchPlanRefID() *v1alpha1.Identifier

GetLaunchPlanRefID provides a mock function with given fields:

func (*ExecutableWorkflowNode) GetSubWorkflowRef

func (_m *ExecutableWorkflowNode) GetSubWorkflowRef() *string

GetSubWorkflowRef provides a mock function with given fields:

func (*ExecutableWorkflowNode) OnGetLaunchPlanRefID

func (_m *ExecutableWorkflowNode) OnGetLaunchPlanRefID() *ExecutableWorkflowNode_GetLaunchPlanRefID

func (*ExecutableWorkflowNode) OnGetLaunchPlanRefIDMatch

func (_m *ExecutableWorkflowNode) OnGetLaunchPlanRefIDMatch(matchers ...interface{}) *ExecutableWorkflowNode_GetLaunchPlanRefID

func (*ExecutableWorkflowNode) OnGetSubWorkflowRef

func (_m *ExecutableWorkflowNode) OnGetSubWorkflowRef() *ExecutableWorkflowNode_GetSubWorkflowRef

func (*ExecutableWorkflowNode) OnGetSubWorkflowRefMatch

func (_m *ExecutableWorkflowNode) OnGetSubWorkflowRefMatch(matchers ...interface{}) *ExecutableWorkflowNode_GetSubWorkflowRef

type ExecutableWorkflowNodeStatus

type ExecutableWorkflowNodeStatus struct {
	mock.Mock
}

ExecutableWorkflowNodeStatus is an autogenerated mock type for the ExecutableWorkflowNodeStatus type

func (*ExecutableWorkflowNodeStatus) GetWorkflowNodePhase

func (_m *ExecutableWorkflowNodeStatus) GetWorkflowNodePhase() v1alpha1.WorkflowNodePhase

GetWorkflowNodePhase provides a mock function with given fields:

func (*ExecutableWorkflowNodeStatus) OnGetWorkflowNodePhase

func (_m *ExecutableWorkflowNodeStatus) OnGetWorkflowNodePhase() *ExecutableWorkflowNodeStatus_GetWorkflowNodePhase

func (*ExecutableWorkflowNodeStatus) OnGetWorkflowNodePhaseMatch

func (_m *ExecutableWorkflowNodeStatus) OnGetWorkflowNodePhaseMatch(matchers ...interface{}) *ExecutableWorkflowNodeStatus_GetWorkflowNodePhase

type ExecutableWorkflowNodeStatus_GetWorkflowNodePhase

type ExecutableWorkflowNodeStatus_GetWorkflowNodePhase struct {
	*mock.Call
}

func (ExecutableWorkflowNodeStatus_GetWorkflowNodePhase) Return

func (_m ExecutableWorkflowNodeStatus_GetWorkflowNodePhase) Return(_a0 v1alpha1.WorkflowNodePhase) *ExecutableWorkflowNodeStatus_GetWorkflowNodePhase

type ExecutableWorkflowNode_GetLaunchPlanRefID

type ExecutableWorkflowNode_GetLaunchPlanRefID struct {
	*mock.Call
}

func (ExecutableWorkflowNode_GetLaunchPlanRefID) Return

func (_m ExecutableWorkflowNode_GetLaunchPlanRefID) Return(_a0 *v1alpha1.Identifier) *ExecutableWorkflowNode_GetLaunchPlanRefID

type ExecutableWorkflowNode_GetSubWorkflowRef

type ExecutableWorkflowNode_GetSubWorkflowRef struct {
	*mock.Call
}

func (ExecutableWorkflowNode_GetSubWorkflowRef) Return

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

type ExecutableWorkflowStatus

type ExecutableWorkflowStatus struct {
	mock.Mock
}

ExecutableWorkflowStatus is an autogenerated mock type for the ExecutableWorkflowStatus type

func (*ExecutableWorkflowStatus) ConstructNodeDataDir

func (_m *ExecutableWorkflowStatus) ConstructNodeDataDir(ctx context.Context, name string) (storage.DataReference, error)

ConstructNodeDataDir provides a mock function with given fields: ctx, name

func (*ExecutableWorkflowStatus) GetDataDir

func (_m *ExecutableWorkflowStatus) GetDataDir() storage.DataReference

GetDataDir provides a mock function with given fields:

func (*ExecutableWorkflowStatus) GetLastUpdatedAt

func (_m *ExecutableWorkflowStatus) GetLastUpdatedAt() *v1.Time

GetLastUpdatedAt provides a mock function with given fields:

func (*ExecutableWorkflowStatus) GetMessage

func (_m *ExecutableWorkflowStatus) GetMessage() string

GetMessage provides a mock function with given fields:

func (*ExecutableWorkflowStatus) GetNodeExecutionStatus

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

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

func (*ExecutableWorkflowStatus) GetOutputReference

func (_m *ExecutableWorkflowStatus) GetOutputReference() storage.DataReference

GetOutputReference provides a mock function with given fields:

func (*ExecutableWorkflowStatus) GetPhase

func (_m *ExecutableWorkflowStatus) GetPhase() v1alpha1.WorkflowPhase

GetPhase provides a mock function with given fields:

func (*ExecutableWorkflowStatus) GetStartedAt

func (_m *ExecutableWorkflowStatus) GetStartedAt() *v1.Time

GetStartedAt provides a mock function with given fields:

func (*ExecutableWorkflowStatus) GetStoppedAt

func (_m *ExecutableWorkflowStatus) GetStoppedAt() *v1.Time

GetStoppedAt provides a mock function with given fields:

func (*ExecutableWorkflowStatus) IncFailedAttempts

func (_m *ExecutableWorkflowStatus) IncFailedAttempts()

IncFailedAttempts provides a mock function with given fields:

func (*ExecutableWorkflowStatus) IsTerminated

func (_m *ExecutableWorkflowStatus) IsTerminated() bool

IsTerminated provides a mock function with given fields:

func (*ExecutableWorkflowStatus) OnConstructNodeDataDir

func (_m *ExecutableWorkflowStatus) OnConstructNodeDataDir(ctx context.Context, name string) *ExecutableWorkflowStatus_ConstructNodeDataDir

func (*ExecutableWorkflowStatus) OnConstructNodeDataDirMatch

func (_m *ExecutableWorkflowStatus) OnConstructNodeDataDirMatch(matchers ...interface{}) *ExecutableWorkflowStatus_ConstructNodeDataDir

func (*ExecutableWorkflowStatus) OnGetDataDir

func (_m *ExecutableWorkflowStatus) OnGetDataDir() *ExecutableWorkflowStatus_GetDataDir

func (*ExecutableWorkflowStatus) OnGetDataDirMatch

func (_m *ExecutableWorkflowStatus) OnGetDataDirMatch(matchers ...interface{}) *ExecutableWorkflowStatus_GetDataDir

func (*ExecutableWorkflowStatus) OnGetLastUpdatedAt

func (_m *ExecutableWorkflowStatus) OnGetLastUpdatedAt() *ExecutableWorkflowStatus_GetLastUpdatedAt

func (*ExecutableWorkflowStatus) OnGetLastUpdatedAtMatch

func (_m *ExecutableWorkflowStatus) OnGetLastUpdatedAtMatch(matchers ...interface{}) *ExecutableWorkflowStatus_GetLastUpdatedAt

func (*ExecutableWorkflowStatus) OnGetMessage

func (_m *ExecutableWorkflowStatus) OnGetMessage() *ExecutableWorkflowStatus_GetMessage

func (*ExecutableWorkflowStatus) OnGetMessageMatch

func (_m *ExecutableWorkflowStatus) OnGetMessageMatch(matchers ...interface{}) *ExecutableWorkflowStatus_GetMessage

func (*ExecutableWorkflowStatus) OnGetNodeExecutionStatus

func (_m *ExecutableWorkflowStatus) OnGetNodeExecutionStatus(ctx context.Context, id string) *ExecutableWorkflowStatus_GetNodeExecutionStatus

func (*ExecutableWorkflowStatus) OnGetNodeExecutionStatusMatch

func (_m *ExecutableWorkflowStatus) OnGetNodeExecutionStatusMatch(matchers ...interface{}) *ExecutableWorkflowStatus_GetNodeExecutionStatus

func (*ExecutableWorkflowStatus) OnGetOutputReference

func (_m *ExecutableWorkflowStatus) OnGetOutputReference() *ExecutableWorkflowStatus_GetOutputReference

func (*ExecutableWorkflowStatus) OnGetOutputReferenceMatch

func (_m *ExecutableWorkflowStatus) OnGetOutputReferenceMatch(matchers ...interface{}) *ExecutableWorkflowStatus_GetOutputReference

func (*ExecutableWorkflowStatus) OnGetPhase

func (_m *ExecutableWorkflowStatus) OnGetPhase() *ExecutableWorkflowStatus_GetPhase

func (*ExecutableWorkflowStatus) OnGetPhaseMatch

func (_m *ExecutableWorkflowStatus) OnGetPhaseMatch(matchers ...interface{}) *ExecutableWorkflowStatus_GetPhase

func (*ExecutableWorkflowStatus) OnGetStartedAt

func (_m *ExecutableWorkflowStatus) OnGetStartedAt() *ExecutableWorkflowStatus_GetStartedAt

func (*ExecutableWorkflowStatus) OnGetStartedAtMatch

func (_m *ExecutableWorkflowStatus) OnGetStartedAtMatch(matchers ...interface{}) *ExecutableWorkflowStatus_GetStartedAt

func (*ExecutableWorkflowStatus) OnGetStoppedAt

func (_m *ExecutableWorkflowStatus) OnGetStoppedAt() *ExecutableWorkflowStatus_GetStoppedAt

func (*ExecutableWorkflowStatus) OnGetStoppedAtMatch

func (_m *ExecutableWorkflowStatus) OnGetStoppedAtMatch(matchers ...interface{}) *ExecutableWorkflowStatus_GetStoppedAt

func (*ExecutableWorkflowStatus) OnIsTerminated

func (_m *ExecutableWorkflowStatus) OnIsTerminated() *ExecutableWorkflowStatus_IsTerminated

func (*ExecutableWorkflowStatus) OnIsTerminatedMatch

func (_m *ExecutableWorkflowStatus) OnIsTerminatedMatch(matchers ...interface{}) *ExecutableWorkflowStatus_IsTerminated

func (*ExecutableWorkflowStatus) SetDataDir

func (_m *ExecutableWorkflowStatus) SetDataDir(_a0 storage.DataReference)

SetDataDir provides a mock function with given fields: _a0

func (*ExecutableWorkflowStatus) SetMessage

func (_m *ExecutableWorkflowStatus) SetMessage(msg string)

SetMessage provides a mock function with given fields: msg

func (*ExecutableWorkflowStatus) SetOutputReference

func (_m *ExecutableWorkflowStatus) SetOutputReference(reference storage.DataReference)

SetOutputReference provides a mock function with given fields: reference

func (*ExecutableWorkflowStatus) UpdatePhase

func (_m *ExecutableWorkflowStatus) UpdatePhase(p v1alpha1.WorkflowPhase, msg string)

UpdatePhase provides a mock function with given fields: p, msg

type ExecutableWorkflowStatus_ConstructNodeDataDir

type ExecutableWorkflowStatus_ConstructNodeDataDir struct {
	*mock.Call
}

func (ExecutableWorkflowStatus_ConstructNodeDataDir) Return

func (_m ExecutableWorkflowStatus_ConstructNodeDataDir) Return(_a0 storage.DataReference, _a1 error) *ExecutableWorkflowStatus_ConstructNodeDataDir

type ExecutableWorkflowStatus_GetDataDir

type ExecutableWorkflowStatus_GetDataDir struct {
	*mock.Call
}

func (ExecutableWorkflowStatus_GetDataDir) Return

func (_m ExecutableWorkflowStatus_GetDataDir) Return(_a0 storage.DataReference) *ExecutableWorkflowStatus_GetDataDir

type ExecutableWorkflowStatus_GetLastUpdatedAt

type ExecutableWorkflowStatus_GetLastUpdatedAt struct {
	*mock.Call
}

func (ExecutableWorkflowStatus_GetLastUpdatedAt) Return

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

type ExecutableWorkflowStatus_GetMessage

type ExecutableWorkflowStatus_GetMessage struct {
	*mock.Call
}

func (ExecutableWorkflowStatus_GetMessage) Return

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

type ExecutableWorkflowStatus_GetNodeExecutionStatus

type ExecutableWorkflowStatus_GetNodeExecutionStatus struct {
	*mock.Call
}

func (ExecutableWorkflowStatus_GetNodeExecutionStatus) Return

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

type ExecutableWorkflowStatus_GetOutputReference

type ExecutableWorkflowStatus_GetOutputReference struct {
	*mock.Call
}

func (ExecutableWorkflowStatus_GetOutputReference) Return

func (_m ExecutableWorkflowStatus_GetOutputReference) Return(_a0 storage.DataReference) *ExecutableWorkflowStatus_GetOutputReference

type ExecutableWorkflowStatus_GetPhase

type ExecutableWorkflowStatus_GetPhase struct {
	*mock.Call
}

func (ExecutableWorkflowStatus_GetPhase) Return

func (_m ExecutableWorkflowStatus_GetPhase) Return(_a0 v1alpha1.WorkflowPhase) *ExecutableWorkflowStatus_GetPhase

type ExecutableWorkflowStatus_GetStartedAt

type ExecutableWorkflowStatus_GetStartedAt struct {
	*mock.Call
}

func (ExecutableWorkflowStatus_GetStartedAt) Return

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

type ExecutableWorkflowStatus_GetStoppedAt

type ExecutableWorkflowStatus_GetStoppedAt struct {
	*mock.Call
}

func (ExecutableWorkflowStatus_GetStoppedAt) Return

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

type ExecutableWorkflowStatus_IsTerminated

type ExecutableWorkflowStatus_IsTerminated struct {
	*mock.Call
}

func (ExecutableWorkflowStatus_IsTerminated) Return

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

type ExecutableWorkflow_FindSubWorkflow

type ExecutableWorkflow_FindSubWorkflow struct {
	*mock.Call
}

func (ExecutableWorkflow_FindSubWorkflow) Return

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

type ExecutableWorkflow_FromNode

type ExecutableWorkflow_FromNode struct {
	*mock.Call
}

func (ExecutableWorkflow_FromNode) Return

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

type ExecutableWorkflow_GetAnnotations

type ExecutableWorkflow_GetAnnotations struct {
	*mock.Call
}

func (ExecutableWorkflow_GetAnnotations) Return

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

type ExecutableWorkflow_GetConnections

type ExecutableWorkflow_GetConnections struct {
	*mock.Call
}

func (ExecutableWorkflow_GetConnections) Return

func (_m ExecutableWorkflow_GetConnections) Return(_a0 *v1alpha1.Connections) *ExecutableWorkflow_GetConnections

type ExecutableWorkflow_GetCreationTimestamp

type ExecutableWorkflow_GetCreationTimestamp struct {
	*mock.Call
}

func (ExecutableWorkflow_GetCreationTimestamp) Return

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

type ExecutableWorkflow_GetExecutionID

type ExecutableWorkflow_GetExecutionID struct {
	*mock.Call
}

func (ExecutableWorkflow_GetExecutionID) Return

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

type ExecutableWorkflow_GetExecutionStatus

type ExecutableWorkflow_GetExecutionStatus struct {
	*mock.Call
}

func (ExecutableWorkflow_GetExecutionStatus) Return

func (_m ExecutableWorkflow_GetExecutionStatus) Return(_a0 v1alpha1.ExecutableWorkflowStatus) *ExecutableWorkflow_GetExecutionStatus

type ExecutableWorkflow_GetID

type ExecutableWorkflow_GetID struct {
	*mock.Call
}

func (ExecutableWorkflow_GetID) Return

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

type ExecutableWorkflow_GetK8sWorkflowID

type ExecutableWorkflow_GetK8sWorkflowID struct {
	*mock.Call
}

func (ExecutableWorkflow_GetK8sWorkflowID) Return

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

type ExecutableWorkflow_GetLabels

type ExecutableWorkflow_GetLabels struct {
	*mock.Call
}

func (ExecutableWorkflow_GetLabels) Return

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

type ExecutableWorkflow_GetName

type ExecutableWorkflow_GetName struct {
	*mock.Call
}

func (ExecutableWorkflow_GetName) Return

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

type ExecutableWorkflow_GetNamespace

type ExecutableWorkflow_GetNamespace struct {
	*mock.Call
}

func (ExecutableWorkflow_GetNamespace) Return

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

type ExecutableWorkflow_GetNode

type ExecutableWorkflow_GetNode struct {
	*mock.Call
}

func (ExecutableWorkflow_GetNode) Return

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

type ExecutableWorkflow_GetNodeExecutionStatus

type ExecutableWorkflow_GetNodeExecutionStatus struct {
	*mock.Call
}

func (ExecutableWorkflow_GetNodeExecutionStatus) Return

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

type ExecutableWorkflow_GetNodes

type ExecutableWorkflow_GetNodes struct {
	*mock.Call
}

func (ExecutableWorkflow_GetNodes) Return

func (_m ExecutableWorkflow_GetNodes) Return(_a0 []string) *ExecutableWorkflow_GetNodes

type ExecutableWorkflow_GetOnFailureNode

type ExecutableWorkflow_GetOnFailureNode struct {
	*mock.Call
}

func (ExecutableWorkflow_GetOnFailureNode) Return

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

type ExecutableWorkflow_GetOutputBindings

type ExecutableWorkflow_GetOutputBindings struct {
	*mock.Call
}

func (ExecutableWorkflow_GetOutputBindings) Return

func (_m ExecutableWorkflow_GetOutputBindings) Return(_a0 []*v1alpha1.Binding) *ExecutableWorkflow_GetOutputBindings

type ExecutableWorkflow_GetOutputs

type ExecutableWorkflow_GetOutputs struct {
	*mock.Call
}

func (ExecutableWorkflow_GetOutputs) Return

func (_m ExecutableWorkflow_GetOutputs) Return(_a0 *v1alpha1.OutputVarMap) *ExecutableWorkflow_GetOutputs

type ExecutableWorkflow_GetOwnerReference

type ExecutableWorkflow_GetOwnerReference struct {
	*mock.Call
}

func (ExecutableWorkflow_GetOwnerReference) Return

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

type ExecutableWorkflow_GetServiceAccountName

type ExecutableWorkflow_GetServiceAccountName struct {
	*mock.Call
}

func (ExecutableWorkflow_GetServiceAccountName) Return

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

type ExecutableWorkflow_GetTask

type ExecutableWorkflow_GetTask struct {
	*mock.Call
}

func (ExecutableWorkflow_GetTask) Return

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

type ExecutableWorkflow_StartNode

type ExecutableWorkflow_StartNode struct {
	*mock.Call
}

func (ExecutableWorkflow_StartNode) Return

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

type Mutable

type Mutable struct {
	mock.Mock
}

Mutable is an autogenerated mock type for the Mutable type

func (*Mutable) IsDirty

func (_m *Mutable) IsDirty() bool

IsDirty provides a mock function with given fields:

func (*Mutable) OnIsDirty

func (_m *Mutable) OnIsDirty() *Mutable_IsDirty

func (*Mutable) OnIsDirtyMatch

func (_m *Mutable) OnIsDirtyMatch(matchers ...interface{}) *Mutable_IsDirty

type MutableBranchNodeStatus

type MutableBranchNodeStatus struct {
	mock.Mock
}

MutableBranchNodeStatus is an autogenerated mock type for the MutableBranchNodeStatus type

func (*MutableBranchNodeStatus) GetFinalizedNode

func (_m *MutableBranchNodeStatus) GetFinalizedNode() *string

GetFinalizedNode provides a mock function with given fields:

func (*MutableBranchNodeStatus) GetPhase

func (_m *MutableBranchNodeStatus) GetPhase() v1alpha1.BranchNodePhase

GetPhase provides a mock function with given fields:

func (*MutableBranchNodeStatus) IsDirty

func (_m *MutableBranchNodeStatus) IsDirty() bool

IsDirty provides a mock function with given fields:

func (*MutableBranchNodeStatus) OnGetFinalizedNode

func (_m *MutableBranchNodeStatus) OnGetFinalizedNode() *MutableBranchNodeStatus_GetFinalizedNode

func (*MutableBranchNodeStatus) OnGetFinalizedNodeMatch

func (_m *MutableBranchNodeStatus) OnGetFinalizedNodeMatch(matchers ...interface{}) *MutableBranchNodeStatus_GetFinalizedNode

func (*MutableBranchNodeStatus) OnGetPhase

func (_m *MutableBranchNodeStatus) OnGetPhase() *MutableBranchNodeStatus_GetPhase

func (*MutableBranchNodeStatus) OnGetPhaseMatch

func (_m *MutableBranchNodeStatus) OnGetPhaseMatch(matchers ...interface{}) *MutableBranchNodeStatus_GetPhase

func (*MutableBranchNodeStatus) OnIsDirty

func (_m *MutableBranchNodeStatus) OnIsDirty() *MutableBranchNodeStatus_IsDirty

func (*MutableBranchNodeStatus) OnIsDirtyMatch

func (_m *MutableBranchNodeStatus) OnIsDirtyMatch(matchers ...interface{}) *MutableBranchNodeStatus_IsDirty

func (*MutableBranchNodeStatus) SetBranchNodeError

func (_m *MutableBranchNodeStatus) SetBranchNodeError()

SetBranchNodeError provides a mock function with given fields:

func (*MutableBranchNodeStatus) SetBranchNodeSuccess

func (_m *MutableBranchNodeStatus) SetBranchNodeSuccess(id string)

SetBranchNodeSuccess provides a mock function with given fields: id

type MutableBranchNodeStatus_GetFinalizedNode

type MutableBranchNodeStatus_GetFinalizedNode struct {
	*mock.Call
}

func (MutableBranchNodeStatus_GetFinalizedNode) Return

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

type MutableBranchNodeStatus_GetPhase

type MutableBranchNodeStatus_GetPhase struct {
	*mock.Call
}

func (MutableBranchNodeStatus_GetPhase) Return

func (_m MutableBranchNodeStatus_GetPhase) Return(_a0 v1alpha1.BranchNodePhase) *MutableBranchNodeStatus_GetPhase

type MutableBranchNodeStatus_IsDirty

type MutableBranchNodeStatus_IsDirty struct {
	*mock.Call
}

func (MutableBranchNodeStatus_IsDirty) Return

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

type MutableDynamicNodeStatus

type MutableDynamicNodeStatus struct {
	mock.Mock
}

MutableDynamicNodeStatus is an autogenerated mock type for the MutableDynamicNodeStatus type

func (*MutableDynamicNodeStatus) GetDynamicNodePhase

func (_m *MutableDynamicNodeStatus) GetDynamicNodePhase() v1alpha1.DynamicNodePhase

GetDynamicNodePhase provides a mock function with given fields:

func (*MutableDynamicNodeStatus) GetDynamicNodeReason

func (_m *MutableDynamicNodeStatus) GetDynamicNodeReason() string

GetDynamicNodeReason provides a mock function with given fields:

func (*MutableDynamicNodeStatus) IsDirty

func (_m *MutableDynamicNodeStatus) IsDirty() bool

IsDirty provides a mock function with given fields:

func (*MutableDynamicNodeStatus) OnGetDynamicNodePhase

func (_m *MutableDynamicNodeStatus) OnGetDynamicNodePhase() *MutableDynamicNodeStatus_GetDynamicNodePhase

func (*MutableDynamicNodeStatus) OnGetDynamicNodePhaseMatch

func (_m *MutableDynamicNodeStatus) OnGetDynamicNodePhaseMatch(matchers ...interface{}) *MutableDynamicNodeStatus_GetDynamicNodePhase

func (*MutableDynamicNodeStatus) OnGetDynamicNodeReason

func (_m *MutableDynamicNodeStatus) OnGetDynamicNodeReason() *MutableDynamicNodeStatus_GetDynamicNodeReason

func (*MutableDynamicNodeStatus) OnGetDynamicNodeReasonMatch

func (_m *MutableDynamicNodeStatus) OnGetDynamicNodeReasonMatch(matchers ...interface{}) *MutableDynamicNodeStatus_GetDynamicNodeReason

func (*MutableDynamicNodeStatus) OnIsDirty

func (_m *MutableDynamicNodeStatus) OnIsDirty() *MutableDynamicNodeStatus_IsDirty

func (*MutableDynamicNodeStatus) OnIsDirtyMatch

func (_m *MutableDynamicNodeStatus) OnIsDirtyMatch(matchers ...interface{}) *MutableDynamicNodeStatus_IsDirty

func (*MutableDynamicNodeStatus) SetDynamicNodePhase

func (_m *MutableDynamicNodeStatus) SetDynamicNodePhase(phase v1alpha1.DynamicNodePhase)

SetDynamicNodePhase provides a mock function with given fields: phase

func (*MutableDynamicNodeStatus) SetDynamicNodeReason

func (_m *MutableDynamicNodeStatus) SetDynamicNodeReason(reason string)

SetDynamicNodeReason provides a mock function with given fields: reason

type MutableDynamicNodeStatus_GetDynamicNodePhase

type MutableDynamicNodeStatus_GetDynamicNodePhase struct {
	*mock.Call
}

func (MutableDynamicNodeStatus_GetDynamicNodePhase) Return

func (_m MutableDynamicNodeStatus_GetDynamicNodePhase) Return(_a0 v1alpha1.DynamicNodePhase) *MutableDynamicNodeStatus_GetDynamicNodePhase

type MutableDynamicNodeStatus_GetDynamicNodeReason

type MutableDynamicNodeStatus_GetDynamicNodeReason struct {
	*mock.Call
}

func (MutableDynamicNodeStatus_GetDynamicNodeReason) Return

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

type MutableDynamicNodeStatus_IsDirty

type MutableDynamicNodeStatus_IsDirty struct {
	*mock.Call
}

func (MutableDynamicNodeStatus_IsDirty) Return

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

type MutableNodeStatus

type MutableNodeStatus struct {
	mock.Mock
}

MutableNodeStatus is an autogenerated mock type for the MutableNodeStatus type

func (*MutableNodeStatus) ClearDynamicNodeStatus

func (_m *MutableNodeStatus) ClearDynamicNodeStatus()

ClearDynamicNodeStatus provides a mock function with given fields:

func (*MutableNodeStatus) ClearLastAttemptStartedAt

func (_m *MutableNodeStatus) ClearLastAttemptStartedAt()

ClearLastAttemptStartedAt provides a mock function with given fields:

func (*MutableNodeStatus) ClearSubNodeStatus

func (_m *MutableNodeStatus) ClearSubNodeStatus()

ClearSubNodeStatus provides a mock function with given fields:

func (*MutableNodeStatus) ClearTaskStatus

func (_m *MutableNodeStatus) ClearTaskStatus()

ClearTaskStatus provides a mock function with given fields:

func (*MutableNodeStatus) ClearWorkflowStatus

func (_m *MutableNodeStatus) ClearWorkflowStatus()

ClearWorkflowStatus provides a mock function with given fields:

func (*MutableNodeStatus) GetBranchStatus

func (_m *MutableNodeStatus) GetBranchStatus() v1alpha1.MutableBranchNodeStatus

GetBranchStatus provides a mock function with given fields:

func (*MutableNodeStatus) GetDynamicNodeStatus

func (_m *MutableNodeStatus) GetDynamicNodeStatus() v1alpha1.MutableDynamicNodeStatus

GetDynamicNodeStatus provides a mock function with given fields:

func (*MutableNodeStatus) GetOrCreateBranchStatus

func (_m *MutableNodeStatus) GetOrCreateBranchStatus() v1alpha1.MutableBranchNodeStatus

GetOrCreateBranchStatus provides a mock function with given fields:

func (*MutableNodeStatus) GetOrCreateDynamicNodeStatus

func (_m *MutableNodeStatus) GetOrCreateDynamicNodeStatus() v1alpha1.MutableDynamicNodeStatus

GetOrCreateDynamicNodeStatus provides a mock function with given fields:

func (*MutableNodeStatus) GetOrCreateTaskStatus

func (_m *MutableNodeStatus) GetOrCreateTaskStatus() v1alpha1.MutableTaskNodeStatus

GetOrCreateTaskStatus provides a mock function with given fields:

func (*MutableNodeStatus) GetOrCreateWorkflowStatus

func (_m *MutableNodeStatus) GetOrCreateWorkflowStatus() v1alpha1.MutableWorkflowNodeStatus

GetOrCreateWorkflowStatus provides a mock function with given fields:

func (*MutableNodeStatus) GetTaskStatus

func (_m *MutableNodeStatus) GetTaskStatus() v1alpha1.MutableTaskNodeStatus

GetTaskStatus provides a mock function with given fields:

func (*MutableNodeStatus) GetWorkflowStatus

func (_m *MutableNodeStatus) GetWorkflowStatus() v1alpha1.MutableWorkflowNodeStatus

GetWorkflowStatus provides a mock function with given fields:

func (*MutableNodeStatus) IncrementAttempts

func (_m *MutableNodeStatus) IncrementAttempts() uint32

IncrementAttempts provides a mock function with given fields:

func (*MutableNodeStatus) IsDirty

func (_m *MutableNodeStatus) IsDirty() bool

IsDirty provides a mock function with given fields:

func (*MutableNodeStatus) OnGetBranchStatus

func (_m *MutableNodeStatus) OnGetBranchStatus() *MutableNodeStatus_GetBranchStatus

func (*MutableNodeStatus) OnGetBranchStatusMatch

func (_m *MutableNodeStatus) OnGetBranchStatusMatch(matchers ...interface{}) *MutableNodeStatus_GetBranchStatus

func (*MutableNodeStatus) OnGetDynamicNodeStatus

func (_m *MutableNodeStatus) OnGetDynamicNodeStatus() *MutableNodeStatus_GetDynamicNodeStatus

func (*MutableNodeStatus) OnGetDynamicNodeStatusMatch

func (_m *MutableNodeStatus) OnGetDynamicNodeStatusMatch(matchers ...interface{}) *MutableNodeStatus_GetDynamicNodeStatus

func (*MutableNodeStatus) OnGetOrCreateBranchStatus

func (_m *MutableNodeStatus) OnGetOrCreateBranchStatus() *MutableNodeStatus_GetOrCreateBranchStatus

func (*MutableNodeStatus) OnGetOrCreateBranchStatusMatch

func (_m *MutableNodeStatus) OnGetOrCreateBranchStatusMatch(matchers ...interface{}) *MutableNodeStatus_GetOrCreateBranchStatus

func (*MutableNodeStatus) OnGetOrCreateDynamicNodeStatus

func (_m *MutableNodeStatus) OnGetOrCreateDynamicNodeStatus() *MutableNodeStatus_GetOrCreateDynamicNodeStatus

func (*MutableNodeStatus) OnGetOrCreateDynamicNodeStatusMatch

func (_m *MutableNodeStatus) OnGetOrCreateDynamicNodeStatusMatch(matchers ...interface{}) *MutableNodeStatus_GetOrCreateDynamicNodeStatus

func (*MutableNodeStatus) OnGetOrCreateTaskStatus

func (_m *MutableNodeStatus) OnGetOrCreateTaskStatus() *MutableNodeStatus_GetOrCreateTaskStatus

func (*MutableNodeStatus) OnGetOrCreateTaskStatusMatch

func (_m *MutableNodeStatus) OnGetOrCreateTaskStatusMatch(matchers ...interface{}) *MutableNodeStatus_GetOrCreateTaskStatus

func (*MutableNodeStatus) OnGetOrCreateWorkflowStatus

func (_m *MutableNodeStatus) OnGetOrCreateWorkflowStatus() *MutableNodeStatus_GetOrCreateWorkflowStatus

func (*MutableNodeStatus) OnGetOrCreateWorkflowStatusMatch

func (_m *MutableNodeStatus) OnGetOrCreateWorkflowStatusMatch(matchers ...interface{}) *MutableNodeStatus_GetOrCreateWorkflowStatus

func (*MutableNodeStatus) OnGetTaskStatus

func (_m *MutableNodeStatus) OnGetTaskStatus() *MutableNodeStatus_GetTaskStatus

func (*MutableNodeStatus) OnGetTaskStatusMatch

func (_m *MutableNodeStatus) OnGetTaskStatusMatch(matchers ...interface{}) *MutableNodeStatus_GetTaskStatus

func (*MutableNodeStatus) OnGetWorkflowStatus

func (_m *MutableNodeStatus) OnGetWorkflowStatus() *MutableNodeStatus_GetWorkflowStatus

func (*MutableNodeStatus) OnGetWorkflowStatusMatch

func (_m *MutableNodeStatus) OnGetWorkflowStatusMatch(matchers ...interface{}) *MutableNodeStatus_GetWorkflowStatus

func (*MutableNodeStatus) OnIncrementAttempts

func (_m *MutableNodeStatus) OnIncrementAttempts() *MutableNodeStatus_IncrementAttempts

func (*MutableNodeStatus) OnIncrementAttemptsMatch

func (_m *MutableNodeStatus) OnIncrementAttemptsMatch(matchers ...interface{}) *MutableNodeStatus_IncrementAttempts

func (*MutableNodeStatus) OnIsDirty

func (_m *MutableNodeStatus) OnIsDirty() *MutableNodeStatus_IsDirty

func (*MutableNodeStatus) OnIsDirtyMatch

func (_m *MutableNodeStatus) OnIsDirtyMatch(matchers ...interface{}) *MutableNodeStatus_IsDirty

func (*MutableNodeStatus) ResetDirty

func (_m *MutableNodeStatus) ResetDirty()

ResetDirty provides a mock function with given fields:

func (*MutableNodeStatus) SetCached

func (_m *MutableNodeStatus) SetCached()

SetCached provides a mock function with given fields:

func (*MutableNodeStatus) SetDataDir

func (_m *MutableNodeStatus) SetDataDir(_a0 storage.DataReference)

SetDataDir provides a mock function with given fields: _a0

func (*MutableNodeStatus) SetOutputDir

func (_m *MutableNodeStatus) SetOutputDir(d storage.DataReference)

SetOutputDir provides a mock function with given fields: d

func (*MutableNodeStatus) SetParentNodeID

func (_m *MutableNodeStatus) SetParentNodeID(n *string)

SetParentNodeID provides a mock function with given fields: n

func (*MutableNodeStatus) SetParentTaskID

func (_m *MutableNodeStatus) SetParentTaskID(t *core.TaskExecutionIdentifier)

SetParentTaskID provides a mock function with given fields: t

func (*MutableNodeStatus) UpdatePhase

func (_m *MutableNodeStatus) UpdatePhase(phase v1alpha1.NodePhase, occurredAt v1.Time, reason string)

UpdatePhase provides a mock function with given fields: phase, occurredAt, reason

type MutableNodeStatus_GetBranchStatus

type MutableNodeStatus_GetBranchStatus struct {
	*mock.Call
}

func (MutableNodeStatus_GetBranchStatus) Return

func (_m MutableNodeStatus_GetBranchStatus) Return(_a0 v1alpha1.MutableBranchNodeStatus) *MutableNodeStatus_GetBranchStatus

type MutableNodeStatus_GetDynamicNodeStatus

type MutableNodeStatus_GetDynamicNodeStatus struct {
	*mock.Call
}

func (MutableNodeStatus_GetDynamicNodeStatus) Return

func (_m MutableNodeStatus_GetDynamicNodeStatus) Return(_a0 v1alpha1.MutableDynamicNodeStatus) *MutableNodeStatus_GetDynamicNodeStatus

type MutableNodeStatus_GetOrCreateBranchStatus

type MutableNodeStatus_GetOrCreateBranchStatus struct {
	*mock.Call
}

func (MutableNodeStatus_GetOrCreateBranchStatus) Return

func (_m MutableNodeStatus_GetOrCreateBranchStatus) Return(_a0 v1alpha1.MutableBranchNodeStatus) *MutableNodeStatus_GetOrCreateBranchStatus

type MutableNodeStatus_GetOrCreateDynamicNodeStatus

type MutableNodeStatus_GetOrCreateDynamicNodeStatus struct {
	*mock.Call
}

func (MutableNodeStatus_GetOrCreateDynamicNodeStatus) Return

func (_m MutableNodeStatus_GetOrCreateDynamicNodeStatus) Return(_a0 v1alpha1.MutableDynamicNodeStatus) *MutableNodeStatus_GetOrCreateDynamicNodeStatus

type MutableNodeStatus_GetOrCreateTaskStatus

type MutableNodeStatus_GetOrCreateTaskStatus struct {
	*mock.Call
}

func (MutableNodeStatus_GetOrCreateTaskStatus) Return

func (_m MutableNodeStatus_GetOrCreateTaskStatus) Return(_a0 v1alpha1.MutableTaskNodeStatus) *MutableNodeStatus_GetOrCreateTaskStatus

type MutableNodeStatus_GetOrCreateWorkflowStatus

type MutableNodeStatus_GetOrCreateWorkflowStatus struct {
	*mock.Call
}

func (MutableNodeStatus_GetOrCreateWorkflowStatus) Return

func (_m MutableNodeStatus_GetOrCreateWorkflowStatus) Return(_a0 v1alpha1.MutableWorkflowNodeStatus) *MutableNodeStatus_GetOrCreateWorkflowStatus

type MutableNodeStatus_GetTaskStatus

type MutableNodeStatus_GetTaskStatus struct {
	*mock.Call
}

func (MutableNodeStatus_GetTaskStatus) Return

func (_m MutableNodeStatus_GetTaskStatus) Return(_a0 v1alpha1.MutableTaskNodeStatus) *MutableNodeStatus_GetTaskStatus

type MutableNodeStatus_GetWorkflowStatus

type MutableNodeStatus_GetWorkflowStatus struct {
	*mock.Call
}

func (MutableNodeStatus_GetWorkflowStatus) Return

func (_m MutableNodeStatus_GetWorkflowStatus) Return(_a0 v1alpha1.MutableWorkflowNodeStatus) *MutableNodeStatus_GetWorkflowStatus

type MutableNodeStatus_IncrementAttempts

type MutableNodeStatus_IncrementAttempts struct {
	*mock.Call
}

func (MutableNodeStatus_IncrementAttempts) Return

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

type MutableNodeStatus_IsDirty

type MutableNodeStatus_IsDirty struct {
	*mock.Call
}

func (MutableNodeStatus_IsDirty) Return

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

type MutableSubWorkflowNodeStatus

type MutableSubWorkflowNodeStatus struct {
	mock.Mock
}

MutableSubWorkflowNodeStatus is an autogenerated mock type for the MutableSubWorkflowNodeStatus type

func (*MutableSubWorkflowNodeStatus) GetPhase

func (_m *MutableSubWorkflowNodeStatus) GetPhase() v1alpha1.WorkflowPhase

GetPhase provides a mock function with given fields:

func (*MutableSubWorkflowNodeStatus) IsDirty

func (_m *MutableSubWorkflowNodeStatus) IsDirty() bool

IsDirty provides a mock function with given fields:

func (*MutableSubWorkflowNodeStatus) OnGetPhase

func (_m *MutableSubWorkflowNodeStatus) OnGetPhase() *MutableSubWorkflowNodeStatus_GetPhase

func (*MutableSubWorkflowNodeStatus) OnGetPhaseMatch

func (_m *MutableSubWorkflowNodeStatus) OnGetPhaseMatch(matchers ...interface{}) *MutableSubWorkflowNodeStatus_GetPhase

func (*MutableSubWorkflowNodeStatus) OnIsDirty

func (_m *MutableSubWorkflowNodeStatus) OnIsDirty() *MutableSubWorkflowNodeStatus_IsDirty

func (*MutableSubWorkflowNodeStatus) OnIsDirtyMatch

func (_m *MutableSubWorkflowNodeStatus) OnIsDirtyMatch(matchers ...interface{}) *MutableSubWorkflowNodeStatus_IsDirty

func (*MutableSubWorkflowNodeStatus) SetPhase

func (_m *MutableSubWorkflowNodeStatus) SetPhase(phase v1alpha1.WorkflowPhase)

SetPhase provides a mock function with given fields: phase

type MutableSubWorkflowNodeStatus_GetPhase

type MutableSubWorkflowNodeStatus_GetPhase struct {
	*mock.Call
}

func (MutableSubWorkflowNodeStatus_GetPhase) Return

func (_m MutableSubWorkflowNodeStatus_GetPhase) Return(_a0 v1alpha1.WorkflowPhase) *MutableSubWorkflowNodeStatus_GetPhase

type MutableSubWorkflowNodeStatus_IsDirty

type MutableSubWorkflowNodeStatus_IsDirty struct {
	*mock.Call
}

func (MutableSubWorkflowNodeStatus_IsDirty) Return

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

type MutableTaskNodeStatus

type MutableTaskNodeStatus struct {
	mock.Mock
}

MutableTaskNodeStatus is an autogenerated mock type for the MutableTaskNodeStatus type

func (*MutableTaskNodeStatus) GetBarrierClockTick

func (_m *MutableTaskNodeStatus) GetBarrierClockTick() uint32

GetBarrierClockTick provides a mock function with given fields:

func (*MutableTaskNodeStatus) GetLastPhaseUpdatedAt

func (_m *MutableTaskNodeStatus) GetLastPhaseUpdatedAt() time.Time

GetLastPhaseUpdatedAt provides a mock function with given fields:

func (*MutableTaskNodeStatus) GetPhase

func (_m *MutableTaskNodeStatus) GetPhase() int

GetPhase provides a mock function with given fields:

func (*MutableTaskNodeStatus) GetPhaseVersion

func (_m *MutableTaskNodeStatus) GetPhaseVersion() uint32

GetPhaseVersion provides a mock function with given fields:

func (*MutableTaskNodeStatus) GetPluginState

func (_m *MutableTaskNodeStatus) GetPluginState() []byte

GetPluginState provides a mock function with given fields:

func (*MutableTaskNodeStatus) GetPluginStateVersion

func (_m *MutableTaskNodeStatus) GetPluginStateVersion() uint32

GetPluginStateVersion provides a mock function with given fields:

func (*MutableTaskNodeStatus) IsDirty

func (_m *MutableTaskNodeStatus) IsDirty() bool

IsDirty provides a mock function with given fields:

func (*MutableTaskNodeStatus) OnGetBarrierClockTick

func (_m *MutableTaskNodeStatus) OnGetBarrierClockTick() *MutableTaskNodeStatus_GetBarrierClockTick

func (*MutableTaskNodeStatus) OnGetBarrierClockTickMatch

func (_m *MutableTaskNodeStatus) OnGetBarrierClockTickMatch(matchers ...interface{}) *MutableTaskNodeStatus_GetBarrierClockTick

func (*MutableTaskNodeStatus) OnGetLastPhaseUpdatedAt

func (_m *MutableTaskNodeStatus) OnGetLastPhaseUpdatedAt() *MutableTaskNodeStatus_GetLastPhaseUpdatedAt

func (*MutableTaskNodeStatus) OnGetLastPhaseUpdatedAtMatch

func (_m *MutableTaskNodeStatus) OnGetLastPhaseUpdatedAtMatch(matchers ...interface{}) *MutableTaskNodeStatus_GetLastPhaseUpdatedAt

func (*MutableTaskNodeStatus) OnGetPhase

func (_m *MutableTaskNodeStatus) OnGetPhase() *MutableTaskNodeStatus_GetPhase

func (*MutableTaskNodeStatus) OnGetPhaseMatch

func (_m *MutableTaskNodeStatus) OnGetPhaseMatch(matchers ...interface{}) *MutableTaskNodeStatus_GetPhase

func (*MutableTaskNodeStatus) OnGetPhaseVersion

func (_m *MutableTaskNodeStatus) OnGetPhaseVersion() *MutableTaskNodeStatus_GetPhaseVersion

func (*MutableTaskNodeStatus) OnGetPhaseVersionMatch

func (_m *MutableTaskNodeStatus) OnGetPhaseVersionMatch(matchers ...interface{}) *MutableTaskNodeStatus_GetPhaseVersion

func (*MutableTaskNodeStatus) OnGetPluginState

func (_m *MutableTaskNodeStatus) OnGetPluginState() *MutableTaskNodeStatus_GetPluginState

func (*MutableTaskNodeStatus) OnGetPluginStateMatch

func (_m *MutableTaskNodeStatus) OnGetPluginStateMatch(matchers ...interface{}) *MutableTaskNodeStatus_GetPluginState

func (*MutableTaskNodeStatus) OnGetPluginStateVersion

func (_m *MutableTaskNodeStatus) OnGetPluginStateVersion() *MutableTaskNodeStatus_GetPluginStateVersion

func (*MutableTaskNodeStatus) OnGetPluginStateVersionMatch

func (_m *MutableTaskNodeStatus) OnGetPluginStateVersionMatch(matchers ...interface{}) *MutableTaskNodeStatus_GetPluginStateVersion

func (*MutableTaskNodeStatus) OnIsDirty

func (_m *MutableTaskNodeStatus) OnIsDirty() *MutableTaskNodeStatus_IsDirty

func (*MutableTaskNodeStatus) OnIsDirtyMatch

func (_m *MutableTaskNodeStatus) OnIsDirtyMatch(matchers ...interface{}) *MutableTaskNodeStatus_IsDirty

func (*MutableTaskNodeStatus) SetBarrierClockTick

func (_m *MutableTaskNodeStatus) SetBarrierClockTick(tick uint32)

SetBarrierClockTick provides a mock function with given fields: tick

func (*MutableTaskNodeStatus) SetLastPhaseUpdatedAt

func (_m *MutableTaskNodeStatus) SetLastPhaseUpdatedAt(updatedAt time.Time)

SetLastPhaseUpdatedAt provides a mock function with given fields: updatedAt

func (*MutableTaskNodeStatus) SetPhase

func (_m *MutableTaskNodeStatus) SetPhase(phase int)

SetPhase provides a mock function with given fields: phase

func (*MutableTaskNodeStatus) SetPhaseVersion

func (_m *MutableTaskNodeStatus) SetPhaseVersion(version uint32)

SetPhaseVersion provides a mock function with given fields: version

func (*MutableTaskNodeStatus) SetPluginState

func (_m *MutableTaskNodeStatus) SetPluginState(_a0 []byte)

SetPluginState provides a mock function with given fields: _a0

func (*MutableTaskNodeStatus) SetPluginStateVersion

func (_m *MutableTaskNodeStatus) SetPluginStateVersion(_a0 uint32)

SetPluginStateVersion provides a mock function with given fields: _a0

type MutableTaskNodeStatus_GetBarrierClockTick

type MutableTaskNodeStatus_GetBarrierClockTick struct {
	*mock.Call
}

func (MutableTaskNodeStatus_GetBarrierClockTick) Return

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

type MutableTaskNodeStatus_GetLastPhaseUpdatedAt

type MutableTaskNodeStatus_GetLastPhaseUpdatedAt struct {
	*mock.Call
}

func (MutableTaskNodeStatus_GetLastPhaseUpdatedAt) Return

func (_m MutableTaskNodeStatus_GetLastPhaseUpdatedAt) Return(_a0 time.Time) *MutableTaskNodeStatus_GetLastPhaseUpdatedAt

type MutableTaskNodeStatus_GetPhase

type MutableTaskNodeStatus_GetPhase struct {
	*mock.Call
}

func (MutableTaskNodeStatus_GetPhase) Return

func (_m MutableTaskNodeStatus_GetPhase) Return(_a0 int) *MutableTaskNodeStatus_GetPhase

type MutableTaskNodeStatus_GetPhaseVersion

type MutableTaskNodeStatus_GetPhaseVersion struct {
	*mock.Call
}

func (MutableTaskNodeStatus_GetPhaseVersion) Return

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

type MutableTaskNodeStatus_GetPluginState

type MutableTaskNodeStatus_GetPluginState struct {
	*mock.Call
}

func (MutableTaskNodeStatus_GetPluginState) Return

func (_m MutableTaskNodeStatus_GetPluginState) Return(_a0 []byte) *MutableTaskNodeStatus_GetPluginState

type MutableTaskNodeStatus_GetPluginStateVersion

type MutableTaskNodeStatus_GetPluginStateVersion struct {
	*mock.Call
}

func (MutableTaskNodeStatus_GetPluginStateVersion) Return

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

type MutableTaskNodeStatus_IsDirty

type MutableTaskNodeStatus_IsDirty struct {
	*mock.Call
}

func (MutableTaskNodeStatus_IsDirty) Return

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

type MutableWorkflowNodeStatus

type MutableWorkflowNodeStatus struct {
	mock.Mock
}

MutableWorkflowNodeStatus is an autogenerated mock type for the MutableWorkflowNodeStatus type

func (*MutableWorkflowNodeStatus) GetWorkflowNodePhase

func (_m *MutableWorkflowNodeStatus) GetWorkflowNodePhase() v1alpha1.WorkflowNodePhase

GetWorkflowNodePhase provides a mock function with given fields:

func (*MutableWorkflowNodeStatus) IsDirty

func (_m *MutableWorkflowNodeStatus) IsDirty() bool

IsDirty provides a mock function with given fields:

func (*MutableWorkflowNodeStatus) OnGetWorkflowNodePhase

func (_m *MutableWorkflowNodeStatus) OnGetWorkflowNodePhase() *MutableWorkflowNodeStatus_GetWorkflowNodePhase

func (*MutableWorkflowNodeStatus) OnGetWorkflowNodePhaseMatch

func (_m *MutableWorkflowNodeStatus) OnGetWorkflowNodePhaseMatch(matchers ...interface{}) *MutableWorkflowNodeStatus_GetWorkflowNodePhase

func (*MutableWorkflowNodeStatus) OnIsDirty

func (_m *MutableWorkflowNodeStatus) OnIsDirty() *MutableWorkflowNodeStatus_IsDirty

func (*MutableWorkflowNodeStatus) OnIsDirtyMatch

func (_m *MutableWorkflowNodeStatus) OnIsDirtyMatch(matchers ...interface{}) *MutableWorkflowNodeStatus_IsDirty

func (*MutableWorkflowNodeStatus) SetWorkflowNodePhase

func (_m *MutableWorkflowNodeStatus) SetWorkflowNodePhase(phase v1alpha1.WorkflowNodePhase)

SetWorkflowNodePhase provides a mock function with given fields: phase

type MutableWorkflowNodeStatus_GetWorkflowNodePhase

type MutableWorkflowNodeStatus_GetWorkflowNodePhase struct {
	*mock.Call
}

func (MutableWorkflowNodeStatus_GetWorkflowNodePhase) Return

func (_m MutableWorkflowNodeStatus_GetWorkflowNodePhase) Return(_a0 v1alpha1.WorkflowNodePhase) *MutableWorkflowNodeStatus_GetWorkflowNodePhase

type MutableWorkflowNodeStatus_IsDirty

type MutableWorkflowNodeStatus_IsDirty struct {
	*mock.Call
}

func (MutableWorkflowNodeStatus_IsDirty) Return

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

type Mutable_IsDirty

type Mutable_IsDirty struct {
	*mock.Call
}

func (Mutable_IsDirty) Return

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

type NodeStatusGetter

type NodeStatusGetter struct {
	mock.Mock
}

NodeStatusGetter is an autogenerated mock type for the NodeStatusGetter type

func (*NodeStatusGetter) GetNodeExecutionStatus

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

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

func (*NodeStatusGetter) OnGetNodeExecutionStatus

func (_m *NodeStatusGetter) OnGetNodeExecutionStatus(ctx context.Context, id string) *NodeStatusGetter_GetNodeExecutionStatus

func (*NodeStatusGetter) OnGetNodeExecutionStatusMatch

func (_m *NodeStatusGetter) OnGetNodeExecutionStatusMatch(matchers ...interface{}) *NodeStatusGetter_GetNodeExecutionStatus

type NodeStatusGetter_GetNodeExecutionStatus

type NodeStatusGetter_GetNodeExecutionStatus struct {
	*mock.Call
}

func (NodeStatusGetter_GetNodeExecutionStatus) Return

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

type NodeStatusVisitor

type NodeStatusVisitor struct {
	mock.Mock
}

NodeStatusVisitor is an autogenerated mock type for the NodeStatusVisitor type

func (*NodeStatusVisitor) VisitNodeStatuses

func (_m *NodeStatusVisitor) VisitNodeStatuses(visitor func(string, v1alpha1.ExecutableNodeStatus))

VisitNodeStatuses provides a mock function with given fields: visitor

type TaskDetailsGetter

type TaskDetailsGetter struct {
	mock.Mock
}

TaskDetailsGetter is an autogenerated mock type for the TaskDetailsGetter type

func (*TaskDetailsGetter) GetTask

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

GetTask provides a mock function with given fields: id

func (*TaskDetailsGetter) OnGetTask

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

func (*TaskDetailsGetter) OnGetTaskMatch

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

type TaskDetailsGetter_GetTask

type TaskDetailsGetter_GetTask struct {
	*mock.Call
}

func (TaskDetailsGetter_GetTask) Return

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

type WorkflowMeta

type WorkflowMeta struct {
	mock.Mock
}

WorkflowMeta is an autogenerated mock type for the WorkflowMeta type

func (*WorkflowMeta) GetAnnotations

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

GetAnnotations provides a mock function with given fields:

func (*WorkflowMeta) GetCreationTimestamp

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

GetCreationTimestamp provides a mock function with given fields:

func (*WorkflowMeta) GetExecutionID

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

GetExecutionID provides a mock function with given fields:

func (*WorkflowMeta) GetK8sWorkflowID

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

GetK8sWorkflowID provides a mock function with given fields:

func (*WorkflowMeta) GetLabels

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

GetLabels provides a mock function with given fields:

func (*WorkflowMeta) GetName

func (_m *WorkflowMeta) GetName() string

GetName provides a mock function with given fields:

func (*WorkflowMeta) GetNamespace

func (_m *WorkflowMeta) GetNamespace() string

GetNamespace provides a mock function with given fields:

func (*WorkflowMeta) GetOwnerReference

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

GetOwnerReference provides a mock function with given fields:

func (*WorkflowMeta) GetServiceAccountName

func (_m *WorkflowMeta) GetServiceAccountName() string

GetServiceAccountName provides a mock function with given fields:

func (*WorkflowMeta) OnGetAnnotations

func (_m *WorkflowMeta) OnGetAnnotations() *WorkflowMeta_GetAnnotations

func (*WorkflowMeta) OnGetAnnotationsMatch

func (_m *WorkflowMeta) OnGetAnnotationsMatch(matchers ...interface{}) *WorkflowMeta_GetAnnotations

func (*WorkflowMeta) OnGetCreationTimestamp

func (_m *WorkflowMeta) OnGetCreationTimestamp() *WorkflowMeta_GetCreationTimestamp

func (*WorkflowMeta) OnGetCreationTimestampMatch

func (_m *WorkflowMeta) OnGetCreationTimestampMatch(matchers ...interface{}) *WorkflowMeta_GetCreationTimestamp

func (*WorkflowMeta) OnGetExecutionID

func (_m *WorkflowMeta) OnGetExecutionID() *WorkflowMeta_GetExecutionID

func (*WorkflowMeta) OnGetExecutionIDMatch

func (_m *WorkflowMeta) OnGetExecutionIDMatch(matchers ...interface{}) *WorkflowMeta_GetExecutionID

func (*WorkflowMeta) OnGetK8sWorkflowID

func (_m *WorkflowMeta) OnGetK8sWorkflowID() *WorkflowMeta_GetK8sWorkflowID

func (*WorkflowMeta) OnGetK8sWorkflowIDMatch

func (_m *WorkflowMeta) OnGetK8sWorkflowIDMatch(matchers ...interface{}) *WorkflowMeta_GetK8sWorkflowID

func (*WorkflowMeta) OnGetLabels

func (_m *WorkflowMeta) OnGetLabels() *WorkflowMeta_GetLabels

func (*WorkflowMeta) OnGetLabelsMatch

func (_m *WorkflowMeta) OnGetLabelsMatch(matchers ...interface{}) *WorkflowMeta_GetLabels

func (*WorkflowMeta) OnGetName

func (_m *WorkflowMeta) OnGetName() *WorkflowMeta_GetName

func (*WorkflowMeta) OnGetNameMatch

func (_m *WorkflowMeta) OnGetNameMatch(matchers ...interface{}) *WorkflowMeta_GetName

func (*WorkflowMeta) OnGetNamespace

func (_m *WorkflowMeta) OnGetNamespace() *WorkflowMeta_GetNamespace

func (*WorkflowMeta) OnGetNamespaceMatch

func (_m *WorkflowMeta) OnGetNamespaceMatch(matchers ...interface{}) *WorkflowMeta_GetNamespace

func (*WorkflowMeta) OnGetOwnerReference

func (_m *WorkflowMeta) OnGetOwnerReference() *WorkflowMeta_GetOwnerReference

func (*WorkflowMeta) OnGetOwnerReferenceMatch

func (_m *WorkflowMeta) OnGetOwnerReferenceMatch(matchers ...interface{}) *WorkflowMeta_GetOwnerReference

func (*WorkflowMeta) OnGetServiceAccountName

func (_m *WorkflowMeta) OnGetServiceAccountName() *WorkflowMeta_GetServiceAccountName

func (*WorkflowMeta) OnGetServiceAccountNameMatch

func (_m *WorkflowMeta) OnGetServiceAccountNameMatch(matchers ...interface{}) *WorkflowMeta_GetServiceAccountName

type WorkflowMetaExtended

type WorkflowMetaExtended struct {
	mock.Mock
}

WorkflowMetaExtended is an autogenerated mock type for the WorkflowMetaExtended type

func (*WorkflowMetaExtended) FindSubWorkflow

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

FindSubWorkflow provides a mock function with given fields: subID

func (*WorkflowMetaExtended) GetAnnotations

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

GetAnnotations provides a mock function with given fields:

func (*WorkflowMetaExtended) GetCreationTimestamp

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

GetCreationTimestamp provides a mock function with given fields:

func (*WorkflowMetaExtended) GetExecutionID

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

GetExecutionID provides a mock function with given fields:

func (*WorkflowMetaExtended) GetExecutionStatus

func (_m *WorkflowMetaExtended) GetExecutionStatus() v1alpha1.ExecutableWorkflowStatus

GetExecutionStatus provides a mock function with given fields:

func (*WorkflowMetaExtended) GetK8sWorkflowID

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

GetK8sWorkflowID provides a mock function with given fields:

func (*WorkflowMetaExtended) GetLabels

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

GetLabels provides a mock function with given fields:

func (*WorkflowMetaExtended) GetName

func (_m *WorkflowMetaExtended) GetName() string

GetName provides a mock function with given fields:

func (*WorkflowMetaExtended) GetNamespace

func (_m *WorkflowMetaExtended) GetNamespace() string

GetNamespace provides a mock function with given fields:

func (*WorkflowMetaExtended) GetOwnerReference

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

GetOwnerReference provides a mock function with given fields:

func (*WorkflowMetaExtended) GetServiceAccountName

func (_m *WorkflowMetaExtended) GetServiceAccountName() string

GetServiceAccountName provides a mock function with given fields:

func (*WorkflowMetaExtended) GetTask

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

GetTask provides a mock function with given fields: id

func (*WorkflowMetaExtended) OnFindSubWorkflow

func (_m *WorkflowMetaExtended) OnFindSubWorkflow(subID string) *WorkflowMetaExtended_FindSubWorkflow

func (*WorkflowMetaExtended) OnFindSubWorkflowMatch

func (_m *WorkflowMetaExtended) OnFindSubWorkflowMatch(matchers ...interface{}) *WorkflowMetaExtended_FindSubWorkflow

func (*WorkflowMetaExtended) OnGetAnnotations

func (_m *WorkflowMetaExtended) OnGetAnnotations() *WorkflowMetaExtended_GetAnnotations

func (*WorkflowMetaExtended) OnGetAnnotationsMatch

func (_m *WorkflowMetaExtended) OnGetAnnotationsMatch(matchers ...interface{}) *WorkflowMetaExtended_GetAnnotations

func (*WorkflowMetaExtended) OnGetCreationTimestamp

func (_m *WorkflowMetaExtended) OnGetCreationTimestamp() *WorkflowMetaExtended_GetCreationTimestamp

func (*WorkflowMetaExtended) OnGetCreationTimestampMatch

func (_m *WorkflowMetaExtended) OnGetCreationTimestampMatch(matchers ...interface{}) *WorkflowMetaExtended_GetCreationTimestamp

func (*WorkflowMetaExtended) OnGetExecutionID

func (_m *WorkflowMetaExtended) OnGetExecutionID() *WorkflowMetaExtended_GetExecutionID

func (*WorkflowMetaExtended) OnGetExecutionIDMatch

func (_m *WorkflowMetaExtended) OnGetExecutionIDMatch(matchers ...interface{}) *WorkflowMetaExtended_GetExecutionID

func (*WorkflowMetaExtended) OnGetExecutionStatus

func (_m *WorkflowMetaExtended) OnGetExecutionStatus() *WorkflowMetaExtended_GetExecutionStatus

func (*WorkflowMetaExtended) OnGetExecutionStatusMatch

func (_m *WorkflowMetaExtended) OnGetExecutionStatusMatch(matchers ...interface{}) *WorkflowMetaExtended_GetExecutionStatus

func (*WorkflowMetaExtended) OnGetK8sWorkflowID

func (_m *WorkflowMetaExtended) OnGetK8sWorkflowID() *WorkflowMetaExtended_GetK8sWorkflowID

func (*WorkflowMetaExtended) OnGetK8sWorkflowIDMatch

func (_m *WorkflowMetaExtended) OnGetK8sWorkflowIDMatch(matchers ...interface{}) *WorkflowMetaExtended_GetK8sWorkflowID

func (*WorkflowMetaExtended) OnGetLabels

func (_m *WorkflowMetaExtended) OnGetLabels() *WorkflowMetaExtended_GetLabels

func (*WorkflowMetaExtended) OnGetLabelsMatch

func (_m *WorkflowMetaExtended) OnGetLabelsMatch(matchers ...interface{}) *WorkflowMetaExtended_GetLabels

func (*WorkflowMetaExtended) OnGetName

func (_m *WorkflowMetaExtended) OnGetName() *WorkflowMetaExtended_GetName

func (*WorkflowMetaExtended) OnGetNameMatch

func (_m *WorkflowMetaExtended) OnGetNameMatch(matchers ...interface{}) *WorkflowMetaExtended_GetName

func (*WorkflowMetaExtended) OnGetNamespace

func (_m *WorkflowMetaExtended) OnGetNamespace() *WorkflowMetaExtended_GetNamespace

func (*WorkflowMetaExtended) OnGetNamespaceMatch

func (_m *WorkflowMetaExtended) OnGetNamespaceMatch(matchers ...interface{}) *WorkflowMetaExtended_GetNamespace

func (*WorkflowMetaExtended) OnGetOwnerReference

func (_m *WorkflowMetaExtended) OnGetOwnerReference() *WorkflowMetaExtended_GetOwnerReference

func (*WorkflowMetaExtended) OnGetOwnerReferenceMatch

func (_m *WorkflowMetaExtended) OnGetOwnerReferenceMatch(matchers ...interface{}) *WorkflowMetaExtended_GetOwnerReference

func (*WorkflowMetaExtended) OnGetServiceAccountName

func (_m *WorkflowMetaExtended) OnGetServiceAccountName() *WorkflowMetaExtended_GetServiceAccountName

func (*WorkflowMetaExtended) OnGetServiceAccountNameMatch

func (_m *WorkflowMetaExtended) OnGetServiceAccountNameMatch(matchers ...interface{}) *WorkflowMetaExtended_GetServiceAccountName

func (*WorkflowMetaExtended) OnGetTask

func (_m *WorkflowMetaExtended) OnGetTask(id string) *WorkflowMetaExtended_GetTask

func (*WorkflowMetaExtended) OnGetTaskMatch

func (_m *WorkflowMetaExtended) OnGetTaskMatch(matchers ...interface{}) *WorkflowMetaExtended_GetTask

type WorkflowMetaExtended_FindSubWorkflow

type WorkflowMetaExtended_FindSubWorkflow struct {
	*mock.Call
}

func (WorkflowMetaExtended_FindSubWorkflow) Return

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

type WorkflowMetaExtended_GetAnnotations

type WorkflowMetaExtended_GetAnnotations struct {
	*mock.Call
}

func (WorkflowMetaExtended_GetAnnotations) Return

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

type WorkflowMetaExtended_GetCreationTimestamp

type WorkflowMetaExtended_GetCreationTimestamp struct {
	*mock.Call
}

func (WorkflowMetaExtended_GetCreationTimestamp) Return

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

type WorkflowMetaExtended_GetExecutionID

type WorkflowMetaExtended_GetExecutionID struct {
	*mock.Call
}

func (WorkflowMetaExtended_GetExecutionID) Return

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

type WorkflowMetaExtended_GetExecutionStatus

type WorkflowMetaExtended_GetExecutionStatus struct {
	*mock.Call
}

func (WorkflowMetaExtended_GetExecutionStatus) Return

func (_m WorkflowMetaExtended_GetExecutionStatus) Return(_a0 v1alpha1.ExecutableWorkflowStatus) *WorkflowMetaExtended_GetExecutionStatus

type WorkflowMetaExtended_GetK8sWorkflowID

type WorkflowMetaExtended_GetK8sWorkflowID struct {
	*mock.Call
}

func (WorkflowMetaExtended_GetK8sWorkflowID) Return

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

type WorkflowMetaExtended_GetLabels

type WorkflowMetaExtended_GetLabels struct {
	*mock.Call
}

func (WorkflowMetaExtended_GetLabels) Return

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

type WorkflowMetaExtended_GetName

type WorkflowMetaExtended_GetName struct {
	*mock.Call
}

func (WorkflowMetaExtended_GetName) Return

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

type WorkflowMetaExtended_GetNamespace

type WorkflowMetaExtended_GetNamespace struct {
	*mock.Call
}

func (WorkflowMetaExtended_GetNamespace) Return

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

type WorkflowMetaExtended_GetOwnerReference

type WorkflowMetaExtended_GetOwnerReference struct {
	*mock.Call
}

func (WorkflowMetaExtended_GetOwnerReference) Return

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

type WorkflowMetaExtended_GetServiceAccountName

type WorkflowMetaExtended_GetServiceAccountName struct {
	*mock.Call
}

func (WorkflowMetaExtended_GetServiceAccountName) Return

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

type WorkflowMetaExtended_GetTask

type WorkflowMetaExtended_GetTask struct {
	*mock.Call
}

func (WorkflowMetaExtended_GetTask) Return

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

type WorkflowMeta_GetAnnotations

type WorkflowMeta_GetAnnotations struct {
	*mock.Call
}

func (WorkflowMeta_GetAnnotations) Return

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

type WorkflowMeta_GetCreationTimestamp

type WorkflowMeta_GetCreationTimestamp struct {
	*mock.Call
}

func (WorkflowMeta_GetCreationTimestamp) Return

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

type WorkflowMeta_GetExecutionID

type WorkflowMeta_GetExecutionID struct {
	*mock.Call
}

func (WorkflowMeta_GetExecutionID) Return

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

type WorkflowMeta_GetK8sWorkflowID

type WorkflowMeta_GetK8sWorkflowID struct {
	*mock.Call
}

func (WorkflowMeta_GetK8sWorkflowID) Return

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

type WorkflowMeta_GetLabels

type WorkflowMeta_GetLabels struct {
	*mock.Call
}

func (WorkflowMeta_GetLabels) Return

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

type WorkflowMeta_GetName

type WorkflowMeta_GetName struct {
	*mock.Call
}

func (WorkflowMeta_GetName) Return

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

type WorkflowMeta_GetNamespace

type WorkflowMeta_GetNamespace struct {
	*mock.Call
}

func (WorkflowMeta_GetNamespace) Return

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

type WorkflowMeta_GetOwnerReference

type WorkflowMeta_GetOwnerReference struct {
	*mock.Call
}

func (WorkflowMeta_GetOwnerReference) Return

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

type WorkflowMeta_GetServiceAccountName

type WorkflowMeta_GetServiceAccountName struct {
	*mock.Call
}

func (WorkflowMeta_GetServiceAccountName) Return

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