Implemented new TsTimeStamp type. Updated examples and tests.

NRedisTimeSeries.Example/AddExample.cs

@@ -19,8 +19,7 @@ public static void DefaultAdd()
         {
             ConnectionMultiplexer redis = ConnectionMultiplexer.Connect("localhost");
             IDatabase db = redis.GetDatabase();
-            TimeStamp timestamp = "*";
-            db.TimeSeriesAdd("my_ts", timestamp, 0.0);
+            db.TimeSeriesAdd("my_ts", 0.0);
             redis.Close();
         }
 
@@ -33,7 +32,7 @@ public static void LongAdd()
         {
             ConnectionMultiplexer redis = ConnectionMultiplexer.Connect("localhost");
             IDatabase db = redis.GetDatabase();
-            TimeStamp timestamp = 1;
+            var timestamp = new TsTimeStamp(1);
             db.TimeSeriesAdd("my_ts", timestamp, 0.0);
             redis.Close();
         }
@@ -47,7 +46,7 @@ public static void DateTimeAdd()
         {
             ConnectionMultiplexer redis = ConnectionMultiplexer.Connect("localhost");
             IDatabase db = redis.GetDatabase();
-            TimeStamp timestamp = DateTime.UtcNow;
+            var timestamp = DateTime.UtcNow;
             db.TimeSeriesAdd("my_ts", timestamp, 0.0);
             redis.Close();
         }
@@ -60,10 +59,9 @@ public static void ParameterizedAdd()
         {
             ConnectionMultiplexer redis = ConnectionMultiplexer.Connect("localhost");
             IDatabase db = redis.GetDatabase();
-            TimeStamp timestamp = "*";
             var label = new TimeSeriesLabel("key", "value");
             var labels = new List<TimeSeriesLabel> { label };
-            db.TimeSeriesAdd("my_ts", timestamp, 0.0, retentionTime:5000, labels:labels, uncompressed:true);
+            db.TimeSeriesAdd("my_ts", 0.0, retentionTime: 5000, labels: labels, uncompressed: true);
             redis.Close();
         }
     }

NRedisTimeSeries.Example/AddExampleAsync.cs

@@ -1,8 +1,8 @@
-using System;
+using NRedisTimeSeries.DataTypes;
+using StackExchange.Redis;
+using System;
 using System.Collections.Generic;
 using System.Threading.Tasks;
-using NRedisTimeSeries.DataTypes;
-using StackExchange.Redis;
 
 namespace NRedisTimeSeries.Example
 {
@@ -20,8 +20,7 @@ public static async Task DefaultAddAsync()
         {
             ConnectionMultiplexer redis = ConnectionMultiplexer.Connect("localhost");
             IDatabase db = redis.GetDatabase();
-            TimeStamp timestamp = "*";
-            await db.TimeSeriesAddAsync("my_ts", timestamp, 0.0);
+            await db.TimeSeriesAddAsync("my_ts", 0.0);
             redis.Close();
         }
 
@@ -34,7 +33,7 @@ public static async Task LongAddAsync()
         {
             ConnectionMultiplexer redis = ConnectionMultiplexer.Connect("localhost");
             IDatabase db = redis.GetDatabase();
-            TimeStamp timestamp = 1;
+            var timestamp = new TsTimeStamp(1);
             await db.TimeSeriesAddAsync("my_ts", timestamp, 0.0);
             redis.Close();
         }
@@ -48,7 +47,7 @@ public static async Task DateTimeAddAsync()
         {
             ConnectionMultiplexer redis = ConnectionMultiplexer.Connect("localhost");
             IDatabase db = redis.GetDatabase();
-            TimeStamp timestamp = DateTime.UtcNow;
+            var timestamp = DateTime.UtcNow;
             await db.TimeSeriesAddAsync("my_ts", timestamp, 0.0);
             redis.Close();
         }
@@ -61,10 +60,9 @@ public static async Task ParameterizedAddAsync()
         {
             ConnectionMultiplexer redis = ConnectionMultiplexer.Connect("localhost");
             IDatabase db = redis.GetDatabase();
-            TimeStamp timestamp = "*";
             var label = new TimeSeriesLabel("key", "value");
             var labels = new List<TimeSeriesLabel> { label };
-            await db.TimeSeriesAddAsync("my_ts", timestamp, 0.0, retentionTime:5000, labels:labels, uncompressed:true);
+            await db.TimeSeriesAddAsync("my_ts", 0.0, retentionTime: 5000, labels: labels, uncompressed: true);
             redis.Close();
         }
     }

NRedisTimeSeries.Example/DecrByExample.cs

@@ -1,7 +1,6 @@
-using System;
-using System.Collections.Generic;
-using NRedisTimeSeries.DataTypes;
+using NRedisTimeSeries.DataTypes;
 using StackExchange.Redis;
+using System.Collections.Generic;
 
 namespace NRedisTimeSeries.Example
 {
@@ -28,7 +27,7 @@ public static void SystemTimeIncrByExample()
         {
             ConnectionMultiplexer redis = ConnectionMultiplexer.Connect("localhost");
             IDatabase db = redis.GetDatabase();
-            db.TimeSeriesDecrBy("my_ts", 5, timestamp: "*");
+            db.TimeSeriesDecrBy("my_ts", 5);
             redis.Close();
         }
 
@@ -39,7 +38,7 @@ public static void DateTimeIncrByExample()
         {
             ConnectionMultiplexer redis = ConnectionMultiplexer.Connect("localhost");
             IDatabase db = redis.GetDatabase();
-            db.TimeSeriesDecrBy("my_ts", 5, timestamp: DateTime.UtcNow);
+            db.TimeSeriesDecrBy("my_ts", 5);
             redis.Close();
         }
 
@@ -50,7 +49,7 @@ public static void LongIncrByExample()
         {
             ConnectionMultiplexer redis = ConnectionMultiplexer.Connect("localhost");
             IDatabase db = redis.GetDatabase();
-            db.TimeSeriesDecrBy("my_ts", 5, timestamp: long.MaxValue);
+            db.TimeSeriesDecrBy("my_ts", 5);
             redis.Close();
         }
 
@@ -64,7 +63,7 @@ public static void ParameterizedIncrByExample()
             IDatabase db = redis.GetDatabase();
             var label = new TimeSeriesLabel("key", "value");
             var labels = new List<TimeSeriesLabel> { label };
-            db.TimeSeriesDecrBy("my_ts", 5, timestamp: "*", retentionTime: 5000, uncompressed: true, labels: labels);
+            db.TimeSeriesDecrBy("my_ts", 5, retentionTime: 5000, uncompressed: true, labels: labels);
             redis.Close();
         }
     }

NRedisTimeSeries.Example/DecrByExampleAsync.cs

@@ -29,7 +29,7 @@ public static async Task SystemTimeDecrByAsyncExample()
         {
             ConnectionMultiplexer redis = ConnectionMultiplexer.Connect("localhost");
             IDatabase db = redis.GetDatabase();
-            await db.TimeSeriesDecrByAsync("my_ts", 5, timestamp: "*");
+            await db.TimeSeriesDecrByAsync("my_ts", 5);
             redis.Close();
         }
 
@@ -40,7 +40,7 @@ public static async Task DateTimeDecrByAsyncExample()
         {
             ConnectionMultiplexer redis = ConnectionMultiplexer.Connect("localhost");
             IDatabase db = redis.GetDatabase();
-            await db.TimeSeriesDecrByAsync("my_ts", 5, timestamp: DateTime.UtcNow);
+            await db.TimeSeriesDecrByAsync("my_ts", 5);
             redis.Close();
         }
 
@@ -51,7 +51,7 @@ public static async Task LongDecrByAsyncExample()
         {
             ConnectionMultiplexer redis = ConnectionMultiplexer.Connect("localhost");
             IDatabase db = redis.GetDatabase();
-            await db.TimeSeriesDecrByAsync("my_ts", 5, timestamp: long.MaxValue);
+            await db.TimeSeriesDecrByAsync("my_ts", 5);
             redis.Close();
         }
 
@@ -65,7 +65,7 @@ public static async Task ParameterizedDecrByAsyncExample()
             IDatabase db = redis.GetDatabase();
             var label = new TimeSeriesLabel("key", "value");
             var labels = new List<TimeSeriesLabel> { label };
-            await db.TimeSeriesDecrByAsync("my_ts", 5, timestamp: "*", retentionTime: 5000, uncompressed: true, labels: labels);
+            await db.TimeSeriesDecrByAsync("my_ts", 5, retentionTime: 5000, uncompressed: true, labels: labels);
             redis.Close();
         }
     }

NRedisTimeSeries.Example/IncrByExample.cs

@@ -28,7 +28,7 @@ public static void SystemTimeIncrByExample()
         {
             ConnectionMultiplexer redis = ConnectionMultiplexer.Connect("localhost");
             IDatabase db = redis.GetDatabase();
-            db.TimeSeriesIncrBy("my_ts", 5, timestamp: "*");
+            db.TimeSeriesIncrBy("my_ts", 5);
             redis.Close();
         }
 
@@ -39,7 +39,7 @@ public static void DateTimeIncrByExample()
         {
             ConnectionMultiplexer redis = ConnectionMultiplexer.Connect("localhost");
             IDatabase db = redis.GetDatabase();
-            db.TimeSeriesIncrBy("my_ts", 5, timestamp: DateTime.UtcNow);
+            db.TimeSeriesIncrBy("my_ts", 5);
             redis.Close();
         }
 
@@ -50,7 +50,7 @@ public static void LongIncrByExample()
         {
             ConnectionMultiplexer redis = ConnectionMultiplexer.Connect("localhost");
             IDatabase db = redis.GetDatabase();
-            db.TimeSeriesIncrBy("my_ts", 5, timestamp: long.MaxValue);
+            db.TimeSeriesIncrBy("my_ts", 5);
             redis.Close();
         }
 
@@ -64,7 +64,7 @@ public static void ParameterizedIncrByExample()
             IDatabase db = redis.GetDatabase();
             var label = new TimeSeriesLabel("key", "value");
             var labels = new List<TimeSeriesLabel> { label };
-            db.TimeSeriesIncrBy("my_ts", 5, timestamp: "*", retentionTime:5000, uncompressed:true, labels: labels);
+            db.TimeSeriesIncrBy("my_ts", 5, retentionTime: 5000, uncompressed: true, labels: labels);
             redis.Close();
         }
     }

NRedisTimeSeries.Example/IncrByExampleAsync.cs

@@ -29,7 +29,7 @@ public static async Task SystemTimeIncrByAsyncExample()
         {
             ConnectionMultiplexer redis = ConnectionMultiplexer.Connect("localhost");
             IDatabase db = redis.GetDatabase();
-            await db.TimeSeriesIncrByAsync("my_ts", 5, timestamp: "*");
+            await db.TimeSeriesIncrByAsync("my_ts", 5);
             redis.Close();
         }
 
@@ -40,7 +40,7 @@ public static async Task DateTimeIncrByAsyncExample()
         {
             ConnectionMultiplexer redis = ConnectionMultiplexer.Connect("localhost");
             IDatabase db = redis.GetDatabase();
-            await db.TimeSeriesIncrByAsync("my_ts", 5, timestamp: DateTime.UtcNow);
+            await db.TimeSeriesIncrByAsync("my_ts", 5);
             redis.Close();
         }
 
@@ -51,7 +51,7 @@ public static async Task LongIncrByAsyncExample()
         {
             ConnectionMultiplexer redis = ConnectionMultiplexer.Connect("localhost");
             IDatabase db = redis.GetDatabase();
-            await db.TimeSeriesIncrByAsync("my_ts", 5, timestamp: long.MaxValue);
+            await db.TimeSeriesIncrByAsync("my_ts", 5);
             redis.Close();
         }
 
@@ -65,7 +65,7 @@ public static async Task ParameterizedIncrByAsyncExample()
             IDatabase db = redis.GetDatabase();
             var label = new TimeSeriesLabel("key", "value");
             var labels = new List<TimeSeriesLabel> { label };
-            await db.TimeSeriesIncrByAsync("my_ts", 5, timestamp: "*", retentionTime: 5000, uncompressed: true, labels: labels);
+            await db.TimeSeriesIncrByAsync("my_ts", 5, retentionTime: 5000, uncompressed: true, labels: labels);
             redis.Close();
         }
     }

NRedisTimeSeries.Example/MAddExample.cs

@@ -11,19 +11,38 @@ namespace NRedisTimeSeries.Example
     internal class MAddExample
     {
         /// <summary>
-        /// Example for mutiple sample addtion. One is using RedisTimeSeris default system time in one time series,
-        /// the second is using DateTime in the second time series and the third is using long in the third time series.
+        /// Example for mutiple sample addtion. One is using default TsTimeStamp value in one time series,
+        /// the second is using current system DateTime in the second time series and the third is using a specified TsTimeStamp in the third time series.
         /// </summary>
-        public static void MAddFlowExample()
+        public static void MAddWithTimeStampExample()
         {
-            string[] keys = { "system_time_ts", "datetime_ts", "long_ts" };
-            var sequence = new List<(string, TimeStamp, double)>(keys.Length);
-            // Add sample to the system_time_ts
-            sequence.Add((keys[0], "*", 0.0));
-            // Add sample to the datetime_ts
-            sequence.Add((keys[1], DateTime.UtcNow, 0.0));
-            // Add sample to the long_ts
-            sequence.Add((keys[2], 1, 0.0));
+            string[] keys = { "ts_first", "ts_second", "ts_third" };
+            var sequence = new List<(string, TsTimeStamp, double)>(keys.Length)
+            {
+                (keys[0], default(TsTimeStamp), 1.0),
+                (keys[1], DateTime.UtcNow, 1.0),
+                (keys[2], new TsTimeStamp(1), 1.0)
+            };
+            ConnectionMultiplexer redis = ConnectionMultiplexer.Connect("localhost");
+            IDatabase db = redis.GetDatabase();
+            db.TimeSeriesMAdd(sequence);
+            redis.Close();
+        }
+
+        /// <summary>
+        /// Example for mutiple sample addtion using the Redis system timestamp. Two samples are added to the first timeseries,
+        /// and two samples are added to the second timeseries.
+        /// </summary>
+        public static void MAddWithoutTimeStampExample()
+        {
+            string[] keys = { "ts_first", "ts_second" };
+            var sequence = new List<(string, double)>(keys.Length)
+            {
+                (keys[0], 1.0),
+                (keys[0], 2.0),
+                (keys[1], 1.0),
+                (keys[1], 2.0)
+            };
             ConnectionMultiplexer redis = ConnectionMultiplexer.Connect("localhost");
             IDatabase db = redis.GetDatabase();
             db.TimeSeriesMAdd(sequence);

NRedisTimeSeries.Example/MAddExampleAsync.cs

@@ -12,19 +12,38 @@ namespace NRedisTimeSeries.Example
     internal class MAddAsyncExample
     {
         /// <summary>
-        /// Example for mutiple sample addtion. One is using RedisTimeSeris default system time in one time series,
-        /// the second is using DateTime in the second time series and the third is using long in the third time series.
+        /// Example for mutiple sample addtion. One is using default TsTimeStamp value in one time series,
+        /// the second is using current system DateTime in the second time series and the third is using a specified TsTimeStamp in the third time series.
         /// </summary>
-        public static async Task MAddFlowAsyncExample()
+        public static async Task MAddWithTimeStampExample()
         {
-            string[] keys = { "system_time_ts", "datetime_ts", "long_ts" };
-            var sequence = new List<(string, TimeStamp, double)>(keys.Length);
-            // Add sample to the system_time_ts
-            sequence.Add((keys[0], "*", 0.0));
-            // Add sample to the datetime_ts
-            sequence.Add((keys[1], DateTime.UtcNow, 0.0));
-            // Add sample to the long_ts
-            sequence.Add((keys[2], 1, 0.0));
+            string[] keys = { "ts_first", "ts_second", "ts_third" };
+            var sequence = new List<(string, TsTimeStamp, double)>(keys.Length)
+            {
+                (keys[0], default(TsTimeStamp), 1.0),
+                (keys[1], DateTime.UtcNow, 1.0),
+                (keys[2], new TsTimeStamp(1), 1.0)
+            };
+            ConnectionMultiplexer redis = ConnectionMultiplexer.Connect("localhost");
+            IDatabase db = redis.GetDatabase();
+            await db.TimeSeriesMAddAsync(sequence);
+            redis.Close();
+        }
+
+        /// <summary>
+        /// Example for mutiple sample addtion using the Redis system timestamp. Two samples are added to the first timeseries,
+        /// and two samples are added to the second timeseries.
+        /// </summary>
+        public static async Task MAddWithoutTimeStampExample()
+        {
+            string[] keys = { "ts_first", "ts_second" };
+            var sequence = new List<(string, double)>(keys.Length)
+            {
+                (keys[0], 1.0),
+                (keys[0], 2.0),
+                (keys[1], 1.0),
+                (keys[1], 2.0)
+            };
             ConnectionMultiplexer redis = ConnectionMultiplexer.Connect("localhost");
             IDatabase db = redis.GetDatabase();
             await db.TimeSeriesMAddAsync(sequence);