Versions in this module Expand all Collapse all v0 v0.1.10 Dec 16, 2019 Changes in this version + type MessageNetwork interface + ConnectTo func(context.Context, peer.ID) error + NewMessageSender func(context.Context, peer.ID) (bsnet.MessageSender, error) + type MessageQueue struct + func New(ctx context.Context, p peer.ID, network MessageNetwork) *MessageQueue + func (mq *MessageQueue) AddMessage(entries []bsmsg.Entry, ses uint64) + func (mq *MessageQueue) AddWantlist(initialWants *wantlist.SessionTrackedWantlist) + func (mq *MessageQueue) SetRebroadcastInterval(delay time.Duration) + func (mq *MessageQueue) Shutdown() + func (mq *MessageQueue) Startup() v0.1.10-1 Dec 16, 2019
Go to main page