compiler

package

Go to main page

Versions in this module

v0

v0.1.5

Oct 14, 2026

Changes in this version

+ func FilterRequestParamByHandles(requestParam map[string]any, inputs map[string]any) map[string]any

type CompileContext

+ RequestParam map[string]any

type NodeRuntimeState

+ RequestParam map[string]any

v0.1.4

Sep 19, 2026

v0.1.3

Sep 1, 2026

v0.1.2

Aug 31, 2026

v0.1.1

Aug 27, 2026

Changes in this version

+ func BuildRuntimeTasks(analysisID int64, params map[string]any, dagDefinition map[string]any) (map[string]any, error)

+ type ClassifyStage struct

+ func (s *ClassifyStage) Name() string

+ func (s *ClassifyStage) Run(ctx *CompileContext) error

+ type CompileContext struct

+ Abort bool

+ AnalysisEdges []map[string]any

+ AnalysisID int64

+ AnalysisNodes []map[string]any

+ Dag map[string]any

+ Edges []map[string]any

+ Incoming map[string][]map[string]any

+ NodeKind map[string]string

+ NodeLabel map[string][]string

+ NodeMap map[string]map[string]any

+ NodeSamplesMap map[string]map[string]map[string]any

+ NodeStates map[string][]*NodeRuntimeState

+ Nodes []map[string]any

+ Order []string

+ Outgoing map[string][]map[string]any

+ OutputCache map[cacheKey]any

+ Params map[string]any

+ StateOrder []*NodeRuntimeState

+ func NewCompileContext(analysisID int64, params map[string]any, dagDefinition map[string]any) *CompileContext

+ type DecorateStage struct

+ func (s *DecorateStage) Name() string

+ func (s *DecorateStage) Run(ctx *CompileContext) error

+ type EdgeStage struct

+ func (s *EdgeStage) Name() string

+ func (s *EdgeStage) Run(ctx *CompileContext) error

+ type EdgeStrategy interface

+ Build func(ctx *CompileContext, nid string, node map[string]any, ...) []map[string]any

+ type ExpandStage struct

+ func (s *ExpandStage) Name() string

+ func (s *ExpandStage) Run(ctx *CompileContext) error

+ type NodeExpandStrategy interface

+ Expand func(ctx *CompileContext, nid string, node map[string]any) ([]*NodeRuntimeState, error)

+ type NodeRuntimeState struct

+ InputErrors []string

+ Inputs map[string]any

+ Kind string

+ MaxRetry int

+ Node map[string]any

+ NodeID string

+ NodeIDBase string

+ NodeName string

+ NodeParams map[string]any

+ OriginalNodeID string

+ Outputs map[string]any

+ ResolvedInputs map[string]any

+ ResolvedOutput map[string]any

+ Sample map[string]any

+ SampleLabel string

+ ScriptID string

+ type OutputStage struct

+ func (s *OutputStage) Name() string

+ func (s *OutputStage) Run(ctx *CompileContext) error

+ type ResolveStage struct

+ func (s *ResolveStage) Name() string

+ func (s *ResolveStage) Run(ctx *CompileContext) error

+ type ResolveStrategy interface

+ Resolve func(ctx *CompileContext, state *NodeRuntimeState) error

+ type RuntimeCompiler struct

+ func NewRuntimeCompiler() *RuntimeCompiler

+ func (c *RuntimeCompiler) Compile(analysisID int64, params map[string]any, dagDefinition map[string]any) (map[string]any, error)

+ type RuntimeEdgeBuilder struct

+ func (b *RuntimeEdgeBuilder) Build(analysisID int64, sourceNode string, targetNode string, sourceHandle string, ...) map[string]any

+ type RuntimeNodeBuilder struct

+ func (b *RuntimeNodeBuilder) Build(ctx *CompileContext, state *NodeRuntimeState) map[string]any

+ type SampleEdgeStrategy struct

+ func (s *SampleEdgeStrategy) Build(ctx *CompileContext, nid string, node map[string]any, ...) []map[string]any

+ type SampleExpandStrategy struct

+ func (s *SampleExpandStrategy) Expand(ctx *CompileContext, nid string, node map[string]any) ([]*NodeRuntimeState, error)

+ type SampleResolveStrategy struct

+ func (s *SampleResolveStrategy) Resolve(ctx *CompileContext, state *NodeRuntimeState) error

+ type SingletonEdgeStrategy struct

+ func (s *SingletonEdgeStrategy) Build(ctx *CompileContext, nid string, node map[string]any, ...) []map[string]any

+ type SingletonExpandStrategy struct

+ func (s *SingletonExpandStrategy) Expand(ctx *CompileContext, nid string, node map[string]any) ([]*NodeRuntimeState, error)

+ type SingletonResolveStrategy struct

+ func (s *SingletonResolveStrategy) Resolve(ctx *CompileContext, state *NodeRuntimeState) error

+ type Stage interface

+ Name func() string

+ Run func(ctx *CompileContext) error

+ type TopologyStage struct

+ func (s *TopologyStage) Name() string

+ func (s *TopologyStage) Run(ctx *CompileContext) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL