task_queue.go 759 B

123456789101112
  1. package settings
  2. type TaskQueue struct {
  3. MaxRetryTimes int `json:"max_retry_times" default:"3"` // 单个任务失败后,最大重试次数,超过后会降一级
  4. OneJobTimeOut int `json:"one_job_time_out" default:"300"` // 单个任务的超时时间 5 * 60 s
  5. Interval int `json:"interval" default:"10"` // 任务的间隔,单位 s,这里会有一个限制,不允许太快,然后会做一定的随机时间范围,当前值 x ~ 2*x 之内随机
  6. ExpirationTime int `json:"expiration_time" default:"90"` // 添加任务后,过期的时间(单位 day),超过后,任务会降级到 Low
  7. }
  8. func NewTaskQueue() *TaskQueue {
  9. return &TaskQueue{MaxRetryTimes: 3, Interval: 10, ExpirationTime: 90, OneJobTimeOut: 300}
  10. }