Versions in this module Expand all Collapse all v0 v0.5.0 Jan 28, 2023 Changes in this version + type BatchQueue struct + OutQueue chan []any + func NewBatchQueue(config *Options) *BatchQueue + func (b *BatchQueue) Enqueue(item any) + func (b *BatchQueue) GetDispatchedCount() int + func (b *BatchQueue) Start() + func (b *BatchQueue) Stop() + type Options struct + DequeueFunc func([]any) + Interval time.Duration + MaxBatchItems int + MaxQueueSize int
Go to main page