remote

Jul 17, 2024

Changes in this version

type Node

+ func (n *Node) SendPropertyChange(propertyId string, value core.Any)

+ func (n *Node) SendSignal(signalId string, args core.Args)

Feb 9, 2023

Changes in this version

+ type MockSource struct

+ CollectPropertiesHandler func() (core.KWArgs, error)

+ Id string

+ InvokeHandler func(methodId string, args core.Args) (core.Any, error)

+ LinkedHandler func(objectId string, node *Node) error

+ Messages core.Message

+ SetPropertyHandler func(propertyId string, value core.Any) error

+ func NewMockSource(id string) *MockSource

+ func (s *MockSource) CollectProperties() (core.KWArgs, error)

+ func (s *MockSource) Invoke(methodId string, args core.Args) (core.Any, error)

+ func (s *MockSource) Linked(objectId string, node *Node) error

+ func (s *MockSource) ObjectId() string

+ func (s *MockSource) SetProperty(propertyId string, value core.Any) error

+ type MockWriteCloser struct

+ CloseHandler func() error

+ Closed bool

+ Messages [][]byte

+ WriteHandler func(p []byte) (n int, err error)

+ func NewMockWriteCloser() *MockWriteCloser

+ func (m *MockWriteCloser) Close() error

+ func (m *MockWriteCloser) Write(p []byte) (n int, err error)

Feb 7, 2023

Changes in this version

type Registry

+ func (e *Registry) NotifySignal(objectId string, name string, args core.Args)

Jan 27, 2023

Changes in this version

+ type IObjectSource interface

+ CollectProperties func() (core.KWArgs, error)

+ Invoke func(methodId string, args core.Args) (core.Any, error)

+ Linked func(objectId string, node *Node) error

+ ObjectId func() string

+ SetProperty func(propertyId string, value core.Any) error

+ type Node struct

+ Converter core.MessageConverter

+ Registry *Registry

+ func NewNode(registry *Registry) *Node

+ func (n *Node) BroadcastMessage(objectId string, msg core.Message)

+ func (n *Node) Close() error

+ func (n *Node) Id() string

+ func (n *Node) IncomingPump()

+ func (n *Node) NotifyPropertyChange(propertyId string, value core.Any)

+ func (n *Node) NotifySignal(signalId string, args core.Args)

+ func (n *Node) RemoveNode()

+ func (n *Node) SendMessage(msg core.Message)

+ func (n *Node) SetOutput(out io.WriteCloser)

+ func (n *Node) Write(data []byte) (int, error)

+ type Registry struct

+ func NewRegistry() *Registry

+ func (e *Registry) NotifyPropertyChange(objectId string, value core.Any)

+ func (r *Registry) AddObjectSource(source IObjectSource)

+ func (r *Registry) AttachRemoteNode(node *Node)

+ func (r *Registry) DetachRemoteNode(node *Node)

+ func (r *Registry) GetObjectSource(objectId string) IObjectSource

+ func (r *Registry) GetRemoteNodes(objectId string) []*Node

+ func (r *Registry) Id() string

+ func (r *Registry) IsRegistered(objectId string) bool

+ func (r *Registry) LinkRemoteNode(objectId string, node *Node)

+ func (r *Registry) RemoveObjectSource(source IObjectSource)

+ func (r *Registry) SetSourceFactory(factory SourceFactory)

+ func (r *Registry) UnlinkRemoteNode(objectId string, node *Node)

+ type SourceFactory func(objectId string) IObjectSource

+ type SourceToNodeEntry struct