handler

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Feb 21, 2024 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 

type ArrayNodeInfo struct {
}

type ArrayNodeState 

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 

type BranchNodeInfo struct {
}

type BranchNodeState 

type BranchNodeState struct {
	FinalizedNodeID *v1alpha1.NodeID
	Phase           v1alpha1.BranchNodePhase
}

type DynamicNodeInfo 

type DynamicNodeInfo struct {
}

type DynamicNodePhase 

type DynamicNodePhase uint8

type DynamicNodeState 

type DynamicNodeState struct {
	Phase              v1alpha1.DynamicNodePhase
	Reason             string
	Error              *core.ExecutionError
	IsFailurePermanent bool
}

type EPhase 

type EPhase uint8
const (
	EPhaseUndefined EPhase = iota
	EPhaseNotReady
	EPhaseQueued
	EPhaseRunning
	EPhaseSkip
	EPhaseFailed
	EPhaseRetryableFailure
	EPhaseSuccess
	EPhaseTimedout
	EPhaseFailing
	EPhaseDynamicRunning
	EPhaseRecovered
)

func EPhaseString 

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 

func EPhaseValues() []EPhase

EPhaseValues returns all values of the enum

func (EPhase) IsAEPhase 

func (i EPhase) IsAEPhase() bool

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

func (EPhase) IsTerminal 

func (p EPhase) IsTerminal() bool

func (EPhase) String 

func (i EPhase) String() string

type ExecutionInfo 

type ExecutionInfo struct {
	DynamicNodeInfo  *DynamicNodeInfo
	WorkflowNodeInfo *WorkflowNodeInfo
	BranchNodeInfo   *BranchNodeInfo
	Inputs           *core.LiteralMap
	OutputInfo       *OutputInfo
	TaskNodeInfo     *TaskNodeInfo
	GateNodeInfo     *GateNodeInfo
	ArrayNodeInfo    *ArrayNodeInfo
}

type GateNodeInfo 

type GateNodeInfo struct {
}

type GateNodeState 

type GateNodeState struct {
	Phase     v1alpha1.GateNodePhase
	StartedAt time.Time
}

type OutputInfo 

type OutputInfo struct {
	OutputURI storage.DataReference
	DeckURI   *storage.DataReference
}

type PhaseInfo 

type PhaseInfo struct {
	// contains filtered or unexported fields
}

func PhaseInfoDynamicRunning 

func PhaseInfoDynamicRunning(info *ExecutionInfo) PhaseInfo

func PhaseInfoFailingErr 

func PhaseInfoFailingErr(err *core.ExecutionError, info *ExecutionInfo) PhaseInfo

func PhaseInfoFailure 

func PhaseInfoFailure(kind core.ExecutionError_ErrorKind, code, reason string, info *ExecutionInfo) PhaseInfo

func PhaseInfoFailureErr 

func PhaseInfoFailureErr(err *core.ExecutionError, info *ExecutionInfo) PhaseInfo

func PhaseInfoNotReady 

func PhaseInfoNotReady(reason string) PhaseInfo

func PhaseInfoQueued 

func PhaseInfoQueued(reason string, inputs *core.LiteralMap) PhaseInfo

func PhaseInfoRecovered 

func PhaseInfoRecovered(info *ExecutionInfo) PhaseInfo

func PhaseInfoRetryableFailure 

func PhaseInfoRetryableFailure(kind core.ExecutionError_ErrorKind, code, reason string, info *ExecutionInfo) PhaseInfo

func PhaseInfoRetryableFailureErr 

func PhaseInfoRetryableFailureErr(err *core.ExecutionError, info *ExecutionInfo) PhaseInfo

func PhaseInfoRunning 

func PhaseInfoRunning(info *ExecutionInfo) PhaseInfo

func PhaseInfoSkip 

func PhaseInfoSkip(info *ExecutionInfo, reason string) PhaseInfo

func PhaseInfoSuccess 

func PhaseInfoSuccess(info *ExecutionInfo) PhaseInfo

func PhaseInfoTimedOut 

func PhaseInfoTimedOut(info *ExecutionInfo, reason string) PhaseInfo

func (PhaseInfo) GetErr 

func (p PhaseInfo) GetErr() *core.ExecutionError

func (PhaseInfo) GetInfo 

func (p PhaseInfo) GetInfo() *ExecutionInfo

func (PhaseInfo) GetOccurredAt 

func (p PhaseInfo) GetOccurredAt() time.Time

func (PhaseInfo) GetPhase 

func (p PhaseInfo) GetPhase() EPhase

func (PhaseInfo) GetReason 

func (p PhaseInfo) GetReason() string

func (PhaseInfo) WithInfo 

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

func (PhaseInfo) WithOccuredAt 

func (p PhaseInfo) WithOccuredAt(t time.Time) PhaseInfo

type TaskNodeInfo 

type TaskNodeInfo struct {
	TaskNodeMetadata *event.TaskNodeMetadata
}

Carries any information that should be sent as part of NodeEvents

type TaskNodeState 

type TaskNodeState struct {
	PluginPhase                        pluginCore.Phase
	PluginPhaseVersion                 uint32
	PluginState                        []byte
	PluginStateVersion                 uint32
	LastPhaseUpdatedAt                 time.Time
	PreviousNodeExecutionCheckpointURI storage.DataReference
	CleanupOnFailure                   bool
}

type Transition 

type Transition struct {
	// contains filtered or unexported fields
}

func DoTransition 

func DoTransition(ttype TransitionType, info PhaseInfo) Transition

func (Transition) Info 

func (t Transition) Info() PhaseInfo

func (Transition) Type 

func (t Transition) Type() TransitionType

func (Transition) WithInfo 

func (t Transition) WithInfo(p PhaseInfo) Transition

type TransitionType 

type TransitionType int
const (
	TransitionTypeEphemeral TransitionType = iota
	// @deprecated support for Barrier type transitions has been deprecated
	TransitionTypeBarrier
)

type WorkflowNodeInfo 

type WorkflowNodeInfo struct {
	LaunchedWorkflowID *core.WorkflowExecutionIdentifier
}

type WorkflowNodeState 

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.