Versions in this module Expand all Collapse all v1 v1.0.2 Jan 31, 2023 Changes in this version + type Callbacks struct + IsProcessed func(idx.Epoch) bool + LowestEpochToFetch func() idx.Epoch + MaxEpochToFetch func() idx.Epoch + PeerEpoch func(peer string) idx.Epoch + RequestChunk func(peer string, r epstream.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 basepeerleecher.EpochDownloaderConfig + func DefaultConfig() Config + func LiteConfig() Config + type Leecher struct + func New(cfg Config, callback Callbacks) *Leecher + func (d *Leecher) ForceSyncing() + func (d *Leecher) NotifyChunkReceived(sessionID uint32, lastEpoch idx.Epoch, done bool) error
Go to main page