p2p

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)