Versions in this module Expand all Collapse all v1 v1.0.1 Feb 6, 2026 Changes in this version + type BatchQueue struct + FlushTimeout time.Duration + MaxBatchSize int + Name string + func New[T any](name string, size int, batchSize int, flushTimeout time.Duration) *BatchQueue[T] + func (q *BatchQueue[T]) Add(ctx context.Context, item T) + func (q *BatchQueue[T]) Close() + func (q *BatchQueue[T]) Consume(handler Handler[T]) + type Handler func(context.Context, []T) + type Item struct
Go to main page