goqueue

Nov 29, 2024

Changes in this version

+ var QueueErrorsCount = prometheus.NewCounterVec(prometheus.CounterOpts{}, []string{ ... })

+ var QueueSize = prometheus.NewGaugeVec(prometheus.GaugeOpts{}, []string{ ... })

+ func PrometheusCollectors(namespace string) []prometheus.Collector

+ type Queue struct

+ func NewQueue(queueName string, queues *Queues) Queue

+ func (q Queue) Enqueue(inter interface{}) error

+ type QueueDef struct

+ Builder func() interface{}

+ Location string

+ Name string

+ SegmentSize int

+ TurboMode bool

+ type Queues struct

+ func NewQueues(registeredInterfaces []interface{}) *Queues

+ func (q *Queues) AddDef(name string, queueDef *QueueDef)

+ func (q *Queues) Attach(queue string, handler func(interface{}) (reEnqueue bool, err error)) error

+ func (q *Queues) Enqueue(queue string, inter interface{}) error

+ func (q *Queues) OpenQueues()

+ func (q *Queues) Shutdown()