messagequeue

Jun 24, 2025

Changes in this version

+ func WithDontHaveTimeoutConfig(dhtConfig *DontHaveTimeoutConfig) option

+ func WithPerPeerSendDelay(perPeerDelay time.Duration) option

+ type DontHaveTimeoutConfig struct

+ DontHaveTimeout time.Duration

+ MaxExpectedWantProcessTime time.Duration

+ MaxTimeout time.Duration

+ MessageLatencyAlpha float64

+ MessageLatencyMultiplier int

+ MinTimeout time.Duration

+ PingLatencyMultiplier int

+ func DefaultDontHaveTimeoutConfig() *DontHaveTimeoutConfig

type MessageQueue

+ BcastInc func()

+ func (mq *MessageQueue) HasMessage() bool

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