Versions in this module Expand all Collapse all v4 v4.14.1 Apr 26, 2023 Changes in this version + type Capped struct + func NewCapped(capacity int64) *Capped[T] + func (c *Capped[T]) Highest() *T + func (c *Capped[T]) Track(ctx context.Context, payload T, batchSize int64) (func() *T, error) + type Uncapped struct + func NewUncapped() *Uncapped[T] + func (t *Uncapped[T]) Highest() *T + func (t *Uncapped[T]) Pending() int64 + func (t *Uncapped[T]) Track(payload T, batchSize int64) func() *T Other modules containing this package github.com/dafanshu/benthos/v3