Versions in this module Expand all Collapse all v0 v0.0.2 Aug 30, 2021 v0.0.1 Aug 22, 2021 Changes in this version + type DontHaveTimeoutManager interface + AddPending func([]cid.Cid) + CancelPending func([]cid.Cid) + Shutdown func() + Start func() + UpdateMessageLatency func(time.Duration) + type MessageNetwork interface + ConnectTo func(context.Context, peer.ID) error + Latency func(peer.ID) time.Duration + NewMessageSender func(context.Context, peer.ID, *bsnet.MessageSenderOpts) (bsnet.MessageSender, error) + Ping func(context.Context, peer.ID) ping.Result + Self func() peer.ID + type MessageQueue struct + func New(ctx context.Context, p peer.ID, network MessageNetwork, ...) *MessageQueue + func (mq *MessageQueue) AddBroadcastWantHaves(wantHaves []cid.Cid) + func (mq *MessageQueue) AddCancels(cancelKs []cid.Cid) + func (mq *MessageQueue) AddWants(wantBlocks []cid.Cid, wantHaves []cid.Cid) + func (mq *MessageQueue) ResponseReceived(ks []cid.Cid) + func (mq *MessageQueue) SetRebroadcastInterval(delay time.Duration) + func (mq *MessageQueue) Shutdown() + func (mq *MessageQueue) Startup() + type OnDontHaveTimeout func(peer.ID, []cid.Cid) + type PeerConnection interface + Latency func() time.Duration + Ping func(context.Context) ping.Result
Go to main page