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
- type 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) OnToNode(name string) *BaseWorkflow_ToNode
- func (_m *BaseWorkflow) OnToNodeMatch(matchers ...interface{}) *BaseWorkflow_ToNode
- func (_m *BaseWorkflow) StartNode() v1alpha1.ExecutableNode
- func (_m *BaseWorkflow) ToNode(name string) ([]string, error)
- 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) OnToNode(name string) *BaseWorkflowWithStatus_ToNode
- func (_m *BaseWorkflowWithStatus) OnToNodeMatch(matchers ...interface{}) *BaseWorkflowWithStatus_ToNode
- func (_m *BaseWorkflowWithStatus) StartNode() v1alpha1.ExecutableNode
- func (_m *BaseWorkflowWithStatus) ToNode(name string) ([]string, error)
- type BaseWorkflowWithStatus_FromNode
- type BaseWorkflowWithStatus_GetID
- type BaseWorkflowWithStatus_GetNode
- type BaseWorkflowWithStatus_GetNodeExecutionStatus
- type BaseWorkflowWithStatus_StartNode
- type BaseWorkflowWithStatus_ToNode
- type BaseWorkflow_FromNode
- type BaseWorkflow_GetID
- type BaseWorkflow_GetNode
- type BaseWorkflow_StartNode
- type BaseWorkflow_ToNode
- 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
- type ExecutableBranchNodeStatus_GetPhase
- type ExecutableBranchNode_GetElse
- type ExecutableBranchNode_GetElseFail
- type ExecutableBranchNode_GetElseIf
- type ExecutableBranchNode_GetIf
- type ExecutableDynamicNodeStatus
- func (_m *ExecutableDynamicNodeStatus) GetDynamicNodePhase() v1alpha1.DynamicNodePhase
- func (_m *ExecutableDynamicNodeStatus) GetDynamicNodeReason() string
- func (_m *ExecutableDynamicNodeStatus) GetExecutionError() *core.ExecutionError
- 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
- func (_m *ExecutableDynamicNodeStatus) OnGetExecutionError() *ExecutableDynamicNodeStatus_GetExecutionError
- func (_m *ExecutableDynamicNodeStatus) OnGetExecutionErrorMatch(matchers ...interface{}) *ExecutableDynamicNodeStatus_GetExecutionError
- type ExecutableDynamicNodeStatus_GetDynamicNodePhase
- type ExecutableDynamicNodeStatus_GetDynamicNodeReason
- type ExecutableDynamicNodeStatus_GetExecutionError
- 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
- type 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) IsInterruptible() *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) OnIsInterruptible() *ExecutableNode_IsInterruptible
- func (_m *ExecutableNode) OnIsInterruptibleMatch(matchers ...interface{}) *ExecutableNode_IsInterruptible
- 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) GetExecutionError() *core.ExecutionError
- 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) GetSystemFailures() uint32
- 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) IncrementSystemFailures() 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) OnGetExecutionError() *ExecutableNodeStatus_GetExecutionError
- func (_m *ExecutableNodeStatus) OnGetExecutionErrorMatch(matchers ...interface{}) *ExecutableNodeStatus_GetExecutionError
- 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) OnGetSystemFailures() *ExecutableNodeStatus_GetSystemFailures
- func (_m *ExecutableNodeStatus) OnGetSystemFailuresMatch(matchers ...interface{}) *ExecutableNodeStatus_GetSystemFailures
- 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) OnIncrementSystemFailures() *ExecutableNodeStatus_IncrementSystemFailures
- func (_m *ExecutableNodeStatus) OnIncrementSystemFailuresMatch(matchers ...interface{}) *ExecutableNodeStatus_IncrementSystemFailures
- 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
- type ExecutableNodeStatus_GetBranchStatus
- type ExecutableNodeStatus_GetDataDir
- type ExecutableNodeStatus_GetDynamicNodeStatus
- type ExecutableNodeStatus_GetExecutionError
- type ExecutableNodeStatus_GetLastAttemptStartedAt
- type ExecutableNodeStatus_GetLastUpdatedAt
- type ExecutableNodeStatus_GetMessage
- type ExecutableNodeStatus_GetNodeExecutionStatus
- type ExecutableNodeStatus_GetOrCreateBranchStatus
- type ExecutableNodeStatus_GetOrCreateDynamicNodeStatus
- type ExecutableNodeStatus_GetOrCreateTaskStatus
- type ExecutableNodeStatus_GetOrCreateWorkflowStatus
- type ExecutableNodeStatus_GetOutputDir
- type ExecutableNodeStatus_GetParentNodeID
- type ExecutableNodeStatus_GetParentTaskID
- type ExecutableNodeStatus_GetPhase
- type ExecutableNodeStatus_GetQueuedAt
- type ExecutableNodeStatus_GetStartedAt
- type ExecutableNodeStatus_GetStoppedAt
- type ExecutableNodeStatus_GetSystemFailures
- type ExecutableNodeStatus_GetTaskNodeStatus
- type ExecutableNodeStatus_GetTaskStatus
- type ExecutableNodeStatus_GetWorkflowNodeStatus
- type ExecutableNodeStatus_GetWorkflowStatus
- type ExecutableNodeStatus_IncrementAttempts
- type ExecutableNodeStatus_IncrementSystemFailures
- type ExecutableNodeStatus_IsCached
- type ExecutableNodeStatus_IsDirty
- type ExecutableNode_GetActiveDeadline
- type ExecutableNode_GetBranchNode
- type ExecutableNode_GetConfig
- type ExecutableNode_GetExecutionDeadline
- type ExecutableNode_GetID
- type ExecutableNode_GetInputBindings
- type ExecutableNode_GetKind
- type ExecutableNode_GetOutputAlias
- type ExecutableNode_GetResources
- type ExecutableNode_GetRetryStrategy
- type ExecutableNode_GetTaskID
- type ExecutableNode_GetWorkflowNode
- type ExecutableNode_IsEndNode
- type ExecutableNode_IsInterruptible
- type 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) OnToNode(name string) *ExecutableSubWorkflow_ToNode
- func (_m *ExecutableSubWorkflow) OnToNodeMatch(matchers ...interface{}) *ExecutableSubWorkflow_ToNode
- func (_m *ExecutableSubWorkflow) StartNode() v1alpha1.ExecutableNode
- func (_m *ExecutableSubWorkflow) ToNode(name string) ([]string, error)
- 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
- type ExecutableSubWorkflow_FromNode
- type ExecutableSubWorkflow_GetConnections
- type ExecutableSubWorkflow_GetID
- type ExecutableSubWorkflow_GetNode
- type ExecutableSubWorkflow_GetNodes
- type ExecutableSubWorkflow_GetOnFailureNode
- type ExecutableSubWorkflow_GetOutputBindings
- type ExecutableSubWorkflow_GetOutputs
- type ExecutableSubWorkflow_StartNode
- type ExecutableSubWorkflow_ToNode
- 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
- type ExecutableTaskNodeStatus_GetLastPhaseUpdatedAt
- type ExecutableTaskNodeStatus_GetPhase
- type ExecutableTaskNodeStatus_GetPhaseVersion
- type ExecutableTaskNodeStatus_GetPluginState
- type ExecutableTaskNodeStatus_GetPluginStateVersion
- type ExecutableTask_CoreTask
- type 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) IsInterruptible() bool
- 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) OnIsInterruptible() *ExecutableWorkflow_IsInterruptible
- func (_m *ExecutableWorkflow) OnIsInterruptibleMatch(matchers ...interface{}) *ExecutableWorkflow_IsInterruptible
- func (_m *ExecutableWorkflow) OnStartNode() *ExecutableWorkflow_StartNode
- func (_m *ExecutableWorkflow) OnStartNodeMatch(matchers ...interface{}) *ExecutableWorkflow_StartNode
- func (_m *ExecutableWorkflow) OnToNode(name string) *ExecutableWorkflow_ToNode
- func (_m *ExecutableWorkflow) OnToNodeMatch(matchers ...interface{}) *ExecutableWorkflow_ToNode
- func (_m *ExecutableWorkflow) StartNode() v1alpha1.ExecutableNode
- func (_m *ExecutableWorkflow) ToNode(name string) ([]string, error)
- 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) GetExecutionError() *core.ExecutionError
- func (_m *ExecutableWorkflowNodeStatus) GetWorkflowNodePhase() v1alpha1.WorkflowNodePhase
- func (_m *ExecutableWorkflowNodeStatus) OnGetExecutionError() *ExecutableWorkflowNodeStatus_GetExecutionError
- func (_m *ExecutableWorkflowNodeStatus) OnGetExecutionErrorMatch(matchers ...interface{}) *ExecutableWorkflowNodeStatus_GetExecutionError
- func (_m *ExecutableWorkflowNodeStatus) OnGetWorkflowNodePhase() *ExecutableWorkflowNodeStatus_GetWorkflowNodePhase
- func (_m *ExecutableWorkflowNodeStatus) OnGetWorkflowNodePhaseMatch(matchers ...interface{}) *ExecutableWorkflowNodeStatus_GetWorkflowNodePhase
- type ExecutableWorkflowNodeStatus_GetExecutionError
- type ExecutableWorkflowNodeStatus_GetWorkflowNodePhase
- type ExecutableWorkflowNode_GetLaunchPlanRefID
- type 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) GetExecutionError() *core.ExecutionError
- 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) OnGetExecutionError() *ExecutableWorkflowStatus_GetExecutionError
- func (_m *ExecutableWorkflowStatus) OnGetExecutionErrorMatch(matchers ...interface{}) *ExecutableWorkflowStatus_GetExecutionError
- 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, err *core.ExecutionError)
- type ExecutableWorkflowStatus_ConstructNodeDataDir
- type ExecutableWorkflowStatus_GetDataDir
- type ExecutableWorkflowStatus_GetExecutionError
- type ExecutableWorkflowStatus_GetLastUpdatedAt
- type ExecutableWorkflowStatus_GetMessage
- type ExecutableWorkflowStatus_GetNodeExecutionStatus
- type ExecutableWorkflowStatus_GetOutputReference
- type ExecutableWorkflowStatus_GetPhase
- type ExecutableWorkflowStatus_GetStartedAt
- type ExecutableWorkflowStatus_GetStoppedAt
- type ExecutableWorkflowStatus_IsTerminated
- type ExecutableWorkflow_FindSubWorkflow
- type ExecutableWorkflow_FromNode
- type ExecutableWorkflow_GetAnnotations
- type ExecutableWorkflow_GetConnections
- type ExecutableWorkflow_GetCreationTimestamp
- type ExecutableWorkflow_GetExecutionID
- type ExecutableWorkflow_GetExecutionStatus
- type ExecutableWorkflow_GetID
- type ExecutableWorkflow_GetK8sWorkflowID
- type ExecutableWorkflow_GetLabels
- type ExecutableWorkflow_GetName
- type ExecutableWorkflow_GetNamespace
- type ExecutableWorkflow_GetNode
- type ExecutableWorkflow_GetNodeExecutionStatus
- type ExecutableWorkflow_GetNodes
- type ExecutableWorkflow_GetOnFailureNode
- type ExecutableWorkflow_GetOutputBindings
- type ExecutableWorkflow_GetOutputs
- type ExecutableWorkflow_GetOwnerReference
- type ExecutableWorkflow_GetServiceAccountName
- type ExecutableWorkflow_GetTask
- type ExecutableWorkflow_IsInterruptible
- type ExecutableWorkflow_StartNode
- type ExecutableWorkflow_ToNode
- type ExecutionTimeInfo
- func (_m *ExecutionTimeInfo) GetLastUpdatedAt() *v1.Time
- func (_m *ExecutionTimeInfo) GetStartedAt() *v1.Time
- func (_m *ExecutionTimeInfo) GetStoppedAt() *v1.Time
- func (_m *ExecutionTimeInfo) OnGetLastUpdatedAt() *ExecutionTimeInfo_GetLastUpdatedAt
- func (_m *ExecutionTimeInfo) OnGetLastUpdatedAtMatch(matchers ...interface{}) *ExecutionTimeInfo_GetLastUpdatedAt
- func (_m *ExecutionTimeInfo) OnGetStartedAt() *ExecutionTimeInfo_GetStartedAt
- func (_m *ExecutionTimeInfo) OnGetStartedAtMatch(matchers ...interface{}) *ExecutionTimeInfo_GetStartedAt
- func (_m *ExecutionTimeInfo) OnGetStoppedAt() *ExecutionTimeInfo_GetStoppedAt
- func (_m *ExecutionTimeInfo) OnGetStoppedAtMatch(matchers ...interface{}) *ExecutionTimeInfo_GetStoppedAt
- type ExecutionTimeInfo_GetLastUpdatedAt
- type ExecutionTimeInfo_GetStartedAt
- type ExecutionTimeInfo_GetStoppedAt
- type Meta
- func (_m *Meta) GetAnnotations() map[string]string
- func (_m *Meta) GetCreationTimestamp() v1.Time
- func (_m *Meta) GetExecutionID() v1alpha1.WorkflowExecutionIdentifier
- func (_m *Meta) GetK8sWorkflowID() types.NamespacedName
- func (_m *Meta) GetLabels() map[string]string
- func (_m *Meta) GetName() string
- func (_m *Meta) GetNamespace() string
- func (_m *Meta) GetOwnerReference() v1.OwnerReference
- func (_m *Meta) GetServiceAccountName() string
- func (_m *Meta) IsInterruptible() bool
- func (_m *Meta) OnGetAnnotations() *Meta_GetAnnotations
- func (_m *Meta) OnGetAnnotationsMatch(matchers ...interface{}) *Meta_GetAnnotations
- func (_m *Meta) OnGetCreationTimestamp() *Meta_GetCreationTimestamp
- func (_m *Meta) OnGetCreationTimestampMatch(matchers ...interface{}) *Meta_GetCreationTimestamp
- func (_m *Meta) OnGetExecutionID() *Meta_GetExecutionID
- func (_m *Meta) OnGetExecutionIDMatch(matchers ...interface{}) *Meta_GetExecutionID
- func (_m *Meta) OnGetK8sWorkflowID() *Meta_GetK8sWorkflowID
- func (_m *Meta) OnGetK8sWorkflowIDMatch(matchers ...interface{}) *Meta_GetK8sWorkflowID
- func (_m *Meta) OnGetLabels() *Meta_GetLabels
- func (_m *Meta) OnGetLabelsMatch(matchers ...interface{}) *Meta_GetLabels
- func (_m *Meta) OnGetName() *Meta_GetName
- func (_m *Meta) OnGetNameMatch(matchers ...interface{}) *Meta_GetName
- func (_m *Meta) OnGetNamespace() *Meta_GetNamespace
- func (_m *Meta) OnGetNamespaceMatch(matchers ...interface{}) *Meta_GetNamespace
- func (_m *Meta) OnGetOwnerReference() *Meta_GetOwnerReference
- func (_m *Meta) OnGetOwnerReferenceMatch(matchers ...interface{}) *Meta_GetOwnerReference
- func (_m *Meta) OnGetServiceAccountName() *Meta_GetServiceAccountName
- func (_m *Meta) OnGetServiceAccountNameMatch(matchers ...interface{}) *Meta_GetServiceAccountName
- func (_m *Meta) OnIsInterruptible() *Meta_IsInterruptible
- func (_m *Meta) OnIsInterruptibleMatch(matchers ...interface{}) *Meta_IsInterruptible
- type MetaExtended
- func (_m *MetaExtended) FindSubWorkflow(subID string) v1alpha1.ExecutableSubWorkflow
- func (_m *MetaExtended) GetAnnotations() map[string]string
- func (_m *MetaExtended) GetCreationTimestamp() v1.Time
- func (_m *MetaExtended) GetExecutionID() v1alpha1.WorkflowExecutionIdentifier
- func (_m *MetaExtended) GetExecutionStatus() v1alpha1.ExecutableWorkflowStatus
- func (_m *MetaExtended) GetK8sWorkflowID() types.NamespacedName
- func (_m *MetaExtended) GetLabels() map[string]string
- func (_m *MetaExtended) GetName() string
- func (_m *MetaExtended) GetNamespace() string
- func (_m *MetaExtended) GetOwnerReference() v1.OwnerReference
- func (_m *MetaExtended) GetServiceAccountName() string
- func (_m *MetaExtended) GetTask(id string) (v1alpha1.ExecutableTask, error)
- func (_m *MetaExtended) IsInterruptible() bool
- func (_m *MetaExtended) OnFindSubWorkflow(subID string) *MetaExtended_FindSubWorkflow
- func (_m *MetaExtended) OnFindSubWorkflowMatch(matchers ...interface{}) *MetaExtended_FindSubWorkflow
- func (_m *MetaExtended) OnGetAnnotations() *MetaExtended_GetAnnotations
- func (_m *MetaExtended) OnGetAnnotationsMatch(matchers ...interface{}) *MetaExtended_GetAnnotations
- func (_m *MetaExtended) OnGetCreationTimestamp() *MetaExtended_GetCreationTimestamp
- func (_m *MetaExtended) OnGetCreationTimestampMatch(matchers ...interface{}) *MetaExtended_GetCreationTimestamp
- func (_m *MetaExtended) OnGetExecutionID() *MetaExtended_GetExecutionID
- func (_m *MetaExtended) OnGetExecutionIDMatch(matchers ...interface{}) *MetaExtended_GetExecutionID
- func (_m *MetaExtended) OnGetExecutionStatus() *MetaExtended_GetExecutionStatus
- func (_m *MetaExtended) OnGetExecutionStatusMatch(matchers ...interface{}) *MetaExtended_GetExecutionStatus
- func (_m *MetaExtended) OnGetK8sWorkflowID() *MetaExtended_GetK8sWorkflowID
- func (_m *MetaExtended) OnGetK8sWorkflowIDMatch(matchers ...interface{}) *MetaExtended_GetK8sWorkflowID
- func (_m *MetaExtended) OnGetLabels() *MetaExtended_GetLabels
- func (_m *MetaExtended) OnGetLabelsMatch(matchers ...interface{}) *MetaExtended_GetLabels
- func (_m *MetaExtended) OnGetName() *MetaExtended_GetName
- func (_m *MetaExtended) OnGetNameMatch(matchers ...interface{}) *MetaExtended_GetName
- func (_m *MetaExtended) OnGetNamespace() *MetaExtended_GetNamespace
- func (_m *MetaExtended) OnGetNamespaceMatch(matchers ...interface{}) *MetaExtended_GetNamespace
- func (_m *MetaExtended) OnGetOwnerReference() *MetaExtended_GetOwnerReference
- func (_m *MetaExtended) OnGetOwnerReferenceMatch(matchers ...interface{}) *MetaExtended_GetOwnerReference
- func (_m *MetaExtended) OnGetServiceAccountName() *MetaExtended_GetServiceAccountName
- func (_m *MetaExtended) OnGetServiceAccountNameMatch(matchers ...interface{}) *MetaExtended_GetServiceAccountName
- func (_m *MetaExtended) OnGetTask(id string) *MetaExtended_GetTask
- func (_m *MetaExtended) OnGetTaskMatch(matchers ...interface{}) *MetaExtended_GetTask
- func (_m *MetaExtended) OnIsInterruptible() *MetaExtended_IsInterruptible
- func (_m *MetaExtended) OnIsInterruptibleMatch(matchers ...interface{}) *MetaExtended_IsInterruptible
- type MetaExtended_FindSubWorkflow
- type MetaExtended_GetAnnotations
- type MetaExtended_GetCreationTimestamp
- type MetaExtended_GetExecutionID
- type MetaExtended_GetExecutionStatus
- type MetaExtended_GetK8sWorkflowID
- type MetaExtended_GetLabels
- type MetaExtended_GetName
- type MetaExtended_GetNamespace
- type MetaExtended_GetOwnerReference
- type MetaExtended_GetServiceAccountName
- type MetaExtended_GetTask
- type MetaExtended_IsInterruptible
- type Meta_GetAnnotations
- type Meta_GetCreationTimestamp
- type Meta_GetExecutionID
- type Meta_GetK8sWorkflowID
- type Meta_GetLabels
- type Meta_GetName
- type Meta_GetNamespace
- type Meta_GetOwnerReference
- type Meta_GetServiceAccountName
- type Meta_IsInterruptible
- type Mutable
- 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
- type MutableBranchNodeStatus_GetPhase
- type MutableBranchNodeStatus_IsDirty
- type MutableDynamicNodeStatus
- func (_m *MutableDynamicNodeStatus) GetDynamicNodePhase() v1alpha1.DynamicNodePhase
- func (_m *MutableDynamicNodeStatus) GetDynamicNodeReason() string
- func (_m *MutableDynamicNodeStatus) GetExecutionError() *core.ExecutionError
- 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) OnGetExecutionError() *MutableDynamicNodeStatus_GetExecutionError
- func (_m *MutableDynamicNodeStatus) OnGetExecutionErrorMatch(matchers ...interface{}) *MutableDynamicNodeStatus_GetExecutionError
- 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)
- func (_m *MutableDynamicNodeStatus) SetExecutionError(executionError *core.ExecutionError)
- type MutableDynamicNodeStatus_GetDynamicNodePhase
- type MutableDynamicNodeStatus_GetDynamicNodeReason
- type MutableDynamicNodeStatus_GetExecutionError
- type 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) IncrementSystemFailures() 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) OnIncrementSystemFailures() *MutableNodeStatus_IncrementSystemFailures
- func (_m *MutableNodeStatus) OnIncrementSystemFailuresMatch(matchers ...interface{}) *MutableNodeStatus_IncrementSystemFailures
- 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
- type MutableNodeStatus_GetDynamicNodeStatus
- type MutableNodeStatus_GetOrCreateBranchStatus
- type MutableNodeStatus_GetOrCreateDynamicNodeStatus
- type MutableNodeStatus_GetOrCreateTaskStatus
- type MutableNodeStatus_GetOrCreateWorkflowStatus
- type MutableNodeStatus_GetTaskStatus
- type MutableNodeStatus_GetWorkflowStatus
- type MutableNodeStatus_IncrementAttempts
- type MutableNodeStatus_IncrementSystemFailures
- type 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
- type 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
- type MutableTaskNodeStatus_GetLastPhaseUpdatedAt
- type MutableTaskNodeStatus_GetPhase
- type MutableTaskNodeStatus_GetPhaseVersion
- type MutableTaskNodeStatus_GetPluginState
- type MutableTaskNodeStatus_GetPluginStateVersion
- type MutableTaskNodeStatus_IsDirty
- type MutableWorkflowNodeStatus
- func (_m *MutableWorkflowNodeStatus) GetExecutionError() *core.ExecutionError
- func (_m *MutableWorkflowNodeStatus) GetWorkflowNodePhase() v1alpha1.WorkflowNodePhase
- func (_m *MutableWorkflowNodeStatus) IsDirty() bool
- func (_m *MutableWorkflowNodeStatus) OnGetExecutionError() *MutableWorkflowNodeStatus_GetExecutionError
- func (_m *MutableWorkflowNodeStatus) OnGetExecutionErrorMatch(matchers ...interface{}) *MutableWorkflowNodeStatus_GetExecutionError
- 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) SetExecutionError(executionError *core.ExecutionError)
- func (_m *MutableWorkflowNodeStatus) SetWorkflowNodePhase(phase v1alpha1.WorkflowNodePhase)
- type MutableWorkflowNodeStatus_GetExecutionError
- type MutableWorkflowNodeStatus_GetWorkflowNodePhase
- type MutableWorkflowNodeStatus_IsDirty
- type Mutable_IsDirty
- type NodeGetter
- type NodeGetter_GetNode
- 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
- type NodeStatusVisitor
- type SubWorkflowGetter
- type SubWorkflowGetter_FindSubWorkflow
- type TaskDetailsGetter
- type 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) IsInterruptible() bool
- 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
- func (_m *WorkflowMeta) OnIsInterruptible() *WorkflowMeta_IsInterruptible
- func (_m *WorkflowMeta) OnIsInterruptibleMatch(matchers ...interface{}) *WorkflowMeta_IsInterruptible
- 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) IsInterruptible() bool
- 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
- func (_m *WorkflowMetaExtended) OnIsInterruptible() *WorkflowMetaExtended_IsInterruptible
- func (_m *WorkflowMetaExtended) OnIsInterruptibleMatch(matchers ...interface{}) *WorkflowMetaExtended_IsInterruptible
- type WorkflowMetaExtended_FindSubWorkflow
- type WorkflowMetaExtended_GetAnnotations
- type WorkflowMetaExtended_GetCreationTimestamp
- type WorkflowMetaExtended_GetExecutionID
- type WorkflowMetaExtended_GetExecutionStatus
- type WorkflowMetaExtended_GetK8sWorkflowID
- type WorkflowMetaExtended_GetLabels
- type WorkflowMetaExtended_GetName
- type WorkflowMetaExtended_GetNamespace
- type WorkflowMetaExtended_GetOwnerReference
- type WorkflowMetaExtended_GetServiceAccountName
- type WorkflowMetaExtended_GetTask
- type WorkflowMetaExtended_IsInterruptible
- type WorkflowMeta_GetAnnotations
- type WorkflowMeta_GetCreationTimestamp
- type WorkflowMeta_GetExecutionID
- type WorkflowMeta_GetK8sWorkflowID
- type WorkflowMeta_GetLabels
- type WorkflowMeta_GetName
- type WorkflowMeta_GetNamespace
- type WorkflowMeta_GetOwnerReference
- type WorkflowMeta_GetServiceAccountName
- type WorkflowMeta_IsInterruptible
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BaseNode ¶
BaseNode is an autogenerated mock type for the BaseNode type
func (*BaseNode) OnGetID ¶ added in v0.1.13
func (_m *BaseNode) OnGetID() *BaseNode_GetID
func (*BaseNode) OnGetIDMatch ¶ added in v0.1.13
func (_m *BaseNode) OnGetIDMatch(matchers ...interface{}) *BaseNode_GetID
func (*BaseNode) OnGetKind ¶ added in v0.1.13
func (_m *BaseNode) OnGetKind() *BaseNode_GetKind
func (*BaseNode) OnGetKindMatch ¶ added in v0.1.13
func (_m *BaseNode) OnGetKindMatch(matchers ...interface{}) *BaseNode_GetKind
type BaseNode_GetID ¶ added in v0.1.13
func (BaseNode_GetID) Return ¶ added in v0.1.13
func (_m BaseNode_GetID) Return(_a0 string) *BaseNode_GetID
type BaseNode_GetKind ¶ added in v0.1.13
func (BaseNode_GetKind) Return ¶ added in v0.1.13
func (_m BaseNode_GetKind) Return(_a0 v1alpha1.NodeKind) *BaseNode_GetKind
type BaseWorkflow ¶
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 ¶ added in v0.1.13
func (_m *BaseWorkflow) OnFromNode(name string) *BaseWorkflow_FromNode
func (*BaseWorkflow) OnFromNodeMatch ¶ added in v0.1.13
func (_m *BaseWorkflow) OnFromNodeMatch(matchers ...interface{}) *BaseWorkflow_FromNode
func (*BaseWorkflow) OnGetID ¶ added in v0.1.13
func (_m *BaseWorkflow) OnGetID() *BaseWorkflow_GetID
func (*BaseWorkflow) OnGetIDMatch ¶ added in v0.1.13
func (_m *BaseWorkflow) OnGetIDMatch(matchers ...interface{}) *BaseWorkflow_GetID
func (*BaseWorkflow) OnGetNode ¶ added in v0.1.13
func (_m *BaseWorkflow) OnGetNode(nodeID string) *BaseWorkflow_GetNode
func (*BaseWorkflow) OnGetNodeMatch ¶ added in v0.1.13
func (_m *BaseWorkflow) OnGetNodeMatch(matchers ...interface{}) *BaseWorkflow_GetNode
func (*BaseWorkflow) OnStartNode ¶ added in v0.1.13
func (_m *BaseWorkflow) OnStartNode() *BaseWorkflow_StartNode
func (*BaseWorkflow) OnStartNodeMatch ¶ added in v0.1.13
func (_m *BaseWorkflow) OnStartNodeMatch(matchers ...interface{}) *BaseWorkflow_StartNode
func (*BaseWorkflow) OnToNode ¶ added in v0.2.28
func (_m *BaseWorkflow) OnToNode(name string) *BaseWorkflow_ToNode
func (*BaseWorkflow) OnToNodeMatch ¶ added in v0.2.28
func (_m *BaseWorkflow) OnToNodeMatch(matchers ...interface{}) *BaseWorkflow_ToNode
func (*BaseWorkflow) StartNode ¶
func (_m *BaseWorkflow) StartNode() v1alpha1.ExecutableNode
StartNode provides a mock function with given fields:
type BaseWorkflowWithStatus ¶
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 ¶ added in v0.1.13
func (_m *BaseWorkflowWithStatus) OnFromNode(name string) *BaseWorkflowWithStatus_FromNode
func (*BaseWorkflowWithStatus) OnFromNodeMatch ¶ added in v0.1.13
func (_m *BaseWorkflowWithStatus) OnFromNodeMatch(matchers ...interface{}) *BaseWorkflowWithStatus_FromNode
func (*BaseWorkflowWithStatus) OnGetID ¶ added in v0.1.13
func (_m *BaseWorkflowWithStatus) OnGetID() *BaseWorkflowWithStatus_GetID
func (*BaseWorkflowWithStatus) OnGetIDMatch ¶ added in v0.1.13
func (_m *BaseWorkflowWithStatus) OnGetIDMatch(matchers ...interface{}) *BaseWorkflowWithStatus_GetID
func (*BaseWorkflowWithStatus) OnGetNode ¶ added in v0.1.13
func (_m *BaseWorkflowWithStatus) OnGetNode(nodeID string) *BaseWorkflowWithStatus_GetNode
func (*BaseWorkflowWithStatus) OnGetNodeExecutionStatus ¶ added in v0.1.13
func (_m *BaseWorkflowWithStatus) OnGetNodeExecutionStatus(ctx context.Context, id string) *BaseWorkflowWithStatus_GetNodeExecutionStatus
func (*BaseWorkflowWithStatus) OnGetNodeExecutionStatusMatch ¶ added in v0.1.13
func (_m *BaseWorkflowWithStatus) OnGetNodeExecutionStatusMatch(matchers ...interface{}) *BaseWorkflowWithStatus_GetNodeExecutionStatus
func (*BaseWorkflowWithStatus) OnGetNodeMatch ¶ added in v0.1.13
func (_m *BaseWorkflowWithStatus) OnGetNodeMatch(matchers ...interface{}) *BaseWorkflowWithStatus_GetNode
func (*BaseWorkflowWithStatus) OnStartNode ¶ added in v0.1.13
func (_m *BaseWorkflowWithStatus) OnStartNode() *BaseWorkflowWithStatus_StartNode
func (*BaseWorkflowWithStatus) OnStartNodeMatch ¶ added in v0.1.13
func (_m *BaseWorkflowWithStatus) OnStartNodeMatch(matchers ...interface{}) *BaseWorkflowWithStatus_StartNode
func (*BaseWorkflowWithStatus) OnToNode ¶ added in v0.2.28
func (_m *BaseWorkflowWithStatus) OnToNode(name string) *BaseWorkflowWithStatus_ToNode
func (*BaseWorkflowWithStatus) OnToNodeMatch ¶ added in v0.2.28
func (_m *BaseWorkflowWithStatus) OnToNodeMatch(matchers ...interface{}) *BaseWorkflowWithStatus_ToNode
func (*BaseWorkflowWithStatus) StartNode ¶
func (_m *BaseWorkflowWithStatus) StartNode() v1alpha1.ExecutableNode
StartNode provides a mock function with given fields:
type BaseWorkflowWithStatus_FromNode ¶ added in v0.1.13
func (BaseWorkflowWithStatus_FromNode) Return ¶ added in v0.1.13
func (_m BaseWorkflowWithStatus_FromNode) Return(_a0 []string, _a1 error) *BaseWorkflowWithStatus_FromNode
type BaseWorkflowWithStatus_GetID ¶ added in v0.1.13
func (BaseWorkflowWithStatus_GetID) Return ¶ added in v0.1.13
func (_m BaseWorkflowWithStatus_GetID) Return(_a0 string) *BaseWorkflowWithStatus_GetID
type BaseWorkflowWithStatus_GetNode ¶ added in v0.1.13
func (BaseWorkflowWithStatus_GetNode) Return ¶ added in v0.1.13
func (_m BaseWorkflowWithStatus_GetNode) Return(_a0 v1alpha1.ExecutableNode, _a1 bool) *BaseWorkflowWithStatus_GetNode
type BaseWorkflowWithStatus_GetNodeExecutionStatus ¶ added in v0.1.13
type BaseWorkflowWithStatus_StartNode ¶ added in v0.1.13
func (BaseWorkflowWithStatus_StartNode) Return ¶ added in v0.1.13
func (_m BaseWorkflowWithStatus_StartNode) Return(_a0 v1alpha1.ExecutableNode) *BaseWorkflowWithStatus_StartNode
type BaseWorkflowWithStatus_ToNode ¶ added in v0.2.28
func (BaseWorkflowWithStatus_ToNode) Return ¶ added in v0.2.28
func (_m BaseWorkflowWithStatus_ToNode) Return(_a0 []string, _a1 error) *BaseWorkflowWithStatus_ToNode
type BaseWorkflow_FromNode ¶ added in v0.1.13
func (BaseWorkflow_FromNode) Return ¶ added in v0.1.13
func (_m BaseWorkflow_FromNode) Return(_a0 []string, _a1 error) *BaseWorkflow_FromNode
type BaseWorkflow_GetID ¶ added in v0.1.13
func (BaseWorkflow_GetID) Return ¶ added in v0.1.13
func (_m BaseWorkflow_GetID) Return(_a0 string) *BaseWorkflow_GetID
type BaseWorkflow_GetNode ¶ added in v0.1.13
func (BaseWorkflow_GetNode) Return ¶ added in v0.1.13
func (_m BaseWorkflow_GetNode) Return(_a0 v1alpha1.ExecutableNode, _a1 bool) *BaseWorkflow_GetNode
type BaseWorkflow_StartNode ¶ added in v0.1.13
func (BaseWorkflow_StartNode) Return ¶ added in v0.1.13
func (_m BaseWorkflow_StartNode) Return(_a0 v1alpha1.ExecutableNode) *BaseWorkflow_StartNode
type BaseWorkflow_ToNode ¶ added in v0.2.28
func (BaseWorkflow_ToNode) Return ¶ added in v0.2.28
func (_m BaseWorkflow_ToNode) Return(_a0 []string, _a1 error) *BaseWorkflow_ToNode
type ExecutableBranchNode ¶
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 ¶ added in v0.1.13
func (_m *ExecutableBranchNode) OnGetElse() *ExecutableBranchNode_GetElse
func (*ExecutableBranchNode) OnGetElseFail ¶ added in v0.1.13
func (_m *ExecutableBranchNode) OnGetElseFail() *ExecutableBranchNode_GetElseFail
func (*ExecutableBranchNode) OnGetElseFailMatch ¶ added in v0.1.13
func (_m *ExecutableBranchNode) OnGetElseFailMatch(matchers ...interface{}) *ExecutableBranchNode_GetElseFail
func (*ExecutableBranchNode) OnGetElseIf ¶ added in v0.1.13
func (_m *ExecutableBranchNode) OnGetElseIf() *ExecutableBranchNode_GetElseIf
func (*ExecutableBranchNode) OnGetElseIfMatch ¶ added in v0.1.13
func (_m *ExecutableBranchNode) OnGetElseIfMatch(matchers ...interface{}) *ExecutableBranchNode_GetElseIf
func (*ExecutableBranchNode) OnGetElseMatch ¶ added in v0.1.13
func (_m *ExecutableBranchNode) OnGetElseMatch(matchers ...interface{}) *ExecutableBranchNode_GetElse
func (*ExecutableBranchNode) OnGetIf ¶ added in v0.1.13
func (_m *ExecutableBranchNode) OnGetIf() *ExecutableBranchNode_GetIf
func (*ExecutableBranchNode) OnGetIfMatch ¶ added in v0.1.13
func (_m *ExecutableBranchNode) OnGetIfMatch(matchers ...interface{}) *ExecutableBranchNode_GetIf
type ExecutableBranchNodeStatus ¶
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 ¶ added in v0.1.13
func (_m *ExecutableBranchNodeStatus) OnGetFinalizedNode() *ExecutableBranchNodeStatus_GetFinalizedNode
func (*ExecutableBranchNodeStatus) OnGetFinalizedNodeMatch ¶ added in v0.1.13
func (_m *ExecutableBranchNodeStatus) OnGetFinalizedNodeMatch(matchers ...interface{}) *ExecutableBranchNodeStatus_GetFinalizedNode
func (*ExecutableBranchNodeStatus) OnGetPhase ¶ added in v0.1.13
func (_m *ExecutableBranchNodeStatus) OnGetPhase() *ExecutableBranchNodeStatus_GetPhase
func (*ExecutableBranchNodeStatus) OnGetPhaseMatch ¶ added in v0.1.13
func (_m *ExecutableBranchNodeStatus) OnGetPhaseMatch(matchers ...interface{}) *ExecutableBranchNodeStatus_GetPhase
type ExecutableBranchNodeStatus_GetFinalizedNode ¶ added in v0.1.13
func (ExecutableBranchNodeStatus_GetFinalizedNode) Return ¶ added in v0.1.13
func (_m ExecutableBranchNodeStatus_GetFinalizedNode) Return(_a0 *string) *ExecutableBranchNodeStatus_GetFinalizedNode
type ExecutableBranchNodeStatus_GetPhase ¶ added in v0.1.13
func (ExecutableBranchNodeStatus_GetPhase) Return ¶ added in v0.1.13
func (_m ExecutableBranchNodeStatus_GetPhase) Return(_a0 v1alpha1.BranchNodePhase) *ExecutableBranchNodeStatus_GetPhase
type ExecutableBranchNode_GetElse ¶ added in v0.1.13
func (ExecutableBranchNode_GetElse) Return ¶ added in v0.1.13
func (_m ExecutableBranchNode_GetElse) Return(_a0 *string) *ExecutableBranchNode_GetElse
type ExecutableBranchNode_GetElseFail ¶ added in v0.1.13
func (ExecutableBranchNode_GetElseFail) Return ¶ added in v0.1.13
func (_m ExecutableBranchNode_GetElseFail) Return(_a0 *core.Error) *ExecutableBranchNode_GetElseFail
type ExecutableBranchNode_GetElseIf ¶ added in v0.1.13
func (ExecutableBranchNode_GetElseIf) Return ¶ added in v0.1.13
func (_m ExecutableBranchNode_GetElseIf) Return(_a0 []v1alpha1.ExecutableIfBlock) *ExecutableBranchNode_GetElseIf
type ExecutableBranchNode_GetIf ¶ added in v0.1.13
func (ExecutableBranchNode_GetIf) Return ¶ added in v0.1.13
func (_m ExecutableBranchNode_GetIf) Return(_a0 v1alpha1.ExecutableIfBlock) *ExecutableBranchNode_GetIf
type ExecutableDynamicNodeStatus ¶
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 ¶ added in v0.1.15
func (_m *ExecutableDynamicNodeStatus) GetDynamicNodeReason() string
GetDynamicNodeReason provides a mock function with given fields:
func (*ExecutableDynamicNodeStatus) GetExecutionError ¶ added in v0.2.43
func (_m *ExecutableDynamicNodeStatus) GetExecutionError() *core.ExecutionError
GetExecutionError provides a mock function with given fields:
func (*ExecutableDynamicNodeStatus) OnGetDynamicNodePhase ¶ added in v0.1.13
func (_m *ExecutableDynamicNodeStatus) OnGetDynamicNodePhase() *ExecutableDynamicNodeStatus_GetDynamicNodePhase
func (*ExecutableDynamicNodeStatus) OnGetDynamicNodePhaseMatch ¶ added in v0.1.13
func (_m *ExecutableDynamicNodeStatus) OnGetDynamicNodePhaseMatch(matchers ...interface{}) *ExecutableDynamicNodeStatus_GetDynamicNodePhase
func (*ExecutableDynamicNodeStatus) OnGetDynamicNodeReason ¶ added in v0.1.15
func (_m *ExecutableDynamicNodeStatus) OnGetDynamicNodeReason() *ExecutableDynamicNodeStatus_GetDynamicNodeReason
func (*ExecutableDynamicNodeStatus) OnGetDynamicNodeReasonMatch ¶ added in v0.1.15
func (_m *ExecutableDynamicNodeStatus) OnGetDynamicNodeReasonMatch(matchers ...interface{}) *ExecutableDynamicNodeStatus_GetDynamicNodeReason
func (*ExecutableDynamicNodeStatus) OnGetExecutionError ¶ added in v0.2.43
func (_m *ExecutableDynamicNodeStatus) OnGetExecutionError() *ExecutableDynamicNodeStatus_GetExecutionError
func (*ExecutableDynamicNodeStatus) OnGetExecutionErrorMatch ¶ added in v0.2.43
func (_m *ExecutableDynamicNodeStatus) OnGetExecutionErrorMatch(matchers ...interface{}) *ExecutableDynamicNodeStatus_GetExecutionError
type ExecutableDynamicNodeStatus_GetDynamicNodePhase ¶ added in v0.1.13
type ExecutableDynamicNodeStatus_GetDynamicNodeReason ¶ added in v0.1.15
type ExecutableDynamicNodeStatus_GetExecutionError ¶ added in v0.2.43
func (ExecutableDynamicNodeStatus_GetExecutionError) Return ¶ added in v0.2.43
func (_m ExecutableDynamicNodeStatus_GetExecutionError) Return(_a0 *core.ExecutionError) *ExecutableDynamicNodeStatus_GetExecutionError
type ExecutableIfBlock ¶
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 ¶ added in v0.1.13
func (_m *ExecutableIfBlock) OnGetCondition() *ExecutableIfBlock_GetCondition
func (*ExecutableIfBlock) OnGetConditionMatch ¶ added in v0.1.13
func (_m *ExecutableIfBlock) OnGetConditionMatch(matchers ...interface{}) *ExecutableIfBlock_GetCondition
func (*ExecutableIfBlock) OnGetThenNode ¶ added in v0.1.13
func (_m *ExecutableIfBlock) OnGetThenNode() *ExecutableIfBlock_GetThenNode
func (*ExecutableIfBlock) OnGetThenNodeMatch ¶ added in v0.1.13
func (_m *ExecutableIfBlock) OnGetThenNodeMatch(matchers ...interface{}) *ExecutableIfBlock_GetThenNode
type ExecutableIfBlock_GetCondition ¶ added in v0.1.13
func (ExecutableIfBlock_GetCondition) Return ¶ added in v0.1.13
func (_m ExecutableIfBlock_GetCondition) Return(_a0 *core.BooleanExpression) *ExecutableIfBlock_GetCondition
type ExecutableIfBlock_GetThenNode ¶ added in v0.1.13
func (ExecutableIfBlock_GetThenNode) Return ¶ added in v0.1.13
func (_m ExecutableIfBlock_GetThenNode) Return(_a0 *string) *ExecutableIfBlock_GetThenNode
type ExecutableNode ¶
ExecutableNode is an autogenerated mock type for the ExecutableNode type
func (*ExecutableNode) GetActiveDeadline ¶ added in v0.1.17
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 ¶ added in v0.1.17
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) IsInterruptible ¶ added in v0.2.15
func (_m *ExecutableNode) IsInterruptible() *bool
IsInterruptible 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 ¶ added in v0.1.17
func (_m *ExecutableNode) OnGetActiveDeadline() *ExecutableNode_GetActiveDeadline
func (*ExecutableNode) OnGetActiveDeadlineMatch ¶ added in v0.1.17
func (_m *ExecutableNode) OnGetActiveDeadlineMatch(matchers ...interface{}) *ExecutableNode_GetActiveDeadline
func (*ExecutableNode) OnGetBranchNode ¶ added in v0.1.13
func (_m *ExecutableNode) OnGetBranchNode() *ExecutableNode_GetBranchNode
func (*ExecutableNode) OnGetBranchNodeMatch ¶ added in v0.1.13
func (_m *ExecutableNode) OnGetBranchNodeMatch(matchers ...interface{}) *ExecutableNode_GetBranchNode
func (*ExecutableNode) OnGetConfig ¶ added in v0.1.13
func (_m *ExecutableNode) OnGetConfig() *ExecutableNode_GetConfig
func (*ExecutableNode) OnGetConfigMatch ¶ added in v0.1.13
func (_m *ExecutableNode) OnGetConfigMatch(matchers ...interface{}) *ExecutableNode_GetConfig
func (*ExecutableNode) OnGetExecutionDeadline ¶ added in v0.1.17
func (_m *ExecutableNode) OnGetExecutionDeadline() *ExecutableNode_GetExecutionDeadline
func (*ExecutableNode) OnGetExecutionDeadlineMatch ¶ added in v0.1.17
func (_m *ExecutableNode) OnGetExecutionDeadlineMatch(matchers ...interface{}) *ExecutableNode_GetExecutionDeadline
func (*ExecutableNode) OnGetID ¶ added in v0.1.13
func (_m *ExecutableNode) OnGetID() *ExecutableNode_GetID
func (*ExecutableNode) OnGetIDMatch ¶ added in v0.1.13
func (_m *ExecutableNode) OnGetIDMatch(matchers ...interface{}) *ExecutableNode_GetID
func (*ExecutableNode) OnGetInputBindings ¶ added in v0.1.13
func (_m *ExecutableNode) OnGetInputBindings() *ExecutableNode_GetInputBindings
func (*ExecutableNode) OnGetInputBindingsMatch ¶ added in v0.1.13
func (_m *ExecutableNode) OnGetInputBindingsMatch(matchers ...interface{}) *ExecutableNode_GetInputBindings
func (*ExecutableNode) OnGetKind ¶ added in v0.1.13
func (_m *ExecutableNode) OnGetKind() *ExecutableNode_GetKind
func (*ExecutableNode) OnGetKindMatch ¶ added in v0.1.13
func (_m *ExecutableNode) OnGetKindMatch(matchers ...interface{}) *ExecutableNode_GetKind
func (*ExecutableNode) OnGetOutputAlias ¶ added in v0.1.13
func (_m *ExecutableNode) OnGetOutputAlias() *ExecutableNode_GetOutputAlias
func (*ExecutableNode) OnGetOutputAliasMatch ¶ added in v0.1.13
func (_m *ExecutableNode) OnGetOutputAliasMatch(matchers ...interface{}) *ExecutableNode_GetOutputAlias
func (*ExecutableNode) OnGetResources ¶ added in v0.1.13
func (_m *ExecutableNode) OnGetResources() *ExecutableNode_GetResources
func (*ExecutableNode) OnGetResourcesMatch ¶ added in v0.1.13
func (_m *ExecutableNode) OnGetResourcesMatch(matchers ...interface{}) *ExecutableNode_GetResources
func (*ExecutableNode) OnGetRetryStrategy ¶ added in v0.1.13
func (_m *ExecutableNode) OnGetRetryStrategy() *ExecutableNode_GetRetryStrategy
func (*ExecutableNode) OnGetRetryStrategyMatch ¶ added in v0.1.13
func (_m *ExecutableNode) OnGetRetryStrategyMatch(matchers ...interface{}) *ExecutableNode_GetRetryStrategy
func (*ExecutableNode) OnGetTaskID ¶ added in v0.1.13
func (_m *ExecutableNode) OnGetTaskID() *ExecutableNode_GetTaskID
func (*ExecutableNode) OnGetTaskIDMatch ¶ added in v0.1.13
func (_m *ExecutableNode) OnGetTaskIDMatch(matchers ...interface{}) *ExecutableNode_GetTaskID
func (*ExecutableNode) OnGetWorkflowNode ¶ added in v0.1.13
func (_m *ExecutableNode) OnGetWorkflowNode() *ExecutableNode_GetWorkflowNode
func (*ExecutableNode) OnGetWorkflowNodeMatch ¶ added in v0.1.13
func (_m *ExecutableNode) OnGetWorkflowNodeMatch(matchers ...interface{}) *ExecutableNode_GetWorkflowNode
func (*ExecutableNode) OnIsEndNode ¶ added in v0.1.13
func (_m *ExecutableNode) OnIsEndNode() *ExecutableNode_IsEndNode
func (*ExecutableNode) OnIsEndNodeMatch ¶ added in v0.1.13
func (_m *ExecutableNode) OnIsEndNodeMatch(matchers ...interface{}) *ExecutableNode_IsEndNode
func (*ExecutableNode) OnIsInterruptible ¶ added in v0.2.15
func (_m *ExecutableNode) OnIsInterruptible() *ExecutableNode_IsInterruptible
func (*ExecutableNode) OnIsInterruptibleMatch ¶ added in v0.2.15
func (_m *ExecutableNode) OnIsInterruptibleMatch(matchers ...interface{}) *ExecutableNode_IsInterruptible
func (*ExecutableNode) OnIsStartNode ¶ added in v0.1.13
func (_m *ExecutableNode) OnIsStartNode() *ExecutableNode_IsStartNode
func (*ExecutableNode) OnIsStartNodeMatch ¶ added in v0.1.13
func (_m *ExecutableNode) OnIsStartNodeMatch(matchers ...interface{}) *ExecutableNode_IsStartNode
type ExecutableNodeStatus ¶
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 ¶ added in v0.1.17
func (_m *ExecutableNodeStatus) ClearLastAttemptStartedAt()
ClearLastAttemptStartedAt provides a mock function with given fields:
func (*ExecutableNodeStatus) ClearSubNodeStatus ¶ added in v0.1.25
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 ¶ added in v0.1.13
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 ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) GetDynamicNodeStatus() v1alpha1.MutableDynamicNodeStatus
GetDynamicNodeStatus provides a mock function with given fields:
func (*ExecutableNodeStatus) GetExecutionError ¶ added in v0.2.33
func (_m *ExecutableNodeStatus) GetExecutionError() *core.ExecutionError
GetExecutionError provides a mock function with given fields:
func (*ExecutableNodeStatus) GetLastAttemptStartedAt ¶ added in v0.1.17
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 ¶ added in v0.1.27
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) GetSystemFailures ¶ added in v0.2.11
func (_m *ExecutableNodeStatus) GetSystemFailures() uint32
GetSystemFailures 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 ¶ added in v0.1.13
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 ¶ added in v0.1.13
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) IncrementSystemFailures ¶ added in v0.2.11
func (_m *ExecutableNodeStatus) IncrementSystemFailures() uint32
IncrementSystemFailures 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 ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnGetAttempts() *ExecutableNodeStatus_GetAttempts
func (*ExecutableNodeStatus) OnGetAttemptsMatch ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnGetAttemptsMatch(matchers ...interface{}) *ExecutableNodeStatus_GetAttempts
func (*ExecutableNodeStatus) OnGetBranchStatus ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnGetBranchStatus() *ExecutableNodeStatus_GetBranchStatus
func (*ExecutableNodeStatus) OnGetBranchStatusMatch ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnGetBranchStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetBranchStatus
func (*ExecutableNodeStatus) OnGetDataDir ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnGetDataDir() *ExecutableNodeStatus_GetDataDir
func (*ExecutableNodeStatus) OnGetDataDirMatch ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnGetDataDirMatch(matchers ...interface{}) *ExecutableNodeStatus_GetDataDir
func (*ExecutableNodeStatus) OnGetDynamicNodeStatus ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnGetDynamicNodeStatus() *ExecutableNodeStatus_GetDynamicNodeStatus
func (*ExecutableNodeStatus) OnGetDynamicNodeStatusMatch ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnGetDynamicNodeStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetDynamicNodeStatus
func (*ExecutableNodeStatus) OnGetExecutionError ¶ added in v0.2.33
func (_m *ExecutableNodeStatus) OnGetExecutionError() *ExecutableNodeStatus_GetExecutionError
func (*ExecutableNodeStatus) OnGetExecutionErrorMatch ¶ added in v0.2.33
func (_m *ExecutableNodeStatus) OnGetExecutionErrorMatch(matchers ...interface{}) *ExecutableNodeStatus_GetExecutionError
func (*ExecutableNodeStatus) OnGetLastAttemptStartedAt ¶ added in v0.1.17
func (_m *ExecutableNodeStatus) OnGetLastAttemptStartedAt() *ExecutableNodeStatus_GetLastAttemptStartedAt
func (*ExecutableNodeStatus) OnGetLastAttemptStartedAtMatch ¶ added in v0.1.17
func (_m *ExecutableNodeStatus) OnGetLastAttemptStartedAtMatch(matchers ...interface{}) *ExecutableNodeStatus_GetLastAttemptStartedAt
func (*ExecutableNodeStatus) OnGetLastUpdatedAt ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnGetLastUpdatedAt() *ExecutableNodeStatus_GetLastUpdatedAt
func (*ExecutableNodeStatus) OnGetLastUpdatedAtMatch ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnGetLastUpdatedAtMatch(matchers ...interface{}) *ExecutableNodeStatus_GetLastUpdatedAt
func (*ExecutableNodeStatus) OnGetMessage ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnGetMessage() *ExecutableNodeStatus_GetMessage
func (*ExecutableNodeStatus) OnGetMessageMatch ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnGetMessageMatch(matchers ...interface{}) *ExecutableNodeStatus_GetMessage
func (*ExecutableNodeStatus) OnGetNodeExecutionStatus ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnGetNodeExecutionStatus(ctx context.Context, id string) *ExecutableNodeStatus_GetNodeExecutionStatus
func (*ExecutableNodeStatus) OnGetNodeExecutionStatusMatch ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnGetNodeExecutionStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetNodeExecutionStatus
func (*ExecutableNodeStatus) OnGetOrCreateBranchStatus ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnGetOrCreateBranchStatus() *ExecutableNodeStatus_GetOrCreateBranchStatus
func (*ExecutableNodeStatus) OnGetOrCreateBranchStatusMatch ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnGetOrCreateBranchStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetOrCreateBranchStatus
func (*ExecutableNodeStatus) OnGetOrCreateDynamicNodeStatus ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnGetOrCreateDynamicNodeStatus() *ExecutableNodeStatus_GetOrCreateDynamicNodeStatus
func (*ExecutableNodeStatus) OnGetOrCreateDynamicNodeStatusMatch ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnGetOrCreateDynamicNodeStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetOrCreateDynamicNodeStatus
func (*ExecutableNodeStatus) OnGetOrCreateTaskStatus ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnGetOrCreateTaskStatus() *ExecutableNodeStatus_GetOrCreateTaskStatus
func (*ExecutableNodeStatus) OnGetOrCreateTaskStatusMatch ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnGetOrCreateTaskStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetOrCreateTaskStatus
func (*ExecutableNodeStatus) OnGetOrCreateWorkflowStatus ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnGetOrCreateWorkflowStatus() *ExecutableNodeStatus_GetOrCreateWorkflowStatus
func (*ExecutableNodeStatus) OnGetOrCreateWorkflowStatusMatch ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnGetOrCreateWorkflowStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetOrCreateWorkflowStatus
func (*ExecutableNodeStatus) OnGetOutputDir ¶ added in v0.1.27
func (_m *ExecutableNodeStatus) OnGetOutputDir() *ExecutableNodeStatus_GetOutputDir
func (*ExecutableNodeStatus) OnGetOutputDirMatch ¶ added in v0.1.27
func (_m *ExecutableNodeStatus) OnGetOutputDirMatch(matchers ...interface{}) *ExecutableNodeStatus_GetOutputDir
func (*ExecutableNodeStatus) OnGetParentNodeID ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnGetParentNodeID() *ExecutableNodeStatus_GetParentNodeID
func (*ExecutableNodeStatus) OnGetParentNodeIDMatch ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnGetParentNodeIDMatch(matchers ...interface{}) *ExecutableNodeStatus_GetParentNodeID
func (*ExecutableNodeStatus) OnGetParentTaskID ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnGetParentTaskID() *ExecutableNodeStatus_GetParentTaskID
func (*ExecutableNodeStatus) OnGetParentTaskIDMatch ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnGetParentTaskIDMatch(matchers ...interface{}) *ExecutableNodeStatus_GetParentTaskID
func (*ExecutableNodeStatus) OnGetPhase ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnGetPhase() *ExecutableNodeStatus_GetPhase
func (*ExecutableNodeStatus) OnGetPhaseMatch ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnGetPhaseMatch(matchers ...interface{}) *ExecutableNodeStatus_GetPhase
func (*ExecutableNodeStatus) OnGetQueuedAt ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnGetQueuedAt() *ExecutableNodeStatus_GetQueuedAt
func (*ExecutableNodeStatus) OnGetQueuedAtMatch ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnGetQueuedAtMatch(matchers ...interface{}) *ExecutableNodeStatus_GetQueuedAt
func (*ExecutableNodeStatus) OnGetStartedAt ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnGetStartedAt() *ExecutableNodeStatus_GetStartedAt
func (*ExecutableNodeStatus) OnGetStartedAtMatch ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnGetStartedAtMatch(matchers ...interface{}) *ExecutableNodeStatus_GetStartedAt
func (*ExecutableNodeStatus) OnGetStoppedAt ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnGetStoppedAt() *ExecutableNodeStatus_GetStoppedAt
func (*ExecutableNodeStatus) OnGetStoppedAtMatch ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnGetStoppedAtMatch(matchers ...interface{}) *ExecutableNodeStatus_GetStoppedAt
func (*ExecutableNodeStatus) OnGetSystemFailures ¶ added in v0.2.11
func (_m *ExecutableNodeStatus) OnGetSystemFailures() *ExecutableNodeStatus_GetSystemFailures
func (*ExecutableNodeStatus) OnGetSystemFailuresMatch ¶ added in v0.2.11
func (_m *ExecutableNodeStatus) OnGetSystemFailuresMatch(matchers ...interface{}) *ExecutableNodeStatus_GetSystemFailures
func (*ExecutableNodeStatus) OnGetTaskNodeStatus ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnGetTaskNodeStatus() *ExecutableNodeStatus_GetTaskNodeStatus
func (*ExecutableNodeStatus) OnGetTaskNodeStatusMatch ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnGetTaskNodeStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetTaskNodeStatus
func (*ExecutableNodeStatus) OnGetTaskStatus ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnGetTaskStatus() *ExecutableNodeStatus_GetTaskStatus
func (*ExecutableNodeStatus) OnGetTaskStatusMatch ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnGetTaskStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetTaskStatus
func (*ExecutableNodeStatus) OnGetWorkflowNodeStatus ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnGetWorkflowNodeStatus() *ExecutableNodeStatus_GetWorkflowNodeStatus
func (*ExecutableNodeStatus) OnGetWorkflowNodeStatusMatch ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnGetWorkflowNodeStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetWorkflowNodeStatus
func (*ExecutableNodeStatus) OnGetWorkflowStatus ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnGetWorkflowStatus() *ExecutableNodeStatus_GetWorkflowStatus
func (*ExecutableNodeStatus) OnGetWorkflowStatusMatch ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnGetWorkflowStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetWorkflowStatus
func (*ExecutableNodeStatus) OnIncrementAttempts ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnIncrementAttempts() *ExecutableNodeStatus_IncrementAttempts
func (*ExecutableNodeStatus) OnIncrementAttemptsMatch ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnIncrementAttemptsMatch(matchers ...interface{}) *ExecutableNodeStatus_IncrementAttempts
func (*ExecutableNodeStatus) OnIncrementSystemFailures ¶ added in v0.2.11
func (_m *ExecutableNodeStatus) OnIncrementSystemFailures() *ExecutableNodeStatus_IncrementSystemFailures
func (*ExecutableNodeStatus) OnIncrementSystemFailuresMatch ¶ added in v0.2.11
func (_m *ExecutableNodeStatus) OnIncrementSystemFailuresMatch(matchers ...interface{}) *ExecutableNodeStatus_IncrementSystemFailures
func (*ExecutableNodeStatus) OnIsCached ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnIsCached() *ExecutableNodeStatus_IsCached
func (*ExecutableNodeStatus) OnIsCachedMatch ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnIsCachedMatch(matchers ...interface{}) *ExecutableNodeStatus_IsCached
func (*ExecutableNodeStatus) OnIsDirty ¶ added in v0.1.13
func (_m *ExecutableNodeStatus) OnIsDirty() *ExecutableNodeStatus_IsDirty
func (*ExecutableNodeStatus) OnIsDirtyMatch ¶ added in v0.1.13
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 ¶ added in v0.1.27
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, err *core.ExecutionError)
UpdatePhase provides a mock function with given fields: phase, occurredAt, reason, err
func (*ExecutableNodeStatus) VisitNodeStatuses ¶
func (_m *ExecutableNodeStatus) VisitNodeStatuses(visitor func(string, v1alpha1.ExecutableNodeStatus))
VisitNodeStatuses provides a mock function with given fields: visitor
type ExecutableNodeStatus_GetAttempts ¶ added in v0.1.13
func (ExecutableNodeStatus_GetAttempts) Return ¶ added in v0.1.13
func (_m ExecutableNodeStatus_GetAttempts) Return(_a0 uint32) *ExecutableNodeStatus_GetAttempts
type ExecutableNodeStatus_GetBranchStatus ¶ added in v0.1.13
func (ExecutableNodeStatus_GetBranchStatus) Return ¶ added in v0.1.13
func (_m ExecutableNodeStatus_GetBranchStatus) Return(_a0 v1alpha1.MutableBranchNodeStatus) *ExecutableNodeStatus_GetBranchStatus
type ExecutableNodeStatus_GetDataDir ¶ added in v0.1.13
func (ExecutableNodeStatus_GetDataDir) Return ¶ added in v0.1.13
func (_m ExecutableNodeStatus_GetDataDir) Return(_a0 storage.DataReference) *ExecutableNodeStatus_GetDataDir
type ExecutableNodeStatus_GetDynamicNodeStatus ¶ added in v0.1.13
type ExecutableNodeStatus_GetExecutionError ¶ added in v0.2.33
func (ExecutableNodeStatus_GetExecutionError) Return ¶ added in v0.2.33
func (_m ExecutableNodeStatus_GetExecutionError) Return(_a0 *core.ExecutionError) *ExecutableNodeStatus_GetExecutionError
type ExecutableNodeStatus_GetLastAttemptStartedAt ¶ added in v0.1.17
func (ExecutableNodeStatus_GetLastAttemptStartedAt) Return ¶ added in v0.1.17
func (_m ExecutableNodeStatus_GetLastAttemptStartedAt) Return(_a0 *v1.Time) *ExecutableNodeStatus_GetLastAttemptStartedAt
type ExecutableNodeStatus_GetLastUpdatedAt ¶ added in v0.1.13
func (ExecutableNodeStatus_GetLastUpdatedAt) Return ¶ added in v0.1.13
func (_m ExecutableNodeStatus_GetLastUpdatedAt) Return(_a0 *v1.Time) *ExecutableNodeStatus_GetLastUpdatedAt
type ExecutableNodeStatus_GetMessage ¶ added in v0.1.13
func (ExecutableNodeStatus_GetMessage) Return ¶ added in v0.1.13
func (_m ExecutableNodeStatus_GetMessage) Return(_a0 string) *ExecutableNodeStatus_GetMessage
type ExecutableNodeStatus_GetNodeExecutionStatus ¶ added in v0.1.13
type ExecutableNodeStatus_GetOrCreateBranchStatus ¶ added in v0.1.13
type ExecutableNodeStatus_GetOrCreateDynamicNodeStatus ¶ added in v0.1.13
type ExecutableNodeStatus_GetOrCreateTaskStatus ¶ added in v0.1.13
type ExecutableNodeStatus_GetOrCreateWorkflowStatus ¶ added in v0.1.13
type ExecutableNodeStatus_GetOutputDir ¶ added in v0.1.27
func (ExecutableNodeStatus_GetOutputDir) Return ¶ added in v0.1.27
func (_m ExecutableNodeStatus_GetOutputDir) Return(_a0 storage.DataReference) *ExecutableNodeStatus_GetOutputDir
type ExecutableNodeStatus_GetParentNodeID ¶ added in v0.1.13
func (ExecutableNodeStatus_GetParentNodeID) Return ¶ added in v0.1.13
func (_m ExecutableNodeStatus_GetParentNodeID) Return(_a0 *string) *ExecutableNodeStatus_GetParentNodeID
type ExecutableNodeStatus_GetParentTaskID ¶ added in v0.1.13
func (ExecutableNodeStatus_GetParentTaskID) Return ¶ added in v0.1.13
func (_m ExecutableNodeStatus_GetParentTaskID) Return(_a0 *core.TaskExecutionIdentifier) *ExecutableNodeStatus_GetParentTaskID
type ExecutableNodeStatus_GetPhase ¶ added in v0.1.13
func (ExecutableNodeStatus_GetPhase) Return ¶ added in v0.1.13
func (_m ExecutableNodeStatus_GetPhase) Return(_a0 v1alpha1.NodePhase) *ExecutableNodeStatus_GetPhase
type ExecutableNodeStatus_GetQueuedAt ¶ added in v0.1.13
func (ExecutableNodeStatus_GetQueuedAt) Return ¶ added in v0.1.13
func (_m ExecutableNodeStatus_GetQueuedAt) Return(_a0 *v1.Time) *ExecutableNodeStatus_GetQueuedAt
type ExecutableNodeStatus_GetStartedAt ¶ added in v0.1.13
func (ExecutableNodeStatus_GetStartedAt) Return ¶ added in v0.1.13
func (_m ExecutableNodeStatus_GetStartedAt) Return(_a0 *v1.Time) *ExecutableNodeStatus_GetStartedAt
type ExecutableNodeStatus_GetStoppedAt ¶ added in v0.1.13
func (ExecutableNodeStatus_GetStoppedAt) Return ¶ added in v0.1.13
func (_m ExecutableNodeStatus_GetStoppedAt) Return(_a0 *v1.Time) *ExecutableNodeStatus_GetStoppedAt
type ExecutableNodeStatus_GetSystemFailures ¶ added in v0.2.11
func (ExecutableNodeStatus_GetSystemFailures) Return ¶ added in v0.2.11
func (_m ExecutableNodeStatus_GetSystemFailures) Return(_a0 uint32) *ExecutableNodeStatus_GetSystemFailures
type ExecutableNodeStatus_GetTaskNodeStatus ¶ added in v0.1.13
type ExecutableNodeStatus_GetTaskStatus ¶ added in v0.1.13
func (ExecutableNodeStatus_GetTaskStatus) Return ¶ added in v0.1.13
func (_m ExecutableNodeStatus_GetTaskStatus) Return(_a0 v1alpha1.MutableTaskNodeStatus) *ExecutableNodeStatus_GetTaskStatus
type ExecutableNodeStatus_GetWorkflowNodeStatus ¶ added in v0.1.13
type ExecutableNodeStatus_GetWorkflowStatus ¶ added in v0.1.13
type ExecutableNodeStatus_IncrementAttempts ¶ added in v0.1.13
func (ExecutableNodeStatus_IncrementAttempts) Return ¶ added in v0.1.13
func (_m ExecutableNodeStatus_IncrementAttempts) Return(_a0 uint32) *ExecutableNodeStatus_IncrementAttempts
type ExecutableNodeStatus_IncrementSystemFailures ¶ added in v0.2.11
func (ExecutableNodeStatus_IncrementSystemFailures) Return ¶ added in v0.2.11
func (_m ExecutableNodeStatus_IncrementSystemFailures) Return(_a0 uint32) *ExecutableNodeStatus_IncrementSystemFailures
type ExecutableNodeStatus_IsCached ¶ added in v0.1.13
func (ExecutableNodeStatus_IsCached) Return ¶ added in v0.1.13
func (_m ExecutableNodeStatus_IsCached) Return(_a0 bool) *ExecutableNodeStatus_IsCached
type ExecutableNodeStatus_IsDirty ¶ added in v0.1.13
func (ExecutableNodeStatus_IsDirty) Return ¶ added in v0.1.13
func (_m ExecutableNodeStatus_IsDirty) Return(_a0 bool) *ExecutableNodeStatus_IsDirty
type ExecutableNode_GetActiveDeadline ¶ added in v0.1.17
func (ExecutableNode_GetActiveDeadline) Return ¶ added in v0.1.17
func (_m ExecutableNode_GetActiveDeadline) Return(_a0 *time.Duration) *ExecutableNode_GetActiveDeadline
type ExecutableNode_GetBranchNode ¶ added in v0.1.13
func (ExecutableNode_GetBranchNode) Return ¶ added in v0.1.13
func (_m ExecutableNode_GetBranchNode) Return(_a0 v1alpha1.ExecutableBranchNode) *ExecutableNode_GetBranchNode
type ExecutableNode_GetConfig ¶ added in v0.1.13
func (ExecutableNode_GetConfig) Return ¶ added in v0.1.13
func (_m ExecutableNode_GetConfig) Return(_a0 *v1.ConfigMap) *ExecutableNode_GetConfig
type ExecutableNode_GetExecutionDeadline ¶ added in v0.1.17
func (ExecutableNode_GetExecutionDeadline) Return ¶ added in v0.1.17
func (_m ExecutableNode_GetExecutionDeadline) Return(_a0 *time.Duration) *ExecutableNode_GetExecutionDeadline
type ExecutableNode_GetID ¶ added in v0.1.13
func (ExecutableNode_GetID) Return ¶ added in v0.1.13
func (_m ExecutableNode_GetID) Return(_a0 string) *ExecutableNode_GetID
type ExecutableNode_GetInputBindings ¶ added in v0.1.13
func (ExecutableNode_GetInputBindings) Return ¶ added in v0.1.13
func (_m ExecutableNode_GetInputBindings) Return(_a0 []*v1alpha1.Binding) *ExecutableNode_GetInputBindings
type ExecutableNode_GetKind ¶ added in v0.1.13
func (ExecutableNode_GetKind) Return ¶ added in v0.1.13
func (_m ExecutableNode_GetKind) Return(_a0 v1alpha1.NodeKind) *ExecutableNode_GetKind
type ExecutableNode_GetOutputAlias ¶ added in v0.1.13
func (ExecutableNode_GetOutputAlias) Return ¶ added in v0.1.13
func (_m ExecutableNode_GetOutputAlias) Return(_a0 []v1alpha1.Alias) *ExecutableNode_GetOutputAlias
type ExecutableNode_GetResources ¶ added in v0.1.13
func (ExecutableNode_GetResources) Return ¶ added in v0.1.13
func (_m ExecutableNode_GetResources) Return(_a0 *v1.ResourceRequirements) *ExecutableNode_GetResources
type ExecutableNode_GetRetryStrategy ¶ added in v0.1.13
func (ExecutableNode_GetRetryStrategy) Return ¶ added in v0.1.13
func (_m ExecutableNode_GetRetryStrategy) Return(_a0 *v1alpha1.RetryStrategy) *ExecutableNode_GetRetryStrategy
type ExecutableNode_GetTaskID ¶ added in v0.1.13
func (ExecutableNode_GetTaskID) Return ¶ added in v0.1.13
func (_m ExecutableNode_GetTaskID) Return(_a0 *string) *ExecutableNode_GetTaskID
type ExecutableNode_GetWorkflowNode ¶ added in v0.1.13
func (ExecutableNode_GetWorkflowNode) Return ¶ added in v0.1.13
func (_m ExecutableNode_GetWorkflowNode) Return(_a0 v1alpha1.ExecutableWorkflowNode) *ExecutableNode_GetWorkflowNode
type ExecutableNode_IsEndNode ¶ added in v0.1.13
func (ExecutableNode_IsEndNode) Return ¶ added in v0.1.13
func (_m ExecutableNode_IsEndNode) Return(_a0 bool) *ExecutableNode_IsEndNode
type ExecutableNode_IsInterruptible ¶ added in v0.2.15
func (ExecutableNode_IsInterruptible) Return ¶ added in v0.2.15
func (_m ExecutableNode_IsInterruptible) Return(_a0 *bool) *ExecutableNode_IsInterruptible
type ExecutableNode_IsStartNode ¶ added in v0.1.13
func (ExecutableNode_IsStartNode) Return ¶ added in v0.1.13
func (_m ExecutableNode_IsStartNode) Return(_a0 bool) *ExecutableNode_IsStartNode
type ExecutableSubWorkflow ¶
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 ¶ added in v0.1.13
func (_m *ExecutableSubWorkflow) OnFromNode(name string) *ExecutableSubWorkflow_FromNode
func (*ExecutableSubWorkflow) OnFromNodeMatch ¶ added in v0.1.13
func (_m *ExecutableSubWorkflow) OnFromNodeMatch(matchers ...interface{}) *ExecutableSubWorkflow_FromNode
func (*ExecutableSubWorkflow) OnGetConnections ¶ added in v0.1.13
func (_m *ExecutableSubWorkflow) OnGetConnections() *ExecutableSubWorkflow_GetConnections
func (*ExecutableSubWorkflow) OnGetConnectionsMatch ¶ added in v0.1.13
func (_m *ExecutableSubWorkflow) OnGetConnectionsMatch(matchers ...interface{}) *ExecutableSubWorkflow_GetConnections
func (*ExecutableSubWorkflow) OnGetID ¶ added in v0.1.13
func (_m *ExecutableSubWorkflow) OnGetID() *ExecutableSubWorkflow_GetID
func (*ExecutableSubWorkflow) OnGetIDMatch ¶ added in v0.1.13
func (_m *ExecutableSubWorkflow) OnGetIDMatch(matchers ...interface{}) *ExecutableSubWorkflow_GetID
func (*ExecutableSubWorkflow) OnGetNode ¶ added in v0.1.13
func (_m *ExecutableSubWorkflow) OnGetNode(nodeID string) *ExecutableSubWorkflow_GetNode
func (*ExecutableSubWorkflow) OnGetNodeMatch ¶ added in v0.1.13
func (_m *ExecutableSubWorkflow) OnGetNodeMatch(matchers ...interface{}) *ExecutableSubWorkflow_GetNode
func (*ExecutableSubWorkflow) OnGetNodes ¶ added in v0.1.13
func (_m *ExecutableSubWorkflow) OnGetNodes() *ExecutableSubWorkflow_GetNodes
func (*ExecutableSubWorkflow) OnGetNodesMatch ¶ added in v0.1.13
func (_m *ExecutableSubWorkflow) OnGetNodesMatch(matchers ...interface{}) *ExecutableSubWorkflow_GetNodes
func (*ExecutableSubWorkflow) OnGetOnFailureNode ¶ added in v0.1.13
func (_m *ExecutableSubWorkflow) OnGetOnFailureNode() *ExecutableSubWorkflow_GetOnFailureNode
func (*ExecutableSubWorkflow) OnGetOnFailureNodeMatch ¶ added in v0.1.13
func (_m *ExecutableSubWorkflow) OnGetOnFailureNodeMatch(matchers ...interface{}) *ExecutableSubWorkflow_GetOnFailureNode
func (*ExecutableSubWorkflow) OnGetOutputBindings ¶ added in v0.1.13
func (_m *ExecutableSubWorkflow) OnGetOutputBindings() *ExecutableSubWorkflow_GetOutputBindings
func (*ExecutableSubWorkflow) OnGetOutputBindingsMatch ¶ added in v0.1.13
func (_m *ExecutableSubWorkflow) OnGetOutputBindingsMatch(matchers ...interface{}) *ExecutableSubWorkflow_GetOutputBindings
func (*ExecutableSubWorkflow) OnGetOutputs ¶ added in v0.1.13
func (_m *ExecutableSubWorkflow) OnGetOutputs() *ExecutableSubWorkflow_GetOutputs
func (*ExecutableSubWorkflow) OnGetOutputsMatch ¶ added in v0.1.13
func (_m *ExecutableSubWorkflow) OnGetOutputsMatch(matchers ...interface{}) *ExecutableSubWorkflow_GetOutputs
func (*ExecutableSubWorkflow) OnStartNode ¶ added in v0.1.13
func (_m *ExecutableSubWorkflow) OnStartNode() *ExecutableSubWorkflow_StartNode
func (*ExecutableSubWorkflow) OnStartNodeMatch ¶ added in v0.1.13
func (_m *ExecutableSubWorkflow) OnStartNodeMatch(matchers ...interface{}) *ExecutableSubWorkflow_StartNode
func (*ExecutableSubWorkflow) OnToNode ¶ added in v0.2.28
func (_m *ExecutableSubWorkflow) OnToNode(name string) *ExecutableSubWorkflow_ToNode
func (*ExecutableSubWorkflow) OnToNodeMatch ¶ added in v0.2.28
func (_m *ExecutableSubWorkflow) OnToNodeMatch(matchers ...interface{}) *ExecutableSubWorkflow_ToNode
func (*ExecutableSubWorkflow) StartNode ¶
func (_m *ExecutableSubWorkflow) StartNode() v1alpha1.ExecutableNode
StartNode provides a mock function with given fields:
type ExecutableSubWorkflowNodeStatus ¶
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 ¶ added in v0.1.13
func (_m *ExecutableSubWorkflowNodeStatus) OnGetPhase() *ExecutableSubWorkflowNodeStatus_GetPhase
func (*ExecutableSubWorkflowNodeStatus) OnGetPhaseMatch ¶ added in v0.1.13
func (_m *ExecutableSubWorkflowNodeStatus) OnGetPhaseMatch(matchers ...interface{}) *ExecutableSubWorkflowNodeStatus_GetPhase
type ExecutableSubWorkflowNodeStatus_GetPhase ¶ added in v0.1.13
func (ExecutableSubWorkflowNodeStatus_GetPhase) Return ¶ added in v0.1.13
func (_m ExecutableSubWorkflowNodeStatus_GetPhase) Return(_a0 v1alpha1.WorkflowPhase) *ExecutableSubWorkflowNodeStatus_GetPhase
type ExecutableSubWorkflow_FromNode ¶ added in v0.1.13
func (ExecutableSubWorkflow_FromNode) Return ¶ added in v0.1.13
func (_m ExecutableSubWorkflow_FromNode) Return(_a0 []string, _a1 error) *ExecutableSubWorkflow_FromNode
type ExecutableSubWorkflow_GetConnections ¶ added in v0.1.13
func (ExecutableSubWorkflow_GetConnections) Return ¶ added in v0.1.13
func (_m ExecutableSubWorkflow_GetConnections) Return(_a0 *v1alpha1.Connections) *ExecutableSubWorkflow_GetConnections
type ExecutableSubWorkflow_GetID ¶ added in v0.1.13
func (ExecutableSubWorkflow_GetID) Return ¶ added in v0.1.13
func (_m ExecutableSubWorkflow_GetID) Return(_a0 string) *ExecutableSubWorkflow_GetID
type ExecutableSubWorkflow_GetNode ¶ added in v0.1.13
func (ExecutableSubWorkflow_GetNode) Return ¶ added in v0.1.13
func (_m ExecutableSubWorkflow_GetNode) Return(_a0 v1alpha1.ExecutableNode, _a1 bool) *ExecutableSubWorkflow_GetNode
type ExecutableSubWorkflow_GetNodes ¶ added in v0.1.13
func (ExecutableSubWorkflow_GetNodes) Return ¶ added in v0.1.13
func (_m ExecutableSubWorkflow_GetNodes) Return(_a0 []string) *ExecutableSubWorkflow_GetNodes
type ExecutableSubWorkflow_GetOnFailureNode ¶ added in v0.1.13
func (ExecutableSubWorkflow_GetOnFailureNode) Return ¶ added in v0.1.13
func (_m ExecutableSubWorkflow_GetOnFailureNode) Return(_a0 v1alpha1.ExecutableNode) *ExecutableSubWorkflow_GetOnFailureNode
type ExecutableSubWorkflow_GetOutputBindings ¶ added in v0.1.13
func (ExecutableSubWorkflow_GetOutputBindings) Return ¶ added in v0.1.13
func (_m ExecutableSubWorkflow_GetOutputBindings) Return(_a0 []*v1alpha1.Binding) *ExecutableSubWorkflow_GetOutputBindings
type ExecutableSubWorkflow_GetOutputs ¶ added in v0.1.13
func (ExecutableSubWorkflow_GetOutputs) Return ¶ added in v0.1.13
func (_m ExecutableSubWorkflow_GetOutputs) Return(_a0 *v1alpha1.OutputVarMap) *ExecutableSubWorkflow_GetOutputs
type ExecutableSubWorkflow_StartNode ¶ added in v0.1.13
func (ExecutableSubWorkflow_StartNode) Return ¶ added in v0.1.13
func (_m ExecutableSubWorkflow_StartNode) Return(_a0 v1alpha1.ExecutableNode) *ExecutableSubWorkflow_StartNode
type ExecutableSubWorkflow_ToNode ¶ added in v0.2.28
func (ExecutableSubWorkflow_ToNode) Return ¶ added in v0.2.28
func (_m ExecutableSubWorkflow_ToNode) Return(_a0 []string, _a1 error) *ExecutableSubWorkflow_ToNode
type ExecutableTask ¶
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 ¶ added in v0.1.13
func (_m *ExecutableTask) OnCoreTask() *ExecutableTask_CoreTask
func (*ExecutableTask) OnCoreTaskMatch ¶ added in v0.1.13
func (_m *ExecutableTask) OnCoreTaskMatch(matchers ...interface{}) *ExecutableTask_CoreTask
func (*ExecutableTask) OnTaskType ¶ added in v0.1.13
func (_m *ExecutableTask) OnTaskType() *ExecutableTask_TaskType
func (*ExecutableTask) OnTaskTypeMatch ¶ added in v0.1.13
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 ¶
ExecutableTaskNodeStatus is an autogenerated mock type for the ExecutableTaskNodeStatus type
func (*ExecutableTaskNodeStatus) GetBarrierClockTick ¶ added in v0.1.13
func (_m *ExecutableTaskNodeStatus) GetBarrierClockTick() uint32
GetBarrierClockTick provides a mock function with given fields:
func (*ExecutableTaskNodeStatus) GetLastPhaseUpdatedAt ¶ added in v0.1.27
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 ¶ added in v0.1.13
func (_m *ExecutableTaskNodeStatus) GetPluginState() []byte
GetPluginState provides a mock function with given fields:
func (*ExecutableTaskNodeStatus) GetPluginStateVersion ¶ added in v0.1.13
func (_m *ExecutableTaskNodeStatus) GetPluginStateVersion() uint32
GetPluginStateVersion provides a mock function with given fields:
func (*ExecutableTaskNodeStatus) OnGetBarrierClockTick ¶ added in v0.1.13
func (_m *ExecutableTaskNodeStatus) OnGetBarrierClockTick() *ExecutableTaskNodeStatus_GetBarrierClockTick
func (*ExecutableTaskNodeStatus) OnGetBarrierClockTickMatch ¶ added in v0.1.13
func (_m *ExecutableTaskNodeStatus) OnGetBarrierClockTickMatch(matchers ...interface{}) *ExecutableTaskNodeStatus_GetBarrierClockTick
func (*ExecutableTaskNodeStatus) OnGetLastPhaseUpdatedAt ¶ added in v0.1.27
func (_m *ExecutableTaskNodeStatus) OnGetLastPhaseUpdatedAt() *ExecutableTaskNodeStatus_GetLastPhaseUpdatedAt
func (*ExecutableTaskNodeStatus) OnGetLastPhaseUpdatedAtMatch ¶ added in v0.1.27
func (_m *ExecutableTaskNodeStatus) OnGetLastPhaseUpdatedAtMatch(matchers ...interface{}) *ExecutableTaskNodeStatus_GetLastPhaseUpdatedAt
func (*ExecutableTaskNodeStatus) OnGetPhase ¶ added in v0.1.13
func (_m *ExecutableTaskNodeStatus) OnGetPhase() *ExecutableTaskNodeStatus_GetPhase
func (*ExecutableTaskNodeStatus) OnGetPhaseMatch ¶ added in v0.1.13
func (_m *ExecutableTaskNodeStatus) OnGetPhaseMatch(matchers ...interface{}) *ExecutableTaskNodeStatus_GetPhase
func (*ExecutableTaskNodeStatus) OnGetPhaseVersion ¶ added in v0.1.13
func (_m *ExecutableTaskNodeStatus) OnGetPhaseVersion() *ExecutableTaskNodeStatus_GetPhaseVersion
func (*ExecutableTaskNodeStatus) OnGetPhaseVersionMatch ¶ added in v0.1.13
func (_m *ExecutableTaskNodeStatus) OnGetPhaseVersionMatch(matchers ...interface{}) *ExecutableTaskNodeStatus_GetPhaseVersion
func (*ExecutableTaskNodeStatus) OnGetPluginState ¶ added in v0.1.13
func (_m *ExecutableTaskNodeStatus) OnGetPluginState() *ExecutableTaskNodeStatus_GetPluginState
func (*ExecutableTaskNodeStatus) OnGetPluginStateMatch ¶ added in v0.1.13
func (_m *ExecutableTaskNodeStatus) OnGetPluginStateMatch(matchers ...interface{}) *ExecutableTaskNodeStatus_GetPluginState
func (*ExecutableTaskNodeStatus) OnGetPluginStateVersion ¶ added in v0.1.13
func (_m *ExecutableTaskNodeStatus) OnGetPluginStateVersion() *ExecutableTaskNodeStatus_GetPluginStateVersion
func (*ExecutableTaskNodeStatus) OnGetPluginStateVersionMatch ¶ added in v0.1.13
func (_m *ExecutableTaskNodeStatus) OnGetPluginStateVersionMatch(matchers ...interface{}) *ExecutableTaskNodeStatus_GetPluginStateVersion
type ExecutableTaskNodeStatus_GetBarrierClockTick ¶ added in v0.1.13
func (ExecutableTaskNodeStatus_GetBarrierClockTick) Return ¶ added in v0.1.13
func (_m ExecutableTaskNodeStatus_GetBarrierClockTick) Return(_a0 uint32) *ExecutableTaskNodeStatus_GetBarrierClockTick
type ExecutableTaskNodeStatus_GetLastPhaseUpdatedAt ¶ added in v0.1.27
func (ExecutableTaskNodeStatus_GetLastPhaseUpdatedAt) Return ¶ added in v0.1.27
func (_m ExecutableTaskNodeStatus_GetLastPhaseUpdatedAt) Return(_a0 time.Time) *ExecutableTaskNodeStatus_GetLastPhaseUpdatedAt
type ExecutableTaskNodeStatus_GetPhase ¶ added in v0.1.13
func (ExecutableTaskNodeStatus_GetPhase) Return ¶ added in v0.1.13
func (_m ExecutableTaskNodeStatus_GetPhase) Return(_a0 int) *ExecutableTaskNodeStatus_GetPhase
type ExecutableTaskNodeStatus_GetPhaseVersion ¶ added in v0.1.13
func (ExecutableTaskNodeStatus_GetPhaseVersion) Return ¶ added in v0.1.13
func (_m ExecutableTaskNodeStatus_GetPhaseVersion) Return(_a0 uint32) *ExecutableTaskNodeStatus_GetPhaseVersion
type ExecutableTaskNodeStatus_GetPluginState ¶ added in v0.1.13
func (ExecutableTaskNodeStatus_GetPluginState) Return ¶ added in v0.1.13
func (_m ExecutableTaskNodeStatus_GetPluginState) Return(_a0 []byte) *ExecutableTaskNodeStatus_GetPluginState
type ExecutableTaskNodeStatus_GetPluginStateVersion ¶ added in v0.1.13
func (ExecutableTaskNodeStatus_GetPluginStateVersion) Return ¶ added in v0.1.13
func (_m ExecutableTaskNodeStatus_GetPluginStateVersion) Return(_a0 uint32) *ExecutableTaskNodeStatus_GetPluginStateVersion
type ExecutableTask_CoreTask ¶ added in v0.1.13
func (ExecutableTask_CoreTask) Return ¶ added in v0.1.13
func (_m ExecutableTask_CoreTask) Return(_a0 *core.TaskTemplate) *ExecutableTask_CoreTask
type ExecutableTask_TaskType ¶ added in v0.1.13
func (ExecutableTask_TaskType) Return ¶ added in v0.1.13
func (_m ExecutableTask_TaskType) Return(_a0 string) *ExecutableTask_TaskType
type ExecutableWorkflow ¶
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 ¶ added in v0.1.13
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) IsInterruptible ¶ added in v0.2.15
func (_m *ExecutableWorkflow) IsInterruptible() bool
IsInterruptible provides a mock function with given fields:
func (*ExecutableWorkflow) OnFindSubWorkflow ¶ added in v0.1.13
func (_m *ExecutableWorkflow) OnFindSubWorkflow(subID string) *ExecutableWorkflow_FindSubWorkflow
func (*ExecutableWorkflow) OnFindSubWorkflowMatch ¶ added in v0.1.13
func (_m *ExecutableWorkflow) OnFindSubWorkflowMatch(matchers ...interface{}) *ExecutableWorkflow_FindSubWorkflow
func (*ExecutableWorkflow) OnFromNode ¶ added in v0.1.13
func (_m *ExecutableWorkflow) OnFromNode(name string) *ExecutableWorkflow_FromNode
func (*ExecutableWorkflow) OnFromNodeMatch ¶ added in v0.1.13
func (_m *ExecutableWorkflow) OnFromNodeMatch(matchers ...interface{}) *ExecutableWorkflow_FromNode
func (*ExecutableWorkflow) OnGetAnnotations ¶ added in v0.1.13
func (_m *ExecutableWorkflow) OnGetAnnotations() *ExecutableWorkflow_GetAnnotations
func (*ExecutableWorkflow) OnGetAnnotationsMatch ¶ added in v0.1.13
func (_m *ExecutableWorkflow) OnGetAnnotationsMatch(matchers ...interface{}) *ExecutableWorkflow_GetAnnotations
func (*ExecutableWorkflow) OnGetConnections ¶ added in v0.1.13
func (_m *ExecutableWorkflow) OnGetConnections() *ExecutableWorkflow_GetConnections
func (*ExecutableWorkflow) OnGetConnectionsMatch ¶ added in v0.1.13
func (_m *ExecutableWorkflow) OnGetConnectionsMatch(matchers ...interface{}) *ExecutableWorkflow_GetConnections
func (*ExecutableWorkflow) OnGetCreationTimestamp ¶ added in v0.1.13
func (_m *ExecutableWorkflow) OnGetCreationTimestamp() *ExecutableWorkflow_GetCreationTimestamp
func (*ExecutableWorkflow) OnGetCreationTimestampMatch ¶ added in v0.1.13
func (_m *ExecutableWorkflow) OnGetCreationTimestampMatch(matchers ...interface{}) *ExecutableWorkflow_GetCreationTimestamp
func (*ExecutableWorkflow) OnGetExecutionID ¶ added in v0.1.13
func (_m *ExecutableWorkflow) OnGetExecutionID() *ExecutableWorkflow_GetExecutionID
func (*ExecutableWorkflow) OnGetExecutionIDMatch ¶ added in v0.1.13
func (_m *ExecutableWorkflow) OnGetExecutionIDMatch(matchers ...interface{}) *ExecutableWorkflow_GetExecutionID
func (*ExecutableWorkflow) OnGetExecutionStatus ¶ added in v0.1.13
func (_m *ExecutableWorkflow) OnGetExecutionStatus() *ExecutableWorkflow_GetExecutionStatus
func (*ExecutableWorkflow) OnGetExecutionStatusMatch ¶ added in v0.1.13
func (_m *ExecutableWorkflow) OnGetExecutionStatusMatch(matchers ...interface{}) *ExecutableWorkflow_GetExecutionStatus
func (*ExecutableWorkflow) OnGetID ¶ added in v0.1.13
func (_m *ExecutableWorkflow) OnGetID() *ExecutableWorkflow_GetID
func (*ExecutableWorkflow) OnGetIDMatch ¶ added in v0.1.13
func (_m *ExecutableWorkflow) OnGetIDMatch(matchers ...interface{}) *ExecutableWorkflow_GetID
func (*ExecutableWorkflow) OnGetK8sWorkflowID ¶ added in v0.1.13
func (_m *ExecutableWorkflow) OnGetK8sWorkflowID() *ExecutableWorkflow_GetK8sWorkflowID
func (*ExecutableWorkflow) OnGetK8sWorkflowIDMatch ¶ added in v0.1.13
func (_m *ExecutableWorkflow) OnGetK8sWorkflowIDMatch(matchers ...interface{}) *ExecutableWorkflow_GetK8sWorkflowID
func (*ExecutableWorkflow) OnGetLabels ¶ added in v0.1.13
func (_m *ExecutableWorkflow) OnGetLabels() *ExecutableWorkflow_GetLabels
func (*ExecutableWorkflow) OnGetLabelsMatch ¶ added in v0.1.13
func (_m *ExecutableWorkflow) OnGetLabelsMatch(matchers ...interface{}) *ExecutableWorkflow_GetLabels
func (*ExecutableWorkflow) OnGetName ¶ added in v0.1.13
func (_m *ExecutableWorkflow) OnGetName() *ExecutableWorkflow_GetName
func (*ExecutableWorkflow) OnGetNameMatch ¶ added in v0.1.13
func (_m *ExecutableWorkflow) OnGetNameMatch(matchers ...interface{}) *ExecutableWorkflow_GetName
func (*ExecutableWorkflow) OnGetNamespace ¶ added in v0.1.13
func (_m *ExecutableWorkflow) OnGetNamespace() *ExecutableWorkflow_GetNamespace
func (*ExecutableWorkflow) OnGetNamespaceMatch ¶ added in v0.1.13
func (_m *ExecutableWorkflow) OnGetNamespaceMatch(matchers ...interface{}) *ExecutableWorkflow_GetNamespace
func (*ExecutableWorkflow) OnGetNode ¶ added in v0.1.13
func (_m *ExecutableWorkflow) OnGetNode(nodeID string) *ExecutableWorkflow_GetNode
func (*ExecutableWorkflow) OnGetNodeExecutionStatus ¶ added in v0.1.13
func (_m *ExecutableWorkflow) OnGetNodeExecutionStatus(ctx context.Context, id string) *ExecutableWorkflow_GetNodeExecutionStatus
func (*ExecutableWorkflow) OnGetNodeExecutionStatusMatch ¶ added in v0.1.13
func (_m *ExecutableWorkflow) OnGetNodeExecutionStatusMatch(matchers ...interface{}) *ExecutableWorkflow_GetNodeExecutionStatus
func (*ExecutableWorkflow) OnGetNodeMatch ¶ added in v0.1.13
func (_m *ExecutableWorkflow) OnGetNodeMatch(matchers ...interface{}) *ExecutableWorkflow_GetNode
func (*ExecutableWorkflow) OnGetNodes ¶ added in v0.1.13
func (_m *ExecutableWorkflow) OnGetNodes() *ExecutableWorkflow_GetNodes
func (*ExecutableWorkflow) OnGetNodesMatch ¶ added in v0.1.13
func (_m *ExecutableWorkflow) OnGetNodesMatch(matchers ...interface{}) *ExecutableWorkflow_GetNodes
func (*ExecutableWorkflow) OnGetOnFailureNode ¶ added in v0.1.13
func (_m *ExecutableWorkflow) OnGetOnFailureNode() *ExecutableWorkflow_GetOnFailureNode
func (*ExecutableWorkflow) OnGetOnFailureNodeMatch ¶ added in v0.1.13
func (_m *ExecutableWorkflow) OnGetOnFailureNodeMatch(matchers ...interface{}) *ExecutableWorkflow_GetOnFailureNode
func (*ExecutableWorkflow) OnGetOutputBindings ¶ added in v0.1.13
func (_m *ExecutableWorkflow) OnGetOutputBindings() *ExecutableWorkflow_GetOutputBindings
func (*ExecutableWorkflow) OnGetOutputBindingsMatch ¶ added in v0.1.13
func (_m *ExecutableWorkflow) OnGetOutputBindingsMatch(matchers ...interface{}) *ExecutableWorkflow_GetOutputBindings
func (*ExecutableWorkflow) OnGetOutputs ¶ added in v0.1.13
func (_m *ExecutableWorkflow) OnGetOutputs() *ExecutableWorkflow_GetOutputs
func (*ExecutableWorkflow) OnGetOutputsMatch ¶ added in v0.1.13
func (_m *ExecutableWorkflow) OnGetOutputsMatch(matchers ...interface{}) *ExecutableWorkflow_GetOutputs
func (*ExecutableWorkflow) OnGetOwnerReference ¶ added in v0.1.13
func (_m *ExecutableWorkflow) OnGetOwnerReference() *ExecutableWorkflow_GetOwnerReference
func (*ExecutableWorkflow) OnGetOwnerReferenceMatch ¶ added in v0.1.13
func (_m *ExecutableWorkflow) OnGetOwnerReferenceMatch(matchers ...interface{}) *ExecutableWorkflow_GetOwnerReference
func (*ExecutableWorkflow) OnGetServiceAccountName ¶ added in v0.1.13
func (_m *ExecutableWorkflow) OnGetServiceAccountName() *ExecutableWorkflow_GetServiceAccountName
func (*ExecutableWorkflow) OnGetServiceAccountNameMatch ¶ added in v0.1.13
func (_m *ExecutableWorkflow) OnGetServiceAccountNameMatch(matchers ...interface{}) *ExecutableWorkflow_GetServiceAccountName
func (*ExecutableWorkflow) OnGetTask ¶ added in v0.1.13
func (_m *ExecutableWorkflow) OnGetTask(id string) *ExecutableWorkflow_GetTask
func (*ExecutableWorkflow) OnGetTaskMatch ¶ added in v0.1.13
func (_m *ExecutableWorkflow) OnGetTaskMatch(matchers ...interface{}) *ExecutableWorkflow_GetTask
func (*ExecutableWorkflow) OnIsInterruptible ¶ added in v0.2.15
func (_m *ExecutableWorkflow) OnIsInterruptible() *ExecutableWorkflow_IsInterruptible
func (*ExecutableWorkflow) OnIsInterruptibleMatch ¶ added in v0.2.15
func (_m *ExecutableWorkflow) OnIsInterruptibleMatch(matchers ...interface{}) *ExecutableWorkflow_IsInterruptible
func (*ExecutableWorkflow) OnStartNode ¶ added in v0.1.13
func (_m *ExecutableWorkflow) OnStartNode() *ExecutableWorkflow_StartNode
func (*ExecutableWorkflow) OnStartNodeMatch ¶ added in v0.1.13
func (_m *ExecutableWorkflow) OnStartNodeMatch(matchers ...interface{}) *ExecutableWorkflow_StartNode
func (*ExecutableWorkflow) OnToNode ¶ added in v0.2.28
func (_m *ExecutableWorkflow) OnToNode(name string) *ExecutableWorkflow_ToNode
func (*ExecutableWorkflow) OnToNodeMatch ¶ added in v0.2.28
func (_m *ExecutableWorkflow) OnToNodeMatch(matchers ...interface{}) *ExecutableWorkflow_ToNode
func (*ExecutableWorkflow) StartNode ¶
func (_m *ExecutableWorkflow) StartNode() v1alpha1.ExecutableNode
StartNode provides a mock function with given fields:
type ExecutableWorkflowNode ¶
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 ¶ added in v0.1.13
func (_m *ExecutableWorkflowNode) OnGetLaunchPlanRefID() *ExecutableWorkflowNode_GetLaunchPlanRefID
func (*ExecutableWorkflowNode) OnGetLaunchPlanRefIDMatch ¶ added in v0.1.13
func (_m *ExecutableWorkflowNode) OnGetLaunchPlanRefIDMatch(matchers ...interface{}) *ExecutableWorkflowNode_GetLaunchPlanRefID
func (*ExecutableWorkflowNode) OnGetSubWorkflowRef ¶ added in v0.1.13
func (_m *ExecutableWorkflowNode) OnGetSubWorkflowRef() *ExecutableWorkflowNode_GetSubWorkflowRef
func (*ExecutableWorkflowNode) OnGetSubWorkflowRefMatch ¶ added in v0.1.13
func (_m *ExecutableWorkflowNode) OnGetSubWorkflowRefMatch(matchers ...interface{}) *ExecutableWorkflowNode_GetSubWorkflowRef
type ExecutableWorkflowNodeStatus ¶
ExecutableWorkflowNodeStatus is an autogenerated mock type for the ExecutableWorkflowNodeStatus type
func (*ExecutableWorkflowNodeStatus) GetExecutionError ¶ added in v0.2.43
func (_m *ExecutableWorkflowNodeStatus) GetExecutionError() *core.ExecutionError
GetExecutionError provides a mock function with given fields:
func (*ExecutableWorkflowNodeStatus) GetWorkflowNodePhase ¶ added in v0.1.13
func (_m *ExecutableWorkflowNodeStatus) GetWorkflowNodePhase() v1alpha1.WorkflowNodePhase
GetWorkflowNodePhase provides a mock function with given fields:
func (*ExecutableWorkflowNodeStatus) OnGetExecutionError ¶ added in v0.2.43
func (_m *ExecutableWorkflowNodeStatus) OnGetExecutionError() *ExecutableWorkflowNodeStatus_GetExecutionError
func (*ExecutableWorkflowNodeStatus) OnGetExecutionErrorMatch ¶ added in v0.2.43
func (_m *ExecutableWorkflowNodeStatus) OnGetExecutionErrorMatch(matchers ...interface{}) *ExecutableWorkflowNodeStatus_GetExecutionError
func (*ExecutableWorkflowNodeStatus) OnGetWorkflowNodePhase ¶ added in v0.1.13
func (_m *ExecutableWorkflowNodeStatus) OnGetWorkflowNodePhase() *ExecutableWorkflowNodeStatus_GetWorkflowNodePhase
func (*ExecutableWorkflowNodeStatus) OnGetWorkflowNodePhaseMatch ¶ added in v0.1.13
func (_m *ExecutableWorkflowNodeStatus) OnGetWorkflowNodePhaseMatch(matchers ...interface{}) *ExecutableWorkflowNodeStatus_GetWorkflowNodePhase
type ExecutableWorkflowNodeStatus_GetExecutionError ¶ added in v0.2.43
type ExecutableWorkflowNodeStatus_GetWorkflowNodePhase ¶ added in v0.1.13
type ExecutableWorkflowNode_GetLaunchPlanRefID ¶ added in v0.1.13
func (ExecutableWorkflowNode_GetLaunchPlanRefID) Return ¶ added in v0.1.13
func (_m ExecutableWorkflowNode_GetLaunchPlanRefID) Return(_a0 *v1alpha1.Identifier) *ExecutableWorkflowNode_GetLaunchPlanRefID
type ExecutableWorkflowNode_GetSubWorkflowRef ¶ added in v0.1.13
func (ExecutableWorkflowNode_GetSubWorkflowRef) Return ¶ added in v0.1.13
func (_m ExecutableWorkflowNode_GetSubWorkflowRef) Return(_a0 *string) *ExecutableWorkflowNode_GetSubWorkflowRef
type ExecutableWorkflowStatus ¶
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) GetExecutionError ¶ added in v0.2.33
func (_m *ExecutableWorkflowStatus) GetExecutionError() *core.ExecutionError
GetExecutionError 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 ¶ added in v0.1.13
func (_m *ExecutableWorkflowStatus) OnConstructNodeDataDir(ctx context.Context, name string) *ExecutableWorkflowStatus_ConstructNodeDataDir
func (*ExecutableWorkflowStatus) OnConstructNodeDataDirMatch ¶ added in v0.1.13
func (_m *ExecutableWorkflowStatus) OnConstructNodeDataDirMatch(matchers ...interface{}) *ExecutableWorkflowStatus_ConstructNodeDataDir
func (*ExecutableWorkflowStatus) OnGetDataDir ¶ added in v0.1.13
func (_m *ExecutableWorkflowStatus) OnGetDataDir() *ExecutableWorkflowStatus_GetDataDir
func (*ExecutableWorkflowStatus) OnGetDataDirMatch ¶ added in v0.1.13
func (_m *ExecutableWorkflowStatus) OnGetDataDirMatch(matchers ...interface{}) *ExecutableWorkflowStatus_GetDataDir
func (*ExecutableWorkflowStatus) OnGetExecutionError ¶ added in v0.2.33
func (_m *ExecutableWorkflowStatus) OnGetExecutionError() *ExecutableWorkflowStatus_GetExecutionError
func (*ExecutableWorkflowStatus) OnGetExecutionErrorMatch ¶ added in v0.2.33
func (_m *ExecutableWorkflowStatus) OnGetExecutionErrorMatch(matchers ...interface{}) *ExecutableWorkflowStatus_GetExecutionError
func (*ExecutableWorkflowStatus) OnGetLastUpdatedAt ¶ added in v0.1.13
func (_m *ExecutableWorkflowStatus) OnGetLastUpdatedAt() *ExecutableWorkflowStatus_GetLastUpdatedAt
func (*ExecutableWorkflowStatus) OnGetLastUpdatedAtMatch ¶ added in v0.1.13
func (_m *ExecutableWorkflowStatus) OnGetLastUpdatedAtMatch(matchers ...interface{}) *ExecutableWorkflowStatus_GetLastUpdatedAt
func (*ExecutableWorkflowStatus) OnGetMessage ¶ added in v0.1.13
func (_m *ExecutableWorkflowStatus) OnGetMessage() *ExecutableWorkflowStatus_GetMessage
func (*ExecutableWorkflowStatus) OnGetMessageMatch ¶ added in v0.1.13
func (_m *ExecutableWorkflowStatus) OnGetMessageMatch(matchers ...interface{}) *ExecutableWorkflowStatus_GetMessage
func (*ExecutableWorkflowStatus) OnGetNodeExecutionStatus ¶ added in v0.1.13
func (_m *ExecutableWorkflowStatus) OnGetNodeExecutionStatus(ctx context.Context, id string) *ExecutableWorkflowStatus_GetNodeExecutionStatus
func (*ExecutableWorkflowStatus) OnGetNodeExecutionStatusMatch ¶ added in v0.1.13
func (_m *ExecutableWorkflowStatus) OnGetNodeExecutionStatusMatch(matchers ...interface{}) *ExecutableWorkflowStatus_GetNodeExecutionStatus
func (*ExecutableWorkflowStatus) OnGetOutputReference ¶ added in v0.1.13
func (_m *ExecutableWorkflowStatus) OnGetOutputReference() *ExecutableWorkflowStatus_GetOutputReference
func (*ExecutableWorkflowStatus) OnGetOutputReferenceMatch ¶ added in v0.1.13
func (_m *ExecutableWorkflowStatus) OnGetOutputReferenceMatch(matchers ...interface{}) *ExecutableWorkflowStatus_GetOutputReference
func (*ExecutableWorkflowStatus) OnGetPhase ¶ added in v0.1.13
func (_m *ExecutableWorkflowStatus) OnGetPhase() *ExecutableWorkflowStatus_GetPhase
func (*ExecutableWorkflowStatus) OnGetPhaseMatch ¶ added in v0.1.13
func (_m *ExecutableWorkflowStatus) OnGetPhaseMatch(matchers ...interface{}) *ExecutableWorkflowStatus_GetPhase
func (*ExecutableWorkflowStatus) OnGetStartedAt ¶ added in v0.1.13
func (_m *ExecutableWorkflowStatus) OnGetStartedAt() *ExecutableWorkflowStatus_GetStartedAt
func (*ExecutableWorkflowStatus) OnGetStartedAtMatch ¶ added in v0.1.13
func (_m *ExecutableWorkflowStatus) OnGetStartedAtMatch(matchers ...interface{}) *ExecutableWorkflowStatus_GetStartedAt
func (*ExecutableWorkflowStatus) OnGetStoppedAt ¶ added in v0.1.13
func (_m *ExecutableWorkflowStatus) OnGetStoppedAt() *ExecutableWorkflowStatus_GetStoppedAt
func (*ExecutableWorkflowStatus) OnGetStoppedAtMatch ¶ added in v0.1.13
func (_m *ExecutableWorkflowStatus) OnGetStoppedAtMatch(matchers ...interface{}) *ExecutableWorkflowStatus_GetStoppedAt
func (*ExecutableWorkflowStatus) OnIsTerminated ¶ added in v0.1.13
func (_m *ExecutableWorkflowStatus) OnIsTerminated() *ExecutableWorkflowStatus_IsTerminated
func (*ExecutableWorkflowStatus) OnIsTerminatedMatch ¶ added in v0.1.13
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, err *core.ExecutionError)
UpdatePhase provides a mock function with given fields: p, msg, err
type ExecutableWorkflowStatus_ConstructNodeDataDir ¶ added in v0.1.13
func (ExecutableWorkflowStatus_ConstructNodeDataDir) Return ¶ added in v0.1.13
func (_m ExecutableWorkflowStatus_ConstructNodeDataDir) Return(_a0 storage.DataReference, _a1 error) *ExecutableWorkflowStatus_ConstructNodeDataDir
type ExecutableWorkflowStatus_GetDataDir ¶ added in v0.1.13
func (ExecutableWorkflowStatus_GetDataDir) Return ¶ added in v0.1.13
func (_m ExecutableWorkflowStatus_GetDataDir) Return(_a0 storage.DataReference) *ExecutableWorkflowStatus_GetDataDir
type ExecutableWorkflowStatus_GetExecutionError ¶ added in v0.2.33
func (ExecutableWorkflowStatus_GetExecutionError) Return ¶ added in v0.2.33
func (_m ExecutableWorkflowStatus_GetExecutionError) Return(_a0 *core.ExecutionError) *ExecutableWorkflowStatus_GetExecutionError
type ExecutableWorkflowStatus_GetLastUpdatedAt ¶ added in v0.1.13
func (ExecutableWorkflowStatus_GetLastUpdatedAt) Return ¶ added in v0.1.13
func (_m ExecutableWorkflowStatus_GetLastUpdatedAt) Return(_a0 *v1.Time) *ExecutableWorkflowStatus_GetLastUpdatedAt
type ExecutableWorkflowStatus_GetMessage ¶ added in v0.1.13
func (ExecutableWorkflowStatus_GetMessage) Return ¶ added in v0.1.13
func (_m ExecutableWorkflowStatus_GetMessage) Return(_a0 string) *ExecutableWorkflowStatus_GetMessage
type ExecutableWorkflowStatus_GetNodeExecutionStatus ¶ added in v0.1.13
type ExecutableWorkflowStatus_GetOutputReference ¶ added in v0.1.13
type ExecutableWorkflowStatus_GetPhase ¶ added in v0.1.13
func (ExecutableWorkflowStatus_GetPhase) Return ¶ added in v0.1.13
func (_m ExecutableWorkflowStatus_GetPhase) Return(_a0 v1alpha1.WorkflowPhase) *ExecutableWorkflowStatus_GetPhase
type ExecutableWorkflowStatus_GetStartedAt ¶ added in v0.1.13
func (ExecutableWorkflowStatus_GetStartedAt) Return ¶ added in v0.1.13
func (_m ExecutableWorkflowStatus_GetStartedAt) Return(_a0 *v1.Time) *ExecutableWorkflowStatus_GetStartedAt
type ExecutableWorkflowStatus_GetStoppedAt ¶ added in v0.1.13
func (ExecutableWorkflowStatus_GetStoppedAt) Return ¶ added in v0.1.13
func (_m ExecutableWorkflowStatus_GetStoppedAt) Return(_a0 *v1.Time) *ExecutableWorkflowStatus_GetStoppedAt
type ExecutableWorkflowStatus_IsTerminated ¶ added in v0.1.13
func (ExecutableWorkflowStatus_IsTerminated) Return ¶ added in v0.1.13
func (_m ExecutableWorkflowStatus_IsTerminated) Return(_a0 bool) *ExecutableWorkflowStatus_IsTerminated
type ExecutableWorkflow_FindSubWorkflow ¶ added in v0.1.13
func (ExecutableWorkflow_FindSubWorkflow) Return ¶ added in v0.1.13
func (_m ExecutableWorkflow_FindSubWorkflow) Return(_a0 v1alpha1.ExecutableSubWorkflow) *ExecutableWorkflow_FindSubWorkflow
type ExecutableWorkflow_FromNode ¶ added in v0.1.13
func (ExecutableWorkflow_FromNode) Return ¶ added in v0.1.13
func (_m ExecutableWorkflow_FromNode) Return(_a0 []string, _a1 error) *ExecutableWorkflow_FromNode
type ExecutableWorkflow_GetAnnotations ¶ added in v0.1.13
func (ExecutableWorkflow_GetAnnotations) Return ¶ added in v0.1.13
func (_m ExecutableWorkflow_GetAnnotations) Return(_a0 map[string]string) *ExecutableWorkflow_GetAnnotations
type ExecutableWorkflow_GetConnections ¶ added in v0.1.13
func (ExecutableWorkflow_GetConnections) Return ¶ added in v0.1.13
func (_m ExecutableWorkflow_GetConnections) Return(_a0 *v1alpha1.Connections) *ExecutableWorkflow_GetConnections
type ExecutableWorkflow_GetCreationTimestamp ¶ added in v0.1.13
func (ExecutableWorkflow_GetCreationTimestamp) Return ¶ added in v0.1.13
func (_m ExecutableWorkflow_GetCreationTimestamp) Return(_a0 v1.Time) *ExecutableWorkflow_GetCreationTimestamp
type ExecutableWorkflow_GetExecutionID ¶ added in v0.1.13
func (ExecutableWorkflow_GetExecutionID) Return ¶ added in v0.1.13
func (_m ExecutableWorkflow_GetExecutionID) Return(_a0 v1alpha1.WorkflowExecutionIdentifier) *ExecutableWorkflow_GetExecutionID
type ExecutableWorkflow_GetExecutionStatus ¶ added in v0.1.13
type ExecutableWorkflow_GetID ¶ added in v0.1.13
func (ExecutableWorkflow_GetID) Return ¶ added in v0.1.13
func (_m ExecutableWorkflow_GetID) Return(_a0 string) *ExecutableWorkflow_GetID
type ExecutableWorkflow_GetK8sWorkflowID ¶ added in v0.1.13
func (ExecutableWorkflow_GetK8sWorkflowID) Return ¶ added in v0.1.13
func (_m ExecutableWorkflow_GetK8sWorkflowID) Return(_a0 types.NamespacedName) *ExecutableWorkflow_GetK8sWorkflowID
type ExecutableWorkflow_GetLabels ¶ added in v0.1.13
func (ExecutableWorkflow_GetLabels) Return ¶ added in v0.1.13
func (_m ExecutableWorkflow_GetLabels) Return(_a0 map[string]string) *ExecutableWorkflow_GetLabels
type ExecutableWorkflow_GetName ¶ added in v0.1.13
func (ExecutableWorkflow_GetName) Return ¶ added in v0.1.13
func (_m ExecutableWorkflow_GetName) Return(_a0 string) *ExecutableWorkflow_GetName
type ExecutableWorkflow_GetNamespace ¶ added in v0.1.13
func (ExecutableWorkflow_GetNamespace) Return ¶ added in v0.1.13
func (_m ExecutableWorkflow_GetNamespace) Return(_a0 string) *ExecutableWorkflow_GetNamespace
type ExecutableWorkflow_GetNode ¶ added in v0.1.13
func (ExecutableWorkflow_GetNode) Return ¶ added in v0.1.13
func (_m ExecutableWorkflow_GetNode) Return(_a0 v1alpha1.ExecutableNode, _a1 bool) *ExecutableWorkflow_GetNode
type ExecutableWorkflow_GetNodeExecutionStatus ¶ added in v0.1.13
type ExecutableWorkflow_GetNodes ¶ added in v0.1.13
func (ExecutableWorkflow_GetNodes) Return ¶ added in v0.1.13
func (_m ExecutableWorkflow_GetNodes) Return(_a0 []string) *ExecutableWorkflow_GetNodes
type ExecutableWorkflow_GetOnFailureNode ¶ added in v0.1.13
func (ExecutableWorkflow_GetOnFailureNode) Return ¶ added in v0.1.13
func (_m ExecutableWorkflow_GetOnFailureNode) Return(_a0 v1alpha1.ExecutableNode) *ExecutableWorkflow_GetOnFailureNode
type ExecutableWorkflow_GetOutputBindings ¶ added in v0.1.13
func (ExecutableWorkflow_GetOutputBindings) Return ¶ added in v0.1.13
func (_m ExecutableWorkflow_GetOutputBindings) Return(_a0 []*v1alpha1.Binding) *ExecutableWorkflow_GetOutputBindings
type ExecutableWorkflow_GetOutputs ¶ added in v0.1.13
func (ExecutableWorkflow_GetOutputs) Return ¶ added in v0.1.13
func (_m ExecutableWorkflow_GetOutputs) Return(_a0 *v1alpha1.OutputVarMap) *ExecutableWorkflow_GetOutputs
type ExecutableWorkflow_GetOwnerReference ¶ added in v0.1.13
func (ExecutableWorkflow_GetOwnerReference) Return ¶ added in v0.1.13
func (_m ExecutableWorkflow_GetOwnerReference) Return(_a0 v1.OwnerReference) *ExecutableWorkflow_GetOwnerReference
type ExecutableWorkflow_GetServiceAccountName ¶ added in v0.1.13
func (ExecutableWorkflow_GetServiceAccountName) Return ¶ added in v0.1.13
func (_m ExecutableWorkflow_GetServiceAccountName) Return(_a0 string) *ExecutableWorkflow_GetServiceAccountName
type ExecutableWorkflow_GetTask ¶ added in v0.1.13
func (ExecutableWorkflow_GetTask) Return ¶ added in v0.1.13
func (_m ExecutableWorkflow_GetTask) Return(_a0 v1alpha1.ExecutableTask, _a1 error) *ExecutableWorkflow_GetTask
type ExecutableWorkflow_IsInterruptible ¶ added in v0.2.15
func (ExecutableWorkflow_IsInterruptible) Return ¶ added in v0.2.15
func (_m ExecutableWorkflow_IsInterruptible) Return(_a0 bool) *ExecutableWorkflow_IsInterruptible
type ExecutableWorkflow_StartNode ¶ added in v0.1.13
func (ExecutableWorkflow_StartNode) Return ¶ added in v0.1.13
func (_m ExecutableWorkflow_StartNode) Return(_a0 v1alpha1.ExecutableNode) *ExecutableWorkflow_StartNode
type ExecutableWorkflow_ToNode ¶ added in v0.2.28
func (ExecutableWorkflow_ToNode) Return ¶ added in v0.2.28
func (_m ExecutableWorkflow_ToNode) Return(_a0 []string, _a1 error) *ExecutableWorkflow_ToNode
type ExecutionTimeInfo ¶ added in v0.2.28
ExecutionTimeInfo is an autogenerated mock type for the ExecutionTimeInfo type
func (*ExecutionTimeInfo) GetLastUpdatedAt ¶ added in v0.2.28
func (_m *ExecutionTimeInfo) GetLastUpdatedAt() *v1.Time
GetLastUpdatedAt provides a mock function with given fields:
func (*ExecutionTimeInfo) GetStartedAt ¶ added in v0.2.28
func (_m *ExecutionTimeInfo) GetStartedAt() *v1.Time
GetStartedAt provides a mock function with given fields:
func (*ExecutionTimeInfo) GetStoppedAt ¶ added in v0.2.28
func (_m *ExecutionTimeInfo) GetStoppedAt() *v1.Time
GetStoppedAt provides a mock function with given fields:
func (*ExecutionTimeInfo) OnGetLastUpdatedAt ¶ added in v0.2.28
func (_m *ExecutionTimeInfo) OnGetLastUpdatedAt() *ExecutionTimeInfo_GetLastUpdatedAt
func (*ExecutionTimeInfo) OnGetLastUpdatedAtMatch ¶ added in v0.2.28
func (_m *ExecutionTimeInfo) OnGetLastUpdatedAtMatch(matchers ...interface{}) *ExecutionTimeInfo_GetLastUpdatedAt
func (*ExecutionTimeInfo) OnGetStartedAt ¶ added in v0.2.28
func (_m *ExecutionTimeInfo) OnGetStartedAt() *ExecutionTimeInfo_GetStartedAt
func (*ExecutionTimeInfo) OnGetStartedAtMatch ¶ added in v0.2.28
func (_m *ExecutionTimeInfo) OnGetStartedAtMatch(matchers ...interface{}) *ExecutionTimeInfo_GetStartedAt
func (*ExecutionTimeInfo) OnGetStoppedAt ¶ added in v0.2.28
func (_m *ExecutionTimeInfo) OnGetStoppedAt() *ExecutionTimeInfo_GetStoppedAt
func (*ExecutionTimeInfo) OnGetStoppedAtMatch ¶ added in v0.2.28
func (_m *ExecutionTimeInfo) OnGetStoppedAtMatch(matchers ...interface{}) *ExecutionTimeInfo_GetStoppedAt
type ExecutionTimeInfo_GetLastUpdatedAt ¶ added in v0.2.28
func (ExecutionTimeInfo_GetLastUpdatedAt) Return ¶ added in v0.2.28
func (_m ExecutionTimeInfo_GetLastUpdatedAt) Return(_a0 *v1.Time) *ExecutionTimeInfo_GetLastUpdatedAt
type ExecutionTimeInfo_GetStartedAt ¶ added in v0.2.28
func (ExecutionTimeInfo_GetStartedAt) Return ¶ added in v0.2.28
func (_m ExecutionTimeInfo_GetStartedAt) Return(_a0 *v1.Time) *ExecutionTimeInfo_GetStartedAt
type ExecutionTimeInfo_GetStoppedAt ¶ added in v0.2.28
func (ExecutionTimeInfo_GetStoppedAt) Return ¶ added in v0.2.28
func (_m ExecutionTimeInfo_GetStoppedAt) Return(_a0 *v1.Time) *ExecutionTimeInfo_GetStoppedAt
type Meta ¶ added in v0.2.28
Meta is an autogenerated mock type for the Meta type
func (*Meta) GetAnnotations ¶ added in v0.2.28
GetAnnotations provides a mock function with given fields:
func (*Meta) GetCreationTimestamp ¶ added in v0.2.28
GetCreationTimestamp provides a mock function with given fields:
func (*Meta) GetExecutionID ¶ added in v0.2.28
func (_m *Meta) GetExecutionID() v1alpha1.WorkflowExecutionIdentifier
GetExecutionID provides a mock function with given fields:
func (*Meta) GetK8sWorkflowID ¶ added in v0.2.28
func (_m *Meta) GetK8sWorkflowID() types.NamespacedName
GetK8sWorkflowID provides a mock function with given fields:
func (*Meta) GetNamespace ¶ added in v0.2.28
GetNamespace provides a mock function with given fields:
func (*Meta) GetOwnerReference ¶ added in v0.2.28
func (_m *Meta) GetOwnerReference() v1.OwnerReference
GetOwnerReference provides a mock function with given fields:
func (*Meta) GetServiceAccountName ¶ added in v0.2.28
GetServiceAccountName provides a mock function with given fields:
func (*Meta) IsInterruptible ¶ added in v0.2.28
IsInterruptible provides a mock function with given fields:
func (*Meta) OnGetAnnotations ¶ added in v0.2.28
func (_m *Meta) OnGetAnnotations() *Meta_GetAnnotations
func (*Meta) OnGetAnnotationsMatch ¶ added in v0.2.28
func (_m *Meta) OnGetAnnotationsMatch(matchers ...interface{}) *Meta_GetAnnotations
func (*Meta) OnGetCreationTimestamp ¶ added in v0.2.28
func (_m *Meta) OnGetCreationTimestamp() *Meta_GetCreationTimestamp
func (*Meta) OnGetCreationTimestampMatch ¶ added in v0.2.28
func (_m *Meta) OnGetCreationTimestampMatch(matchers ...interface{}) *Meta_GetCreationTimestamp
func (*Meta) OnGetExecutionID ¶ added in v0.2.28
func (_m *Meta) OnGetExecutionID() *Meta_GetExecutionID
func (*Meta) OnGetExecutionIDMatch ¶ added in v0.2.28
func (_m *Meta) OnGetExecutionIDMatch(matchers ...interface{}) *Meta_GetExecutionID
func (*Meta) OnGetK8sWorkflowID ¶ added in v0.2.28
func (_m *Meta) OnGetK8sWorkflowID() *Meta_GetK8sWorkflowID
func (*Meta) OnGetK8sWorkflowIDMatch ¶ added in v0.2.28
func (_m *Meta) OnGetK8sWorkflowIDMatch(matchers ...interface{}) *Meta_GetK8sWorkflowID
func (*Meta) OnGetLabels ¶ added in v0.2.28
func (_m *Meta) OnGetLabels() *Meta_GetLabels
func (*Meta) OnGetLabelsMatch ¶ added in v0.2.28
func (_m *Meta) OnGetLabelsMatch(matchers ...interface{}) *Meta_GetLabels
func (*Meta) OnGetName ¶ added in v0.2.28
func (_m *Meta) OnGetName() *Meta_GetName
func (*Meta) OnGetNameMatch ¶ added in v0.2.28
func (_m *Meta) OnGetNameMatch(matchers ...interface{}) *Meta_GetName
func (*Meta) OnGetNamespace ¶ added in v0.2.28
func (_m *Meta) OnGetNamespace() *Meta_GetNamespace
func (*Meta) OnGetNamespaceMatch ¶ added in v0.2.28
func (_m *Meta) OnGetNamespaceMatch(matchers ...interface{}) *Meta_GetNamespace
func (*Meta) OnGetOwnerReference ¶ added in v0.2.28
func (_m *Meta) OnGetOwnerReference() *Meta_GetOwnerReference
func (*Meta) OnGetOwnerReferenceMatch ¶ added in v0.2.28
func (_m *Meta) OnGetOwnerReferenceMatch(matchers ...interface{}) *Meta_GetOwnerReference
func (*Meta) OnGetServiceAccountName ¶ added in v0.2.28
func (_m *Meta) OnGetServiceAccountName() *Meta_GetServiceAccountName
func (*Meta) OnGetServiceAccountNameMatch ¶ added in v0.2.28
func (_m *Meta) OnGetServiceAccountNameMatch(matchers ...interface{}) *Meta_GetServiceAccountName
func (*Meta) OnIsInterruptible ¶ added in v0.2.28
func (_m *Meta) OnIsInterruptible() *Meta_IsInterruptible
func (*Meta) OnIsInterruptibleMatch ¶ added in v0.2.28
func (_m *Meta) OnIsInterruptibleMatch(matchers ...interface{}) *Meta_IsInterruptible
type MetaExtended ¶ added in v0.2.28
MetaExtended is an autogenerated mock type for the MetaExtended type
func (*MetaExtended) FindSubWorkflow ¶ added in v0.2.28
func (_m *MetaExtended) FindSubWorkflow(subID string) v1alpha1.ExecutableSubWorkflow
FindSubWorkflow provides a mock function with given fields: subID
func (*MetaExtended) GetAnnotations ¶ added in v0.2.28
func (_m *MetaExtended) GetAnnotations() map[string]string
GetAnnotations provides a mock function with given fields:
func (*MetaExtended) GetCreationTimestamp ¶ added in v0.2.28
func (_m *MetaExtended) GetCreationTimestamp() v1.Time
GetCreationTimestamp provides a mock function with given fields:
func (*MetaExtended) GetExecutionID ¶ added in v0.2.28
func (_m *MetaExtended) GetExecutionID() v1alpha1.WorkflowExecutionIdentifier
GetExecutionID provides a mock function with given fields:
func (*MetaExtended) GetExecutionStatus ¶ added in v0.2.28
func (_m *MetaExtended) GetExecutionStatus() v1alpha1.ExecutableWorkflowStatus
GetExecutionStatus provides a mock function with given fields:
func (*MetaExtended) GetK8sWorkflowID ¶ added in v0.2.28
func (_m *MetaExtended) GetK8sWorkflowID() types.NamespacedName
GetK8sWorkflowID provides a mock function with given fields:
func (*MetaExtended) GetLabels ¶ added in v0.2.28
func (_m *MetaExtended) GetLabels() map[string]string
GetLabels provides a mock function with given fields:
func (*MetaExtended) GetName ¶ added in v0.2.28
func (_m *MetaExtended) GetName() string
GetName provides a mock function with given fields:
func (*MetaExtended) GetNamespace ¶ added in v0.2.28
func (_m *MetaExtended) GetNamespace() string
GetNamespace provides a mock function with given fields:
func (*MetaExtended) GetOwnerReference ¶ added in v0.2.28
func (_m *MetaExtended) GetOwnerReference() v1.OwnerReference
GetOwnerReference provides a mock function with given fields:
func (*MetaExtended) GetServiceAccountName ¶ added in v0.2.28
func (_m *MetaExtended) GetServiceAccountName() string
GetServiceAccountName provides a mock function with given fields:
func (*MetaExtended) GetTask ¶ added in v0.2.28
func (_m *MetaExtended) GetTask(id string) (v1alpha1.ExecutableTask, error)
GetTask provides a mock function with given fields: id
func (*MetaExtended) IsInterruptible ¶ added in v0.2.28
func (_m *MetaExtended) IsInterruptible() bool
IsInterruptible provides a mock function with given fields:
func (*MetaExtended) OnFindSubWorkflow ¶ added in v0.2.28
func (_m *MetaExtended) OnFindSubWorkflow(subID string) *MetaExtended_FindSubWorkflow
func (*MetaExtended) OnFindSubWorkflowMatch ¶ added in v0.2.28
func (_m *MetaExtended) OnFindSubWorkflowMatch(matchers ...interface{}) *MetaExtended_FindSubWorkflow
func (*MetaExtended) OnGetAnnotations ¶ added in v0.2.28
func (_m *MetaExtended) OnGetAnnotations() *MetaExtended_GetAnnotations
func (*MetaExtended) OnGetAnnotationsMatch ¶ added in v0.2.28
func (_m *MetaExtended) OnGetAnnotationsMatch(matchers ...interface{}) *MetaExtended_GetAnnotations
func (*MetaExtended) OnGetCreationTimestamp ¶ added in v0.2.28
func (_m *MetaExtended) OnGetCreationTimestamp() *MetaExtended_GetCreationTimestamp
func (*MetaExtended) OnGetCreationTimestampMatch ¶ added in v0.2.28
func (_m *MetaExtended) OnGetCreationTimestampMatch(matchers ...interface{}) *MetaExtended_GetCreationTimestamp
func (*MetaExtended) OnGetExecutionID ¶ added in v0.2.28
func (_m *MetaExtended) OnGetExecutionID() *MetaExtended_GetExecutionID
func (*MetaExtended) OnGetExecutionIDMatch ¶ added in v0.2.28
func (_m *MetaExtended) OnGetExecutionIDMatch(matchers ...interface{}) *MetaExtended_GetExecutionID
func (*MetaExtended) OnGetExecutionStatus ¶ added in v0.2.28
func (_m *MetaExtended) OnGetExecutionStatus() *MetaExtended_GetExecutionStatus
func (*MetaExtended) OnGetExecutionStatusMatch ¶ added in v0.2.28
func (_m *MetaExtended) OnGetExecutionStatusMatch(matchers ...interface{}) *MetaExtended_GetExecutionStatus
func (*MetaExtended) OnGetK8sWorkflowID ¶ added in v0.2.28
func (_m *MetaExtended) OnGetK8sWorkflowID() *MetaExtended_GetK8sWorkflowID
func (*MetaExtended) OnGetK8sWorkflowIDMatch ¶ added in v0.2.28
func (_m *MetaExtended) OnGetK8sWorkflowIDMatch(matchers ...interface{}) *MetaExtended_GetK8sWorkflowID
func (*MetaExtended) OnGetLabels ¶ added in v0.2.28
func (_m *MetaExtended) OnGetLabels() *MetaExtended_GetLabels
func (*MetaExtended) OnGetLabelsMatch ¶ added in v0.2.28
func (_m *MetaExtended) OnGetLabelsMatch(matchers ...interface{}) *MetaExtended_GetLabels
func (*MetaExtended) OnGetName ¶ added in v0.2.28
func (_m *MetaExtended) OnGetName() *MetaExtended_GetName
func (*MetaExtended) OnGetNameMatch ¶ added in v0.2.28
func (_m *MetaExtended) OnGetNameMatch(matchers ...interface{}) *MetaExtended_GetName
func (*MetaExtended) OnGetNamespace ¶ added in v0.2.28
func (_m *MetaExtended) OnGetNamespace() *MetaExtended_GetNamespace
func (*MetaExtended) OnGetNamespaceMatch ¶ added in v0.2.28
func (_m *MetaExtended) OnGetNamespaceMatch(matchers ...interface{}) *MetaExtended_GetNamespace
func (*MetaExtended) OnGetOwnerReference ¶ added in v0.2.28
func (_m *MetaExtended) OnGetOwnerReference() *MetaExtended_GetOwnerReference
func (*MetaExtended) OnGetOwnerReferenceMatch ¶ added in v0.2.28
func (_m *MetaExtended) OnGetOwnerReferenceMatch(matchers ...interface{}) *MetaExtended_GetOwnerReference
func (*MetaExtended) OnGetServiceAccountName ¶ added in v0.2.28
func (_m *MetaExtended) OnGetServiceAccountName() *MetaExtended_GetServiceAccountName
func (*MetaExtended) OnGetServiceAccountNameMatch ¶ added in v0.2.28
func (_m *MetaExtended) OnGetServiceAccountNameMatch(matchers ...interface{}) *MetaExtended_GetServiceAccountName
func (*MetaExtended) OnGetTask ¶ added in v0.2.28
func (_m *MetaExtended) OnGetTask(id string) *MetaExtended_GetTask
func (*MetaExtended) OnGetTaskMatch ¶ added in v0.2.28
func (_m *MetaExtended) OnGetTaskMatch(matchers ...interface{}) *MetaExtended_GetTask
func (*MetaExtended) OnIsInterruptible ¶ added in v0.2.28
func (_m *MetaExtended) OnIsInterruptible() *MetaExtended_IsInterruptible
func (*MetaExtended) OnIsInterruptibleMatch ¶ added in v0.2.28
func (_m *MetaExtended) OnIsInterruptibleMatch(matchers ...interface{}) *MetaExtended_IsInterruptible
type MetaExtended_FindSubWorkflow ¶ added in v0.2.28
func (MetaExtended_FindSubWorkflow) Return ¶ added in v0.2.28
func (_m MetaExtended_FindSubWorkflow) Return(_a0 v1alpha1.ExecutableSubWorkflow) *MetaExtended_FindSubWorkflow
type MetaExtended_GetAnnotations ¶ added in v0.2.28
func (MetaExtended_GetAnnotations) Return ¶ added in v0.2.28
func (_m MetaExtended_GetAnnotations) Return(_a0 map[string]string) *MetaExtended_GetAnnotations
type MetaExtended_GetCreationTimestamp ¶ added in v0.2.28
func (MetaExtended_GetCreationTimestamp) Return ¶ added in v0.2.28
func (_m MetaExtended_GetCreationTimestamp) Return(_a0 v1.Time) *MetaExtended_GetCreationTimestamp
type MetaExtended_GetExecutionID ¶ added in v0.2.28
func (MetaExtended_GetExecutionID) Return ¶ added in v0.2.28
func (_m MetaExtended_GetExecutionID) Return(_a0 v1alpha1.WorkflowExecutionIdentifier) *MetaExtended_GetExecutionID
type MetaExtended_GetExecutionStatus ¶ added in v0.2.28
func (MetaExtended_GetExecutionStatus) Return ¶ added in v0.2.28
func (_m MetaExtended_GetExecutionStatus) Return(_a0 v1alpha1.ExecutableWorkflowStatus) *MetaExtended_GetExecutionStatus
type MetaExtended_GetK8sWorkflowID ¶ added in v0.2.28
func (MetaExtended_GetK8sWorkflowID) Return ¶ added in v0.2.28
func (_m MetaExtended_GetK8sWorkflowID) Return(_a0 types.NamespacedName) *MetaExtended_GetK8sWorkflowID
type MetaExtended_GetLabels ¶ added in v0.2.28
func (MetaExtended_GetLabels) Return ¶ added in v0.2.28
func (_m MetaExtended_GetLabels) Return(_a0 map[string]string) *MetaExtended_GetLabels
type MetaExtended_GetName ¶ added in v0.2.28
func (MetaExtended_GetName) Return ¶ added in v0.2.28
func (_m MetaExtended_GetName) Return(_a0 string) *MetaExtended_GetName
type MetaExtended_GetNamespace ¶ added in v0.2.28
func (MetaExtended_GetNamespace) Return ¶ added in v0.2.28
func (_m MetaExtended_GetNamespace) Return(_a0 string) *MetaExtended_GetNamespace
type MetaExtended_GetOwnerReference ¶ added in v0.2.28
func (MetaExtended_GetOwnerReference) Return ¶ added in v0.2.28
func (_m MetaExtended_GetOwnerReference) Return(_a0 v1.OwnerReference) *MetaExtended_GetOwnerReference
type MetaExtended_GetServiceAccountName ¶ added in v0.2.28
func (MetaExtended_GetServiceAccountName) Return ¶ added in v0.2.28
func (_m MetaExtended_GetServiceAccountName) Return(_a0 string) *MetaExtended_GetServiceAccountName
type MetaExtended_GetTask ¶ added in v0.2.28
func (MetaExtended_GetTask) Return ¶ added in v0.2.28
func (_m MetaExtended_GetTask) Return(_a0 v1alpha1.ExecutableTask, _a1 error) *MetaExtended_GetTask
type MetaExtended_IsInterruptible ¶ added in v0.2.28
func (MetaExtended_IsInterruptible) Return ¶ added in v0.2.28
func (_m MetaExtended_IsInterruptible) Return(_a0 bool) *MetaExtended_IsInterruptible
type Meta_GetAnnotations ¶ added in v0.2.28
func (Meta_GetAnnotations) Return ¶ added in v0.2.28
func (_m Meta_GetAnnotations) Return(_a0 map[string]string) *Meta_GetAnnotations
type Meta_GetCreationTimestamp ¶ added in v0.2.28
func (Meta_GetCreationTimestamp) Return ¶ added in v0.2.28
func (_m Meta_GetCreationTimestamp) Return(_a0 v1.Time) *Meta_GetCreationTimestamp
type Meta_GetExecutionID ¶ added in v0.2.28
func (Meta_GetExecutionID) Return ¶ added in v0.2.28
func (_m Meta_GetExecutionID) Return(_a0 v1alpha1.WorkflowExecutionIdentifier) *Meta_GetExecutionID
type Meta_GetK8sWorkflowID ¶ added in v0.2.28
func (Meta_GetK8sWorkflowID) Return ¶ added in v0.2.28
func (_m Meta_GetK8sWorkflowID) Return(_a0 types.NamespacedName) *Meta_GetK8sWorkflowID
type Meta_GetLabels ¶ added in v0.2.28
func (Meta_GetLabels) Return ¶ added in v0.2.28
func (_m Meta_GetLabels) Return(_a0 map[string]string) *Meta_GetLabels
type Meta_GetName ¶ added in v0.2.28
func (Meta_GetName) Return ¶ added in v0.2.28
func (_m Meta_GetName) Return(_a0 string) *Meta_GetName
type Meta_GetNamespace ¶ added in v0.2.28
func (Meta_GetNamespace) Return ¶ added in v0.2.28
func (_m Meta_GetNamespace) Return(_a0 string) *Meta_GetNamespace
type Meta_GetOwnerReference ¶ added in v0.2.28
func (Meta_GetOwnerReference) Return ¶ added in v0.2.28
func (_m Meta_GetOwnerReference) Return(_a0 v1.OwnerReference) *Meta_GetOwnerReference
type Meta_GetServiceAccountName ¶ added in v0.2.28
func (Meta_GetServiceAccountName) Return ¶ added in v0.2.28
func (_m Meta_GetServiceAccountName) Return(_a0 string) *Meta_GetServiceAccountName
type Meta_IsInterruptible ¶ added in v0.2.28
func (Meta_IsInterruptible) Return ¶ added in v0.2.28
func (_m Meta_IsInterruptible) Return(_a0 bool) *Meta_IsInterruptible
type Mutable ¶ added in v0.1.25
Mutable is an autogenerated mock type for the Mutable type
func (*Mutable) OnIsDirty ¶ added in v0.1.25
func (_m *Mutable) OnIsDirty() *Mutable_IsDirty
func (*Mutable) OnIsDirtyMatch ¶ added in v0.1.25
func (_m *Mutable) OnIsDirtyMatch(matchers ...interface{}) *Mutable_IsDirty
type MutableBranchNodeStatus ¶
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 ¶ added in v0.1.25
func (_m *MutableBranchNodeStatus) IsDirty() bool
IsDirty provides a mock function with given fields:
func (*MutableBranchNodeStatus) OnGetFinalizedNode ¶ added in v0.1.13
func (_m *MutableBranchNodeStatus) OnGetFinalizedNode() *MutableBranchNodeStatus_GetFinalizedNode
func (*MutableBranchNodeStatus) OnGetFinalizedNodeMatch ¶ added in v0.1.13
func (_m *MutableBranchNodeStatus) OnGetFinalizedNodeMatch(matchers ...interface{}) *MutableBranchNodeStatus_GetFinalizedNode
func (*MutableBranchNodeStatus) OnGetPhase ¶ added in v0.1.13
func (_m *MutableBranchNodeStatus) OnGetPhase() *MutableBranchNodeStatus_GetPhase
func (*MutableBranchNodeStatus) OnGetPhaseMatch ¶ added in v0.1.13
func (_m *MutableBranchNodeStatus) OnGetPhaseMatch(matchers ...interface{}) *MutableBranchNodeStatus_GetPhase
func (*MutableBranchNodeStatus) OnIsDirty ¶ added in v0.1.25
func (_m *MutableBranchNodeStatus) OnIsDirty() *MutableBranchNodeStatus_IsDirty
func (*MutableBranchNodeStatus) OnIsDirtyMatch ¶ added in v0.1.25
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 ¶ added in v0.1.13
func (MutableBranchNodeStatus_GetFinalizedNode) Return ¶ added in v0.1.13
func (_m MutableBranchNodeStatus_GetFinalizedNode) Return(_a0 *string) *MutableBranchNodeStatus_GetFinalizedNode
type MutableBranchNodeStatus_GetPhase ¶ added in v0.1.13
func (MutableBranchNodeStatus_GetPhase) Return ¶ added in v0.1.13
func (_m MutableBranchNodeStatus_GetPhase) Return(_a0 v1alpha1.BranchNodePhase) *MutableBranchNodeStatus_GetPhase
type MutableBranchNodeStatus_IsDirty ¶ added in v0.1.25
func (MutableBranchNodeStatus_IsDirty) Return ¶ added in v0.1.25
func (_m MutableBranchNodeStatus_IsDirty) Return(_a0 bool) *MutableBranchNodeStatus_IsDirty
type MutableDynamicNodeStatus ¶
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 ¶ added in v0.1.15
func (_m *MutableDynamicNodeStatus) GetDynamicNodeReason() string
GetDynamicNodeReason provides a mock function with given fields:
func (*MutableDynamicNodeStatus) GetExecutionError ¶ added in v0.2.43
func (_m *MutableDynamicNodeStatus) GetExecutionError() *core.ExecutionError
GetExecutionError provides a mock function with given fields:
func (*MutableDynamicNodeStatus) IsDirty ¶ added in v0.1.25
func (_m *MutableDynamicNodeStatus) IsDirty() bool
IsDirty provides a mock function with given fields:
func (*MutableDynamicNodeStatus) OnGetDynamicNodePhase ¶ added in v0.1.13
func (_m *MutableDynamicNodeStatus) OnGetDynamicNodePhase() *MutableDynamicNodeStatus_GetDynamicNodePhase
func (*MutableDynamicNodeStatus) OnGetDynamicNodePhaseMatch ¶ added in v0.1.13
func (_m *MutableDynamicNodeStatus) OnGetDynamicNodePhaseMatch(matchers ...interface{}) *MutableDynamicNodeStatus_GetDynamicNodePhase
func (*MutableDynamicNodeStatus) OnGetDynamicNodeReason ¶ added in v0.1.15
func (_m *MutableDynamicNodeStatus) OnGetDynamicNodeReason() *MutableDynamicNodeStatus_GetDynamicNodeReason
func (*MutableDynamicNodeStatus) OnGetDynamicNodeReasonMatch ¶ added in v0.1.15
func (_m *MutableDynamicNodeStatus) OnGetDynamicNodeReasonMatch(matchers ...interface{}) *MutableDynamicNodeStatus_GetDynamicNodeReason
func (*MutableDynamicNodeStatus) OnGetExecutionError ¶ added in v0.2.43
func (_m *MutableDynamicNodeStatus) OnGetExecutionError() *MutableDynamicNodeStatus_GetExecutionError
func (*MutableDynamicNodeStatus) OnGetExecutionErrorMatch ¶ added in v0.2.43
func (_m *MutableDynamicNodeStatus) OnGetExecutionErrorMatch(matchers ...interface{}) *MutableDynamicNodeStatus_GetExecutionError
func (*MutableDynamicNodeStatus) OnIsDirty ¶ added in v0.1.25
func (_m *MutableDynamicNodeStatus) OnIsDirty() *MutableDynamicNodeStatus_IsDirty
func (*MutableDynamicNodeStatus) OnIsDirtyMatch ¶ added in v0.1.25
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 ¶ added in v0.1.15
func (_m *MutableDynamicNodeStatus) SetDynamicNodeReason(reason string)
SetDynamicNodeReason provides a mock function with given fields: reason
func (*MutableDynamicNodeStatus) SetExecutionError ¶ added in v0.2.43
func (_m *MutableDynamicNodeStatus) SetExecutionError(executionError *core.ExecutionError)
SetExecutionError provides a mock function with given fields: executionError
type MutableDynamicNodeStatus_GetDynamicNodePhase ¶ added in v0.1.13
type MutableDynamicNodeStatus_GetDynamicNodeReason ¶ added in v0.1.15
func (MutableDynamicNodeStatus_GetDynamicNodeReason) Return ¶ added in v0.1.15
func (_m MutableDynamicNodeStatus_GetDynamicNodeReason) Return(_a0 string) *MutableDynamicNodeStatus_GetDynamicNodeReason
type MutableDynamicNodeStatus_GetExecutionError ¶ added in v0.2.43
func (MutableDynamicNodeStatus_GetExecutionError) Return ¶ added in v0.2.43
func (_m MutableDynamicNodeStatus_GetExecutionError) Return(_a0 *core.ExecutionError) *MutableDynamicNodeStatus_GetExecutionError
type MutableDynamicNodeStatus_IsDirty ¶ added in v0.1.25
func (MutableDynamicNodeStatus_IsDirty) Return ¶ added in v0.1.25
func (_m MutableDynamicNodeStatus_IsDirty) Return(_a0 bool) *MutableDynamicNodeStatus_IsDirty
type MutableNodeStatus ¶
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 ¶ added in v0.1.17
func (_m *MutableNodeStatus) ClearLastAttemptStartedAt()
ClearLastAttemptStartedAt provides a mock function with given fields:
func (*MutableNodeStatus) ClearSubNodeStatus ¶ added in v0.1.25
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 ¶ added in v0.1.13
func (_m *MutableNodeStatus) GetBranchStatus() v1alpha1.MutableBranchNodeStatus
GetBranchStatus provides a mock function with given fields:
func (*MutableNodeStatus) GetDynamicNodeStatus ¶ added in v0.1.13
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 ¶ added in v0.1.13
func (_m *MutableNodeStatus) GetTaskStatus() v1alpha1.MutableTaskNodeStatus
GetTaskStatus provides a mock function with given fields:
func (*MutableNodeStatus) GetWorkflowStatus ¶ added in v0.1.13
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) IncrementSystemFailures ¶ added in v0.2.11
func (_m *MutableNodeStatus) IncrementSystemFailures() uint32
IncrementSystemFailures provides a mock function with given fields:
func (*MutableNodeStatus) IsDirty ¶ added in v0.1.25
func (_m *MutableNodeStatus) IsDirty() bool
IsDirty provides a mock function with given fields:
func (*MutableNodeStatus) OnGetBranchStatus ¶ added in v0.1.13
func (_m *MutableNodeStatus) OnGetBranchStatus() *MutableNodeStatus_GetBranchStatus
func (*MutableNodeStatus) OnGetBranchStatusMatch ¶ added in v0.1.13
func (_m *MutableNodeStatus) OnGetBranchStatusMatch(matchers ...interface{}) *MutableNodeStatus_GetBranchStatus
func (*MutableNodeStatus) OnGetDynamicNodeStatus ¶ added in v0.1.13
func (_m *MutableNodeStatus) OnGetDynamicNodeStatus() *MutableNodeStatus_GetDynamicNodeStatus
func (*MutableNodeStatus) OnGetDynamicNodeStatusMatch ¶ added in v0.1.13
func (_m *MutableNodeStatus) OnGetDynamicNodeStatusMatch(matchers ...interface{}) *MutableNodeStatus_GetDynamicNodeStatus
func (*MutableNodeStatus) OnGetOrCreateBranchStatus ¶ added in v0.1.13
func (_m *MutableNodeStatus) OnGetOrCreateBranchStatus() *MutableNodeStatus_GetOrCreateBranchStatus
func (*MutableNodeStatus) OnGetOrCreateBranchStatusMatch ¶ added in v0.1.13
func (_m *MutableNodeStatus) OnGetOrCreateBranchStatusMatch(matchers ...interface{}) *MutableNodeStatus_GetOrCreateBranchStatus
func (*MutableNodeStatus) OnGetOrCreateDynamicNodeStatus ¶ added in v0.1.13
func (_m *MutableNodeStatus) OnGetOrCreateDynamicNodeStatus() *MutableNodeStatus_GetOrCreateDynamicNodeStatus
func (*MutableNodeStatus) OnGetOrCreateDynamicNodeStatusMatch ¶ added in v0.1.13
func (_m *MutableNodeStatus) OnGetOrCreateDynamicNodeStatusMatch(matchers ...interface{}) *MutableNodeStatus_GetOrCreateDynamicNodeStatus
func (*MutableNodeStatus) OnGetOrCreateTaskStatus ¶ added in v0.1.13
func (_m *MutableNodeStatus) OnGetOrCreateTaskStatus() *MutableNodeStatus_GetOrCreateTaskStatus
func (*MutableNodeStatus) OnGetOrCreateTaskStatusMatch ¶ added in v0.1.13
func (_m *MutableNodeStatus) OnGetOrCreateTaskStatusMatch(matchers ...interface{}) *MutableNodeStatus_GetOrCreateTaskStatus
func (*MutableNodeStatus) OnGetOrCreateWorkflowStatus ¶ added in v0.1.13
func (_m *MutableNodeStatus) OnGetOrCreateWorkflowStatus() *MutableNodeStatus_GetOrCreateWorkflowStatus
func (*MutableNodeStatus) OnGetOrCreateWorkflowStatusMatch ¶ added in v0.1.13
func (_m *MutableNodeStatus) OnGetOrCreateWorkflowStatusMatch(matchers ...interface{}) *MutableNodeStatus_GetOrCreateWorkflowStatus
func (*MutableNodeStatus) OnGetTaskStatus ¶ added in v0.1.13
func (_m *MutableNodeStatus) OnGetTaskStatus() *MutableNodeStatus_GetTaskStatus
func (*MutableNodeStatus) OnGetTaskStatusMatch ¶ added in v0.1.13
func (_m *MutableNodeStatus) OnGetTaskStatusMatch(matchers ...interface{}) *MutableNodeStatus_GetTaskStatus
func (*MutableNodeStatus) OnGetWorkflowStatus ¶ added in v0.1.13
func (_m *MutableNodeStatus) OnGetWorkflowStatus() *MutableNodeStatus_GetWorkflowStatus
func (*MutableNodeStatus) OnGetWorkflowStatusMatch ¶ added in v0.1.13
func (_m *MutableNodeStatus) OnGetWorkflowStatusMatch(matchers ...interface{}) *MutableNodeStatus_GetWorkflowStatus
func (*MutableNodeStatus) OnIncrementAttempts ¶ added in v0.1.13
func (_m *MutableNodeStatus) OnIncrementAttempts() *MutableNodeStatus_IncrementAttempts
func (*MutableNodeStatus) OnIncrementAttemptsMatch ¶ added in v0.1.13
func (_m *MutableNodeStatus) OnIncrementAttemptsMatch(matchers ...interface{}) *MutableNodeStatus_IncrementAttempts
func (*MutableNodeStatus) OnIncrementSystemFailures ¶ added in v0.2.11
func (_m *MutableNodeStatus) OnIncrementSystemFailures() *MutableNodeStatus_IncrementSystemFailures
func (*MutableNodeStatus) OnIncrementSystemFailuresMatch ¶ added in v0.2.11
func (_m *MutableNodeStatus) OnIncrementSystemFailuresMatch(matchers ...interface{}) *MutableNodeStatus_IncrementSystemFailures
func (*MutableNodeStatus) OnIsDirty ¶ added in v0.1.25
func (_m *MutableNodeStatus) OnIsDirty() *MutableNodeStatus_IsDirty
func (*MutableNodeStatus) OnIsDirtyMatch ¶ added in v0.1.25
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 ¶ added in v0.1.27
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, err *core.ExecutionError)
UpdatePhase provides a mock function with given fields: phase, occurredAt, reason, err
type MutableNodeStatus_GetBranchStatus ¶ added in v0.1.13
func (MutableNodeStatus_GetBranchStatus) Return ¶ added in v0.1.13
func (_m MutableNodeStatus_GetBranchStatus) Return(_a0 v1alpha1.MutableBranchNodeStatus) *MutableNodeStatus_GetBranchStatus
type MutableNodeStatus_GetDynamicNodeStatus ¶ added in v0.1.13
type MutableNodeStatus_GetOrCreateBranchStatus ¶ added in v0.1.13
type MutableNodeStatus_GetOrCreateDynamicNodeStatus ¶ added in v0.1.13
type MutableNodeStatus_GetOrCreateTaskStatus ¶ added in v0.1.13
type MutableNodeStatus_GetOrCreateWorkflowStatus ¶ added in v0.1.13
type MutableNodeStatus_GetTaskStatus ¶ added in v0.1.13
func (MutableNodeStatus_GetTaskStatus) Return ¶ added in v0.1.13
func (_m MutableNodeStatus_GetTaskStatus) Return(_a0 v1alpha1.MutableTaskNodeStatus) *MutableNodeStatus_GetTaskStatus
type MutableNodeStatus_GetWorkflowStatus ¶ added in v0.1.13
func (MutableNodeStatus_GetWorkflowStatus) Return ¶ added in v0.1.13
func (_m MutableNodeStatus_GetWorkflowStatus) Return(_a0 v1alpha1.MutableWorkflowNodeStatus) *MutableNodeStatus_GetWorkflowStatus
type MutableNodeStatus_IncrementAttempts ¶ added in v0.1.13
func (MutableNodeStatus_IncrementAttempts) Return ¶ added in v0.1.13
func (_m MutableNodeStatus_IncrementAttempts) Return(_a0 uint32) *MutableNodeStatus_IncrementAttempts
type MutableNodeStatus_IncrementSystemFailures ¶ added in v0.2.11
func (MutableNodeStatus_IncrementSystemFailures) Return ¶ added in v0.2.11
func (_m MutableNodeStatus_IncrementSystemFailures) Return(_a0 uint32) *MutableNodeStatus_IncrementSystemFailures
type MutableNodeStatus_IsDirty ¶ added in v0.1.25
func (MutableNodeStatus_IsDirty) Return ¶ added in v0.1.25
func (_m MutableNodeStatus_IsDirty) Return(_a0 bool) *MutableNodeStatus_IsDirty
type MutableSubWorkflowNodeStatus ¶
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 ¶ added in v0.1.25
func (_m *MutableSubWorkflowNodeStatus) IsDirty() bool
IsDirty provides a mock function with given fields:
func (*MutableSubWorkflowNodeStatus) OnGetPhase ¶ added in v0.1.13
func (_m *MutableSubWorkflowNodeStatus) OnGetPhase() *MutableSubWorkflowNodeStatus_GetPhase
func (*MutableSubWorkflowNodeStatus) OnGetPhaseMatch ¶ added in v0.1.13
func (_m *MutableSubWorkflowNodeStatus) OnGetPhaseMatch(matchers ...interface{}) *MutableSubWorkflowNodeStatus_GetPhase
func (*MutableSubWorkflowNodeStatus) OnIsDirty ¶ added in v0.1.25
func (_m *MutableSubWorkflowNodeStatus) OnIsDirty() *MutableSubWorkflowNodeStatus_IsDirty
func (*MutableSubWorkflowNodeStatus) OnIsDirtyMatch ¶ added in v0.1.25
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 ¶ added in v0.1.13
func (MutableSubWorkflowNodeStatus_GetPhase) Return ¶ added in v0.1.13
func (_m MutableSubWorkflowNodeStatus_GetPhase) Return(_a0 v1alpha1.WorkflowPhase) *MutableSubWorkflowNodeStatus_GetPhase
type MutableSubWorkflowNodeStatus_IsDirty ¶ added in v0.1.25
func (MutableSubWorkflowNodeStatus_IsDirty) Return ¶ added in v0.1.25
func (_m MutableSubWorkflowNodeStatus_IsDirty) Return(_a0 bool) *MutableSubWorkflowNodeStatus_IsDirty
type MutableTaskNodeStatus ¶
MutableTaskNodeStatus is an autogenerated mock type for the MutableTaskNodeStatus type
func (*MutableTaskNodeStatus) GetBarrierClockTick ¶ added in v0.1.13
func (_m *MutableTaskNodeStatus) GetBarrierClockTick() uint32
GetBarrierClockTick provides a mock function with given fields:
func (*MutableTaskNodeStatus) GetLastPhaseUpdatedAt ¶ added in v0.1.27
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 ¶ added in v0.1.13
func (_m *MutableTaskNodeStatus) GetPluginState() []byte
GetPluginState provides a mock function with given fields:
func (*MutableTaskNodeStatus) GetPluginStateVersion ¶ added in v0.1.13
func (_m *MutableTaskNodeStatus) GetPluginStateVersion() uint32
GetPluginStateVersion provides a mock function with given fields:
func (*MutableTaskNodeStatus) IsDirty ¶ added in v0.1.25
func (_m *MutableTaskNodeStatus) IsDirty() bool
IsDirty provides a mock function with given fields:
func (*MutableTaskNodeStatus) OnGetBarrierClockTick ¶ added in v0.1.13
func (_m *MutableTaskNodeStatus) OnGetBarrierClockTick() *MutableTaskNodeStatus_GetBarrierClockTick
func (*MutableTaskNodeStatus) OnGetBarrierClockTickMatch ¶ added in v0.1.13
func (_m *MutableTaskNodeStatus) OnGetBarrierClockTickMatch(matchers ...interface{}) *MutableTaskNodeStatus_GetBarrierClockTick
func (*MutableTaskNodeStatus) OnGetLastPhaseUpdatedAt ¶ added in v0.1.27
func (_m *MutableTaskNodeStatus) OnGetLastPhaseUpdatedAt() *MutableTaskNodeStatus_GetLastPhaseUpdatedAt
func (*MutableTaskNodeStatus) OnGetLastPhaseUpdatedAtMatch ¶ added in v0.1.27
func (_m *MutableTaskNodeStatus) OnGetLastPhaseUpdatedAtMatch(matchers ...interface{}) *MutableTaskNodeStatus_GetLastPhaseUpdatedAt
func (*MutableTaskNodeStatus) OnGetPhase ¶ added in v0.1.13
func (_m *MutableTaskNodeStatus) OnGetPhase() *MutableTaskNodeStatus_GetPhase
func (*MutableTaskNodeStatus) OnGetPhaseMatch ¶ added in v0.1.13
func (_m *MutableTaskNodeStatus) OnGetPhaseMatch(matchers ...interface{}) *MutableTaskNodeStatus_GetPhase
func (*MutableTaskNodeStatus) OnGetPhaseVersion ¶ added in v0.1.13
func (_m *MutableTaskNodeStatus) OnGetPhaseVersion() *MutableTaskNodeStatus_GetPhaseVersion
func (*MutableTaskNodeStatus) OnGetPhaseVersionMatch ¶ added in v0.1.13
func (_m *MutableTaskNodeStatus) OnGetPhaseVersionMatch(matchers ...interface{}) *MutableTaskNodeStatus_GetPhaseVersion
func (*MutableTaskNodeStatus) OnGetPluginState ¶ added in v0.1.13
func (_m *MutableTaskNodeStatus) OnGetPluginState() *MutableTaskNodeStatus_GetPluginState
func (*MutableTaskNodeStatus) OnGetPluginStateMatch ¶ added in v0.1.13
func (_m *MutableTaskNodeStatus) OnGetPluginStateMatch(matchers ...interface{}) *MutableTaskNodeStatus_GetPluginState
func (*MutableTaskNodeStatus) OnGetPluginStateVersion ¶ added in v0.1.13
func (_m *MutableTaskNodeStatus) OnGetPluginStateVersion() *MutableTaskNodeStatus_GetPluginStateVersion
func (*MutableTaskNodeStatus) OnGetPluginStateVersionMatch ¶ added in v0.1.13
func (_m *MutableTaskNodeStatus) OnGetPluginStateVersionMatch(matchers ...interface{}) *MutableTaskNodeStatus_GetPluginStateVersion
func (*MutableTaskNodeStatus) OnIsDirty ¶ added in v0.1.25
func (_m *MutableTaskNodeStatus) OnIsDirty() *MutableTaskNodeStatus_IsDirty
func (*MutableTaskNodeStatus) OnIsDirtyMatch ¶ added in v0.1.25
func (_m *MutableTaskNodeStatus) OnIsDirtyMatch(matchers ...interface{}) *MutableTaskNodeStatus_IsDirty
func (*MutableTaskNodeStatus) SetBarrierClockTick ¶ added in v0.1.13
func (_m *MutableTaskNodeStatus) SetBarrierClockTick(tick uint32)
SetBarrierClockTick provides a mock function with given fields: tick
func (*MutableTaskNodeStatus) SetLastPhaseUpdatedAt ¶ added in v0.1.27
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 ¶ added in v0.1.13
func (_m *MutableTaskNodeStatus) SetPluginState(_a0 []byte)
SetPluginState provides a mock function with given fields: _a0
func (*MutableTaskNodeStatus) SetPluginStateVersion ¶ added in v0.1.13
func (_m *MutableTaskNodeStatus) SetPluginStateVersion(_a0 uint32)
SetPluginStateVersion provides a mock function with given fields: _a0
type MutableTaskNodeStatus_GetBarrierClockTick ¶ added in v0.1.13
func (MutableTaskNodeStatus_GetBarrierClockTick) Return ¶ added in v0.1.13
func (_m MutableTaskNodeStatus_GetBarrierClockTick) Return(_a0 uint32) *MutableTaskNodeStatus_GetBarrierClockTick
type MutableTaskNodeStatus_GetLastPhaseUpdatedAt ¶ added in v0.1.27
func (MutableTaskNodeStatus_GetLastPhaseUpdatedAt) Return ¶ added in v0.1.27
func (_m MutableTaskNodeStatus_GetLastPhaseUpdatedAt) Return(_a0 time.Time) *MutableTaskNodeStatus_GetLastPhaseUpdatedAt
type MutableTaskNodeStatus_GetPhase ¶ added in v0.1.13
func (MutableTaskNodeStatus_GetPhase) Return ¶ added in v0.1.13
func (_m MutableTaskNodeStatus_GetPhase) Return(_a0 int) *MutableTaskNodeStatus_GetPhase
type MutableTaskNodeStatus_GetPhaseVersion ¶ added in v0.1.13
func (MutableTaskNodeStatus_GetPhaseVersion) Return ¶ added in v0.1.13
func (_m MutableTaskNodeStatus_GetPhaseVersion) Return(_a0 uint32) *MutableTaskNodeStatus_GetPhaseVersion
type MutableTaskNodeStatus_GetPluginState ¶ added in v0.1.13
func (MutableTaskNodeStatus_GetPluginState) Return ¶ added in v0.1.13
func (_m MutableTaskNodeStatus_GetPluginState) Return(_a0 []byte) *MutableTaskNodeStatus_GetPluginState
type MutableTaskNodeStatus_GetPluginStateVersion ¶ added in v0.1.13
func (MutableTaskNodeStatus_GetPluginStateVersion) Return ¶ added in v0.1.13
func (_m MutableTaskNodeStatus_GetPluginStateVersion) Return(_a0 uint32) *MutableTaskNodeStatus_GetPluginStateVersion
type MutableTaskNodeStatus_IsDirty ¶ added in v0.1.25
func (MutableTaskNodeStatus_IsDirty) Return ¶ added in v0.1.25
func (_m MutableTaskNodeStatus_IsDirty) Return(_a0 bool) *MutableTaskNodeStatus_IsDirty
type MutableWorkflowNodeStatus ¶
MutableWorkflowNodeStatus is an autogenerated mock type for the MutableWorkflowNodeStatus type
func (*MutableWorkflowNodeStatus) GetExecutionError ¶ added in v0.2.43
func (_m *MutableWorkflowNodeStatus) GetExecutionError() *core.ExecutionError
GetExecutionError provides a mock function with given fields:
func (*MutableWorkflowNodeStatus) GetWorkflowNodePhase ¶ added in v0.1.13
func (_m *MutableWorkflowNodeStatus) GetWorkflowNodePhase() v1alpha1.WorkflowNodePhase
GetWorkflowNodePhase provides a mock function with given fields:
func (*MutableWorkflowNodeStatus) IsDirty ¶ added in v0.1.25
func (_m *MutableWorkflowNodeStatus) IsDirty() bool
IsDirty provides a mock function with given fields:
func (*MutableWorkflowNodeStatus) OnGetExecutionError ¶ added in v0.2.43
func (_m *MutableWorkflowNodeStatus) OnGetExecutionError() *MutableWorkflowNodeStatus_GetExecutionError
func (*MutableWorkflowNodeStatus) OnGetExecutionErrorMatch ¶ added in v0.2.43
func (_m *MutableWorkflowNodeStatus) OnGetExecutionErrorMatch(matchers ...interface{}) *MutableWorkflowNodeStatus_GetExecutionError
func (*MutableWorkflowNodeStatus) OnGetWorkflowNodePhase ¶ added in v0.1.13
func (_m *MutableWorkflowNodeStatus) OnGetWorkflowNodePhase() *MutableWorkflowNodeStatus_GetWorkflowNodePhase
func (*MutableWorkflowNodeStatus) OnGetWorkflowNodePhaseMatch ¶ added in v0.1.13
func (_m *MutableWorkflowNodeStatus) OnGetWorkflowNodePhaseMatch(matchers ...interface{}) *MutableWorkflowNodeStatus_GetWorkflowNodePhase
func (*MutableWorkflowNodeStatus) OnIsDirty ¶ added in v0.1.25
func (_m *MutableWorkflowNodeStatus) OnIsDirty() *MutableWorkflowNodeStatus_IsDirty
func (*MutableWorkflowNodeStatus) OnIsDirtyMatch ¶ added in v0.1.25
func (_m *MutableWorkflowNodeStatus) OnIsDirtyMatch(matchers ...interface{}) *MutableWorkflowNodeStatus_IsDirty
func (*MutableWorkflowNodeStatus) SetExecutionError ¶ added in v0.2.43
func (_m *MutableWorkflowNodeStatus) SetExecutionError(executionError *core.ExecutionError)
SetExecutionError provides a mock function with given fields: executionError
func (*MutableWorkflowNodeStatus) SetWorkflowNodePhase ¶ added in v0.1.13
func (_m *MutableWorkflowNodeStatus) SetWorkflowNodePhase(phase v1alpha1.WorkflowNodePhase)
SetWorkflowNodePhase provides a mock function with given fields: phase
type MutableWorkflowNodeStatus_GetExecutionError ¶ added in v0.2.43
func (MutableWorkflowNodeStatus_GetExecutionError) Return ¶ added in v0.2.43
func (_m MutableWorkflowNodeStatus_GetExecutionError) Return(_a0 *core.ExecutionError) *MutableWorkflowNodeStatus_GetExecutionError
type MutableWorkflowNodeStatus_GetWorkflowNodePhase ¶ added in v0.1.13
type MutableWorkflowNodeStatus_IsDirty ¶ added in v0.1.25
func (MutableWorkflowNodeStatus_IsDirty) Return ¶ added in v0.1.25
func (_m MutableWorkflowNodeStatus_IsDirty) Return(_a0 bool) *MutableWorkflowNodeStatus_IsDirty
type Mutable_IsDirty ¶ added in v0.1.25
func (Mutable_IsDirty) Return ¶ added in v0.1.25
func (_m Mutable_IsDirty) Return(_a0 bool) *Mutable_IsDirty
type NodeGetter ¶ added in v0.2.28
NodeGetter is an autogenerated mock type for the NodeGetter type
func (*NodeGetter) GetNode ¶ added in v0.2.28
func (_m *NodeGetter) GetNode(nodeID string) (v1alpha1.ExecutableNode, bool)
GetNode provides a mock function with given fields: nodeID
func (*NodeGetter) OnGetNode ¶ added in v0.2.28
func (_m *NodeGetter) OnGetNode(nodeID string) *NodeGetter_GetNode
func (*NodeGetter) OnGetNodeMatch ¶ added in v0.2.28
func (_m *NodeGetter) OnGetNodeMatch(matchers ...interface{}) *NodeGetter_GetNode
type NodeGetter_GetNode ¶ added in v0.2.28
func (NodeGetter_GetNode) Return ¶ added in v0.2.28
func (_m NodeGetter_GetNode) Return(_a0 v1alpha1.ExecutableNode, _a1 bool) *NodeGetter_GetNode
type NodeStatusGetter ¶
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 ¶ added in v0.1.13
func (_m *NodeStatusGetter) OnGetNodeExecutionStatus(ctx context.Context, id string) *NodeStatusGetter_GetNodeExecutionStatus
func (*NodeStatusGetter) OnGetNodeExecutionStatusMatch ¶ added in v0.1.13
func (_m *NodeStatusGetter) OnGetNodeExecutionStatusMatch(matchers ...interface{}) *NodeStatusGetter_GetNodeExecutionStatus
type NodeStatusGetter_GetNodeExecutionStatus ¶ added in v0.1.13
type NodeStatusVisitor ¶
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 SubWorkflowGetter ¶ added in v0.2.28
SubWorkflowGetter is an autogenerated mock type for the SubWorkflowGetter type
func (*SubWorkflowGetter) FindSubWorkflow ¶ added in v0.2.28
func (_m *SubWorkflowGetter) FindSubWorkflow(subID string) v1alpha1.ExecutableSubWorkflow
FindSubWorkflow provides a mock function with given fields: subID
func (*SubWorkflowGetter) OnFindSubWorkflow ¶ added in v0.2.28
func (_m *SubWorkflowGetter) OnFindSubWorkflow(subID string) *SubWorkflowGetter_FindSubWorkflow
func (*SubWorkflowGetter) OnFindSubWorkflowMatch ¶ added in v0.2.28
func (_m *SubWorkflowGetter) OnFindSubWorkflowMatch(matchers ...interface{}) *SubWorkflowGetter_FindSubWorkflow
type SubWorkflowGetter_FindSubWorkflow ¶ added in v0.2.28
func (SubWorkflowGetter_FindSubWorkflow) Return ¶ added in v0.2.28
func (_m SubWorkflowGetter_FindSubWorkflow) Return(_a0 v1alpha1.ExecutableSubWorkflow) *SubWorkflowGetter_FindSubWorkflow
type TaskDetailsGetter ¶ added in v0.1.13
TaskDetailsGetter is an autogenerated mock type for the TaskDetailsGetter type
func (*TaskDetailsGetter) GetTask ¶ added in v0.1.13
func (_m *TaskDetailsGetter) GetTask(id string) (v1alpha1.ExecutableTask, error)
GetTask provides a mock function with given fields: id
func (*TaskDetailsGetter) OnGetTask ¶ added in v0.1.13
func (_m *TaskDetailsGetter) OnGetTask(id string) *TaskDetailsGetter_GetTask
func (*TaskDetailsGetter) OnGetTaskMatch ¶ added in v0.1.13
func (_m *TaskDetailsGetter) OnGetTaskMatch(matchers ...interface{}) *TaskDetailsGetter_GetTask
type TaskDetailsGetter_GetTask ¶ added in v0.1.13
func (TaskDetailsGetter_GetTask) Return ¶ added in v0.1.13
func (_m TaskDetailsGetter_GetTask) Return(_a0 v1alpha1.ExecutableTask, _a1 error) *TaskDetailsGetter_GetTask
type WorkflowMeta ¶
Meta is an autogenerated mock type for the Meta 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 ¶ added in v0.1.13
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) IsInterruptible ¶ added in v0.2.15
func (_m *WorkflowMeta) IsInterruptible() bool
IsInterruptible provides a mock function with given fields:
func (*WorkflowMeta) OnGetAnnotations ¶ added in v0.1.13
func (_m *WorkflowMeta) OnGetAnnotations() *WorkflowMeta_GetAnnotations
func (*WorkflowMeta) OnGetAnnotationsMatch ¶ added in v0.1.13
func (_m *WorkflowMeta) OnGetAnnotationsMatch(matchers ...interface{}) *WorkflowMeta_GetAnnotations
func (*WorkflowMeta) OnGetCreationTimestamp ¶ added in v0.1.13
func (_m *WorkflowMeta) OnGetCreationTimestamp() *WorkflowMeta_GetCreationTimestamp
func (*WorkflowMeta) OnGetCreationTimestampMatch ¶ added in v0.1.13
func (_m *WorkflowMeta) OnGetCreationTimestampMatch(matchers ...interface{}) *WorkflowMeta_GetCreationTimestamp
func (*WorkflowMeta) OnGetExecutionID ¶ added in v0.1.13
func (_m *WorkflowMeta) OnGetExecutionID() *WorkflowMeta_GetExecutionID
func (*WorkflowMeta) OnGetExecutionIDMatch ¶ added in v0.1.13
func (_m *WorkflowMeta) OnGetExecutionIDMatch(matchers ...interface{}) *WorkflowMeta_GetExecutionID
func (*WorkflowMeta) OnGetK8sWorkflowID ¶ added in v0.1.13
func (_m *WorkflowMeta) OnGetK8sWorkflowID() *WorkflowMeta_GetK8sWorkflowID
func (*WorkflowMeta) OnGetK8sWorkflowIDMatch ¶ added in v0.1.13
func (_m *WorkflowMeta) OnGetK8sWorkflowIDMatch(matchers ...interface{}) *WorkflowMeta_GetK8sWorkflowID
func (*WorkflowMeta) OnGetLabels ¶ added in v0.1.13
func (_m *WorkflowMeta) OnGetLabels() *WorkflowMeta_GetLabels
func (*WorkflowMeta) OnGetLabelsMatch ¶ added in v0.1.13
func (_m *WorkflowMeta) OnGetLabelsMatch(matchers ...interface{}) *WorkflowMeta_GetLabels
func (*WorkflowMeta) OnGetName ¶ added in v0.1.13
func (_m *WorkflowMeta) OnGetName() *WorkflowMeta_GetName
func (*WorkflowMeta) OnGetNameMatch ¶ added in v0.1.13
func (_m *WorkflowMeta) OnGetNameMatch(matchers ...interface{}) *WorkflowMeta_GetName
func (*WorkflowMeta) OnGetNamespace ¶ added in v0.1.13
func (_m *WorkflowMeta) OnGetNamespace() *WorkflowMeta_GetNamespace
func (*WorkflowMeta) OnGetNamespaceMatch ¶ added in v0.1.13
func (_m *WorkflowMeta) OnGetNamespaceMatch(matchers ...interface{}) *WorkflowMeta_GetNamespace
func (*WorkflowMeta) OnGetOwnerReference ¶ added in v0.1.13
func (_m *WorkflowMeta) OnGetOwnerReference() *WorkflowMeta_GetOwnerReference
func (*WorkflowMeta) OnGetOwnerReferenceMatch ¶ added in v0.1.13
func (_m *WorkflowMeta) OnGetOwnerReferenceMatch(matchers ...interface{}) *WorkflowMeta_GetOwnerReference
func (*WorkflowMeta) OnGetServiceAccountName ¶ added in v0.1.13
func (_m *WorkflowMeta) OnGetServiceAccountName() *WorkflowMeta_GetServiceAccountName
func (*WorkflowMeta) OnGetServiceAccountNameMatch ¶ added in v0.1.13
func (_m *WorkflowMeta) OnGetServiceAccountNameMatch(matchers ...interface{}) *WorkflowMeta_GetServiceAccountName
func (*WorkflowMeta) OnIsInterruptible ¶ added in v0.2.15
func (_m *WorkflowMeta) OnIsInterruptible() *WorkflowMeta_IsInterruptible
func (*WorkflowMeta) OnIsInterruptibleMatch ¶ added in v0.2.15
func (_m *WorkflowMeta) OnIsInterruptibleMatch(matchers ...interface{}) *WorkflowMeta_IsInterruptible
type WorkflowMetaExtended ¶
MetaExtended is an autogenerated mock type for the MetaExtended 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 ¶ added in v0.1.13
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) IsInterruptible ¶ added in v0.2.15
func (_m *WorkflowMetaExtended) IsInterruptible() bool
IsInterruptible provides a mock function with given fields:
func (*WorkflowMetaExtended) OnFindSubWorkflow ¶ added in v0.1.13
func (_m *WorkflowMetaExtended) OnFindSubWorkflow(subID string) *WorkflowMetaExtended_FindSubWorkflow
func (*WorkflowMetaExtended) OnFindSubWorkflowMatch ¶ added in v0.1.13
func (_m *WorkflowMetaExtended) OnFindSubWorkflowMatch(matchers ...interface{}) *WorkflowMetaExtended_FindSubWorkflow
func (*WorkflowMetaExtended) OnGetAnnotations ¶ added in v0.1.13
func (_m *WorkflowMetaExtended) OnGetAnnotations() *WorkflowMetaExtended_GetAnnotations
func (*WorkflowMetaExtended) OnGetAnnotationsMatch ¶ added in v0.1.13
func (_m *WorkflowMetaExtended) OnGetAnnotationsMatch(matchers ...interface{}) *WorkflowMetaExtended_GetAnnotations
func (*WorkflowMetaExtended) OnGetCreationTimestamp ¶ added in v0.1.13
func (_m *WorkflowMetaExtended) OnGetCreationTimestamp() *WorkflowMetaExtended_GetCreationTimestamp
func (*WorkflowMetaExtended) OnGetCreationTimestampMatch ¶ added in v0.1.13
func (_m *WorkflowMetaExtended) OnGetCreationTimestampMatch(matchers ...interface{}) *WorkflowMetaExtended_GetCreationTimestamp
func (*WorkflowMetaExtended) OnGetExecutionID ¶ added in v0.1.13
func (_m *WorkflowMetaExtended) OnGetExecutionID() *WorkflowMetaExtended_GetExecutionID
func (*WorkflowMetaExtended) OnGetExecutionIDMatch ¶ added in v0.1.13
func (_m *WorkflowMetaExtended) OnGetExecutionIDMatch(matchers ...interface{}) *WorkflowMetaExtended_GetExecutionID
func (*WorkflowMetaExtended) OnGetExecutionStatus ¶ added in v0.1.13
func (_m *WorkflowMetaExtended) OnGetExecutionStatus() *WorkflowMetaExtended_GetExecutionStatus
func (*WorkflowMetaExtended) OnGetExecutionStatusMatch ¶ added in v0.1.13
func (_m *WorkflowMetaExtended) OnGetExecutionStatusMatch(matchers ...interface{}) *WorkflowMetaExtended_GetExecutionStatus
func (*WorkflowMetaExtended) OnGetK8sWorkflowID ¶ added in v0.1.13
func (_m *WorkflowMetaExtended) OnGetK8sWorkflowID() *WorkflowMetaExtended_GetK8sWorkflowID
func (*WorkflowMetaExtended) OnGetK8sWorkflowIDMatch ¶ added in v0.1.13
func (_m *WorkflowMetaExtended) OnGetK8sWorkflowIDMatch(matchers ...interface{}) *WorkflowMetaExtended_GetK8sWorkflowID
func (*WorkflowMetaExtended) OnGetLabels ¶ added in v0.1.13
func (_m *WorkflowMetaExtended) OnGetLabels() *WorkflowMetaExtended_GetLabels
func (*WorkflowMetaExtended) OnGetLabelsMatch ¶ added in v0.1.13
func (_m *WorkflowMetaExtended) OnGetLabelsMatch(matchers ...interface{}) *WorkflowMetaExtended_GetLabels
func (*WorkflowMetaExtended) OnGetName ¶ added in v0.1.13
func (_m *WorkflowMetaExtended) OnGetName() *WorkflowMetaExtended_GetName
func (*WorkflowMetaExtended) OnGetNameMatch ¶ added in v0.1.13
func (_m *WorkflowMetaExtended) OnGetNameMatch(matchers ...interface{}) *WorkflowMetaExtended_GetName
func (*WorkflowMetaExtended) OnGetNamespace ¶ added in v0.1.13
func (_m *WorkflowMetaExtended) OnGetNamespace() *WorkflowMetaExtended_GetNamespace
func (*WorkflowMetaExtended) OnGetNamespaceMatch ¶ added in v0.1.13
func (_m *WorkflowMetaExtended) OnGetNamespaceMatch(matchers ...interface{}) *WorkflowMetaExtended_GetNamespace
func (*WorkflowMetaExtended) OnGetOwnerReference ¶ added in v0.1.13
func (_m *WorkflowMetaExtended) OnGetOwnerReference() *WorkflowMetaExtended_GetOwnerReference
func (*WorkflowMetaExtended) OnGetOwnerReferenceMatch ¶ added in v0.1.13
func (_m *WorkflowMetaExtended) OnGetOwnerReferenceMatch(matchers ...interface{}) *WorkflowMetaExtended_GetOwnerReference
func (*WorkflowMetaExtended) OnGetServiceAccountName ¶ added in v0.1.13
func (_m *WorkflowMetaExtended) OnGetServiceAccountName() *WorkflowMetaExtended_GetServiceAccountName
func (*WorkflowMetaExtended) OnGetServiceAccountNameMatch ¶ added in v0.1.13
func (_m *WorkflowMetaExtended) OnGetServiceAccountNameMatch(matchers ...interface{}) *WorkflowMetaExtended_GetServiceAccountName
func (*WorkflowMetaExtended) OnGetTask ¶ added in v0.1.13
func (_m *WorkflowMetaExtended) OnGetTask(id string) *WorkflowMetaExtended_GetTask
func (*WorkflowMetaExtended) OnGetTaskMatch ¶ added in v0.1.13
func (_m *WorkflowMetaExtended) OnGetTaskMatch(matchers ...interface{}) *WorkflowMetaExtended_GetTask
func (*WorkflowMetaExtended) OnIsInterruptible ¶ added in v0.2.15
func (_m *WorkflowMetaExtended) OnIsInterruptible() *WorkflowMetaExtended_IsInterruptible
func (*WorkflowMetaExtended) OnIsInterruptibleMatch ¶ added in v0.2.15
func (_m *WorkflowMetaExtended) OnIsInterruptibleMatch(matchers ...interface{}) *WorkflowMetaExtended_IsInterruptible
type WorkflowMetaExtended_FindSubWorkflow ¶ added in v0.1.13
func (WorkflowMetaExtended_FindSubWorkflow) Return ¶ added in v0.1.13
func (_m WorkflowMetaExtended_FindSubWorkflow) Return(_a0 v1alpha1.ExecutableSubWorkflow) *WorkflowMetaExtended_FindSubWorkflow
type WorkflowMetaExtended_GetAnnotations ¶ added in v0.1.13
func (WorkflowMetaExtended_GetAnnotations) Return ¶ added in v0.1.13
func (_m WorkflowMetaExtended_GetAnnotations) Return(_a0 map[string]string) *WorkflowMetaExtended_GetAnnotations
type WorkflowMetaExtended_GetCreationTimestamp ¶ added in v0.1.13
func (WorkflowMetaExtended_GetCreationTimestamp) Return ¶ added in v0.1.13
func (_m WorkflowMetaExtended_GetCreationTimestamp) Return(_a0 v1.Time) *WorkflowMetaExtended_GetCreationTimestamp
type WorkflowMetaExtended_GetExecutionID ¶ added in v0.1.13
type WorkflowMetaExtended_GetExecutionStatus ¶ added in v0.1.13
type WorkflowMetaExtended_GetK8sWorkflowID ¶ added in v0.1.13
func (WorkflowMetaExtended_GetK8sWorkflowID) Return ¶ added in v0.1.13
func (_m WorkflowMetaExtended_GetK8sWorkflowID) Return(_a0 types.NamespacedName) *WorkflowMetaExtended_GetK8sWorkflowID
type WorkflowMetaExtended_GetLabels ¶ added in v0.1.13
func (WorkflowMetaExtended_GetLabels) Return ¶ added in v0.1.13
func (_m WorkflowMetaExtended_GetLabels) Return(_a0 map[string]string) *WorkflowMetaExtended_GetLabels
type WorkflowMetaExtended_GetName ¶ added in v0.1.13
func (WorkflowMetaExtended_GetName) Return ¶ added in v0.1.13
func (_m WorkflowMetaExtended_GetName) Return(_a0 string) *WorkflowMetaExtended_GetName
type WorkflowMetaExtended_GetNamespace ¶ added in v0.1.13
func (WorkflowMetaExtended_GetNamespace) Return ¶ added in v0.1.13
func (_m WorkflowMetaExtended_GetNamespace) Return(_a0 string) *WorkflowMetaExtended_GetNamespace
type WorkflowMetaExtended_GetOwnerReference ¶ added in v0.1.13
func (WorkflowMetaExtended_GetOwnerReference) Return ¶ added in v0.1.13
func (_m WorkflowMetaExtended_GetOwnerReference) Return(_a0 v1.OwnerReference) *WorkflowMetaExtended_GetOwnerReference
type WorkflowMetaExtended_GetServiceAccountName ¶ added in v0.1.13
func (WorkflowMetaExtended_GetServiceAccountName) Return ¶ added in v0.1.13
func (_m WorkflowMetaExtended_GetServiceAccountName) Return(_a0 string) *WorkflowMetaExtended_GetServiceAccountName
type WorkflowMetaExtended_GetTask ¶ added in v0.1.13
func (WorkflowMetaExtended_GetTask) Return ¶ added in v0.1.13
func (_m WorkflowMetaExtended_GetTask) Return(_a0 v1alpha1.ExecutableTask, _a1 error) *WorkflowMetaExtended_GetTask
type WorkflowMetaExtended_IsInterruptible ¶ added in v0.2.15
func (WorkflowMetaExtended_IsInterruptible) Return ¶ added in v0.2.15
func (_m WorkflowMetaExtended_IsInterruptible) Return(_a0 bool) *WorkflowMetaExtended_IsInterruptible
type WorkflowMeta_GetAnnotations ¶ added in v0.1.13
func (WorkflowMeta_GetAnnotations) Return ¶ added in v0.1.13
func (_m WorkflowMeta_GetAnnotations) Return(_a0 map[string]string) *WorkflowMeta_GetAnnotations
type WorkflowMeta_GetCreationTimestamp ¶ added in v0.1.13
func (WorkflowMeta_GetCreationTimestamp) Return ¶ added in v0.1.13
func (_m WorkflowMeta_GetCreationTimestamp) Return(_a0 v1.Time) *WorkflowMeta_GetCreationTimestamp
type WorkflowMeta_GetExecutionID ¶ added in v0.1.13
func (WorkflowMeta_GetExecutionID) Return ¶ added in v0.1.13
func (_m WorkflowMeta_GetExecutionID) Return(_a0 v1alpha1.WorkflowExecutionIdentifier) *WorkflowMeta_GetExecutionID
type WorkflowMeta_GetK8sWorkflowID ¶ added in v0.1.13
func (WorkflowMeta_GetK8sWorkflowID) Return ¶ added in v0.1.13
func (_m WorkflowMeta_GetK8sWorkflowID) Return(_a0 types.NamespacedName) *WorkflowMeta_GetK8sWorkflowID
type WorkflowMeta_GetLabels ¶ added in v0.1.13
func (WorkflowMeta_GetLabels) Return ¶ added in v0.1.13
func (_m WorkflowMeta_GetLabels) Return(_a0 map[string]string) *WorkflowMeta_GetLabels
type WorkflowMeta_GetName ¶ added in v0.1.13
func (WorkflowMeta_GetName) Return ¶ added in v0.1.13
func (_m WorkflowMeta_GetName) Return(_a0 string) *WorkflowMeta_GetName
type WorkflowMeta_GetNamespace ¶ added in v0.1.13
func (WorkflowMeta_GetNamespace) Return ¶ added in v0.1.13
func (_m WorkflowMeta_GetNamespace) Return(_a0 string) *WorkflowMeta_GetNamespace
type WorkflowMeta_GetOwnerReference ¶ added in v0.1.13
func (WorkflowMeta_GetOwnerReference) Return ¶ added in v0.1.13
func (_m WorkflowMeta_GetOwnerReference) Return(_a0 v1.OwnerReference) *WorkflowMeta_GetOwnerReference
type WorkflowMeta_GetServiceAccountName ¶ added in v0.1.13
func (WorkflowMeta_GetServiceAccountName) Return ¶ added in v0.1.13
func (_m WorkflowMeta_GetServiceAccountName) Return(_a0 string) *WorkflowMeta_GetServiceAccountName
type WorkflowMeta_IsInterruptible ¶ added in v0.2.15
func (WorkflowMeta_IsInterruptible) Return ¶ added in v0.2.15
func (_m WorkflowMeta_IsInterruptible) Return(_a0 bool) *WorkflowMeta_IsInterruptible
Source Files ¶
- BaseNode.go
- BaseWorkflow.go
- BaseWorkflowWithStatus.go
- ExecutableBranchNode.go
- ExecutableBranchNodeStatus.go
- ExecutableDynamicNodeStatus.go
- ExecutableIfBlock.go
- ExecutableNode.go
- ExecutableNodeStatus.go
- ExecutableSubWorkflow.go
- ExecutableSubWorkflowNodeStatus.go
- ExecutableTask.go
- ExecutableTaskNodeStatus.go
- ExecutableWorkflow.go
- ExecutableWorkflowNode.go
- ExecutableWorkflowNodeStatus.go
- ExecutableWorkflowStatus.go
- ExecutionTimeInfo.go
- Meta.go
- MetaExtended.go
- Mutable.go
- MutableBranchNodeStatus.go
- MutableDynamicNodeStatus.go
- MutableNodeStatus.go
- MutableSubWorkflowNodeStatus.go
- MutableTaskNodeStatus.go
- MutableWorkflowNodeStatus.go
- NodeGetter.go
- NodeStatusGetter.go
- NodeStatusVisitor.go
- SubWorkflowGetter.go
- TaskDetailsGetter.go
- WorkflowMeta.go
- WorkflowMetaExtended.go