Implement new TDIGEST commands and TDIGEST.CREATE compression (#33)

* Update Tdigest Commands

* Fix Rank Commands Tests

Author: shacharPash

src/NRedisStack/ResponseParser.cs

@@ -368,11 +368,11 @@ public static IReadOnlyList<TimeSeriesRule> ToRuleArray(this RedisResult result)
 
         public static TdigestInformation ToTdigestInfo(this RedisResult result) //TODO: Think about a different implementation, because if the output of CMS.INFO changes or even just the names of the labels then the parsing will not work
         {
-            long compression, capacity, mergedNodes, unmergedNodes, totalCompressions;
-            double mergedWeight, unmergedWeight;
+            long compression, capacity, mergedNodes, unmergedNodes, totalCompressions, memoryUsage;
+            double mergedWeight, unmergedWeight, sumWeight;
 
-            compression = capacity = mergedNodes = unmergedNodes = totalCompressions = -1;
-            mergedWeight = unmergedWeight = -1.0;
+            compression = capacity = mergedNodes = unmergedNodes = totalCompressions = memoryUsage = -1;
+            mergedWeight = unmergedWeight = sumWeight = -1.0;
 
             RedisResult[] redisResults = result.ToArray();
 
@@ -395,20 +395,25 @@ public static IReadOnlyList<TimeSeriesRule> ToRuleArray(this RedisResult result)
                         unmergedNodes = (long)redisResults[i];
                         break;
                     case "Merged weight":
-
                         mergedWeight = (double)redisResults[i];
                         break;
                     case "Unmerged weight":
                         unmergedWeight = (double)redisResults[i];
                         break;
+                    case "Sum weights":
+                        sumWeight = (double)redisResults[i];
+                        break;
                     case "Total compressions":
                         totalCompressions = (long)redisResults[i];
                         break;
+                    case "Memory usage":
+                        memoryUsage = (long)redisResults[i];
+                        break;
                 }
             }
 
             return new TdigestInformation(compression, capacity, mergedNodes, unmergedNodes,
-                                          mergedWeight, unmergedWeight, totalCompressions);
+                                          mergedWeight, unmergedWeight, sumWeight, totalCompressions, memoryUsage);
         }
 
         public static TimeSeriesInformation ToTimeSeriesInfo(this RedisResult result)
@@ -531,7 +536,7 @@ public static IReadOnlyList<string> ToStringArray(this RedisResult result)
             Array.ForEach(redisResults, str => list.Add((string)str));
             return list;
         }
-        
+
         public static long?[] ToNullableLongArray(this RedisResult result)
         {
             if (result.IsNull)

src/NRedisStack/Tdigest/DataTypes/TdigestInformation.cs

@@ -12,13 +12,14 @@ public class TdigestInformation
         public long UnmergedNodes { get; private set; }
         public double MergedWeight { get; private set; }
         public double UnmergedWeight { get; private set; }
-
+        public double SumWeights { get; private set; }
         public long TotalCompressions { get; private set; }
+        public long MemoryUsage { get; private set; }
 
 
         internal TdigestInformation(long compression, long capacity, long mergedNodes,
                                     long unmergedNodes, double mergedWeight,
-                                    double unmergedWeight, long totalCompressions)
+                                    double unmergedWeight, double sumWeights, long totalCompressions, long memoryUsage)
 
         {
             Compression = compression;
@@ -27,7 +28,9 @@ internal TdigestInformation(long compression, long capacity, long mergedNodes,
             UnmergedNodes = unmergedNodes;
             MergedWeight = mergedWeight;
             UnmergedWeight = unmergedWeight;
+            SumWeights = sumWeights;
             TotalCompressions = totalCompressions;
+            MemoryUsage = memoryUsage;
         }
     }
 }

src/NRedisStack/Tdigest/Literals/Commands.cs

@@ -13,5 +13,9 @@ internal class TDIGEST
         public const string CDF = "TDIGEST.CDF";
         public const string TRIMMED_MEAN = "TDIGEST.TRIMMED_MEAN";
         public const string INFO = "TDIGEST.INFO";
+        public const string RANK = "TDIGEST.RANK";
+        public const string REVRANK = "TDIGEST.REVRANK";
+        public const string BYRANK = "TDIGEST.BYRANK";
+        public const string BYREVRANK = "TDIGEST.BYREVRANK";
     }
 }