Documentation
¶
Index ¶
- Variables
- type ArrayNodeInfo
- type ArrayNodeState
- type BranchNodeInfo
- type BranchNodeState
- type DynamicNodeInfo
- type DynamicNodePhase
- type DynamicNodeState
- type EPhase
- type ExecutionInfo
- type GateNodeInfo
- type GateNodeState
- type OutputInfo
- type PhaseInfo
- func PhaseInfoDynamicRunning(info *ExecutionInfo) PhaseInfo
- func PhaseInfoFailingErr(err *core.ExecutionError, info *ExecutionInfo) PhaseInfo
- func PhaseInfoFailure(kind core.ExecutionError_ErrorKind, code, reason string, info *ExecutionInfo) PhaseInfo
- func PhaseInfoFailureErr(err *core.ExecutionError, info *ExecutionInfo) PhaseInfo
- func PhaseInfoNotReady(reason string) PhaseInfo
- func PhaseInfoQueued(reason string, inputs *core.LiteralMap) PhaseInfo
- func PhaseInfoRecovered(info *ExecutionInfo) PhaseInfo
- func PhaseInfoRetryableFailure(kind core.ExecutionError_ErrorKind, code, reason string, info *ExecutionInfo) PhaseInfo
- func PhaseInfoRetryableFailureErr(err *core.ExecutionError, info *ExecutionInfo) PhaseInfo
- func PhaseInfoRunning(info *ExecutionInfo) PhaseInfo
- func PhaseInfoSkip(info *ExecutionInfo, reason string) PhaseInfo
- func PhaseInfoSuccess(info *ExecutionInfo) PhaseInfo
- func PhaseInfoTimedOut(info *ExecutionInfo, reason string) PhaseInfo
- func (p PhaseInfo) GetErr() *core.ExecutionError
- func (p PhaseInfo) GetInfo() *ExecutionInfo
- func (p PhaseInfo) GetOccurredAt() time.Time
- func (p PhaseInfo) GetPhase() EPhase
- func (p PhaseInfo) GetReason() string
- func (p PhaseInfo) WithInfo(i *ExecutionInfo) PhaseInfo
- func (p PhaseInfo) WithOccuredAt(t time.Time) PhaseInfo
- type TaskNodeInfo
- type TaskNodeState
- type Transition
- type TransitionType
- type WorkflowNodeInfo
- type WorkflowNodeState
Constants ¶
This section is empty.
Variables ¶
View Source
var PhaseInfoUndefined = PhaseInfo{/* contains filtered or unexported fields */}
View Source
var UnknownTransition = Transition{TransitionTypeEphemeral, PhaseInfoUndefined}
Functions ¶
This section is empty.
Types ¶
type ArrayNodeInfo ¶ added in v1.1.111
type ArrayNodeInfo struct {
}
type ArrayNodeState ¶ added in v1.1.111
type ArrayNodeState struct {
Phase v1alpha1.ArrayNodePhase
TaskPhaseVersion uint32
Error *core.ExecutionError
SubNodePhases bitarray.CompactArray
SubNodeTaskPhases bitarray.CompactArray
SubNodeRetryAttempts bitarray.CompactArray
SubNodeSystemFailures bitarray.CompactArray
}
type BranchNodeInfo ¶ added in v0.1.13
type BranchNodeInfo struct {
}
type BranchNodeState ¶ added in v0.1.13
type BranchNodeState struct {
FinalizedNodeID *v1alpha1.NodeID
Phase v1alpha1.BranchNodePhase
}
type DynamicNodeInfo ¶ added in v0.1.13
type DynamicNodeInfo struct {
}
type DynamicNodePhase ¶ added in v0.1.13
type DynamicNodePhase uint8
type DynamicNodeState ¶ added in v0.1.13
type DynamicNodeState struct {
Phase v1alpha1.DynamicNodePhase
Reason string
Error *core.ExecutionError
IsFailurePermanent bool
}
type EPhase ¶ added in v0.1.13
type EPhase uint8
func EPhaseString ¶ added in v0.7.0
EPhaseString retrieves an enum value from the enum constants string name. Throws an error if the param is not part of the enum.
func EPhaseValues ¶ added in v0.7.0
func EPhaseValues() []EPhase
EPhaseValues returns all values of the enum
func (EPhase) IsAEPhase ¶ added in v0.7.0
IsAEPhase returns "true" if the value is listed in the enum definition. "false" otherwise
func (EPhase) IsTerminal ¶ added in v0.1.13
type ExecutionInfo ¶ added in v0.1.13
type ExecutionInfo struct {
DynamicNodeInfo *DynamicNodeInfo
WorkflowNodeInfo *WorkflowNodeInfo
BranchNodeInfo *BranchNodeInfo
Inputs *core.LiteralMap
OutputInfo *OutputInfo
TaskNodeInfo *TaskNodeInfo
GateNodeInfo *GateNodeInfo
ArrayNodeInfo *ArrayNodeInfo
}
type GateNodeInfo ¶ added in v1.1.51
type GateNodeInfo struct {
}
type GateNodeState ¶ added in v1.1.51
type GateNodeState struct {
Phase v1alpha1.GateNodePhase
StartedAt time.Time
}
type OutputInfo ¶ added in v0.1.13
type OutputInfo struct {
OutputURI storage.DataReference
DeckURI *storage.DataReference
}
type PhaseInfo ¶ added in v0.1.13
type PhaseInfo struct {
// contains filtered or unexported fields
}
func PhaseInfoDynamicRunning ¶ added in v0.10.5
func PhaseInfoDynamicRunning(info *ExecutionInfo) PhaseInfo
func PhaseInfoFailingErr ¶ added in v0.7.0
func PhaseInfoFailingErr(err *core.ExecutionError, info *ExecutionInfo) PhaseInfo
func PhaseInfoFailure ¶ added in v0.1.13
func PhaseInfoFailure(kind core.ExecutionError_ErrorKind, code, reason string, info *ExecutionInfo) PhaseInfo
func PhaseInfoFailureErr ¶ added in v0.1.13
func PhaseInfoFailureErr(err *core.ExecutionError, info *ExecutionInfo) PhaseInfo
func PhaseInfoNotReady ¶ added in v0.1.13
func PhaseInfoQueued ¶ added in v0.1.13
func PhaseInfoQueued(reason string, inputs *core.LiteralMap) PhaseInfo
func PhaseInfoRecovered ¶ added in v0.13.3
func PhaseInfoRecovered(info *ExecutionInfo) PhaseInfo
func PhaseInfoRetryableFailure ¶ added in v0.1.13
func PhaseInfoRetryableFailure(kind core.ExecutionError_ErrorKind, code, reason string, info *ExecutionInfo) PhaseInfo
func PhaseInfoRetryableFailureErr ¶ added in v0.1.13
func PhaseInfoRetryableFailureErr(err *core.ExecutionError, info *ExecutionInfo) PhaseInfo
func PhaseInfoRunning ¶ added in v0.1.13
func PhaseInfoRunning(info *ExecutionInfo) PhaseInfo
func PhaseInfoSkip ¶ added in v0.1.13
func PhaseInfoSkip(info *ExecutionInfo, reason string) PhaseInfo
func PhaseInfoSuccess ¶ added in v0.1.13
func PhaseInfoSuccess(info *ExecutionInfo) PhaseInfo
func PhaseInfoTimedOut ¶ added in v0.1.17
func PhaseInfoTimedOut(info *ExecutionInfo, reason string) PhaseInfo
func (PhaseInfo) GetErr ¶ added in v0.1.13
func (p PhaseInfo) GetErr() *core.ExecutionError
func (PhaseInfo) GetInfo ¶ added in v0.1.13
func (p PhaseInfo) GetInfo() *ExecutionInfo
func (PhaseInfo) GetOccurredAt ¶ added in v0.1.13
func (PhaseInfo) WithInfo ¶ added in v0.7.0
func (p PhaseInfo) WithInfo(i *ExecutionInfo) PhaseInfo
type TaskNodeInfo ¶ added in v0.1.13
type TaskNodeInfo struct {
TaskNodeMetadata *event.TaskNodeMetadata
}
Carries any information that should be sent as part of NodeEvents
type TaskNodeState ¶ added in v0.1.13
type TaskNodeState struct {
PluginPhase pluginCore.Phase
PluginPhaseVersion uint32
PluginState []byte
PluginStateVersion uint32
LastPhaseUpdatedAt time.Time
PreviousNodeExecutionCheckpointURI storage.DataReference
CleanupOnFailure bool
}
type Transition ¶ added in v0.1.13
type Transition struct {
// contains filtered or unexported fields
}
func DoTransition ¶ added in v0.1.13
func DoTransition(ttype TransitionType, info PhaseInfo) Transition
func (Transition) Info ¶ added in v0.1.13
func (t Transition) Info() PhaseInfo
func (Transition) Type ¶ added in v0.1.13
func (t Transition) Type() TransitionType
func (Transition) WithInfo ¶ added in v0.1.13
func (t Transition) WithInfo(p PhaseInfo) Transition
type TransitionType ¶ added in v0.1.13
type TransitionType int
const ( TransitionTypeEphemeral TransitionType = iota // @deprecated support for Barrier type transitions has been deprecated TransitionTypeBarrier )
type WorkflowNodeInfo ¶ added in v0.1.13
type WorkflowNodeInfo struct {
LaunchedWorkflowID *core.WorkflowExecutionIdentifier
}
type WorkflowNodeState ¶ added in v0.1.13
type WorkflowNodeState struct {
Phase v1alpha1.WorkflowNodePhase
Error *core.ExecutionError
}
Click to show internal directories.
Click to hide internal directories.