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, }),