proxy

package

v0.36.6 Latest Latest Go to latest Published: Jul 25, 2024 License: AGPL-3.0 Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type ProxyConduit struct {
	network.Conduit
	// contains filtered or unexported fields
}

ProxyConduit is a special conduit which wraps the given conduit and replaces the target of every network send with the given target node.

func (c *ProxyConduit) Multicast(event interface{}, num uint, targetIDs ...flow.Identifier) error

func (c *ProxyConduit) Publish(event interface{}, targetIDs ...flow.Identifier) error

func (c *ProxyConduit) Unicast(event interface{}, targetID flow.Identifier) error

type ProxyNetwork struct {
	network.EngineRegistry
	// contains filtered or unexported fields
}

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.

func (n *ProxyNetwork) Register(channel channels.Channel, engine network.Engine) (network.Conduit, error)

Register registers an engine with the proxy network.