compiler

type ClassifyStage struct{}

type CompileContext struct {
	AnalysisID int64
	Params     map[string]any
	Dag        map[string]any
	Abort      bool

	Nodes []map[string]any
	Edges []map[string]any

	NodeMap   map[string]map[string]any
	Incoming  map[string][]map[string]any
	Outgoing  map[string][]map[string]any
	Order     []string
	NodeKind  map[string]string
	NodeLabel map[string][]string

	NodeSamplesMap map[string]map[string]map[string]any
	OutputCache    map[cacheKey]any
	NodeStates     map[string][]*NodeRuntimeState
	StateOrder     []*NodeRuntimeState

	AnalysisNodes []map[string]any
	AnalysisEdges []map[string]any
}

type DecorateStage struct{}

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

type EdgeStrategy interface {
	Build(ctx *CompileContext, nid string, node map[string]any, states []*NodeRuntimeState, builder *RuntimeEdgeBuilder) []map[string]any
}

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

type NodeExpandStrategy interface {
	Expand(ctx *CompileContext, nid string, node map[string]any) ([]*NodeRuntimeState, error)
}

type NodeRuntimeState struct {
	OriginalNodeID string
	Node           map[string]any
	Kind           string
	NodeIDBase     string
	NodeID         string
	NodeName       string
	ScriptID       string
	SampleLabel    string
	Sample         map[string]any
	Inputs         map[string]any
	Outputs        map[string]any
	NodeParams     map[string]any
	ResolvedInputs map[string]any
	ResolvedOutput map[string]any
	InputErrors    []string
	MaxRetry       int
}

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

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

type ResolveStrategy interface {
	Resolve(ctx *CompileContext, state *NodeRuntimeState) error
}

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

type RuntimeEdgeBuilder struct{}

type RuntimeNodeBuilder struct{}

type SampleEdgeStrategy struct{}

type SampleExpandStrategy struct{}

type SampleResolveStrategy struct{}

type SingletonEdgeStrategy struct{}

type SingletonExpandStrategy struct{}

type SingletonResolveStrategy struct{}

type Stage interface {
	Name() string
	Run(ctx *CompileContext) error
}

type TopologyStage struct{}