queue

Dec 14, 2025

Changes in this version

+ var JobConfigMap = map[string]JobConfig

+ var JobMutex sync.RWMutex

+ func CloseClient() error

+ func GetClient() (*asynq.Client, error)

+ func RegisterJob(name string, config JobConfig)

+ func StartQueue() error

+ type Executor interface

+ Execute func(ctx context.Context, task *asynq.Task) error

+ type JobConfig struct

+ Executor Executor

+ Name string

+ Priority int

+ type QueueConfig struct

+ DB int

+ Enable bool

+ Host string

+ Password string

+ Port string

+ var LightQueueConfig *QueueConfig