Versions in this module Expand all Collapse all v1 v1.0.1 Apr 12, 2022 v1.0.0 Mar 6, 2022 Changes in this version + type AsyncBatchWriter struct + BatchWrite func([]interface{}) + func NewAsyncBatchWriter(nDesiredBatchSize int, buffsize int, maxWait time.Duration) *AsyncBatchWriter + func (t *AsyncBatchWriter) Close() + func (t *AsyncBatchWriter) PostMessage(msg interface{}) + func (t *AsyncBatchWriter) PostMessageUnique(key string, msg interface{}) + type ElementT struct + type SyncBatchWriter struct + BatchWrite func([]interface{}) error + func NewSyncBatchWriter(nDesiredBatchSize int, buffsize int, maxWait time.Duration) *SyncBatchWriter + func (t *SyncBatchWriter) Close() + func (t *SyncBatchWriter) SendMessage(msg interface{}) error
Go to main page