remote

Documentation

Index

• type IObjectSource
• type MockSource
  • 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
  • func NewMockWriteCloser() *MockWriteCloser
  • func (m *MockWriteCloser) Close() error
  • func (m *MockWriteCloser) Write(p []byte) (n int, err error)
• type Node
  • func NewNode(registry *Registry) *Node
  • 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) Registry() *Registry
  • func (n *Node) RemoveNode()
  • func (n *Node) SendMessage(msg core.Message)
  • func (n *Node) SendPropertyChange(propertyId string, value core.Any)
  • func (n *Node) SendSignal(signalId string, args core.Args)
  • func (n *Node) SetOutput(out io.WriteCloser)
  • func (n *Node) Write(data []byte) (int, error)
• type Registry
  • func NewRegistry() *Registry
  • func (r *Registry) AddObjectSource(source IObjectSource) error
  • 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) NotifyPropertyChange(objectId string, kwargs core.KWArgs)
  • func (r *Registry) NotifySignal(objectId string, name string, args core.Args)
  • func (r *Registry) RemoveObjectSource(source IObjectSource)
  • func (r *Registry) SetSourceFactory(factory SourceFactory)
  • func (r *Registry) UnlinkRemoteNode(objectId string, node *Node)
• type SourceFactory

Types

type IObjectSource

type IObjectSource interface {
	ObjectId() string
	Invoke(methodId string, args core.Args) (core.Any, error)
	SetProperty(propertyId string, value core.Any) error
	Linked(objectId string, node *Node) error
	CollectProperties() (core.KWArgs, error)
}

type MockSource

type MockSource struct {
	Id                       string
	Messages                 core.Message
	InvokeHandler            func(methodId string, args core.Args) (core.Any, error)
	SetPropertyHandler       func(propertyId string, value core.Any) error
	LinkedHandler            func(objectId string, node *Node) error
	CollectPropertiesHandler func() (core.KWArgs, error)
}

func NewMockSource

func NewMockSource(id string) *MockSource

func (*MockSource) CollectProperties

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

func (*MockSource) Invoke

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

func (*MockSource) Linked

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

func (*MockSource) ObjectId

func (s *MockSource) ObjectId() string

func (*MockSource) SetProperty

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

type MockWriteCloser

type MockWriteCloser struct {
	Messages     [][]byte
	WriteHandler func(p []byte) (n int, err error)
	Closed       bool
	CloseHandler func() error
}

func NewMockWriteCloser

func NewMockWriteCloser() *MockWriteCloser

func (*MockWriteCloser) Close

func (m *MockWriteCloser) Close() error

func (*MockWriteCloser) Write

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

type Node

type Node struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewNode

func NewNode(registry *Registry) *Node

func (*Node) Close

func (n *Node) Close() error

func (*Node) Id

func (n *Node) Id() string

func (*Node) IncomingPump

func (n *Node) IncomingPump()

func (*Node) NotifyPropertyChange

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

func (*Node) NotifySignal

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

func (*Node) Registry

func (n *Node) Registry() *Registry

func (*Node) RemoveNode

func (n *Node) RemoveNode()

func (*Node) SendMessage

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

func (*Node) SendPropertyChange

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

func (*Node) SendSignal

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

func (*Node) SetOutput

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

func (*Node) Write

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

type Registry

type Registry struct {
	// contains filtered or unexported fields
}

Registry is the registry of remote objects. It is optimized for the retrieval of object sources A object source is registered in the registry and can be retrieved by the object id. The source can have one or more remote nodes linked to it.

func NewRegistry

func NewRegistry() *Registry

NewRegistry creates a new registry.

func (*Registry) AddObjectSource

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

AddObjectSource adds the object source to the registry.

func (*Registry) AttachRemoteNode

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

AttachRemoteNode attaches the node to the registry.

func (*Registry) DetachRemoteNode

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

DetachRemoteNode removes the link between the object and the node.

func (*Registry) GetObjectSource

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

GetObjectSource returns the object source by name.

func (*Registry) GetRemoteNodes

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

GetRemoteNode returns the node that is linked to the object.

func (*Registry) Id

func (r *Registry) Id() string

Id returns the registry id.

func (*Registry) IsRegistered

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

Checks if the object is registered.

func (*Registry) LinkRemoteNode

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

LinkRemoteNode adds a link between the object and the node.

func (*Registry) NotifyPropertyChange

func (r *Registry) NotifyPropertyChange(objectId string, kwargs core.KWArgs)

NotifyPropertyChange notifies the property change to the nodes.

func (*Registry) NotifySignal

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

NotifySignal notifies the signal to the nodes that are linked to the object.

func (*Registry) RemoveObjectSource

func (r *Registry) RemoveObjectSource(source IObjectSource)

RemoveObjectSource removes the object source from the registry.

func (*Registry) SetSourceFactory

func (r *Registry) SetSourceFactory(factory SourceFactory)

SetSourceFactory sets the source factory.

func (*Registry) UnlinkRemoteNode

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

UnlinkRemoteNode removes the link between the object and the node.

type SourceFactory

type SourceFactory func(objectId string) IObjectSource