mirror of
https://github.com/hibiken/asynq.git
synced 2025-04-19 23:30:20 +08:00
attempt to return NewUniversalClient from MakeRedisClient
This commit is contained in:
parent
7dbb5b08b7
commit
c065df6a18
5
asynq.go
5
asynq.go
@ -290,9 +290,8 @@ type RedisClientOpt struct {
|
||||
}
|
||||
|
||||
func (opt RedisClientOpt) MakeRedisClient() interface{} {
|
||||
return redis.NewClient(&redis.Options{
|
||||
Network: opt.Network,
|
||||
Addr: opt.Addr,
|
||||
return redis.NewUniversalClient(&redis.UniversalOptions{
|
||||
Addrs: []string{opt.Addr},
|
||||
Username: opt.Username,
|
||||
Password: opt.Password,
|
||||
DB: opt.DB,
|
||||
|
Loading…
x
Reference in New Issue
Block a user