Function NewQueue

queue.go:58–71

NewQueue initializes a new Queue instance with the provided configuration. Parameters: - conf *config.Configuration: The configuration for the queue. Returns: - *Queue: A pointer to the newly created Queue instance.

(conf *config.Configuration, client *asynq.Client)

// Returns:
// - *Queue: A pointer to the newly created Queue instance.
func NewQueue(conf *config.Configuration, client *asynq.Client) *Queue {
	redisOption, err := redis_db.ParseRedisURL(conf.Redis.Dns, conf.Redis.SkipTLSVerify)
	if err != nil {
		logrus.WithError(err).Fatal("failed to parse Redis URL")
	}

	queueOptions := asynq.RedisClientOpt{Addr: redisOption.Addr, Password: redisOption.Password, DB: redisOption.DB, TLSConfig: redisOption.TLSConfig, PoolSize: conf.Redis.PoolSize}
	inspector := asynq.NewInspector(queueOptions)
	return &Queue{
		Client:    client,
		Inspector: inspector,
		config:    conf,
	}
}

// queueInflightExpiry enqueues a task to handle inflight expiry for a transaction.
//