Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ProxyConduit ¶
ProxyConduit is a special conduit which wraps the given conduit and replaces the target of every network send with the given target node.
func (*ProxyConduit) Multicast ¶
func (c *ProxyConduit) Multicast(event interface{}, num uint, targetIDs ...flow.Identifier) error
func (*ProxyConduit) Publish ¶
func (c *ProxyConduit) Publish(event interface{}, targetIDs ...flow.Identifier) error
func (*ProxyConduit) Unicast ¶
func (c *ProxyConduit) Unicast(event interface{}, targetID flow.Identifier) error
type ProxyNetwork ¶
type ProxyNetwork struct { network.EngineRegistry // contains filtered or unexported fields }
func NewProxyNetwork ¶
func NewProxyNetwork(net network.EngineRegistry, targetNodeID flow.Identifier) *ProxyNetwork
NewProxyNetwork creates a new proxy network. All messages sent on this network are sent only to the node identified by the given target ID.
Click to show internal directories.
Click to hide internal directories.