p2p

package

Go to main page

Versions in this module

v1

v1.1.0

Dec 17, 2018

Changes in this version

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

type MessageType

+ const PublishTx

type Peer

+ func (p *Peer) Addr() string

+ func (p *Peer) ID() string

type PeerManager

+ func (pm *PeerManager) AllNeighborCount() int

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

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

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

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

type Service

+ GetAllNeighbors func() []*Peer

+ PutPeerToBlack func(string)

v1.0.0

Sep 30, 2018

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")

+ var ErrStreamCountExceed = errors.New("stream count exceed")

+ 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 PublishTxRequest

+ 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) Broadcast(data []byte, typ MessageType, mp MessagePriority)

+ func (ns *NetService) ConnectBPs(ids []string)

+ func (ns *NetService) Deregister(id string, typs ...MessageType)

+ func (ns *NetService) ID() string

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

+ func (ns *NetService) NeighborStat() map[string]interface{}

+ func (ns *NetService) Register(id string, typs ...MessageType) chan IncomingMessage

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

+ func (ns *NetService) Start() error

+ func (ns *NetService) Stop()

+ type Peer struct

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

+ func (p *Peer) AddStream(stream libnet.Stream) error

+ func (p *Peer) CloseStream(stream libnet.Stream)

+ 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) Broadcast(data []byte, typ MessageType, mp MessagePriority)

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

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

+ func (pm *PeerManager) DumpRoutingTable()

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

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

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

+ func (pm *PeerManager) LoadRoutingTable()

+ func (pm *PeerManager) NeighborCount() int

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

+ 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(ids []string)

+ Deregister func(string, ...MessageType)

+ ID func() string

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

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

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

+ Start func() error

+ Stop func()

Incompatible versions in this module

v3.3.1+incompatible

Dec 13, 2019

v2.1.0+incompatible

Jan 3, 2019

v2.0.1+incompatible

Dec 17, 2018

v2.0.0+incompatible

Dec 17, 2018

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL