Add getCodec method to StatefulConnection (#3444)

* Add getCodec method to StatefulRedisClusterConnectionImpl

* feat: Added `StatefulConnection.getCodec()` method

* Formatting fix and and some re-wording

* One file was missed in the original change

---------

Co-authored-by: Tihomir Mateev <tihomir.mateev@gmail.com>

Author: jruaux

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

@@ -109,6 +109,7 @@ public StatefulRedisConnectionImpl(RedisChannelWriter writer, PushHandler pushHa
         this.reactive = newRedisReactiveCommandsImpl();
     }
 
+    @Override
     public RedisCodec<K, V> getCodec() {
         return codec;
     }

src/main/java/io/lettuce/core/api/StatefulConnection.java

@@ -6,6 +6,7 @@
 
 import io.lettuce.core.ClientOptions;
 import io.lettuce.core.RedisConnectionStateListener;
+import io.lettuce.core.codec.RedisCodec;
 import io.lettuce.core.protocol.RedisCommand;
 import io.lettuce.core.resource.ClientResources;
 
@@ -117,4 +118,9 @@ public interface StatefulConnection<K, V> extends AutoCloseable, AsyncCloseable
      */
     void flushCommands();
 
+    /**
+     * @return the {@link RedisCodec} used by this connection.
+     */
+    RedisCodec<K, V> getCodec();
+
 }

src/main/java/io/lettuce/core/cluster/StatefulRedisClusterConnectionImpl.java

@@ -126,6 +126,11 @@ public StatefulRedisClusterConnectionImpl(RedisChannelWriter writer, ClusterPush
         this.reactive = newRedisAdvancedClusterReactiveCommandsImpl();
     }
 
+    @Override
+    public RedisCodec<K, V> getCodec() {
+        return codec;
+    }
+
     protected RedisAdvancedClusterReactiveCommandsImpl<K, V> newRedisAdvancedClusterReactiveCommandsImpl() {
         return new RedisAdvancedClusterReactiveCommandsImpl<>((StatefulRedisClusterConnection<K, V>) this, codec, parser);
     }

src/main/java/io/lettuce/core/masterslave/MasterSlaveConnectionWrapper.java

@@ -11,6 +11,7 @@
 import io.lettuce.core.api.push.PushListener;
 import io.lettuce.core.api.reactive.RedisReactiveCommands;
 import io.lettuce.core.api.sync.RedisCommands;
+import io.lettuce.core.codec.RedisCodec;
 import io.lettuce.core.masterreplica.StatefulRedisMasterReplicaConnection;
 import io.lettuce.core.protocol.RedisCommand;
 import io.lettuce.core.resource.ClientResources;
@@ -134,4 +135,9 @@ public void flushCommands() {
         delegate.flushCommands();
     }
 
+    @Override
+    public RedisCodec<K, V> getCodec() {
+        return delegate.getCodec();
+    }
+
 }

src/main/java/io/lettuce/core/sentinel/StatefulRedisSentinelConnectionImpl.java

@@ -128,6 +128,11 @@ public ConnectionState getConnectionState() {
         return connectionState;
     }
 
+    @Override
+    public RedisCodec<K, V> getCodec() {
+        return codec;
+    }
+
     static class SentinelConnectionState extends ConnectionState {
 
         @Override