Versions in this module Expand all Collapse all v0 v0.4.1 Apr 18, 2026 v0.4.0 Apr 18, 2026 Changes in this version + const PluginName + type Handler func(context.Context, *Task) error + type Shutdownable interface + Shutdown func(ctx context.Context) error + type Task struct + Attempt int + Data any + ID string + Queue string + func NewTask(id, queue string, data any) *Task + func NewTaskWithCallbacks(id, queue string, data any, attempt int, ack, nack func()) *Task + func (t *Task) Ack() + func (t *Task) Nack() + type WorkQueue interface + Enqueue func(queue string, data any) + Subscribe func(queue string, handler Handler) + Wait func(ctx context.Context) error + func FromContext(ctx context.Context) WorkQueue + type WorkQueuePlugin struct + func Plugin(wq WorkQueue) *WorkQueuePlugin + func (p *WorkQueuePlugin) Name() string + func (p *WorkQueuePlugin) ServerOptions() []prefab.ServerOption + func (p *WorkQueuePlugin) Shutdown(ctx context.Context) error v0.4.0-beta.1 Nov 27, 2025
Go to main page