tasker

type QueueName string

type Task struct {
	Id      string          `json:"id"`
	Payload json.RawMessage `json:"payload"`
}

type TaskName string

type TaskerClient struct {
	Client *asynq.Client
}

type TaskerClientOpts struct {
	RedisPool *redis.RedisPool
}

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

type TaskerServerOpts struct {
	Concurrency      int
	ErrorHandler     asynq.ErrorHandler
	IsFailureHandler func(error) bool
	Logg             logf.Logger
	LogLevel         asynq.LogLevel
	RedisPool        *redis.RedisPool
	RetryHandler     asynq.RetryDelayFunc
}