Versions in this module Expand all Collapse all v1 v1.1.0 Nov 7, 2026 v1.0.0 Nov 7, 2026 Changes in this version + type Handler func(context.Context, Message) error + type Message struct + Attempts int + Body []byte + ID string + type Options struct + Buffer int + MaxAttempts int + Name string + OnDeadLetter func(context.Context, Message, error) + RetryDelay time.Duration + Workers int + type Queue struct + func New(opt Options, h Handler) (*Queue, error) + func (q *Queue) Enqueue(ctx context.Context, body []byte) (string, error) + func (q *Queue) Name() string + func (q *Queue) OnReady(ctx context.Context) error + func (q *Queue) OnShutdown(ctx context.Context) error + func (q *Queue) Start(parent context.Context) error + func (q *Queue) Stop(ctx context.Context) error
Go to main page