graph

Documentation

Index

• type DAG
  • func BuildGraph(manifest *fh.Manifest) *DAG
  • func (dag *DAG) Run() error
  • func (dag *DAG) RunModule(selectedNode *NodeModule) error
• type ModuleStatus
• type NodeModule
  • func (nm *NodeModule) Export() error
  • func (nm *NodeModule) Run() ModuleStatus
• type OutputType
• type RuntimeContext

Types

type DAG

type DAG struct {
	Nodes  map[string]*NodeModule
	Edges  map[string][]string
	Sorted [][]*NodeModule
}

func BuildGraph

func BuildGraph(manifest *fh.Manifest) *DAG

func (*DAG) Run

func (dag *DAG) Run() error

func (*DAG) RunModule

func (dag *DAG) RunModule(selectedNode *NodeModule) error

type ModuleStatus

type ModuleStatus string

const (
	StatusPending ModuleStatus = "pending"
	StatusRunning ModuleStatus = "running"
	StatusSuccess ModuleStatus = "success"
	StatusFailed  ModuleStatus = "failed"
)

type NodeModule

type NodeModule struct {
	LuaManager *engine.LuaManager
	ModuleName string
	ScriptPath string
	Depends    []*NodeModule
	Children   []*NodeModule
	DataOutput string
	Adapter    string
	InArgs     map[string]any
	OutArgs    map[string]any
	Payloads   map[string]*df.Dataframe
	Status     ModuleStatus
	ExportFlag bool
	Context    *RuntimeContext
}

func (*NodeModule) Export

func (nm *NodeModule) Export() error

func (*NodeModule) Run

func (nm *NodeModule) Run() ModuleStatus

type OutputType

type OutputType string

type RuntimeContext

type RuntimeContext struct {
	Global map[string]any
}