Pass username to new redis client

This commit is contained in:
Simon Hang
2025-10-19 02:54:49 +11:00
committed by ginuerzh
parent a0c46cec6e
commit d2cc07d3ac
2 changed files with 7 additions and 0 deletions
+4
View File
@@ -69,6 +69,7 @@ func RedisStringLoader(addr string, opts ...RedisLoaderOption) Loader {
return &redisStringLoader{ return &redisStringLoader{
client: redis.NewClient(&redis.Options{ client: redis.NewClient(&redis.Options{
Addr: addr, Addr: addr,
Username: options.username,
Password: options.password, Password: options.password,
DB: options.db, DB: options.db,
}), }),
@@ -110,6 +111,7 @@ func RedisSetLoader(addr string, opts ...RedisLoaderOption) Loader {
return &redisSetLoader{ return &redisSetLoader{
client: redis.NewClient(&redis.Options{ client: redis.NewClient(&redis.Options{
Addr: addr, Addr: addr,
Username: options.username,
Password: options.password, Password: options.password,
DB: options.db, DB: options.db,
}), }),
@@ -154,6 +156,7 @@ func RedisListLoader(addr string, opts ...RedisLoaderOption) Loader {
return &redisListLoader{ return &redisListLoader{
client: redis.NewClient(&redis.Options{ client: redis.NewClient(&redis.Options{
Addr: addr, Addr: addr,
Username: options.username,
Password: options.password, Password: options.password,
DB: options.db, DB: options.db,
}), }),
@@ -198,6 +201,7 @@ func RedisHashLoader(addr string, opts ...RedisLoaderOption) Loader {
return &redisHashLoader{ return &redisHashLoader{
client: redis.NewClient(&redis.Options{ client: redis.NewClient(&redis.Options{
Addr: addr, Addr: addr,
Username: options.username,
Password: options.password, Password: options.password,
DB: options.db, DB: options.db,
}), }),
+3
View File
@@ -64,6 +64,7 @@ func RedisSetRecorder(addr string, opts ...RedisRecorderOption) recorder.Recorde
recorder: options.recorder, recorder: options.recorder,
client: redis.NewClient(&redis.Options{ client: redis.NewClient(&redis.Options{
Addr: addr, Addr: addr,
Username: options.username,
Password: options.password, Password: options.password,
DB: options.db, DB: options.db,
}), }),
@@ -102,6 +103,7 @@ func RedisListRecorder(addr string, opts ...RedisRecorderOption) recorder.Record
recorder: options.recorder, recorder: options.recorder,
client: redis.NewClient(&redis.Options{ client: redis.NewClient(&redis.Options{
Addr: addr, Addr: addr,
Username: options.username,
Password: options.password, Password: options.password,
DB: options.db, DB: options.db,
}), }),
@@ -140,6 +142,7 @@ func RedisSortedSetRecorder(addr string, opts ...RedisRecorderOption) recorder.R
recorder: options.recorder, recorder: options.recorder,
client: redis.NewClient(&redis.Options{ client: redis.NewClient(&redis.Options{
Addr: addr, Addr: addr,
Username: options.username,
Password: options.password, Password: options.password,
DB: options.db, DB: options.db,
}), }),