gotask

type AckWhenStatus int

type ArgsMap map[string]interface{}

type Broker interface {
	Acquire(string) (*Task, error)
	Ack(*Task) bool
	Update(*Task) error
	Enqueue(*Task) string
	QueueLen(string) int64
}

type JobHandler func(string, ArgsMap) (ArgsMap, error)

type Queue struct {
	Name     string
	MaxLimit int
	Async    bool

	// monitor
	MonitorInterval int
}

type QueueOption func(*Queue)

type RedisBroker struct {
	TaskTTL int
}

type RedisBrokerOption func(rb *RedisBroker)

type ReentrantOption func(*ReentrantOptions)

type ReentrantOptions struct {
	MaxTimes int
	SleepyMS int
}

type Task struct {
	ID                  string    `json:"task_id"`               //任务ID
	CreatedAt           time.Time `json:"created_at"`            // 创建任务的时间
	UpdatedAt           time.Time `json:"updated_at"`            // 最近一次更新任务的时间
	QueueName           string    `json:"queue_name"`            // 任务队列的名字
	JobName             string    `json:"job_name"`              // 任务的名称
	ResultArgsMap       ArgsMap   `json:"result_args_map"`       // 任务执行结果的map
	CurrentHandlerIndex int       `json:"current_handler_index"` // 当前任务所在task执行队列的索引id
	OriginalArgsMap     ArgsMap   `json:"original_args_map"`     //  从消息队列请求的参数map
	ResultLog           string    `json:"result_log"`            // 返回的
	Status              status    `json:"status"`                // 任务的当前状态
	Errlog              string    `json:"err_log"`               //任务的错误结果日志
}