workflow

Jul 7, 2022

Changes in this version

type Node

+ Cache bool

Jul 5, 2022

Changes in this version

+ type Analyzer interface

+ Analyze func(w Workflow, nodes map[string]RuntimeNode, fullscore float64) Result

+ func LoadAnalyzer(plugin string) (Analyzer, error)

+ type Bound struct

+ LabelIndex int

+ Name string

+ type Builder struct

+ func (r *Builder) AddEdge(from, frlabel, to, tolabel string)

+ func (r *Builder) AddInbound(group Groupname, field, to, tolabel string)

+ func (r *Builder) SetNode(name string, procName string, key bool)

+ func (r *Builder) WorkflowGraph() (*WorkflowGraph, error)

+ type DefaultAnalyzer struct

+ func (r DefaultAnalyzer) Analyze(w Workflow, nodes map[string]RuntimeNode, fullscore float64) Result

+ type Edge struct

+ From Outbound

+ To Inbound

+ type Groupname string

+ const Gstatic

+ const Gsubm

+ const Gsubt

+ const Gtests

+ type Inbound Bound

+ type Node struct

+ Key bool

+ ProcName string

+ type Outbound Bound

+ type Result struct

+ File []ResultFileDisplay

+ func (r Result) Byte() []byte

+ type ResultFileDisplay struct

+ Content string

+ Title string

+ func FileDisplay(path string, title string, len int) ResultFileDisplay

+ type ResultMeta struct

+ Fullscore float64

+ Memory utils.ByteValue

+ Property map[string]string

+ Score float64

+ Time time.Duration

+ Title string

+ type RuntimeNode struct

+ Attr map[string]string

+ Input []string

+ Output []string

+ Result *processor.Result

+ type Workflow struct

+ type WorkflowGraph struct

+ Edge []Edge

+ Inbound map[Groupname]*map[string][]Inbound

+ Node map[string]Node

+ func Load(serial []byte) (*WorkflowGraph, error)

+ func LoadFile(path string) (*WorkflowGraph, error)

+ func NewGraph() WorkflowGraph

+ func (r *WorkflowGraph) EdgeFrom(name string) []Edge

+ func (r *WorkflowGraph) EdgeTo(name string) []Edge

+ func (r *WorkflowGraph) Serialize() []byte