zlei6/go-zero
1
0
Fork 0
mirror of https://github.com/zeromicro/go-zero.git synced 2026-05-14 02:10:00 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: redis username not working in redis v7 (#4632)

Browse Source
This commit is contained in:
Kevin Wan
2025-02-08 12:21:35 +08:00
committed by GitHub
parent ca797ed22c
commit 24073969a1
3 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
core/stores/redis/redisblockingnode.go
View File

@@ -21,6 +21,7 @@ func CreateBlockingNode(r *Redis) (ClosableNode, error) {
case NodeType: case NodeType:
client := red.NewClient(&red.Options{ client := red.NewClient(&red.Options{
Addr: r.Addr, Addr: r.Addr,
Username: r.User,
Password: r.Pass, Password: r.Pass,
DB: defaultDatabase, DB: defaultDatabase,
MaxRetries: maxRetries, MaxRetries: maxRetries,
@@ -32,6 +33,7 @@ func CreateBlockingNode(r *Redis) (ClosableNode, error) {
case ClusterType: case ClusterType:
client := red.NewClusterClient(&red.ClusterOptions{ client := red.NewClusterClient(&red.ClusterOptions{
Addrs: splitClusterAddrs(r.Addr), Addrs: splitClusterAddrs(r.Addr),
Username: r.User,
Password: r.Pass, Password: r.Pass,
MaxRetries: maxRetries, MaxRetries: maxRetries,
PoolSize: 1, PoolSize: 1,

1
core/stores/redis/redisclientmanager.go
View File

@@ -31,6 +31,7 @@ func getClient(r *Redis) (*red.Client, error) {
} }
store := red.NewClient(&red.Options{ store := red.NewClient(&red.Options{
Addr: r.Addr, Addr: r.Addr,
Username: r.User,
Password: r.Pass, Password: r.Pass,
DB: defaultDatabase, DB: defaultDatabase,
MaxRetries: maxRetries, MaxRetries: maxRetries,

1
core/stores/redis/redisclustermanager.go
View File

@@ -28,6 +28,7 @@ func getCluster(r *Redis) (*red.ClusterClient, error) {
} }
store := red.NewClusterClient(&red.ClusterOptions{ store := red.NewClusterClient(&red.ClusterOptions{
Addrs: splitClusterAddrs(r.Addr), Addrs: splitClusterAddrs(r.Addr),
Username: r.User,
Password: r.Pass, Password: r.Pass,
MaxRetries: maxRetries, MaxRetries: maxRetries,
MinIdleConns: idleConns, MinIdleConns: idleConns,