queue

type Dispatcher struct {
	// contains filtered or unexported fields
}

type Handler func(job *Job) error

type Job struct {
	ID        string                 `json:"id"`
	Queue     string                 `json:"queue"`
	Payload   map[string]interface{} `json:"payload"`
	Attempts  int                    `json:"attempts"`
	MaxTries  int                    `json:"max_tries"`
	Timeout   time.Duration          `json:"timeout"`
	CreatedAt time.Time              `json:"created_at"`
}

type Queue interface {
	// Push 推送任务到队列
	Push(job *Job) error

	// Pop 从队列获取任务
	Pop(queue string) (*Job, error)

	// Later 延迟推送任务
	Later(job *Job, delay time.Duration) error

	// Size 获取队列大小
	Size(queue string) (int64, error)

	// Clear 清空队列
	Clear(queue string) error
}

type SyncDriver struct {
	// contains filtered or unexported fields
}

type Worker struct {
	// contains filtered or unexported fields
}