memqueue

Apr 18, 2026

Changes in this version

+ func New(ctx context.Context, opts ...Option) workqueue.WorkQueue

+ type Option func(*Queue)

+ func WithWorkerPool(size int) Option

+ type Queue struct

+ func (q *Queue) Enqueue(queue string, data any)

+ func (q *Queue) Shutdown(ctx context.Context) error

+ func (q *Queue) Subscribe(queue string, handler workqueue.Handler)

+ func (q *Queue) Wait(ctx context.Context) error