Versions in this module Expand all Collapse all v0 v0.0.2 Sep 5, 2019 Changes in this version + func GetModulePath(module string) string + func ToJSON(data interface{}) string + type Batcher struct + func NewBatcher(maxBatchSize int, maxDelay time.Duration, now func() time.Time) *Batcher + func (b *Batcher) Add(task interface{}, time time.Time) + func (b *Batcher) Close() + func (b *Batcher) StartWorker(run func(chan []interface{}, *sync.WaitGroup))