fix: Authentication issue with sentinel=true (#870)

tair-opensource · Oct 14, 2024 · 0f42759 · 0f42759
1 parent 94d36b0
commit 0f42759
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/internal/client/redis.go b/internal/client/redis.go
@@ -22,8 +22,8 @@ type Redis struct {
 	protoWriter *proto.Writer
 }
 
-func NewSentinelMasterClient(ctx context.Context, address string, Tls bool) *Redis {
-	return NewRedisClient(ctx, address, "", "", Tls, false)
+func NewSentinelMasterClient(ctx context.Context, address string, username string, password string, Tls bool) *Redis {
+	return NewRedisClient(ctx, address, username, password, Tls, false)
 }
 
 func NewRedisClient(ctx context.Context, address string, username string, password string, Tls bool, replica bool) *Redis {

diff --git a/internal/writer/redis_sentinel_writer.go b/internal/writer/redis_sentinel_writer.go
@@ -8,7 +8,7 @@ import (
 )
 
 func NewRedisSentinelWriter(ctx context.Context, opts *RedisWriterOptions) Writer {
-	sentinel := client.NewSentinelMasterClient(ctx, opts.Address, opts.Tls)
+	sentinel := client.NewSentinelMasterClient(ctx, opts.Address, opts.Username, opts.Password, opts.Tls)
 	sentinel.Send("SENTINEL", "GET-MASTER-ADDR-BY-NAME", opts.Master)
 	addr, err := sentinel.Receive()
 	if err != nil {