Versions in this module Expand all Collapse all v1 v1.15.1 Nov 7, 2019 Changes in this version + type BoundedQueue struct + func NewBoundedQueue(capacity int, onDroppedItem func(item interface{})) *BoundedQueue + func (q *BoundedQueue) Capacity() int + func (q *BoundedQueue) Produce(item interface{}) bool + func (q *BoundedQueue) Size() int + func (q *BoundedQueue) StartConsumers(num int, consumer func(item interface{})) + func (q *BoundedQueue) StartLengthReporting(reportPeriod time.Duration, gauge metrics.Gauge) + func (q *BoundedQueue) Stop()
Go to main page