worker

type Enqueuer interface {
	EnqueueUniqueTask(t *Task, uniqueTTL time.Duration) error
	EnqueueUniqueTaskIn(t *Task, delay time.Duration, uniqueTTL time.Duration) error
}

type EnqueuerOpts struct {
	PoolSize int
	RedisUrl string
	RedisDB  int
}

type Handler struct {
	TaskName    string
	HandlerFunc asynq.HandlerFunc
}

type Middleware interface {
	ProcessTask(context.Context, *Task) error
}

type Queue struct {
	Name     string
	Priority int
}

type Task struct {
	Name    string
	Retry   int
	Timeout time.Duration
	Payload interface{}
}

type UIOpts struct {
	Username string
	Password string
	Endpoint string
	RedisUrl string
}

type Worker interface {
	Start(context.Context) error
	RegisterHandlers([]*Handler)
	Stop()
}

type WorkerOpts struct {
	PoolSize        int
	RedisUrl        string
	Concurrency     int
	Queues          []*Queue
	ShutdownTimeout time.Duration
	RedisDB         int
}