asynq

type Client interface {
	Ping() error
	EnqueueContext(ctx context.Context, task *Task, opts ...Option) (*asynq.TaskInfo, error)
}

type Config struct {
	RedisURL     string
	Concurrency  int
	PoolSize     int
	TimeZone     string
	QueuesConfig map[string]int

	DisableCronJobEmitter bool

	Logger logger.Logger

	Middlewares []asynq.MiddlewareFunc
}

type HandleFunc func(context.Context, *Task) error

type Manager interface {
	// will launch goroutine, blocks until some specified `os.Signal`s received
	Run()

	RegisterHandler(name string, fn HandleFunc)

	// will set a job id which ensure cron triggers the job only once when time is up.
	// be careful when set a retention which should be end before the next turn,
	// otherwise the job will not be triggered in the next turn due to the conflict job id.
	RegisterCron(cronspec string, task *Task, opts ...Option) (entryID string, err error)
}

type Option = asynq.Option

type Task struct {
	*asynq.Task
	// contains filtered or unexported fields
}