Versions in this module Expand all Collapse all v0 v0.5.1 Jul 4, 2017 v0.5.0 Jul 1, 2017 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