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 ExecutableArrayNode
- func (_m *ExecutableArrayNode) GetMinSuccessRatio() *float32
- func (_m *ExecutableArrayNode) GetMinSuccesses() *uint32
- func (_m *ExecutableArrayNode) GetParallelism() *uint32
- func (_m *ExecutableArrayNode) GetSubNodeSpec() *v1alpha1.NodeSpec
- func (_m *ExecutableArrayNode) OnGetMinSuccessRatio() *ExecutableArrayNode_GetMinSuccessRatio
- func (_m *ExecutableArrayNode) OnGetMinSuccessRatioMatch(matchers ...interface{}) *ExecutableArrayNode_GetMinSuccessRatio
- func (_m *ExecutableArrayNode) OnGetMinSuccesses() *ExecutableArrayNode_GetMinSuccesses
- func (_m *ExecutableArrayNode) OnGetMinSuccessesMatch(matchers ...interface{}) *ExecutableArrayNode_GetMinSuccesses
- func (_m *ExecutableArrayNode) OnGetParallelism() *ExecutableArrayNode_GetParallelism
- func (_m *ExecutableArrayNode) OnGetParallelismMatch(matchers ...interface{}) *ExecutableArrayNode_GetParallelism
- func (_m *ExecutableArrayNode) OnGetSubNodeSpec() *ExecutableArrayNode_GetSubNodeSpec
- func (_m *ExecutableArrayNode) OnGetSubNodeSpecMatch(matchers ...interface{}) *ExecutableArrayNode_GetSubNodeSpec
- type ExecutableArrayNodeStatus
- func (_m *ExecutableArrayNodeStatus) GetArrayNodePhase() v1alpha1.ArrayNodePhase
- func (_m *ExecutableArrayNodeStatus) GetExecutionError() *core.ExecutionError
- func (_m *ExecutableArrayNodeStatus) GetSubNodePhases() bitarray.CompactArray
- func (_m *ExecutableArrayNodeStatus) GetSubNodeRetryAttempts() bitarray.CompactArray
- func (_m *ExecutableArrayNodeStatus) GetSubNodeSystemFailures() bitarray.CompactArray
- func (_m *ExecutableArrayNodeStatus) GetSubNodeTaskPhases() bitarray.CompactArray
- func (_m *ExecutableArrayNodeStatus) GetTaskPhaseVersion() uint32
- func (_m *ExecutableArrayNodeStatus) OnGetArrayNodePhase() *ExecutableArrayNodeStatus_GetArrayNodePhase
- func (_m *ExecutableArrayNodeStatus) OnGetArrayNodePhaseMatch(matchers ...interface{}) *ExecutableArrayNodeStatus_GetArrayNodePhase
- func (_m *ExecutableArrayNodeStatus) OnGetExecutionError() *ExecutableArrayNodeStatus_GetExecutionError
- func (_m *ExecutableArrayNodeStatus) OnGetExecutionErrorMatch(matchers ...interface{}) *ExecutableArrayNodeStatus_GetExecutionError
- func (_m *ExecutableArrayNodeStatus) OnGetSubNodePhases() *ExecutableArrayNodeStatus_GetSubNodePhases
- func (_m *ExecutableArrayNodeStatus) OnGetSubNodePhasesMatch(matchers ...interface{}) *ExecutableArrayNodeStatus_GetSubNodePhases
- func (_m *ExecutableArrayNodeStatus) OnGetSubNodeRetryAttempts() *ExecutableArrayNodeStatus_GetSubNodeRetryAttempts
- func (_m *ExecutableArrayNodeStatus) OnGetSubNodeRetryAttemptsMatch(matchers ...interface{}) *ExecutableArrayNodeStatus_GetSubNodeRetryAttempts
- func (_m *ExecutableArrayNodeStatus) OnGetSubNodeSystemFailures() *ExecutableArrayNodeStatus_GetSubNodeSystemFailures
- func (_m *ExecutableArrayNodeStatus) OnGetSubNodeSystemFailuresMatch(matchers ...interface{}) *ExecutableArrayNodeStatus_GetSubNodeSystemFailures
- func (_m *ExecutableArrayNodeStatus) OnGetSubNodeTaskPhases() *ExecutableArrayNodeStatus_GetSubNodeTaskPhases
- func (_m *ExecutableArrayNodeStatus) OnGetSubNodeTaskPhasesMatch(matchers ...interface{}) *ExecutableArrayNodeStatus_GetSubNodeTaskPhases
- func (_m *ExecutableArrayNodeStatus) OnGetTaskPhaseVersion() *ExecutableArrayNodeStatus_GetTaskPhaseVersion
- func (_m *ExecutableArrayNodeStatus) OnGetTaskPhaseVersionMatch(matchers ...interface{}) *ExecutableArrayNodeStatus_GetTaskPhaseVersion
- type ExecutableArrayNodeStatus_GetArrayNodePhase
- type ExecutableArrayNodeStatus_GetExecutionError
- type ExecutableArrayNodeStatus_GetSubNodePhases
- type ExecutableArrayNodeStatus_GetSubNodeRetryAttempts
- type ExecutableArrayNodeStatus_GetSubNodeSystemFailures
- type ExecutableArrayNodeStatus_GetSubNodeTaskPhases
- type ExecutableArrayNodeStatus_GetTaskPhaseVersion
- type ExecutableArrayNode_GetMinSuccessRatio
- type ExecutableArrayNode_GetMinSuccesses
- type ExecutableArrayNode_GetParallelism
- type ExecutableArrayNode_GetSubNodeSpec
- 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) GetIsFailurePermanent() bool
- 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
- func (_m *ExecutableDynamicNodeStatus) OnGetIsFailurePermanent() *ExecutableDynamicNodeStatus_GetIsFailurePermanent
- func (_m *ExecutableDynamicNodeStatus) OnGetIsFailurePermanentMatch(matchers ...interface{}) *ExecutableDynamicNodeStatus_GetIsFailurePermanent
- type ExecutableDynamicNodeStatus_GetDynamicNodePhase
- type ExecutableDynamicNodeStatus_GetDynamicNodeReason
- type ExecutableDynamicNodeStatus_GetExecutionError
- type ExecutableDynamicNodeStatus_GetIsFailurePermanent
- type ExecutableGateNode
- func (_m *ExecutableGateNode) GetApprove() *core.ApproveCondition
- func (_m *ExecutableGateNode) GetKind() v1alpha1.ConditionKind
- func (_m *ExecutableGateNode) GetSignal() *core.SignalCondition
- func (_m *ExecutableGateNode) GetSleep() *core.SleepCondition
- func (_m *ExecutableGateNode) OnGetApprove() *ExecutableGateNode_GetApprove
- func (_m *ExecutableGateNode) OnGetApproveMatch(matchers ...interface{}) *ExecutableGateNode_GetApprove
- func (_m *ExecutableGateNode) OnGetKind() *ExecutableGateNode_GetKind
- func (_m *ExecutableGateNode) OnGetKindMatch(matchers ...interface{}) *ExecutableGateNode_GetKind
- func (_m *ExecutableGateNode) OnGetSignal() *ExecutableGateNode_GetSignal
- func (_m *ExecutableGateNode) OnGetSignalMatch(matchers ...interface{}) *ExecutableGateNode_GetSignal
- func (_m *ExecutableGateNode) OnGetSleep() *ExecutableGateNode_GetSleep
- func (_m *ExecutableGateNode) OnGetSleepMatch(matchers ...interface{}) *ExecutableGateNode_GetSleep
- type ExecutableGateNodeStatus
- func (_m *ExecutableGateNodeStatus) GetGateNodePhase() v1alpha1.GateNodePhase
- func (_m *ExecutableGateNodeStatus) OnGetGateNodePhase() *ExecutableGateNodeStatus_GetGateNodePhase
- func (_m *ExecutableGateNodeStatus) OnGetGateNodePhaseMatch(matchers ...interface{}) *ExecutableGateNodeStatus_GetGateNodePhase
- type ExecutableGateNodeStatus_GetGateNodePhase
- type ExecutableGateNode_GetApprove
- type ExecutableGateNode_GetKind
- type ExecutableGateNode_GetSignal
- type ExecutableGateNode_GetSleep
- 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) GetArrayNode() v1alpha1.ExecutableArrayNode
- func (_m *ExecutableNode) GetBranchNode() v1alpha1.ExecutableBranchNode
- func (_m *ExecutableNode) GetConfig() *v1.ConfigMap
- func (_m *ExecutableNode) GetContainerImage() string
- func (_m *ExecutableNode) GetExecutionDeadline() *time.Duration
- func (_m *ExecutableNode) GetExtendedResources() *core.ExtendedResources
- func (_m *ExecutableNode) GetGateNode() v1alpha1.ExecutableGateNode
- func (_m *ExecutableNode) GetID() string
- func (_m *ExecutableNode) GetInputBindings() []*v1alpha1.Binding
- func (_m *ExecutableNode) GetKind() v1alpha1.NodeKind
- func (_m *ExecutableNode) GetName() string
- 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) OnGetArrayNode() *ExecutableNode_GetArrayNode
- func (_m *ExecutableNode) OnGetArrayNodeMatch(matchers ...interface{}) *ExecutableNode_GetArrayNode
- 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) OnGetContainerImage() *ExecutableNode_GetContainerImage
- func (_m *ExecutableNode) OnGetContainerImageMatch(matchers ...interface{}) *ExecutableNode_GetContainerImage
- func (_m *ExecutableNode) OnGetExecutionDeadline() *ExecutableNode_GetExecutionDeadline
- func (_m *ExecutableNode) OnGetExecutionDeadlineMatch(matchers ...interface{}) *ExecutableNode_GetExecutionDeadline
- func (_m *ExecutableNode) OnGetExtendedResources() *ExecutableNode_GetExtendedResources
- func (_m *ExecutableNode) OnGetExtendedResourcesMatch(matchers ...interface{}) *ExecutableNode_GetExtendedResources
- func (_m *ExecutableNode) OnGetGateNode() *ExecutableNode_GetGateNode
- func (_m *ExecutableNode) OnGetGateNodeMatch(matchers ...interface{}) *ExecutableNode_GetGateNode
- 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) OnGetName() *ExecutableNode_GetName
- func (_m *ExecutableNode) OnGetNameMatch(matchers ...interface{}) *ExecutableNode_GetName
- 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) ClearArrayNodeStatus()
- func (_m *ExecutableNodeStatus) ClearDynamicNodeStatus()
- func (_m *ExecutableNodeStatus) ClearGateNodeStatus()
- func (_m *ExecutableNodeStatus) ClearLastAttemptStartedAt()
- func (_m *ExecutableNodeStatus) ClearSubNodeStatus()
- func (_m *ExecutableNodeStatus) ClearTaskStatus()
- func (_m *ExecutableNodeStatus) ClearWorkflowStatus()
- func (_m *ExecutableNodeStatus) GetArrayNodeStatus() v1alpha1.MutableArrayNodeStatus
- 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) GetGateNodeStatus() v1alpha1.MutableGateNodeStatus
- 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) GetOrCreateArrayNodeStatus() v1alpha1.MutableArrayNodeStatus
- func (_m *ExecutableNodeStatus) GetOrCreateBranchStatus() v1alpha1.MutableBranchNodeStatus
- func (_m *ExecutableNodeStatus) GetOrCreateDynamicNodeStatus() v1alpha1.MutableDynamicNodeStatus
- func (_m *ExecutableNodeStatus) GetOrCreateGateNodeStatus() v1alpha1.MutableGateNodeStatus
- 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) OnGetArrayNodeStatus() *ExecutableNodeStatus_GetArrayNodeStatus
- func (_m *ExecutableNodeStatus) OnGetArrayNodeStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetArrayNodeStatus
- 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) OnGetGateNodeStatus() *ExecutableNodeStatus_GetGateNodeStatus
- func (_m *ExecutableNodeStatus) OnGetGateNodeStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetGateNodeStatus
- 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) OnGetOrCreateArrayNodeStatus() *ExecutableNodeStatus_GetOrCreateArrayNodeStatus
- func (_m *ExecutableNodeStatus) OnGetOrCreateArrayNodeStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetOrCreateArrayNodeStatus
- 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) OnGetOrCreateGateNodeStatus() *ExecutableNodeStatus_GetOrCreateGateNodeStatus
- func (_m *ExecutableNodeStatus) OnGetOrCreateGateNodeStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetOrCreateGateNodeStatus
- 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_GetArrayNodeStatus
- type ExecutableNodeStatus_GetAttempts
- type ExecutableNodeStatus_GetBranchStatus
- type ExecutableNodeStatus_GetDataDir
- type ExecutableNodeStatus_GetDynamicNodeStatus
- type ExecutableNodeStatus_GetExecutionError
- type ExecutableNodeStatus_GetGateNodeStatus
- type ExecutableNodeStatus_GetLastAttemptStartedAt
- type ExecutableNodeStatus_GetLastUpdatedAt
- type ExecutableNodeStatus_GetMessage
- type ExecutableNodeStatus_GetNodeExecutionStatus
- type ExecutableNodeStatus_GetOrCreateArrayNodeStatus
- type ExecutableNodeStatus_GetOrCreateBranchStatus
- type ExecutableNodeStatus_GetOrCreateDynamicNodeStatus
- type ExecutableNodeStatus_GetOrCreateGateNodeStatus
- 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_GetArrayNode
- type ExecutableNode_GetBranchNode
- type ExecutableNode_GetConfig
- type ExecutableNode_GetContainerImage
- type ExecutableNode_GetExecutionDeadline
- type ExecutableNode_GetExtendedResources
- type ExecutableNode_GetGateNode
- type ExecutableNode_GetID
- type ExecutableNode_GetInputBindings
- type ExecutableNode_GetKind
- type ExecutableNode_GetName
- 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) GetOnFailurePolicy() v1alpha1.WorkflowOnFailurePolicy
- 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) OnGetOnFailurePolicy() *ExecutableSubWorkflow_GetOnFailurePolicy
- func (_m *ExecutableSubWorkflow) OnGetOnFailurePolicyMatch(matchers ...interface{}) *ExecutableSubWorkflow_GetOnFailurePolicy
- 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_GetOnFailurePolicy
- 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) GetCleanupOnFailure() bool
- 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) GetPreviousNodeExecutionCheckpointPath() storage.DataReference
- func (_m *ExecutableTaskNodeStatus) OnGetBarrierClockTick() *ExecutableTaskNodeStatus_GetBarrierClockTick
- func (_m *ExecutableTaskNodeStatus) OnGetBarrierClockTickMatch(matchers ...interface{}) *ExecutableTaskNodeStatus_GetBarrierClockTick
- func (_m *ExecutableTaskNodeStatus) OnGetCleanupOnFailure() *ExecutableTaskNodeStatus_GetCleanupOnFailure
- func (_m *ExecutableTaskNodeStatus) OnGetCleanupOnFailureMatch(matchers ...interface{}) *ExecutableTaskNodeStatus_GetCleanupOnFailure
- 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
- func (_m *ExecutableTaskNodeStatus) OnGetPreviousNodeExecutionCheckpointPath() *ExecutableTaskNodeStatus_GetPreviousNodeExecutionCheckpointPath
- func (_m *ExecutableTaskNodeStatus) OnGetPreviousNodeExecutionCheckpointPathMatch(matchers ...interface{}) *ExecutableTaskNodeStatus_GetPreviousNodeExecutionCheckpointPath
- type ExecutableTaskNodeStatus_GetBarrierClockTick
- type ExecutableTaskNodeStatus_GetCleanupOnFailure
- type ExecutableTaskNodeStatus_GetLastPhaseUpdatedAt
- type ExecutableTaskNodeStatus_GetPhase
- type ExecutableTaskNodeStatus_GetPhaseVersion
- type ExecutableTaskNodeStatus_GetPluginState
- type ExecutableTaskNodeStatus_GetPluginStateVersion
- type ExecutableTaskNodeStatus_GetPreviousNodeExecutionCheckpointPath
- 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) GetDefinitionVersion() v1alpha1.WorkflowDefinitionVersion
- func (_m *ExecutableWorkflow) GetEventVersion() v1alpha1.EventVersion
- func (_m *ExecutableWorkflow) GetExecutionConfig() v1alpha1.ExecutionConfig
- 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) GetOnFailurePolicy() v1alpha1.WorkflowOnFailurePolicy
- func (_m *ExecutableWorkflow) GetOutputBindings() []*v1alpha1.Binding
- func (_m *ExecutableWorkflow) GetOutputs() *v1alpha1.OutputVarMap
- func (_m *ExecutableWorkflow) GetOwnerReference() v1.OwnerReference
- func (_m *ExecutableWorkflow) GetRawOutputDataConfig() v1alpha1.RawOutputDataConfig
- func (_m *ExecutableWorkflow) GetSecurityContext() core.SecurityContext
- 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) OnGetDefinitionVersion() *ExecutableWorkflow_GetDefinitionVersion
- func (_m *ExecutableWorkflow) OnGetDefinitionVersionMatch(matchers ...interface{}) *ExecutableWorkflow_GetDefinitionVersion
- func (_m *ExecutableWorkflow) OnGetEventVersion() *ExecutableWorkflow_GetEventVersion
- func (_m *ExecutableWorkflow) OnGetEventVersionMatch(matchers ...interface{}) *ExecutableWorkflow_GetEventVersion
- func (_m *ExecutableWorkflow) OnGetExecutionConfig() *ExecutableWorkflow_GetExecutionConfig
- func (_m *ExecutableWorkflow) OnGetExecutionConfigMatch(matchers ...interface{}) *ExecutableWorkflow_GetExecutionConfig
- 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) OnGetOnFailurePolicy() *ExecutableWorkflow_GetOnFailurePolicy
- func (_m *ExecutableWorkflow) OnGetOnFailurePolicyMatch(matchers ...interface{}) *ExecutableWorkflow_GetOnFailurePolicy
- 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) OnGetRawOutputDataConfig() *ExecutableWorkflow_GetRawOutputDataConfig
- func (_m *ExecutableWorkflow) OnGetRawOutputDataConfigMatch(matchers ...interface{}) *ExecutableWorkflow_GetRawOutputDataConfig
- func (_m *ExecutableWorkflow) OnGetSecurityContext() *ExecutableWorkflow_GetSecurityContext
- func (_m *ExecutableWorkflow) OnGetSecurityContextMatch(matchers ...interface{}) *ExecutableWorkflow_GetSecurityContext
- 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_GetDefinitionVersion
- type ExecutableWorkflow_GetEventVersion
- type ExecutableWorkflow_GetExecutionConfig
- 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_GetOnFailurePolicy
- type ExecutableWorkflow_GetOutputBindings
- type ExecutableWorkflow_GetOutputs
- type ExecutableWorkflow_GetOwnerReference
- type ExecutableWorkflow_GetRawOutputDataConfig
- type ExecutableWorkflow_GetSecurityContext
- 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) GetDefinitionVersion() v1alpha1.WorkflowDefinitionVersion
- func (_m *Meta) GetEventVersion() v1alpha1.EventVersion
- 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) GetRawOutputDataConfig() v1alpha1.RawOutputDataConfig
- func (_m *Meta) GetSecurityContext() core.SecurityContext
- 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) OnGetDefinitionVersion() *Meta_GetDefinitionVersion
- func (_m *Meta) OnGetDefinitionVersionMatch(matchers ...interface{}) *Meta_GetDefinitionVersion
- func (_m *Meta) OnGetEventVersion() *Meta_GetEventVersion
- func (_m *Meta) OnGetEventVersionMatch(matchers ...interface{}) *Meta_GetEventVersion
- 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) OnGetRawOutputDataConfig() *Meta_GetRawOutputDataConfig
- func (_m *Meta) OnGetRawOutputDataConfigMatch(matchers ...interface{}) *Meta_GetRawOutputDataConfig
- func (_m *Meta) OnGetSecurityContext() *Meta_GetSecurityContext
- func (_m *Meta) OnGetSecurityContextMatch(matchers ...interface{}) *Meta_GetSecurityContext
- 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) GetDefinitionVersion() v1alpha1.WorkflowDefinitionVersion
- func (_m *MetaExtended) GetEventVersion() v1alpha1.EventVersion
- 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) GetRawOutputDataConfig() v1alpha1.RawOutputDataConfig
- func (_m *MetaExtended) GetSecurityContext() core.SecurityContext
- 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) OnGetDefinitionVersion() *MetaExtended_GetDefinitionVersion
- func (_m *MetaExtended) OnGetDefinitionVersionMatch(matchers ...interface{}) *MetaExtended_GetDefinitionVersion
- func (_m *MetaExtended) OnGetEventVersion() *MetaExtended_GetEventVersion
- func (_m *MetaExtended) OnGetEventVersionMatch(matchers ...interface{}) *MetaExtended_GetEventVersion
- 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) OnGetRawOutputDataConfig() *MetaExtended_GetRawOutputDataConfig
- func (_m *MetaExtended) OnGetRawOutputDataConfigMatch(matchers ...interface{}) *MetaExtended_GetRawOutputDataConfig
- func (_m *MetaExtended) OnGetSecurityContext() *MetaExtended_GetSecurityContext
- func (_m *MetaExtended) OnGetSecurityContextMatch(matchers ...interface{}) *MetaExtended_GetSecurityContext
- 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_GetDefinitionVersion
- type MetaExtended_GetEventVersion
- type MetaExtended_GetExecutionID
- type MetaExtended_GetExecutionStatus
- type MetaExtended_GetK8sWorkflowID
- type MetaExtended_GetLabels
- type MetaExtended_GetName
- type MetaExtended_GetNamespace
- type MetaExtended_GetOwnerReference
- type MetaExtended_GetRawOutputDataConfig
- type MetaExtended_GetSecurityContext
- type MetaExtended_GetServiceAccountName
- type MetaExtended_GetTask
- type MetaExtended_IsInterruptible
- type Meta_GetAnnotations
- type Meta_GetCreationTimestamp
- type Meta_GetDefinitionVersion
- type Meta_GetEventVersion
- type Meta_GetExecutionID
- type Meta_GetK8sWorkflowID
- type Meta_GetLabels
- type Meta_GetName
- type Meta_GetNamespace
- type Meta_GetOwnerReference
- type Meta_GetRawOutputDataConfig
- type Meta_GetSecurityContext
- type Meta_GetServiceAccountName
- type Meta_IsInterruptible
- type Mutable
- type MutableArrayNodeStatus
- func (_m *MutableArrayNodeStatus) GetArrayNodePhase() v1alpha1.ArrayNodePhase
- func (_m *MutableArrayNodeStatus) GetExecutionError() *core.ExecutionError
- func (_m *MutableArrayNodeStatus) GetSubNodePhases() bitarray.CompactArray
- func (_m *MutableArrayNodeStatus) GetSubNodeRetryAttempts() bitarray.CompactArray
- func (_m *MutableArrayNodeStatus) GetSubNodeSystemFailures() bitarray.CompactArray
- func (_m *MutableArrayNodeStatus) GetSubNodeTaskPhases() bitarray.CompactArray
- func (_m *MutableArrayNodeStatus) GetTaskPhaseVersion() uint32
- func (_m *MutableArrayNodeStatus) IsDirty() bool
- func (_m *MutableArrayNodeStatus) OnGetArrayNodePhase() *MutableArrayNodeStatus_GetArrayNodePhase
- func (_m *MutableArrayNodeStatus) OnGetArrayNodePhaseMatch(matchers ...interface{}) *MutableArrayNodeStatus_GetArrayNodePhase
- func (_m *MutableArrayNodeStatus) OnGetExecutionError() *MutableArrayNodeStatus_GetExecutionError
- func (_m *MutableArrayNodeStatus) OnGetExecutionErrorMatch(matchers ...interface{}) *MutableArrayNodeStatus_GetExecutionError
- func (_m *MutableArrayNodeStatus) OnGetSubNodePhases() *MutableArrayNodeStatus_GetSubNodePhases
- func (_m *MutableArrayNodeStatus) OnGetSubNodePhasesMatch(matchers ...interface{}) *MutableArrayNodeStatus_GetSubNodePhases
- func (_m *MutableArrayNodeStatus) OnGetSubNodeRetryAttempts() *MutableArrayNodeStatus_GetSubNodeRetryAttempts
- func (_m *MutableArrayNodeStatus) OnGetSubNodeRetryAttemptsMatch(matchers ...interface{}) *MutableArrayNodeStatus_GetSubNodeRetryAttempts
- func (_m *MutableArrayNodeStatus) OnGetSubNodeSystemFailures() *MutableArrayNodeStatus_GetSubNodeSystemFailures
- func (_m *MutableArrayNodeStatus) OnGetSubNodeSystemFailuresMatch(matchers ...interface{}) *MutableArrayNodeStatus_GetSubNodeSystemFailures
- func (_m *MutableArrayNodeStatus) OnGetSubNodeTaskPhases() *MutableArrayNodeStatus_GetSubNodeTaskPhases
- func (_m *MutableArrayNodeStatus) OnGetSubNodeTaskPhasesMatch(matchers ...interface{}) *MutableArrayNodeStatus_GetSubNodeTaskPhases
- func (_m *MutableArrayNodeStatus) OnGetTaskPhaseVersion() *MutableArrayNodeStatus_GetTaskPhaseVersion
- func (_m *MutableArrayNodeStatus) OnGetTaskPhaseVersionMatch(matchers ...interface{}) *MutableArrayNodeStatus_GetTaskPhaseVersion
- func (_m *MutableArrayNodeStatus) OnIsDirty() *MutableArrayNodeStatus_IsDirty
- func (_m *MutableArrayNodeStatus) OnIsDirtyMatch(matchers ...interface{}) *MutableArrayNodeStatus_IsDirty
- func (_m *MutableArrayNodeStatus) SetArrayNodePhase(phase v1alpha1.ArrayNodePhase)
- func (_m *MutableArrayNodeStatus) SetExecutionError(executionError *core.ExecutionError)
- func (_m *MutableArrayNodeStatus) SetSubNodePhases(subNodePhases bitarray.CompactArray)
- func (_m *MutableArrayNodeStatus) SetSubNodeRetryAttempts(subNodeRetryAttempts bitarray.CompactArray)
- func (_m *MutableArrayNodeStatus) SetSubNodeSystemFailures(subNodeSystemFailures bitarray.CompactArray)
- func (_m *MutableArrayNodeStatus) SetSubNodeTaskPhases(subNodeTaskPhases bitarray.CompactArray)
- func (_m *MutableArrayNodeStatus) SetTaskPhaseVersion(taskPhaseVersion uint32)
- type MutableArrayNodeStatus_GetArrayNodePhase
- type MutableArrayNodeStatus_GetExecutionError
- type MutableArrayNodeStatus_GetSubNodePhases
- type MutableArrayNodeStatus_GetSubNodeRetryAttempts
- type MutableArrayNodeStatus_GetSubNodeSystemFailures
- type MutableArrayNodeStatus_GetSubNodeTaskPhases
- type MutableArrayNodeStatus_GetTaskPhaseVersion
- type MutableArrayNodeStatus_IsDirty
- type MutableBranchNodeStatus
- func (_m *MutableBranchNodeStatus) GetFinalizedNode() *string
- func (_m *MutableBranchNodeStatus) GetPhase() v1alpha1.BranchNodePhase
- func (_m *MutableBranchNodeStatus) IsDirty() bool
- func (_m *MutableBranchNodeStatus) OnGetFinalizedNode() *MutableBranchNodeStatus_GetFinalizedNode
- func (_m *MutableBranchNodeStatus) OnGetFinalizedNodeMatch(matchers ...interface{}) *MutableBranchNodeStatus_GetFinalizedNode
- func (_m *MutableBranchNodeStatus) OnGetPhase() *MutableBranchNodeStatus_GetPhase
- func (_m *MutableBranchNodeStatus) OnGetPhaseMatch(matchers ...interface{}) *MutableBranchNodeStatus_GetPhase
- func (_m *MutableBranchNodeStatus) OnIsDirty() *MutableBranchNodeStatus_IsDirty
- func (_m *MutableBranchNodeStatus) OnIsDirtyMatch(matchers ...interface{}) *MutableBranchNodeStatus_IsDirty
- func (_m *MutableBranchNodeStatus) SetBranchNodeError()
- func (_m *MutableBranchNodeStatus) SetBranchNodeSuccess(id string)
- type MutableBranchNodeStatus_GetFinalizedNode
- 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) GetIsFailurePermanent() bool
- 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) OnGetIsFailurePermanent() *MutableDynamicNodeStatus_GetIsFailurePermanent
- func (_m *MutableDynamicNodeStatus) OnGetIsFailurePermanentMatch(matchers ...interface{}) *MutableDynamicNodeStatus_GetIsFailurePermanent
- 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)
- func (_m *MutableDynamicNodeStatus) SetIsFailurePermanent(isFailurePermanent bool)
- type MutableDynamicNodeStatus_GetDynamicNodePhase
- type MutableDynamicNodeStatus_GetDynamicNodeReason
- type MutableDynamicNodeStatus_GetExecutionError
- type MutableDynamicNodeStatus_GetIsFailurePermanent
- type MutableDynamicNodeStatus_IsDirty
- type MutableGateNodeStatus
- func (_m *MutableGateNodeStatus) GetGateNodePhase() v1alpha1.GateNodePhase
- func (_m *MutableGateNodeStatus) IsDirty() bool
- func (_m *MutableGateNodeStatus) OnGetGateNodePhase() *MutableGateNodeStatus_GetGateNodePhase
- func (_m *MutableGateNodeStatus) OnGetGateNodePhaseMatch(matchers ...interface{}) *MutableGateNodeStatus_GetGateNodePhase
- func (_m *MutableGateNodeStatus) OnIsDirty() *MutableGateNodeStatus_IsDirty
- func (_m *MutableGateNodeStatus) OnIsDirtyMatch(matchers ...interface{}) *MutableGateNodeStatus_IsDirty
- func (_m *MutableGateNodeStatus) SetGateNodePhase(phase v1alpha1.GateNodePhase)
- type MutableGateNodeStatus_GetGateNodePhase
- type MutableGateNodeStatus_IsDirty
- type MutableNodeStatus
- func (_m *MutableNodeStatus) ClearArrayNodeStatus()
- func (_m *MutableNodeStatus) ClearDynamicNodeStatus()
- func (_m *MutableNodeStatus) ClearGateNodeStatus()
- func (_m *MutableNodeStatus) ClearLastAttemptStartedAt()
- func (_m *MutableNodeStatus) ClearSubNodeStatus()
- func (_m *MutableNodeStatus) ClearTaskStatus()
- func (_m *MutableNodeStatus) ClearWorkflowStatus()
- func (_m *MutableNodeStatus) GetArrayNodeStatus() v1alpha1.MutableArrayNodeStatus
- func (_m *MutableNodeStatus) GetBranchStatus() v1alpha1.MutableBranchNodeStatus
- func (_m *MutableNodeStatus) GetDynamicNodeStatus() v1alpha1.MutableDynamicNodeStatus
- func (_m *MutableNodeStatus) GetGateNodeStatus() v1alpha1.MutableGateNodeStatus
- func (_m *MutableNodeStatus) GetOrCreateArrayNodeStatus() v1alpha1.MutableArrayNodeStatus
- func (_m *MutableNodeStatus) GetOrCreateBranchStatus() v1alpha1.MutableBranchNodeStatus
- func (_m *MutableNodeStatus) GetOrCreateDynamicNodeStatus() v1alpha1.MutableDynamicNodeStatus
- func (_m *MutableNodeStatus) GetOrCreateGateNodeStatus() v1alpha1.MutableGateNodeStatus
- 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) OnGetArrayNodeStatus() *MutableNodeStatus_GetArrayNodeStatus
- func (_m *MutableNodeStatus) OnGetArrayNodeStatusMatch(matchers ...interface{}) *MutableNodeStatus_GetArrayNodeStatus
- 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) OnGetGateNodeStatus() *MutableNodeStatus_GetGateNodeStatus
- func (_m *MutableNodeStatus) OnGetGateNodeStatusMatch(matchers ...interface{}) *MutableNodeStatus_GetGateNodeStatus
- func (_m *MutableNodeStatus) OnGetOrCreateArrayNodeStatus() *MutableNodeStatus_GetOrCreateArrayNodeStatus
- func (_m *MutableNodeStatus) OnGetOrCreateArrayNodeStatusMatch(matchers ...interface{}) *MutableNodeStatus_GetOrCreateArrayNodeStatus
- 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) OnGetOrCreateGateNodeStatus() *MutableNodeStatus_GetOrCreateGateNodeStatus
- func (_m *MutableNodeStatus) OnGetOrCreateGateNodeStatusMatch(matchers ...interface{}) *MutableNodeStatus_GetOrCreateGateNodeStatus
- 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_GetArrayNodeStatus
- type MutableNodeStatus_GetBranchStatus
- type MutableNodeStatus_GetDynamicNodeStatus
- type MutableNodeStatus_GetGateNodeStatus
- type MutableNodeStatus_GetOrCreateArrayNodeStatus
- type MutableNodeStatus_GetOrCreateBranchStatus
- type MutableNodeStatus_GetOrCreateDynamicNodeStatus
- type MutableNodeStatus_GetOrCreateGateNodeStatus
- 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) GetCleanupOnFailure() bool
- 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) GetPreviousNodeExecutionCheckpointPath() storage.DataReference
- func (_m *MutableTaskNodeStatus) IsDirty() bool
- func (_m *MutableTaskNodeStatus) OnGetBarrierClockTick() *MutableTaskNodeStatus_GetBarrierClockTick
- func (_m *MutableTaskNodeStatus) OnGetBarrierClockTickMatch(matchers ...interface{}) *MutableTaskNodeStatus_GetBarrierClockTick
- func (_m *MutableTaskNodeStatus) OnGetCleanupOnFailure() *MutableTaskNodeStatus_GetCleanupOnFailure
- func (_m *MutableTaskNodeStatus) OnGetCleanupOnFailureMatch(matchers ...interface{}) *MutableTaskNodeStatus_GetCleanupOnFailure
- 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) OnGetPreviousNodeExecutionCheckpointPath() *MutableTaskNodeStatus_GetPreviousNodeExecutionCheckpointPath
- func (_m *MutableTaskNodeStatus) OnGetPreviousNodeExecutionCheckpointPathMatch(matchers ...interface{}) *MutableTaskNodeStatus_GetPreviousNodeExecutionCheckpointPath
- func (_m *MutableTaskNodeStatus) OnIsDirty() *MutableTaskNodeStatus_IsDirty
- func (_m *MutableTaskNodeStatus) OnIsDirtyMatch(matchers ...interface{}) *MutableTaskNodeStatus_IsDirty
- func (_m *MutableTaskNodeStatus) SetBarrierClockTick(tick uint32)
- func (_m *MutableTaskNodeStatus) SetCleanupOnFailure(_a0 bool)
- 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)
- func (_m *MutableTaskNodeStatus) SetPreviousNodeExecutionCheckpointPath(_a0 storage.DataReference)
- type MutableTaskNodeStatus_GetBarrierClockTick
- type MutableTaskNodeStatus_GetCleanupOnFailure
- type MutableTaskNodeStatus_GetLastPhaseUpdatedAt
- type MutableTaskNodeStatus_GetPhase
- type MutableTaskNodeStatus_GetPhaseVersion
- type MutableTaskNodeStatus_GetPluginState
- type MutableTaskNodeStatus_GetPluginStateVersion
- type MutableTaskNodeStatus_GetPreviousNodeExecutionCheckpointPath
- 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 ¶
func (_m *BaseNode) OnGetID() *BaseNode_GetID
func (*BaseNode) OnGetIDMatch ¶
func (_m *BaseNode) OnGetIDMatch(matchers ...interface{}) *BaseNode_GetID
func (*BaseNode) OnGetKind ¶
func (_m *BaseNode) OnGetKind() *BaseNode_GetKind
func (*BaseNode) OnGetKindMatch ¶
func (_m *BaseNode) OnGetKindMatch(matchers ...interface{}) *BaseNode_GetKind
type BaseNode_GetID ¶
func (BaseNode_GetID) Return ¶
func (_m BaseNode_GetID) Return(_a0 string) *BaseNode_GetID
type BaseNode_GetKind ¶
func (BaseNode_GetKind) Return ¶
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 ¶
func (_m *BaseWorkflow) OnFromNode(name string) *BaseWorkflow_FromNode
func (*BaseWorkflow) OnFromNodeMatch ¶
func (_m *BaseWorkflow) OnFromNodeMatch(matchers ...interface{}) *BaseWorkflow_FromNode
func (*BaseWorkflow) OnGetID ¶
func (_m *BaseWorkflow) OnGetID() *BaseWorkflow_GetID
func (*BaseWorkflow) OnGetIDMatch ¶
func (_m *BaseWorkflow) OnGetIDMatch(matchers ...interface{}) *BaseWorkflow_GetID
func (*BaseWorkflow) OnGetNode ¶
func (_m *BaseWorkflow) OnGetNode(nodeID string) *BaseWorkflow_GetNode
func (*BaseWorkflow) OnGetNodeMatch ¶
func (_m *BaseWorkflow) OnGetNodeMatch(matchers ...interface{}) *BaseWorkflow_GetNode
func (*BaseWorkflow) OnStartNode ¶
func (_m *BaseWorkflow) OnStartNode() *BaseWorkflow_StartNode
func (*BaseWorkflow) OnStartNodeMatch ¶
func (_m *BaseWorkflow) OnStartNodeMatch(matchers ...interface{}) *BaseWorkflow_StartNode
func (*BaseWorkflow) OnToNode ¶
func (_m *BaseWorkflow) OnToNode(name string) *BaseWorkflow_ToNode
func (*BaseWorkflow) OnToNodeMatch ¶
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 ¶
func (_m *BaseWorkflowWithStatus) OnFromNode(name string) *BaseWorkflowWithStatus_FromNode
func (*BaseWorkflowWithStatus) OnFromNodeMatch ¶
func (_m *BaseWorkflowWithStatus) OnFromNodeMatch(matchers ...interface{}) *BaseWorkflowWithStatus_FromNode
func (*BaseWorkflowWithStatus) OnGetID ¶
func (_m *BaseWorkflowWithStatus) OnGetID() *BaseWorkflowWithStatus_GetID
func (*BaseWorkflowWithStatus) OnGetIDMatch ¶
func (_m *BaseWorkflowWithStatus) OnGetIDMatch(matchers ...interface{}) *BaseWorkflowWithStatus_GetID
func (*BaseWorkflowWithStatus) OnGetNode ¶
func (_m *BaseWorkflowWithStatus) OnGetNode(nodeID string) *BaseWorkflowWithStatus_GetNode
func (*BaseWorkflowWithStatus) OnGetNodeExecutionStatus ¶
func (_m *BaseWorkflowWithStatus) OnGetNodeExecutionStatus(ctx context.Context, id string) *BaseWorkflowWithStatus_GetNodeExecutionStatus
func (*BaseWorkflowWithStatus) OnGetNodeExecutionStatusMatch ¶
func (_m *BaseWorkflowWithStatus) OnGetNodeExecutionStatusMatch(matchers ...interface{}) *BaseWorkflowWithStatus_GetNodeExecutionStatus
func (*BaseWorkflowWithStatus) OnGetNodeMatch ¶
func (_m *BaseWorkflowWithStatus) OnGetNodeMatch(matchers ...interface{}) *BaseWorkflowWithStatus_GetNode
func (*BaseWorkflowWithStatus) OnStartNode ¶
func (_m *BaseWorkflowWithStatus) OnStartNode() *BaseWorkflowWithStatus_StartNode
func (*BaseWorkflowWithStatus) OnStartNodeMatch ¶
func (_m *BaseWorkflowWithStatus) OnStartNodeMatch(matchers ...interface{}) *BaseWorkflowWithStatus_StartNode
func (*BaseWorkflowWithStatus) OnToNode ¶
func (_m *BaseWorkflowWithStatus) OnToNode(name string) *BaseWorkflowWithStatus_ToNode
func (*BaseWorkflowWithStatus) OnToNodeMatch ¶
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 ¶
func (BaseWorkflowWithStatus_FromNode) Return ¶
func (_m BaseWorkflowWithStatus_FromNode) Return(_a0 []string, _a1 error) *BaseWorkflowWithStatus_FromNode
type BaseWorkflowWithStatus_GetID ¶
func (BaseWorkflowWithStatus_GetID) Return ¶
func (_m BaseWorkflowWithStatus_GetID) Return(_a0 string) *BaseWorkflowWithStatus_GetID
type BaseWorkflowWithStatus_GetNode ¶
func (BaseWorkflowWithStatus_GetNode) Return ¶
func (_m BaseWorkflowWithStatus_GetNode) Return(_a0 v1alpha1.ExecutableNode, _a1 bool) *BaseWorkflowWithStatus_GetNode
type BaseWorkflowWithStatus_GetNodeExecutionStatus ¶
type BaseWorkflowWithStatus_StartNode ¶
func (BaseWorkflowWithStatus_StartNode) Return ¶
func (_m BaseWorkflowWithStatus_StartNode) Return(_a0 v1alpha1.ExecutableNode) *BaseWorkflowWithStatus_StartNode
type BaseWorkflowWithStatus_ToNode ¶
func (BaseWorkflowWithStatus_ToNode) Return ¶
func (_m BaseWorkflowWithStatus_ToNode) Return(_a0 []string, _a1 error) *BaseWorkflowWithStatus_ToNode
type BaseWorkflow_FromNode ¶
func (BaseWorkflow_FromNode) Return ¶
func (_m BaseWorkflow_FromNode) Return(_a0 []string, _a1 error) *BaseWorkflow_FromNode
type BaseWorkflow_GetID ¶
func (BaseWorkflow_GetID) Return ¶
func (_m BaseWorkflow_GetID) Return(_a0 string) *BaseWorkflow_GetID
type BaseWorkflow_GetNode ¶
func (BaseWorkflow_GetNode) Return ¶
func (_m BaseWorkflow_GetNode) Return(_a0 v1alpha1.ExecutableNode, _a1 bool) *BaseWorkflow_GetNode
type BaseWorkflow_StartNode ¶
func (BaseWorkflow_StartNode) Return ¶
func (_m BaseWorkflow_StartNode) Return(_a0 v1alpha1.ExecutableNode) *BaseWorkflow_StartNode
type BaseWorkflow_ToNode ¶
func (BaseWorkflow_ToNode) Return ¶
func (_m BaseWorkflow_ToNode) Return(_a0 []string, _a1 error) *BaseWorkflow_ToNode
type ExecutableArrayNode ¶
ExecutableArrayNode is an autogenerated mock type for the ExecutableArrayNode type
func (*ExecutableArrayNode) GetMinSuccessRatio ¶
func (_m *ExecutableArrayNode) GetMinSuccessRatio() *float32
GetMinSuccessRatio provides a mock function with given fields:
func (*ExecutableArrayNode) GetMinSuccesses ¶
func (_m *ExecutableArrayNode) GetMinSuccesses() *uint32
GetMinSuccesses provides a mock function with given fields:
func (*ExecutableArrayNode) GetParallelism ¶
func (_m *ExecutableArrayNode) GetParallelism() *uint32
GetParallelism provides a mock function with given fields:
func (*ExecutableArrayNode) GetSubNodeSpec ¶
func (_m *ExecutableArrayNode) GetSubNodeSpec() *v1alpha1.NodeSpec
GetSubNodeSpec provides a mock function with given fields:
func (*ExecutableArrayNode) OnGetMinSuccessRatio ¶
func (_m *ExecutableArrayNode) OnGetMinSuccessRatio() *ExecutableArrayNode_GetMinSuccessRatio
func (*ExecutableArrayNode) OnGetMinSuccessRatioMatch ¶
func (_m *ExecutableArrayNode) OnGetMinSuccessRatioMatch(matchers ...interface{}) *ExecutableArrayNode_GetMinSuccessRatio
func (*ExecutableArrayNode) OnGetMinSuccesses ¶
func (_m *ExecutableArrayNode) OnGetMinSuccesses() *ExecutableArrayNode_GetMinSuccesses
func (*ExecutableArrayNode) OnGetMinSuccessesMatch ¶
func (_m *ExecutableArrayNode) OnGetMinSuccessesMatch(matchers ...interface{}) *ExecutableArrayNode_GetMinSuccesses
func (*ExecutableArrayNode) OnGetParallelism ¶
func (_m *ExecutableArrayNode) OnGetParallelism() *ExecutableArrayNode_GetParallelism
func (*ExecutableArrayNode) OnGetParallelismMatch ¶
func (_m *ExecutableArrayNode) OnGetParallelismMatch(matchers ...interface{}) *ExecutableArrayNode_GetParallelism
func (*ExecutableArrayNode) OnGetSubNodeSpec ¶
func (_m *ExecutableArrayNode) OnGetSubNodeSpec() *ExecutableArrayNode_GetSubNodeSpec
func (*ExecutableArrayNode) OnGetSubNodeSpecMatch ¶
func (_m *ExecutableArrayNode) OnGetSubNodeSpecMatch(matchers ...interface{}) *ExecutableArrayNode_GetSubNodeSpec
type ExecutableArrayNodeStatus ¶
ExecutableArrayNodeStatus is an autogenerated mock type for the ExecutableArrayNodeStatus type
func (*ExecutableArrayNodeStatus) GetArrayNodePhase ¶
func (_m *ExecutableArrayNodeStatus) GetArrayNodePhase() v1alpha1.ArrayNodePhase
GetArrayNodePhase provides a mock function with given fields:
func (*ExecutableArrayNodeStatus) GetExecutionError ¶
func (_m *ExecutableArrayNodeStatus) GetExecutionError() *core.ExecutionError
GetExecutionError provides a mock function with given fields:
func (*ExecutableArrayNodeStatus) GetSubNodePhases ¶
func (_m *ExecutableArrayNodeStatus) GetSubNodePhases() bitarray.CompactArray
GetSubNodePhases provides a mock function with given fields:
func (*ExecutableArrayNodeStatus) GetSubNodeRetryAttempts ¶
func (_m *ExecutableArrayNodeStatus) GetSubNodeRetryAttempts() bitarray.CompactArray
GetSubNodeRetryAttempts provides a mock function with given fields:
func (*ExecutableArrayNodeStatus) GetSubNodeSystemFailures ¶
func (_m *ExecutableArrayNodeStatus) GetSubNodeSystemFailures() bitarray.CompactArray
GetSubNodeSystemFailures provides a mock function with given fields:
func (*ExecutableArrayNodeStatus) GetSubNodeTaskPhases ¶
func (_m *ExecutableArrayNodeStatus) GetSubNodeTaskPhases() bitarray.CompactArray
GetSubNodeTaskPhases provides a mock function with given fields:
func (*ExecutableArrayNodeStatus) GetTaskPhaseVersion ¶
func (_m *ExecutableArrayNodeStatus) GetTaskPhaseVersion() uint32
GetTaskPhaseVersion provides a mock function with given fields:
func (*ExecutableArrayNodeStatus) OnGetArrayNodePhase ¶
func (_m *ExecutableArrayNodeStatus) OnGetArrayNodePhase() *ExecutableArrayNodeStatus_GetArrayNodePhase
func (*ExecutableArrayNodeStatus) OnGetArrayNodePhaseMatch ¶
func (_m *ExecutableArrayNodeStatus) OnGetArrayNodePhaseMatch(matchers ...interface{}) *ExecutableArrayNodeStatus_GetArrayNodePhase
func (*ExecutableArrayNodeStatus) OnGetExecutionError ¶
func (_m *ExecutableArrayNodeStatus) OnGetExecutionError() *ExecutableArrayNodeStatus_GetExecutionError
func (*ExecutableArrayNodeStatus) OnGetExecutionErrorMatch ¶
func (_m *ExecutableArrayNodeStatus) OnGetExecutionErrorMatch(matchers ...interface{}) *ExecutableArrayNodeStatus_GetExecutionError
func (*ExecutableArrayNodeStatus) OnGetSubNodePhases ¶
func (_m *ExecutableArrayNodeStatus) OnGetSubNodePhases() *ExecutableArrayNodeStatus_GetSubNodePhases
func (*ExecutableArrayNodeStatus) OnGetSubNodePhasesMatch ¶
func (_m *ExecutableArrayNodeStatus) OnGetSubNodePhasesMatch(matchers ...interface{}) *ExecutableArrayNodeStatus_GetSubNodePhases
func (*ExecutableArrayNodeStatus) OnGetSubNodeRetryAttempts ¶
func (_m *ExecutableArrayNodeStatus) OnGetSubNodeRetryAttempts() *ExecutableArrayNodeStatus_GetSubNodeRetryAttempts
func (*ExecutableArrayNodeStatus) OnGetSubNodeRetryAttemptsMatch ¶
func (_m *ExecutableArrayNodeStatus) OnGetSubNodeRetryAttemptsMatch(matchers ...interface{}) *ExecutableArrayNodeStatus_GetSubNodeRetryAttempts
func (*ExecutableArrayNodeStatus) OnGetSubNodeSystemFailures ¶
func (_m *ExecutableArrayNodeStatus) OnGetSubNodeSystemFailures() *ExecutableArrayNodeStatus_GetSubNodeSystemFailures
func (*ExecutableArrayNodeStatus) OnGetSubNodeSystemFailuresMatch ¶
func (_m *ExecutableArrayNodeStatus) OnGetSubNodeSystemFailuresMatch(matchers ...interface{}) *ExecutableArrayNodeStatus_GetSubNodeSystemFailures
func (*ExecutableArrayNodeStatus) OnGetSubNodeTaskPhases ¶
func (_m *ExecutableArrayNodeStatus) OnGetSubNodeTaskPhases() *ExecutableArrayNodeStatus_GetSubNodeTaskPhases
func (*ExecutableArrayNodeStatus) OnGetSubNodeTaskPhasesMatch ¶
func (_m *ExecutableArrayNodeStatus) OnGetSubNodeTaskPhasesMatch(matchers ...interface{}) *ExecutableArrayNodeStatus_GetSubNodeTaskPhases
func (*ExecutableArrayNodeStatus) OnGetTaskPhaseVersion ¶
func (_m *ExecutableArrayNodeStatus) OnGetTaskPhaseVersion() *ExecutableArrayNodeStatus_GetTaskPhaseVersion
func (*ExecutableArrayNodeStatus) OnGetTaskPhaseVersionMatch ¶
func (_m *ExecutableArrayNodeStatus) OnGetTaskPhaseVersionMatch(matchers ...interface{}) *ExecutableArrayNodeStatus_GetTaskPhaseVersion
type ExecutableArrayNodeStatus_GetArrayNodePhase ¶
type ExecutableArrayNodeStatus_GetExecutionError ¶
func (ExecutableArrayNodeStatus_GetExecutionError) Return ¶
func (_m ExecutableArrayNodeStatus_GetExecutionError) Return(_a0 *core.ExecutionError) *ExecutableArrayNodeStatus_GetExecutionError
type ExecutableArrayNodeStatus_GetSubNodePhases ¶
func (ExecutableArrayNodeStatus_GetSubNodePhases) Return ¶
func (_m ExecutableArrayNodeStatus_GetSubNodePhases) Return(_a0 bitarray.CompactArray) *ExecutableArrayNodeStatus_GetSubNodePhases
type ExecutableArrayNodeStatus_GetSubNodeRetryAttempts ¶
type ExecutableArrayNodeStatus_GetSubNodeSystemFailures ¶
type ExecutableArrayNodeStatus_GetSubNodeTaskPhases ¶
type ExecutableArrayNodeStatus_GetTaskPhaseVersion ¶
func (ExecutableArrayNodeStatus_GetTaskPhaseVersion) Return ¶
func (_m ExecutableArrayNodeStatus_GetTaskPhaseVersion) Return(_a0 uint32) *ExecutableArrayNodeStatus_GetTaskPhaseVersion
type ExecutableArrayNode_GetMinSuccessRatio ¶
func (ExecutableArrayNode_GetMinSuccessRatio) Return ¶
func (_m ExecutableArrayNode_GetMinSuccessRatio) Return(_a0 *float32) *ExecutableArrayNode_GetMinSuccessRatio
type ExecutableArrayNode_GetMinSuccesses ¶
func (ExecutableArrayNode_GetMinSuccesses) Return ¶
func (_m ExecutableArrayNode_GetMinSuccesses) Return(_a0 *uint32) *ExecutableArrayNode_GetMinSuccesses
type ExecutableArrayNode_GetParallelism ¶
func (ExecutableArrayNode_GetParallelism) Return ¶
func (_m ExecutableArrayNode_GetParallelism) Return(_a0 *uint32) *ExecutableArrayNode_GetParallelism
type ExecutableArrayNode_GetSubNodeSpec ¶
func (ExecutableArrayNode_GetSubNodeSpec) Return ¶
func (_m ExecutableArrayNode_GetSubNodeSpec) Return(_a0 *v1alpha1.NodeSpec) *ExecutableArrayNode_GetSubNodeSpec
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 ¶
func (_m *ExecutableBranchNode) OnGetElse() *ExecutableBranchNode_GetElse
func (*ExecutableBranchNode) OnGetElseFail ¶
func (_m *ExecutableBranchNode) OnGetElseFail() *ExecutableBranchNode_GetElseFail
func (*ExecutableBranchNode) OnGetElseFailMatch ¶
func (_m *ExecutableBranchNode) OnGetElseFailMatch(matchers ...interface{}) *ExecutableBranchNode_GetElseFail
func (*ExecutableBranchNode) OnGetElseIf ¶
func (_m *ExecutableBranchNode) OnGetElseIf() *ExecutableBranchNode_GetElseIf
func (*ExecutableBranchNode) OnGetElseIfMatch ¶
func (_m *ExecutableBranchNode) OnGetElseIfMatch(matchers ...interface{}) *ExecutableBranchNode_GetElseIf
func (*ExecutableBranchNode) OnGetElseMatch ¶
func (_m *ExecutableBranchNode) OnGetElseMatch(matchers ...interface{}) *ExecutableBranchNode_GetElse
func (*ExecutableBranchNode) OnGetIf ¶
func (_m *ExecutableBranchNode) OnGetIf() *ExecutableBranchNode_GetIf
func (*ExecutableBranchNode) OnGetIfMatch ¶
func (_m *ExecutableBranchNode) OnGetIfMatch(matchers ...interface{}) *ExecutableBranchNode_GetIf
type ExecutableBranchNodeStatus ¶
ExecutableBranchNodeStatus is an autogenerated mock type for the ExecutableBranchNodeStatus type
func (*ExecutableBranchNodeStatus) GetFinalizedNode ¶
func (_m *ExecutableBranchNodeStatus) GetFinalizedNode() *string
GetFinalizedNode provides a mock function with given fields:
func (*ExecutableBranchNodeStatus) GetPhase ¶
func (_m *ExecutableBranchNodeStatus) GetPhase() v1alpha1.BranchNodePhase
GetPhase provides a mock function with given fields:
func (*ExecutableBranchNodeStatus) OnGetFinalizedNode ¶
func (_m *ExecutableBranchNodeStatus) OnGetFinalizedNode() *ExecutableBranchNodeStatus_GetFinalizedNode
func (*ExecutableBranchNodeStatus) OnGetFinalizedNodeMatch ¶
func (_m *ExecutableBranchNodeStatus) OnGetFinalizedNodeMatch(matchers ...interface{}) *ExecutableBranchNodeStatus_GetFinalizedNode
func (*ExecutableBranchNodeStatus) OnGetPhase ¶
func (_m *ExecutableBranchNodeStatus) OnGetPhase() *ExecutableBranchNodeStatus_GetPhase
func (*ExecutableBranchNodeStatus) OnGetPhaseMatch ¶
func (_m *ExecutableBranchNodeStatus) OnGetPhaseMatch(matchers ...interface{}) *ExecutableBranchNodeStatus_GetPhase
type ExecutableBranchNodeStatus_GetFinalizedNode ¶
func (ExecutableBranchNodeStatus_GetFinalizedNode) Return ¶
func (_m ExecutableBranchNodeStatus_GetFinalizedNode) Return(_a0 *string) *ExecutableBranchNodeStatus_GetFinalizedNode
type ExecutableBranchNodeStatus_GetPhase ¶
func (ExecutableBranchNodeStatus_GetPhase) Return ¶
func (_m ExecutableBranchNodeStatus_GetPhase) Return(_a0 v1alpha1.BranchNodePhase) *ExecutableBranchNodeStatus_GetPhase
type ExecutableBranchNode_GetElse ¶
func (ExecutableBranchNode_GetElse) Return ¶
func (_m ExecutableBranchNode_GetElse) Return(_a0 *string) *ExecutableBranchNode_GetElse
type ExecutableBranchNode_GetElseFail ¶
func (ExecutableBranchNode_GetElseFail) Return ¶
func (_m ExecutableBranchNode_GetElseFail) Return(_a0 *core.Error) *ExecutableBranchNode_GetElseFail
type ExecutableBranchNode_GetElseIf ¶
func (ExecutableBranchNode_GetElseIf) Return ¶
func (_m ExecutableBranchNode_GetElseIf) Return(_a0 []v1alpha1.ExecutableIfBlock) *ExecutableBranchNode_GetElseIf
type ExecutableBranchNode_GetIf ¶
func (ExecutableBranchNode_GetIf) Return ¶
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 ¶
func (_m *ExecutableDynamicNodeStatus) GetDynamicNodeReason() string
GetDynamicNodeReason provides a mock function with given fields:
func (*ExecutableDynamicNodeStatus) GetExecutionError ¶
func (_m *ExecutableDynamicNodeStatus) GetExecutionError() *core.ExecutionError
GetExecutionError provides a mock function with given fields:
func (*ExecutableDynamicNodeStatus) GetIsFailurePermanent ¶
func (_m *ExecutableDynamicNodeStatus) GetIsFailurePermanent() bool
GetIsFailurePermanent provides a mock function with given fields:
func (*ExecutableDynamicNodeStatus) OnGetDynamicNodePhase ¶
func (_m *ExecutableDynamicNodeStatus) OnGetDynamicNodePhase() *ExecutableDynamicNodeStatus_GetDynamicNodePhase
func (*ExecutableDynamicNodeStatus) OnGetDynamicNodePhaseMatch ¶
func (_m *ExecutableDynamicNodeStatus) OnGetDynamicNodePhaseMatch(matchers ...interface{}) *ExecutableDynamicNodeStatus_GetDynamicNodePhase
func (*ExecutableDynamicNodeStatus) OnGetDynamicNodeReason ¶
func (_m *ExecutableDynamicNodeStatus) OnGetDynamicNodeReason() *ExecutableDynamicNodeStatus_GetDynamicNodeReason
func (*ExecutableDynamicNodeStatus) OnGetDynamicNodeReasonMatch ¶
func (_m *ExecutableDynamicNodeStatus) OnGetDynamicNodeReasonMatch(matchers ...interface{}) *ExecutableDynamicNodeStatus_GetDynamicNodeReason
func (*ExecutableDynamicNodeStatus) OnGetExecutionError ¶
func (_m *ExecutableDynamicNodeStatus) OnGetExecutionError() *ExecutableDynamicNodeStatus_GetExecutionError
func (*ExecutableDynamicNodeStatus) OnGetExecutionErrorMatch ¶
func (_m *ExecutableDynamicNodeStatus) OnGetExecutionErrorMatch(matchers ...interface{}) *ExecutableDynamicNodeStatus_GetExecutionError
func (*ExecutableDynamicNodeStatus) OnGetIsFailurePermanent ¶
func (_m *ExecutableDynamicNodeStatus) OnGetIsFailurePermanent() *ExecutableDynamicNodeStatus_GetIsFailurePermanent
func (*ExecutableDynamicNodeStatus) OnGetIsFailurePermanentMatch ¶
func (_m *ExecutableDynamicNodeStatus) OnGetIsFailurePermanentMatch(matchers ...interface{}) *ExecutableDynamicNodeStatus_GetIsFailurePermanent
type ExecutableDynamicNodeStatus_GetDynamicNodePhase ¶
type ExecutableDynamicNodeStatus_GetDynamicNodeReason ¶
type ExecutableDynamicNodeStatus_GetExecutionError ¶
func (ExecutableDynamicNodeStatus_GetExecutionError) Return ¶
func (_m ExecutableDynamicNodeStatus_GetExecutionError) Return(_a0 *core.ExecutionError) *ExecutableDynamicNodeStatus_GetExecutionError
type ExecutableDynamicNodeStatus_GetIsFailurePermanent ¶
type ExecutableGateNode ¶
ExecutableGateNode is an autogenerated mock type for the ExecutableGateNode type
func (*ExecutableGateNode) GetApprove ¶
func (_m *ExecutableGateNode) GetApprove() *core.ApproveCondition
GetApprove provides a mock function with given fields:
func (*ExecutableGateNode) GetKind ¶
func (_m *ExecutableGateNode) GetKind() v1alpha1.ConditionKind
GetKind provides a mock function with given fields:
func (*ExecutableGateNode) GetSignal ¶
func (_m *ExecutableGateNode) GetSignal() *core.SignalCondition
GetSignal provides a mock function with given fields:
func (*ExecutableGateNode) GetSleep ¶
func (_m *ExecutableGateNode) GetSleep() *core.SleepCondition
GetSleep provides a mock function with given fields:
func (*ExecutableGateNode) OnGetApprove ¶
func (_m *ExecutableGateNode) OnGetApprove() *ExecutableGateNode_GetApprove
func (*ExecutableGateNode) OnGetApproveMatch ¶
func (_m *ExecutableGateNode) OnGetApproveMatch(matchers ...interface{}) *ExecutableGateNode_GetApprove
func (*ExecutableGateNode) OnGetKind ¶
func (_m *ExecutableGateNode) OnGetKind() *ExecutableGateNode_GetKind
func (*ExecutableGateNode) OnGetKindMatch ¶
func (_m *ExecutableGateNode) OnGetKindMatch(matchers ...interface{}) *ExecutableGateNode_GetKind
func (*ExecutableGateNode) OnGetSignal ¶
func (_m *ExecutableGateNode) OnGetSignal() *ExecutableGateNode_GetSignal
func (*ExecutableGateNode) OnGetSignalMatch ¶
func (_m *ExecutableGateNode) OnGetSignalMatch(matchers ...interface{}) *ExecutableGateNode_GetSignal
func (*ExecutableGateNode) OnGetSleep ¶
func (_m *ExecutableGateNode) OnGetSleep() *ExecutableGateNode_GetSleep
func (*ExecutableGateNode) OnGetSleepMatch ¶
func (_m *ExecutableGateNode) OnGetSleepMatch(matchers ...interface{}) *ExecutableGateNode_GetSleep
type ExecutableGateNodeStatus ¶
ExecutableGateNodeStatus is an autogenerated mock type for the ExecutableGateNodeStatus type
func (*ExecutableGateNodeStatus) GetGateNodePhase ¶
func (_m *ExecutableGateNodeStatus) GetGateNodePhase() v1alpha1.GateNodePhase
GetGateNodePhase provides a mock function with given fields:
func (*ExecutableGateNodeStatus) OnGetGateNodePhase ¶
func (_m *ExecutableGateNodeStatus) OnGetGateNodePhase() *ExecutableGateNodeStatus_GetGateNodePhase
func (*ExecutableGateNodeStatus) OnGetGateNodePhaseMatch ¶
func (_m *ExecutableGateNodeStatus) OnGetGateNodePhaseMatch(matchers ...interface{}) *ExecutableGateNodeStatus_GetGateNodePhase
type ExecutableGateNodeStatus_GetGateNodePhase ¶
func (ExecutableGateNodeStatus_GetGateNodePhase) Return ¶
func (_m ExecutableGateNodeStatus_GetGateNodePhase) Return(_a0 v1alpha1.GateNodePhase) *ExecutableGateNodeStatus_GetGateNodePhase
type ExecutableGateNode_GetApprove ¶
func (ExecutableGateNode_GetApprove) Return ¶
func (_m ExecutableGateNode_GetApprove) Return(_a0 *core.ApproveCondition) *ExecutableGateNode_GetApprove
type ExecutableGateNode_GetKind ¶
func (ExecutableGateNode_GetKind) Return ¶
func (_m ExecutableGateNode_GetKind) Return(_a0 v1alpha1.ConditionKind) *ExecutableGateNode_GetKind
type ExecutableGateNode_GetSignal ¶
func (ExecutableGateNode_GetSignal) Return ¶
func (_m ExecutableGateNode_GetSignal) Return(_a0 *core.SignalCondition) *ExecutableGateNode_GetSignal
type ExecutableGateNode_GetSleep ¶
func (ExecutableGateNode_GetSleep) Return ¶
func (_m ExecutableGateNode_GetSleep) Return(_a0 *core.SleepCondition) *ExecutableGateNode_GetSleep
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 ¶
func (_m *ExecutableIfBlock) OnGetCondition() *ExecutableIfBlock_GetCondition
func (*ExecutableIfBlock) OnGetConditionMatch ¶
func (_m *ExecutableIfBlock) OnGetConditionMatch(matchers ...interface{}) *ExecutableIfBlock_GetCondition
func (*ExecutableIfBlock) OnGetThenNode ¶
func (_m *ExecutableIfBlock) OnGetThenNode() *ExecutableIfBlock_GetThenNode
func (*ExecutableIfBlock) OnGetThenNodeMatch ¶
func (_m *ExecutableIfBlock) OnGetThenNodeMatch(matchers ...interface{}) *ExecutableIfBlock_GetThenNode
type ExecutableIfBlock_GetCondition ¶
func (ExecutableIfBlock_GetCondition) Return ¶
func (_m ExecutableIfBlock_GetCondition) Return(_a0 *core.BooleanExpression) *ExecutableIfBlock_GetCondition
type ExecutableIfBlock_GetThenNode ¶
func (ExecutableIfBlock_GetThenNode) Return ¶
func (_m ExecutableIfBlock_GetThenNode) Return(_a0 *string) *ExecutableIfBlock_GetThenNode
type ExecutableNode ¶
ExecutableNode is an autogenerated mock type for the ExecutableNode type
func (*ExecutableNode) GetActiveDeadline ¶
func (_m *ExecutableNode) GetActiveDeadline() *time.Duration
GetActiveDeadline provides a mock function with given fields:
func (*ExecutableNode) GetArrayNode ¶
func (_m *ExecutableNode) GetArrayNode() v1alpha1.ExecutableArrayNode
GetArrayNode 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) GetContainerImage ¶ added in v1.11.0
func (_m *ExecutableNode) GetContainerImage() string
GetContainerImage provides a mock function with given fields:
func (*ExecutableNode) GetExecutionDeadline ¶
func (_m *ExecutableNode) GetExecutionDeadline() *time.Duration
GetExecutionDeadline provides a mock function with given fields:
func (*ExecutableNode) GetExtendedResources ¶ added in v1.9.20
func (_m *ExecutableNode) GetExtendedResources() *core.ExtendedResources
GetExtendedResources provides a mock function with given fields:
func (*ExecutableNode) GetGateNode ¶
func (_m *ExecutableNode) GetGateNode() v1alpha1.ExecutableGateNode
GetGateNode 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) GetName ¶
func (_m *ExecutableNode) GetName() string
GetName 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 ¶
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 ¶
func (_m *ExecutableNode) OnGetActiveDeadline() *ExecutableNode_GetActiveDeadline
func (*ExecutableNode) OnGetActiveDeadlineMatch ¶
func (_m *ExecutableNode) OnGetActiveDeadlineMatch(matchers ...interface{}) *ExecutableNode_GetActiveDeadline
func (*ExecutableNode) OnGetArrayNode ¶
func (_m *ExecutableNode) OnGetArrayNode() *ExecutableNode_GetArrayNode
func (*ExecutableNode) OnGetArrayNodeMatch ¶
func (_m *ExecutableNode) OnGetArrayNodeMatch(matchers ...interface{}) *ExecutableNode_GetArrayNode
func (*ExecutableNode) OnGetBranchNode ¶
func (_m *ExecutableNode) OnGetBranchNode() *ExecutableNode_GetBranchNode
func (*ExecutableNode) OnGetBranchNodeMatch ¶
func (_m *ExecutableNode) OnGetBranchNodeMatch(matchers ...interface{}) *ExecutableNode_GetBranchNode
func (*ExecutableNode) OnGetConfig ¶
func (_m *ExecutableNode) OnGetConfig() *ExecutableNode_GetConfig
func (*ExecutableNode) OnGetConfigMatch ¶
func (_m *ExecutableNode) OnGetConfigMatch(matchers ...interface{}) *ExecutableNode_GetConfig
func (*ExecutableNode) OnGetContainerImage ¶ added in v1.11.0
func (_m *ExecutableNode) OnGetContainerImage() *ExecutableNode_GetContainerImage
func (*ExecutableNode) OnGetContainerImageMatch ¶ added in v1.11.0
func (_m *ExecutableNode) OnGetContainerImageMatch(matchers ...interface{}) *ExecutableNode_GetContainerImage
func (*ExecutableNode) OnGetExecutionDeadline ¶
func (_m *ExecutableNode) OnGetExecutionDeadline() *ExecutableNode_GetExecutionDeadline
func (*ExecutableNode) OnGetExecutionDeadlineMatch ¶
func (_m *ExecutableNode) OnGetExecutionDeadlineMatch(matchers ...interface{}) *ExecutableNode_GetExecutionDeadline
func (*ExecutableNode) OnGetExtendedResources ¶ added in v1.9.20
func (_m *ExecutableNode) OnGetExtendedResources() *ExecutableNode_GetExtendedResources
func (*ExecutableNode) OnGetExtendedResourcesMatch ¶ added in v1.9.20
func (_m *ExecutableNode) OnGetExtendedResourcesMatch(matchers ...interface{}) *ExecutableNode_GetExtendedResources
func (*ExecutableNode) OnGetGateNode ¶
func (_m *ExecutableNode) OnGetGateNode() *ExecutableNode_GetGateNode
func (*ExecutableNode) OnGetGateNodeMatch ¶
func (_m *ExecutableNode) OnGetGateNodeMatch(matchers ...interface{}) *ExecutableNode_GetGateNode
func (*ExecutableNode) OnGetID ¶
func (_m *ExecutableNode) OnGetID() *ExecutableNode_GetID
func (*ExecutableNode) OnGetIDMatch ¶
func (_m *ExecutableNode) OnGetIDMatch(matchers ...interface{}) *ExecutableNode_GetID
func (*ExecutableNode) OnGetInputBindings ¶
func (_m *ExecutableNode) OnGetInputBindings() *ExecutableNode_GetInputBindings
func (*ExecutableNode) OnGetInputBindingsMatch ¶
func (_m *ExecutableNode) OnGetInputBindingsMatch(matchers ...interface{}) *ExecutableNode_GetInputBindings
func (*ExecutableNode) OnGetKind ¶
func (_m *ExecutableNode) OnGetKind() *ExecutableNode_GetKind
func (*ExecutableNode) OnGetKindMatch ¶
func (_m *ExecutableNode) OnGetKindMatch(matchers ...interface{}) *ExecutableNode_GetKind
func (*ExecutableNode) OnGetName ¶
func (_m *ExecutableNode) OnGetName() *ExecutableNode_GetName
func (*ExecutableNode) OnGetNameMatch ¶
func (_m *ExecutableNode) OnGetNameMatch(matchers ...interface{}) *ExecutableNode_GetName
func (*ExecutableNode) OnGetOutputAlias ¶
func (_m *ExecutableNode) OnGetOutputAlias() *ExecutableNode_GetOutputAlias
func (*ExecutableNode) OnGetOutputAliasMatch ¶
func (_m *ExecutableNode) OnGetOutputAliasMatch(matchers ...interface{}) *ExecutableNode_GetOutputAlias
func (*ExecutableNode) OnGetResources ¶
func (_m *ExecutableNode) OnGetResources() *ExecutableNode_GetResources
func (*ExecutableNode) OnGetResourcesMatch ¶
func (_m *ExecutableNode) OnGetResourcesMatch(matchers ...interface{}) *ExecutableNode_GetResources
func (*ExecutableNode) OnGetRetryStrategy ¶
func (_m *ExecutableNode) OnGetRetryStrategy() *ExecutableNode_GetRetryStrategy
func (*ExecutableNode) OnGetRetryStrategyMatch ¶
func (_m *ExecutableNode) OnGetRetryStrategyMatch(matchers ...interface{}) *ExecutableNode_GetRetryStrategy
func (*ExecutableNode) OnGetTaskID ¶
func (_m *ExecutableNode) OnGetTaskID() *ExecutableNode_GetTaskID
func (*ExecutableNode) OnGetTaskIDMatch ¶
func (_m *ExecutableNode) OnGetTaskIDMatch(matchers ...interface{}) *ExecutableNode_GetTaskID
func (*ExecutableNode) OnGetWorkflowNode ¶
func (_m *ExecutableNode) OnGetWorkflowNode() *ExecutableNode_GetWorkflowNode
func (*ExecutableNode) OnGetWorkflowNodeMatch ¶
func (_m *ExecutableNode) OnGetWorkflowNodeMatch(matchers ...interface{}) *ExecutableNode_GetWorkflowNode
func (*ExecutableNode) OnIsEndNode ¶
func (_m *ExecutableNode) OnIsEndNode() *ExecutableNode_IsEndNode
func (*ExecutableNode) OnIsEndNodeMatch ¶
func (_m *ExecutableNode) OnIsEndNodeMatch(matchers ...interface{}) *ExecutableNode_IsEndNode
func (*ExecutableNode) OnIsInterruptible ¶
func (_m *ExecutableNode) OnIsInterruptible() *ExecutableNode_IsInterruptible
func (*ExecutableNode) OnIsInterruptibleMatch ¶
func (_m *ExecutableNode) OnIsInterruptibleMatch(matchers ...interface{}) *ExecutableNode_IsInterruptible
func (*ExecutableNode) OnIsStartNode ¶
func (_m *ExecutableNode) OnIsStartNode() *ExecutableNode_IsStartNode
func (*ExecutableNode) OnIsStartNodeMatch ¶
func (_m *ExecutableNode) OnIsStartNodeMatch(matchers ...interface{}) *ExecutableNode_IsStartNode
type ExecutableNodeStatus ¶
ExecutableNodeStatus is an autogenerated mock type for the ExecutableNodeStatus type
func (*ExecutableNodeStatus) ClearArrayNodeStatus ¶
func (_m *ExecutableNodeStatus) ClearArrayNodeStatus()
ClearArrayNodeStatus provides a mock function with given fields:
func (*ExecutableNodeStatus) ClearDynamicNodeStatus ¶
func (_m *ExecutableNodeStatus) ClearDynamicNodeStatus()
ClearDynamicNodeStatus provides a mock function with given fields:
func (*ExecutableNodeStatus) ClearGateNodeStatus ¶
func (_m *ExecutableNodeStatus) ClearGateNodeStatus()
ClearGateNodeStatus provides a mock function with given fields:
func (*ExecutableNodeStatus) ClearLastAttemptStartedAt ¶
func (_m *ExecutableNodeStatus) ClearLastAttemptStartedAt()
ClearLastAttemptStartedAt provides a mock function with given fields:
func (*ExecutableNodeStatus) ClearSubNodeStatus ¶
func (_m *ExecutableNodeStatus) ClearSubNodeStatus()
ClearSubNodeStatus provides a mock function with given fields:
func (*ExecutableNodeStatus) ClearTaskStatus ¶
func (_m *ExecutableNodeStatus) ClearTaskStatus()
ClearTaskStatus provides a mock function with given fields:
func (*ExecutableNodeStatus) ClearWorkflowStatus ¶
func (_m *ExecutableNodeStatus) ClearWorkflowStatus()
ClearWorkflowStatus provides a mock function with given fields:
func (*ExecutableNodeStatus) GetArrayNodeStatus ¶
func (_m *ExecutableNodeStatus) GetArrayNodeStatus() v1alpha1.MutableArrayNodeStatus
GetArrayNodeStatus provides a mock function with given fields:
func (*ExecutableNodeStatus) GetAttempts ¶
func (_m *ExecutableNodeStatus) GetAttempts() uint32
GetAttempts provides a mock function with given fields:
func (*ExecutableNodeStatus) GetBranchStatus ¶
func (_m *ExecutableNodeStatus) GetBranchStatus() v1alpha1.MutableBranchNodeStatus
GetBranchStatus provides a mock function with given fields:
func (*ExecutableNodeStatus) GetDataDir ¶
func (_m *ExecutableNodeStatus) GetDataDir() storage.DataReference
GetDataDir provides a mock function with given fields:
func (*ExecutableNodeStatus) GetDynamicNodeStatus ¶
func (_m *ExecutableNodeStatus) GetDynamicNodeStatus() v1alpha1.MutableDynamicNodeStatus
GetDynamicNodeStatus provides a mock function with given fields:
func (*ExecutableNodeStatus) GetExecutionError ¶
func (_m *ExecutableNodeStatus) GetExecutionError() *core.ExecutionError
GetExecutionError provides a mock function with given fields:
func (*ExecutableNodeStatus) GetGateNodeStatus ¶
func (_m *ExecutableNodeStatus) GetGateNodeStatus() v1alpha1.MutableGateNodeStatus
GetGateNodeStatus provides a mock function with given fields:
func (*ExecutableNodeStatus) GetLastAttemptStartedAt ¶
func (_m *ExecutableNodeStatus) GetLastAttemptStartedAt() *v1.Time
GetLastAttemptStartedAt provides a mock function with given fields:
func (*ExecutableNodeStatus) GetLastUpdatedAt ¶
func (_m *ExecutableNodeStatus) GetLastUpdatedAt() *v1.Time
GetLastUpdatedAt provides a mock function with given fields:
func (*ExecutableNodeStatus) GetMessage ¶
func (_m *ExecutableNodeStatus) GetMessage() string
GetMessage provides a mock function with given fields:
func (*ExecutableNodeStatus) GetNodeExecutionStatus ¶
func (_m *ExecutableNodeStatus) GetNodeExecutionStatus(ctx context.Context, id string) v1alpha1.ExecutableNodeStatus
GetNodeExecutionStatus provides a mock function with given fields: ctx, id
func (*ExecutableNodeStatus) GetOrCreateArrayNodeStatus ¶
func (_m *ExecutableNodeStatus) GetOrCreateArrayNodeStatus() v1alpha1.MutableArrayNodeStatus
GetOrCreateArrayNodeStatus provides a mock function with given fields:
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) GetOrCreateGateNodeStatus ¶
func (_m *ExecutableNodeStatus) GetOrCreateGateNodeStatus() v1alpha1.MutableGateNodeStatus
GetOrCreateGateNodeStatus provides a mock function with given fields:
func (*ExecutableNodeStatus) GetOrCreateTaskStatus ¶
func (_m *ExecutableNodeStatus) GetOrCreateTaskStatus() v1alpha1.MutableTaskNodeStatus
GetOrCreateTaskStatus provides a mock function with given fields:
func (*ExecutableNodeStatus) GetOrCreateWorkflowStatus ¶
func (_m *ExecutableNodeStatus) GetOrCreateWorkflowStatus() v1alpha1.MutableWorkflowNodeStatus
GetOrCreateWorkflowStatus provides a mock function with given fields:
func (*ExecutableNodeStatus) GetOutputDir ¶
func (_m *ExecutableNodeStatus) GetOutputDir() storage.DataReference
GetOutputDir provides a mock function with given fields:
func (*ExecutableNodeStatus) GetParentNodeID ¶
func (_m *ExecutableNodeStatus) GetParentNodeID() *string
GetParentNodeID provides a mock function with given fields:
func (*ExecutableNodeStatus) GetParentTaskID ¶
func (_m *ExecutableNodeStatus) GetParentTaskID() *core.TaskExecutionIdentifier
GetParentTaskID provides a mock function with given fields:
func (*ExecutableNodeStatus) GetPhase ¶
func (_m *ExecutableNodeStatus) GetPhase() v1alpha1.NodePhase
GetPhase provides a mock function with given fields:
func (*ExecutableNodeStatus) GetQueuedAt ¶
func (_m *ExecutableNodeStatus) GetQueuedAt() *v1.Time
GetQueuedAt provides a mock function with given fields:
func (*ExecutableNodeStatus) GetStartedAt ¶
func (_m *ExecutableNodeStatus) GetStartedAt() *v1.Time
GetStartedAt provides a mock function with given fields:
func (*ExecutableNodeStatus) GetStoppedAt ¶
func (_m *ExecutableNodeStatus) GetStoppedAt() *v1.Time
GetStoppedAt provides a mock function with given fields:
func (*ExecutableNodeStatus) GetSystemFailures ¶
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 ¶
func (_m *ExecutableNodeStatus) GetTaskStatus() v1alpha1.MutableTaskNodeStatus
GetTaskStatus provides a mock function with given fields:
func (*ExecutableNodeStatus) GetWorkflowNodeStatus ¶
func (_m *ExecutableNodeStatus) GetWorkflowNodeStatus() v1alpha1.ExecutableWorkflowNodeStatus
GetWorkflowNodeStatus provides a mock function with given fields:
func (*ExecutableNodeStatus) GetWorkflowStatus ¶
func (_m *ExecutableNodeStatus) GetWorkflowStatus() v1alpha1.MutableWorkflowNodeStatus
GetWorkflowStatus provides a mock function with given fields:
func (*ExecutableNodeStatus) IncrementAttempts ¶
func (_m *ExecutableNodeStatus) IncrementAttempts() uint32
IncrementAttempts provides a mock function with given fields:
func (*ExecutableNodeStatus) IncrementSystemFailures ¶
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) OnGetArrayNodeStatus ¶
func (_m *ExecutableNodeStatus) OnGetArrayNodeStatus() *ExecutableNodeStatus_GetArrayNodeStatus
func (*ExecutableNodeStatus) OnGetArrayNodeStatusMatch ¶
func (_m *ExecutableNodeStatus) OnGetArrayNodeStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetArrayNodeStatus
func (*ExecutableNodeStatus) OnGetAttempts ¶
func (_m *ExecutableNodeStatus) OnGetAttempts() *ExecutableNodeStatus_GetAttempts
func (*ExecutableNodeStatus) OnGetAttemptsMatch ¶
func (_m *ExecutableNodeStatus) OnGetAttemptsMatch(matchers ...interface{}) *ExecutableNodeStatus_GetAttempts
func (*ExecutableNodeStatus) OnGetBranchStatus ¶
func (_m *ExecutableNodeStatus) OnGetBranchStatus() *ExecutableNodeStatus_GetBranchStatus
func (*ExecutableNodeStatus) OnGetBranchStatusMatch ¶
func (_m *ExecutableNodeStatus) OnGetBranchStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetBranchStatus
func (*ExecutableNodeStatus) OnGetDataDir ¶
func (_m *ExecutableNodeStatus) OnGetDataDir() *ExecutableNodeStatus_GetDataDir
func (*ExecutableNodeStatus) OnGetDataDirMatch ¶
func (_m *ExecutableNodeStatus) OnGetDataDirMatch(matchers ...interface{}) *ExecutableNodeStatus_GetDataDir
func (*ExecutableNodeStatus) OnGetDynamicNodeStatus ¶
func (_m *ExecutableNodeStatus) OnGetDynamicNodeStatus() *ExecutableNodeStatus_GetDynamicNodeStatus
func (*ExecutableNodeStatus) OnGetDynamicNodeStatusMatch ¶
func (_m *ExecutableNodeStatus) OnGetDynamicNodeStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetDynamicNodeStatus
func (*ExecutableNodeStatus) OnGetExecutionError ¶
func (_m *ExecutableNodeStatus) OnGetExecutionError() *ExecutableNodeStatus_GetExecutionError
func (*ExecutableNodeStatus) OnGetExecutionErrorMatch ¶
func (_m *ExecutableNodeStatus) OnGetExecutionErrorMatch(matchers ...interface{}) *ExecutableNodeStatus_GetExecutionError
func (*ExecutableNodeStatus) OnGetGateNodeStatus ¶
func (_m *ExecutableNodeStatus) OnGetGateNodeStatus() *ExecutableNodeStatus_GetGateNodeStatus
func (*ExecutableNodeStatus) OnGetGateNodeStatusMatch ¶
func (_m *ExecutableNodeStatus) OnGetGateNodeStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetGateNodeStatus
func (*ExecutableNodeStatus) OnGetLastAttemptStartedAt ¶
func (_m *ExecutableNodeStatus) OnGetLastAttemptStartedAt() *ExecutableNodeStatus_GetLastAttemptStartedAt
func (*ExecutableNodeStatus) OnGetLastAttemptStartedAtMatch ¶
func (_m *ExecutableNodeStatus) OnGetLastAttemptStartedAtMatch(matchers ...interface{}) *ExecutableNodeStatus_GetLastAttemptStartedAt
func (*ExecutableNodeStatus) OnGetLastUpdatedAt ¶
func (_m *ExecutableNodeStatus) OnGetLastUpdatedAt() *ExecutableNodeStatus_GetLastUpdatedAt
func (*ExecutableNodeStatus) OnGetLastUpdatedAtMatch ¶
func (_m *ExecutableNodeStatus) OnGetLastUpdatedAtMatch(matchers ...interface{}) *ExecutableNodeStatus_GetLastUpdatedAt
func (*ExecutableNodeStatus) OnGetMessage ¶
func (_m *ExecutableNodeStatus) OnGetMessage() *ExecutableNodeStatus_GetMessage
func (*ExecutableNodeStatus) OnGetMessageMatch ¶
func (_m *ExecutableNodeStatus) OnGetMessageMatch(matchers ...interface{}) *ExecutableNodeStatus_GetMessage
func (*ExecutableNodeStatus) OnGetNodeExecutionStatus ¶
func (_m *ExecutableNodeStatus) OnGetNodeExecutionStatus(ctx context.Context, id string) *ExecutableNodeStatus_GetNodeExecutionStatus
func (*ExecutableNodeStatus) OnGetNodeExecutionStatusMatch ¶
func (_m *ExecutableNodeStatus) OnGetNodeExecutionStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetNodeExecutionStatus
func (*ExecutableNodeStatus) OnGetOrCreateArrayNodeStatus ¶
func (_m *ExecutableNodeStatus) OnGetOrCreateArrayNodeStatus() *ExecutableNodeStatus_GetOrCreateArrayNodeStatus
func (*ExecutableNodeStatus) OnGetOrCreateArrayNodeStatusMatch ¶
func (_m *ExecutableNodeStatus) OnGetOrCreateArrayNodeStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetOrCreateArrayNodeStatus
func (*ExecutableNodeStatus) OnGetOrCreateBranchStatus ¶
func (_m *ExecutableNodeStatus) OnGetOrCreateBranchStatus() *ExecutableNodeStatus_GetOrCreateBranchStatus
func (*ExecutableNodeStatus) OnGetOrCreateBranchStatusMatch ¶
func (_m *ExecutableNodeStatus) OnGetOrCreateBranchStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetOrCreateBranchStatus
func (*ExecutableNodeStatus) OnGetOrCreateDynamicNodeStatus ¶
func (_m *ExecutableNodeStatus) OnGetOrCreateDynamicNodeStatus() *ExecutableNodeStatus_GetOrCreateDynamicNodeStatus
func (*ExecutableNodeStatus) OnGetOrCreateDynamicNodeStatusMatch ¶
func (_m *ExecutableNodeStatus) OnGetOrCreateDynamicNodeStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetOrCreateDynamicNodeStatus
func (*ExecutableNodeStatus) OnGetOrCreateGateNodeStatus ¶
func (_m *ExecutableNodeStatus) OnGetOrCreateGateNodeStatus() *ExecutableNodeStatus_GetOrCreateGateNodeStatus
func (*ExecutableNodeStatus) OnGetOrCreateGateNodeStatusMatch ¶
func (_m *ExecutableNodeStatus) OnGetOrCreateGateNodeStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetOrCreateGateNodeStatus
func (*ExecutableNodeStatus) OnGetOrCreateTaskStatus ¶
func (_m *ExecutableNodeStatus) OnGetOrCreateTaskStatus() *ExecutableNodeStatus_GetOrCreateTaskStatus
func (*ExecutableNodeStatus) OnGetOrCreateTaskStatusMatch ¶
func (_m *ExecutableNodeStatus) OnGetOrCreateTaskStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetOrCreateTaskStatus
func (*ExecutableNodeStatus) OnGetOrCreateWorkflowStatus ¶
func (_m *ExecutableNodeStatus) OnGetOrCreateWorkflowStatus() *ExecutableNodeStatus_GetOrCreateWorkflowStatus
func (*ExecutableNodeStatus) OnGetOrCreateWorkflowStatusMatch ¶
func (_m *ExecutableNodeStatus) OnGetOrCreateWorkflowStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetOrCreateWorkflowStatus
func (*ExecutableNodeStatus) OnGetOutputDir ¶
func (_m *ExecutableNodeStatus) OnGetOutputDir() *ExecutableNodeStatus_GetOutputDir
func (*ExecutableNodeStatus) OnGetOutputDirMatch ¶
func (_m *ExecutableNodeStatus) OnGetOutputDirMatch(matchers ...interface{}) *ExecutableNodeStatus_GetOutputDir
func (*ExecutableNodeStatus) OnGetParentNodeID ¶
func (_m *ExecutableNodeStatus) OnGetParentNodeID() *ExecutableNodeStatus_GetParentNodeID
func (*ExecutableNodeStatus) OnGetParentNodeIDMatch ¶
func (_m *ExecutableNodeStatus) OnGetParentNodeIDMatch(matchers ...interface{}) *ExecutableNodeStatus_GetParentNodeID
func (*ExecutableNodeStatus) OnGetParentTaskID ¶
func (_m *ExecutableNodeStatus) OnGetParentTaskID() *ExecutableNodeStatus_GetParentTaskID
func (*ExecutableNodeStatus) OnGetParentTaskIDMatch ¶
func (_m *ExecutableNodeStatus) OnGetParentTaskIDMatch(matchers ...interface{}) *ExecutableNodeStatus_GetParentTaskID
func (*ExecutableNodeStatus) OnGetPhase ¶
func (_m *ExecutableNodeStatus) OnGetPhase() *ExecutableNodeStatus_GetPhase
func (*ExecutableNodeStatus) OnGetPhaseMatch ¶
func (_m *ExecutableNodeStatus) OnGetPhaseMatch(matchers ...interface{}) *ExecutableNodeStatus_GetPhase
func (*ExecutableNodeStatus) OnGetQueuedAt ¶
func (_m *ExecutableNodeStatus) OnGetQueuedAt() *ExecutableNodeStatus_GetQueuedAt
func (*ExecutableNodeStatus) OnGetQueuedAtMatch ¶
func (_m *ExecutableNodeStatus) OnGetQueuedAtMatch(matchers ...interface{}) *ExecutableNodeStatus_GetQueuedAt
func (*ExecutableNodeStatus) OnGetStartedAt ¶
func (_m *ExecutableNodeStatus) OnGetStartedAt() *ExecutableNodeStatus_GetStartedAt
func (*ExecutableNodeStatus) OnGetStartedAtMatch ¶
func (_m *ExecutableNodeStatus) OnGetStartedAtMatch(matchers ...interface{}) *ExecutableNodeStatus_GetStartedAt
func (*ExecutableNodeStatus) OnGetStoppedAt ¶
func (_m *ExecutableNodeStatus) OnGetStoppedAt() *ExecutableNodeStatus_GetStoppedAt
func (*ExecutableNodeStatus) OnGetStoppedAtMatch ¶
func (_m *ExecutableNodeStatus) OnGetStoppedAtMatch(matchers ...interface{}) *ExecutableNodeStatus_GetStoppedAt
func (*ExecutableNodeStatus) OnGetSystemFailures ¶
func (_m *ExecutableNodeStatus) OnGetSystemFailures() *ExecutableNodeStatus_GetSystemFailures
func (*ExecutableNodeStatus) OnGetSystemFailuresMatch ¶
func (_m *ExecutableNodeStatus) OnGetSystemFailuresMatch(matchers ...interface{}) *ExecutableNodeStatus_GetSystemFailures
func (*ExecutableNodeStatus) OnGetTaskNodeStatus ¶
func (_m *ExecutableNodeStatus) OnGetTaskNodeStatus() *ExecutableNodeStatus_GetTaskNodeStatus
func (*ExecutableNodeStatus) OnGetTaskNodeStatusMatch ¶
func (_m *ExecutableNodeStatus) OnGetTaskNodeStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetTaskNodeStatus
func (*ExecutableNodeStatus) OnGetTaskStatus ¶
func (_m *ExecutableNodeStatus) OnGetTaskStatus() *ExecutableNodeStatus_GetTaskStatus
func (*ExecutableNodeStatus) OnGetTaskStatusMatch ¶
func (_m *ExecutableNodeStatus) OnGetTaskStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetTaskStatus
func (*ExecutableNodeStatus) OnGetWorkflowNodeStatus ¶
func (_m *ExecutableNodeStatus) OnGetWorkflowNodeStatus() *ExecutableNodeStatus_GetWorkflowNodeStatus
func (*ExecutableNodeStatus) OnGetWorkflowNodeStatusMatch ¶
func (_m *ExecutableNodeStatus) OnGetWorkflowNodeStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetWorkflowNodeStatus
func (*ExecutableNodeStatus) OnGetWorkflowStatus ¶
func (_m *ExecutableNodeStatus) OnGetWorkflowStatus() *ExecutableNodeStatus_GetWorkflowStatus
func (*ExecutableNodeStatus) OnGetWorkflowStatusMatch ¶
func (_m *ExecutableNodeStatus) OnGetWorkflowStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetWorkflowStatus
func (*ExecutableNodeStatus) OnIncrementAttempts ¶
func (_m *ExecutableNodeStatus) OnIncrementAttempts() *ExecutableNodeStatus_IncrementAttempts
func (*ExecutableNodeStatus) OnIncrementAttemptsMatch ¶
func (_m *ExecutableNodeStatus) OnIncrementAttemptsMatch(matchers ...interface{}) *ExecutableNodeStatus_IncrementAttempts
func (*ExecutableNodeStatus) OnIncrementSystemFailures ¶
func (_m *ExecutableNodeStatus) OnIncrementSystemFailures() *ExecutableNodeStatus_IncrementSystemFailures
func (*ExecutableNodeStatus) OnIncrementSystemFailuresMatch ¶
func (_m *ExecutableNodeStatus) OnIncrementSystemFailuresMatch(matchers ...interface{}) *ExecutableNodeStatus_IncrementSystemFailures
func (*ExecutableNodeStatus) OnIsCached ¶
func (_m *ExecutableNodeStatus) OnIsCached() *ExecutableNodeStatus_IsCached
func (*ExecutableNodeStatus) OnIsCachedMatch ¶
func (_m *ExecutableNodeStatus) OnIsCachedMatch(matchers ...interface{}) *ExecutableNodeStatus_IsCached
func (*ExecutableNodeStatus) OnIsDirty ¶
func (_m *ExecutableNodeStatus) OnIsDirty() *ExecutableNodeStatus_IsDirty
func (*ExecutableNodeStatus) OnIsDirtyMatch ¶
func (_m *ExecutableNodeStatus) OnIsDirtyMatch(matchers ...interface{}) *ExecutableNodeStatus_IsDirty
func (*ExecutableNodeStatus) ResetDirty ¶
func (_m *ExecutableNodeStatus) ResetDirty()
ResetDirty provides a mock function with given fields:
func (*ExecutableNodeStatus) SetCached ¶
func (_m *ExecutableNodeStatus) SetCached()
SetCached provides a mock function with given fields:
func (*ExecutableNodeStatus) SetDataDir ¶
func (_m *ExecutableNodeStatus) SetDataDir(_a0 storage.DataReference)
SetDataDir provides a mock function with given fields: _a0
func (*ExecutableNodeStatus) SetOutputDir ¶
func (_m *ExecutableNodeStatus) SetOutputDir(d storage.DataReference)
SetOutputDir provides a mock function with given fields: d
func (*ExecutableNodeStatus) SetParentNodeID ¶
func (_m *ExecutableNodeStatus) SetParentNodeID(n *string)
SetParentNodeID provides a mock function with given fields: n
func (*ExecutableNodeStatus) SetParentTaskID ¶
func (_m *ExecutableNodeStatus) SetParentTaskID(t *core.TaskExecutionIdentifier)
SetParentTaskID provides a mock function with given fields: t
func (*ExecutableNodeStatus) UpdatePhase ¶
func (_m *ExecutableNodeStatus) UpdatePhase(phase v1alpha1.NodePhase, occurredAt v1.Time, reason string, enableCRDebugMetadata bool, err *core.ExecutionError)
UpdatePhase provides a mock function with given fields: phase, occurredAt, reason, enableCRDebugMetadata, err
func (*ExecutableNodeStatus) VisitNodeStatuses ¶
func (_m *ExecutableNodeStatus) VisitNodeStatuses(visitor func(string, v1alpha1.ExecutableNodeStatus))
VisitNodeStatuses provides a mock function with given fields: visitor
type ExecutableNodeStatus_GetArrayNodeStatus ¶
type ExecutableNodeStatus_GetAttempts ¶
func (ExecutableNodeStatus_GetAttempts) Return ¶
func (_m ExecutableNodeStatus_GetAttempts) Return(_a0 uint32) *ExecutableNodeStatus_GetAttempts
type ExecutableNodeStatus_GetBranchStatus ¶
func (ExecutableNodeStatus_GetBranchStatus) Return ¶
func (_m ExecutableNodeStatus_GetBranchStatus) Return(_a0 v1alpha1.MutableBranchNodeStatus) *ExecutableNodeStatus_GetBranchStatus
type ExecutableNodeStatus_GetDataDir ¶
func (ExecutableNodeStatus_GetDataDir) Return ¶
func (_m ExecutableNodeStatus_GetDataDir) Return(_a0 storage.DataReference) *ExecutableNodeStatus_GetDataDir
type ExecutableNodeStatus_GetDynamicNodeStatus ¶
type ExecutableNodeStatus_GetExecutionError ¶
func (ExecutableNodeStatus_GetExecutionError) Return ¶
func (_m ExecutableNodeStatus_GetExecutionError) Return(_a0 *core.ExecutionError) *ExecutableNodeStatus_GetExecutionError
type ExecutableNodeStatus_GetGateNodeStatus ¶
type ExecutableNodeStatus_GetLastAttemptStartedAt ¶
func (ExecutableNodeStatus_GetLastAttemptStartedAt) Return ¶
func (_m ExecutableNodeStatus_GetLastAttemptStartedAt) Return(_a0 *v1.Time) *ExecutableNodeStatus_GetLastAttemptStartedAt
type ExecutableNodeStatus_GetLastUpdatedAt ¶
func (ExecutableNodeStatus_GetLastUpdatedAt) Return ¶
func (_m ExecutableNodeStatus_GetLastUpdatedAt) Return(_a0 *v1.Time) *ExecutableNodeStatus_GetLastUpdatedAt
type ExecutableNodeStatus_GetMessage ¶
func (ExecutableNodeStatus_GetMessage) Return ¶
func (_m ExecutableNodeStatus_GetMessage) Return(_a0 string) *ExecutableNodeStatus_GetMessage
type ExecutableNodeStatus_GetNodeExecutionStatus ¶
type ExecutableNodeStatus_GetOrCreateArrayNodeStatus ¶
type ExecutableNodeStatus_GetOrCreateBranchStatus ¶
type ExecutableNodeStatus_GetOrCreateDynamicNodeStatus ¶
type ExecutableNodeStatus_GetOrCreateGateNodeStatus ¶
type ExecutableNodeStatus_GetOrCreateTaskStatus ¶
type ExecutableNodeStatus_GetOrCreateWorkflowStatus ¶
type ExecutableNodeStatus_GetOutputDir ¶
func (ExecutableNodeStatus_GetOutputDir) Return ¶
func (_m ExecutableNodeStatus_GetOutputDir) Return(_a0 storage.DataReference) *ExecutableNodeStatus_GetOutputDir
type ExecutableNodeStatus_GetParentNodeID ¶
func (ExecutableNodeStatus_GetParentNodeID) Return ¶
func (_m ExecutableNodeStatus_GetParentNodeID) Return(_a0 *string) *ExecutableNodeStatus_GetParentNodeID
type ExecutableNodeStatus_GetParentTaskID ¶
func (ExecutableNodeStatus_GetParentTaskID) Return ¶
func (_m ExecutableNodeStatus_GetParentTaskID) Return(_a0 *core.TaskExecutionIdentifier) *ExecutableNodeStatus_GetParentTaskID
type ExecutableNodeStatus_GetPhase ¶
func (ExecutableNodeStatus_GetPhase) Return ¶
func (_m ExecutableNodeStatus_GetPhase) Return(_a0 v1alpha1.NodePhase) *ExecutableNodeStatus_GetPhase
type ExecutableNodeStatus_GetQueuedAt ¶
func (ExecutableNodeStatus_GetQueuedAt) Return ¶
func (_m ExecutableNodeStatus_GetQueuedAt) Return(_a0 *v1.Time) *ExecutableNodeStatus_GetQueuedAt
type ExecutableNodeStatus_GetStartedAt ¶
func (ExecutableNodeStatus_GetStartedAt) Return ¶
func (_m ExecutableNodeStatus_GetStartedAt) Return(_a0 *v1.Time) *ExecutableNodeStatus_GetStartedAt
type ExecutableNodeStatus_GetStoppedAt ¶
func (ExecutableNodeStatus_GetStoppedAt) Return ¶
func (_m ExecutableNodeStatus_GetStoppedAt) Return(_a0 *v1.Time) *ExecutableNodeStatus_GetStoppedAt
type ExecutableNodeStatus_GetSystemFailures ¶
func (ExecutableNodeStatus_GetSystemFailures) Return ¶
func (_m ExecutableNodeStatus_GetSystemFailures) Return(_a0 uint32) *ExecutableNodeStatus_GetSystemFailures
type ExecutableNodeStatus_GetTaskNodeStatus ¶
type ExecutableNodeStatus_GetTaskStatus ¶
func (ExecutableNodeStatus_GetTaskStatus) Return ¶
func (_m ExecutableNodeStatus_GetTaskStatus) Return(_a0 v1alpha1.MutableTaskNodeStatus) *ExecutableNodeStatus_GetTaskStatus
type ExecutableNodeStatus_GetWorkflowNodeStatus ¶
type ExecutableNodeStatus_GetWorkflowStatus ¶
type ExecutableNodeStatus_IncrementAttempts ¶
func (ExecutableNodeStatus_IncrementAttempts) Return ¶
func (_m ExecutableNodeStatus_IncrementAttempts) Return(_a0 uint32) *ExecutableNodeStatus_IncrementAttempts
type ExecutableNodeStatus_IncrementSystemFailures ¶
func (ExecutableNodeStatus_IncrementSystemFailures) Return ¶
func (_m ExecutableNodeStatus_IncrementSystemFailures) Return(_a0 uint32) *ExecutableNodeStatus_IncrementSystemFailures
type ExecutableNodeStatus_IsCached ¶
func (ExecutableNodeStatus_IsCached) Return ¶
func (_m ExecutableNodeStatus_IsCached) Return(_a0 bool) *ExecutableNodeStatus_IsCached
type ExecutableNodeStatus_IsDirty ¶
func (ExecutableNodeStatus_IsDirty) Return ¶
func (_m ExecutableNodeStatus_IsDirty) Return(_a0 bool) *ExecutableNodeStatus_IsDirty
type ExecutableNode_GetActiveDeadline ¶
func (ExecutableNode_GetActiveDeadline) Return ¶
func (_m ExecutableNode_GetActiveDeadline) Return(_a0 *time.Duration) *ExecutableNode_GetActiveDeadline
type ExecutableNode_GetArrayNode ¶
func (ExecutableNode_GetArrayNode) Return ¶
func (_m ExecutableNode_GetArrayNode) Return(_a0 v1alpha1.ExecutableArrayNode) *ExecutableNode_GetArrayNode
type ExecutableNode_GetBranchNode ¶
func (ExecutableNode_GetBranchNode) Return ¶
func (_m ExecutableNode_GetBranchNode) Return(_a0 v1alpha1.ExecutableBranchNode) *ExecutableNode_GetBranchNode
type ExecutableNode_GetConfig ¶
func (ExecutableNode_GetConfig) Return ¶
func (_m ExecutableNode_GetConfig) Return(_a0 *v1.ConfigMap) *ExecutableNode_GetConfig
type ExecutableNode_GetContainerImage ¶ added in v1.11.0
func (ExecutableNode_GetContainerImage) Return ¶ added in v1.11.0
func (_m ExecutableNode_GetContainerImage) Return(_a0 string) *ExecutableNode_GetContainerImage
type ExecutableNode_GetExecutionDeadline ¶
func (ExecutableNode_GetExecutionDeadline) Return ¶
func (_m ExecutableNode_GetExecutionDeadline) Return(_a0 *time.Duration) *ExecutableNode_GetExecutionDeadline
type ExecutableNode_GetExtendedResources ¶ added in v1.9.20
func (ExecutableNode_GetExtendedResources) Return ¶ added in v1.9.20
func (_m ExecutableNode_GetExtendedResources) Return(_a0 *core.ExtendedResources) *ExecutableNode_GetExtendedResources
type ExecutableNode_GetGateNode ¶
func (ExecutableNode_GetGateNode) Return ¶
func (_m ExecutableNode_GetGateNode) Return(_a0 v1alpha1.ExecutableGateNode) *ExecutableNode_GetGateNode
type ExecutableNode_GetID ¶
func (ExecutableNode_GetID) Return ¶
func (_m ExecutableNode_GetID) Return(_a0 string) *ExecutableNode_GetID
type ExecutableNode_GetInputBindings ¶
func (ExecutableNode_GetInputBindings) Return ¶
func (_m ExecutableNode_GetInputBindings) Return(_a0 []*v1alpha1.Binding) *ExecutableNode_GetInputBindings
type ExecutableNode_GetKind ¶
func (ExecutableNode_GetKind) Return ¶
func (_m ExecutableNode_GetKind) Return(_a0 v1alpha1.NodeKind) *ExecutableNode_GetKind
type ExecutableNode_GetName ¶
func (ExecutableNode_GetName) Return ¶
func (_m ExecutableNode_GetName) Return(_a0 string) *ExecutableNode_GetName
type ExecutableNode_GetOutputAlias ¶
func (ExecutableNode_GetOutputAlias) Return ¶
func (_m ExecutableNode_GetOutputAlias) Return(_a0 []v1alpha1.Alias) *ExecutableNode_GetOutputAlias
type ExecutableNode_GetResources ¶
func (ExecutableNode_GetResources) Return ¶
func (_m ExecutableNode_GetResources) Return(_a0 *v1.ResourceRequirements) *ExecutableNode_GetResources
type ExecutableNode_GetRetryStrategy ¶
func (ExecutableNode_GetRetryStrategy) Return ¶
func (_m ExecutableNode_GetRetryStrategy) Return(_a0 *v1alpha1.RetryStrategy) *ExecutableNode_GetRetryStrategy
type ExecutableNode_GetTaskID ¶
func (ExecutableNode_GetTaskID) Return ¶
func (_m ExecutableNode_GetTaskID) Return(_a0 *string) *ExecutableNode_GetTaskID
type ExecutableNode_GetWorkflowNode ¶
func (ExecutableNode_GetWorkflowNode) Return ¶
func (_m ExecutableNode_GetWorkflowNode) Return(_a0 v1alpha1.ExecutableWorkflowNode) *ExecutableNode_GetWorkflowNode
type ExecutableNode_IsEndNode ¶
func (ExecutableNode_IsEndNode) Return ¶
func (_m ExecutableNode_IsEndNode) Return(_a0 bool) *ExecutableNode_IsEndNode
type ExecutableNode_IsInterruptible ¶
func (ExecutableNode_IsInterruptible) Return ¶
func (_m ExecutableNode_IsInterruptible) Return(_a0 *bool) *ExecutableNode_IsInterruptible
type ExecutableNode_IsStartNode ¶
func (ExecutableNode_IsStartNode) Return ¶
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) GetOnFailurePolicy ¶
func (_m *ExecutableSubWorkflow) GetOnFailurePolicy() v1alpha1.WorkflowOnFailurePolicy
GetOnFailurePolicy provides a mock function with given fields:
func (*ExecutableSubWorkflow) GetOutputBindings ¶
func (_m *ExecutableSubWorkflow) GetOutputBindings() []*v1alpha1.Binding
GetOutputBindings provides a mock function with given fields:
func (*ExecutableSubWorkflow) GetOutputs ¶
func (_m *ExecutableSubWorkflow) GetOutputs() *v1alpha1.OutputVarMap
GetOutputs provides a mock function with given fields:
func (*ExecutableSubWorkflow) OnFromNode ¶
func (_m *ExecutableSubWorkflow) OnFromNode(name string) *ExecutableSubWorkflow_FromNode
func (*ExecutableSubWorkflow) OnFromNodeMatch ¶
func (_m *ExecutableSubWorkflow) OnFromNodeMatch(matchers ...interface{}) *ExecutableSubWorkflow_FromNode
func (*ExecutableSubWorkflow) OnGetConnections ¶
func (_m *ExecutableSubWorkflow) OnGetConnections() *ExecutableSubWorkflow_GetConnections
func (*ExecutableSubWorkflow) OnGetConnectionsMatch ¶
func (_m *ExecutableSubWorkflow) OnGetConnectionsMatch(matchers ...interface{}) *ExecutableSubWorkflow_GetConnections
func (*ExecutableSubWorkflow) OnGetID ¶
func (_m *ExecutableSubWorkflow) OnGetID() *ExecutableSubWorkflow_GetID
func (*ExecutableSubWorkflow) OnGetIDMatch ¶
func (_m *ExecutableSubWorkflow) OnGetIDMatch(matchers ...interface{}) *ExecutableSubWorkflow_GetID
func (*ExecutableSubWorkflow) OnGetNode ¶
func (_m *ExecutableSubWorkflow) OnGetNode(nodeID string) *ExecutableSubWorkflow_GetNode
func (*ExecutableSubWorkflow) OnGetNodeMatch ¶
func (_m *ExecutableSubWorkflow) OnGetNodeMatch(matchers ...interface{}) *ExecutableSubWorkflow_GetNode
func (*ExecutableSubWorkflow) OnGetNodes ¶
func (_m *ExecutableSubWorkflow) OnGetNodes() *ExecutableSubWorkflow_GetNodes
func (*ExecutableSubWorkflow) OnGetNodesMatch ¶
func (_m *ExecutableSubWorkflow) OnGetNodesMatch(matchers ...interface{}) *ExecutableSubWorkflow_GetNodes
func (*ExecutableSubWorkflow) OnGetOnFailureNode ¶
func (_m *ExecutableSubWorkflow) OnGetOnFailureNode() *ExecutableSubWorkflow_GetOnFailureNode
func (*ExecutableSubWorkflow) OnGetOnFailureNodeMatch ¶
func (_m *ExecutableSubWorkflow) OnGetOnFailureNodeMatch(matchers ...interface{}) *ExecutableSubWorkflow_GetOnFailureNode
func (*ExecutableSubWorkflow) OnGetOnFailurePolicy ¶
func (_m *ExecutableSubWorkflow) OnGetOnFailurePolicy() *ExecutableSubWorkflow_GetOnFailurePolicy
func (*ExecutableSubWorkflow) OnGetOnFailurePolicyMatch ¶
func (_m *ExecutableSubWorkflow) OnGetOnFailurePolicyMatch(matchers ...interface{}) *ExecutableSubWorkflow_GetOnFailurePolicy
func (*ExecutableSubWorkflow) OnGetOutputBindings ¶
func (_m *ExecutableSubWorkflow) OnGetOutputBindings() *ExecutableSubWorkflow_GetOutputBindings
func (*ExecutableSubWorkflow) OnGetOutputBindingsMatch ¶
func (_m *ExecutableSubWorkflow) OnGetOutputBindingsMatch(matchers ...interface{}) *ExecutableSubWorkflow_GetOutputBindings
func (*ExecutableSubWorkflow) OnGetOutputs ¶
func (_m *ExecutableSubWorkflow) OnGetOutputs() *ExecutableSubWorkflow_GetOutputs
func (*ExecutableSubWorkflow) OnGetOutputsMatch ¶
func (_m *ExecutableSubWorkflow) OnGetOutputsMatch(matchers ...interface{}) *ExecutableSubWorkflow_GetOutputs
func (*ExecutableSubWorkflow) OnStartNode ¶
func (_m *ExecutableSubWorkflow) OnStartNode() *ExecutableSubWorkflow_StartNode
func (*ExecutableSubWorkflow) OnStartNodeMatch ¶
func (_m *ExecutableSubWorkflow) OnStartNodeMatch(matchers ...interface{}) *ExecutableSubWorkflow_StartNode
func (*ExecutableSubWorkflow) OnToNode ¶
func (_m *ExecutableSubWorkflow) OnToNode(name string) *ExecutableSubWorkflow_ToNode
func (*ExecutableSubWorkflow) OnToNodeMatch ¶
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 ¶
func (_m *ExecutableSubWorkflowNodeStatus) OnGetPhase() *ExecutableSubWorkflowNodeStatus_GetPhase
func (*ExecutableSubWorkflowNodeStatus) OnGetPhaseMatch ¶
func (_m *ExecutableSubWorkflowNodeStatus) OnGetPhaseMatch(matchers ...interface{}) *ExecutableSubWorkflowNodeStatus_GetPhase
type ExecutableSubWorkflowNodeStatus_GetPhase ¶
func (ExecutableSubWorkflowNodeStatus_GetPhase) Return ¶
func (_m ExecutableSubWorkflowNodeStatus_GetPhase) Return(_a0 v1alpha1.WorkflowPhase) *ExecutableSubWorkflowNodeStatus_GetPhase
type ExecutableSubWorkflow_FromNode ¶
func (ExecutableSubWorkflow_FromNode) Return ¶
func (_m ExecutableSubWorkflow_FromNode) Return(_a0 []string, _a1 error) *ExecutableSubWorkflow_FromNode
type ExecutableSubWorkflow_GetConnections ¶
func (ExecutableSubWorkflow_GetConnections) Return ¶
func (_m ExecutableSubWorkflow_GetConnections) Return(_a0 *v1alpha1.Connections) *ExecutableSubWorkflow_GetConnections
type ExecutableSubWorkflow_GetID ¶
func (ExecutableSubWorkflow_GetID) Return ¶
func (_m ExecutableSubWorkflow_GetID) Return(_a0 string) *ExecutableSubWorkflow_GetID
type ExecutableSubWorkflow_GetNode ¶
func (ExecutableSubWorkflow_GetNode) Return ¶
func (_m ExecutableSubWorkflow_GetNode) Return(_a0 v1alpha1.ExecutableNode, _a1 bool) *ExecutableSubWorkflow_GetNode
type ExecutableSubWorkflow_GetNodes ¶
func (ExecutableSubWorkflow_GetNodes) Return ¶
func (_m ExecutableSubWorkflow_GetNodes) Return(_a0 []string) *ExecutableSubWorkflow_GetNodes
type ExecutableSubWorkflow_GetOnFailureNode ¶
func (ExecutableSubWorkflow_GetOnFailureNode) Return ¶
func (_m ExecutableSubWorkflow_GetOnFailureNode) Return(_a0 v1alpha1.ExecutableNode) *ExecutableSubWorkflow_GetOnFailureNode
type ExecutableSubWorkflow_GetOnFailurePolicy ¶
type ExecutableSubWorkflow_GetOutputBindings ¶
func (ExecutableSubWorkflow_GetOutputBindings) Return ¶
func (_m ExecutableSubWorkflow_GetOutputBindings) Return(_a0 []*v1alpha1.Binding) *ExecutableSubWorkflow_GetOutputBindings
type ExecutableSubWorkflow_GetOutputs ¶
func (ExecutableSubWorkflow_GetOutputs) Return ¶
func (_m ExecutableSubWorkflow_GetOutputs) Return(_a0 *v1alpha1.OutputVarMap) *ExecutableSubWorkflow_GetOutputs
type ExecutableSubWorkflow_StartNode ¶
func (ExecutableSubWorkflow_StartNode) Return ¶
func (_m ExecutableSubWorkflow_StartNode) Return(_a0 v1alpha1.ExecutableNode) *ExecutableSubWorkflow_StartNode
type ExecutableSubWorkflow_ToNode ¶
func (ExecutableSubWorkflow_ToNode) Return ¶
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 ¶
func (_m *ExecutableTask) OnCoreTask() *ExecutableTask_CoreTask
func (*ExecutableTask) OnCoreTaskMatch ¶
func (_m *ExecutableTask) OnCoreTaskMatch(matchers ...interface{}) *ExecutableTask_CoreTask
func (*ExecutableTask) OnTaskType ¶
func (_m *ExecutableTask) OnTaskType() *ExecutableTask_TaskType
func (*ExecutableTask) OnTaskTypeMatch ¶
func (_m *ExecutableTask) OnTaskTypeMatch(matchers ...interface{}) *ExecutableTask_TaskType
func (*ExecutableTask) TaskType ¶
func (_m *ExecutableTask) TaskType() string
TaskType provides a mock function with given fields:
type ExecutableTaskNodeStatus ¶
ExecutableTaskNodeStatus is an autogenerated mock type for the ExecutableTaskNodeStatus type
func (*ExecutableTaskNodeStatus) GetBarrierClockTick ¶
func (_m *ExecutableTaskNodeStatus) GetBarrierClockTick() uint32
GetBarrierClockTick provides a mock function with given fields:
func (*ExecutableTaskNodeStatus) GetCleanupOnFailure ¶
func (_m *ExecutableTaskNodeStatus) GetCleanupOnFailure() bool
GetCleanupOnFailure provides a mock function with given fields:
func (*ExecutableTaskNodeStatus) GetLastPhaseUpdatedAt ¶
func (_m *ExecutableTaskNodeStatus) GetLastPhaseUpdatedAt() time.Time
GetLastPhaseUpdatedAt provides a mock function with given fields:
func (*ExecutableTaskNodeStatus) GetPhase ¶
func (_m *ExecutableTaskNodeStatus) GetPhase() int
GetPhase provides a mock function with given fields:
func (*ExecutableTaskNodeStatus) GetPhaseVersion ¶
func (_m *ExecutableTaskNodeStatus) GetPhaseVersion() uint32
GetPhaseVersion provides a mock function with given fields:
func (*ExecutableTaskNodeStatus) GetPluginState ¶
func (_m *ExecutableTaskNodeStatus) GetPluginState() []byte
GetPluginState provides a mock function with given fields:
func (*ExecutableTaskNodeStatus) GetPluginStateVersion ¶
func (_m *ExecutableTaskNodeStatus) GetPluginStateVersion() uint32
GetPluginStateVersion provides a mock function with given fields:
func (*ExecutableTaskNodeStatus) GetPreviousNodeExecutionCheckpointPath ¶
func (_m *ExecutableTaskNodeStatus) GetPreviousNodeExecutionCheckpointPath() storage.DataReference
GetPreviousNodeExecutionCheckpointPath provides a mock function with given fields:
func (*ExecutableTaskNodeStatus) OnGetBarrierClockTick ¶
func (_m *ExecutableTaskNodeStatus) OnGetBarrierClockTick() *ExecutableTaskNodeStatus_GetBarrierClockTick
func (*ExecutableTaskNodeStatus) OnGetBarrierClockTickMatch ¶
func (_m *ExecutableTaskNodeStatus) OnGetBarrierClockTickMatch(matchers ...interface{}) *ExecutableTaskNodeStatus_GetBarrierClockTick
func (*ExecutableTaskNodeStatus) OnGetCleanupOnFailure ¶
func (_m *ExecutableTaskNodeStatus) OnGetCleanupOnFailure() *ExecutableTaskNodeStatus_GetCleanupOnFailure
func (*ExecutableTaskNodeStatus) OnGetCleanupOnFailureMatch ¶
func (_m *ExecutableTaskNodeStatus) OnGetCleanupOnFailureMatch(matchers ...interface{}) *ExecutableTaskNodeStatus_GetCleanupOnFailure
func (*ExecutableTaskNodeStatus) OnGetLastPhaseUpdatedAt ¶
func (_m *ExecutableTaskNodeStatus) OnGetLastPhaseUpdatedAt() *ExecutableTaskNodeStatus_GetLastPhaseUpdatedAt
func (*ExecutableTaskNodeStatus) OnGetLastPhaseUpdatedAtMatch ¶
func (_m *ExecutableTaskNodeStatus) OnGetLastPhaseUpdatedAtMatch(matchers ...interface{}) *ExecutableTaskNodeStatus_GetLastPhaseUpdatedAt
func (*ExecutableTaskNodeStatus) OnGetPhase ¶
func (_m *ExecutableTaskNodeStatus) OnGetPhase() *ExecutableTaskNodeStatus_GetPhase
func (*ExecutableTaskNodeStatus) OnGetPhaseMatch ¶
func (_m *ExecutableTaskNodeStatus) OnGetPhaseMatch(matchers ...interface{}) *ExecutableTaskNodeStatus_GetPhase
func (*ExecutableTaskNodeStatus) OnGetPhaseVersion ¶
func (_m *ExecutableTaskNodeStatus) OnGetPhaseVersion() *ExecutableTaskNodeStatus_GetPhaseVersion
func (*ExecutableTaskNodeStatus) OnGetPhaseVersionMatch ¶
func (_m *ExecutableTaskNodeStatus) OnGetPhaseVersionMatch(matchers ...interface{}) *ExecutableTaskNodeStatus_GetPhaseVersion
func (*ExecutableTaskNodeStatus) OnGetPluginState ¶
func (_m *ExecutableTaskNodeStatus) OnGetPluginState() *ExecutableTaskNodeStatus_GetPluginState
func (*ExecutableTaskNodeStatus) OnGetPluginStateMatch ¶
func (_m *ExecutableTaskNodeStatus) OnGetPluginStateMatch(matchers ...interface{}) *ExecutableTaskNodeStatus_GetPluginState
func (*ExecutableTaskNodeStatus) OnGetPluginStateVersion ¶
func (_m *ExecutableTaskNodeStatus) OnGetPluginStateVersion() *ExecutableTaskNodeStatus_GetPluginStateVersion
func (*ExecutableTaskNodeStatus) OnGetPluginStateVersionMatch ¶
func (_m *ExecutableTaskNodeStatus) OnGetPluginStateVersionMatch(matchers ...interface{}) *ExecutableTaskNodeStatus_GetPluginStateVersion
func (*ExecutableTaskNodeStatus) OnGetPreviousNodeExecutionCheckpointPath ¶
func (_m *ExecutableTaskNodeStatus) OnGetPreviousNodeExecutionCheckpointPath() *ExecutableTaskNodeStatus_GetPreviousNodeExecutionCheckpointPath
func (*ExecutableTaskNodeStatus) OnGetPreviousNodeExecutionCheckpointPathMatch ¶
func (_m *ExecutableTaskNodeStatus) OnGetPreviousNodeExecutionCheckpointPathMatch(matchers ...interface{}) *ExecutableTaskNodeStatus_GetPreviousNodeExecutionCheckpointPath
type ExecutableTaskNodeStatus_GetBarrierClockTick ¶
func (ExecutableTaskNodeStatus_GetBarrierClockTick) Return ¶
func (_m ExecutableTaskNodeStatus_GetBarrierClockTick) Return(_a0 uint32) *ExecutableTaskNodeStatus_GetBarrierClockTick
type ExecutableTaskNodeStatus_GetCleanupOnFailure ¶
func (ExecutableTaskNodeStatus_GetCleanupOnFailure) Return ¶
func (_m ExecutableTaskNodeStatus_GetCleanupOnFailure) Return(_a0 bool) *ExecutableTaskNodeStatus_GetCleanupOnFailure
type ExecutableTaskNodeStatus_GetLastPhaseUpdatedAt ¶
func (ExecutableTaskNodeStatus_GetLastPhaseUpdatedAt) Return ¶
func (_m ExecutableTaskNodeStatus_GetLastPhaseUpdatedAt) Return(_a0 time.Time) *ExecutableTaskNodeStatus_GetLastPhaseUpdatedAt
type ExecutableTaskNodeStatus_GetPhase ¶
func (ExecutableTaskNodeStatus_GetPhase) Return ¶
func (_m ExecutableTaskNodeStatus_GetPhase) Return(_a0 int) *ExecutableTaskNodeStatus_GetPhase
type ExecutableTaskNodeStatus_GetPhaseVersion ¶
func (ExecutableTaskNodeStatus_GetPhaseVersion) Return ¶
func (_m ExecutableTaskNodeStatus_GetPhaseVersion) Return(_a0 uint32) *ExecutableTaskNodeStatus_GetPhaseVersion
type ExecutableTaskNodeStatus_GetPluginState ¶
func (ExecutableTaskNodeStatus_GetPluginState) Return ¶
func (_m ExecutableTaskNodeStatus_GetPluginState) Return(_a0 []byte) *ExecutableTaskNodeStatus_GetPluginState
type ExecutableTaskNodeStatus_GetPluginStateVersion ¶
func (ExecutableTaskNodeStatus_GetPluginStateVersion) Return ¶
func (_m ExecutableTaskNodeStatus_GetPluginStateVersion) Return(_a0 uint32) *ExecutableTaskNodeStatus_GetPluginStateVersion
type ExecutableTaskNodeStatus_GetPreviousNodeExecutionCheckpointPath ¶
type ExecutableTask_CoreTask ¶
func (ExecutableTask_CoreTask) Return ¶
func (_m ExecutableTask_CoreTask) Return(_a0 *core.TaskTemplate) *ExecutableTask_CoreTask
type ExecutableTask_TaskType ¶
func (ExecutableTask_TaskType) Return ¶
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) GetDefinitionVersion ¶
func (_m *ExecutableWorkflow) GetDefinitionVersion() v1alpha1.WorkflowDefinitionVersion
GetDefinitionVersion provides a mock function with given fields:
func (*ExecutableWorkflow) GetEventVersion ¶
func (_m *ExecutableWorkflow) GetEventVersion() v1alpha1.EventVersion
GetEventVersion provides a mock function with given fields:
func (*ExecutableWorkflow) GetExecutionConfig ¶
func (_m *ExecutableWorkflow) GetExecutionConfig() v1alpha1.ExecutionConfig
GetExecutionConfig 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) GetOnFailurePolicy ¶
func (_m *ExecutableWorkflow) GetOnFailurePolicy() v1alpha1.WorkflowOnFailurePolicy
GetOnFailurePolicy provides a mock function with given fields:
func (*ExecutableWorkflow) GetOutputBindings ¶
func (_m *ExecutableWorkflow) GetOutputBindings() []*v1alpha1.Binding
GetOutputBindings provides a mock function with given fields:
func (*ExecutableWorkflow) GetOutputs ¶
func (_m *ExecutableWorkflow) GetOutputs() *v1alpha1.OutputVarMap
GetOutputs provides a mock function with given fields:
func (*ExecutableWorkflow) GetOwnerReference ¶
func (_m *ExecutableWorkflow) GetOwnerReference() v1.OwnerReference
GetOwnerReference provides a mock function with given fields:
func (*ExecutableWorkflow) GetRawOutputDataConfig ¶
func (_m *ExecutableWorkflow) GetRawOutputDataConfig() v1alpha1.RawOutputDataConfig
GetRawOutputDataConfig provides a mock function with given fields:
func (*ExecutableWorkflow) GetSecurityContext ¶
func (_m *ExecutableWorkflow) GetSecurityContext() core.SecurityContext
GetSecurityContext 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 ¶
func (_m *ExecutableWorkflow) IsInterruptible() bool
IsInterruptible provides a mock function with given fields:
func (*ExecutableWorkflow) OnFindSubWorkflow ¶
func (_m *ExecutableWorkflow) OnFindSubWorkflow(subID string) *ExecutableWorkflow_FindSubWorkflow
func (*ExecutableWorkflow) OnFindSubWorkflowMatch ¶
func (_m *ExecutableWorkflow) OnFindSubWorkflowMatch(matchers ...interface{}) *ExecutableWorkflow_FindSubWorkflow
func (*ExecutableWorkflow) OnFromNode ¶
func (_m *ExecutableWorkflow) OnFromNode(name string) *ExecutableWorkflow_FromNode
func (*ExecutableWorkflow) OnFromNodeMatch ¶
func (_m *ExecutableWorkflow) OnFromNodeMatch(matchers ...interface{}) *ExecutableWorkflow_FromNode
func (*ExecutableWorkflow) OnGetAnnotations ¶
func (_m *ExecutableWorkflow) OnGetAnnotations() *ExecutableWorkflow_GetAnnotations
func (*ExecutableWorkflow) OnGetAnnotationsMatch ¶
func (_m *ExecutableWorkflow) OnGetAnnotationsMatch(matchers ...interface{}) *ExecutableWorkflow_GetAnnotations
func (*ExecutableWorkflow) OnGetConnections ¶
func (_m *ExecutableWorkflow) OnGetConnections() *ExecutableWorkflow_GetConnections
func (*ExecutableWorkflow) OnGetConnectionsMatch ¶
func (_m *ExecutableWorkflow) OnGetConnectionsMatch(matchers ...interface{}) *ExecutableWorkflow_GetConnections
func (*ExecutableWorkflow) OnGetCreationTimestamp ¶
func (_m *ExecutableWorkflow) OnGetCreationTimestamp() *ExecutableWorkflow_GetCreationTimestamp
func (*ExecutableWorkflow) OnGetCreationTimestampMatch ¶
func (_m *ExecutableWorkflow) OnGetCreationTimestampMatch(matchers ...interface{}) *ExecutableWorkflow_GetCreationTimestamp
func (*ExecutableWorkflow) OnGetDefinitionVersion ¶
func (_m *ExecutableWorkflow) OnGetDefinitionVersion() *ExecutableWorkflow_GetDefinitionVersion
func (*ExecutableWorkflow) OnGetDefinitionVersionMatch ¶
func (_m *ExecutableWorkflow) OnGetDefinitionVersionMatch(matchers ...interface{}) *ExecutableWorkflow_GetDefinitionVersion
func (*ExecutableWorkflow) OnGetEventVersion ¶
func (_m *ExecutableWorkflow) OnGetEventVersion() *ExecutableWorkflow_GetEventVersion
func (*ExecutableWorkflow) OnGetEventVersionMatch ¶
func (_m *ExecutableWorkflow) OnGetEventVersionMatch(matchers ...interface{}) *ExecutableWorkflow_GetEventVersion
func (*ExecutableWorkflow) OnGetExecutionConfig ¶
func (_m *ExecutableWorkflow) OnGetExecutionConfig() *ExecutableWorkflow_GetExecutionConfig
func (*ExecutableWorkflow) OnGetExecutionConfigMatch ¶
func (_m *ExecutableWorkflow) OnGetExecutionConfigMatch(matchers ...interface{}) *ExecutableWorkflow_GetExecutionConfig
func (*ExecutableWorkflow) OnGetExecutionID ¶
func (_m *ExecutableWorkflow) OnGetExecutionID() *ExecutableWorkflow_GetExecutionID
func (*ExecutableWorkflow) OnGetExecutionIDMatch ¶
func (_m *ExecutableWorkflow) OnGetExecutionIDMatch(matchers ...interface{}) *ExecutableWorkflow_GetExecutionID
func (*ExecutableWorkflow) OnGetExecutionStatus ¶
func (_m *ExecutableWorkflow) OnGetExecutionStatus() *ExecutableWorkflow_GetExecutionStatus
func (*ExecutableWorkflow) OnGetExecutionStatusMatch ¶
func (_m *ExecutableWorkflow) OnGetExecutionStatusMatch(matchers ...interface{}) *ExecutableWorkflow_GetExecutionStatus
func (*ExecutableWorkflow) OnGetID ¶
func (_m *ExecutableWorkflow) OnGetID() *ExecutableWorkflow_GetID
func (*ExecutableWorkflow) OnGetIDMatch ¶
func (_m *ExecutableWorkflow) OnGetIDMatch(matchers ...interface{}) *ExecutableWorkflow_GetID
func (*ExecutableWorkflow) OnGetK8sWorkflowID ¶
func (_m *ExecutableWorkflow) OnGetK8sWorkflowID() *ExecutableWorkflow_GetK8sWorkflowID
func (*ExecutableWorkflow) OnGetK8sWorkflowIDMatch ¶
func (_m *ExecutableWorkflow) OnGetK8sWorkflowIDMatch(matchers ...interface{}) *ExecutableWorkflow_GetK8sWorkflowID
func (*ExecutableWorkflow) OnGetLabels ¶
func (_m *ExecutableWorkflow) OnGetLabels() *ExecutableWorkflow_GetLabels
func (*ExecutableWorkflow) OnGetLabelsMatch ¶
func (_m *ExecutableWorkflow) OnGetLabelsMatch(matchers ...interface{}) *ExecutableWorkflow_GetLabels
func (*ExecutableWorkflow) OnGetName ¶
func (_m *ExecutableWorkflow) OnGetName() *ExecutableWorkflow_GetName
func (*ExecutableWorkflow) OnGetNameMatch ¶
func (_m *ExecutableWorkflow) OnGetNameMatch(matchers ...interface{}) *ExecutableWorkflow_GetName
func (*ExecutableWorkflow) OnGetNamespace ¶
func (_m *ExecutableWorkflow) OnGetNamespace() *ExecutableWorkflow_GetNamespace
func (*ExecutableWorkflow) OnGetNamespaceMatch ¶
func (_m *ExecutableWorkflow) OnGetNamespaceMatch(matchers ...interface{}) *ExecutableWorkflow_GetNamespace
func (*ExecutableWorkflow) OnGetNode ¶
func (_m *ExecutableWorkflow) OnGetNode(nodeID string) *ExecutableWorkflow_GetNode
func (*ExecutableWorkflow) OnGetNodeExecutionStatus ¶
func (_m *ExecutableWorkflow) OnGetNodeExecutionStatus(ctx context.Context, id string) *ExecutableWorkflow_GetNodeExecutionStatus
func (*ExecutableWorkflow) OnGetNodeExecutionStatusMatch ¶
func (_m *ExecutableWorkflow) OnGetNodeExecutionStatusMatch(matchers ...interface{}) *ExecutableWorkflow_GetNodeExecutionStatus
func (*ExecutableWorkflow) OnGetNodeMatch ¶
func (_m *ExecutableWorkflow) OnGetNodeMatch(matchers ...interface{}) *ExecutableWorkflow_GetNode
func (*ExecutableWorkflow) OnGetNodes ¶
func (_m *ExecutableWorkflow) OnGetNodes() *ExecutableWorkflow_GetNodes
func (*ExecutableWorkflow) OnGetNodesMatch ¶
func (_m *ExecutableWorkflow) OnGetNodesMatch(matchers ...interface{}) *ExecutableWorkflow_GetNodes
func (*ExecutableWorkflow) OnGetOnFailureNode ¶
func (_m *ExecutableWorkflow) OnGetOnFailureNode() *ExecutableWorkflow_GetOnFailureNode
func (*ExecutableWorkflow) OnGetOnFailureNodeMatch ¶
func (_m *ExecutableWorkflow) OnGetOnFailureNodeMatch(matchers ...interface{}) *ExecutableWorkflow_GetOnFailureNode
func (*ExecutableWorkflow) OnGetOnFailurePolicy ¶
func (_m *ExecutableWorkflow) OnGetOnFailurePolicy() *ExecutableWorkflow_GetOnFailurePolicy
func (*ExecutableWorkflow) OnGetOnFailurePolicyMatch ¶
func (_m *ExecutableWorkflow) OnGetOnFailurePolicyMatch(matchers ...interface{}) *ExecutableWorkflow_GetOnFailurePolicy
func (*ExecutableWorkflow) OnGetOutputBindings ¶
func (_m *ExecutableWorkflow) OnGetOutputBindings() *ExecutableWorkflow_GetOutputBindings
func (*ExecutableWorkflow) OnGetOutputBindingsMatch ¶
func (_m *ExecutableWorkflow) OnGetOutputBindingsMatch(matchers ...interface{}) *ExecutableWorkflow_GetOutputBindings
func (*ExecutableWorkflow) OnGetOutputs ¶
func (_m *ExecutableWorkflow) OnGetOutputs() *ExecutableWorkflow_GetOutputs
func (*ExecutableWorkflow) OnGetOutputsMatch ¶
func (_m *ExecutableWorkflow) OnGetOutputsMatch(matchers ...interface{}) *ExecutableWorkflow_GetOutputs
func (*ExecutableWorkflow) OnGetOwnerReference ¶
func (_m *ExecutableWorkflow) OnGetOwnerReference() *ExecutableWorkflow_GetOwnerReference
func (*ExecutableWorkflow) OnGetOwnerReferenceMatch ¶
func (_m *ExecutableWorkflow) OnGetOwnerReferenceMatch(matchers ...interface{}) *ExecutableWorkflow_GetOwnerReference
func (*ExecutableWorkflow) OnGetRawOutputDataConfig ¶
func (_m *ExecutableWorkflow) OnGetRawOutputDataConfig() *ExecutableWorkflow_GetRawOutputDataConfig
func (*ExecutableWorkflow) OnGetRawOutputDataConfigMatch ¶
func (_m *ExecutableWorkflow) OnGetRawOutputDataConfigMatch(matchers ...interface{}) *ExecutableWorkflow_GetRawOutputDataConfig
func (*ExecutableWorkflow) OnGetSecurityContext ¶
func (_m *ExecutableWorkflow) OnGetSecurityContext() *ExecutableWorkflow_GetSecurityContext
func (*ExecutableWorkflow) OnGetSecurityContextMatch ¶
func (_m *ExecutableWorkflow) OnGetSecurityContextMatch(matchers ...interface{}) *ExecutableWorkflow_GetSecurityContext
func (*ExecutableWorkflow) OnGetServiceAccountName ¶
func (_m *ExecutableWorkflow) OnGetServiceAccountName() *ExecutableWorkflow_GetServiceAccountName
func (*ExecutableWorkflow) OnGetServiceAccountNameMatch ¶
func (_m *ExecutableWorkflow) OnGetServiceAccountNameMatch(matchers ...interface{}) *ExecutableWorkflow_GetServiceAccountName
func (*ExecutableWorkflow) OnGetTask ¶
func (_m *ExecutableWorkflow) OnGetTask(id string) *ExecutableWorkflow_GetTask
func (*ExecutableWorkflow) OnGetTaskMatch ¶
func (_m *ExecutableWorkflow) OnGetTaskMatch(matchers ...interface{}) *ExecutableWorkflow_GetTask
func (*ExecutableWorkflow) OnIsInterruptible ¶
func (_m *ExecutableWorkflow) OnIsInterruptible() *ExecutableWorkflow_IsInterruptible
func (*ExecutableWorkflow) OnIsInterruptibleMatch ¶
func (_m *ExecutableWorkflow) OnIsInterruptibleMatch(matchers ...interface{}) *ExecutableWorkflow_IsInterruptible
func (*ExecutableWorkflow) OnStartNode ¶
func (_m *ExecutableWorkflow) OnStartNode() *ExecutableWorkflow_StartNode
func (*ExecutableWorkflow) OnStartNodeMatch ¶
func (_m *ExecutableWorkflow) OnStartNodeMatch(matchers ...interface{}) *ExecutableWorkflow_StartNode
func (*ExecutableWorkflow) OnToNode ¶
func (_m *ExecutableWorkflow) OnToNode(name string) *ExecutableWorkflow_ToNode
func (*ExecutableWorkflow) OnToNodeMatch ¶
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 ¶
func (_m *ExecutableWorkflowNode) OnGetLaunchPlanRefID() *ExecutableWorkflowNode_GetLaunchPlanRefID
func (*ExecutableWorkflowNode) OnGetLaunchPlanRefIDMatch ¶
func (_m *ExecutableWorkflowNode) OnGetLaunchPlanRefIDMatch(matchers ...interface{}) *ExecutableWorkflowNode_GetLaunchPlanRefID
func (*ExecutableWorkflowNode) OnGetSubWorkflowRef ¶
func (_m *ExecutableWorkflowNode) OnGetSubWorkflowRef() *ExecutableWorkflowNode_GetSubWorkflowRef
func (*ExecutableWorkflowNode) OnGetSubWorkflowRefMatch ¶
func (_m *ExecutableWorkflowNode) OnGetSubWorkflowRefMatch(matchers ...interface{}) *ExecutableWorkflowNode_GetSubWorkflowRef
type ExecutableWorkflowNodeStatus ¶
ExecutableWorkflowNodeStatus is an autogenerated mock type for the ExecutableWorkflowNodeStatus type
func (*ExecutableWorkflowNodeStatus) GetExecutionError ¶
func (_m *ExecutableWorkflowNodeStatus) GetExecutionError() *core.ExecutionError
GetExecutionError provides a mock function with given fields:
func (*ExecutableWorkflowNodeStatus) GetWorkflowNodePhase ¶
func (_m *ExecutableWorkflowNodeStatus) GetWorkflowNodePhase() v1alpha1.WorkflowNodePhase
GetWorkflowNodePhase provides a mock function with given fields:
func (*ExecutableWorkflowNodeStatus) OnGetExecutionError ¶
func (_m *ExecutableWorkflowNodeStatus) OnGetExecutionError() *ExecutableWorkflowNodeStatus_GetExecutionError
func (*ExecutableWorkflowNodeStatus) OnGetExecutionErrorMatch ¶
func (_m *ExecutableWorkflowNodeStatus) OnGetExecutionErrorMatch(matchers ...interface{}) *ExecutableWorkflowNodeStatus_GetExecutionError
func (*ExecutableWorkflowNodeStatus) OnGetWorkflowNodePhase ¶
func (_m *ExecutableWorkflowNodeStatus) OnGetWorkflowNodePhase() *ExecutableWorkflowNodeStatus_GetWorkflowNodePhase
func (*ExecutableWorkflowNodeStatus) OnGetWorkflowNodePhaseMatch ¶
func (_m *ExecutableWorkflowNodeStatus) OnGetWorkflowNodePhaseMatch(matchers ...interface{}) *ExecutableWorkflowNodeStatus_GetWorkflowNodePhase
type ExecutableWorkflowNodeStatus_GetExecutionError ¶
type ExecutableWorkflowNodeStatus_GetWorkflowNodePhase ¶
type ExecutableWorkflowNode_GetLaunchPlanRefID ¶
func (ExecutableWorkflowNode_GetLaunchPlanRefID) Return ¶
func (_m ExecutableWorkflowNode_GetLaunchPlanRefID) Return(_a0 *v1alpha1.Identifier) *ExecutableWorkflowNode_GetLaunchPlanRefID
type ExecutableWorkflowNode_GetSubWorkflowRef ¶
func (ExecutableWorkflowNode_GetSubWorkflowRef) Return ¶
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 ¶
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 ¶
func (_m *ExecutableWorkflowStatus) OnConstructNodeDataDir(ctx context.Context, name string) *ExecutableWorkflowStatus_ConstructNodeDataDir
func (*ExecutableWorkflowStatus) OnConstructNodeDataDirMatch ¶
func (_m *ExecutableWorkflowStatus) OnConstructNodeDataDirMatch(matchers ...interface{}) *ExecutableWorkflowStatus_ConstructNodeDataDir
func (*ExecutableWorkflowStatus) OnGetDataDir ¶
func (_m *ExecutableWorkflowStatus) OnGetDataDir() *ExecutableWorkflowStatus_GetDataDir
func (*ExecutableWorkflowStatus) OnGetDataDirMatch ¶
func (_m *ExecutableWorkflowStatus) OnGetDataDirMatch(matchers ...interface{}) *ExecutableWorkflowStatus_GetDataDir
func (*ExecutableWorkflowStatus) OnGetExecutionError ¶
func (_m *ExecutableWorkflowStatus) OnGetExecutionError() *ExecutableWorkflowStatus_GetExecutionError
func (*ExecutableWorkflowStatus) OnGetExecutionErrorMatch ¶
func (_m *ExecutableWorkflowStatus) OnGetExecutionErrorMatch(matchers ...interface{}) *ExecutableWorkflowStatus_GetExecutionError
func (*ExecutableWorkflowStatus) OnGetLastUpdatedAt ¶
func (_m *ExecutableWorkflowStatus) OnGetLastUpdatedAt() *ExecutableWorkflowStatus_GetLastUpdatedAt
func (*ExecutableWorkflowStatus) OnGetLastUpdatedAtMatch ¶
func (_m *ExecutableWorkflowStatus) OnGetLastUpdatedAtMatch(matchers ...interface{}) *ExecutableWorkflowStatus_GetLastUpdatedAt
func (*ExecutableWorkflowStatus) OnGetMessage ¶
func (_m *ExecutableWorkflowStatus) OnGetMessage() *ExecutableWorkflowStatus_GetMessage
func (*ExecutableWorkflowStatus) OnGetMessageMatch ¶
func (_m *ExecutableWorkflowStatus) OnGetMessageMatch(matchers ...interface{}) *ExecutableWorkflowStatus_GetMessage
func (*ExecutableWorkflowStatus) OnGetNodeExecutionStatus ¶
func (_m *ExecutableWorkflowStatus) OnGetNodeExecutionStatus(ctx context.Context, id string) *ExecutableWorkflowStatus_GetNodeExecutionStatus
func (*ExecutableWorkflowStatus) OnGetNodeExecutionStatusMatch ¶
func (_m *ExecutableWorkflowStatus) OnGetNodeExecutionStatusMatch(matchers ...interface{}) *ExecutableWorkflowStatus_GetNodeExecutionStatus
func (*ExecutableWorkflowStatus) OnGetOutputReference ¶
func (_m *ExecutableWorkflowStatus) OnGetOutputReference() *ExecutableWorkflowStatus_GetOutputReference
func (*ExecutableWorkflowStatus) OnGetOutputReferenceMatch ¶
func (_m *ExecutableWorkflowStatus) OnGetOutputReferenceMatch(matchers ...interface{}) *ExecutableWorkflowStatus_GetOutputReference
func (*ExecutableWorkflowStatus) OnGetPhase ¶
func (_m *ExecutableWorkflowStatus) OnGetPhase() *ExecutableWorkflowStatus_GetPhase
func (*ExecutableWorkflowStatus) OnGetPhaseMatch ¶
func (_m *ExecutableWorkflowStatus) OnGetPhaseMatch(matchers ...interface{}) *ExecutableWorkflowStatus_GetPhase
func (*ExecutableWorkflowStatus) OnGetStartedAt ¶
func (_m *ExecutableWorkflowStatus) OnGetStartedAt() *ExecutableWorkflowStatus_GetStartedAt
func (*ExecutableWorkflowStatus) OnGetStartedAtMatch ¶
func (_m *ExecutableWorkflowStatus) OnGetStartedAtMatch(matchers ...interface{}) *ExecutableWorkflowStatus_GetStartedAt
func (*ExecutableWorkflowStatus) OnGetStoppedAt ¶
func (_m *ExecutableWorkflowStatus) OnGetStoppedAt() *ExecutableWorkflowStatus_GetStoppedAt
func (*ExecutableWorkflowStatus) OnGetStoppedAtMatch ¶
func (_m *ExecutableWorkflowStatus) OnGetStoppedAtMatch(matchers ...interface{}) *ExecutableWorkflowStatus_GetStoppedAt
func (*ExecutableWorkflowStatus) OnIsTerminated ¶
func (_m *ExecutableWorkflowStatus) OnIsTerminated() *ExecutableWorkflowStatus_IsTerminated
func (*ExecutableWorkflowStatus) OnIsTerminatedMatch ¶
func (_m *ExecutableWorkflowStatus) OnIsTerminatedMatch(matchers ...interface{}) *ExecutableWorkflowStatus_IsTerminated
func (*ExecutableWorkflowStatus) SetDataDir ¶
func (_m *ExecutableWorkflowStatus) SetDataDir(_a0 storage.DataReference)
SetDataDir provides a mock function with given fields: _a0
func (*ExecutableWorkflowStatus) SetMessage ¶
func (_m *ExecutableWorkflowStatus) SetMessage(msg string)
SetMessage provides a mock function with given fields: msg
func (*ExecutableWorkflowStatus) SetOutputReference ¶
func (_m *ExecutableWorkflowStatus) SetOutputReference(reference storage.DataReference)
SetOutputReference provides a mock function with given fields: reference
func (*ExecutableWorkflowStatus) UpdatePhase ¶
func (_m *ExecutableWorkflowStatus) UpdatePhase(p v1alpha1.WorkflowPhase, msg string, err *core.ExecutionError)
UpdatePhase provides a mock function with given fields: p, msg, err
type ExecutableWorkflowStatus_ConstructNodeDataDir ¶
func (ExecutableWorkflowStatus_ConstructNodeDataDir) Return ¶
func (_m ExecutableWorkflowStatus_ConstructNodeDataDir) Return(_a0 storage.DataReference, _a1 error) *ExecutableWorkflowStatus_ConstructNodeDataDir
type ExecutableWorkflowStatus_GetDataDir ¶
func (ExecutableWorkflowStatus_GetDataDir) Return ¶
func (_m ExecutableWorkflowStatus_GetDataDir) Return(_a0 storage.DataReference) *ExecutableWorkflowStatus_GetDataDir
type ExecutableWorkflowStatus_GetExecutionError ¶
func (ExecutableWorkflowStatus_GetExecutionError) Return ¶
func (_m ExecutableWorkflowStatus_GetExecutionError) Return(_a0 *core.ExecutionError) *ExecutableWorkflowStatus_GetExecutionError
type ExecutableWorkflowStatus_GetLastUpdatedAt ¶
func (ExecutableWorkflowStatus_GetLastUpdatedAt) Return ¶
func (_m ExecutableWorkflowStatus_GetLastUpdatedAt) Return(_a0 *v1.Time) *ExecutableWorkflowStatus_GetLastUpdatedAt
type ExecutableWorkflowStatus_GetMessage ¶
func (ExecutableWorkflowStatus_GetMessage) Return ¶
func (_m ExecutableWorkflowStatus_GetMessage) Return(_a0 string) *ExecutableWorkflowStatus_GetMessage
type ExecutableWorkflowStatus_GetNodeExecutionStatus ¶
type ExecutableWorkflowStatus_GetOutputReference ¶
type ExecutableWorkflowStatus_GetPhase ¶
func (ExecutableWorkflowStatus_GetPhase) Return ¶
func (_m ExecutableWorkflowStatus_GetPhase) Return(_a0 v1alpha1.WorkflowPhase) *ExecutableWorkflowStatus_GetPhase
type ExecutableWorkflowStatus_GetStartedAt ¶
func (ExecutableWorkflowStatus_GetStartedAt) Return ¶
func (_m ExecutableWorkflowStatus_GetStartedAt) Return(_a0 *v1.Time) *ExecutableWorkflowStatus_GetStartedAt
type ExecutableWorkflowStatus_GetStoppedAt ¶
func (ExecutableWorkflowStatus_GetStoppedAt) Return ¶
func (_m ExecutableWorkflowStatus_GetStoppedAt) Return(_a0 *v1.Time) *ExecutableWorkflowStatus_GetStoppedAt
type ExecutableWorkflowStatus_IsTerminated ¶
func (ExecutableWorkflowStatus_IsTerminated) Return ¶
func (_m ExecutableWorkflowStatus_IsTerminated) Return(_a0 bool) *ExecutableWorkflowStatus_IsTerminated
type ExecutableWorkflow_FindSubWorkflow ¶
func (ExecutableWorkflow_FindSubWorkflow) Return ¶
func (_m ExecutableWorkflow_FindSubWorkflow) Return(_a0 v1alpha1.ExecutableSubWorkflow) *ExecutableWorkflow_FindSubWorkflow
type ExecutableWorkflow_FromNode ¶
func (ExecutableWorkflow_FromNode) Return ¶
func (_m ExecutableWorkflow_FromNode) Return(_a0 []string, _a1 error) *ExecutableWorkflow_FromNode
type ExecutableWorkflow_GetAnnotations ¶
func (ExecutableWorkflow_GetAnnotations) Return ¶
func (_m ExecutableWorkflow_GetAnnotations) Return(_a0 map[string]string) *ExecutableWorkflow_GetAnnotations
type ExecutableWorkflow_GetConnections ¶
func (ExecutableWorkflow_GetConnections) Return ¶
func (_m ExecutableWorkflow_GetConnections) Return(_a0 *v1alpha1.Connections) *ExecutableWorkflow_GetConnections
type ExecutableWorkflow_GetCreationTimestamp ¶
func (ExecutableWorkflow_GetCreationTimestamp) Return ¶
func (_m ExecutableWorkflow_GetCreationTimestamp) Return(_a0 v1.Time) *ExecutableWorkflow_GetCreationTimestamp
type ExecutableWorkflow_GetDefinitionVersion ¶
type ExecutableWorkflow_GetEventVersion ¶
func (ExecutableWorkflow_GetEventVersion) Return ¶
func (_m ExecutableWorkflow_GetEventVersion) Return(_a0 v1alpha1.EventVersion) *ExecutableWorkflow_GetEventVersion
type ExecutableWorkflow_GetExecutionConfig ¶
func (ExecutableWorkflow_GetExecutionConfig) Return ¶
func (_m ExecutableWorkflow_GetExecutionConfig) Return(_a0 v1alpha1.ExecutionConfig) *ExecutableWorkflow_GetExecutionConfig
type ExecutableWorkflow_GetExecutionID ¶
func (ExecutableWorkflow_GetExecutionID) Return ¶
func (_m ExecutableWorkflow_GetExecutionID) Return(_a0 v1alpha1.WorkflowExecutionIdentifier) *ExecutableWorkflow_GetExecutionID
type ExecutableWorkflow_GetExecutionStatus ¶
type ExecutableWorkflow_GetID ¶
func (ExecutableWorkflow_GetID) Return ¶
func (_m ExecutableWorkflow_GetID) Return(_a0 string) *ExecutableWorkflow_GetID
type ExecutableWorkflow_GetK8sWorkflowID ¶
func (ExecutableWorkflow_GetK8sWorkflowID) Return ¶
func (_m ExecutableWorkflow_GetK8sWorkflowID) Return(_a0 types.NamespacedName) *ExecutableWorkflow_GetK8sWorkflowID
type ExecutableWorkflow_GetLabels ¶
func (ExecutableWorkflow_GetLabels) Return ¶
func (_m ExecutableWorkflow_GetLabels) Return(_a0 map[string]string) *ExecutableWorkflow_GetLabels
type ExecutableWorkflow_GetName ¶
func (ExecutableWorkflow_GetName) Return ¶
func (_m ExecutableWorkflow_GetName) Return(_a0 string) *ExecutableWorkflow_GetName
type ExecutableWorkflow_GetNamespace ¶
func (ExecutableWorkflow_GetNamespace) Return ¶
func (_m ExecutableWorkflow_GetNamespace) Return(_a0 string) *ExecutableWorkflow_GetNamespace
type ExecutableWorkflow_GetNode ¶
func (ExecutableWorkflow_GetNode) Return ¶
func (_m ExecutableWorkflow_GetNode) Return(_a0 v1alpha1.ExecutableNode, _a1 bool) *ExecutableWorkflow_GetNode
type ExecutableWorkflow_GetNodeExecutionStatus ¶
type ExecutableWorkflow_GetNodes ¶
func (ExecutableWorkflow_GetNodes) Return ¶
func (_m ExecutableWorkflow_GetNodes) Return(_a0 []string) *ExecutableWorkflow_GetNodes
type ExecutableWorkflow_GetOnFailureNode ¶
func (ExecutableWorkflow_GetOnFailureNode) Return ¶
func (_m ExecutableWorkflow_GetOnFailureNode) Return(_a0 v1alpha1.ExecutableNode) *ExecutableWorkflow_GetOnFailureNode
type ExecutableWorkflow_GetOnFailurePolicy ¶
type ExecutableWorkflow_GetOutputBindings ¶
func (ExecutableWorkflow_GetOutputBindings) Return ¶
func (_m ExecutableWorkflow_GetOutputBindings) Return(_a0 []*v1alpha1.Binding) *ExecutableWorkflow_GetOutputBindings
type ExecutableWorkflow_GetOutputs ¶
func (ExecutableWorkflow_GetOutputs) Return ¶
func (_m ExecutableWorkflow_GetOutputs) Return(_a0 *v1alpha1.OutputVarMap) *ExecutableWorkflow_GetOutputs
type ExecutableWorkflow_GetOwnerReference ¶
func (ExecutableWorkflow_GetOwnerReference) Return ¶
func (_m ExecutableWorkflow_GetOwnerReference) Return(_a0 v1.OwnerReference) *ExecutableWorkflow_GetOwnerReference
type ExecutableWorkflow_GetRawOutputDataConfig ¶
type ExecutableWorkflow_GetSecurityContext ¶
func (ExecutableWorkflow_GetSecurityContext) Return ¶
func (_m ExecutableWorkflow_GetSecurityContext) Return(_a0 core.SecurityContext) *ExecutableWorkflow_GetSecurityContext
type ExecutableWorkflow_GetServiceAccountName ¶
func (ExecutableWorkflow_GetServiceAccountName) Return ¶
func (_m ExecutableWorkflow_GetServiceAccountName) Return(_a0 string) *ExecutableWorkflow_GetServiceAccountName
type ExecutableWorkflow_GetTask ¶
func (ExecutableWorkflow_GetTask) Return ¶
func (_m ExecutableWorkflow_GetTask) Return(_a0 v1alpha1.ExecutableTask, _a1 error) *ExecutableWorkflow_GetTask
type ExecutableWorkflow_IsInterruptible ¶
func (ExecutableWorkflow_IsInterruptible) Return ¶
func (_m ExecutableWorkflow_IsInterruptible) Return(_a0 bool) *ExecutableWorkflow_IsInterruptible
type ExecutableWorkflow_StartNode ¶
func (ExecutableWorkflow_StartNode) Return ¶
func (_m ExecutableWorkflow_StartNode) Return(_a0 v1alpha1.ExecutableNode) *ExecutableWorkflow_StartNode
type ExecutableWorkflow_ToNode ¶
func (ExecutableWorkflow_ToNode) Return ¶
func (_m ExecutableWorkflow_ToNode) Return(_a0 []string, _a1 error) *ExecutableWorkflow_ToNode
type ExecutionTimeInfo ¶
ExecutionTimeInfo is an autogenerated mock type for the ExecutionTimeInfo type
func (*ExecutionTimeInfo) GetLastUpdatedAt ¶
func (_m *ExecutionTimeInfo) GetLastUpdatedAt() *v1.Time
GetLastUpdatedAt provides a mock function with given fields:
func (*ExecutionTimeInfo) GetStartedAt ¶
func (_m *ExecutionTimeInfo) GetStartedAt() *v1.Time
GetStartedAt provides a mock function with given fields:
func (*ExecutionTimeInfo) GetStoppedAt ¶
func (_m *ExecutionTimeInfo) GetStoppedAt() *v1.Time
GetStoppedAt provides a mock function with given fields:
func (*ExecutionTimeInfo) OnGetLastUpdatedAt ¶
func (_m *ExecutionTimeInfo) OnGetLastUpdatedAt() *ExecutionTimeInfo_GetLastUpdatedAt
func (*ExecutionTimeInfo) OnGetLastUpdatedAtMatch ¶
func (_m *ExecutionTimeInfo) OnGetLastUpdatedAtMatch(matchers ...interface{}) *ExecutionTimeInfo_GetLastUpdatedAt
func (*ExecutionTimeInfo) OnGetStartedAt ¶
func (_m *ExecutionTimeInfo) OnGetStartedAt() *ExecutionTimeInfo_GetStartedAt
func (*ExecutionTimeInfo) OnGetStartedAtMatch ¶
func (_m *ExecutionTimeInfo) OnGetStartedAtMatch(matchers ...interface{}) *ExecutionTimeInfo_GetStartedAt
func (*ExecutionTimeInfo) OnGetStoppedAt ¶
func (_m *ExecutionTimeInfo) OnGetStoppedAt() *ExecutionTimeInfo_GetStoppedAt
func (*ExecutionTimeInfo) OnGetStoppedAtMatch ¶
func (_m *ExecutionTimeInfo) OnGetStoppedAtMatch(matchers ...interface{}) *ExecutionTimeInfo_GetStoppedAt
type ExecutionTimeInfo_GetLastUpdatedAt ¶
func (ExecutionTimeInfo_GetLastUpdatedAt) Return ¶
func (_m ExecutionTimeInfo_GetLastUpdatedAt) Return(_a0 *v1.Time) *ExecutionTimeInfo_GetLastUpdatedAt
type ExecutionTimeInfo_GetStartedAt ¶
func (ExecutionTimeInfo_GetStartedAt) Return ¶
func (_m ExecutionTimeInfo_GetStartedAt) Return(_a0 *v1.Time) *ExecutionTimeInfo_GetStartedAt
type ExecutionTimeInfo_GetStoppedAt ¶
func (ExecutionTimeInfo_GetStoppedAt) Return ¶
func (_m ExecutionTimeInfo_GetStoppedAt) Return(_a0 *v1.Time) *ExecutionTimeInfo_GetStoppedAt
type Meta ¶
Meta is an autogenerated mock type for the Meta type
func (*Meta) GetAnnotations ¶
GetAnnotations provides a mock function with given fields:
func (*Meta) GetCreationTimestamp ¶
GetCreationTimestamp provides a mock function with given fields:
func (*Meta) GetDefinitionVersion ¶
func (_m *Meta) GetDefinitionVersion() v1alpha1.WorkflowDefinitionVersion
GetDefinitionVersion provides a mock function with given fields:
func (*Meta) GetEventVersion ¶
func (_m *Meta) GetEventVersion() v1alpha1.EventVersion
GetEventVersion provides a mock function with given fields:
func (*Meta) GetExecutionID ¶
func (_m *Meta) GetExecutionID() v1alpha1.WorkflowExecutionIdentifier
GetExecutionID provides a mock function with given fields:
func (*Meta) GetK8sWorkflowID ¶
func (_m *Meta) GetK8sWorkflowID() types.NamespacedName
GetK8sWorkflowID provides a mock function with given fields:
func (*Meta) GetNamespace ¶
GetNamespace provides a mock function with given fields:
func (*Meta) GetOwnerReference ¶
func (_m *Meta) GetOwnerReference() v1.OwnerReference
GetOwnerReference provides a mock function with given fields:
func (*Meta) GetRawOutputDataConfig ¶
func (_m *Meta) GetRawOutputDataConfig() v1alpha1.RawOutputDataConfig
GetRawOutputDataConfig provides a mock function with given fields:
func (*Meta) GetSecurityContext ¶
func (_m *Meta) GetSecurityContext() core.SecurityContext
GetSecurityContext provides a mock function with given fields:
func (*Meta) GetServiceAccountName ¶
GetServiceAccountName provides a mock function with given fields:
func (*Meta) IsInterruptible ¶
IsInterruptible provides a mock function with given fields:
func (*Meta) OnGetAnnotations ¶
func (_m *Meta) OnGetAnnotations() *Meta_GetAnnotations
func (*Meta) OnGetAnnotationsMatch ¶
func (_m *Meta) OnGetAnnotationsMatch(matchers ...interface{}) *Meta_GetAnnotations
func (*Meta) OnGetCreationTimestamp ¶
func (_m *Meta) OnGetCreationTimestamp() *Meta_GetCreationTimestamp
func (*Meta) OnGetCreationTimestampMatch ¶
func (_m *Meta) OnGetCreationTimestampMatch(matchers ...interface{}) *Meta_GetCreationTimestamp
func (*Meta) OnGetDefinitionVersion ¶
func (_m *Meta) OnGetDefinitionVersion() *Meta_GetDefinitionVersion
func (*Meta) OnGetDefinitionVersionMatch ¶
func (_m *Meta) OnGetDefinitionVersionMatch(matchers ...interface{}) *Meta_GetDefinitionVersion
func (*Meta) OnGetEventVersion ¶
func (_m *Meta) OnGetEventVersion() *Meta_GetEventVersion
func (*Meta) OnGetEventVersionMatch ¶
func (_m *Meta) OnGetEventVersionMatch(matchers ...interface{}) *Meta_GetEventVersion
func (*Meta) OnGetExecutionID ¶
func (_m *Meta) OnGetExecutionID() *Meta_GetExecutionID
func (*Meta) OnGetExecutionIDMatch ¶
func (_m *Meta) OnGetExecutionIDMatch(matchers ...interface{}) *Meta_GetExecutionID
func (*Meta) OnGetK8sWorkflowID ¶
func (_m *Meta) OnGetK8sWorkflowID() *Meta_GetK8sWorkflowID
func (*Meta) OnGetK8sWorkflowIDMatch ¶
func (_m *Meta) OnGetK8sWorkflowIDMatch(matchers ...interface{}) *Meta_GetK8sWorkflowID
func (*Meta) OnGetLabels ¶
func (_m *Meta) OnGetLabels() *Meta_GetLabels
func (*Meta) OnGetLabelsMatch ¶
func (_m *Meta) OnGetLabelsMatch(matchers ...interface{}) *Meta_GetLabels
func (*Meta) OnGetName ¶
func (_m *Meta) OnGetName() *Meta_GetName
func (*Meta) OnGetNameMatch ¶
func (_m *Meta) OnGetNameMatch(matchers ...interface{}) *Meta_GetName
func (*Meta) OnGetNamespace ¶
func (_m *Meta) OnGetNamespace() *Meta_GetNamespace
func (*Meta) OnGetNamespaceMatch ¶
func (_m *Meta) OnGetNamespaceMatch(matchers ...interface{}) *Meta_GetNamespace
func (*Meta) OnGetOwnerReference ¶
func (_m *Meta) OnGetOwnerReference() *Meta_GetOwnerReference
func (*Meta) OnGetOwnerReferenceMatch ¶
func (_m *Meta) OnGetOwnerReferenceMatch(matchers ...interface{}) *Meta_GetOwnerReference
func (*Meta) OnGetRawOutputDataConfig ¶
func (_m *Meta) OnGetRawOutputDataConfig() *Meta_GetRawOutputDataConfig
func (*Meta) OnGetRawOutputDataConfigMatch ¶
func (_m *Meta) OnGetRawOutputDataConfigMatch(matchers ...interface{}) *Meta_GetRawOutputDataConfig
func (*Meta) OnGetSecurityContext ¶
func (_m *Meta) OnGetSecurityContext() *Meta_GetSecurityContext
func (*Meta) OnGetSecurityContextMatch ¶
func (_m *Meta) OnGetSecurityContextMatch(matchers ...interface{}) *Meta_GetSecurityContext
func (*Meta) OnGetServiceAccountName ¶
func (_m *Meta) OnGetServiceAccountName() *Meta_GetServiceAccountName
func (*Meta) OnGetServiceAccountNameMatch ¶
func (_m *Meta) OnGetServiceAccountNameMatch(matchers ...interface{}) *Meta_GetServiceAccountName
func (*Meta) OnIsInterruptible ¶
func (_m *Meta) OnIsInterruptible() *Meta_IsInterruptible
func (*Meta) OnIsInterruptibleMatch ¶
func (_m *Meta) OnIsInterruptibleMatch(matchers ...interface{}) *Meta_IsInterruptible
type MetaExtended ¶
MetaExtended is an autogenerated mock type for the MetaExtended type
func (*MetaExtended) FindSubWorkflow ¶
func (_m *MetaExtended) FindSubWorkflow(subID string) v1alpha1.ExecutableSubWorkflow
FindSubWorkflow provides a mock function with given fields: subID
func (*MetaExtended) GetAnnotations ¶
func (_m *MetaExtended) GetAnnotations() map[string]string
GetAnnotations provides a mock function with given fields:
func (*MetaExtended) GetCreationTimestamp ¶
func (_m *MetaExtended) GetCreationTimestamp() v1.Time
GetCreationTimestamp provides a mock function with given fields:
func (*MetaExtended) GetDefinitionVersion ¶
func (_m *MetaExtended) GetDefinitionVersion() v1alpha1.WorkflowDefinitionVersion
GetDefinitionVersion provides a mock function with given fields:
func (*MetaExtended) GetEventVersion ¶
func (_m *MetaExtended) GetEventVersion() v1alpha1.EventVersion
GetEventVersion provides a mock function with given fields:
func (*MetaExtended) GetExecutionID ¶
func (_m *MetaExtended) GetExecutionID() v1alpha1.WorkflowExecutionIdentifier
GetExecutionID provides a mock function with given fields:
func (*MetaExtended) GetExecutionStatus ¶
func (_m *MetaExtended) GetExecutionStatus() v1alpha1.ExecutableWorkflowStatus
GetExecutionStatus provides a mock function with given fields:
func (*MetaExtended) GetK8sWorkflowID ¶
func (_m *MetaExtended) GetK8sWorkflowID() types.NamespacedName
GetK8sWorkflowID provides a mock function with given fields:
func (*MetaExtended) GetLabels ¶
func (_m *MetaExtended) GetLabels() map[string]string
GetLabels provides a mock function with given fields:
func (*MetaExtended) GetName ¶
func (_m *MetaExtended) GetName() string
GetName provides a mock function with given fields:
func (*MetaExtended) GetNamespace ¶
func (_m *MetaExtended) GetNamespace() string
GetNamespace provides a mock function with given fields:
func (*MetaExtended) GetOwnerReference ¶
func (_m *MetaExtended) GetOwnerReference() v1.OwnerReference
GetOwnerReference provides a mock function with given fields:
func (*MetaExtended) GetRawOutputDataConfig ¶
func (_m *MetaExtended) GetRawOutputDataConfig() v1alpha1.RawOutputDataConfig
GetRawOutputDataConfig provides a mock function with given fields:
func (*MetaExtended) GetSecurityContext ¶
func (_m *MetaExtended) GetSecurityContext() core.SecurityContext
GetSecurityContext provides a mock function with given fields:
func (*MetaExtended) GetServiceAccountName ¶
func (_m *MetaExtended) GetServiceAccountName() string
GetServiceAccountName provides a mock function with given fields:
func (*MetaExtended) GetTask ¶
func (_m *MetaExtended) GetTask(id string) (v1alpha1.ExecutableTask, error)
GetTask provides a mock function with given fields: id
func (*MetaExtended) IsInterruptible ¶
func (_m *MetaExtended) IsInterruptible() bool
IsInterruptible provides a mock function with given fields:
func (*MetaExtended) OnFindSubWorkflow ¶
func (_m *MetaExtended) OnFindSubWorkflow(subID string) *MetaExtended_FindSubWorkflow
func (*MetaExtended) OnFindSubWorkflowMatch ¶
func (_m *MetaExtended) OnFindSubWorkflowMatch(matchers ...interface{}) *MetaExtended_FindSubWorkflow
func (*MetaExtended) OnGetAnnotations ¶
func (_m *MetaExtended) OnGetAnnotations() *MetaExtended_GetAnnotations
func (*MetaExtended) OnGetAnnotationsMatch ¶
func (_m *MetaExtended) OnGetAnnotationsMatch(matchers ...interface{}) *MetaExtended_GetAnnotations
func (*MetaExtended) OnGetCreationTimestamp ¶
func (_m *MetaExtended) OnGetCreationTimestamp() *MetaExtended_GetCreationTimestamp
func (*MetaExtended) OnGetCreationTimestampMatch ¶
func (_m *MetaExtended) OnGetCreationTimestampMatch(matchers ...interface{}) *MetaExtended_GetCreationTimestamp
func (*MetaExtended) OnGetDefinitionVersion ¶
func (_m *MetaExtended) OnGetDefinitionVersion() *MetaExtended_GetDefinitionVersion
func (*MetaExtended) OnGetDefinitionVersionMatch ¶
func (_m *MetaExtended) OnGetDefinitionVersionMatch(matchers ...interface{}) *MetaExtended_GetDefinitionVersion
func (*MetaExtended) OnGetEventVersion ¶
func (_m *MetaExtended) OnGetEventVersion() *MetaExtended_GetEventVersion
func (*MetaExtended) OnGetEventVersionMatch ¶
func (_m *MetaExtended) OnGetEventVersionMatch(matchers ...interface{}) *MetaExtended_GetEventVersion
func (*MetaExtended) OnGetExecutionID ¶
func (_m *MetaExtended) OnGetExecutionID() *MetaExtended_GetExecutionID
func (*MetaExtended) OnGetExecutionIDMatch ¶
func (_m *MetaExtended) OnGetExecutionIDMatch(matchers ...interface{}) *MetaExtended_GetExecutionID
func (*MetaExtended) OnGetExecutionStatus ¶
func (_m *MetaExtended) OnGetExecutionStatus() *MetaExtended_GetExecutionStatus
func (*MetaExtended) OnGetExecutionStatusMatch ¶
func (_m *MetaExtended) OnGetExecutionStatusMatch(matchers ...interface{}) *MetaExtended_GetExecutionStatus
func (*MetaExtended) OnGetK8sWorkflowID ¶
func (_m *MetaExtended) OnGetK8sWorkflowID() *MetaExtended_GetK8sWorkflowID
func (*MetaExtended) OnGetK8sWorkflowIDMatch ¶
func (_m *MetaExtended) OnGetK8sWorkflowIDMatch(matchers ...interface{}) *MetaExtended_GetK8sWorkflowID
func (*MetaExtended) OnGetLabels ¶
func (_m *MetaExtended) OnGetLabels() *MetaExtended_GetLabels
func (*MetaExtended) OnGetLabelsMatch ¶
func (_m *MetaExtended) OnGetLabelsMatch(matchers ...interface{}) *MetaExtended_GetLabels
func (*MetaExtended) OnGetName ¶
func (_m *MetaExtended) OnGetName() *MetaExtended_GetName
func (*MetaExtended) OnGetNameMatch ¶
func (_m *MetaExtended) OnGetNameMatch(matchers ...interface{}) *MetaExtended_GetName
func (*MetaExtended) OnGetNamespace ¶
func (_m *MetaExtended) OnGetNamespace() *MetaExtended_GetNamespace
func (*MetaExtended) OnGetNamespaceMatch ¶
func (_m *MetaExtended) OnGetNamespaceMatch(matchers ...interface{}) *MetaExtended_GetNamespace
func (*MetaExtended) OnGetOwnerReference ¶
func (_m *MetaExtended) OnGetOwnerReference() *MetaExtended_GetOwnerReference
func (*MetaExtended) OnGetOwnerReferenceMatch ¶
func (_m *MetaExtended) OnGetOwnerReferenceMatch(matchers ...interface{}) *MetaExtended_GetOwnerReference
func (*MetaExtended) OnGetRawOutputDataConfig ¶
func (_m *MetaExtended) OnGetRawOutputDataConfig() *MetaExtended_GetRawOutputDataConfig
func (*MetaExtended) OnGetRawOutputDataConfigMatch ¶
func (_m *MetaExtended) OnGetRawOutputDataConfigMatch(matchers ...interface{}) *MetaExtended_GetRawOutputDataConfig
func (*MetaExtended) OnGetSecurityContext ¶
func (_m *MetaExtended) OnGetSecurityContext() *MetaExtended_GetSecurityContext
func (*MetaExtended) OnGetSecurityContextMatch ¶
func (_m *MetaExtended) OnGetSecurityContextMatch(matchers ...interface{}) *MetaExtended_GetSecurityContext
func (*MetaExtended) OnGetServiceAccountName ¶
func (_m *MetaExtended) OnGetServiceAccountName() *MetaExtended_GetServiceAccountName
func (*MetaExtended) OnGetServiceAccountNameMatch ¶
func (_m *MetaExtended) OnGetServiceAccountNameMatch(matchers ...interface{}) *MetaExtended_GetServiceAccountName
func (*MetaExtended) OnGetTask ¶
func (_m *MetaExtended) OnGetTask(id string) *MetaExtended_GetTask
func (*MetaExtended) OnGetTaskMatch ¶
func (_m *MetaExtended) OnGetTaskMatch(matchers ...interface{}) *MetaExtended_GetTask
func (*MetaExtended) OnIsInterruptible ¶
func (_m *MetaExtended) OnIsInterruptible() *MetaExtended_IsInterruptible
func (*MetaExtended) OnIsInterruptibleMatch ¶
func (_m *MetaExtended) OnIsInterruptibleMatch(matchers ...interface{}) *MetaExtended_IsInterruptible
type MetaExtended_FindSubWorkflow ¶
func (MetaExtended_FindSubWorkflow) Return ¶
func (_m MetaExtended_FindSubWorkflow) Return(_a0 v1alpha1.ExecutableSubWorkflow) *MetaExtended_FindSubWorkflow
type MetaExtended_GetAnnotations ¶
func (MetaExtended_GetAnnotations) Return ¶
func (_m MetaExtended_GetAnnotations) Return(_a0 map[string]string) *MetaExtended_GetAnnotations
type MetaExtended_GetCreationTimestamp ¶
func (MetaExtended_GetCreationTimestamp) Return ¶
func (_m MetaExtended_GetCreationTimestamp) Return(_a0 v1.Time) *MetaExtended_GetCreationTimestamp
type MetaExtended_GetDefinitionVersion ¶
func (MetaExtended_GetDefinitionVersion) Return ¶
func (_m MetaExtended_GetDefinitionVersion) Return(_a0 v1alpha1.WorkflowDefinitionVersion) *MetaExtended_GetDefinitionVersion
type MetaExtended_GetEventVersion ¶
func (MetaExtended_GetEventVersion) Return ¶
func (_m MetaExtended_GetEventVersion) Return(_a0 v1alpha1.EventVersion) *MetaExtended_GetEventVersion
type MetaExtended_GetExecutionID ¶
func (MetaExtended_GetExecutionID) Return ¶
func (_m MetaExtended_GetExecutionID) Return(_a0 v1alpha1.WorkflowExecutionIdentifier) *MetaExtended_GetExecutionID
type MetaExtended_GetExecutionStatus ¶
func (MetaExtended_GetExecutionStatus) Return ¶
func (_m MetaExtended_GetExecutionStatus) Return(_a0 v1alpha1.ExecutableWorkflowStatus) *MetaExtended_GetExecutionStatus
type MetaExtended_GetK8sWorkflowID ¶
func (MetaExtended_GetK8sWorkflowID) Return ¶
func (_m MetaExtended_GetK8sWorkflowID) Return(_a0 types.NamespacedName) *MetaExtended_GetK8sWorkflowID
type MetaExtended_GetLabels ¶
func (MetaExtended_GetLabels) Return ¶
func (_m MetaExtended_GetLabels) Return(_a0 map[string]string) *MetaExtended_GetLabels
type MetaExtended_GetName ¶
func (MetaExtended_GetName) Return ¶
func (_m MetaExtended_GetName) Return(_a0 string) *MetaExtended_GetName
type MetaExtended_GetNamespace ¶
func (MetaExtended_GetNamespace) Return ¶
func (_m MetaExtended_GetNamespace) Return(_a0 string) *MetaExtended_GetNamespace
type MetaExtended_GetOwnerReference ¶
func (MetaExtended_GetOwnerReference) Return ¶
func (_m MetaExtended_GetOwnerReference) Return(_a0 v1.OwnerReference) *MetaExtended_GetOwnerReference
type MetaExtended_GetRawOutputDataConfig ¶
func (MetaExtended_GetRawOutputDataConfig) Return ¶
func (_m MetaExtended_GetRawOutputDataConfig) Return(_a0 v1alpha1.RawOutputDataConfig) *MetaExtended_GetRawOutputDataConfig
type MetaExtended_GetSecurityContext ¶
func (MetaExtended_GetSecurityContext) Return ¶
func (_m MetaExtended_GetSecurityContext) Return(_a0 core.SecurityContext) *MetaExtended_GetSecurityContext
type MetaExtended_GetServiceAccountName ¶
func (MetaExtended_GetServiceAccountName) Return ¶
func (_m MetaExtended_GetServiceAccountName) Return(_a0 string) *MetaExtended_GetServiceAccountName
type MetaExtended_GetTask ¶
func (MetaExtended_GetTask) Return ¶
func (_m MetaExtended_GetTask) Return(_a0 v1alpha1.ExecutableTask, _a1 error) *MetaExtended_GetTask
type MetaExtended_IsInterruptible ¶
func (MetaExtended_IsInterruptible) Return ¶
func (_m MetaExtended_IsInterruptible) Return(_a0 bool) *MetaExtended_IsInterruptible
type Meta_GetAnnotations ¶
func (Meta_GetAnnotations) Return ¶
func (_m Meta_GetAnnotations) Return(_a0 map[string]string) *Meta_GetAnnotations
type Meta_GetCreationTimestamp ¶
func (Meta_GetCreationTimestamp) Return ¶
func (_m Meta_GetCreationTimestamp) Return(_a0 v1.Time) *Meta_GetCreationTimestamp
type Meta_GetDefinitionVersion ¶
func (Meta_GetDefinitionVersion) Return ¶
func (_m Meta_GetDefinitionVersion) Return(_a0 v1alpha1.WorkflowDefinitionVersion) *Meta_GetDefinitionVersion
type Meta_GetEventVersion ¶
func (Meta_GetEventVersion) Return ¶
func (_m Meta_GetEventVersion) Return(_a0 v1alpha1.EventVersion) *Meta_GetEventVersion
type Meta_GetExecutionID ¶
func (Meta_GetExecutionID) Return ¶
func (_m Meta_GetExecutionID) Return(_a0 v1alpha1.WorkflowExecutionIdentifier) *Meta_GetExecutionID
type Meta_GetK8sWorkflowID ¶
func (Meta_GetK8sWorkflowID) Return ¶
func (_m Meta_GetK8sWorkflowID) Return(_a0 types.NamespacedName) *Meta_GetK8sWorkflowID
type Meta_GetLabels ¶
func (Meta_GetLabels) Return ¶
func (_m Meta_GetLabels) Return(_a0 map[string]string) *Meta_GetLabels
type Meta_GetName ¶
func (Meta_GetName) Return ¶
func (_m Meta_GetName) Return(_a0 string) *Meta_GetName
type Meta_GetNamespace ¶
func (Meta_GetNamespace) Return ¶
func (_m Meta_GetNamespace) Return(_a0 string) *Meta_GetNamespace
type Meta_GetOwnerReference ¶
func (Meta_GetOwnerReference) Return ¶
func (_m Meta_GetOwnerReference) Return(_a0 v1.OwnerReference) *Meta_GetOwnerReference
type Meta_GetRawOutputDataConfig ¶
func (Meta_GetRawOutputDataConfig) Return ¶
func (_m Meta_GetRawOutputDataConfig) Return(_a0 v1alpha1.RawOutputDataConfig) *Meta_GetRawOutputDataConfig
type Meta_GetSecurityContext ¶
func (Meta_GetSecurityContext) Return ¶
func (_m Meta_GetSecurityContext) Return(_a0 core.SecurityContext) *Meta_GetSecurityContext
type Meta_GetServiceAccountName ¶
func (Meta_GetServiceAccountName) Return ¶
func (_m Meta_GetServiceAccountName) Return(_a0 string) *Meta_GetServiceAccountName
type Meta_IsInterruptible ¶
func (Meta_IsInterruptible) Return ¶
func (_m Meta_IsInterruptible) Return(_a0 bool) *Meta_IsInterruptible
type Mutable ¶
Mutable is an autogenerated mock type for the Mutable type
func (*Mutable) OnIsDirty ¶
func (_m *Mutable) OnIsDirty() *Mutable_IsDirty
func (*Mutable) OnIsDirtyMatch ¶
func (_m *Mutable) OnIsDirtyMatch(matchers ...interface{}) *Mutable_IsDirty
type MutableArrayNodeStatus ¶
MutableArrayNodeStatus is an autogenerated mock type for the MutableArrayNodeStatus type
func (*MutableArrayNodeStatus) GetArrayNodePhase ¶
func (_m *MutableArrayNodeStatus) GetArrayNodePhase() v1alpha1.ArrayNodePhase
GetArrayNodePhase provides a mock function with given fields:
func (*MutableArrayNodeStatus) GetExecutionError ¶
func (_m *MutableArrayNodeStatus) GetExecutionError() *core.ExecutionError
GetExecutionError provides a mock function with given fields:
func (*MutableArrayNodeStatus) GetSubNodePhases ¶
func (_m *MutableArrayNodeStatus) GetSubNodePhases() bitarray.CompactArray
GetSubNodePhases provides a mock function with given fields:
func (*MutableArrayNodeStatus) GetSubNodeRetryAttempts ¶
func (_m *MutableArrayNodeStatus) GetSubNodeRetryAttempts() bitarray.CompactArray
GetSubNodeRetryAttempts provides a mock function with given fields:
func (*MutableArrayNodeStatus) GetSubNodeSystemFailures ¶
func (_m *MutableArrayNodeStatus) GetSubNodeSystemFailures() bitarray.CompactArray
GetSubNodeSystemFailures provides a mock function with given fields:
func (*MutableArrayNodeStatus) GetSubNodeTaskPhases ¶
func (_m *MutableArrayNodeStatus) GetSubNodeTaskPhases() bitarray.CompactArray
GetSubNodeTaskPhases provides a mock function with given fields:
func (*MutableArrayNodeStatus) GetTaskPhaseVersion ¶
func (_m *MutableArrayNodeStatus) GetTaskPhaseVersion() uint32
GetTaskPhaseVersion provides a mock function with given fields:
func (*MutableArrayNodeStatus) IsDirty ¶
func (_m *MutableArrayNodeStatus) IsDirty() bool
IsDirty provides a mock function with given fields:
func (*MutableArrayNodeStatus) OnGetArrayNodePhase ¶
func (_m *MutableArrayNodeStatus) OnGetArrayNodePhase() *MutableArrayNodeStatus_GetArrayNodePhase
func (*MutableArrayNodeStatus) OnGetArrayNodePhaseMatch ¶
func (_m *MutableArrayNodeStatus) OnGetArrayNodePhaseMatch(matchers ...interface{}) *MutableArrayNodeStatus_GetArrayNodePhase
func (*MutableArrayNodeStatus) OnGetExecutionError ¶
func (_m *MutableArrayNodeStatus) OnGetExecutionError() *MutableArrayNodeStatus_GetExecutionError
func (*MutableArrayNodeStatus) OnGetExecutionErrorMatch ¶
func (_m *MutableArrayNodeStatus) OnGetExecutionErrorMatch(matchers ...interface{}) *MutableArrayNodeStatus_GetExecutionError
func (*MutableArrayNodeStatus) OnGetSubNodePhases ¶
func (_m *MutableArrayNodeStatus) OnGetSubNodePhases() *MutableArrayNodeStatus_GetSubNodePhases
func (*MutableArrayNodeStatus) OnGetSubNodePhasesMatch ¶
func (_m *MutableArrayNodeStatus) OnGetSubNodePhasesMatch(matchers ...interface{}) *MutableArrayNodeStatus_GetSubNodePhases
func (*MutableArrayNodeStatus) OnGetSubNodeRetryAttempts ¶
func (_m *MutableArrayNodeStatus) OnGetSubNodeRetryAttempts() *MutableArrayNodeStatus_GetSubNodeRetryAttempts
func (*MutableArrayNodeStatus) OnGetSubNodeRetryAttemptsMatch ¶
func (_m *MutableArrayNodeStatus) OnGetSubNodeRetryAttemptsMatch(matchers ...interface{}) *MutableArrayNodeStatus_GetSubNodeRetryAttempts
func (*MutableArrayNodeStatus) OnGetSubNodeSystemFailures ¶
func (_m *MutableArrayNodeStatus) OnGetSubNodeSystemFailures() *MutableArrayNodeStatus_GetSubNodeSystemFailures
func (*MutableArrayNodeStatus) OnGetSubNodeSystemFailuresMatch ¶
func (_m *MutableArrayNodeStatus) OnGetSubNodeSystemFailuresMatch(matchers ...interface{}) *MutableArrayNodeStatus_GetSubNodeSystemFailures
func (*MutableArrayNodeStatus) OnGetSubNodeTaskPhases ¶
func (_m *MutableArrayNodeStatus) OnGetSubNodeTaskPhases() *MutableArrayNodeStatus_GetSubNodeTaskPhases
func (*MutableArrayNodeStatus) OnGetSubNodeTaskPhasesMatch ¶
func (_m *MutableArrayNodeStatus) OnGetSubNodeTaskPhasesMatch(matchers ...interface{}) *MutableArrayNodeStatus_GetSubNodeTaskPhases
func (*MutableArrayNodeStatus) OnGetTaskPhaseVersion ¶
func (_m *MutableArrayNodeStatus) OnGetTaskPhaseVersion() *MutableArrayNodeStatus_GetTaskPhaseVersion
func (*MutableArrayNodeStatus) OnGetTaskPhaseVersionMatch ¶
func (_m *MutableArrayNodeStatus) OnGetTaskPhaseVersionMatch(matchers ...interface{}) *MutableArrayNodeStatus_GetTaskPhaseVersion
func (*MutableArrayNodeStatus) OnIsDirty ¶
func (_m *MutableArrayNodeStatus) OnIsDirty() *MutableArrayNodeStatus_IsDirty
func (*MutableArrayNodeStatus) OnIsDirtyMatch ¶
func (_m *MutableArrayNodeStatus) OnIsDirtyMatch(matchers ...interface{}) *MutableArrayNodeStatus_IsDirty
func (*MutableArrayNodeStatus) SetArrayNodePhase ¶
func (_m *MutableArrayNodeStatus) SetArrayNodePhase(phase v1alpha1.ArrayNodePhase)
SetArrayNodePhase provides a mock function with given fields: phase
func (*MutableArrayNodeStatus) SetExecutionError ¶
func (_m *MutableArrayNodeStatus) SetExecutionError(executionError *core.ExecutionError)
SetExecutionError provides a mock function with given fields: executionError
func (*MutableArrayNodeStatus) SetSubNodePhases ¶
func (_m *MutableArrayNodeStatus) SetSubNodePhases(subNodePhases bitarray.CompactArray)
SetSubNodePhases provides a mock function with given fields: subNodePhases
func (*MutableArrayNodeStatus) SetSubNodeRetryAttempts ¶
func (_m *MutableArrayNodeStatus) SetSubNodeRetryAttempts(subNodeRetryAttempts bitarray.CompactArray)
SetSubNodeRetryAttempts provides a mock function with given fields: subNodeRetryAttempts
func (*MutableArrayNodeStatus) SetSubNodeSystemFailures ¶
func (_m *MutableArrayNodeStatus) SetSubNodeSystemFailures(subNodeSystemFailures bitarray.CompactArray)
SetSubNodeSystemFailures provides a mock function with given fields: subNodeSystemFailures
func (*MutableArrayNodeStatus) SetSubNodeTaskPhases ¶
func (_m *MutableArrayNodeStatus) SetSubNodeTaskPhases(subNodeTaskPhases bitarray.CompactArray)
SetSubNodeTaskPhases provides a mock function with given fields: subNodeTaskPhases
func (*MutableArrayNodeStatus) SetTaskPhaseVersion ¶
func (_m *MutableArrayNodeStatus) SetTaskPhaseVersion(taskPhaseVersion uint32)
SetTaskPhaseVersion provides a mock function with given fields: taskPhaseVersion
type MutableArrayNodeStatus_GetArrayNodePhase ¶
func (MutableArrayNodeStatus_GetArrayNodePhase) Return ¶
func (_m MutableArrayNodeStatus_GetArrayNodePhase) Return(_a0 v1alpha1.ArrayNodePhase) *MutableArrayNodeStatus_GetArrayNodePhase
type MutableArrayNodeStatus_GetExecutionError ¶
func (MutableArrayNodeStatus_GetExecutionError) Return ¶
func (_m MutableArrayNodeStatus_GetExecutionError) Return(_a0 *core.ExecutionError) *MutableArrayNodeStatus_GetExecutionError
type MutableArrayNodeStatus_GetSubNodePhases ¶
func (MutableArrayNodeStatus_GetSubNodePhases) Return ¶
func (_m MutableArrayNodeStatus_GetSubNodePhases) Return(_a0 bitarray.CompactArray) *MutableArrayNodeStatus_GetSubNodePhases
type MutableArrayNodeStatus_GetSubNodeRetryAttempts ¶
type MutableArrayNodeStatus_GetSubNodeSystemFailures ¶
type MutableArrayNodeStatus_GetSubNodeTaskPhases ¶
type MutableArrayNodeStatus_GetTaskPhaseVersion ¶
func (MutableArrayNodeStatus_GetTaskPhaseVersion) Return ¶
func (_m MutableArrayNodeStatus_GetTaskPhaseVersion) Return(_a0 uint32) *MutableArrayNodeStatus_GetTaskPhaseVersion
type MutableArrayNodeStatus_IsDirty ¶
func (MutableArrayNodeStatus_IsDirty) Return ¶
func (_m MutableArrayNodeStatus_IsDirty) Return(_a0 bool) *MutableArrayNodeStatus_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 ¶
func (_m *MutableBranchNodeStatus) IsDirty() bool
IsDirty provides a mock function with given fields:
func (*MutableBranchNodeStatus) OnGetFinalizedNode ¶
func (_m *MutableBranchNodeStatus) OnGetFinalizedNode() *MutableBranchNodeStatus_GetFinalizedNode
func (*MutableBranchNodeStatus) OnGetFinalizedNodeMatch ¶
func (_m *MutableBranchNodeStatus) OnGetFinalizedNodeMatch(matchers ...interface{}) *MutableBranchNodeStatus_GetFinalizedNode
func (*MutableBranchNodeStatus) OnGetPhase ¶
func (_m *MutableBranchNodeStatus) OnGetPhase() *MutableBranchNodeStatus_GetPhase
func (*MutableBranchNodeStatus) OnGetPhaseMatch ¶
func (_m *MutableBranchNodeStatus) OnGetPhaseMatch(matchers ...interface{}) *MutableBranchNodeStatus_GetPhase
func (*MutableBranchNodeStatus) OnIsDirty ¶
func (_m *MutableBranchNodeStatus) OnIsDirty() *MutableBranchNodeStatus_IsDirty
func (*MutableBranchNodeStatus) OnIsDirtyMatch ¶
func (_m *MutableBranchNodeStatus) OnIsDirtyMatch(matchers ...interface{}) *MutableBranchNodeStatus_IsDirty
func (*MutableBranchNodeStatus) SetBranchNodeError ¶
func (_m *MutableBranchNodeStatus) SetBranchNodeError()
SetBranchNodeError provides a mock function with given fields:
func (*MutableBranchNodeStatus) SetBranchNodeSuccess ¶
func (_m *MutableBranchNodeStatus) SetBranchNodeSuccess(id string)
SetBranchNodeSuccess provides a mock function with given fields: id
type MutableBranchNodeStatus_GetFinalizedNode ¶
func (MutableBranchNodeStatus_GetFinalizedNode) Return ¶
func (_m MutableBranchNodeStatus_GetFinalizedNode) Return(_a0 *string) *MutableBranchNodeStatus_GetFinalizedNode
type MutableBranchNodeStatus_GetPhase ¶
func (MutableBranchNodeStatus_GetPhase) Return ¶
func (_m MutableBranchNodeStatus_GetPhase) Return(_a0 v1alpha1.BranchNodePhase) *MutableBranchNodeStatus_GetPhase
type MutableBranchNodeStatus_IsDirty ¶
func (MutableBranchNodeStatus_IsDirty) Return ¶
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 ¶
func (_m *MutableDynamicNodeStatus) GetDynamicNodeReason() string
GetDynamicNodeReason provides a mock function with given fields:
func (*MutableDynamicNodeStatus) GetExecutionError ¶
func (_m *MutableDynamicNodeStatus) GetExecutionError() *core.ExecutionError
GetExecutionError provides a mock function with given fields:
func (*MutableDynamicNodeStatus) GetIsFailurePermanent ¶
func (_m *MutableDynamicNodeStatus) GetIsFailurePermanent() bool
GetIsFailurePermanent provides a mock function with given fields:
func (*MutableDynamicNodeStatus) IsDirty ¶
func (_m *MutableDynamicNodeStatus) IsDirty() bool
IsDirty provides a mock function with given fields:
func (*MutableDynamicNodeStatus) OnGetDynamicNodePhase ¶
func (_m *MutableDynamicNodeStatus) OnGetDynamicNodePhase() *MutableDynamicNodeStatus_GetDynamicNodePhase
func (*MutableDynamicNodeStatus) OnGetDynamicNodePhaseMatch ¶
func (_m *MutableDynamicNodeStatus) OnGetDynamicNodePhaseMatch(matchers ...interface{}) *MutableDynamicNodeStatus_GetDynamicNodePhase
func (*MutableDynamicNodeStatus) OnGetDynamicNodeReason ¶
func (_m *MutableDynamicNodeStatus) OnGetDynamicNodeReason() *MutableDynamicNodeStatus_GetDynamicNodeReason
func (*MutableDynamicNodeStatus) OnGetDynamicNodeReasonMatch ¶
func (_m *MutableDynamicNodeStatus) OnGetDynamicNodeReasonMatch(matchers ...interface{}) *MutableDynamicNodeStatus_GetDynamicNodeReason
func (*MutableDynamicNodeStatus) OnGetExecutionError ¶
func (_m *MutableDynamicNodeStatus) OnGetExecutionError() *MutableDynamicNodeStatus_GetExecutionError
func (*MutableDynamicNodeStatus) OnGetExecutionErrorMatch ¶
func (_m *MutableDynamicNodeStatus) OnGetExecutionErrorMatch(matchers ...interface{}) *MutableDynamicNodeStatus_GetExecutionError
func (*MutableDynamicNodeStatus) OnGetIsFailurePermanent ¶
func (_m *MutableDynamicNodeStatus) OnGetIsFailurePermanent() *MutableDynamicNodeStatus_GetIsFailurePermanent
func (*MutableDynamicNodeStatus) OnGetIsFailurePermanentMatch ¶
func (_m *MutableDynamicNodeStatus) OnGetIsFailurePermanentMatch(matchers ...interface{}) *MutableDynamicNodeStatus_GetIsFailurePermanent
func (*MutableDynamicNodeStatus) OnIsDirty ¶
func (_m *MutableDynamicNodeStatus) OnIsDirty() *MutableDynamicNodeStatus_IsDirty
func (*MutableDynamicNodeStatus) OnIsDirtyMatch ¶
func (_m *MutableDynamicNodeStatus) OnIsDirtyMatch(matchers ...interface{}) *MutableDynamicNodeStatus_IsDirty
func (*MutableDynamicNodeStatus) SetDynamicNodePhase ¶
func (_m *MutableDynamicNodeStatus) SetDynamicNodePhase(phase v1alpha1.DynamicNodePhase)
SetDynamicNodePhase provides a mock function with given fields: phase
func (*MutableDynamicNodeStatus) SetDynamicNodeReason ¶
func (_m *MutableDynamicNodeStatus) SetDynamicNodeReason(reason string)
SetDynamicNodeReason provides a mock function with given fields: reason
func (*MutableDynamicNodeStatus) SetExecutionError ¶
func (_m *MutableDynamicNodeStatus) SetExecutionError(executionError *core.ExecutionError)
SetExecutionError provides a mock function with given fields: executionError
func (*MutableDynamicNodeStatus) SetIsFailurePermanent ¶
func (_m *MutableDynamicNodeStatus) SetIsFailurePermanent(isFailurePermanent bool)
SetIsFailurePermanent provides a mock function with given fields: isFailurePermanent
type MutableDynamicNodeStatus_GetDynamicNodePhase ¶
type MutableDynamicNodeStatus_GetDynamicNodeReason ¶
func (MutableDynamicNodeStatus_GetDynamicNodeReason) Return ¶
func (_m MutableDynamicNodeStatus_GetDynamicNodeReason) Return(_a0 string) *MutableDynamicNodeStatus_GetDynamicNodeReason
type MutableDynamicNodeStatus_GetExecutionError ¶
func (MutableDynamicNodeStatus_GetExecutionError) Return ¶
func (_m MutableDynamicNodeStatus_GetExecutionError) Return(_a0 *core.ExecutionError) *MutableDynamicNodeStatus_GetExecutionError
type MutableDynamicNodeStatus_GetIsFailurePermanent ¶
func (MutableDynamicNodeStatus_GetIsFailurePermanent) Return ¶
func (_m MutableDynamicNodeStatus_GetIsFailurePermanent) Return(_a0 bool) *MutableDynamicNodeStatus_GetIsFailurePermanent
type MutableDynamicNodeStatus_IsDirty ¶
func (MutableDynamicNodeStatus_IsDirty) Return ¶
func (_m MutableDynamicNodeStatus_IsDirty) Return(_a0 bool) *MutableDynamicNodeStatus_IsDirty
type MutableGateNodeStatus ¶
MutableGateNodeStatus is an autogenerated mock type for the MutableGateNodeStatus type
func (*MutableGateNodeStatus) GetGateNodePhase ¶
func (_m *MutableGateNodeStatus) GetGateNodePhase() v1alpha1.GateNodePhase
GetGateNodePhase provides a mock function with given fields:
func (*MutableGateNodeStatus) IsDirty ¶
func (_m *MutableGateNodeStatus) IsDirty() bool
IsDirty provides a mock function with given fields:
func (*MutableGateNodeStatus) OnGetGateNodePhase ¶
func (_m *MutableGateNodeStatus) OnGetGateNodePhase() *MutableGateNodeStatus_GetGateNodePhase
func (*MutableGateNodeStatus) OnGetGateNodePhaseMatch ¶
func (_m *MutableGateNodeStatus) OnGetGateNodePhaseMatch(matchers ...interface{}) *MutableGateNodeStatus_GetGateNodePhase
func (*MutableGateNodeStatus) OnIsDirty ¶
func (_m *MutableGateNodeStatus) OnIsDirty() *MutableGateNodeStatus_IsDirty
func (*MutableGateNodeStatus) OnIsDirtyMatch ¶
func (_m *MutableGateNodeStatus) OnIsDirtyMatch(matchers ...interface{}) *MutableGateNodeStatus_IsDirty
func (*MutableGateNodeStatus) SetGateNodePhase ¶
func (_m *MutableGateNodeStatus) SetGateNodePhase(phase v1alpha1.GateNodePhase)
SetGateNodePhase provides a mock function with given fields: phase
type MutableGateNodeStatus_GetGateNodePhase ¶
func (MutableGateNodeStatus_GetGateNodePhase) Return ¶
func (_m MutableGateNodeStatus_GetGateNodePhase) Return(_a0 v1alpha1.GateNodePhase) *MutableGateNodeStatus_GetGateNodePhase
type MutableGateNodeStatus_IsDirty ¶
func (MutableGateNodeStatus_IsDirty) Return ¶
func (_m MutableGateNodeStatus_IsDirty) Return(_a0 bool) *MutableGateNodeStatus_IsDirty
type MutableNodeStatus ¶
MutableNodeStatus is an autogenerated mock type for the MutableNodeStatus type
func (*MutableNodeStatus) ClearArrayNodeStatus ¶
func (_m *MutableNodeStatus) ClearArrayNodeStatus()
ClearArrayNodeStatus provides a mock function with given fields:
func (*MutableNodeStatus) ClearDynamicNodeStatus ¶
func (_m *MutableNodeStatus) ClearDynamicNodeStatus()
ClearDynamicNodeStatus provides a mock function with given fields:
func (*MutableNodeStatus) ClearGateNodeStatus ¶
func (_m *MutableNodeStatus) ClearGateNodeStatus()
ClearGateNodeStatus provides a mock function with given fields:
func (*MutableNodeStatus) ClearLastAttemptStartedAt ¶
func (_m *MutableNodeStatus) ClearLastAttemptStartedAt()
ClearLastAttemptStartedAt provides a mock function with given fields:
func (*MutableNodeStatus) ClearSubNodeStatus ¶
func (_m *MutableNodeStatus) ClearSubNodeStatus()
ClearSubNodeStatus provides a mock function with given fields:
func (*MutableNodeStatus) ClearTaskStatus ¶
func (_m *MutableNodeStatus) ClearTaskStatus()
ClearTaskStatus provides a mock function with given fields:
func (*MutableNodeStatus) ClearWorkflowStatus ¶
func (_m *MutableNodeStatus) ClearWorkflowStatus()
ClearWorkflowStatus provides a mock function with given fields:
func (*MutableNodeStatus) GetArrayNodeStatus ¶
func (_m *MutableNodeStatus) GetArrayNodeStatus() v1alpha1.MutableArrayNodeStatus
GetArrayNodeStatus provides a mock function with given fields:
func (*MutableNodeStatus) GetBranchStatus ¶
func (_m *MutableNodeStatus) GetBranchStatus() v1alpha1.MutableBranchNodeStatus
GetBranchStatus provides a mock function with given fields:
func (*MutableNodeStatus) GetDynamicNodeStatus ¶
func (_m *MutableNodeStatus) GetDynamicNodeStatus() v1alpha1.MutableDynamicNodeStatus
GetDynamicNodeStatus provides a mock function with given fields:
func (*MutableNodeStatus) GetGateNodeStatus ¶
func (_m *MutableNodeStatus) GetGateNodeStatus() v1alpha1.MutableGateNodeStatus
GetGateNodeStatus provides a mock function with given fields:
func (*MutableNodeStatus) GetOrCreateArrayNodeStatus ¶
func (_m *MutableNodeStatus) GetOrCreateArrayNodeStatus() v1alpha1.MutableArrayNodeStatus
GetOrCreateArrayNodeStatus 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) GetOrCreateGateNodeStatus ¶
func (_m *MutableNodeStatus) GetOrCreateGateNodeStatus() v1alpha1.MutableGateNodeStatus
GetOrCreateGateNodeStatus provides a mock function with given fields:
func (*MutableNodeStatus) GetOrCreateTaskStatus ¶
func (_m *MutableNodeStatus) GetOrCreateTaskStatus() v1alpha1.MutableTaskNodeStatus
GetOrCreateTaskStatus provides a mock function with given fields:
func (*MutableNodeStatus) GetOrCreateWorkflowStatus ¶
func (_m *MutableNodeStatus) GetOrCreateWorkflowStatus() v1alpha1.MutableWorkflowNodeStatus
GetOrCreateWorkflowStatus provides a mock function with given fields:
func (*MutableNodeStatus) GetTaskStatus ¶
func (_m *MutableNodeStatus) GetTaskStatus() v1alpha1.MutableTaskNodeStatus
GetTaskStatus provides a mock function with given fields:
func (*MutableNodeStatus) GetWorkflowStatus ¶
func (_m *MutableNodeStatus) GetWorkflowStatus() v1alpha1.MutableWorkflowNodeStatus
GetWorkflowStatus provides a mock function with given fields:
func (*MutableNodeStatus) IncrementAttempts ¶
func (_m *MutableNodeStatus) IncrementAttempts() uint32
IncrementAttempts provides a mock function with given fields:
func (*MutableNodeStatus) IncrementSystemFailures ¶
func (_m *MutableNodeStatus) IncrementSystemFailures() uint32
IncrementSystemFailures provides a mock function with given fields:
func (*MutableNodeStatus) IsDirty ¶
func (_m *MutableNodeStatus) IsDirty() bool
IsDirty provides a mock function with given fields:
func (*MutableNodeStatus) OnGetArrayNodeStatus ¶
func (_m *MutableNodeStatus) OnGetArrayNodeStatus() *MutableNodeStatus_GetArrayNodeStatus
func (*MutableNodeStatus) OnGetArrayNodeStatusMatch ¶
func (_m *MutableNodeStatus) OnGetArrayNodeStatusMatch(matchers ...interface{}) *MutableNodeStatus_GetArrayNodeStatus
func (*MutableNodeStatus) OnGetBranchStatus ¶
func (_m *MutableNodeStatus) OnGetBranchStatus() *MutableNodeStatus_GetBranchStatus
func (*MutableNodeStatus) OnGetBranchStatusMatch ¶
func (_m *MutableNodeStatus) OnGetBranchStatusMatch(matchers ...interface{}) *MutableNodeStatus_GetBranchStatus
func (*MutableNodeStatus) OnGetDynamicNodeStatus ¶
func (_m *MutableNodeStatus) OnGetDynamicNodeStatus() *MutableNodeStatus_GetDynamicNodeStatus
func (*MutableNodeStatus) OnGetDynamicNodeStatusMatch ¶
func (_m *MutableNodeStatus) OnGetDynamicNodeStatusMatch(matchers ...interface{}) *MutableNodeStatus_GetDynamicNodeStatus
func (*MutableNodeStatus) OnGetGateNodeStatus ¶
func (_m *MutableNodeStatus) OnGetGateNodeStatus() *MutableNodeStatus_GetGateNodeStatus
func (*MutableNodeStatus) OnGetGateNodeStatusMatch ¶
func (_m *MutableNodeStatus) OnGetGateNodeStatusMatch(matchers ...interface{}) *MutableNodeStatus_GetGateNodeStatus
func (*MutableNodeStatus) OnGetOrCreateArrayNodeStatus ¶
func (_m *MutableNodeStatus) OnGetOrCreateArrayNodeStatus() *MutableNodeStatus_GetOrCreateArrayNodeStatus
func (*MutableNodeStatus) OnGetOrCreateArrayNodeStatusMatch ¶
func (_m *MutableNodeStatus) OnGetOrCreateArrayNodeStatusMatch(matchers ...interface{}) *MutableNodeStatus_GetOrCreateArrayNodeStatus
func (*MutableNodeStatus) OnGetOrCreateBranchStatus ¶
func (_m *MutableNodeStatus) OnGetOrCreateBranchStatus() *MutableNodeStatus_GetOrCreateBranchStatus
func (*MutableNodeStatus) OnGetOrCreateBranchStatusMatch ¶
func (_m *MutableNodeStatus) OnGetOrCreateBranchStatusMatch(matchers ...interface{}) *MutableNodeStatus_GetOrCreateBranchStatus
func (*MutableNodeStatus) OnGetOrCreateDynamicNodeStatus ¶
func (_m *MutableNodeStatus) OnGetOrCreateDynamicNodeStatus() *MutableNodeStatus_GetOrCreateDynamicNodeStatus
func (*MutableNodeStatus) OnGetOrCreateDynamicNodeStatusMatch ¶
func (_m *MutableNodeStatus) OnGetOrCreateDynamicNodeStatusMatch(matchers ...interface{}) *MutableNodeStatus_GetOrCreateDynamicNodeStatus
func (*MutableNodeStatus) OnGetOrCreateGateNodeStatus ¶
func (_m *MutableNodeStatus) OnGetOrCreateGateNodeStatus() *MutableNodeStatus_GetOrCreateGateNodeStatus
func (*MutableNodeStatus) OnGetOrCreateGateNodeStatusMatch ¶
func (_m *MutableNodeStatus) OnGetOrCreateGateNodeStatusMatch(matchers ...interface{}) *MutableNodeStatus_GetOrCreateGateNodeStatus
func (*MutableNodeStatus) OnGetOrCreateTaskStatus ¶
func (_m *MutableNodeStatus) OnGetOrCreateTaskStatus() *MutableNodeStatus_GetOrCreateTaskStatus
func (*MutableNodeStatus) OnGetOrCreateTaskStatusMatch ¶
func (_m *MutableNodeStatus) OnGetOrCreateTaskStatusMatch(matchers ...interface{}) *MutableNodeStatus_GetOrCreateTaskStatus
func (*MutableNodeStatus) OnGetOrCreateWorkflowStatus ¶
func (_m *MutableNodeStatus) OnGetOrCreateWorkflowStatus() *MutableNodeStatus_GetOrCreateWorkflowStatus
func (*MutableNodeStatus) OnGetOrCreateWorkflowStatusMatch ¶
func (_m *MutableNodeStatus) OnGetOrCreateWorkflowStatusMatch(matchers ...interface{}) *MutableNodeStatus_GetOrCreateWorkflowStatus
func (*MutableNodeStatus) OnGetTaskStatus ¶
func (_m *MutableNodeStatus) OnGetTaskStatus() *MutableNodeStatus_GetTaskStatus
func (*MutableNodeStatus) OnGetTaskStatusMatch ¶
func (_m *MutableNodeStatus) OnGetTaskStatusMatch(matchers ...interface{}) *MutableNodeStatus_GetTaskStatus
func (*MutableNodeStatus) OnGetWorkflowStatus ¶
func (_m *MutableNodeStatus) OnGetWorkflowStatus() *MutableNodeStatus_GetWorkflowStatus
func (*MutableNodeStatus) OnGetWorkflowStatusMatch ¶
func (_m *MutableNodeStatus) OnGetWorkflowStatusMatch(matchers ...interface{}) *MutableNodeStatus_GetWorkflowStatus
func (*MutableNodeStatus) OnIncrementAttempts ¶
func (_m *MutableNodeStatus) OnIncrementAttempts() *MutableNodeStatus_IncrementAttempts
func (*MutableNodeStatus) OnIncrementAttemptsMatch ¶
func (_m *MutableNodeStatus) OnIncrementAttemptsMatch(matchers ...interface{}) *MutableNodeStatus_IncrementAttempts
func (*MutableNodeStatus) OnIncrementSystemFailures ¶
func (_m *MutableNodeStatus) OnIncrementSystemFailures() *MutableNodeStatus_IncrementSystemFailures
func (*MutableNodeStatus) OnIncrementSystemFailuresMatch ¶
func (_m *MutableNodeStatus) OnIncrementSystemFailuresMatch(matchers ...interface{}) *MutableNodeStatus_IncrementSystemFailures
func (*MutableNodeStatus) OnIsDirty ¶
func (_m *MutableNodeStatus) OnIsDirty() *MutableNodeStatus_IsDirty
func (*MutableNodeStatus) OnIsDirtyMatch ¶
func (_m *MutableNodeStatus) OnIsDirtyMatch(matchers ...interface{}) *MutableNodeStatus_IsDirty
func (*MutableNodeStatus) ResetDirty ¶
func (_m *MutableNodeStatus) ResetDirty()
ResetDirty provides a mock function with given fields:
func (*MutableNodeStatus) SetCached ¶
func (_m *MutableNodeStatus) SetCached()
SetCached provides a mock function with given fields:
func (*MutableNodeStatus) SetDataDir ¶
func (_m *MutableNodeStatus) SetDataDir(_a0 storage.DataReference)
SetDataDir provides a mock function with given fields: _a0
func (*MutableNodeStatus) SetOutputDir ¶
func (_m *MutableNodeStatus) SetOutputDir(d storage.DataReference)
SetOutputDir provides a mock function with given fields: d
func (*MutableNodeStatus) SetParentNodeID ¶
func (_m *MutableNodeStatus) SetParentNodeID(n *string)
SetParentNodeID provides a mock function with given fields: n
func (*MutableNodeStatus) SetParentTaskID ¶
func (_m *MutableNodeStatus) SetParentTaskID(t *core.TaskExecutionIdentifier)
SetParentTaskID provides a mock function with given fields: t
func (*MutableNodeStatus) UpdatePhase ¶
func (_m *MutableNodeStatus) UpdatePhase(phase v1alpha1.NodePhase, occurredAt v1.Time, reason string, enableCRDebugMetadata bool, err *core.ExecutionError)
UpdatePhase provides a mock function with given fields: phase, occurredAt, reason, enableCRDebugMetadata, err
type MutableNodeStatus_GetArrayNodeStatus ¶
func (MutableNodeStatus_GetArrayNodeStatus) Return ¶
func (_m MutableNodeStatus_GetArrayNodeStatus) Return(_a0 v1alpha1.MutableArrayNodeStatus) *MutableNodeStatus_GetArrayNodeStatus
type MutableNodeStatus_GetBranchStatus ¶
func (MutableNodeStatus_GetBranchStatus) Return ¶
func (_m MutableNodeStatus_GetBranchStatus) Return(_a0 v1alpha1.MutableBranchNodeStatus) *MutableNodeStatus_GetBranchStatus
type MutableNodeStatus_GetDynamicNodeStatus ¶
type MutableNodeStatus_GetGateNodeStatus ¶
func (MutableNodeStatus_GetGateNodeStatus) Return ¶
func (_m MutableNodeStatus_GetGateNodeStatus) Return(_a0 v1alpha1.MutableGateNodeStatus) *MutableNodeStatus_GetGateNodeStatus
type MutableNodeStatus_GetOrCreateArrayNodeStatus ¶
type MutableNodeStatus_GetOrCreateBranchStatus ¶
type MutableNodeStatus_GetOrCreateDynamicNodeStatus ¶
type MutableNodeStatus_GetOrCreateGateNodeStatus ¶
type MutableNodeStatus_GetOrCreateTaskStatus ¶
type MutableNodeStatus_GetOrCreateWorkflowStatus ¶
type MutableNodeStatus_GetTaskStatus ¶
func (MutableNodeStatus_GetTaskStatus) Return ¶
func (_m MutableNodeStatus_GetTaskStatus) Return(_a0 v1alpha1.MutableTaskNodeStatus) *MutableNodeStatus_GetTaskStatus
type MutableNodeStatus_GetWorkflowStatus ¶
func (MutableNodeStatus_GetWorkflowStatus) Return ¶
func (_m MutableNodeStatus_GetWorkflowStatus) Return(_a0 v1alpha1.MutableWorkflowNodeStatus) *MutableNodeStatus_GetWorkflowStatus
type MutableNodeStatus_IncrementAttempts ¶
func (MutableNodeStatus_IncrementAttempts) Return ¶
func (_m MutableNodeStatus_IncrementAttempts) Return(_a0 uint32) *MutableNodeStatus_IncrementAttempts
type MutableNodeStatus_IncrementSystemFailures ¶
func (MutableNodeStatus_IncrementSystemFailures) Return ¶
func (_m MutableNodeStatus_IncrementSystemFailures) Return(_a0 uint32) *MutableNodeStatus_IncrementSystemFailures
type MutableNodeStatus_IsDirty ¶
func (MutableNodeStatus_IsDirty) Return ¶
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 ¶
func (_m *MutableSubWorkflowNodeStatus) IsDirty() bool
IsDirty provides a mock function with given fields:
func (*MutableSubWorkflowNodeStatus) OnGetPhase ¶
func (_m *MutableSubWorkflowNodeStatus) OnGetPhase() *MutableSubWorkflowNodeStatus_GetPhase
func (*MutableSubWorkflowNodeStatus) OnGetPhaseMatch ¶
func (_m *MutableSubWorkflowNodeStatus) OnGetPhaseMatch(matchers ...interface{}) *MutableSubWorkflowNodeStatus_GetPhase
func (*MutableSubWorkflowNodeStatus) OnIsDirty ¶
func (_m *MutableSubWorkflowNodeStatus) OnIsDirty() *MutableSubWorkflowNodeStatus_IsDirty
func (*MutableSubWorkflowNodeStatus) OnIsDirtyMatch ¶
func (_m *MutableSubWorkflowNodeStatus) OnIsDirtyMatch(matchers ...interface{}) *MutableSubWorkflowNodeStatus_IsDirty
func (*MutableSubWorkflowNodeStatus) SetPhase ¶
func (_m *MutableSubWorkflowNodeStatus) SetPhase(phase v1alpha1.WorkflowPhase)
SetPhase provides a mock function with given fields: phase
type MutableSubWorkflowNodeStatus_GetPhase ¶
func (MutableSubWorkflowNodeStatus_GetPhase) Return ¶
func (_m MutableSubWorkflowNodeStatus_GetPhase) Return(_a0 v1alpha1.WorkflowPhase) *MutableSubWorkflowNodeStatus_GetPhase
type MutableSubWorkflowNodeStatus_IsDirty ¶
func (MutableSubWorkflowNodeStatus_IsDirty) Return ¶
func (_m MutableSubWorkflowNodeStatus_IsDirty) Return(_a0 bool) *MutableSubWorkflowNodeStatus_IsDirty
type MutableTaskNodeStatus ¶
MutableTaskNodeStatus is an autogenerated mock type for the MutableTaskNodeStatus type
func (*MutableTaskNodeStatus) GetBarrierClockTick ¶
func (_m *MutableTaskNodeStatus) GetBarrierClockTick() uint32
GetBarrierClockTick provides a mock function with given fields:
func (*MutableTaskNodeStatus) GetCleanupOnFailure ¶
func (_m *MutableTaskNodeStatus) GetCleanupOnFailure() bool
GetCleanupOnFailure provides a mock function with given fields:
func (*MutableTaskNodeStatus) GetLastPhaseUpdatedAt ¶
func (_m *MutableTaskNodeStatus) GetLastPhaseUpdatedAt() time.Time
GetLastPhaseUpdatedAt provides a mock function with given fields:
func (*MutableTaskNodeStatus) GetPhase ¶
func (_m *MutableTaskNodeStatus) GetPhase() int
GetPhase provides a mock function with given fields:
func (*MutableTaskNodeStatus) GetPhaseVersion ¶
func (_m *MutableTaskNodeStatus) GetPhaseVersion() uint32
GetPhaseVersion provides a mock function with given fields:
func (*MutableTaskNodeStatus) GetPluginState ¶
func (_m *MutableTaskNodeStatus) GetPluginState() []byte
GetPluginState provides a mock function with given fields:
func (*MutableTaskNodeStatus) GetPluginStateVersion ¶
func (_m *MutableTaskNodeStatus) GetPluginStateVersion() uint32
GetPluginStateVersion provides a mock function with given fields:
func (*MutableTaskNodeStatus) GetPreviousNodeExecutionCheckpointPath ¶
func (_m *MutableTaskNodeStatus) GetPreviousNodeExecutionCheckpointPath() storage.DataReference
GetPreviousNodeExecutionCheckpointPath provides a mock function with given fields:
func (*MutableTaskNodeStatus) IsDirty ¶
func (_m *MutableTaskNodeStatus) IsDirty() bool
IsDirty provides a mock function with given fields:
func (*MutableTaskNodeStatus) OnGetBarrierClockTick ¶
func (_m *MutableTaskNodeStatus) OnGetBarrierClockTick() *MutableTaskNodeStatus_GetBarrierClockTick
func (*MutableTaskNodeStatus) OnGetBarrierClockTickMatch ¶
func (_m *MutableTaskNodeStatus) OnGetBarrierClockTickMatch(matchers ...interface{}) *MutableTaskNodeStatus_GetBarrierClockTick
func (*MutableTaskNodeStatus) OnGetCleanupOnFailure ¶
func (_m *MutableTaskNodeStatus) OnGetCleanupOnFailure() *MutableTaskNodeStatus_GetCleanupOnFailure
func (*MutableTaskNodeStatus) OnGetCleanupOnFailureMatch ¶
func (_m *MutableTaskNodeStatus) OnGetCleanupOnFailureMatch(matchers ...interface{}) *MutableTaskNodeStatus_GetCleanupOnFailure
func (*MutableTaskNodeStatus) OnGetLastPhaseUpdatedAt ¶
func (_m *MutableTaskNodeStatus) OnGetLastPhaseUpdatedAt() *MutableTaskNodeStatus_GetLastPhaseUpdatedAt
func (*MutableTaskNodeStatus) OnGetLastPhaseUpdatedAtMatch ¶
func (_m *MutableTaskNodeStatus) OnGetLastPhaseUpdatedAtMatch(matchers ...interface{}) *MutableTaskNodeStatus_GetLastPhaseUpdatedAt
func (*MutableTaskNodeStatus) OnGetPhase ¶
func (_m *MutableTaskNodeStatus) OnGetPhase() *MutableTaskNodeStatus_GetPhase
func (*MutableTaskNodeStatus) OnGetPhaseMatch ¶
func (_m *MutableTaskNodeStatus) OnGetPhaseMatch(matchers ...interface{}) *MutableTaskNodeStatus_GetPhase
func (*MutableTaskNodeStatus) OnGetPhaseVersion ¶
func (_m *MutableTaskNodeStatus) OnGetPhaseVersion() *MutableTaskNodeStatus_GetPhaseVersion
func (*MutableTaskNodeStatus) OnGetPhaseVersionMatch ¶
func (_m *MutableTaskNodeStatus) OnGetPhaseVersionMatch(matchers ...interface{}) *MutableTaskNodeStatus_GetPhaseVersion
func (*MutableTaskNodeStatus) OnGetPluginState ¶
func (_m *MutableTaskNodeStatus) OnGetPluginState() *MutableTaskNodeStatus_GetPluginState
func (*MutableTaskNodeStatus) OnGetPluginStateMatch ¶
func (_m *MutableTaskNodeStatus) OnGetPluginStateMatch(matchers ...interface{}) *MutableTaskNodeStatus_GetPluginState
func (*MutableTaskNodeStatus) OnGetPluginStateVersion ¶
func (_m *MutableTaskNodeStatus) OnGetPluginStateVersion() *MutableTaskNodeStatus_GetPluginStateVersion
func (*MutableTaskNodeStatus) OnGetPluginStateVersionMatch ¶
func (_m *MutableTaskNodeStatus) OnGetPluginStateVersionMatch(matchers ...interface{}) *MutableTaskNodeStatus_GetPluginStateVersion
func (*MutableTaskNodeStatus) OnGetPreviousNodeExecutionCheckpointPath ¶
func (_m *MutableTaskNodeStatus) OnGetPreviousNodeExecutionCheckpointPath() *MutableTaskNodeStatus_GetPreviousNodeExecutionCheckpointPath
func (*MutableTaskNodeStatus) OnGetPreviousNodeExecutionCheckpointPathMatch ¶
func (_m *MutableTaskNodeStatus) OnGetPreviousNodeExecutionCheckpointPathMatch(matchers ...interface{}) *MutableTaskNodeStatus_GetPreviousNodeExecutionCheckpointPath
func (*MutableTaskNodeStatus) OnIsDirty ¶
func (_m *MutableTaskNodeStatus) OnIsDirty() *MutableTaskNodeStatus_IsDirty
func (*MutableTaskNodeStatus) OnIsDirtyMatch ¶
func (_m *MutableTaskNodeStatus) OnIsDirtyMatch(matchers ...interface{}) *MutableTaskNodeStatus_IsDirty
func (*MutableTaskNodeStatus) SetBarrierClockTick ¶
func (_m *MutableTaskNodeStatus) SetBarrierClockTick(tick uint32)
SetBarrierClockTick provides a mock function with given fields: tick
func (*MutableTaskNodeStatus) SetCleanupOnFailure ¶
func (_m *MutableTaskNodeStatus) SetCleanupOnFailure(_a0 bool)
SetCleanupOnFailure provides a mock function with given fields: _a0
func (*MutableTaskNodeStatus) SetLastPhaseUpdatedAt ¶
func (_m *MutableTaskNodeStatus) SetLastPhaseUpdatedAt(updatedAt time.Time)
SetLastPhaseUpdatedAt provides a mock function with given fields: updatedAt
func (*MutableTaskNodeStatus) SetPhase ¶
func (_m *MutableTaskNodeStatus) SetPhase(phase int)
SetPhase provides a mock function with given fields: phase
func (*MutableTaskNodeStatus) SetPhaseVersion ¶
func (_m *MutableTaskNodeStatus) SetPhaseVersion(version uint32)
SetPhaseVersion provides a mock function with given fields: version
func (*MutableTaskNodeStatus) SetPluginState ¶
func (_m *MutableTaskNodeStatus) SetPluginState(_a0 []byte)
SetPluginState provides a mock function with given fields: _a0
func (*MutableTaskNodeStatus) SetPluginStateVersion ¶
func (_m *MutableTaskNodeStatus) SetPluginStateVersion(_a0 uint32)
SetPluginStateVersion provides a mock function with given fields: _a0
func (*MutableTaskNodeStatus) SetPreviousNodeExecutionCheckpointPath ¶
func (_m *MutableTaskNodeStatus) SetPreviousNodeExecutionCheckpointPath(_a0 storage.DataReference)
SetPreviousNodeExecutionCheckpointPath provides a mock function with given fields: _a0
type MutableTaskNodeStatus_GetBarrierClockTick ¶
func (MutableTaskNodeStatus_GetBarrierClockTick) Return ¶
func (_m MutableTaskNodeStatus_GetBarrierClockTick) Return(_a0 uint32) *MutableTaskNodeStatus_GetBarrierClockTick
type MutableTaskNodeStatus_GetCleanupOnFailure ¶
func (MutableTaskNodeStatus_GetCleanupOnFailure) Return ¶
func (_m MutableTaskNodeStatus_GetCleanupOnFailure) Return(_a0 bool) *MutableTaskNodeStatus_GetCleanupOnFailure
type MutableTaskNodeStatus_GetLastPhaseUpdatedAt ¶
func (MutableTaskNodeStatus_GetLastPhaseUpdatedAt) Return ¶
func (_m MutableTaskNodeStatus_GetLastPhaseUpdatedAt) Return(_a0 time.Time) *MutableTaskNodeStatus_GetLastPhaseUpdatedAt
type MutableTaskNodeStatus_GetPhase ¶
func (MutableTaskNodeStatus_GetPhase) Return ¶
func (_m MutableTaskNodeStatus_GetPhase) Return(_a0 int) *MutableTaskNodeStatus_GetPhase
type MutableTaskNodeStatus_GetPhaseVersion ¶
func (MutableTaskNodeStatus_GetPhaseVersion) Return ¶
func (_m MutableTaskNodeStatus_GetPhaseVersion) Return(_a0 uint32) *MutableTaskNodeStatus_GetPhaseVersion
type MutableTaskNodeStatus_GetPluginState ¶
func (MutableTaskNodeStatus_GetPluginState) Return ¶
func (_m MutableTaskNodeStatus_GetPluginState) Return(_a0 []byte) *MutableTaskNodeStatus_GetPluginState
type MutableTaskNodeStatus_GetPluginStateVersion ¶
func (MutableTaskNodeStatus_GetPluginStateVersion) Return ¶
func (_m MutableTaskNodeStatus_GetPluginStateVersion) Return(_a0 uint32) *MutableTaskNodeStatus_GetPluginStateVersion
type MutableTaskNodeStatus_GetPreviousNodeExecutionCheckpointPath ¶
type MutableTaskNodeStatus_IsDirty ¶
func (MutableTaskNodeStatus_IsDirty) Return ¶
func (_m MutableTaskNodeStatus_IsDirty) Return(_a0 bool) *MutableTaskNodeStatus_IsDirty
type MutableWorkflowNodeStatus ¶
MutableWorkflowNodeStatus is an autogenerated mock type for the MutableWorkflowNodeStatus type
func (*MutableWorkflowNodeStatus) GetExecutionError ¶
func (_m *MutableWorkflowNodeStatus) GetExecutionError() *core.ExecutionError
GetExecutionError provides a mock function with given fields:
func (*MutableWorkflowNodeStatus) GetWorkflowNodePhase ¶
func (_m *MutableWorkflowNodeStatus) GetWorkflowNodePhase() v1alpha1.WorkflowNodePhase
GetWorkflowNodePhase provides a mock function with given fields:
func (*MutableWorkflowNodeStatus) IsDirty ¶
func (_m *MutableWorkflowNodeStatus) IsDirty() bool
IsDirty provides a mock function with given fields:
func (*MutableWorkflowNodeStatus) OnGetExecutionError ¶
func (_m *MutableWorkflowNodeStatus) OnGetExecutionError() *MutableWorkflowNodeStatus_GetExecutionError
func (*MutableWorkflowNodeStatus) OnGetExecutionErrorMatch ¶
func (_m *MutableWorkflowNodeStatus) OnGetExecutionErrorMatch(matchers ...interface{}) *MutableWorkflowNodeStatus_GetExecutionError
func (*MutableWorkflowNodeStatus) OnGetWorkflowNodePhase ¶
func (_m *MutableWorkflowNodeStatus) OnGetWorkflowNodePhase() *MutableWorkflowNodeStatus_GetWorkflowNodePhase
func (*MutableWorkflowNodeStatus) OnGetWorkflowNodePhaseMatch ¶
func (_m *MutableWorkflowNodeStatus) OnGetWorkflowNodePhaseMatch(matchers ...interface{}) *MutableWorkflowNodeStatus_GetWorkflowNodePhase
func (*MutableWorkflowNodeStatus) OnIsDirty ¶
func (_m *MutableWorkflowNodeStatus) OnIsDirty() *MutableWorkflowNodeStatus_IsDirty
func (*MutableWorkflowNodeStatus) OnIsDirtyMatch ¶
func (_m *MutableWorkflowNodeStatus) OnIsDirtyMatch(matchers ...interface{}) *MutableWorkflowNodeStatus_IsDirty
func (*MutableWorkflowNodeStatus) SetExecutionError ¶
func (_m *MutableWorkflowNodeStatus) SetExecutionError(executionError *core.ExecutionError)
SetExecutionError provides a mock function with given fields: executionError
func (*MutableWorkflowNodeStatus) SetWorkflowNodePhase ¶
func (_m *MutableWorkflowNodeStatus) SetWorkflowNodePhase(phase v1alpha1.WorkflowNodePhase)
SetWorkflowNodePhase provides a mock function with given fields: phase
type MutableWorkflowNodeStatus_GetExecutionError ¶
func (MutableWorkflowNodeStatus_GetExecutionError) Return ¶
func (_m MutableWorkflowNodeStatus_GetExecutionError) Return(_a0 *core.ExecutionError) *MutableWorkflowNodeStatus_GetExecutionError
type MutableWorkflowNodeStatus_GetWorkflowNodePhase ¶
type MutableWorkflowNodeStatus_IsDirty ¶
func (MutableWorkflowNodeStatus_IsDirty) Return ¶
func (_m MutableWorkflowNodeStatus_IsDirty) Return(_a0 bool) *MutableWorkflowNodeStatus_IsDirty
type Mutable_IsDirty ¶
func (Mutable_IsDirty) Return ¶
func (_m Mutable_IsDirty) Return(_a0 bool) *Mutable_IsDirty
type NodeGetter ¶
NodeGetter is an autogenerated mock type for the NodeGetter type
func (*NodeGetter) GetNode ¶
func (_m *NodeGetter) GetNode(nodeID string) (v1alpha1.ExecutableNode, bool)
GetNode provides a mock function with given fields: nodeID
func (*NodeGetter) OnGetNode ¶
func (_m *NodeGetter) OnGetNode(nodeID string) *NodeGetter_GetNode
func (*NodeGetter) OnGetNodeMatch ¶
func (_m *NodeGetter) OnGetNodeMatch(matchers ...interface{}) *NodeGetter_GetNode
type NodeGetter_GetNode ¶
func (NodeGetter_GetNode) Return ¶
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 ¶
func (_m *NodeStatusGetter) OnGetNodeExecutionStatus(ctx context.Context, id string) *NodeStatusGetter_GetNodeExecutionStatus
func (*NodeStatusGetter) OnGetNodeExecutionStatusMatch ¶
func (_m *NodeStatusGetter) OnGetNodeExecutionStatusMatch(matchers ...interface{}) *NodeStatusGetter_GetNodeExecutionStatus
type NodeStatusGetter_GetNodeExecutionStatus ¶
type 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 ¶
SubWorkflowGetter is an autogenerated mock type for the SubWorkflowGetter type
func (*SubWorkflowGetter) FindSubWorkflow ¶
func (_m *SubWorkflowGetter) FindSubWorkflow(subID string) v1alpha1.ExecutableSubWorkflow
FindSubWorkflow provides a mock function with given fields: subID
func (*SubWorkflowGetter) OnFindSubWorkflow ¶
func (_m *SubWorkflowGetter) OnFindSubWorkflow(subID string) *SubWorkflowGetter_FindSubWorkflow
func (*SubWorkflowGetter) OnFindSubWorkflowMatch ¶
func (_m *SubWorkflowGetter) OnFindSubWorkflowMatch(matchers ...interface{}) *SubWorkflowGetter_FindSubWorkflow
type SubWorkflowGetter_FindSubWorkflow ¶
func (SubWorkflowGetter_FindSubWorkflow) Return ¶
func (_m SubWorkflowGetter_FindSubWorkflow) Return(_a0 v1alpha1.ExecutableSubWorkflow) *SubWorkflowGetter_FindSubWorkflow
type TaskDetailsGetter ¶
TaskDetailsGetter is an autogenerated mock type for the TaskDetailsGetter type
func (*TaskDetailsGetter) GetTask ¶
func (_m *TaskDetailsGetter) GetTask(id string) (v1alpha1.ExecutableTask, error)
GetTask provides a mock function with given fields: id
func (*TaskDetailsGetter) OnGetTask ¶
func (_m *TaskDetailsGetter) OnGetTask(id string) *TaskDetailsGetter_GetTask
func (*TaskDetailsGetter) OnGetTaskMatch ¶
func (_m *TaskDetailsGetter) OnGetTaskMatch(matchers ...interface{}) *TaskDetailsGetter_GetTask
type TaskDetailsGetter_GetTask ¶
func (TaskDetailsGetter_GetTask) Return ¶
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 ¶
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 ¶
func (_m *WorkflowMeta) IsInterruptible() bool
IsInterruptible provides a mock function with given fields:
func (*WorkflowMeta) OnGetAnnotations ¶
func (_m *WorkflowMeta) OnGetAnnotations() *WorkflowMeta_GetAnnotations
func (*WorkflowMeta) OnGetAnnotationsMatch ¶
func (_m *WorkflowMeta) OnGetAnnotationsMatch(matchers ...interface{}) *WorkflowMeta_GetAnnotations
func (*WorkflowMeta) OnGetCreationTimestamp ¶
func (_m *WorkflowMeta) OnGetCreationTimestamp() *WorkflowMeta_GetCreationTimestamp
func (*WorkflowMeta) OnGetCreationTimestampMatch ¶
func (_m *WorkflowMeta) OnGetCreationTimestampMatch(matchers ...interface{}) *WorkflowMeta_GetCreationTimestamp
func (*WorkflowMeta) OnGetExecutionID ¶
func (_m *WorkflowMeta) OnGetExecutionID() *WorkflowMeta_GetExecutionID
func (*WorkflowMeta) OnGetExecutionIDMatch ¶
func (_m *WorkflowMeta) OnGetExecutionIDMatch(matchers ...interface{}) *WorkflowMeta_GetExecutionID
func (*WorkflowMeta) OnGetK8sWorkflowID ¶
func (_m *WorkflowMeta) OnGetK8sWorkflowID() *WorkflowMeta_GetK8sWorkflowID
func (*WorkflowMeta) OnGetK8sWorkflowIDMatch ¶
func (_m *WorkflowMeta) OnGetK8sWorkflowIDMatch(matchers ...interface{}) *WorkflowMeta_GetK8sWorkflowID
func (*WorkflowMeta) OnGetLabels ¶
func (_m *WorkflowMeta) OnGetLabels() *WorkflowMeta_GetLabels
func (*WorkflowMeta) OnGetLabelsMatch ¶
func (_m *WorkflowMeta) OnGetLabelsMatch(matchers ...interface{}) *WorkflowMeta_GetLabels
func (*WorkflowMeta) OnGetName ¶
func (_m *WorkflowMeta) OnGetName() *WorkflowMeta_GetName
func (*WorkflowMeta) OnGetNameMatch ¶
func (_m *WorkflowMeta) OnGetNameMatch(matchers ...interface{}) *WorkflowMeta_GetName
func (*WorkflowMeta) OnGetNamespace ¶
func (_m *WorkflowMeta) OnGetNamespace() *WorkflowMeta_GetNamespace
func (*WorkflowMeta) OnGetNamespaceMatch ¶
func (_m *WorkflowMeta) OnGetNamespaceMatch(matchers ...interface{}) *WorkflowMeta_GetNamespace
func (*WorkflowMeta) OnGetOwnerReference ¶
func (_m *WorkflowMeta) OnGetOwnerReference() *WorkflowMeta_GetOwnerReference
func (*WorkflowMeta) OnGetOwnerReferenceMatch ¶
func (_m *WorkflowMeta) OnGetOwnerReferenceMatch(matchers ...interface{}) *WorkflowMeta_GetOwnerReference
func (*WorkflowMeta) OnGetServiceAccountName ¶
func (_m *WorkflowMeta) OnGetServiceAccountName() *WorkflowMeta_GetServiceAccountName
func (*WorkflowMeta) OnGetServiceAccountNameMatch ¶
func (_m *WorkflowMeta) OnGetServiceAccountNameMatch(matchers ...interface{}) *WorkflowMeta_GetServiceAccountName
func (*WorkflowMeta) OnIsInterruptible ¶
func (_m *WorkflowMeta) OnIsInterruptible() *WorkflowMeta_IsInterruptible
func (*WorkflowMeta) OnIsInterruptibleMatch ¶
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 ¶
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 ¶
func (_m *WorkflowMetaExtended) IsInterruptible() bool
IsInterruptible provides a mock function with given fields:
func (*WorkflowMetaExtended) OnFindSubWorkflow ¶
func (_m *WorkflowMetaExtended) OnFindSubWorkflow(subID string) *WorkflowMetaExtended_FindSubWorkflow
func (*WorkflowMetaExtended) OnFindSubWorkflowMatch ¶
func (_m *WorkflowMetaExtended) OnFindSubWorkflowMatch(matchers ...interface{}) *WorkflowMetaExtended_FindSubWorkflow
func (*WorkflowMetaExtended) OnGetAnnotations ¶
func (_m *WorkflowMetaExtended) OnGetAnnotations() *WorkflowMetaExtended_GetAnnotations
func (*WorkflowMetaExtended) OnGetAnnotationsMatch ¶
func (_m *WorkflowMetaExtended) OnGetAnnotationsMatch(matchers ...interface{}) *WorkflowMetaExtended_GetAnnotations
func (*WorkflowMetaExtended) OnGetCreationTimestamp ¶
func (_m *WorkflowMetaExtended) OnGetCreationTimestamp() *WorkflowMetaExtended_GetCreationTimestamp
func (*WorkflowMetaExtended) OnGetCreationTimestampMatch ¶
func (_m *WorkflowMetaExtended) OnGetCreationTimestampMatch(matchers ...interface{}) *WorkflowMetaExtended_GetCreationTimestamp
func (*WorkflowMetaExtended) OnGetExecutionID ¶
func (_m *WorkflowMetaExtended) OnGetExecutionID() *WorkflowMetaExtended_GetExecutionID
func (*WorkflowMetaExtended) OnGetExecutionIDMatch ¶
func (_m *WorkflowMetaExtended) OnGetExecutionIDMatch(matchers ...interface{}) *WorkflowMetaExtended_GetExecutionID
func (*WorkflowMetaExtended) OnGetExecutionStatus ¶
func (_m *WorkflowMetaExtended) OnGetExecutionStatus() *WorkflowMetaExtended_GetExecutionStatus
func (*WorkflowMetaExtended) OnGetExecutionStatusMatch ¶
func (_m *WorkflowMetaExtended) OnGetExecutionStatusMatch(matchers ...interface{}) *WorkflowMetaExtended_GetExecutionStatus
func (*WorkflowMetaExtended) OnGetK8sWorkflowID ¶
func (_m *WorkflowMetaExtended) OnGetK8sWorkflowID() *WorkflowMetaExtended_GetK8sWorkflowID
func (*WorkflowMetaExtended) OnGetK8sWorkflowIDMatch ¶
func (_m *WorkflowMetaExtended) OnGetK8sWorkflowIDMatch(matchers ...interface{}) *WorkflowMetaExtended_GetK8sWorkflowID
func (*WorkflowMetaExtended) OnGetLabels ¶
func (_m *WorkflowMetaExtended) OnGetLabels() *WorkflowMetaExtended_GetLabels
func (*WorkflowMetaExtended) OnGetLabelsMatch ¶
func (_m *WorkflowMetaExtended) OnGetLabelsMatch(matchers ...interface{}) *WorkflowMetaExtended_GetLabels
func (*WorkflowMetaExtended) OnGetName ¶
func (_m *WorkflowMetaExtended) OnGetName() *WorkflowMetaExtended_GetName
func (*WorkflowMetaExtended) OnGetNameMatch ¶
func (_m *WorkflowMetaExtended) OnGetNameMatch(matchers ...interface{}) *WorkflowMetaExtended_GetName
func (*WorkflowMetaExtended) OnGetNamespace ¶
func (_m *WorkflowMetaExtended) OnGetNamespace() *WorkflowMetaExtended_GetNamespace
func (*WorkflowMetaExtended) OnGetNamespaceMatch ¶
func (_m *WorkflowMetaExtended) OnGetNamespaceMatch(matchers ...interface{}) *WorkflowMetaExtended_GetNamespace
func (*WorkflowMetaExtended) OnGetOwnerReference ¶
func (_m *WorkflowMetaExtended) OnGetOwnerReference() *WorkflowMetaExtended_GetOwnerReference
func (*WorkflowMetaExtended) OnGetOwnerReferenceMatch ¶
func (_m *WorkflowMetaExtended) OnGetOwnerReferenceMatch(matchers ...interface{}) *WorkflowMetaExtended_GetOwnerReference
func (*WorkflowMetaExtended) OnGetServiceAccountName ¶
func (_m *WorkflowMetaExtended) OnGetServiceAccountName() *WorkflowMetaExtended_GetServiceAccountName
func (*WorkflowMetaExtended) OnGetServiceAccountNameMatch ¶
func (_m *WorkflowMetaExtended) OnGetServiceAccountNameMatch(matchers ...interface{}) *WorkflowMetaExtended_GetServiceAccountName
func (*WorkflowMetaExtended) OnGetTask ¶
func (_m *WorkflowMetaExtended) OnGetTask(id string) *WorkflowMetaExtended_GetTask
func (*WorkflowMetaExtended) OnGetTaskMatch ¶
func (_m *WorkflowMetaExtended) OnGetTaskMatch(matchers ...interface{}) *WorkflowMetaExtended_GetTask
func (*WorkflowMetaExtended) OnIsInterruptible ¶
func (_m *WorkflowMetaExtended) OnIsInterruptible() *WorkflowMetaExtended_IsInterruptible
func (*WorkflowMetaExtended) OnIsInterruptibleMatch ¶
func (_m *WorkflowMetaExtended) OnIsInterruptibleMatch(matchers ...interface{}) *WorkflowMetaExtended_IsInterruptible
type WorkflowMetaExtended_FindSubWorkflow ¶
func (WorkflowMetaExtended_FindSubWorkflow) Return ¶
func (_m WorkflowMetaExtended_FindSubWorkflow) Return(_a0 v1alpha1.ExecutableSubWorkflow) *WorkflowMetaExtended_FindSubWorkflow
type WorkflowMetaExtended_GetAnnotations ¶
func (WorkflowMetaExtended_GetAnnotations) Return ¶
func (_m WorkflowMetaExtended_GetAnnotations) Return(_a0 map[string]string) *WorkflowMetaExtended_GetAnnotations
type WorkflowMetaExtended_GetCreationTimestamp ¶
func (WorkflowMetaExtended_GetCreationTimestamp) Return ¶
func (_m WorkflowMetaExtended_GetCreationTimestamp) Return(_a0 v1.Time) *WorkflowMetaExtended_GetCreationTimestamp
type WorkflowMetaExtended_GetExecutionID ¶
type WorkflowMetaExtended_GetExecutionStatus ¶
type WorkflowMetaExtended_GetK8sWorkflowID ¶
func (WorkflowMetaExtended_GetK8sWorkflowID) Return ¶
func (_m WorkflowMetaExtended_GetK8sWorkflowID) Return(_a0 types.NamespacedName) *WorkflowMetaExtended_GetK8sWorkflowID
type WorkflowMetaExtended_GetLabels ¶
func (WorkflowMetaExtended_GetLabels) Return ¶
func (_m WorkflowMetaExtended_GetLabels) Return(_a0 map[string]string) *WorkflowMetaExtended_GetLabels
type WorkflowMetaExtended_GetName ¶
func (WorkflowMetaExtended_GetName) Return ¶
func (_m WorkflowMetaExtended_GetName) Return(_a0 string) *WorkflowMetaExtended_GetName
type WorkflowMetaExtended_GetNamespace ¶
func (WorkflowMetaExtended_GetNamespace) Return ¶
func (_m WorkflowMetaExtended_GetNamespace) Return(_a0 string) *WorkflowMetaExtended_GetNamespace
type WorkflowMetaExtended_GetOwnerReference ¶
func (WorkflowMetaExtended_GetOwnerReference) Return ¶
func (_m WorkflowMetaExtended_GetOwnerReference) Return(_a0 v1.OwnerReference) *WorkflowMetaExtended_GetOwnerReference
type WorkflowMetaExtended_GetServiceAccountName ¶
func (WorkflowMetaExtended_GetServiceAccountName) Return ¶
func (_m WorkflowMetaExtended_GetServiceAccountName) Return(_a0 string) *WorkflowMetaExtended_GetServiceAccountName
type WorkflowMetaExtended_GetTask ¶
func (WorkflowMetaExtended_GetTask) Return ¶
func (_m WorkflowMetaExtended_GetTask) Return(_a0 v1alpha1.ExecutableTask, _a1 error) *WorkflowMetaExtended_GetTask
type WorkflowMetaExtended_IsInterruptible ¶
func (WorkflowMetaExtended_IsInterruptible) Return ¶
func (_m WorkflowMetaExtended_IsInterruptible) Return(_a0 bool) *WorkflowMetaExtended_IsInterruptible
type WorkflowMeta_GetAnnotations ¶
func (WorkflowMeta_GetAnnotations) Return ¶
func (_m WorkflowMeta_GetAnnotations) Return(_a0 map[string]string) *WorkflowMeta_GetAnnotations
type WorkflowMeta_GetCreationTimestamp ¶
func (WorkflowMeta_GetCreationTimestamp) Return ¶
func (_m WorkflowMeta_GetCreationTimestamp) Return(_a0 v1.Time) *WorkflowMeta_GetCreationTimestamp
type WorkflowMeta_GetExecutionID ¶
func (WorkflowMeta_GetExecutionID) Return ¶
func (_m WorkflowMeta_GetExecutionID) Return(_a0 v1alpha1.WorkflowExecutionIdentifier) *WorkflowMeta_GetExecutionID
type WorkflowMeta_GetK8sWorkflowID ¶
func (WorkflowMeta_GetK8sWorkflowID) Return ¶
func (_m WorkflowMeta_GetK8sWorkflowID) Return(_a0 types.NamespacedName) *WorkflowMeta_GetK8sWorkflowID
type WorkflowMeta_GetLabels ¶
func (WorkflowMeta_GetLabels) Return ¶
func (_m WorkflowMeta_GetLabels) Return(_a0 map[string]string) *WorkflowMeta_GetLabels
type WorkflowMeta_GetName ¶
func (WorkflowMeta_GetName) Return ¶
func (_m WorkflowMeta_GetName) Return(_a0 string) *WorkflowMeta_GetName
type WorkflowMeta_GetNamespace ¶
func (WorkflowMeta_GetNamespace) Return ¶
func (_m WorkflowMeta_GetNamespace) Return(_a0 string) *WorkflowMeta_GetNamespace
type WorkflowMeta_GetOwnerReference ¶
func (WorkflowMeta_GetOwnerReference) Return ¶
func (_m WorkflowMeta_GetOwnerReference) Return(_a0 v1.OwnerReference) *WorkflowMeta_GetOwnerReference
type WorkflowMeta_GetServiceAccountName ¶
func (WorkflowMeta_GetServiceAccountName) Return ¶
func (_m WorkflowMeta_GetServiceAccountName) Return(_a0 string) *WorkflowMeta_GetServiceAccountName
type WorkflowMeta_IsInterruptible ¶
func (WorkflowMeta_IsInterruptible) Return ¶
func (_m WorkflowMeta_IsInterruptible) Return(_a0 bool) *WorkflowMeta_IsInterruptible
Source Files ¶
- BaseNode.go
- BaseWorkflow.go
- BaseWorkflowWithStatus.go
- ExecutableArrayNode.go
- ExecutableArrayNodeStatus.go
- ExecutableBranchNode.go
- ExecutableBranchNodeStatus.go
- ExecutableDynamicNodeStatus.go
- ExecutableGateNode.go
- ExecutableGateNodeStatus.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
- MutableArrayNodeStatus.go
- MutableBranchNodeStatus.go
- MutableDynamicNodeStatus.go
- MutableGateNodeStatus.go
- MutableNodeStatus.go
- MutableSubWorkflowNodeStatus.go
- MutableTaskNodeStatus.go
- MutableWorkflowNodeStatus.go
- NodeGetter.go
- NodeStatusGetter.go
- NodeStatusVisitor.go
- SubWorkflowGetter.go
- TaskDetailsGetter.go
- WorkflowMeta.go
- WorkflowMetaExtended.go