mocks

Aug 3, 2023

Changes in this version

+ type ExecutableArrayNode struct

+ 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 struct

+ 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 struct

+ func (_m ExecutableArrayNodeStatus_GetArrayNodePhase) Return(_a0 v1alpha1.ArrayNodePhase) *ExecutableArrayNodeStatus_GetArrayNodePhase

+ type ExecutableArrayNodeStatus_GetExecutionError struct

+ func (_m ExecutableArrayNodeStatus_GetExecutionError) Return(_a0 *core.ExecutionError) *ExecutableArrayNodeStatus_GetExecutionError

+ type ExecutableArrayNodeStatus_GetSubNodePhases struct

+ func (_m ExecutableArrayNodeStatus_GetSubNodePhases) Return(_a0 bitarray.CompactArray) *ExecutableArrayNodeStatus_GetSubNodePhases

+ type ExecutableArrayNodeStatus_GetSubNodeRetryAttempts struct

+ func (_m ExecutableArrayNodeStatus_GetSubNodeRetryAttempts) Return(_a0 bitarray.CompactArray) *ExecutableArrayNodeStatus_GetSubNodeRetryAttempts

+ type ExecutableArrayNodeStatus_GetSubNodeSystemFailures struct

+ func (_m ExecutableArrayNodeStatus_GetSubNodeSystemFailures) Return(_a0 bitarray.CompactArray) *ExecutableArrayNodeStatus_GetSubNodeSystemFailures

+ type ExecutableArrayNodeStatus_GetSubNodeTaskPhases struct

+ func (_m ExecutableArrayNodeStatus_GetSubNodeTaskPhases) Return(_a0 bitarray.CompactArray) *ExecutableArrayNodeStatus_GetSubNodeTaskPhases

+ type ExecutableArrayNodeStatus_GetTaskPhaseVersion struct

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

+ type ExecutableArrayNode_GetMinSuccessRatio struct

+ func (_m ExecutableArrayNode_GetMinSuccessRatio) Return(_a0 *float32) *ExecutableArrayNode_GetMinSuccessRatio

+ type ExecutableArrayNode_GetMinSuccesses struct

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

+ type ExecutableArrayNode_GetParallelism struct

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

+ type ExecutableArrayNode_GetSubNodeSpec struct

+ func (_m ExecutableArrayNode_GetSubNodeSpec) Return(_a0 *v1alpha1.NodeSpec) *ExecutableArrayNode_GetSubNodeSpec

type ExecutableNode

+ func (_m *ExecutableNode) GetArrayNode() v1alpha1.ExecutableArrayNode

+ func (_m *ExecutableNode) OnGetArrayNode() *ExecutableNode_GetArrayNode

+ func (_m *ExecutableNode) OnGetArrayNodeMatch(matchers ...interface{}) *ExecutableNode_GetArrayNode

type ExecutableNodeStatus

+ func (_m *ExecutableNodeStatus) ClearArrayNodeStatus()

+ func (_m *ExecutableNodeStatus) GetArrayNodeStatus() v1alpha1.MutableArrayNodeStatus

+ func (_m *ExecutableNodeStatus) GetOrCreateArrayNodeStatus() v1alpha1.MutableArrayNodeStatus

+ func (_m *ExecutableNodeStatus) OnGetArrayNodeStatus() *ExecutableNodeStatus_GetArrayNodeStatus

+ func (_m *ExecutableNodeStatus) OnGetArrayNodeStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetArrayNodeStatus

+ func (_m *ExecutableNodeStatus) OnGetOrCreateArrayNodeStatus() *ExecutableNodeStatus_GetOrCreateArrayNodeStatus

+ func (_m *ExecutableNodeStatus) OnGetOrCreateArrayNodeStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetOrCreateArrayNodeStatus

+ type ExecutableNodeStatus_GetArrayNodeStatus struct

+ func (_m ExecutableNodeStatus_GetArrayNodeStatus) Return(_a0 v1alpha1.MutableArrayNodeStatus) *ExecutableNodeStatus_GetArrayNodeStatus

+ type ExecutableNodeStatus_GetOrCreateArrayNodeStatus struct

+ func (_m ExecutableNodeStatus_GetOrCreateArrayNodeStatus) Return(_a0 v1alpha1.MutableArrayNodeStatus) *ExecutableNodeStatus_GetOrCreateArrayNodeStatus

+ type ExecutableNode_GetArrayNode struct

+ func (_m ExecutableNode_GetArrayNode) Return(_a0 v1alpha1.ExecutableArrayNode) *ExecutableNode_GetArrayNode

+ type MutableArrayNodeStatus struct

+ 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 struct

+ func (_m MutableArrayNodeStatus_GetArrayNodePhase) Return(_a0 v1alpha1.ArrayNodePhase) *MutableArrayNodeStatus_GetArrayNodePhase

+ type MutableArrayNodeStatus_GetExecutionError struct

+ func (_m MutableArrayNodeStatus_GetExecutionError) Return(_a0 *core.ExecutionError) *MutableArrayNodeStatus_GetExecutionError

+ type MutableArrayNodeStatus_GetSubNodePhases struct

+ func (_m MutableArrayNodeStatus_GetSubNodePhases) Return(_a0 bitarray.CompactArray) *MutableArrayNodeStatus_GetSubNodePhases

+ type MutableArrayNodeStatus_GetSubNodeRetryAttempts struct

+ func (_m MutableArrayNodeStatus_GetSubNodeRetryAttempts) Return(_a0 bitarray.CompactArray) *MutableArrayNodeStatus_GetSubNodeRetryAttempts

+ type MutableArrayNodeStatus_GetSubNodeSystemFailures struct

+ func (_m MutableArrayNodeStatus_GetSubNodeSystemFailures) Return(_a0 bitarray.CompactArray) *MutableArrayNodeStatus_GetSubNodeSystemFailures

+ type MutableArrayNodeStatus_GetSubNodeTaskPhases struct

+ func (_m MutableArrayNodeStatus_GetSubNodeTaskPhases) Return(_a0 bitarray.CompactArray) *MutableArrayNodeStatus_GetSubNodeTaskPhases

+ type MutableArrayNodeStatus_GetTaskPhaseVersion struct

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

+ type MutableArrayNodeStatus_IsDirty struct

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

type MutableNodeStatus

+ func (_m *MutableNodeStatus) ClearArrayNodeStatus()

+ func (_m *MutableNodeStatus) GetArrayNodeStatus() v1alpha1.MutableArrayNodeStatus

+ func (_m *MutableNodeStatus) GetOrCreateArrayNodeStatus() v1alpha1.MutableArrayNodeStatus

+ func (_m *MutableNodeStatus) OnGetArrayNodeStatus() *MutableNodeStatus_GetArrayNodeStatus

+ func (_m *MutableNodeStatus) OnGetArrayNodeStatusMatch(matchers ...interface{}) *MutableNodeStatus_GetArrayNodeStatus

+ func (_m *MutableNodeStatus) OnGetOrCreateArrayNodeStatus() *MutableNodeStatus_GetOrCreateArrayNodeStatus

+ func (_m *MutableNodeStatus) OnGetOrCreateArrayNodeStatusMatch(matchers ...interface{}) *MutableNodeStatus_GetOrCreateArrayNodeStatus

+ type MutableNodeStatus_GetArrayNodeStatus struct

+ func (_m MutableNodeStatus_GetArrayNodeStatus) Return(_a0 v1alpha1.MutableArrayNodeStatus) *MutableNodeStatus_GetArrayNodeStatus

+ type MutableNodeStatus_GetOrCreateArrayNodeStatus struct

+ func (_m MutableNodeStatus_GetOrCreateArrayNodeStatus) Return(_a0 v1alpha1.MutableArrayNodeStatus) *MutableNodeStatus_GetOrCreateArrayNodeStatus

Jul 6, 2023

Changes in this version

type ExecutableDynamicNodeStatus

+ func (_m *ExecutableDynamicNodeStatus) GetIsFailurePermanent() bool

+ func (_m *ExecutableDynamicNodeStatus) OnGetIsFailurePermanent() *ExecutableDynamicNodeStatus_GetIsFailurePermanent

+ func (_m *ExecutableDynamicNodeStatus) OnGetIsFailurePermanentMatch(matchers ...interface{}) *ExecutableDynamicNodeStatus_GetIsFailurePermanent

+ type ExecutableDynamicNodeStatus_GetIsFailurePermanent struct

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

type MutableDynamicNodeStatus

+ func (_m *MutableDynamicNodeStatus) GetIsFailurePermanent() bool

+ func (_m *MutableDynamicNodeStatus) OnGetIsFailurePermanent() *MutableDynamicNodeStatus_GetIsFailurePermanent

+ func (_m *MutableDynamicNodeStatus) OnGetIsFailurePermanentMatch(matchers ...interface{}) *MutableDynamicNodeStatus_GetIsFailurePermanent

+ func (_m *MutableDynamicNodeStatus) SetIsFailurePermanent(isFailurePermanent bool)

+ type MutableDynamicNodeStatus_GetIsFailurePermanent struct

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

Apr 28, 2023

Changes in this version

type ExecutableTaskNodeStatus

+ func (_m *ExecutableTaskNodeStatus) GetCleanupOnFailure() bool

+ func (_m *ExecutableTaskNodeStatus) OnGetCleanupOnFailure() *ExecutableTaskNodeStatus_GetCleanupOnFailure

+ func (_m *ExecutableTaskNodeStatus) OnGetCleanupOnFailureMatch(matchers ...interface{}) *ExecutableTaskNodeStatus_GetCleanupOnFailure

+ type ExecutableTaskNodeStatus_GetCleanupOnFailure struct

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

type MutableTaskNodeStatus

+ func (_m *MutableTaskNodeStatus) GetCleanupOnFailure() bool

+ func (_m *MutableTaskNodeStatus) OnGetCleanupOnFailure() *MutableTaskNodeStatus_GetCleanupOnFailure

+ func (_m *MutableTaskNodeStatus) OnGetCleanupOnFailureMatch(matchers ...interface{}) *MutableTaskNodeStatus_GetCleanupOnFailure

+ func (_m *MutableTaskNodeStatus) SetCleanupOnFailure(_a0 bool)

+ type MutableTaskNodeStatus_GetCleanupOnFailure struct

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

Dec 1, 2022

Changes in this version

+ type ExecutableGateNode struct

+ 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 struct

+ func (_m *ExecutableGateNodeStatus) GetGateNodePhase() v1alpha1.GateNodePhase

+ func (_m *ExecutableGateNodeStatus) OnGetGateNodePhase() *ExecutableGateNodeStatus_GetGateNodePhase

+ func (_m *ExecutableGateNodeStatus) OnGetGateNodePhaseMatch(matchers ...interface{}) *ExecutableGateNodeStatus_GetGateNodePhase

+ type ExecutableGateNodeStatus_GetGateNodePhase struct

+ func (_m ExecutableGateNodeStatus_GetGateNodePhase) Return(_a0 v1alpha1.GateNodePhase) *ExecutableGateNodeStatus_GetGateNodePhase

+ type ExecutableGateNode_GetApprove struct

+ func (_m ExecutableGateNode_GetApprove) Return(_a0 *core.ApproveCondition) *ExecutableGateNode_GetApprove

+ type ExecutableGateNode_GetKind struct

+ func (_m ExecutableGateNode_GetKind) Return(_a0 v1alpha1.ConditionKind) *ExecutableGateNode_GetKind

+ type ExecutableGateNode_GetSignal struct

+ func (_m ExecutableGateNode_GetSignal) Return(_a0 *core.SignalCondition) *ExecutableGateNode_GetSignal

+ type ExecutableGateNode_GetSleep struct

+ func (_m ExecutableGateNode_GetSleep) Return(_a0 *core.SleepCondition) *ExecutableGateNode_GetSleep

type ExecutableNode

+ func (_m *ExecutableNode) GetGateNode() v1alpha1.ExecutableGateNode

+ func (_m *ExecutableNode) OnGetGateNode() *ExecutableNode_GetGateNode

+ func (_m *ExecutableNode) OnGetGateNodeMatch(matchers ...interface{}) *ExecutableNode_GetGateNode

type ExecutableNodeStatus

+ func (_m *ExecutableNodeStatus) ClearGateNodeStatus()

+ func (_m *ExecutableNodeStatus) GetGateNodeStatus() v1alpha1.MutableGateNodeStatus

+ func (_m *ExecutableNodeStatus) GetOrCreateGateNodeStatus() v1alpha1.MutableGateNodeStatus

+ func (_m *ExecutableNodeStatus) OnGetGateNodeStatus() *ExecutableNodeStatus_GetGateNodeStatus

+ func (_m *ExecutableNodeStatus) OnGetGateNodeStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetGateNodeStatus

+ func (_m *ExecutableNodeStatus) OnGetOrCreateGateNodeStatus() *ExecutableNodeStatus_GetOrCreateGateNodeStatus

+ func (_m *ExecutableNodeStatus) OnGetOrCreateGateNodeStatusMatch(matchers ...interface{}) *ExecutableNodeStatus_GetOrCreateGateNodeStatus

+ type ExecutableNodeStatus_GetGateNodeStatus struct

+ func (_m ExecutableNodeStatus_GetGateNodeStatus) Return(_a0 v1alpha1.MutableGateNodeStatus) *ExecutableNodeStatus_GetGateNodeStatus

+ type ExecutableNodeStatus_GetOrCreateGateNodeStatus struct

+ func (_m ExecutableNodeStatus_GetOrCreateGateNodeStatus) Return(_a0 v1alpha1.MutableGateNodeStatus) *ExecutableNodeStatus_GetOrCreateGateNodeStatus

+ type ExecutableNode_GetGateNode struct

+ func (_m ExecutableNode_GetGateNode) Return(_a0 v1alpha1.ExecutableGateNode) *ExecutableNode_GetGateNode

+ type MutableGateNodeStatus struct

+ 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 struct

+ func (_m MutableGateNodeStatus_GetGateNodePhase) Return(_a0 v1alpha1.GateNodePhase) *MutableGateNodeStatus_GetGateNodePhase

+ type MutableGateNodeStatus_IsDirty struct

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

type MutableNodeStatus

+ func (_m *MutableNodeStatus) ClearGateNodeStatus()

+ func (_m *MutableNodeStatus) GetGateNodeStatus() v1alpha1.MutableGateNodeStatus

+ func (_m *MutableNodeStatus) GetOrCreateGateNodeStatus() v1alpha1.MutableGateNodeStatus

+ func (_m *MutableNodeStatus) OnGetGateNodeStatus() *MutableNodeStatus_GetGateNodeStatus

+ func (_m *MutableNodeStatus) OnGetGateNodeStatusMatch(matchers ...interface{}) *MutableNodeStatus_GetGateNodeStatus

+ func (_m *MutableNodeStatus) OnGetOrCreateGateNodeStatus() *MutableNodeStatus_GetOrCreateGateNodeStatus

+ func (_m *MutableNodeStatus) OnGetOrCreateGateNodeStatusMatch(matchers ...interface{}) *MutableNodeStatus_GetOrCreateGateNodeStatus

+ type MutableNodeStatus_GetGateNodeStatus struct

+ func (_m MutableNodeStatus_GetGateNodeStatus) Return(_a0 v1alpha1.MutableGateNodeStatus) *MutableNodeStatus_GetGateNodeStatus

+ type MutableNodeStatus_GetOrCreateGateNodeStatus struct

+ func (_m MutableNodeStatus_GetOrCreateGateNodeStatus) Return(_a0 v1alpha1.MutableGateNodeStatus) *MutableNodeStatus_GetOrCreateGateNodeStatus

Oct 6, 2022

Changes in this version

type ExecutableTaskNodeStatus

+ func (_m *ExecutableTaskNodeStatus) GetPreviousNodeExecutionCheckpointPath() storage.DataReference

+ func (_m *ExecutableTaskNodeStatus) OnGetPreviousNodeExecutionCheckpointPath() *ExecutableTaskNodeStatus_GetPreviousNodeExecutionCheckpointPath

+ func (_m *ExecutableTaskNodeStatus) OnGetPreviousNodeExecutionCheckpointPathMatch(matchers ...interface{}) *ExecutableTaskNodeStatus_GetPreviousNodeExecutionCheckpointPath

+ type ExecutableTaskNodeStatus_GetPreviousNodeExecutionCheckpointPath struct

+ func (_m ExecutableTaskNodeStatus_GetPreviousNodeExecutionCheckpointPath) Return(_a0 storage.DataReference) *ExecutableTaskNodeStatus_GetPreviousNodeExecutionCheckpointPath

type MutableTaskNodeStatus

+ func (_m *MutableTaskNodeStatus) GetPreviousNodeExecutionCheckpointPath() storage.DataReference

+ func (_m *MutableTaskNodeStatus) OnGetPreviousNodeExecutionCheckpointPath() *MutableTaskNodeStatus_GetPreviousNodeExecutionCheckpointPath

+ func (_m *MutableTaskNodeStatus) OnGetPreviousNodeExecutionCheckpointPathMatch(matchers ...interface{}) *MutableTaskNodeStatus_GetPreviousNodeExecutionCheckpointPath

+ func (_m *MutableTaskNodeStatus) SetPreviousNodeExecutionCheckpointPath(_a0 storage.DataReference)

+ type MutableTaskNodeStatus_GetPreviousNodeExecutionCheckpointPath struct

+ func (_m MutableTaskNodeStatus_GetPreviousNodeExecutionCheckpointPath) Return(_a0 storage.DataReference) *MutableTaskNodeStatus_GetPreviousNodeExecutionCheckpointPath

Sep 9, 2022

Changes in this version

type ExecutableWorkflow

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

+ func (_m *ExecutableWorkflow) OnGetDefinitionVersion() *ExecutableWorkflow_GetDefinitionVersion

+ func (_m *ExecutableWorkflow) OnGetDefinitionVersionMatch(matchers ...interface{}) *ExecutableWorkflow_GetDefinitionVersion

+ type ExecutableWorkflow_GetDefinitionVersion struct

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

type Meta

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

+ func (_m *Meta) OnGetDefinitionVersion() *Meta_GetDefinitionVersion

+ func (_m *Meta) OnGetDefinitionVersionMatch(matchers ...interface{}) *Meta_GetDefinitionVersion

type MetaExtended

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

+ func (_m *MetaExtended) OnGetDefinitionVersion() *MetaExtended_GetDefinitionVersion

+ func (_m *MetaExtended) OnGetDefinitionVersionMatch(matchers ...interface{}) *MetaExtended_GetDefinitionVersion

+ type MetaExtended_GetDefinitionVersion struct

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

+ type Meta_GetDefinitionVersion struct

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

Mar 18, 2021

Changes in this version

type ExecutableWorkflow

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

+ func (_m *ExecutableWorkflow) OnGetSecurityContext() *ExecutableWorkflow_GetSecurityContext

+ func (_m *ExecutableWorkflow) OnGetSecurityContextMatch(matchers ...interface{}) *ExecutableWorkflow_GetSecurityContext

+ type ExecutableWorkflow_GetSecurityContext struct

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

type Meta

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

+ func (_m *Meta) OnGetSecurityContext() *Meta_GetSecurityContext

+ func (_m *Meta) OnGetSecurityContextMatch(matchers ...interface{}) *Meta_GetSecurityContext

type MetaExtended

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

+ func (_m *MetaExtended) OnGetSecurityContext() *MetaExtended_GetSecurityContext

+ func (_m *MetaExtended) OnGetSecurityContextMatch(matchers ...interface{}) *MetaExtended_GetSecurityContext

+ type MetaExtended_GetSecurityContext struct

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

+ type Meta_GetSecurityContext struct

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

Mar 10, 2021

Changes in this version

type BaseWorkflow

+ func (_m *BaseWorkflow) OnToNode(name string) *BaseWorkflow_ToNode

+ func (_m *BaseWorkflow) OnToNodeMatch(matchers ...interface{}) *BaseWorkflow_ToNode

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

type BaseWorkflowWithStatus

+ func (_m *BaseWorkflowWithStatus) OnToNode(name string) *BaseWorkflowWithStatus_ToNode

+ func (_m *BaseWorkflowWithStatus) OnToNodeMatch(matchers ...interface{}) *BaseWorkflowWithStatus_ToNode

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

+ type BaseWorkflowWithStatus_ToNode struct

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

+ type BaseWorkflow_ToNode struct

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

type ExecutableDynamicNodeStatus

+ func (_m *ExecutableDynamicNodeStatus) GetExecutionError() *core.ExecutionError

+ func (_m *ExecutableDynamicNodeStatus) OnGetExecutionError() *ExecutableDynamicNodeStatus_GetExecutionError

+ func (_m *ExecutableDynamicNodeStatus) OnGetExecutionErrorMatch(matchers ...interface{}) *ExecutableDynamicNodeStatus_GetExecutionError

+ type ExecutableDynamicNodeStatus_GetExecutionError struct

+ func (_m ExecutableDynamicNodeStatus_GetExecutionError) Return(_a0 *core.ExecutionError) *ExecutableDynamicNodeStatus_GetExecutionError

type ExecutableNode

+ func (_m *ExecutableNode) GetName() string

+ func (_m *ExecutableNode) IsInterruptible() *bool

+ func (_m *ExecutableNode) OnGetName() *ExecutableNode_GetName

+ func (_m *ExecutableNode) OnGetNameMatch(matchers ...interface{}) *ExecutableNode_GetName

+ func (_m *ExecutableNode) OnIsInterruptible() *ExecutableNode_IsInterruptible

+ func (_m *ExecutableNode) OnIsInterruptibleMatch(matchers ...interface{}) *ExecutableNode_IsInterruptible

type ExecutableNodeStatus

+ func (_m *ExecutableNodeStatus) GetExecutionError() *core.ExecutionError

+ func (_m *ExecutableNodeStatus) GetSystemFailures() uint32

+ func (_m *ExecutableNodeStatus) IncrementSystemFailures() uint32

+ func (_m *ExecutableNodeStatus) OnGetExecutionError() *ExecutableNodeStatus_GetExecutionError

+ func (_m *ExecutableNodeStatus) OnGetExecutionErrorMatch(matchers ...interface{}) *ExecutableNodeStatus_GetExecutionError

+ func (_m *ExecutableNodeStatus) OnGetSystemFailures() *ExecutableNodeStatus_GetSystemFailures

+ func (_m *ExecutableNodeStatus) OnGetSystemFailuresMatch(matchers ...interface{}) *ExecutableNodeStatus_GetSystemFailures

+ func (_m *ExecutableNodeStatus) OnIncrementSystemFailures() *ExecutableNodeStatus_IncrementSystemFailures

+ func (_m *ExecutableNodeStatus) OnIncrementSystemFailuresMatch(matchers ...interface{}) *ExecutableNodeStatus_IncrementSystemFailures

+ type ExecutableNodeStatus_GetExecutionError struct

+ func (_m ExecutableNodeStatus_GetExecutionError) Return(_a0 *core.ExecutionError) *ExecutableNodeStatus_GetExecutionError

+ type ExecutableNodeStatus_GetSystemFailures struct

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

+ type ExecutableNodeStatus_IncrementSystemFailures struct

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

+ type ExecutableNode_GetName struct

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

+ type ExecutableNode_IsInterruptible struct

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

type ExecutableSubWorkflow

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

+ func (_m *ExecutableSubWorkflow) OnGetOnFailurePolicy() *ExecutableSubWorkflow_GetOnFailurePolicy

+ func (_m *ExecutableSubWorkflow) OnGetOnFailurePolicyMatch(matchers ...interface{}) *ExecutableSubWorkflow_GetOnFailurePolicy

+ func (_m *ExecutableSubWorkflow) OnToNode(name string) *ExecutableSubWorkflow_ToNode

+ func (_m *ExecutableSubWorkflow) OnToNodeMatch(matchers ...interface{}) *ExecutableSubWorkflow_ToNode

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

+ type ExecutableSubWorkflow_GetOnFailurePolicy struct

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

+ type ExecutableSubWorkflow_ToNode struct

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

type ExecutableWorkflow

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

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

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

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

+ func (_m *ExecutableWorkflow) IsInterruptible() bool

+ 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) OnGetOnFailurePolicy() *ExecutableWorkflow_GetOnFailurePolicy

+ func (_m *ExecutableWorkflow) OnGetOnFailurePolicyMatch(matchers ...interface{}) *ExecutableWorkflow_GetOnFailurePolicy

+ func (_m *ExecutableWorkflow) OnGetRawOutputDataConfig() *ExecutableWorkflow_GetRawOutputDataConfig

+ func (_m *ExecutableWorkflow) OnGetRawOutputDataConfigMatch(matchers ...interface{}) *ExecutableWorkflow_GetRawOutputDataConfig

+ func (_m *ExecutableWorkflow) OnIsInterruptible() *ExecutableWorkflow_IsInterruptible

+ func (_m *ExecutableWorkflow) OnIsInterruptibleMatch(matchers ...interface{}) *ExecutableWorkflow_IsInterruptible

+ func (_m *ExecutableWorkflow) OnToNode(name string) *ExecutableWorkflow_ToNode

+ func (_m *ExecutableWorkflow) OnToNodeMatch(matchers ...interface{}) *ExecutableWorkflow_ToNode

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

type ExecutableWorkflowNodeStatus

+ func (_m *ExecutableWorkflowNodeStatus) GetExecutionError() *core.ExecutionError

+ func (_m *ExecutableWorkflowNodeStatus) OnGetExecutionError() *ExecutableWorkflowNodeStatus_GetExecutionError

+ func (_m *ExecutableWorkflowNodeStatus) OnGetExecutionErrorMatch(matchers ...interface{}) *ExecutableWorkflowNodeStatus_GetExecutionError

+ type ExecutableWorkflowNodeStatus_GetExecutionError struct

+ func (_m ExecutableWorkflowNodeStatus_GetExecutionError) Return(_a0 *core.ExecutionError) *ExecutableWorkflowNodeStatus_GetExecutionError

type ExecutableWorkflowStatus

+ func (_m *ExecutableWorkflowStatus) GetExecutionError() *core.ExecutionError

+ func (_m *ExecutableWorkflowStatus) OnGetExecutionError() *ExecutableWorkflowStatus_GetExecutionError

+ func (_m *ExecutableWorkflowStatus) OnGetExecutionErrorMatch(matchers ...interface{}) *ExecutableWorkflowStatus_GetExecutionError

+ type ExecutableWorkflowStatus_GetExecutionError struct

+ func (_m ExecutableWorkflowStatus_GetExecutionError) Return(_a0 *core.ExecutionError) *ExecutableWorkflowStatus_GetExecutionError

+ type ExecutableWorkflow_GetEventVersion struct

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

+ type ExecutableWorkflow_GetExecutionConfig struct

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

+ type ExecutableWorkflow_GetOnFailurePolicy struct

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

+ type ExecutableWorkflow_GetRawOutputDataConfig struct

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

+ type ExecutableWorkflow_IsInterruptible struct

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

+ type ExecutableWorkflow_ToNode struct

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

+ type ExecutionTimeInfo struct

+ 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 struct

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

+ type ExecutionTimeInfo_GetStartedAt struct

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

+ type ExecutionTimeInfo_GetStoppedAt struct

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

+ type Meta struct

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

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

+ 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) 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) 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) 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 struct

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

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

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

+ 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) 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) 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) 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 struct

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

+ type MetaExtended_GetAnnotations struct

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

+ type MetaExtended_GetCreationTimestamp struct

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

+ type MetaExtended_GetEventVersion struct

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

+ type MetaExtended_GetExecutionID struct

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

+ type MetaExtended_GetExecutionStatus struct

+ func (_m MetaExtended_GetExecutionStatus) Return(_a0 v1alpha1.ExecutableWorkflowStatus) *MetaExtended_GetExecutionStatus

+ type MetaExtended_GetK8sWorkflowID struct

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

+ type MetaExtended_GetLabels struct

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

+ type MetaExtended_GetName struct

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

+ type MetaExtended_GetNamespace struct

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

+ type MetaExtended_GetOwnerReference struct

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

+ type MetaExtended_GetRawOutputDataConfig struct

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

+ type MetaExtended_GetServiceAccountName struct

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

+ type MetaExtended_GetTask struct

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

+ type MetaExtended_IsInterruptible struct

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

+ type Meta_GetAnnotations struct

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

+ type Meta_GetCreationTimestamp struct

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

+ type Meta_GetEventVersion struct

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

+ type Meta_GetExecutionID struct

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

+ type Meta_GetK8sWorkflowID struct

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

+ type Meta_GetLabels struct

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

+ type Meta_GetName struct

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

+ type Meta_GetNamespace struct

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

+ type Meta_GetOwnerReference struct

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

+ type Meta_GetRawOutputDataConfig struct

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

+ type Meta_GetServiceAccountName struct

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

+ type Meta_IsInterruptible struct

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

type MutableDynamicNodeStatus

+ func (_m *MutableDynamicNodeStatus) GetExecutionError() *core.ExecutionError

+ func (_m *MutableDynamicNodeStatus) OnGetExecutionError() *MutableDynamicNodeStatus_GetExecutionError

+ func (_m *MutableDynamicNodeStatus) OnGetExecutionErrorMatch(matchers ...interface{}) *MutableDynamicNodeStatus_GetExecutionError

+ func (_m *MutableDynamicNodeStatus) SetExecutionError(executionError *core.ExecutionError)

+ type MutableDynamicNodeStatus_GetExecutionError struct

+ func (_m MutableDynamicNodeStatus_GetExecutionError) Return(_a0 *core.ExecutionError) *MutableDynamicNodeStatus_GetExecutionError

type MutableNodeStatus

+ func (_m *MutableNodeStatus) IncrementSystemFailures() uint32

+ func (_m *MutableNodeStatus) OnIncrementSystemFailures() *MutableNodeStatus_IncrementSystemFailures

+ func (_m *MutableNodeStatus) OnIncrementSystemFailuresMatch(matchers ...interface{}) *MutableNodeStatus_IncrementSystemFailures

+ type MutableNodeStatus_IncrementSystemFailures struct

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

type MutableWorkflowNodeStatus

+ func (_m *MutableWorkflowNodeStatus) GetExecutionError() *core.ExecutionError

+ func (_m *MutableWorkflowNodeStatus) OnGetExecutionError() *MutableWorkflowNodeStatus_GetExecutionError

+ func (_m *MutableWorkflowNodeStatus) OnGetExecutionErrorMatch(matchers ...interface{}) *MutableWorkflowNodeStatus_GetExecutionError

+ func (_m *MutableWorkflowNodeStatus) SetExecutionError(executionError *core.ExecutionError)

+ type MutableWorkflowNodeStatus_GetExecutionError struct

+ func (_m MutableWorkflowNodeStatus_GetExecutionError) Return(_a0 *core.ExecutionError) *MutableWorkflowNodeStatus_GetExecutionError

+ type NodeGetter struct

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

+ func (_m *NodeGetter) OnGetNode(nodeID string) *NodeGetter_GetNode

+ func (_m *NodeGetter) OnGetNodeMatch(matchers ...interface{}) *NodeGetter_GetNode

+ type NodeGetter_GetNode struct

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

+ type SubWorkflowGetter struct

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

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

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

+ type SubWorkflowGetter_FindSubWorkflow struct

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

type WorkflowMeta

+ func (_m *WorkflowMeta) IsInterruptible() bool

+ func (_m *WorkflowMeta) OnIsInterruptible() *WorkflowMeta_IsInterruptible

+ func (_m *WorkflowMeta) OnIsInterruptibleMatch(matchers ...interface{}) *WorkflowMeta_IsInterruptible

type WorkflowMetaExtended

+ func (_m *WorkflowMetaExtended) IsInterruptible() bool

+ func (_m *WorkflowMetaExtended) OnIsInterruptible() *WorkflowMetaExtended_IsInterruptible

+ func (_m *WorkflowMetaExtended) OnIsInterruptibleMatch(matchers ...interface{}) *WorkflowMetaExtended_IsInterruptible

+ type WorkflowMetaExtended_IsInterruptible struct

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

+ type WorkflowMeta_IsInterruptible struct

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

Jan 10, 2020

Changes in this version

type ExecutableNodeStatus

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

+ func (_m *ExecutableNodeStatus) OnGetOutputDir() *ExecutableNodeStatus_GetOutputDir

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

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

+ type ExecutableNodeStatus_GetOutputDir struct

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

type ExecutableTaskNodeStatus

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

+ func (_m *ExecutableTaskNodeStatus) OnGetLastPhaseUpdatedAt() *ExecutableTaskNodeStatus_GetLastPhaseUpdatedAt

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

+ type ExecutableTaskNodeStatus_GetLastPhaseUpdatedAt struct

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

type MutableNodeStatus

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

type MutableTaskNodeStatus

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

+ func (_m *MutableTaskNodeStatus) OnGetLastPhaseUpdatedAt() *MutableTaskNodeStatus_GetLastPhaseUpdatedAt

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

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

+ type MutableTaskNodeStatus_GetLastPhaseUpdatedAt struct

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

Jan 2, 2020

Changes in this version

type ExecutableNodeStatus

+ func (_m *ExecutableNodeStatus) ClearSubNodeStatus()

+ type Mutable struct

+ func (_m *Mutable) IsDirty() bool

+ func (_m *Mutable) OnIsDirty() *Mutable_IsDirty

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

type MutableBranchNodeStatus

+ func (_m *MutableBranchNodeStatus) IsDirty() bool

+ func (_m *MutableBranchNodeStatus) OnIsDirty() *MutableBranchNodeStatus_IsDirty

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

+ type MutableBranchNodeStatus_IsDirty struct

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

type MutableDynamicNodeStatus

+ func (_m *MutableDynamicNodeStatus) IsDirty() bool

+ func (_m *MutableDynamicNodeStatus) OnIsDirty() *MutableDynamicNodeStatus_IsDirty

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

+ type MutableDynamicNodeStatus_IsDirty struct

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

type MutableNodeStatus

+ func (_m *MutableNodeStatus) ClearSubNodeStatus()

+ func (_m *MutableNodeStatus) IsDirty() bool

+ func (_m *MutableNodeStatus) OnIsDirty() *MutableNodeStatus_IsDirty

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

+ type MutableNodeStatus_IsDirty struct

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

type MutableSubWorkflowNodeStatus

+ func (_m *MutableSubWorkflowNodeStatus) IsDirty() bool

+ func (_m *MutableSubWorkflowNodeStatus) OnIsDirty() *MutableSubWorkflowNodeStatus_IsDirty

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

+ type MutableSubWorkflowNodeStatus_IsDirty struct

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

type MutableTaskNodeStatus

+ func (_m *MutableTaskNodeStatus) IsDirty() bool

+ func (_m *MutableTaskNodeStatus) OnIsDirty() *MutableTaskNodeStatus_IsDirty

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

+ type MutableTaskNodeStatus_IsDirty struct

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

type MutableWorkflowNodeStatus

+ func (_m *MutableWorkflowNodeStatus) IsDirty() bool

+ func (_m *MutableWorkflowNodeStatus) OnIsDirty() *MutableWorkflowNodeStatus_IsDirty

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

+ type MutableWorkflowNodeStatus_IsDirty struct

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

+ type Mutable_IsDirty struct

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

Dec 11, 2019

Changes in this version

type ExecutableNode

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

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

+ func (_m *ExecutableNode) OnGetActiveDeadline() *ExecutableNode_GetActiveDeadline

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

+ func (_m *ExecutableNode) OnGetExecutionDeadline() *ExecutableNode_GetExecutionDeadline

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

type ExecutableNodeStatus

+ func (_m *ExecutableNodeStatus) ClearLastAttemptStartedAt()

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

+ func (_m *ExecutableNodeStatus) OnGetLastAttemptStartedAt() *ExecutableNodeStatus_GetLastAttemptStartedAt

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

+ type ExecutableNodeStatus_GetLastAttemptStartedAt struct

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

+ type ExecutableNode_GetActiveDeadline struct

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

+ type ExecutableNode_GetExecutionDeadline struct

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

type MutableNodeStatus

+ func (_m *MutableNodeStatus) ClearLastAttemptStartedAt()

Dec 3, 2019

Changes in this version

type ExecutableDynamicNodeStatus

+ func (_m *ExecutableDynamicNodeStatus) GetDynamicNodeReason() string

+ func (_m *ExecutableDynamicNodeStatus) OnGetDynamicNodeReason() *ExecutableDynamicNodeStatus_GetDynamicNodeReason

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

+ type ExecutableDynamicNodeStatus_GetDynamicNodeReason struct

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

type MutableDynamicNodeStatus

+ func (_m *MutableDynamicNodeStatus) GetDynamicNodeReason() string

+ func (_m *MutableDynamicNodeStatus) OnGetDynamicNodeReason() *MutableDynamicNodeStatus_GetDynamicNodeReason

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

+ func (_m *MutableDynamicNodeStatus) SetDynamicNodeReason(reason string)

+ type MutableDynamicNodeStatus_GetDynamicNodeReason struct

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

Nov 12, 2019

Changes in this version

type BaseNode

+ 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 struct

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

+ type BaseNode_GetKind struct

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

type BaseWorkflow

+ 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

type BaseWorkflowWithStatus

+ 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(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

+ type BaseWorkflowWithStatus_FromNode struct

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

+ type BaseWorkflowWithStatus_GetID struct

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

+ type BaseWorkflowWithStatus_GetNode struct

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

+ type BaseWorkflowWithStatus_GetNodeExecutionStatus struct

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

+ type BaseWorkflowWithStatus_StartNode struct

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

+ type BaseWorkflow_FromNode struct

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

+ type BaseWorkflow_GetID struct

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

+ type BaseWorkflow_GetNode struct

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

+ type BaseWorkflow_StartNode struct

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

type ExecutableBranchNode

+ 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) 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 struct

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

+ type ExecutableBranchNodeStatus_GetPhase struct

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

+ type ExecutableBranchNode_GetElse struct

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

+ type ExecutableBranchNode_GetElseFail struct

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

+ type ExecutableBranchNode_GetElseIf struct

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

+ type ExecutableBranchNode_GetIf struct

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

type ExecutableDynamicNodeStatus

+ func (_m *ExecutableDynamicNodeStatus) OnGetDynamicNodePhase() *ExecutableDynamicNodeStatus_GetDynamicNodePhase

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

+ type ExecutableDynamicNodeStatus_GetDynamicNodePhase struct

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

type ExecutableIfBlock

+ 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 struct

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

+ type ExecutableIfBlock_GetThenNode struct

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

type ExecutableNode

+ 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) OnGetID() *ExecutableNode_GetID

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

+ func (_m *ExecutableNode) OnGetInputBindings() *ExecutableNode_GetInputBindings

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

+ func (_m *ExecutableNode) OnGetKind() *ExecutableNode_GetKind

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

+ func (_m *ExecutableNode) OnGetOutputAlias() *ExecutableNode_GetOutputAlias

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

+ func (_m *ExecutableNode) OnGetResources() *ExecutableNode_GetResources

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

+ func (_m *ExecutableNode) OnGetRetryStrategy() *ExecutableNode_GetRetryStrategy

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

+ func (_m *ExecutableNode) OnGetTaskID() *ExecutableNode_GetTaskID

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

+ func (_m *ExecutableNode) OnGetWorkflowNode() *ExecutableNode_GetWorkflowNode

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

+ func (_m *ExecutableNode) OnIsEndNode() *ExecutableNode_IsEndNode

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

+ func (_m *ExecutableNode) OnIsStartNode() *ExecutableNode_IsStartNode

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

type ExecutableNodeStatus

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

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

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

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

+ 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) 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(id string) *ExecutableNodeStatus_GetNodeExecutionStatus

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

+ func (_m *ExecutableNodeStatus) OnGetOrCreateBranchStatus() *ExecutableNodeStatus_GetOrCreateBranchStatus

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

+ func (_m *ExecutableNodeStatus) OnGetOrCreateDynamicNodeStatus() *ExecutableNodeStatus_GetOrCreateDynamicNodeStatus

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

+ func (_m *ExecutableNodeStatus) OnGetOrCreateTaskStatus() *ExecutableNodeStatus_GetOrCreateTaskStatus

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

+ func (_m *ExecutableNodeStatus) OnGetOrCreateWorkflowStatus() *ExecutableNodeStatus_GetOrCreateWorkflowStatus

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

+ func (_m *ExecutableNodeStatus) OnGetParentNodeID() *ExecutableNodeStatus_GetParentNodeID

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

+ func (_m *ExecutableNodeStatus) OnGetParentTaskID() *ExecutableNodeStatus_GetParentTaskID

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

+ func (_m *ExecutableNodeStatus) OnGetPhase() *ExecutableNodeStatus_GetPhase

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

+ func (_m *ExecutableNodeStatus) OnGetQueuedAt() *ExecutableNodeStatus_GetQueuedAt

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

+ func (_m *ExecutableNodeStatus) OnGetStartedAt() *ExecutableNodeStatus_GetStartedAt

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

+ func (_m *ExecutableNodeStatus) OnGetStoppedAt() *ExecutableNodeStatus_GetStoppedAt

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

+ func (_m *ExecutableNodeStatus) OnGetTaskNodeStatus() *ExecutableNodeStatus_GetTaskNodeStatus

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

+ func (_m *ExecutableNodeStatus) OnGetTaskStatus() *ExecutableNodeStatus_GetTaskStatus

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

+ func (_m *ExecutableNodeStatus) OnGetWorkflowNodeStatus() *ExecutableNodeStatus_GetWorkflowNodeStatus

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

+ func (_m *ExecutableNodeStatus) OnGetWorkflowStatus() *ExecutableNodeStatus_GetWorkflowStatus

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

+ func (_m *ExecutableNodeStatus) OnIncrementAttempts() *ExecutableNodeStatus_IncrementAttempts

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

+ func (_m *ExecutableNodeStatus) OnIsCached() *ExecutableNodeStatus_IsCached

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

+ func (_m *ExecutableNodeStatus) OnIsDirty() *ExecutableNodeStatus_IsDirty

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

+ type ExecutableNodeStatus_GetAttempts struct

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

+ type ExecutableNodeStatus_GetBranchStatus struct

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

+ type ExecutableNodeStatus_GetDataDir struct

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

+ type ExecutableNodeStatus_GetDynamicNodeStatus struct

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

+ type ExecutableNodeStatus_GetLastUpdatedAt struct

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

+ type ExecutableNodeStatus_GetMessage struct

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

+ type ExecutableNodeStatus_GetNodeExecutionStatus struct

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

+ type ExecutableNodeStatus_GetOrCreateBranchStatus struct

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

+ type ExecutableNodeStatus_GetOrCreateDynamicNodeStatus struct

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

+ type ExecutableNodeStatus_GetOrCreateTaskStatus struct

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

+ type ExecutableNodeStatus_GetOrCreateWorkflowStatus struct

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

+ type ExecutableNodeStatus_GetParentNodeID struct

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

+ type ExecutableNodeStatus_GetParentTaskID struct

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

+ type ExecutableNodeStatus_GetPhase struct

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

+ type ExecutableNodeStatus_GetQueuedAt struct

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

+ type ExecutableNodeStatus_GetStartedAt struct

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

+ type ExecutableNodeStatus_GetStoppedAt struct

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

+ type ExecutableNodeStatus_GetTaskNodeStatus struct

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

+ type ExecutableNodeStatus_GetTaskStatus struct

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

+ type ExecutableNodeStatus_GetWorkflowNodeStatus struct

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

+ type ExecutableNodeStatus_GetWorkflowStatus struct

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

+ type ExecutableNodeStatus_IncrementAttempts struct

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

+ type ExecutableNodeStatus_IsCached struct

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

+ type ExecutableNodeStatus_IsDirty struct

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

+ type ExecutableNode_GetBranchNode struct

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

+ type ExecutableNode_GetConfig struct

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

+ type ExecutableNode_GetID struct

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

+ type ExecutableNode_GetInputBindings struct

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

+ type ExecutableNode_GetKind struct

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

+ type ExecutableNode_GetOutputAlias struct

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

+ type ExecutableNode_GetResources struct

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

+ type ExecutableNode_GetRetryStrategy struct

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

+ type ExecutableNode_GetTaskID struct

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

+ type ExecutableNode_GetWorkflowNode struct

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

+ type ExecutableNode_IsEndNode struct

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

+ type ExecutableNode_IsStartNode struct

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

type ExecutableSubWorkflow

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

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

+ func (_m *ExecutableSubWorkflow) OnGetConnections() *ExecutableSubWorkflow_GetConnections

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

+ func (_m *ExecutableSubWorkflow) OnGetID() *ExecutableSubWorkflow_GetID

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

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

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

+ func (_m *ExecutableSubWorkflow) OnGetNodes() *ExecutableSubWorkflow_GetNodes

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

+ func (_m *ExecutableSubWorkflow) OnGetOnFailureNode() *ExecutableSubWorkflow_GetOnFailureNode

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

+ func (_m *ExecutableSubWorkflow) OnGetOutputBindings() *ExecutableSubWorkflow_GetOutputBindings

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

+ func (_m *ExecutableSubWorkflow) OnGetOutputs() *ExecutableSubWorkflow_GetOutputs

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

+ func (_m *ExecutableSubWorkflow) OnStartNode() *ExecutableSubWorkflow_StartNode

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

type ExecutableSubWorkflowNodeStatus

+ func (_m *ExecutableSubWorkflowNodeStatus) OnGetPhase() *ExecutableSubWorkflowNodeStatus_GetPhase

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

+ type ExecutableSubWorkflowNodeStatus_GetPhase struct

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

+ type ExecutableSubWorkflow_FromNode struct

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

+ type ExecutableSubWorkflow_GetConnections struct

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

+ type ExecutableSubWorkflow_GetID struct

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

+ type ExecutableSubWorkflow_GetNode struct

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

+ type ExecutableSubWorkflow_GetNodes struct

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

+ type ExecutableSubWorkflow_GetOnFailureNode struct

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

+ type ExecutableSubWorkflow_GetOutputBindings struct

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

+ type ExecutableSubWorkflow_GetOutputs struct

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

+ type ExecutableSubWorkflow_StartNode struct

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

type ExecutableTask

+ 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

type ExecutableTaskNodeStatus

+ func (_m *ExecutableTaskNodeStatus) GetBarrierClockTick() uint32

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

+ func (_m *ExecutableTaskNodeStatus) GetPluginStateVersion() uint32

+ func (_m *ExecutableTaskNodeStatus) OnGetBarrierClockTick() *ExecutableTaskNodeStatus_GetBarrierClockTick

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

+ func (_m *ExecutableTaskNodeStatus) OnGetPhase() *ExecutableTaskNodeStatus_GetPhase

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

+ func (_m *ExecutableTaskNodeStatus) OnGetPhaseVersion() *ExecutableTaskNodeStatus_GetPhaseVersion

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

+ func (_m *ExecutableTaskNodeStatus) OnGetPluginState() *ExecutableTaskNodeStatus_GetPluginState

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

+ func (_m *ExecutableTaskNodeStatus) OnGetPluginStateVersion() *ExecutableTaskNodeStatus_GetPluginStateVersion

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

+ type ExecutableTaskNodeStatus_GetBarrierClockTick struct

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

+ type ExecutableTaskNodeStatus_GetPhase struct

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

+ type ExecutableTaskNodeStatus_GetPhaseVersion struct

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

+ type ExecutableTaskNodeStatus_GetPluginState struct

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

+ type ExecutableTaskNodeStatus_GetPluginStateVersion struct

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

+ type ExecutableTask_CoreTask struct

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

+ type ExecutableTask_TaskType struct

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

type ExecutableWorkflow

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

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

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

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

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

+ func (_m *ExecutableWorkflow) OnGetAnnotations() *ExecutableWorkflow_GetAnnotations

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

+ func (_m *ExecutableWorkflow) OnGetConnections() *ExecutableWorkflow_GetConnections

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

+ func (_m *ExecutableWorkflow) OnGetCreationTimestamp() *ExecutableWorkflow_GetCreationTimestamp

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

+ func (_m *ExecutableWorkflow) OnGetExecutionID() *ExecutableWorkflow_GetExecutionID

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

+ func (_m *ExecutableWorkflow) OnGetExecutionStatus() *ExecutableWorkflow_GetExecutionStatus

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

+ func (_m *ExecutableWorkflow) OnGetID() *ExecutableWorkflow_GetID

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

+ func (_m *ExecutableWorkflow) OnGetK8sWorkflowID() *ExecutableWorkflow_GetK8sWorkflowID

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

+ func (_m *ExecutableWorkflow) OnGetLabels() *ExecutableWorkflow_GetLabels

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

+ func (_m *ExecutableWorkflow) OnGetName() *ExecutableWorkflow_GetName

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

+ func (_m *ExecutableWorkflow) OnGetNamespace() *ExecutableWorkflow_GetNamespace

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

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

+ func (_m *ExecutableWorkflow) OnGetNodeExecutionStatus(id string) *ExecutableWorkflow_GetNodeExecutionStatus

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

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

+ func (_m *ExecutableWorkflow) OnGetNodes() *ExecutableWorkflow_GetNodes

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

+ func (_m *ExecutableWorkflow) OnGetOnFailureNode() *ExecutableWorkflow_GetOnFailureNode

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

+ func (_m *ExecutableWorkflow) OnGetOutputBindings() *ExecutableWorkflow_GetOutputBindings

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

+ func (_m *ExecutableWorkflow) OnGetOutputs() *ExecutableWorkflow_GetOutputs

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

+ func (_m *ExecutableWorkflow) OnGetOwnerReference() *ExecutableWorkflow_GetOwnerReference

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

+ func (_m *ExecutableWorkflow) OnGetServiceAccountName() *ExecutableWorkflow_GetServiceAccountName

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

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

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

+ func (_m *ExecutableWorkflow) OnStartNode() *ExecutableWorkflow_StartNode

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

type ExecutableWorkflowNode

+ func (_m *ExecutableWorkflowNode) OnGetLaunchPlanRefID() *ExecutableWorkflowNode_GetLaunchPlanRefID

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

+ func (_m *ExecutableWorkflowNode) OnGetSubWorkflowRef() *ExecutableWorkflowNode_GetSubWorkflowRef

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

type ExecutableWorkflowNodeStatus

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

+ func (_m *ExecutableWorkflowNodeStatus) OnGetWorkflowNodePhase() *ExecutableWorkflowNodeStatus_GetWorkflowNodePhase

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

+ type ExecutableWorkflowNodeStatus_GetWorkflowNodePhase struct

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

+ type ExecutableWorkflowNode_GetLaunchPlanRefID struct

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

+ type ExecutableWorkflowNode_GetSubWorkflowRef struct

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

type ExecutableWorkflowStatus

+ func (_m *ExecutableWorkflowStatus) OnConstructNodeDataDir(ctx context.Context, constructor storage.ReferenceConstructor, name string) *ExecutableWorkflowStatus_ConstructNodeDataDir

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

+ func (_m *ExecutableWorkflowStatus) OnGetDataDir() *ExecutableWorkflowStatus_GetDataDir

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

+ func (_m *ExecutableWorkflowStatus) OnGetLastUpdatedAt() *ExecutableWorkflowStatus_GetLastUpdatedAt

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

+ func (_m *ExecutableWorkflowStatus) OnGetMessage() *ExecutableWorkflowStatus_GetMessage

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

+ func (_m *ExecutableWorkflowStatus) OnGetNodeExecutionStatus(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

+ type ExecutableWorkflowStatus_ConstructNodeDataDir struct

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

+ type ExecutableWorkflowStatus_GetDataDir struct

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

+ type ExecutableWorkflowStatus_GetLastUpdatedAt struct

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

+ type ExecutableWorkflowStatus_GetMessage struct

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

+ type ExecutableWorkflowStatus_GetNodeExecutionStatus struct

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

+ type ExecutableWorkflowStatus_GetOutputReference struct

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

+ type ExecutableWorkflowStatus_GetPhase struct

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

+ type ExecutableWorkflowStatus_GetStartedAt struct

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

+ type ExecutableWorkflowStatus_GetStoppedAt struct

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

+ type ExecutableWorkflowStatus_IsTerminated struct

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

+ type ExecutableWorkflow_FindSubWorkflow struct

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

+ type ExecutableWorkflow_FromNode struct

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

+ type ExecutableWorkflow_GetAnnotations struct

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

+ type ExecutableWorkflow_GetConnections struct

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

+ type ExecutableWorkflow_GetCreationTimestamp struct

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

+ type ExecutableWorkflow_GetExecutionID struct

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

+ type ExecutableWorkflow_GetExecutionStatus struct

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

+ type ExecutableWorkflow_GetID struct

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

+ type ExecutableWorkflow_GetK8sWorkflowID struct

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

+ type ExecutableWorkflow_GetLabels struct

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

+ type ExecutableWorkflow_GetName struct

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

+ type ExecutableWorkflow_GetNamespace struct

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

+ type ExecutableWorkflow_GetNode struct

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

+ type ExecutableWorkflow_GetNodeExecutionStatus struct

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

+ type ExecutableWorkflow_GetNodes struct

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

+ type ExecutableWorkflow_GetOnFailureNode struct

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

+ type ExecutableWorkflow_GetOutputBindings struct

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

+ type ExecutableWorkflow_GetOutputs struct

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

+ type ExecutableWorkflow_GetOwnerReference struct

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

+ type ExecutableWorkflow_GetServiceAccountName struct

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

+ type ExecutableWorkflow_GetTask struct

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

+ type ExecutableWorkflow_StartNode struct

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

type MutableBranchNodeStatus

+ 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

+ type MutableBranchNodeStatus_GetFinalizedNode struct

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

+ type MutableBranchNodeStatus_GetPhase struct

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

type MutableDynamicNodeStatus

+ func (_m *MutableDynamicNodeStatus) OnGetDynamicNodePhase() *MutableDynamicNodeStatus_GetDynamicNodePhase

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

+ type MutableDynamicNodeStatus_GetDynamicNodePhase struct

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

type MutableNodeStatus

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

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

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

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

+ func (_m *MutableNodeStatus) OnGetBranchStatus() *MutableNodeStatus_GetBranchStatus

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

+ func (_m *MutableNodeStatus) OnGetDynamicNodeStatus() *MutableNodeStatus_GetDynamicNodeStatus

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

+ func (_m *MutableNodeStatus) OnGetOrCreateBranchStatus() *MutableNodeStatus_GetOrCreateBranchStatus

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

+ func (_m *MutableNodeStatus) OnGetOrCreateDynamicNodeStatus() *MutableNodeStatus_GetOrCreateDynamicNodeStatus

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

+ func (_m *MutableNodeStatus) OnGetOrCreateTaskStatus() *MutableNodeStatus_GetOrCreateTaskStatus

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

+ func (_m *MutableNodeStatus) OnGetOrCreateWorkflowStatus() *MutableNodeStatus_GetOrCreateWorkflowStatus

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

+ func (_m *MutableNodeStatus) OnGetTaskStatus() *MutableNodeStatus_GetTaskStatus

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

+ func (_m *MutableNodeStatus) OnGetWorkflowStatus() *MutableNodeStatus_GetWorkflowStatus

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

+ func (_m *MutableNodeStatus) OnIncrementAttempts() *MutableNodeStatus_IncrementAttempts

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

+ type MutableNodeStatus_GetBranchStatus struct

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

+ type MutableNodeStatus_GetDynamicNodeStatus struct

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

+ type MutableNodeStatus_GetOrCreateBranchStatus struct

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

+ type MutableNodeStatus_GetOrCreateDynamicNodeStatus struct

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

+ type MutableNodeStatus_GetOrCreateTaskStatus struct

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

+ type MutableNodeStatus_GetOrCreateWorkflowStatus struct

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

+ type MutableNodeStatus_GetTaskStatus struct

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

+ type MutableNodeStatus_GetWorkflowStatus struct

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

+ type MutableNodeStatus_IncrementAttempts struct

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

type MutableSubWorkflowNodeStatus

+ func (_m *MutableSubWorkflowNodeStatus) OnGetPhase() *MutableSubWorkflowNodeStatus_GetPhase

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

+ type MutableSubWorkflowNodeStatus_GetPhase struct

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

type MutableTaskNodeStatus

+ func (_m *MutableTaskNodeStatus) GetBarrierClockTick() uint32

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

+ func (_m *MutableTaskNodeStatus) GetPluginStateVersion() uint32

+ func (_m *MutableTaskNodeStatus) OnGetBarrierClockTick() *MutableTaskNodeStatus_GetBarrierClockTick

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

+ 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) SetBarrierClockTick(tick uint32)

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

+ func (_m *MutableTaskNodeStatus) SetPluginStateVersion(_a0 uint32)

+ type MutableTaskNodeStatus_GetBarrierClockTick struct

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

+ type MutableTaskNodeStatus_GetPhase struct

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

+ type MutableTaskNodeStatus_GetPhaseVersion struct

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

+ type MutableTaskNodeStatus_GetPluginState struct

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

+ type MutableTaskNodeStatus_GetPluginStateVersion struct

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

type MutableWorkflowNodeStatus

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

+ func (_m *MutableWorkflowNodeStatus) OnGetWorkflowNodePhase() *MutableWorkflowNodeStatus_GetWorkflowNodePhase

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

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

+ type MutableWorkflowNodeStatus_GetWorkflowNodePhase struct

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

type NodeStatusGetter

+ func (_m *NodeStatusGetter) OnGetNodeExecutionStatus(id string) *NodeStatusGetter_GetNodeExecutionStatus

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

+ type NodeStatusGetter_GetNodeExecutionStatus struct

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

+ type TaskDetailsGetter struct

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

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

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

+ type TaskDetailsGetter_GetTask struct

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

type WorkflowMeta

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

+ func (_m *WorkflowMeta) OnGetAnnotations() *WorkflowMeta_GetAnnotations

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

+ func (_m *WorkflowMeta) OnGetCreationTimestamp() *WorkflowMeta_GetCreationTimestamp

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

+ func (_m *WorkflowMeta) OnGetExecutionID() *WorkflowMeta_GetExecutionID

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

+ func (_m *WorkflowMeta) OnGetK8sWorkflowID() *WorkflowMeta_GetK8sWorkflowID

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

+ func (_m *WorkflowMeta) OnGetLabels() *WorkflowMeta_GetLabels

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

+ func (_m *WorkflowMeta) OnGetName() *WorkflowMeta_GetName

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

+ func (_m *WorkflowMeta) OnGetNamespace() *WorkflowMeta_GetNamespace

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

+ func (_m *WorkflowMeta) OnGetOwnerReference() *WorkflowMeta_GetOwnerReference

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

+ func (_m *WorkflowMeta) OnGetServiceAccountName() *WorkflowMeta_GetServiceAccountName

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

type WorkflowMetaExtended

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

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

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

+ func (_m *WorkflowMetaExtended) OnGetAnnotations() *WorkflowMetaExtended_GetAnnotations

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

+ func (_m *WorkflowMetaExtended) OnGetCreationTimestamp() *WorkflowMetaExtended_GetCreationTimestamp

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

+ func (_m *WorkflowMetaExtended) OnGetExecutionID() *WorkflowMetaExtended_GetExecutionID

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

+ func (_m *WorkflowMetaExtended) OnGetExecutionStatus() *WorkflowMetaExtended_GetExecutionStatus

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

+ func (_m *WorkflowMetaExtended) OnGetK8sWorkflowID() *WorkflowMetaExtended_GetK8sWorkflowID

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

+ func (_m *WorkflowMetaExtended) OnGetLabels() *WorkflowMetaExtended_GetLabels

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

+ func (_m *WorkflowMetaExtended) OnGetName() *WorkflowMetaExtended_GetName

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

+ func (_m *WorkflowMetaExtended) OnGetNamespace() *WorkflowMetaExtended_GetNamespace

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

+ func (_m *WorkflowMetaExtended) OnGetOwnerReference() *WorkflowMetaExtended_GetOwnerReference

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

+ func (_m *WorkflowMetaExtended) OnGetServiceAccountName() *WorkflowMetaExtended_GetServiceAccountName

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

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

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

+ type WorkflowMetaExtended_FindSubWorkflow struct

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

+ type WorkflowMetaExtended_GetAnnotations struct

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

+ type WorkflowMetaExtended_GetCreationTimestamp struct

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

+ type WorkflowMetaExtended_GetExecutionID struct

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

+ type WorkflowMetaExtended_GetExecutionStatus struct

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

+ type WorkflowMetaExtended_GetK8sWorkflowID struct

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

+ type WorkflowMetaExtended_GetLabels struct

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

+ type WorkflowMetaExtended_GetName struct

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

+ type WorkflowMetaExtended_GetNamespace struct

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

+ type WorkflowMetaExtended_GetOwnerReference struct

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

+ type WorkflowMetaExtended_GetServiceAccountName struct

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

+ type WorkflowMetaExtended_GetTask struct

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

+ type WorkflowMeta_GetAnnotations struct

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

+ type WorkflowMeta_GetCreationTimestamp struct

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

+ type WorkflowMeta_GetExecutionID struct

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

+ type WorkflowMeta_GetK8sWorkflowID struct

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

+ type WorkflowMeta_GetLabels struct

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

+ type WorkflowMeta_GetName struct

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

+ type WorkflowMeta_GetNamespace struct

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

+ type WorkflowMeta_GetOwnerReference struct

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

+ type WorkflowMeta_GetServiceAccountName struct

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

Sep 6, 2019

Changes in this version

+ type BaseNode struct

+ func (_m *BaseNode) GetID() string

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

+ type BaseWorkflow struct

+ 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) StartNode() v1alpha1.ExecutableNode

+ type BaseWorkflowWithStatus struct

+ 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(id string) v1alpha1.ExecutableNodeStatus

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

+ type ExecutableBranchNode struct

+ func (_m *ExecutableBranchNode) GetElse() *string

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

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

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

+ type ExecutableBranchNodeStatus struct

+ func (_m *ExecutableBranchNodeStatus) GetFinalizedNode() *string

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

+ type ExecutableDynamicNodeStatus struct

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

+ type ExecutableIfBlock struct

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

+ func (_m *ExecutableIfBlock) GetThenNode() *string

+ type ExecutableNode struct

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

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

+ func (_m *ExecutableNode) GetID() string

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

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

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

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

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

+ func (_m *ExecutableNode) GetTaskID() *string

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

+ func (_m *ExecutableNode) IsEndNode() bool

+ func (_m *ExecutableNode) IsStartNode() bool

+ type ExecutableNodeStatus struct

+ func (_m *ExecutableNodeStatus) ClearDynamicNodeStatus()

+ func (_m *ExecutableNodeStatus) ClearSubWorkflowStatus()

+ func (_m *ExecutableNodeStatus) ClearTaskStatus()

+ func (_m *ExecutableNodeStatus) ClearWorkflowStatus()

+ func (_m *ExecutableNodeStatus) GetAttempts() uint32

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

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

+ func (_m *ExecutableNodeStatus) GetMessage() string

+ func (_m *ExecutableNodeStatus) GetNodeExecutionStatus(id string) v1alpha1.ExecutableNodeStatus

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

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

+ func (_m *ExecutableNodeStatus) GetOrCreateSubWorkflowStatus() v1alpha1.MutableSubWorkflowNodeStatus

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

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

+ 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) GetSubWorkflowNodeStatus() v1alpha1.ExecutableSubWorkflowNodeStatus

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

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

+ func (_m *ExecutableNodeStatus) IncrementAttempts() uint32

+ func (_m *ExecutableNodeStatus) IsCached() bool

+ func (_m *ExecutableNodeStatus) IsDirty() bool

+ func (_m *ExecutableNodeStatus) ResetDirty()

+ func (_m *ExecutableNodeStatus) SetCached()

+ func (_m *ExecutableNodeStatus) SetDataDir(_a0 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 ExecutableSubWorkflow struct

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

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

+ func (_m *ExecutableSubWorkflow) GetID() string

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

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

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

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

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

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

+ type ExecutableSubWorkflowNodeStatus struct

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

+ type ExecutableTask struct

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

+ func (_m *ExecutableTask) TaskType() string

+ type ExecutableTaskNodeStatus struct

+ func (_m *ExecutableTaskNodeStatus) GetCustomState() map[string]interface{}

+ func (_m *ExecutableTaskNodeStatus) GetPhase() types.TaskPhase

+ func (_m *ExecutableTaskNodeStatus) GetPhaseVersion() uint32

+ type ExecutableWorkflow struct

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

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

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

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

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

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

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

+ func (_m *ExecutableWorkflow) GetID() string

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

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

+ func (_m *ExecutableWorkflow) GetName() string

+ func (_m *ExecutableWorkflow) GetNamespace() string

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

+ func (_m *ExecutableWorkflow) GetNodeExecutionStatus(id string) v1alpha1.ExecutableNodeStatus

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

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

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

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

+ func (_m *ExecutableWorkflow) GetServiceAccountName() string

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

+ func (_m *ExecutableWorkflow) NewControllerRef() v1.OwnerReference

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

+ type ExecutableWorkflowNode struct

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

+ func (_m *ExecutableWorkflowNode) GetSubWorkflowRef() *string

+ type ExecutableWorkflowNodeStatus struct

+ func (_m *ExecutableWorkflowNodeStatus) GetWorkflowExecutionName() string

+ type ExecutableWorkflowStatus struct

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

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

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

+ func (_m *ExecutableWorkflowStatus) GetMessage() string

+ func (_m *ExecutableWorkflowStatus) GetNodeExecutionStatus(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) SetDataDir(_a0 storage.DataReference)

+ func (_m *ExecutableWorkflowStatus) SetMessage(msg string)

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

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

+ type MutableBranchNodeStatus struct

+ func (_m *MutableBranchNodeStatus) GetFinalizedNode() *string

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

+ func (_m *MutableBranchNodeStatus) SetBranchNodeError()

+ func (_m *MutableBranchNodeStatus) SetBranchNodeSuccess(id string)

+ type MutableDynamicNodeStatus struct

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

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

+ type MutableNodeStatus struct

+ func (_m *MutableNodeStatus) ClearDynamicNodeStatus()

+ func (_m *MutableNodeStatus) ClearSubWorkflowStatus()

+ func (_m *MutableNodeStatus) ClearTaskStatus()

+ func (_m *MutableNodeStatus) ClearWorkflowStatus()

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

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

+ func (_m *MutableNodeStatus) GetOrCreateSubWorkflowStatus() v1alpha1.MutableSubWorkflowNodeStatus

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

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

+ func (_m *MutableNodeStatus) IncrementAttempts() uint32

+ func (_m *MutableNodeStatus) ResetDirty()

+ func (_m *MutableNodeStatus) SetCached()

+ func (_m *MutableNodeStatus) SetDataDir(_a0 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 MutableSubWorkflowNodeStatus struct

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

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

+ type MutableTaskNodeStatus struct

+ func (_m *MutableTaskNodeStatus) GetCustomState() map[string]interface{}

+ func (_m *MutableTaskNodeStatus) GetPhase() types.TaskPhase

+ func (_m *MutableTaskNodeStatus) GetPhaseVersion() uint32

+ func (_m *MutableTaskNodeStatus) SetCustomState(state map[string]interface{})

+ func (_m *MutableTaskNodeStatus) SetPhase(phase types.TaskPhase)

+ func (_m *MutableTaskNodeStatus) SetPhaseVersion(version uint32)

+ type MutableWorkflowNodeStatus struct

+ func (_m *MutableWorkflowNodeStatus) GetWorkflowExecutionName() string

+ func (_m *MutableWorkflowNodeStatus) SetWorkflowExecutionName(name string)

+ type NodeStatusGetter struct

+ func (_m *NodeStatusGetter) GetNodeExecutionStatus(id string) v1alpha1.ExecutableNodeStatus

+ type NodeStatusVisitor struct

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

+ type WorkflowMeta struct

+ 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) GetServiceAccountName() string

+ func (_m *WorkflowMeta) NewControllerRef() v1.OwnerReference

+ type WorkflowMetaExtended struct

+ 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) GetServiceAccountName() string

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

+ func (_m *WorkflowMetaExtended) NewControllerRef() v1.OwnerReference