reactive

package module

Go to main page

Versions in this module

v0

v0.0.7

Jan 14, 2024

v0.0.6

Jan 14, 2024

Changes in this version

+ type BaseObject struct

+ Bus map[string]chan *rxlib.Message

+ Connections []*rxlib.Connection

+ EventBus *rxlib.EventBus

+ ID string

+ Inputs []*rxlib.Port

+ LastValue map[string]*rxlib.Port

+ Name string

+ Outputs []*rxlib.Port

+ PublishOnTopic bool

+ UUID string

+ func NewBaseObject(n *Info, bus *rxlib.EventBus) *BaseObject

+ func (n *BaseObject) AddConnection(connection *rxlib.Connection)

+ func (n *BaseObject) AddData(key string, data any)

+ func (n *BaseObject) AddOptions(opts *rxlib.Options)

+ func (n *BaseObject) AddRuntime(runtimeObjects map[string]rxlib.Object)

+ func (n *BaseObject) AddSchema()

+ func (n *BaseObject) AddServices()

+ func (n *BaseObject) AddSettings(settings *rxlib.Settings)

+ func (n *BaseObject) AddToObjectToRuntime(object rxlib.Object) rxlib.Object

+ func (n *BaseObject) BuildSchema(schema *schema.Generated)

+ func (n *BaseObject) BusChannel(inputID string) (chan *rxlib.Message, bool)

+ func (n *BaseObject) Delete()

+ func (n *BaseObject) GetAllInputValues() []*rxlib.Port

+ func (n *BaseObject) GetAllObjectValues() []*rxlib.ObjectValue

+ func (n *BaseObject) GetAllOutputValues() []*rxlib.Port

+ func (n *BaseObject) GetAllPortValues() []*rxlib.Port

+ func (n *BaseObject) GetApplicationUse() string

+ func (n *BaseObject) GetChildObject(uuid string) rxlib.Object

+ func (n *BaseObject) GetChildObjects() []rxlib.Object

+ func (n *BaseObject) GetChildsByType(objectID string) []rxlib.Object

+ func (n *BaseObject) GetConnections() []*rxlib.Connection

+ func (n *BaseObject) GetData() map[string]any

+ func (n *BaseObject) GetDataByKey(key string, out interface{}) error

+ func (n *BaseObject) GetDetails() *rxlib.Details

+ func (n *BaseObject) GetID() string

+ func (n *BaseObject) GetInput(id string) *rxlib.Port

+ func (n *BaseObject) GetInputs() []*rxlib.Port

+ func (n *BaseObject) GetMeta() *rxlib.Meta

+ func (n *BaseObject) GetObjectName() string

+ func (n *BaseObject) GetOptions() *rxlib.Options

+ func (n *BaseObject) GetOutputs() []*rxlib.Port

+ func (n *BaseObject) GetParentUUID() string

+ func (n *BaseObject) GetPluginName() string

+ func (n *BaseObject) GetPortValue(portID string) (*rxlib.Port, error)

+ func (n *BaseObject) GetPortValuesChildObject(uuid string) []*rxlib.Port

+ func (n *BaseObject) GetRuntimeObjects() map[string]rxlib.Object

+ func (n *BaseObject) GetSchema() *schema.Generated

+ func (n *BaseObject) GetSettings() *rxlib.Settings

+ func (n *BaseObject) GetUUID() string

+ func (n *BaseObject) HotFix() bool

+ func (n *BaseObject) Loaded() bool

+ func (n *BaseObject) MessageBus() map[string]chan *rxlib.Message

+ func (n *BaseObject) New(objectUUID, name string, bus *rxlib.EventBus, settings *rxlib.Settings) rxlib.Object

+ func (n *BaseObject) NewInputPort(id, name string, dataType rxlib.PortDataType)

+ func (n *BaseObject) NewOutputPort(id, name string, dataType rxlib.PortDataType)

+ func (n *BaseObject) NewPort(port *rxlib.Port)

+ func (n *BaseObject) NotLoaded() bool

+ func (n *BaseObject) PublishMessage(port *rxlib.Port, setLastValue ...bool)

+ func (n *BaseObject) RegisterChildObject(child rxlib.Object)

+ func (n *BaseObject) RemoveObjectFromRuntime()

+ func (n *BaseObject) SetDetails(details *rxlib.Details)

+ func (n *BaseObject) SetHotFix()

+ func (n *BaseObject) SetInputValue(id string, value interface{})

+ func (n *BaseObject) SetLastValue(port *rxlib.Port)

+ func (n *BaseObject) SetLastValueChildObject(uuid string, port *rxlib.Port)

+ func (n *BaseObject) SetLoaded(set bool)

+ func (n *BaseObject) Start()

+ func (n *BaseObject) SupportsServices() bool

+ func (n *BaseObject) UpdateConnections(connections []*rxlib.Connection)

+ func (n *BaseObject) UpdateSettings(settings *rxlib.Settings)

+ type BaseObjectInterface interface

+ AddConnection func(connection *rxlib.Connection)

+ AddData func(key string, data any)

+ AddOptions func(opts *rxlib.Options)

+ AddRuntime func(runtimeObjects map[string]rxlib.Object)

+ AddSchema func()

+ AddServices func()

+ AddSettings func(settings *rxlib.Settings)

+ AddToObjectToRuntime func(object rxlib.Object) rxlib.Object

+ BuildSchema func(schema *schema.Generated)

+ BusChannel func(inputID string) (chan *rxlib.Message, bool)

+ Delete func()

+ GetAllInputValues func() []*rxlib.Port

+ GetAllObjectValues func() []*rxlib.ObjectValue

+ GetAllOutputValues func() []*rxlib.Port

+ GetAllPortValues func() []*rxlib.Port

+ GetApplicationUse func() string

+ GetChildObject func(uuid string) rxlib.Object

+ GetChildObjects func() []rxlib.Object

+ GetChildsByType func(objectID string) []rxlib.Object

+ GetConnections func() []*rxlib.Connection

+ GetData func() map[string]any

+ GetDataByKey func(key string, out interface{}) error

+ GetDetails func() *rxlib.Details

+ GetID func() string

+ GetInput func(id string) *rxlib.Port

+ GetInputs func() []*rxlib.Port

+ GetMeta func() *rxlib.Meta

+ GetObjectName func() string

+ GetOptions func() *rxlib.Options

+ GetOutputs func() []*rxlib.Port

+ GetParentUUID func() string

+ GetPluginName func() string

+ GetPortValue func(portID string) (*rxlib.Port, error)

+ GetPortValuesChildObject func(uuid string) []*rxlib.Port

+ GetRuntimeObjects func() map[string]rxlib.Object

+ GetSchema func() *schema.Generated

+ GetSettings func() *rxlib.Settings

+ GetUUID func() string

+ HotFix func() bool

+ Loaded func() bool

+ MessageBus func() map[string]chan *rxlib.Message

+ NewPort func(port *rxlib.Port)

+ NotLoaded func() bool

+ PublishMessage func(port *rxlib.Port, setLastValue ...bool)

+ RegisterChildObject func(child rxlib.Object)

+ RemoveObjectFromRuntime func()

+ SetDetails func(details *rxlib.Details)

+ SetHotFix func()

+ SetInputValue func(id string, value interface{})

+ SetLastValue func(port *rxlib.Port)

+ SetLastValueChildObject func(uuid string, port *rxlib.Port)

+ SetLoaded func(set bool)

+ Start func()

+ SupportsServices func() bool

+ UpdateConnections func(connections []*rxlib.Connection)

+ UpdateSettings func(settings *rxlib.Settings)

type Info

+ ObjectID string

+ ObjectUUID string

+ func ObjectInfo(s ...string) *Info

v0.0.5

Jan 12, 2024

Changes in this version

type BaseNode

+ func (n *BaseNode) AddDB(db *gorm.DB)

+ func (n *BaseNode) AddData(key string, data any)

+ func (n *BaseNode) AddLogger(logger *logrus.Logger)

+ func (n *BaseNode) AddOptions(opts *Options)

+ func (n *BaseNode) AddSchema()

+ func (n *BaseNode) GetApplicationUse() string

+ func (n *BaseNode) GetDB() *gorm.DB

+ func (n *BaseNode) GetData() map[string]any

+ func (n *BaseNode) GetDataByKey(key string, out interface{}) error

+ func (n *BaseNode) GetLogger() *logrus.Logger

+ func (n *BaseNode) GetOptions() *Options

+ func (n *BaseNode) GetPluginName() string

+ func (n *BaseNode) GetTracer() *tracer.Tracer

+ func (n *BaseNode) InitTracer(t *tracer.Tracer)

+ func (n *BaseNode) SetTracer(key string) *tracer.Tracer

+ func (n *BaseNode) SupportsDB() bool

+ func (n *BaseNode) SupportsLogging() bool

+ func (n *BaseNode) SupportsSystem() bool

type Details

+ HasDB bool

+ HasLogger bool

+ HasSystem bool

type EventBus

+ WS *WSHub

+ type Info struct

+ Application string

+ Name string

+ NodeID string

+ NodeUUID string

+ PluginName string

+ func NodeInfo(s ...string) *Info

+ type Message struct

+ NodeID string

+ NodeUUID string

+ Port *Port

type Node

+ AddDB func(db *gorm.DB)

+ AddData func(key string, data any)

+ AddLogger func(logger *logrus.Logger)

+ AddOptions func(opts *Options)

+ AddSchema func()

+ GetApplicationUse func() string

+ GetDB func() *gorm.DB

+ GetData func() map[string]any

+ GetDataByKey func(key string, out interface{}) error

+ GetLogger func() *logrus.Logger

+ GetOptions func() *Options

+ GetPluginName func() string

+ GetTracer func() *tracer.Tracer

+ InitTracer func(t *tracer.Tracer)

+ SetTracer func(key string) *tracer.Tracer

+ SupportsDB func() bool

+ SupportsLogging func() bool

+ SupportsSystem func() bool

type Options

+ System systeminfo.System

+ func NewOptions(opts *Options) *Options

+ type WSConnection struct

+ Conn *websocket.Conn

+ Send chan *Message

+ func NewWSConnection(conn *websocket.Conn) *WSConnection

+ type WSHub struct

+ Broadcast chan *Message

+ Connections map[*WSConnection]bool

+ Register chan *WSConnection

+ Unregister chan *WSConnection

+ func NewWSHub() *WSHub

+ func (h *WSHub) Run()

+ func (h *WSHub) Unsubscribe(conn *WSConnection)

v0.0.4

Dec 29, 2023

Changes in this version

type BaseNode

+ func (n *BaseNode) GetChildNode(uuid string) Node

+ func (n *BaseNode) GetChildNodes() []Node

+ func (n *BaseNode) GetChildsByType(nodeID string) []Node

+ func (n *BaseNode) GetDetails() *Details

+ func (n *BaseNode) GetParentUUID() string

+ func (n *BaseNode) GetPortValuesChildNode(uuid string) []*Port

+ func (n *BaseNode) RegisterChildNode(child Node)

+ func (n *BaseNode) SetDetails(details *Details)

+ func (n *BaseNode) SetLastValueChildNode(uuid string, port *Port)

+ func (n *BaseNode) SetMeta(opts *Options)

+ type Details struct

+ Category string

+ ParentID *string

type Meta

+ ParentUUID string

type Node

+ GetChildNode func(uuid string) Node

+ GetChildNodes func() []Node

+ GetChildsByType func(nodeID string) []Node

+ GetDetails func() *Details

+ GetParentUUID func() string

+ GetPortValuesChildNode func(uuid string) []*Port

+ RegisterChildNode func(child Node)

+ SetDetails func(details *Details)

+ SetLastValueChildNode func(uuid string, port *Port)

+ SetMeta func(opts *Options)

+ type Options struct

+ Meta *Meta

v0.0.3

Dec 28, 2023

Changes in this version

type BaseNode

+ Schema *schema.Generated

+ func (n *BaseNode) GetSchema() *schema.Generated

type Node

+ GetSchema func() *schema.Generated

v0.0.2

Dec 26, 2023

Changes in this version

type BaseNode

+ func (n *BaseNode) AddRuntime(runtimeNodes map[string]Node)

+ func (n *BaseNode) AddToNodeToRuntime(node Node) Node

+ func (n *BaseNode) GetRuntimeNodes() map[string]Node

+ func (n *BaseNode) Loaded() bool

+ func (n *BaseNode) NotLoaded() bool

+ func (n *BaseNode) RemoveNodeFromRuntime()

+ func (n *BaseNode) SetLoaded(set bool)

type Node

+ AddRuntime func(runtimeNodes map[string]Node)

+ AddToNodeToRuntime func(node Node) Node

+ GetRuntimeNodes func() map[string]Node

+ Loaded func() bool

+ NotLoaded func() bool

+ RemoveNodeFromRuntime func()

+ SetLoaded func(set bool)

+ type Position struct

+ PositionX int

+ PositionY int

v0.0.1

Dec 24, 2023

Changes in this version

+ const DirectionPublisher

+ const DirectionSubscriber

+ type AllNodeValue struct

+ Inputs []*Port

+ NodeId string

+ NodeUUID string

+ Outputs []*Port

+ type BaseNode struct

+ Bus map[string]chan *message

+ Connections []*Connection

+ EventBus *EventBus

+ ID string

+ Inputs []*Port

+ LastValue map[string]*Port

+ Meta *Meta

+ Name string

+ Node Node

+ Outputs []*Port

+ PublishOnTopic bool

+ Settings *Settings

+ UUID string

+ func NewBaseNode(id, nodeUUID, name string, bus *EventBus) *BaseNode

+ func (n *BaseNode) AddConnection(connection *Connection)

+ func (n *BaseNode) AddSettings(settings *Settings)

+ func (n *BaseNode) AddToNodesMap(nodeUUID string, node Node)

+ func (n *BaseNode) BuildSchema() *schemas.Schema

+ func (n *BaseNode) Delete()

+ func (n *BaseNode) GetAllInputValues() []*Port

+ func (n *BaseNode) GetAllNodeValues() []*NodeValue

+ func (n *BaseNode) GetAllNodes() []Node

+ func (n *BaseNode) GetAllOutputValues() []*Port

+ func (n *BaseNode) GetAllPortValues() []*Port

+ func (n *BaseNode) GetConnections() []*Connection

+ func (n *BaseNode) GetID() string

+ func (n *BaseNode) GetInput(id string) *Port

+ func (n *BaseNode) GetInputs() []*Port

+ func (n *BaseNode) GetMeta() *Meta

+ func (n *BaseNode) GetNodeName() string

+ func (n *BaseNode) GetOutputs() []*Port

+ func (n *BaseNode) GetPortValue(portID string) (*Port, error)

+ func (n *BaseNode) GetSettings() *Settings

+ func (n *BaseNode) GetUUID() string

+ func (n *BaseNode) HotFix() bool

+ func (n *BaseNode) New(nodeUUID, name string, bus *EventBus, opts *NodeOpts) Node

+ func (n *BaseNode) NewInputPort(id, name string, dataType portDataType)

+ func (n *BaseNode) NewOutputPort(id, name string, dataType portDataType)

+ func (n *BaseNode) NewPort(port *Port)

+ func (n *BaseNode) PublishMessage(port *Port, setLastValue ...bool)

+ func (n *BaseNode) RemoveFromNodesMap()

+ func (n *BaseNode) SetHotFix()

+ func (n *BaseNode) SetInputValue(id string, value interface{})

+ func (n *BaseNode) SetLastValue(port *Port)

+ func (n *BaseNode) Start()

+ func (n *BaseNode) UpdateConnections(connections []*Connection)

+ func (n *BaseNode) UpdateSettings(settings *Settings)

+ type Connection struct

+ FlowDirection flowDirection

+ SourcePort string

+ SourceUUID string

+ TargetPort string

+ TargetUUID string

+ type EventBus struct

+ func NewEventBus() *EventBus

+ func (eb *EventBus) Publish(topic string, data *message)

+ func (eb *EventBus) Subscribe(topic string, ch chan *message)

+ func (eb *EventBus) Unsubscribe(topic string, ch chan *message)

+ type Meta struct

+ Position position

+ type Node interface

+ AddConnection func(connection *Connection)

+ AddSettings func(settings *Settings)

+ BuildSchema func() *schemas.Schema

+ Delete func()

+ GetAllInputValues func() []*Port

+ GetAllNodeValues func() []*NodeValue

+ GetAllNodes func() []Node

+ GetAllOutputValues func() []*Port

+ GetAllPortValues func() []*Port

+ GetConnections func() []*Connection

+ GetID func() string

+ GetInput func(id string) *Port

+ GetInputs func() []*Port

+ GetMeta func() *Meta

+ GetNodeName func() string

+ GetOutputs func() []*Port

+ GetPortValue func(portID string) (*Port, error)

+ GetSettings func() *Settings

+ GetUUID func() string

+ HotFix func() bool

+ New func(nodeUUID, name string, bus *EventBus, opts *NodeOpts) Node

+ NewPort func(port *Port)

+ SetHotFix func()

+ SetInputValue func(id string, value interface{})

+ SetLastValue func(port *Port)

+ Start func()

+ UpdateConnections func(connections []*Connection)

+ UpdateSettings func(settings *Settings)

+ type NodeOpts struct

+ Meta *Meta

+ type NodeValue struct

+ NodeId string

+ NodeUUID string

+ Ports []*Port

+ type Port struct

+ DataType portDataType

+ Direction portDirection

+ ID string

+ LastUpdated string

+ Name string

+ Value interface{}

+ type Settings struct

+ Value interface{}

+ func (s *Settings) GetFloat64Value() float64

+ func (s *Settings) GetFloat64ValuePointer() *float64

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