[automatic failover] Merge automatic failover (DO NOT MERGE)

RELEASE-NOTES.md

@@ -1,30 +1,25 @@
-Lettuce 7.2.0 RELEASE NOTES
+Lettuce 7.4.0.BETA1 RELEASE NOTES
 ==============================
 
-The Lettuce team is pleased to announce the Lettuce 7.2.0 minor release!
+The Lettuce team is pleased to announce the **first beta release of Lettuce 7.4.0**!
 
-Lettuce 7.2.0 supports Redis 2.6+ up to Redis 8.x. In terms of Java runtime, Lettuce requires at least Java 8 and
-works with Java 24. The driver is tested against Redis 8.4, Redis 8.2, Redis 8.0, Redis 7.4 and Redis 7.2.
+This release introduces **Automatic Client-Side Endpoint Failover** through the newly added **MultiDBClient**.
 
-Thanks to all contributors who made Lettuce 7.2.0.RELEASE possible.
+### Key Features
 
-📗 Links
-Reference documentation: https://lettuce.io/core/7.2.0.RELEASE/reference/
-Javadoc: https://lettuce.io/core/7.2.0.RELEASE/api/
+- **Automatic Detection**: The client monitors the health of all configured Redis endpoints.
+- **Seamless Failover**: If the active endpoint fails, traffic is automatically rerouted to the next healthiest endpoint based on configurable priorities.
+- **Customizable**: Developers can configure endpoints, set priorities, adjust failure sensitivity, and plug in custom health checks or failure detection logic.
 
-⭐ New Features
-* Add ftHybrid by @a-TODO-rov in https://github.com/redis/lettuce/pull/3540
-* Expose method to add upstream driver libraries to CLIENT SETINFO payload by @viktoriya-kutsarova in https://github.com/redis/lettuce/pull/3542
 
-🐞 Bug Fixes
-* SearchArgs.returnField with alias produces malformed redis command #3528 by @tishun in https://github.com/redis/lettuce/pull/3530
-* fix consistency with get(int) that returns wrapped DelegateJsonObject/DelegateJsonArray for nested structures by @NeatGuyCoding in https://github.com/redis/lettuce/pull/3464
+**Lettuce 7.4.0.BETA1** supports Redis **2.6+** up to Redis **8.x** and requires **Java 8** or newer. The driver is tested against Redis **8.4**, **8.2**, **7.4**, and **7.2**.
 
-💡 Other
-* Bumping Netty to 4.2.5.Final (main) by @tishun in https://github.com/redis/lettuce/pull/3536
 
-❤️ New Contributors
-* @NeatGuyCoding made their first contribution in https://github.com/redis/lettuce/pull/3464
-* @viktoriya-kutsarova made their first contribution in https://github.com/redis/lettuce/pull/3542
 
-**Full Changelog**: https://github.com/redis/lettuce/compare/7.1.0.RELEASE...7.2.0.RELEASE
+We encourage you to try out this beta and provide feedback ahead of the general availability release.
+
+**Full Changelog**: https://github.com/redis/lettuce/compare/7.2.0.RELEASE...7.4.0.BETA1
+
+## Contributors
+We'd like to thank all the contributors who worked on this release!
+@atakavci, @ggivo, @uglide

pom.xml

@@ -3,7 +3,8 @@
 
     <groupId>io.lettuce</groupId>
     <artifactId>lettuce-core</artifactId>
-    <version>7.3.0-SNAPSHOT</version>
+    <version>7.4.0-SNAPSHOT</version>
+
     <packaging>jar</packaging>
 
     <name>Lettuce</name>
@@ -565,6 +566,14 @@
             <scope>test</scope>
         </dependency>
 
+        <!-- Toxiproxy for network failure simulation -->
+        <dependency>
+            <groupId>eu.rekawek.toxiproxy</groupId>
+            <artifactId>toxiproxy-java</artifactId>
+            <version>2.1.11</version>
+            <scope>test</scope>
+        </dependency>
+
         <!-- JMH -->
 
         <dependency>

src/main/java/io/lettuce/core/AbstractRedisClient.java

@@ -35,6 +35,7 @@
 import java.util.concurrent.atomic.AtomicInteger;
 
 import io.lettuce.core.MaintNotificationsConfig.EndpointTypeSource;
+import io.lettuce.core.api.BaseRedisClient;
 import reactor.core.publisher.Mono;
 import io.lettuce.core.event.command.CommandListener;
 import io.lettuce.core.event.connection.ConnectEvent;
@@ -82,7 +83,7 @@
  * @see ClientResources
  * @see DefaultClientResources
  */
-public abstract class AbstractRedisClient implements AutoCloseable {
+public abstract class AbstractRedisClient implements BaseRedisClient {
 
     private static final InternalLogger logger = InternalLoggerFactory.getInstance(AbstractRedisClient.class);
 
@@ -176,6 +177,7 @@ protected int getResourceCount() {
      *
      * @param listener must not be {@code null}.
      */
+    @Override
     public void addListener(RedisConnectionStateListener listener) {
 
         LettuceAssert.notNull(listener, "RedisConnectionStateListener must not be null");
@@ -187,6 +189,7 @@ public void addListener(RedisConnectionStateListener listener) {
      *
      * @param listener must not be {@code null}.
      */
+    @Override
     public void removeListener(RedisConnectionStateListener listener) {
 
         LettuceAssert.notNull(listener, "RedisConnectionStateListener must not be null");
@@ -199,6 +202,7 @@ public void removeListener(RedisConnectionStateListener listener) {
      * @param listener must not be {@code null}.
      * @since 6.1
      */
+    @Override
     public void addListener(CommandListener listener) {
 
         LettuceAssert.notNull(listener, "CommandListener must not be null");
@@ -211,6 +215,7 @@ public void addListener(CommandListener listener) {
      * @param listener must not be {@code null}.
      * @since 6.1
      */
+    @Override
     public void removeListener(CommandListener listener) {
 
         LettuceAssert.notNull(listener, "CommandListener must not be null");
@@ -448,6 +453,7 @@ private void initializeChannelAsync0(ConnectionBuilder connectionBuilder, Comple
      *
      * @see EventExecutorGroup#shutdownGracefully(long, long, TimeUnit)
      */
+    @Override
     public void shutdown() {
         shutdown(0, 2, TimeUnit.SECONDS);
     }
@@ -468,6 +474,7 @@ public void close() {
      * @since 5.0
      * @see EventExecutorGroup#shutdownGracefully(long, long, TimeUnit)
      */
+    @Override
     public void shutdown(Duration quietPeriod, Duration timeout) {
         shutdown(quietPeriod.toNanos(), timeout.toNanos(), TimeUnit.NANOSECONDS);
     }
@@ -483,6 +490,7 @@ public void shutdown(Duration quietPeriod, Duration timeout) {
      * @param timeUnit the unit of {@code quietPeriod} and {@code timeout}.
      * @see EventExecutorGroup#shutdownGracefully(long, long, TimeUnit)
      */
+    @Override
     public void shutdown(long quietPeriod, long timeout, TimeUnit timeUnit) {
 
         try {
@@ -501,6 +509,7 @@ public void shutdown(long quietPeriod, long timeout, TimeUnit timeUnit) {
      * @since 4.4
      * @see EventExecutorGroup#shutdownGracefully(long, long, TimeUnit)
      */
+    @Override
     public CompletableFuture<Void> shutdownAsync() {
         return shutdownAsync(0, 2, TimeUnit.SECONDS);
     }
@@ -517,6 +526,7 @@ public CompletableFuture<Void> shutdownAsync() {
      * @since 4.4
      * @see EventExecutorGroup#shutdownGracefully(long, long, TimeUnit)
      */
+    @Override
     public CompletableFuture<Void> shutdownAsync(long quietPeriod, long timeout, TimeUnit timeUnit) {
 
         if (shutdown.compareAndSet(false, true)) {