goQueue

Dec 30, 2025

Changes in this version

+ type Priority int

+ const PriorityHigh

+ const PriorityImmediate

+ const PriorityLow

+ const PriorityNormal

+ const PriorityRetry

Dec 23, 2025

Changes in this version

type EnqueueOption

+ func WithRetry(retryMax *int) EnqueueOption

Dec 23, 2025

Changes in this version

+ type Config struct

+ Preset map[string]PresetConfig

+ Size int

+ Timeout int

+ Workers int

+ type EnqueueOption func(*enqueueConfig)

+ func WithCallback(fn func(id string, err error)) EnqueueOption

+ func WithTaskID(id string) EnqueueOption

+ func WithTimeout(d time.Duration) EnqueueOption

+ type PresetConfig struct

+ Priority string

+ Timeout int

+ type Queue struct

+ func New(config *Config) *Queue

+ func (q *Queue) Enqueue(ctx context.Context, presetName string, action func(ctx context.Context) error, ...) (string, error)

+ func (q *Queue) Shutdown(ctx context.Context) error

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