Versions in this module Expand all Collapse all v3 v3.9.0 Oct 6, 2026 v3.8.0 Sep 28, 2026 v3.7.1 Sep 8, 2026 v3.7.0 Sep 4, 2026 Changes in this version + func AssignRanks(id string, depth int, nodes map[string]GraphNode, ...) + func GetAllLogKeys(node GraphNode) []string + func GetLogKey(node GraphNode) string + func HasLogs(node GraphNode) bool + func NodeName(node GraphNode) string + func ReUnmarshal[T any](data any) (T, error) + type AdjacencyEntry struct + Children []string + NextIDs []string + type AsyncChainExecutableResponse struct + CallbackID string + CallbackIDs []string + ChainEnd bool + LogKeys []string + Status string + Timeout int64 + Units []string + type AsyncExecutableResponse struct + CallbackIDs []string + LogKeys []string + ShouldRemoveAlreadyProcessedNotifyIDs bool + Status string + Timeout int64 + Units []string + type ChildChainExecutableResponse struct + LastLink bool + NextChildID string + PreviousChildID string + Suspend bool + type ChildExecutableResponse struct + ChildNodeID string + LogKeys []string + Skip bool + Units []string + type ChildPipelineExecutionDetails struct + OrgID string + PlanExecutionID string + ProjectID string + type ChildrenExecutableResponse struct + LogKeys []string + MaxConcurrency int64 + ShouldProceedIfFailed bool + Units []string + type DelegateInfo struct + Name string + type ExecutableResponse struct + Async *AsyncExecutableResponse + AsyncChain *AsyncChainExecutableResponse + Child *ChildExecutableResponse + ChildChain *ChildChainExecutableResponse + Children *ChildrenExecutableResponse + Facilitator *FacilitatorExecutableResponse + ResponseCase string + SkipTask *SkipTaskExecutableResponse + Sync *SyncExecutableResponse + Task *TaskExecutableResponse + TaskChain *TaskChainExecutableResponse + type ExecutionFull struct + EndTs int64 + Graph ExecutionGraph + PipelineStatus string + StartTs int64 + func FetchExecutionFull(ctx *cmdctx.Ctx, execId string) (ExecutionFull, error) + type ExecutionGraph struct + NodeAdjacencyListMap map[string]AdjacencyEntry + NodeMap map[string]GraphNode + RootNodeID string + func FetchExecutionGraph(ctx *cmdctx.Ctx, execId string) (ExecutionGraph, error) + type FacilitatorExecutableResponse struct + CallbackIDs []string + StartTs int64 + Status string + TimeoutInSeconds int64 + Type string + type FailureInfo struct + Message string + type GraphNode struct + BaseFQN string + DelegateInfoList []DelegateInfo + Depth int + EndTs int64 + ExecutableResponses []ExecutableResponse + FailureInfo FailureInfo + Identifier string + LogBaseKey string + Name string + Outcomes map[string]any + Rank int + Raw json.RawMessage + SetupID string + StartTs int64 + Status string + StepDetails StepDetails + StepParameters json.RawMessage + StepType string + UUID string + func WalkNodes(g ExecutionGraph, skipTypes map[string]bool) []GraphNode + func (n *GraphNode) UnmarshalJSON(data []byte) error + func (n GraphNode) ToMap() map[string]any + type LogUnit struct + Key string + Unit string + func GetLogUnits(node GraphNode) []LogUnit + type SkipTaskExecutableResponse struct + Message string + type StepDetails struct + ChildPipelineExecutionDetails ChildPipelineExecutionDetails + type SyncExecutableResponse struct + LogKeys []string + Units []string + type TaskChainExecutableResponse struct + ChainEnd bool + LogKeys []string + TaskCategory string + TaskID string + TaskName string + Units []string + type TaskExecutableResponse struct + LogKeys []string + TaskCategory string + TaskID string + TaskName string + Units []string
Go to main page