queue

Jul 5, 2026

Changes in this version

+ type Key string

+ func (k Key) String() string

+ type Queue struct

+ func New(concurrency int) *Queue

+ func (q *Queue) Dequeue(key Key)

+ func (q *Queue) Enqueue(key Key, fn func() error)

+ func (q *Queue) Start(ctx context.Context)

+ func (q *Queue) WaitForKey(key Key)