Versions in this module Expand all Collapse all v1 v1.0.0 Jan 6, 2023 Changes in this version + type Peer struct + Outbound bool + Persistent bool + func NewPeer(ip net.IP) *Peer + func (mp *Peer) CloseConn() error + func (mp *Peer) FlushStop() + func (mp *Peer) Get(key string) interface{} + func (mp *Peer) ID() p2p.ID + func (mp *Peer) IsOutbound() bool + func (mp *Peer) IsPersistent() bool + func (mp *Peer) NodeInfo() p2p.NodeInfo + func (mp *Peer) RemoteAddr() net.Addr + func (mp *Peer) RemoteIP() net.IP + func (mp *Peer) Send(chID byte, msgBytes []byte) bool + func (mp *Peer) Set(key string, value interface{}) + func (mp *Peer) SocketAddr() *p2p.NetAddress + func (mp *Peer) Status() conn.ConnectionStatus + func (mp *Peer) TrySend(chID byte, msgBytes []byte) bool + type Reactor struct + func NewReactor() *Reactor + func (r *Reactor) AddPeer(peer p2p.Peer) + func (r *Reactor) GetChannels() []*conn.ChannelDescriptor + func (r *Reactor) Receive(chID byte, peer p2p.Peer, msgBytes []byte) + func (r *Reactor) RemovePeer(peer p2p.Peer, reason interface{})
Go to main page