Versions in this module Expand all Collapse all v0 v0.16.2 Dec 14, 2023 v0.16.1 Dec 14, 2023 Changes in this version + type PeerHandler interface + type PeerManager struct + func New(ctx context.Context, createPeerQueue PeerProcessFactory) *PeerManager + func (pm *PeerManager) Connected(p peer.ID) + func (pm *PeerManager) ConnectedPeers() []peer.ID + func (pm *PeerManager) Disconnected(p peer.ID) + func (pm *PeerManager) GetProcess(p peer.ID) PeerHandler + type PeerMessageManager struct + func NewMessageManager(ctx context.Context, createPeerQueue PeerQueueFactory) *PeerMessageManager + func (pmm *PeerMessageManager) AllocateAndBuildMessage(p peer.ID, blkSize uint64, buildMessageFn func(*messagequeue.Builder)) + type PeerProcess interface + Shutdown func() + Startup func() + type PeerProcessFactory func(ctx context.Context, p peer.ID, onShutdown func(peer.ID)) PeerHandler + type PeerQueue interface + AllocateAndBuildMessage func(blkSize uint64, buildMessageFn func(*messagequeue.Builder)) + type PeerQueueFactory func(ctx context.Context, p peer.ID, onShutdown func(peer.ID)) PeerQueue
Go to main page