Versions in this module Expand all Collapse all v2 v2.1.1 Dec 9, 2025 Changes in this version + type BoundedQueue struct + func NewBoundedQueue(capacity int, onDroppedItem func(item interface{})) *BoundedQueue + func NewBoundedQueueWithRetry(capacity int, onDroppedItem func(item interface{}), retryMaxCount uint32, ...) *BoundedQueue + func (q *BoundedQueue) Capacity() int + func (q *BoundedQueue) Produce(item interface{}) bool + func (q *BoundedQueue) Resize(capacity int) bool + func (q *BoundedQueue) Size() int + func (q *BoundedQueue) StartConsumers(num int, callback func(item interface{}) error) + func (q *BoundedQueue) StartConsumersWithFactory(num int, factory func() Consumer) + func (q *BoundedQueue) Stop() + func (q *BoundedQueue) StopConsumers() + type Consumer interface + Consume func(item interface{}) error + type ConsumerFunc func(item interface{}) error + func (c ConsumerFunc) Consume(item interface{}) error type Queue + func NewWithRetry(logger *zap.Logger, name string, limit int, ...) *Queue + type RetryConfig struct v2.0.0 Jun 18, 2023 Changes in this version + type Queue struct + Limit int + Name string + Queue *queue.BoundedQueue + Workers int + func New(logger *zap.Logger, name string, limit int, consumer func(item interface{}), ...) *Queue + func (q *Queue) Close() + func (q *Queue) Produce(item interface{}) bool + func (q *Queue) Size() int + type QueueSpec struct + Queue *Queue + SubscriptionId int64 + Topic string + func (qs *QueueSpec) Close() + func (qs *QueueSpec) Produce(item interface{}) bool + func (qs *QueueSpec) Size() int
Go to main page