feat(redis): use redis sentinel client

DEVmachine-fr · Apr 10, 2024 · 4682749 · 4682749
1 parent 04b02dd
commit 4682749
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/redis_transport.go b/redis_transport.go
@@ -70,10 +70,8 @@ func NewRedisTransport(u *url.URL, l Logger, tss *TopicSelectorStore) (Transport
 		return nil, &TransportError{u.Redacted(), "missing path", err}
 	}
 
-	client := redis.NewClient(&redis.Options{
-		Addr:     path,
-		Password: "", // no password set
-		DB:       0,  // use default DB
+	client := redis.NewSentinelClient(&redis.Options{
+		Addr: path,
 	})
 
 	ctx := context.Background()