p2p

May 30, 2019

Changes in this version

type P2P

+ func New(identity peer.ID, peerHost p2phost.Host, peerstore pstore.Peerstore) *P2P

Nov 2, 2018

Changes in this version

type Listener

+ ListenAddress func() ma.Multiaddr

+ Protocol func() protocol.ID

+ TargetAddress func() ma.Multiaddr

+ type Listeners struct

+ Listeners map[string]Listener

+ func (r *Listeners) Close(matchFunc func(listener Listener) bool) int

+ func (r *Listeners) Register(l Listener) error

type P2P

+ ListenersLocal *Listeners

+ ListenersP2P *Listeners

+ func (p2p *P2P) ForwardLocal(ctx context.Context, peer peer.ID, proto protocol.ID, bindAddr ma.Multiaddr) (Listener, error)

+ func (p2p *P2P) ForwardRemote(ctx context.Context, proto protocol.ID, addr ma.Multiaddr) (Listener, error)

+ type Stream struct

+ Local manet.Conn

+ OriginAddr ma.Multiaddr

+ Protocol protocol.ID

+ Registry *StreamRegistry

+ Remote net.Stream

+ TargetAddr ma.Multiaddr

type StreamRegistry

+ func (r *StreamRegistry) Close(s *Stream) error

+ func (r *StreamRegistry) Reset(s *Stream) error

Sep 27, 2017

Changes in this version

type StreamInfo

+ func (s *StreamInfo) Reset() error

Jun 27, 2017

Changes in this version

+ type Listener interface

+ Accept func() (net.Stream, error)

+ Close func() error

+ type ListenerInfo struct

+ Address ma.Multiaddr

+ Closer io.Closer

+ Identity peer.ID

+ Protocol string

+ Registry *ListenerRegistry

+ Running bool

+ func (c *ListenerInfo) Close() error

+ type ListenerRegistry struct

+ Listeners []*ListenerInfo

+ func (c *ListenerRegistry) Deregister(proto string) error

+ func (c *ListenerRegistry) Register(listenerInfo *ListenerInfo)

+ type P2P struct

+ Listeners ListenerRegistry

+ Streams StreamRegistry

+ func NewP2P(identity peer.ID, peerHost p2phost.Host, peerstore pstore.Peerstore) *P2P

+ func (p2p *P2P) CheckProtoExists(proto string) bool

+ func (p2p *P2P) Dial(ctx context.Context, addr ma.Multiaddr, peer peer.ID, proto string, ...) (*ListenerInfo, error)

+ func (p2p *P2P) NewListener(ctx context.Context, proto string, addr ma.Multiaddr) (*ListenerInfo, error)

+ type P2PListener struct

+ func (il *P2PListener) Accept() (net.Stream, error)

+ func (il *P2PListener) Close() error

+ type StreamInfo struct

+ HandlerID uint64

+ Local io.ReadWriteCloser

+ LocalAddr ma.Multiaddr

+ LocalPeer peer.ID

+ Protocol string

+ Registry *StreamRegistry

+ Remote io.ReadWriteCloser

+ RemoteAddr ma.Multiaddr

+ RemotePeer peer.ID

+ func (s *StreamInfo) Close() error

+ type StreamRegistry struct

+ Streams []*StreamInfo

+ func (c *StreamRegistry) Deregister(handlerID uint64)

+ func (c *StreamRegistry) Register(streamInfo *StreamInfo)