From d2cc07d3ac4a5c23d441093e74b5813624c01786 Mon Sep 17 00:00:00 2001 From: Simon Hang Date: Sun, 19 Oct 2025 02:54:49 +1100 Subject: [PATCH] Pass username to new redis client --- internal/loader/redis.go | 4 ++++ recorder/redis.go | 3 +++ 2 files changed, 7 insertions(+) diff --git a/internal/loader/redis.go b/internal/loader/redis.go index 14ad3c53..dd47dcdc 100644 --- a/internal/loader/redis.go +++ b/internal/loader/redis.go @@ -69,6 +69,7 @@ func RedisStringLoader(addr string, opts ...RedisLoaderOption) Loader { return &redisStringLoader{ client: redis.NewClient(&redis.Options{ Addr: addr, + Username: options.username, Password: options.password, DB: options.db, }), @@ -110,6 +111,7 @@ func RedisSetLoader(addr string, opts ...RedisLoaderOption) Loader { return &redisSetLoader{ client: redis.NewClient(&redis.Options{ Addr: addr, + Username: options.username, Password: options.password, DB: options.db, }), @@ -154,6 +156,7 @@ func RedisListLoader(addr string, opts ...RedisLoaderOption) Loader { return &redisListLoader{ client: redis.NewClient(&redis.Options{ Addr: addr, + Username: options.username, Password: options.password, DB: options.db, }), @@ -198,6 +201,7 @@ func RedisHashLoader(addr string, opts ...RedisLoaderOption) Loader { return &redisHashLoader{ client: redis.NewClient(&redis.Options{ Addr: addr, + Username: options.username, Password: options.password, DB: options.db, }), diff --git a/recorder/redis.go b/recorder/redis.go index c2f202be..78ba4d07 100644 --- a/recorder/redis.go +++ b/recorder/redis.go @@ -64,6 +64,7 @@ func RedisSetRecorder(addr string, opts ...RedisRecorderOption) recorder.Recorde recorder: options.recorder, client: redis.NewClient(&redis.Options{ Addr: addr, + Username: options.username, Password: options.password, DB: options.db, }), @@ -102,6 +103,7 @@ func RedisListRecorder(addr string, opts ...RedisRecorderOption) recorder.Record recorder: options.recorder, client: redis.NewClient(&redis.Options{ Addr: addr, + Username: options.username, Password: options.password, DB: options.db, }), @@ -140,6 +142,7 @@ func RedisSortedSetRecorder(addr string, opts ...RedisRecorderOption) recorder.R recorder: options.recorder, client: redis.NewClient(&redis.Options{ Addr: addr, + Username: options.username, Password: options.password, DB: options.db, }),