Add simple JedisCluster constructor with HostAndPortMapper (#3302)

redis · Feb 27, 2023 · 51334b3 · 51334b3
1 parent 84d0aaa
commit 51334b3
Showing 1 changed file with 15 additions and 8 deletions.
diff --git a/src/main/java/redis/clients/jedis/JedisCluster.java b/src/main/java/redis/clients/jedis/JedisCluster.java
@@ -5,7 +5,6 @@
 import java.util.Map;
 import java.util.Set;
 import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
-import redis.clients.jedis.executors.ClusterCommandExecutor;
 import redis.clients.jedis.providers.ClusterConnectionProvider;
 
 public class JedisCluster extends UnifiedJedis {
@@ -100,6 +99,12 @@ public JedisCluster(Set<HostAndPort> nodes, String user, String password) {
     this(nodes, DefaultJedisClientConfig.builder().user(user).password(password).build());
   }
 
+  public JedisCluster(Set<HostAndPort> nodes, String user, String password,
+      HostAndPortMapper hostAndPortMap) {
+    this(nodes, DefaultJedisClientConfig.builder().user(user).password(password)
+        .hostAndPortMapper(hostAndPortMap).build());
+  }
+
   public JedisCluster(Set<HostAndPort> nodes, final GenericObjectPoolConfig<Connection> poolConfig) {
     this(nodes, DEFAULT_TIMEOUT, DEFAULT_MAX_ATTEMPTS, poolConfig);
   }
@@ -124,8 +129,8 @@ public JedisCluster(Set<HostAndPort> clusterNodes, int connectionTimeout, int so
     this(clusterNodes, connectionTimeout, soTimeout, maxAttempts, password, null, poolConfig);
   }
 
-  public JedisCluster(Set<HostAndPort> clusterNodes, int connectionTimeout,
-      int soTimeout, int maxAttempts, String password, String clientName,
+  public JedisCluster(Set<HostAndPort> clusterNodes, int connectionTimeout, int soTimeout,
+      int maxAttempts, String password, String clientName,
       GenericObjectPoolConfig<Connection> poolConfig) {
     this(clusterNodes, connectionTimeout, soTimeout, maxAttempts, null, password, clientName,
         poolConfig);
@@ -139,9 +144,9 @@ public JedisCluster(Set<HostAndPort> clusterNodes, int connectionTimeout, int so
         maxAttempts, poolConfig);
   }
 
-  public JedisCluster(Set<HostAndPort> clusterNodes, int connectionTimeout,
-      int soTimeout, int infiniteSoTimeout, int maxAttempts, String user, String password,
-      String clientName, GenericObjectPoolConfig<Connection> poolConfig) {
+  public JedisCluster(Set<HostAndPort> clusterNodes, int connectionTimeout, int soTimeout,
+      int infiniteSoTimeout, int maxAttempts, String user, String password, String clientName,
+      GenericObjectPoolConfig<Connection> poolConfig) {
     this(clusterNodes, DefaultJedisClientConfig.builder().connectionTimeoutMillis(connectionTimeout)
         .socketTimeoutMillis(soTimeout).blockingSocketTimeoutMillis(infiniteSoTimeout)
         .user(user).password(password).clientName(clientName).build(), maxAttempts, poolConfig);
@@ -169,7 +174,8 @@ public JedisCluster(Set<HostAndPort> clusterNodes, JedisClientConfig clientConfi
   }
 
   public JedisCluster(Set<HostAndPort> clusterNodes, JedisClientConfig clientConfig,
-      int maxAttempts, Duration maxTotalRetriesDuration, GenericObjectPoolConfig<Connection> poolConfig) {
+      int maxAttempts, Duration maxTotalRetriesDuration,
+      GenericObjectPoolConfig<Connection> poolConfig) {
     super(clusterNodes, clientConfig, poolConfig, maxAttempts, maxTotalRetriesDuration);
   }
 
@@ -181,7 +187,8 @@ public JedisCluster(Set<HostAndPort> clusterNodes, JedisClientConfig clientConfi
     super(clusterNodes, clientConfig, maxAttempts);
   }
 
-  public JedisCluster(Set<HostAndPort> clusterNodes, JedisClientConfig clientConfig, int maxAttempts, Duration maxTotalRetriesDuration) {
+  public JedisCluster(Set<HostAndPort> clusterNodes, JedisClientConfig clientConfig, int maxAttempts,
+      Duration maxTotalRetriesDuration) {
     super(clusterNodes, clientConfig, maxAttempts, maxTotalRetriesDuration);
   }