bvstreamleecher

type BVsID struct {
	Epoch     idx.Epoch
	LastBlock idx.Block
	ID        hash.Event
}

type Callbacks struct {
	LowestBlockToDecide func() (idx.Epoch, idx.Block)
	MaxEpochToDecide    func() idx.Epoch
	IsProcessed         func(epoch idx.Epoch, lastBlock idx.Block, id hash.Event) bool

	RequestChunk func(peer string, r bvstream.Request) error
	Suspend      func(peer string) bool
	PeerBlock    func(peer string) idx.Block
}

type Config struct {
	Session              basepeerleecher.EpochDownloaderConfig
	RecheckInterval      time.Duration
	BaseProgressWatchdog time.Duration
	BaseSessionWatchdog  time.Duration
	MinSessionRestart    time.Duration
	MaxSessionRestart    time.Duration
}

type Leecher struct {
	*basestreamleecher.BaseLeecher
	// contains filtered or unexported fields
}