messagequeue

Dec 2, 2024

Changes in this version

type MessageNetwork

+ Connect func(context.Context, peer.AddrInfo) error

type MessageQueue

+ func (mq *MessageQueue) RebroadcastNow()

Jul 15, 2023

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