queue

Jan 17, 2024

Changes in this version

+ type Counter struct

+ Drop prometheus.Counter

+ Passthrough prometheus.Counter

+ Processed prometheus.Counter

+ QueueCap prometheus.Gauge

+ QueueLen prometheus.Gauge

+ type Item interface

+ Eta func() time.Time

+ type Queue struct

+ func NewQueue[T Item](logger zerolog.Logger, size int, flushTimeout time.Duration, ...) *Queue[T]

+ func (q *Queue[T]) Close()

+ func (q *Queue[T]) Done() <-chan struct{}

+ func (q *Queue[T]) Len() int

+ func (q *Queue[T]) ReceiveChannel() <-chan T

+ func (q *Queue[T]) SendChannel() chan<- T