Versions in this module Expand all Collapse all v1 v1.1.0 Nov 4, 2026 v1.0.0 Jun 14, 2026 Changes in this version + var ErrNotAccepted = errors.New("babelqueue/asynq: task payload is not an acceptable envelope") + func Bind(handler babelqueue.Handler) hasynq.HandlerFunc + func Envelope(task *hasynq.Task) (babelqueue.Envelope, error) + func Register(mux muxRegistrar, urn string, handler babelqueue.Handler) + func Task(env babelqueue.Envelope, opts ...hasynq.Option) (*hasynq.Task, error) + func TaskFor(urn string, data map[string]any, opts ...any) (*hasynq.Task, error) + type Enqueuer interface + EnqueueContext func(ctx context.Context, task *hasynq.Task, opts ...hasynq.Option) (*hasynq.TaskInfo, error) + type Producer struct + func NewProducer(client Enqueuer) *Producer + func (p *Producer) Dispatch(ctx context.Context, urn string, data map[string]any, opts ...any) (*hasynq.TaskInfo, error) + func (p *Producer) Enqueue(ctx context.Context, env babelqueue.Envelope, opts ...hasynq.Option) (*hasynq.TaskInfo, error)
Go to main page