p2p

Jun 10, 2022

Changes in this version

type Peer

+ func (p *Peer) IsOutbound() bool

Mar 10, 2021

Changes in this version

+ var ErrDuplicateMessage = errors.New("reduplicate message")

+ var ErrMessageChannelFull = errors.New("message channel is full")

+ var ErrPortUnavailable = errors.New("port is unavailable")

+ func Ping(rw http.ResponseWriter, r *http.Request)

+ type IncomingMessage struct

+ func NewIncomingMessage(peerID PeerID, data []byte, messageType MessageType) *IncomingMessage

+ func (m *IncomingMessage) Data() []byte

+ func (m *IncomingMessage) From() PeerID

+ func (m *IncomingMessage) Type() MessageType

+ type MessagePriority uint8

+ type MessageType uint16

+ const NewBlock

+ const NewBlockHash

+ const NewBlockRequest

+ const NormalMessage

+ const PublishTx

+ const RoutingTableQuery

+ const RoutingTableResponse

+ const SyncBlockHashRequest

+ const SyncBlockHashResponse

+ const SyncBlockRequest

+ const SyncBlockResponse

+ const SyncHeight

+ const UrgentMessage

+ func (m MessageType) String() string

+ type NetService struct

+ func NewNetService(config *common.P2PConfig) (*NetService, error)

+ func (ns *NetService) ID() string

+ func (ns *NetService) LocalAddrs() []multiaddr.Multiaddr

+ func (ns *NetService) Start() error

+ func (ns *NetService) Stop()

+ type Peer struct

+ func NewPeer(stream libnet.Stream, pm *PeerManager, direction connDirection) *Peer

+ func (p *Peer) Addr() string

+ func (p *Peer) ID() string

+ func (p *Peer) SendMessage(msg *p2pMessage, mp MessagePriority, deduplicate bool) error

+ func (p *Peer) Start()

+ func (p *Peer) Stop()

+ type PeerID = peer.ID

+ type PeerManager struct

+ func NewPeerManager(host host.Host, config *common.P2PConfig) *PeerManager

+ func (pm *PeerManager) AddNeighbor(p *Peer)

+ func (pm *PeerManager) AllNeighborCount() int

+ func (pm *PeerManager) Broadcast(data []byte, typ MessageType, mp MessagePriority)

+ func (pm *PeerManager) CloseAllNeighbors()

+ func (pm *PeerManager) ConnectBPs(ids []string)

+ func (pm *PeerManager) Deregister(id string, mTyps ...MessageType)

+ func (pm *PeerManager) DumpRoutingTable()

+ func (pm *PeerManager) GetAllNeighbors() []*Peer

+ func (pm *PeerManager) GetNeighbor(peerID peer.ID) *Peer

+ func (pm *PeerManager) HandleMessage(msg *p2pMessage, peerID peer.ID)

+ func (pm *PeerManager) HandleStream(s libnet.Stream, direction connDirection)

+ func (pm *PeerManager) LoadRoutingTable()

+ func (pm *PeerManager) NeighborCount(direction connDirection) int

+ func (pm *PeerManager) NeighborStat() map[string]interface{}

+ func (pm *PeerManager) PutIPToBlack(ip string)

+ func (pm *PeerManager) PutPIDToBlack(pid peer.ID)

+ func (pm *PeerManager) PutPeerToBlack(id string)

+ func (pm *PeerManager) Register(id string, mTyps ...MessageType) chan IncomingMessage

+ func (pm *PeerManager) RemoveNeighbor(peerID peer.ID)

+ func (pm *PeerManager) SendToPeer(peerID peer.ID, data []byte, typ MessageType, mp MessagePriority)

+ func (pm *PeerManager) Start()

+ func (pm *PeerManager) Stop()

+ type Service interface

+ Broadcast func([]byte, MessageType, MessagePriority)

+ ConnectBPs func([]string)

+ Deregister func(string, ...MessageType)

+ GetAllNeighbors func() []*Peer

+ ID func() string

+ PutPeerToBlack func(string)

+ Register func(string, ...MessageType) chan IncomingMessage

+ SendToPeer func(PeerID, []byte, MessageType, MessagePriority)

+ Start func() error

+ Stop func()