Versions in this module Expand all Collapse all v1 v1.3.0 Dec 2, 2021 v1.2.0 Aug 24, 2021 Changes in this version + func NewRateLimitedDrain(drain ipfsPump.Drain, sleepAfterDrain time.Duration) ipfsPump.CountedDrain + type RateLimitedDrain struct + func (d *RateLimitedDrain) Drain(block ipfsPump.Block) error + func (d *RateLimitedDrain) SuccessfulBlocksCount() uint64