aggregator

Jun 23, 2024

Changes in this version

+ type Aggregator struct

+ func NewAggregator[T any](bulkSize int, timeout time.Duration) *Aggregator[T]

+ func (agg *Aggregator[T]) Add(item T)

+ func (agg *Aggregator[T]) Close()

+ func (agg *Aggregator[T]) Count() int

+ func (agg *Aggregator[T]) Purge()

+ func (agg *Aggregator[T]) SetBulkCallback(callback bulkCallback[T])

+ func (agg *Aggregator[T]) SetTimeoutCallback(callback timeoutCallback[T])