Versions in this module Expand all Collapse all v0 v0.34.22 Dec 28, 2022 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) GetRemovalFailed() bool + 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(e p2p.Envelope) bool + func (mp *Peer) Set(key string, value interface{}) + func (mp *Peer) SetRemovalFailed() + func (mp *Peer) SocketAddr() *p2p.NetAddress + func (mp *Peer) Status() conn.ConnectionStatus + func (mp *Peer) TrySend(e p2p.Envelope) bool + type Reactor struct + Channels []*conn.ChannelDescriptor + func NewReactor() *Reactor + func (r *Reactor) AddPeer(peer p2p.Peer) + func (r *Reactor) GetChannels() []*conn.ChannelDescriptor + func (r *Reactor) Receive(e p2p.Envelope) + func (r *Reactor) RemovePeer(peer p2p.Peer, reason interface{})
Go to main page