Versions in this module Expand all Collapse all v0 v0.0.0 Jul 4, 2022 Changes in this version + type Callback struct + OnlyInterested func(ids []interface{}) []interface{} + Suspend func() bool + type Config struct + ArriveTimeout time.Duration + ForgetTimeout time.Duration + GatherSlack time.Duration + HashLimit int + MaxBatch int + MaxParallelRequests int + MaxQueuedBatches int + func DefaultConfig(scale cachescale.Func) Config + type Fetcher struct + func New(cfg Config, callback Callback) *Fetcher + func (f *Fetcher) NotifyAnnounces(peer string, ids []interface{}, time time.Time, fetchItems ItemsRequesterFn) error + func (f *Fetcher) NotifyReceived(ids []interface{}) error + func (f *Fetcher) Overloaded() bool + func (f *Fetcher) Start() + func (f *Fetcher) Stop() + type ItemsRequesterFn func([]interface{}) error
Go to main page