Skip to content

Commit

Permalink
Merge branch 'master' into ck-nuget-autorelease
Browse files Browse the repository at this point in the history
  • Loading branch information
gkorland authored Aug 4, 2021
2 parents 263b4ea + dd8fbea commit 39679f5
Show file tree
Hide file tree
Showing 4 changed files with 12 additions and 12 deletions.
6 changes: 3 additions & 3 deletions NRedisTimeSeries.Test/TestAPI/TestMRange.cs
Original file line number Diff line number Diff line change
Expand Up @@ -181,12 +181,12 @@ public void TestMRangeAlign()
new TimeSeriesTuple(50,1),
new TimeSeriesTuple(100,1)
};
var results = db.TimeSeriesMRange("-", "+", new List<string> { "key=MRangeAlign" }, align: "-", aggregation: TsAggregation.Count, timeBucket: 10, count:3);
var results = db.TimeSeriesMRange(0, "+", new List<string> { "key=MRangeAlign" }, align: "-", aggregation: TsAggregation.Count, timeBucket: 10, count:3);
Assert.Equal(1, results.Count);
Assert.Equal(keys[0], results[0].key);
Assert.Equal(expected, results[0].values);
results = db.TimeSeriesMRange("-", "+", new List<string> { "key=MRangeAlign" }, align: "+", aggregation: TsAggregation.Count, timeBucket: 10, count:1);
Assert.Equal(new TimeSeriesTuple(-3,1), results[0].values[0]);
results = db.TimeSeriesMRange(1, 500, new List<string> { "key=MRangeAlign" }, align: "+", aggregation: TsAggregation.Count, timeBucket: 10, count:1);
Assert.Equal(expected[1], results[0].values[0]);
}

[Fact]
Expand Down
6 changes: 3 additions & 3 deletions NRedisTimeSeries.Test/TestAPI/TestMRangeAsync.cs
Original file line number Diff line number Diff line change
Expand Up @@ -184,12 +184,12 @@ public async Task TestMRangeAlign()
new TimeSeriesTuple(50,1),
new TimeSeriesTuple(100,1)
};
var results = await db.TimeSeriesMRangeAsync("-", "+", new List<string> { $"{keys[0]}=value" }, align: "-", aggregation: TsAggregation.Count, timeBucket: 10, count:3);
var results = await db.TimeSeriesMRangeAsync(0, "+", new List<string> { $"{keys[0]}=value" }, align: "-", aggregation: TsAggregation.Count, timeBucket: 10, count:3);
Assert.Equal(1, results.Count);
Assert.Equal(keys[0], results[0].key);
Assert.Equal(expected, results[0].values);
results = await db.TimeSeriesMRangeAsync("-", "+", new List<string> { $"{keys[0]}=value" }, align: "+", aggregation: TsAggregation.Count, timeBucket: 10, count:1);
Assert.Equal(new TimeSeriesTuple(-3,1), results[0].values[0]);
results = await db.TimeSeriesMRangeAsync(0, 500, new List<string> { $"{keys[0]}=value" }, align: "+", aggregation: TsAggregation.Count, timeBucket: 10, count:1);
Assert.Equal(expected[0], results[0].values[0]);
}

[Fact]
Expand Down
6 changes: 3 additions & 3 deletions NRedisTimeSeries.Test/TestAPI/TestMRevRange.cs
Original file line number Diff line number Diff line change
Expand Up @@ -175,12 +175,12 @@ public void TestMRevRangeAlign()
new TimeSeriesTuple(400,1),
new TimeSeriesTuple(350,1)
};
var results = db.TimeSeriesMRevRange("-", "+", new List<string> { $"{keys[0]}=value" }, align: "-", aggregation: TsAggregation.Count, timeBucket: 10, count:3);
var results = db.TimeSeriesMRevRange(0, "+", new List<string> { $"{keys[0]}=value" }, align: "-", aggregation: TsAggregation.Count, timeBucket: 10, count:3);
Assert.Equal(1, results.Count);
Assert.Equal(keys[0], results[0].key);
Assert.Equal(expected, results[0].values);
results = db.TimeSeriesMRevRange("-", "+", new List<string> { $"{keys[0]}=value" }, align: "+", aggregation: TsAggregation.Count, timeBucket: 10, count:1);
Assert.Equal(new TimeSeriesTuple(450-3,1), results[0].values[0]);
results = db.TimeSeriesMRevRange(0, 500, new List<string> { $"{keys[0]}=value" }, align: "+", aggregation: TsAggregation.Count, timeBucket: 10, count:1);
Assert.Equal(expected[0], results[0].values[0]);
}

[Fact]
Expand Down
6 changes: 3 additions & 3 deletions NRedisTimeSeries.Test/TestAPI/TestMRevRangeAsync.cs
Original file line number Diff line number Diff line change
Expand Up @@ -175,12 +175,12 @@ public async Task TestMRevRangeAlign()
new TimeSeriesTuple(400,1),
new TimeSeriesTuple(350,1)
};
var results = await db.TimeSeriesMRevRangeAsync("-", "+", new List<string> { $"{keys[0]}=value" }, align: "-", aggregation: TsAggregation.Count, timeBucket: 10, count:3);
var results = await db.TimeSeriesMRevRangeAsync(0, "+", new List<string> { $"{keys[0]}=value" }, align: "-", aggregation: TsAggregation.Count, timeBucket: 10, count:3);
Assert.Equal(1, results.Count);
Assert.Equal(keys[0], results[0].key);
Assert.Equal(expected, results[0].values);
results = await db.TimeSeriesMRevRangeAsync("-", "+", new List<string> { $"{keys[0]}=value" }, align: "+", aggregation: TsAggregation.Count, timeBucket: 10, count:1);
Assert.Equal(new TimeSeriesTuple(450-3,1), results[0].values[0]);
results = await db.TimeSeriesMRevRangeAsync(0, 500, new List<string> { $"{keys[0]}=value" }, align: "+", aggregation: TsAggregation.Count, timeBucket: 10, count:1);
Assert.Equal(expected[0], results[0].values[0]);
}

[Fact]
Expand Down

0 comments on commit 39679f5

Please sign in to comment.