38 lines
651 B
Go
38 lines
651 B
Go
package queue
|
|
|
|
import (
|
|
"time"
|
|
|
|
"github.com/hibiken/asynq"
|
|
)
|
|
|
|
// Config ...
|
|
type Config struct {
|
|
// For message queue
|
|
Redis ConfigRedis
|
|
|
|
// Priority to process task, eg: Critical 6, Default 3, Low 1
|
|
// Using for server only
|
|
// https://github.com/hibiken/asynq/wiki/Queue-Priority
|
|
Concurrency int
|
|
Priority ConfigPriority
|
|
|
|
TaskTimeout time.Duration
|
|
RetryDelayFunc asynq.RetryDelayFunc
|
|
ServerMiddlewares []asynq.MiddlewareFunc
|
|
}
|
|
|
|
// ConfigRedis ...
|
|
type ConfigRedis struct {
|
|
URL string
|
|
Password string
|
|
}
|
|
|
|
// ConfigPriority ...
|
|
type ConfigPriority struct {
|
|
Critical int
|
|
Default int
|
|
Low int
|
|
StrictMode bool
|
|
}
|