client

Jun 2, 2025

Changes in this version

type IObjectSink

+ HandleInit func(objectId string, props core.KWArgs, node *Node)

+ HandlePropertyChange func(propertyId string, value core.Any)

+ HandleRelease func()

+ HandleSignal func(signalId string, args core.Args)

type MockSink

+ func (m *MockSink) HandleInit(objectId string, props core.KWArgs, node *Node)

+ func (m *MockSink) HandlePropertyChange(propertyId string, value core.Any)

+ func (m *MockSink) HandleRelease()

+ func (m *MockSink) HandleSignal(signalId string, args core.Args)

Jul 17, 2024

Changes in this version

type Node

+ func (n *Node) InvokeRemoteSync(methodId string, args core.Args) (core.Any, error)

Feb 9, 2023

Changes in this version

type MockSink

+ func NewMockSink(objectId string) *MockSink

type Registry

+ func (r *Registry) GetClientNode(objectId string) *Node

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

Jan 27, 2023

Changes in this version

+ type IObjectSink interface

+ ObjectId func() string

+ OnInit func(objectId string, props core.KWArgs, node *Node)

+ OnPropertyChange func(propertyId string, value core.Any)

+ OnRelease func()

+ OnSignal func(signalId string, args core.Args)

+ type InvokeReplyArg struct

+ Identifier string

+ Value core.Any

+ type InvokeReplyFunc func(arg InvokeReplyArg)

+ type MockSink struct

+ func (m *MockSink) ObjectId() string

+ func (m *MockSink) OnInit(objectId string, props core.KWArgs, node *Node)

+ func (m *MockSink) OnPropertyChange(propertyId string, value core.Any)

+ func (m *MockSink) OnRelease()

+ func (m *MockSink) OnSignal(signalId string, args core.Args)

+ type Node struct

+ Registry *Registry

+ func NewNode(registry *Registry) *Node

+ func (n *Node) Close() error

+ func (n *Node) Id() string

+ func (n *Node) InvokeRemote(methodId string, args core.Args, f InvokeReplyFunc)

+ func (n *Node) LinkRemoteNode(objectId string)

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

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

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

+ func (n *Node) UnlinkRemoteNode(objectId string)

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

+ type Registry struct

+ func NewRegistry() *Registry

+ func (r *Registry) AddObjectSink(sink IObjectSink)

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

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

+ func (r *Registry) Entry(objectId string) *SinkToClientEntry

+ func (r *Registry) Id() string

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

+ func (r *Registry) Node(objectId string) *Node

+ func (r *Registry) ObjectIds() []string

+ func (r *Registry) ObjectSink(objectId string) IObjectSink

+ func (r *Registry) RemoveEntry(objectId string)

+ func (r *Registry) RemoveObjectSink(objectId string)

+ func (r *Registry) SetSinkFactory(factory SinkFactory)

+ func (r *Registry) UnlinkClientNode(objectId string)

+ type SinkFactory func(objectId string) IObjectSink

+ type SinkToClientEntry struct