protocolproxy

Nov 16, 2022

Changes in this version

+ const ForwardingProtocolID

+ var ErrInboundRequestsAreSingleProtocol = errors.New("inbound requests are single protocol")

+ var ErrNoInboundRequests = errors.New("inbound requests not accepted")

+ var ErrNoOutboundRequests = errors.New("outbound requests not accepted")

+ func NewForwardingHost(h host.Host, proxy peer.AddrInfo) host.Host

+ type ErrNotRegistered struct

+ func (e ErrNotRegistered) Error() string

+ type ForwardingHost struct

+ func (fh *ForwardingHost) Close() error

+ func (fh *ForwardingHost) Connect(ctx context.Context, pi peer.AddrInfo) error

+ func (fh *ForwardingHost) NewStream(ctx context.Context, p peer.ID, protocols ...protocol.ID) (network.Stream, error)

+ func (fh *ForwardingHost) RemoveStreamHandler(pid protocol.ID)

+ func (fh *ForwardingHost) SetStreamHandler(pid protocol.ID, handler network.StreamHandler)

+ type ProtocolProxy struct

+ func NewProtocolProxy(h host.Host, peerConfig map[peer.ID][]protocol.ID) (*ProtocolProxy, error)

+ func (pp *ProtocolProxy) Close()

+ func (pp *ProtocolProxy) Connected(n network.Network, c network.Conn)

+ func (pp *ProtocolProxy) Disconnected(n network.Network, c network.Conn)

+ func (pp *ProtocolProxy) Listen(network.Network, multiaddr.Multiaddr)

+ func (pp *ProtocolProxy) ListenClose(network.Network, multiaddr.Multiaddr)

+ func (pp *ProtocolProxy) Start(ctx context.Context)