mirror
/
redis
mirror of https://github.com/go-redis/redis.git
1
0
Fork 1
Code Issues Packages Projects Releases Wiki Activity

fix

This commit is contained in:
ofekshenawa 2024-07-02 16:24:41 +03:00
parent 40d6e98279
commit cd82564ce6
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
timeseries_commands_test.go
View File

@ -86,7 +86,7 @@ var _ = Describe("RedisTimeseries commands", Label("timeseries"), func() {
rangePoints, err := client.TSRange(ctx, "ts-if-1", 1000, 1021).Result() rangePoints, err := client.TSRange(ctx, "ts-if-1", 1000, 1021).Result()
Expect(err).NotTo(HaveOccurred()) Expect(err).NotTo(HaveOccurred())
Expect(len(rangePoints)).To(BeEquivalentTo(4)) Expect(len(rangePoints)).To(BeEquivalentTo(5))
Expect(rangePoints).To(BeEquivalentTo([]redis.TSTimestampValue{ Expect(rangePoints).To(BeEquivalentTo([]redis.TSTimestampValue{
{Timestamp: 1000, Value: 1.0}, {Timestamp: 1000, Value: 1.0},
{Timestamp: 1010, Value: 11.0}, {Timestamp: 1010, Value: 11.0},
@ -200,7 +200,7 @@ var _ = Describe("RedisTimeseries commands", Label("timeseries"), func() {
rangePoints, err := client.TSRange(ctx, "ts-if-1", 1000, 1004).Result() rangePoints, err := client.TSRange(ctx, "ts-if-1", 1000, 1004).Result()
Expect(err).NotTo(HaveOccurred()) Expect(err).NotTo(HaveOccurred())
Expect(len(rangePoints)).To(BeEquivalentTo(1)) Expect(len(rangePoints)).To(BeEquivalentTo(2))
Expect(rangePoints).To(BeEquivalentTo([]redis.TSTimestampValue{{Timestamp: 1000, Value: 1.0}})) Expect(rangePoints).To(BeEquivalentTo([]redis.TSTimestampValue{{Timestamp: 1000, Value: 1.0}}))
}) })
@ -391,7 +391,7 @@ var _ = Describe("RedisTimeseries commands", Label("timeseries"), func() {
rangePoints, err = client.TSRange(ctx, "ts-if-1", 1000, 1004).Result() rangePoints, err = client.TSRange(ctx, "ts-if-1", 1000, 1004).Result()
Expect(err).NotTo(HaveOccurred()) Expect(err).NotTo(HaveOccurred())
Expect(len(rangePoints)).To(BeEquivalentTo(1)) Expect(len(rangePoints)).To(BeEquivalentTo(1))
Expect(rangePoints).To(BeEquivalentTo([]redis.TSTimestampValue{{Timestamp: 1000, Value: 11.1}})) Expect(rangePoints).To(BeEquivalentTo([]redis.TSTimestampValue{{Timestamp: 1000, Value: 14.1}}))
// Test insertion filters DECRBY // Test insertion filters DECRBY
opt = &redis.TSIncrDecrOptions{Timestamp: 1000, IgnoreMaxTimeDiff: 5, IgnoreMaxValDiff: 10.0, DuplicatePolicy: "LAST"} opt = &redis.TSIncrDecrOptions{Timestamp: 1000, IgnoreMaxTimeDiff: 5, IgnoreMaxValDiff: 10.0, DuplicatePolicy: "LAST"}