Versions in this module Expand all Collapse all v0 v0.0.0 Jul 4, 2022 Changes in this version + type Callbacks struct + OnlyNotConnected peerleecher.OnlyNotConnectedFn + PeerEpoch func(peer string) idx.Epoch + RequestChunk func(peer string, r dagstream.Request) error + Suspend func(peer string) bool + type Config struct + BaseProgressWatchdog time.Duration + BaseSessionWatchdog time.Duration + MaxSessionRestart time.Duration + MinSessionRestart time.Duration + RecheckInterval time.Duration + Session peerleecher.EpochDownloaderConfig + func DefaultConfig() Config + func LiteConfig() Config + type Leecher struct + func New(epoch idx.Epoch, emptyState bool, cfg Config, callback Callbacks) *Leecher + func (d *Leecher) ForceSyncing() + func (d *Leecher) NotifyChunkReceived(sessionID uint32, last hash.Event, done bool) error + func (d *Leecher) OnNewEpoch(myEpoch idx.Epoch) + func (d *Leecher) PeersNum() int + func (d *Leecher) RegisterPeer(peer string) error + func (d *Leecher) Start() + func (d *Leecher) Stop() + func (d *Leecher) UnregisterPeer(peer string) error