Versions in this module Expand all Collapse all v2 v2.2.1 Aug 15, 2022 v2.2.0 Jun 4, 2022 Changes in this version + type Batcher struct + func NewBatcher(size int, interval time.Duration, writer Writer) *Batcher + func (b *Batcher) Flush() + func (b *Batcher) ForcedFlush() + func (b *Batcher) Write(data interface{}) + type Writer interface + Write func(batch []interface{}) + type WriterFunc func(batch []interface{}) + func (f WriterFunc) Write(batch []interface{})
Go to main page