sqliteq

May 7, 2025

Changes in this version

type Queue

+ func (q *Queue) RequeueNoAckRows()

May 6, 2025

Changes in this version

+ type Option func(*Queue)

+ func WithRemoveOnComplete(remove bool) Option

+ type PriorityQueue struct

+ func (pq *PriorityQueue) Dequeue() (any, bool)

+ func (pq *PriorityQueue) DequeueWithAckId() (any, bool, string)

+ func (pq *PriorityQueue) Enqueue(item any, priority int) bool

+ type Queue struct

+ func (q *Queue) Acknowledge(ackID string) bool

+ func (q *Queue) Close() error

+ func (q *Queue) Dequeue() (any, bool)

+ func (q *Queue) DequeueWithAckId() (any, bool, string)

+ func (q *Queue) Enqueue(item any) bool

+ func (q *Queue) Len() int

+ func (q *Queue) Purge()

+ func (q *Queue) Values() []any

+ type Queues interface

+ Close func() error

+ NewPriorityQueue func(queueKey string, opts ...Option) (*PriorityQueue, error)

+ NewQueue func(queueKey string, opts ...Option) (*Queue, error)

+ func New(dbPath string) Queues