Versions in this module Expand all Collapse all v0 v0.8.14 Sep 15, 2021 Changes in this version + type Connection struct + func (_m *Connection) Close() error + func (_m *Connection) FlushClose() error + func (_m *Connection) Handshake(_a0 context.Context, _a1 types.NodeInfo, _a2 crypto.PrivKey) (types.NodeInfo, crypto.PubKey, error) + func (_m *Connection) LocalEndpoint() p2p.Endpoint + func (_m *Connection) ReceiveMessage() (p2p.ChannelID, []byte, error) + func (_m *Connection) RemoteEndpoint() p2p.Endpoint + func (_m *Connection) SendMessage(_a0 p2p.ChannelID, _a1 []byte) (bool, error) + func (_m *Connection) Status() conn.ConnectionStatus + func (_m *Connection) String() string + func (_m *Connection) TrySendMessage(_a0 p2p.ChannelID, _a1 []byte) (bool, error) + type Peer struct + func (_m *Peer) CloseConn() error + func (_m *Peer) FlushStop() + func (_m *Peer) Get(_a0 string) interface{} + func (_m *Peer) ID() types.NodeID + func (_m *Peer) IsOutbound() bool + func (_m *Peer) IsPersistent() bool + func (_m *Peer) IsRunning() bool + func (_m *Peer) NodeInfo() types.NodeInfo + func (_m *Peer) OnReset() error + func (_m *Peer) OnStart() error + func (_m *Peer) OnStop() + func (_m *Peer) Quit() <-chan struct{} + func (_m *Peer) RemoteAddr() net.Addr + func (_m *Peer) RemoteIP() net.IP + func (_m *Peer) Reset() error + func (_m *Peer) Send(_a0 byte, _a1 []byte) bool + func (_m *Peer) Set(_a0 string, _a1 interface{}) + func (_m *Peer) SetLogger(_a0 log.Logger) + func (_m *Peer) SocketAddr() *types.NetAddress + func (_m *Peer) Start() error + func (_m *Peer) Status() conn.ConnectionStatus + func (_m *Peer) Stop() error + func (_m *Peer) String() string + func (_m *Peer) TrySend(_a0 byte, _a1 []byte) bool + func (_m *Peer) Wait() + type Transport struct + func (_m *Transport) Accept() (p2p.Connection, error) + func (_m *Transport) Close() error + func (_m *Transport) Dial(_a0 context.Context, _a1 p2p.Endpoint) (p2p.Connection, error) + func (_m *Transport) Endpoints() []p2p.Endpoint + func (_m *Transport) Protocols() []p2p.Protocol + func (_m *Transport) String() string