gvsafronov/futriix
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Adds tests for XADD/XTRIM's MAXLEN arguments (#8083)

Browse Source
This commit is contained in:
Itamar Haber 2020-11-23 14:37:58 +02:00 committed by GitHub
parent 01d8e5912b
commit 8aa7cde1b4
1 changed files with 45 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

45
tests/unit/type/stream.tcl
View File

@ -102,6 +102,30 @@ start_server {
}
}
test {XADD with MAXLEN option and the '=' argument} {
r DEL mystream
for {set j 0} {$j < 1000} {incr j} {
if {rand() < 0.9} {
r XADD mystream MAXLEN = 5 * xitem $j
} else {
r XADD mystream MAXLEN = 5 * yitem $j
}
}
assert {[r XLEN mystream] == 5}
}
test {XADD with MAXLEN option and the '~' argument} {
r DEL mystream
for {set j 0} {$j < 1000} {incr j} {
if {rand() < 0.9} {
r XADD mystream MAXLEN ~ 555 * xitem $j
} else {
r XADD mystream MAXLEN ~ 555 * yitem $j
}
}
assert {[r XLEN mystream] == 600}
}
test {XADD with NOMKSTREAM option} {
r DEL mystream
assert_equal "" [r XADD mystream NOMKSTREAM * item 1 value a]
@ -378,6 +402,27 @@ start_server {
r XADD x * f2 v2
assert_equal [r XRANGE x - +] {{2577343934890-18446744073709551615 {f v}} {2577343934891-0 {f2 v2}}}
}
test {XTRIM with MAXLEN option basic test} {
r DEL mystream
for {set j 0} {$j < 1000} {incr j} {
if {rand() < 0.9} {
r XADD mystream * xitem $j
} else {
r XADD mystream * yitem $j
}
}
r XTRIM mystream MAXLEN 666
assert {[r XLEN mystream] == 666}
r XTRIM mystream MAXLEN = 555
assert {[r XLEN mystream] == 555}
r XTRIM mystream MAXLEN ~ 444
assert {[r XLEN mystream] == 500}
r XTRIM mystream MAXLEN ~ 400
assert {[r XLEN mystream] == 400}
}
}
start_server {tags {"stream"} overrides {appendonly yes}} {