mirror of
https://github.com/fluencelabs/redis
synced 2025-03-17 16:10:50 +00:00
parent
c1689166b7
commit
b4f8268371
@ -364,48 +364,33 @@ start_server {tags {"stream"} overrides {appendonly yes stream-node-max-entries
|
||||
}
|
||||
}
|
||||
|
||||
start_server {tags {"xstream command"}} {
|
||||
test {XSTREAM can CREATE an empty stream} {
|
||||
r XSTREAM CREATE mystream *
|
||||
start_server {tags {"xsetid"}} {
|
||||
test {XADD can CREATE an empty stream} {
|
||||
r XADD mystream MAXLEN 0 * a b
|
||||
assert {[dict get [r xinfo stream mystream] length] == 0}
|
||||
}
|
||||
|
||||
test {XSTREAM cannot CREATE on an busy stream} {
|
||||
catch {r XSTREAM CREATE mystream *} err
|
||||
set _ $err
|
||||
} {BUSY*}
|
||||
|
||||
test {XSTREAM can CREATE an empty stream with specific ID} {
|
||||
r del mystream
|
||||
r XSTREAM CREATE mystream "100-100"
|
||||
assert {[dict get [r xinfo stream mystream] length] == 0}
|
||||
assert {[dict get [r xinfo stream mystream] last-generated-id] == "100-100"}
|
||||
}
|
||||
|
||||
test {XSTREAM can SETID with $} {
|
||||
r XSTREAM SETID mystream $
|
||||
assert {[dict get [r xinfo stream mystream] last-generated-id] == "100-100"}
|
||||
}
|
||||
|
||||
test {XSTREAM can SETID with specific ID} {
|
||||
r XSTREAM SETID mystream "200-0"
|
||||
test {XSETID can set a specific ID} {
|
||||
r XSETID mystream "200-0"
|
||||
assert {[dict get [r xinfo stream mystream] last-generated-id] == "200-0"}
|
||||
}
|
||||
|
||||
test {XSTREAM cannot SETID with smaller ID} {
|
||||
catch {r XSTREAM SETID mystream "0-0"} err
|
||||
set _ $err
|
||||
r XADD mystream * a b
|
||||
catch {r XSETID mystream "1-1"} err
|
||||
r XADD mystream MAXLEN 0 * a b
|
||||
set err
|
||||
} {ERR*smaller*}
|
||||
|
||||
test {XSTREAM cannot SETID on non-existent key} {
|
||||
catch {r XSTREAM SETID stream $} err
|
||||
catch {r XSETID stream 1-1} err
|
||||
set _ $err
|
||||
} {ERR no such key}
|
||||
}
|
||||
|
||||
start_server {tags {"stream"} overrides {appendonly yes aof-use-rdb-preamble no}} {
|
||||
test {Empty stream can be rewrite into AOF correctly} {
|
||||
r XSTREAM CREATE mystream 0
|
||||
r XADD mystream MAXLEN 0 * a b
|
||||
assert {[dict get [r xinfo stream mystream] length] == 0}
|
||||
r bgrewriteaof
|
||||
waitForBgrewriteaof r
|
||||
@ -414,6 +399,7 @@ start_server {tags {"stream"} overrides {appendonly yes aof-use-rdb-preamble no}
|
||||
}
|
||||
|
||||
test {Stream can be rewrite into AOF correctly after XDEL lastid} {
|
||||
r XSETID mystream 0-0
|
||||
r XADD mystream 1-1 a b
|
||||
r XADD mystream 2-2 a b
|
||||
assert {[dict get [r xinfo stream mystream] length] == 2}
|
||||
|
Loading…
x
Reference in New Issue
Block a user