Versions in this module Expand all Collapse all v0 v0.0.6 May 21, 2026 v0.0.5 Jan 23, 2026 Changes in this version + func NewConsumerQueue(redisClientOpt RedisClientOpt) (queuex.ConsumerQueue, error) + func NewConsumerQueueWithServer(server *asynq.Server) (q queuex.ConsumerQueue, err error) + func NewProducerQueue(redisClientOpt RedisClientOpt) (queuex.ProducerQueue, error) + func NewProducerQueueWithClient(client *asynq.Client) (q queuex.ProducerQueue, err error) + type RedisClientOpt struct + Addr string + DB int + DialTimeout time.Duration + Network string + Password string + PoolSize int + ReadTimeout time.Duration + Username string + WriteTimeout time.Duration + func (opt RedisClientOpt) ToAsyncQRedisClientOpt() asynq.RedisClientOpt
Go to main page