Versions in this module Expand all Collapse all v0 v0.2.0 Oct 3, 2019 Changes in this version + var ErrInvalidBatchChannelSize = errors.New("invalid batch channel size, it must be greater than zero") + var ErrInvalidNumBatches = errors.New("invalid number of batches, it must be greater than zero") + type Batch []ID + type Batcher interface + AddToCurrentBatch func(id ID) + CloseCurrentAndTakeFirstBatch func() (Batch, bool) + Stop func() + func New(numBatches, newBatchesInitialCapacity, batchChannelSize uint64) (Batcher, error) + type ID []byte