Versions in this module Expand all Collapse all v0 v0.3.0 Feb 27, 2025 Changes in this version + type QueuedMessage interface + Bytes func() []byte + type TaskMessage interface + Payload func() []byte + type Worker interface + Queue func(task TaskMessage) error + Request func() (TaskMessage, error) + Run func(ctx context.Context, task TaskMessage) error + Shutdown func() error
Go to main page