handler

package
v1.1.129 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 29, 2023 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

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
const (
	EPhaseUndefined EPhase = iota
	EPhaseNotReady
	EPhaseQueued
	EPhaseRunning
	EPhaseSkip
	EPhaseFailed
	EPhaseRetryableFailure
	EPhaseSuccess
	EPhaseTimedout
	EPhaseFailing
	EPhaseDynamicRunning
	EPhaseRecovered
)

func EPhaseString added in v0.7.0 

func EPhaseString(s string) (EPhase, error)

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 

func (i EPhase) IsAEPhase() bool

IsAEPhase returns "true" if the value is listed in the enum definition. "false" otherwise

func (EPhase) IsTerminal added in v0.1.13 

func (p EPhase) IsTerminal() bool

func (EPhase) String added in v0.1.13 

func (i EPhase) String() string

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 PhaseInfoNotReady(reason string) PhaseInfo

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 (p PhaseInfo) GetOccurredAt() time.Time

func (PhaseInfo) GetPhase added in v0.1.13 

func (p PhaseInfo) GetPhase() EPhase

func (PhaseInfo) GetReason added in v0.1.13 

func (p PhaseInfo) GetReason() string

func (PhaseInfo) WithInfo added in v0.7.0 

func (p PhaseInfo) WithInfo(i *ExecutionInfo) PhaseInfo

func (PhaseInfo) WithOccuredAt added in v1.1.72 

func (p PhaseInfo) WithOccuredAt(t time.Time) 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
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.