rhos sentinel changes added

gofynd · Apr 26, 2024 · 6422076 · 6422076
1 parent 7ec9dda
commit 6422076
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/src/main/java/com/fynd/extension/storage/RedisStorage.java b/src/main/java/com/fynd/extension/storage/RedisStorage.java
@@ -10,6 +10,7 @@ public class RedisStorage extends BaseStorage {
     private JedisPool jedisPool;
     private JedisCluster jedisCluster;
     private String prefixKey;
+    private JedisSentinelPool jedisSentinelPool;
 
     public RedisStorage(JedisPool jedisPool, String prefixKey) {
         super(prefixKey);
@@ -25,6 +26,13 @@ public RedisStorage(JedisCluster jedisCluster, String prefixKey) {
         this.isClusterMode = true;
     }
 
+    public RedisStorage(JedisSentinelPool jedisSentinelPool, String prefixKey) {
+        super(prefixKey);
+        this.jedisSentinelPool = jedisSentinelPool;
+        this.prefixKey = prefixKey;
+        this.isClusterMode = false; // Sentinel doesn't use clustering
+    }
+
     @Override
     public String get(String key) {
         if (isClusterMode) {