handler

type ArrayNodeInfo struct {
}

type ArrayNodeState struct {
	Phase                  v1alpha1.ArrayNodePhase
	TaskPhaseVersion       uint32
	Error                  *core.ExecutionError
	SubNodePhases          bitarray.CompactArray
	SubNodeTaskPhases      bitarray.CompactArray
	SubNodeRetryAttempts   bitarray.CompactArray
	SubNodeSystemFailures  bitarray.CompactArray
	SubNodeDeltaTimestamps bitarray.CompactArray
}

type BranchNodeInfo struct {
}

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

type DynamicNodeInfo struct {
}

type DynamicNodePhase uint8

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

type EPhase uint8

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

type GateNodeInfo struct {
}

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

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

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

type TaskNodeInfo struct {
	TaskNodeMetadata *event.TaskNodeMetadata
}

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

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

type TransitionType int

type WorkflowNodeInfo struct {
	LaunchedWorkflowID *core.WorkflowExecutionIdentifier
}

type WorkflowNodeState struct {
	Phase v1alpha1.WorkflowNodePhase
	Error *core.ExecutionError
}