Missed several crucial files

Author: tishun

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

@@ -34,7 +34,6 @@
 import io.lettuce.core.output.KeyValueStreamingChannel;
 import io.lettuce.core.output.ScoredValueStreamingChannel;
 import io.lettuce.core.output.ValueStreamingChannel;
-import io.lettuce.core.output.data.DynamicAggregateData;
 import io.lettuce.core.protocol.AsyncCommand;
 import io.lettuce.core.protocol.Command;
 import io.lettuce.core.protocol.CommandArgs;
@@ -391,7 +390,7 @@ public RedisFuture<String> clientTracking(TrackingArgs args) {
     }
 
     @Override
-    public RedisFuture<DynamicAggregateData> clientTrackinginfo() {
+    public RedisFuture<TrackingInfo> clientTrackinginfo() {
         return dispatch(commandBuilder.clientTrackinginfo());
     }
 

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

@@ -34,7 +34,6 @@
 import io.lettuce.core.output.KeyValueStreamingChannel;
 import io.lettuce.core.output.ScoredValueStreamingChannel;
 import io.lettuce.core.output.ValueStreamingChannel;
-import io.lettuce.core.output.data.DynamicAggregateData;
 import io.lettuce.core.protocol.Command;
 import io.lettuce.core.protocol.CommandArgs;
 import io.lettuce.core.protocol.CommandType;
@@ -409,7 +408,7 @@ public Mono<String> clientTracking(TrackingArgs args) {
     }
 
     @Override
-    public Mono<DynamicAggregateData> clientTrackinginfo() {
+    public Mono<TrackingInfo> clientTrackinginfo() {
         return createMono(commandBuilder::clientTrackinginfo);
     }
 

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

@@ -28,7 +28,6 @@
 import io.lettuce.core.models.stream.PendingMessage;
 import io.lettuce.core.models.stream.PendingMessages;
 import io.lettuce.core.output.*;
-import io.lettuce.core.output.data.DynamicAggregateData;
 import io.lettuce.core.protocol.BaseRedisCommandBuilder;
 import io.lettuce.core.protocol.Command;
 import io.lettuce.core.protocol.CommandArgs;
@@ -529,10 +528,10 @@ Command<K, V, String> clientTracking(TrackingArgs trackingArgs) {
         return createCommand(CLIENT, new StatusOutput<>(codec), args);
     }
 
-    Command<K, V, DynamicAggregateData> clientTrackinginfo() {
+    Command<K, V, TrackingInfo> clientTrackinginfo() {
         CommandArgs<K, V> args = new CommandArgs<>(codec).add(TRACKINGINFO);
 
-        return new Command<>(CLIENT, new DynamicAggregateOutput<>(codec), args);
+        return new Command<>(CLIENT, new ComplexOutput<>(codec, TrackingInfoParser.INSTANCE), args);
     }
 
     Command<K, V, Long> clientUnblock(long id, UnblockType type) {

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

@@ -18,7 +18,7 @@
  * limitations under the License.
  */
 
-package io.lettuce.core.api.parsers.tracking;
+package io.lettuce.core;
 
 import java.util.ArrayList;
 import java.util.Collections;

src/main/java/io/lettuce/core/api/async/RedisServerAsyncCommands.java

@@ -30,7 +30,7 @@
 import io.lettuce.core.ShutdownArgs;
 import io.lettuce.core.TrackingArgs;
 import io.lettuce.core.UnblockType;
-import io.lettuce.core.output.data.DynamicAggregateData;
+import io.lettuce.core.TrackingInfo;
 import io.lettuce.core.protocol.CommandType;
 
 /**
@@ -181,12 +181,10 @@ public interface RedisServerAsyncCommands<K, V> {
     /**
      * Returns information about the current client connection's use of the server assisted client side caching feature.
      *
-     * @return {@link DynamicAggregateData}, for more information check the documentation
-     * @see io.lettuce.core.api.parsers.tracking.TrackingInfoParser
-     * @see io.lettuce.core.api.parsers.tracking.TrackingInfo
-     * @since 7.0
+     * @return {@link TrackingInfo}, for more information check the documentation
+     * @since 6.5
      */
-    RedisFuture<DynamicAggregateData> clientTrackinginfo();
+    RedisFuture<TrackingInfo> clientTrackinginfo();
 
     /**
      * Unblock the specified blocked client.

src/main/java/io/lettuce/core/api/reactive/RedisServerReactiveCommands.java

@@ -28,7 +28,7 @@
 import io.lettuce.core.ShutdownArgs;
 import io.lettuce.core.TrackingArgs;
 import io.lettuce.core.UnblockType;
-import io.lettuce.core.output.data.DynamicAggregateData;
+import io.lettuce.core.TrackingInfo;
 import io.lettuce.core.protocol.CommandType;
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
@@ -181,12 +181,10 @@ public interface RedisServerReactiveCommands<K, V> {
     /**
      * Returns information about the current client connection's use of the server assisted client side caching feature.
      *
-     * @return {@link DynamicAggregateData}, for more information check the documentation
-     * @see io.lettuce.core.api.parsers.tracking.TrackingInfoParser
-     * @see io.lettuce.core.api.parsers.tracking.TrackingInfo
-     * @since 7.0
+     * @return {@link TrackingInfo}, for more information check the documentation
+     * @since 6.5
      */
-    Mono<DynamicAggregateData> clientTrackinginfo();
+    Mono<TrackingInfo> clientTrackinginfo();
 
     /**
      * Unblock the specified blocked client.

src/main/java/io/lettuce/core/api/sync/RedisServerCommands.java

@@ -28,8 +28,8 @@
 import io.lettuce.core.KillArgs;
 import io.lettuce.core.ShutdownArgs;
 import io.lettuce.core.TrackingArgs;
+import io.lettuce.core.TrackingInfo;
 import io.lettuce.core.UnblockType;
-import io.lettuce.core.output.data.DynamicAggregateData;
 import io.lettuce.core.protocol.CommandType;
 
 /**
@@ -180,12 +180,10 @@ public interface RedisServerCommands<K, V> {
     /**
      * Returns information about the current client connection's use of the server assisted client side caching feature.
      *
-     * @return {@link DynamicAggregateData}, for more information check the documentation
-     * @see io.lettuce.core.api.parsers.tracking.TrackingInfoParser
-     * @see io.lettuce.core.api.parsers.tracking.TrackingInfo
-     * @since 7.0
+     * @return {@link TrackingInfo}, for more information check the documentation
+     * @since 6.5
      */
-    DynamicAggregateData clientTrackinginfo();
+    TrackingInfo clientTrackinginfo();
 
     /**
      * Unblock the specified blocked client.

src/main/java/io/lettuce/core/cluster/api/async/NodeSelectionServerAsyncCommands.java

@@ -19,16 +19,15 @@
  */
 package io.lettuce.core.cluster.api.async;
 
-import java.util.Date;
-import java.util.List;
 import java.util.Map;
-
+import java.util.List;
+import java.util.Date;
 import io.lettuce.core.ClientListArgs;
 import io.lettuce.core.FlushMode;
 import io.lettuce.core.KillArgs;
 import io.lettuce.core.TrackingArgs;
 import io.lettuce.core.UnblockType;
-import io.lettuce.core.output.data.DynamicAggregateData;
+import io.lettuce.core.TrackingInfo;
 import io.lettuce.core.protocol.CommandType;
 
 /**
@@ -179,12 +178,10 @@ public interface NodeSelectionServerAsyncCommands<K, V> {
     /**
      * Returns information about the current client connection's use of the server assisted client side caching feature.
      *
-     * @return {@link DynamicAggregateData}, for more information check the documentation
-     * @see io.lettuce.core.api.parsers.tracking.TrackingInfoParser
-     * @see io.lettuce.core.api.parsers.tracking.TrackingInfo
-     * @since 7.0
+     * @return {@link TrackingInfo}, for more information check the documentation
+     * @since 6.5
      */
-    AsyncExecutions<DynamicAggregateData> clientTrackinginfo();
+    AsyncExecutions<TrackingInfo> clientTrackinginfo();
 
     /**
      * Unblock the specified blocked client.

src/main/java/io/lettuce/core/cluster/api/sync/NodeSelectionServerCommands.java

@@ -28,7 +28,7 @@
 import io.lettuce.core.KillArgs;
 import io.lettuce.core.TrackingArgs;
 import io.lettuce.core.UnblockType;
-import io.lettuce.core.output.data.DynamicAggregateData;
+import io.lettuce.core.TrackingInfo;
 import io.lettuce.core.protocol.CommandType;
 
 /**
@@ -164,7 +164,7 @@ public interface NodeSelectionServerCommands<K, V> {
      * @return simple-string-reply {@code OK} if the connection name was successfully set.
      * @since 6.3
      */
-    Executions<String> clientSetinfo(String key, V value);
+    Executions<String> clientSetinfo(String key, String value);
 
     /**
      * Enables the tracking feature of the Redis server, that is used for server assisted client side caching. Tracking messages
@@ -179,12 +179,10 @@ public interface NodeSelectionServerCommands<K, V> {
     /**
      * Returns information about the current client connection's use of the server assisted client side caching feature.
      *
-     * @return {@link DynamicAggregateData}, for more information check the documentation
-     * @see io.lettuce.core.api.parsers.tracking.TrackingInfoParser
-     * @see io.lettuce.core.api.parsers.tracking.TrackingInfo
-     * @since 7.0
+     * @return {@link TrackingInfo}, for more information check the documentation
+     * @since 6.5
      */
-    Executions<DynamicAggregateData> clientTrackinginfo();
+    Executions<TrackingInfo> clientTrackinginfo();
 
     /**
      * Unblock the specified blocked client.

src/main/java/io/lettuce/core/output/ArrayComplexData.java

@@ -29,25 +29,25 @@
 import java.util.Set;
 
 /**
- * An implementation of the {@link DynamicAggregateData} that handles arrays.
+ * An implementation of the {@link ComplexData} that handles arrays.
  * <p>
- * For RESP2 calling the {@link DynamicAggregateData#getDynamicMap()} would heuristically go over the list of elements assuming
- * every odd element is a key and every even object is the value and then adding them to an {@link Map}. The logic would follow
- * the same order that was used when the elements were added to the {@link ArrayAggregateData}. Similarly calling the
- * {@link DynamicAggregateData#getDynamicSet()} would return a set of all the elements, adding them in the same order. If - for
- * some reason - duplicate elements exist they would be overwritten.
+ * For RESP2 calling the {@link ComplexData#getDynamicMap()} would heuristically go over the list of elements assuming every odd
+ * element is a key and every even object is the value and then adding them to an {@link Map}. The logic would follow the same
+ * order that was used when the elements were added to the {@link ArrayComplexData}. Similarly calling the
+ * {@link ComplexData#getDynamicSet()} would return a set of all the elements, adding them in the same order. If - for some
+ * reason - duplicate elements exist they would be overwritten.
  * <p>
  * All data structures that the implementation returns are unmodifiable
  *
- * @see DynamicAggregateData
+ * @see ComplexData
  * @author Tihomir Mateev
  * @since 6.5
  */
-class ArrayAggregateData extends DynamicAggregateData {
+class ArrayComplexData extends ComplexData {
 
     private final List<Object> data;
 
-    public ArrayAggregateData(int count) {
+    public ArrayComplexData(int count) {
         data = new ArrayList<>(count);
     }