Merge pull request #4 from shacharPash/AddModuls

Add moduls

Author: shacharPash

src/NRedisStack.Core/RedisStackCommands/Bloom.cs renamed to src/NRedisStack.Core/Bloom/BloomCommands.cs

@@ -1,15 +1,23 @@
 using StackExchange.Redis;
-namespace NRedisStack.Core.RedisStackCommands
+namespace NRedisStack.Core
 {
-    public static class RedisBloomCommands
+
+    public class BloomCommands
     {
-        public static RedisResult BfAdd(this IDatabase db, RedisKey key, string item)
+        IDatabase _db;
+        public BloomCommands(IDatabase db)
         {
-            return db.Execute("BF.ADD", key, item);
+            _db = db;
         }
-        public static RedisResult BfExists(this IDatabase db, RedisKey key, string item)
+
+
+        public RedisResult Add(RedisKey key, string item)
         {
-            return db.Execute("BF.EXISTS", key, item);
+            return _db.Execute("BF.ADD", key, item);
+        }
+        public RedisResult Exists(RedisKey key, string item)
+        {
+            return _db.Execute("BF.EXISTS", key, item);
         }
         /*public static string ADD => "BF.ADD";
         public static string EXISTS => "BF.EXISTS";
@@ -21,4 +29,6 @@ public static RedisResult BfExists(this IDatabase db, RedisKey key, string item)
         public static string RESERVE => "BF.RESERVE";
         public static string SCANDUMP => "BF.SCANDUMP";*/
     }
-}
+
+
+}

src/NRedisStack.Core/RedisStackCommands/Json.cs renamed to src/NRedisStack.Core/Json/JsonCommands.cs

@@ -2,34 +2,39 @@
 using System.Text.Json;
 using System.Text.Json.Serialization;
 
-namespace NRedisStack.Core.Json;
+namespace NRedisStack.Core;
 
-public static class JSON
+public class JsonCommands
 {
-    private static readonly JsonSerializerOptions Options = new()
+    IDatabase _db;
+    public JsonCommands(IDatabase db)
+    {
+        _db = db;
+    }
+    private readonly JsonSerializerOptions Options = new()
     {
         DefaultIgnoreCondition = JsonIgnoreCondition.WhenWritingNull,
     };
-    public static RedisResult JsonSet(this IDatabase db, RedisKey key, string path, object obj, When when = When.Always)
+    public RedisResult Set(RedisKey key, string path, object obj, When when = When.Always)
     {
         string json = JsonSerializer.Serialize(obj);
-        return JsonSet(db, key, path, json, when);
+        return Set(key, path, json, when);
     }
 
-    public static RedisResult JsonSet(this IDatabase db, RedisKey key, string path, string json, When when = When.Always)
+    public RedisResult Set(RedisKey key, string path, string json, When when = When.Always)
     {
         switch (when)
         {
             case When.Exists:
-                return db.Execute("JSON.SET", key, path, json, "XX");
+                return _db.Execute("JSON.SET", key, path, json, "XX");
             case When.NotExists:
-                return db.Execute("JSON.SET", key, path, json, "NX");
+                return _db.Execute("JSON.SET", key, path, json, "NX");
             default:
-                return db.Execute("JSON.SET", key, path, json);
+                return _db.Execute("JSON.SET", key, path, json);
         }
     }
 
-    public static RedisResult JsonGet(this IDatabase db, RedisKey key, string indent = "",
+    public RedisResult Get(RedisKey key, string indent = "",
                                       string newLine = "", string space = "", string path = "")
     {
         List<object> subcommands = new List<object>();
@@ -56,6 +61,6 @@ public static RedisResult JsonGet(this IDatabase db, RedisKey key, string indent
         {
             subcommands.Add(path);
         }
-        return db.Execute("JSON.GET", subcommands.ToArray());
+        return _db.Execute("JSON.GET", subcommands.ToArray());
     }
 }

src/NRedisStack.Core/ModulPrefixes.cs

@@ -0,0 +1,27 @@
+using StackExchange.Redis;
+
+namespace NRedisStack.Core.RedisStackCommands
+{
+    public static class ModulPrefixes
+    {
+        static public BloomCommands BF(this IDatabase db)
+        {
+            return new BloomCommands(db);
+        }
+
+        static public SearchCommands FT(this IDatabase db)
+        {
+            return new SearchCommands(db);
+        }
+
+        static public JsonCommands JSON(this IDatabase db)
+        {
+            return new JsonCommands(db);
+        }
+
+        static public TimeSeriesCommands TS(this IDatabase db)
+        {
+            return new TimeSeriesCommands(db);
+        }
+    }
+}

src/NRedisStack.Core/RedisStackCommands/Search.cs

@@ -0,0 +1,16 @@
+using StackExchange.Redis;
+namespace NRedisStack.Core
+{
+    public class SearchCommands
+    {
+        IDatabase _db;
+        public SearchCommands(IDatabase db)
+        {
+            _db = db;
+        }
+        public RedisResult FtInfo(string index)
+        {
+            return _db.Execute("FT.INFO", index);
+        }
+    }
+}

src/NRedisStack.Core/Search/SearchCommands.cs

@@ -1,4 +1,4 @@
-namespace NRedisStack.Core.TimeSeries.Commands
+namespace NRedisStack.Core.Commands
 {
     internal class CommandArgs
     {
@@ -19,5 +19,6 @@ internal class CommandArgs
         public static string REDUCE => "REDUCE";
         public static string FILTER_BY_TS => "FILTER_BY_TS";
         public static string FILTER_BY_VALUE => "FILTER_BY_VALUE";
+
     }
-}
+}

src/NRedisStack.Core/TimeSeries/Commands/CommandArgs.cs

@@ -1,15 +1,14 @@
-namespace NRedisStack.Core.RedisStackCommands
+namespace NRedisStack.Core.Commands
 {
-    public static class TS
+    internal class TS
     {
-        
-        //TODO: INFO, CREATE, ALTER
-        /*public static string CREATE => "TS.CREATE";
+        public static string CREATE => "TS.CREATE";
         public static string ALTER => "TS.ALTER";
         public static string ADD => "TS.ADD";
         public static string MADD => "TS.MADD";
         public static string INCRBY => "TS.INCRBY";
         public static string DECRBY => "TS.DECRBY";
+        public static string DEL => "TS.DEL";
         public static string CREATERULE => "TS.CREATERULE";
         public static string DELETERULE => "TS.DELETERULE";
         public static string RANGE => "TS.RANGE";
@@ -19,6 +18,6 @@ public static class TS
         public static string GET => "TS.GET";
         public static string MGET => "TS.MGET";
         public static string INFO => "TS.INFO";
-        public static string QUERYINDEX => "TS.QUERYINDEX";*/
+        public static string QUERYINDEX => "TS.QUERYINDEX";
     }
-}
+}

src/NRedisStack.Core/RedisStackCommands/ TimeSeries.cs renamed to src/NRedisStack.Core/TimeSeries/Commands/Commands.cs

@@ -0,0 +1,73 @@
+namespace NRedisStack.Core.Commands.Enums
+{
+    /// <summary>
+    /// An aggregation type to be used with a time bucket.
+    /// </summary>
+    public enum TsAggregation
+    {
+        /// <summary>
+        /// The average of all samples in the aggregation
+        /// </summary>
+        Avg,
+
+        /// <summary>
+        /// A sum of all samples in the aggregation
+        /// </summary>
+        Sum,
+
+        /// <summary>
+        /// A minimum sample of all samples in the aggregation
+        /// </summary>
+        Min,
+
+        /// <summary>
+        /// A maximum sample of all samples in the aggregation
+        /// </summary>
+        Max,
+
+        /// <summary>
+        /// A range of the min and max sample of all samples in the aggregation (range r = max-min)
+        /// For example if the min sample was 100 and the max was 400, the range aggregation would return 300
+        /// </summary>
+        Range,
+
+        /// <summary>
+        /// The total number of all samples in the aggregation
+        /// </summary>
+        Count,
+
+        /// <summary>
+        /// The first sample in the aggregation
+        /// </summary>
+        First,
+
+        /// <summary>
+        /// The last sample in the aggregation
+        /// </summary>
+        Last,
+
+        /// <summary>
+        /// The standard deviation based on the entire population
+        /// The standard deviation is a measure of how widely values are dispersed from the average sample in the aggregation
+        /// </summary>
+        StdP,
+
+        /// <summary>
+        /// The standard deviation based on a sample of the population
+        /// The standard deviation is a measure of how widely values are dispersed from the average sample in the aggregation
+        /// </summary>
+        StdS,
+
+        /// <summary>
+        /// The variance based on the entire population
+        /// The variance is the average of the squared differences from the mean
+        /// </summary>
+        VarP,
+
+        /// <summary>
+        /// The variance based on a sample of the population
+        /// The variance is the average of the squared differences from the mean
+        /// </summary>
+        VarS,
+    }
+}

src/NRedisStack.Core/TimeSeries/Commands/Enums/Aggregation.cs

@@ -0,0 +1,41 @@
+namespace NRedisStack.Core.Commands.Enums
+{
+    /// <summary>
+    /// Policy to handle duplicate samples.
+    /// The default policy for database-wide is BLOCK.
+    /// </summary>
+    public enum TsDuplicatePolicy
+    {
+        /// <summary>
+        /// An error will occur for any out of order sample.
+        /// </summary>
+        BLOCK,
+
+        /// <summary>
+        /// Ignore the new value.
+        /// </summary>
+        FIRST,
+
+        /// <summary>
+        /// Override with latest value.
+        /// </summary>
+        LAST,
+
+        /// <summary>
+        /// Only override if the value is lower than the existing value.
+        /// </summary>
+        MIN,
+
+        /// <summary>
+        /// Only override if the value is higher than the existing value.
+        /// </summary>
+        MAX,
+
+        /// <summary>
+        /// If a previous sample exists, add the new sample to it so that the updated value is equal to (previous + new).
+        /// If no previous sample exists, set the updated value equal to the new value.
+        /// </summary>
+        SUM
+    }
+}
+

src/NRedisStack.Core/TimeSeries/Commands/Enums/DuplicatePolicy.cs

@@ -0,0 +1,23 @@
+namespace NRedisStack.Core.Commands.Enums
+{
+    /// <summary>
+    /// TODO: Add description
+    /// </summary>
+    public enum TsReduce
+    {
+        /// <summary>
+        /// A sum of all samples in the group
+        /// </summary>
+        Sum,
+
+        /// <summary>
+        /// A minimum sample of all samples in the group
+        /// </summary>
+        Min,
+
+        /// <summary>
+        /// A maximum sample of all samples in the group
+        /// </summary>
+        Max,
+    }
+}