Versions in this module Expand all Collapse all v2 v2.8.1 Nov 22, 2023 v2.8.0 Nov 22, 2023 Changes in this version + type BatchWriter struct + func NewBatchWriter(size int, interval time.Duration, writer Writer) *BatchWriter + func (b *BatchWriter) Flush() + func (b *BatchWriter) ForcedFlush() + func (b *BatchWriter) 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