Versions in this module Expand all Collapse all v0 v0.0.1 Mar 12, 2024 Changes in this version + const TpNone + func InitMsgProcessor(m map[string]MsgToErr) + func LinkName(outNode, outPoint, inNode, inPoint string) string + func NewNode(g IGraph, name string) *node + type Conf struct + Comment string + Links []LinkConf + Name string + Nodes []NodeConf + SubGraphs []SubConf + type IGraph interface + AddNode func(name string) (INode, *util.Err) + AddSubGraph func(name string) (ISubGraph, *util.Err) + AnyLink func(fn func(ILink) bool) bool + AnyNode func(fn func(INode) bool) bool + AnySubGraph func(fn func(ISubGraph) bool) bool + Data func() util.M + FindNode func(name string) (INode, bool) + FindNodes func(name string, nodes *[]INode) + GetNode func(name string) (INode, *util.Err) + GetNodeByPath func(names ...string) (INode, *util.Err) + GetSubGraph func(graph string) (ISubGraph, *util.Err) + IterLink func(fn func(ILink)) + IterNode func(fn func(INode)) + IterSubGraph func(fn func(ISubGraph)) + Link func(outNode, outPoint, inNode, inPoint string) (ILink, *util.Err) + Name func() string + Plugin func() IPlugin + SetData func(m util.M) + SetPlugin func(plugin IPlugin) + Start func() *util.Err + func NewGraph(name string, opts ...Option) IGraph + func NewGraphWithConf(conf Conf, opts ...Option) IGraph + type IGraphElem interface + AddAfterEnable func(fn util.FnBool) + AddBeforeEnable func(fn util.BoolToErr) + Comment func() string + Data func() util.M + DelAfterEnable func(fn util.FnBool) + DelBeforeEnable func(fn util.BoolToErr) + Disable func() *util.Err + Enable func() *util.Err + Enabled func() bool + Graph func() IGraph + Name func() string + Path func() string + RootGraph func() IGraph + SetComment func(c string) + SetData func(data util.M) + SetEnable func(enable bool) *util.Err + Start func() *util.Err + type IGraphMarshall interface + type IGraphMarshaller interface + Marshall func(g IGraph) []byte + type IGraphUnMarshaller interface + Unmarshall func(bytes []byte, g IGraph) *util.Err + type IIn interface + Receive func(msg IMsg) *util.Err + type ILink interface + AddFilter func(fn func(IMsg) *util.Err) + In func() IIn + Out func() IOut + Transfer func(msg IMsg) *util.Err + func LinkWithConf(g IGraph, conf LinkConf) (ILink, *util.Err) + type IMsg interface + Data func() any + InNode func() INode + InPoint func() string + OutNode func() string + OutPoint func() string + SetInNode func(inNode INode) + SetInPoint func(inPoint string) + ToJson func() ([]byte, *util.Err) + ToM func() util.M + Type func() TPoint + type INode interface + AddIn func(t TPoint, name string) *util.Err + AddOut func(t TPoint, name string) *util.Err + BindFn func(point string, fn MsgToErr) + GetIn func(name string) (IIn, *util.Err) + GetOut func(name string) (IOut, *util.Err) + HasIn func(name string) bool + HasOut func(name string) bool + Out func(name string, m any) *util.Err + ProcessData func(msg IMsg) *util.Err + func AddNodeWithConf(g IGraph, conf NodeConf) (INode, *util.Err) + type IOut interface + Send func(msg IMsg) *util.Err + type IPlugin interface + OnAddIn func(in IIn) + OnAddLink func(g IGraph, lnk ILink) + OnAddNode func(g IGraph, nd INode) + OnAddOut func(out IOut) + OnAddSubGraph func(g IGraph, sg ISubGraph) + OnStart func(g IGraph) + type IPoint interface + AddFilter func(func(IMsg) *util.Err) + AddLink func(lnk ILink) + GetLink func(name string) (ILink, *util.Err) + Node func() INode + Type func() TPoint + type ISubGraph interface + InNode func() INode + OutNode func() INode + SetInNode func(name string) *util.Err + SetOutNode func(name string) *util.Err + func AddSubGraphWithConf(g IGraph, conf SubConf) (ISubGraph, *util.Err) + type LinkConf struct + InNode string + InPoint string + OutNode string + OutPoint string + type LinkToBool func(ILink) bool + type Msg struct + func (m *Msg) Data() any + func (m *Msg) InNode() INode + func (m *Msg) InPoint() string + func (m *Msg) OutNode() string + func (m *Msg) OutPoint() string + func (m *Msg) SetInNode(inNode INode) + func (m *Msg) SetInPoint(inPoint string) + func (m *Msg) ToJson() ([]byte, *util.Err) + func (m *Msg) ToM() util.M + func (m *Msg) Type() TPoint + type MsgToBoolErr func(IMsg) (bool, *util.Err) + type MsgToErr func(IMsg) *util.Err + func GetMsgProcessor(t string) MsgToErr + type NodeConf struct + Comment string + Ins []PointConf + M util.M + Name string + Outs []PointConf + PointToProcessor map[string]string + type NodeStrToAnyErr func(INode, string) (any, bool) + type NodeToAnyBool func(INode) (any, bool) + type Option func(*option) + func Plugin(plugin IPlugin) Option + type PointConf struct + Comment string + Name string + Type TPoint + type StrLinkToBool func(string, ILink) bool + type SubConf struct + Comment string + In string + Links []LinkConf + Name string + Nodes []NodeConf + Out string + SubGraphs []SubConf + type TPoint string