Updates for latest cross-cluster-commits

Author: viragtripathi

pom.xml

@@ -36,7 +36,7 @@
         <maven.compiler.target>11</maven.compiler.target>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <jmh.version>1.36</jmh.version>
-        <jedis.version>4.4.0-SNAPSHOT</jedis.version>
+        <jedis.version>5.0.0-SNAPSHOT</jedis.version>
         <jreleaser.version>1.3.1</jreleaser.version>
         <resilience4j.version>1.7.1</resilience4j.version>
         <slf4j.version>1.7.36</slf4j.version>

src/main/java/com/redis/benchmark/utils/JedisConnectionManagement.java

@@ -3,10 +3,10 @@
 import redis.clients.jedis.DefaultJedisClientConfig;
 import redis.clients.jedis.HostAndPort;
 import redis.clients.jedis.JedisClientConfig;
-import redis.clients.jedis.MultiClusterJedisClientConfig.ClusterJedisClientConfig;
+import redis.clients.jedis.MultiClusterClientConfig.ClusterConfig;
 import redis.clients.jedis.UnifiedJedis;
 import redis.clients.jedis.commands.JedisCommands;
-import redis.clients.jedis.MultiClusterJedisClientConfig;
+import redis.clients.jedis.MultiClusterClientConfig;
 import redis.clients.jedis.providers.MultiClusterPooledConnectionProvider;
 
 import java.io.File;
@@ -27,7 +27,7 @@ private JedisConnectionManagement() {
     }
 
     private void createJedisConnection() {
-        MultiClusterJedisClientConfig.Builder multiClusterJedisClientConfig;
+        MultiClusterClientConfig.Builder multiClusterJedisClientConfig;
         Set<HostAndPort> hostAndPorts = BenchmarkConfiguration.get().getRedisHostAndPorts();
         int index = 0;
 
@@ -47,12 +47,12 @@ private void createJedisConnection() {
             }
             // Multi cluster
             if (hostAndPorts.size() > 1) {
-                ClusterJedisClientConfig[] clusterJedisClientConfigs = new ClusterJedisClientConfig[hostAndPorts.size()];
+                ClusterConfig[] clusterJedisClientConfigs = new ClusterConfig[hostAndPorts.size()];
                 for (HostAndPort hostAndPort : hostAndPorts) {
-                    clusterJedisClientConfigs[index] = new ClusterJedisClientConfig(new HostAndPort(hostAndPort.getHost(), hostAndPort.getPort()), jedisClientConfig);
+                    clusterJedisClientConfigs[index] = new ClusterConfig(new HostAndPort(hostAndPort.getHost(), hostAndPort.getPort()), jedisClientConfig);
                     index++;
                 }
-                multiClusterJedisClientConfig = new MultiClusterJedisClientConfig.Builder(clusterJedisClientConfigs);
+                multiClusterJedisClientConfig = new MultiClusterClientConfig.Builder(clusterJedisClientConfigs);
                 multiClusterJedisClientConfig.circuitBreakerSlidingWindowSize(Integer.parseInt(BenchmarkConfiguration.get().getConnectionCircuitBreakerSlidingWindowSize()));
                 multiClusterJedisClientConfig.circuitBreakerSlidingWindowMinCalls(Integer.parseInt(BenchmarkConfiguration.get().getConnectionCircuitBreakerSlidingWindowMinCalls()));
                 multiClusterJedisClientConfig.circuitBreakerFailureRateThreshold(Float.parseFloat(BenchmarkConfiguration.get().getConnectionCircuitBreakerFailureRateThreshold()));