Skip to content

Commit

Permalink
Merge pull request #17 from tair-opensource/add-stream
Browse files Browse the repository at this point in the history 
feat: add support for stream
  • Loading branch information
@yangbodong22011
yangbodong22011 authored Aug 23, 2023
2 parents 1c2b9a4 + 6fbb318 commit 90ae83d
Showing 1 changed file with 330 additions and 0 deletions.
330 changes: 330 additions & 0 deletions cts.json
View file
Original file line number Diff line number Diff line change
Expand Up @@ -5491,5 +5491,335 @@
"True"
],
"since": "2.6.0"
},
{
"name": "xack command",
"command": [
"XACK mystream mygroup 1526569495631-0"
],
"result": [
0
],
"since": "5.0.0"
},
{
"name": "xadd command",
"command": [
"xadd mystream 1 myfield mydata"
],
"result": [
"1-0"
],
"since": "5.0.0"
},
{
"name": "xadd with NOMKSTREAM/MINID/LIMIT",
"command": [
"xadd mystream nomkstream * message \"test\"",
"xadd mystream minid 0 1 message \"test\"",
"xadd mystream maxlen ~ 2 2 message \"test\""
],
"result": [
null,
"1-0",
"2-0"
],
"since": "6.2.0",
"command_split": "true"
},
{
"name": "xadd with EXPLICIT ID",
"command": [
"xadd mystream 1526919030474-0 message \"Hello,\"",
"xadd mystream 1526919030474-* message \" World!\""
],
"result": [
"1526919030474-0",
"1526919030474-1"
],
"since": "7.0.0",
"command_split": "true"
},
{
"name": "xclaim command",
"command": [
"xadd mystream 1 myfield mydata",
"xgroup create mystream mygroup 0",
"XCLAIM mystream mygroup Alice 3600000 1-0"
],
"result": [
"1-0",
"OK",
[]
],
"since": "5.0.0"
},
{
"name": "xdel command",
"command": [
"xadd mystream 1 myfield mydata",
"xdel mystream 1-0"
],
"result": [
"1-0",
1
],
"since": "5.0.0"
},
{
"name": "xgroup create command",
"command": [
"xadd mystream 1 myfield mydata",
"xgroup create mystream mygroup 0"
],
"result": [
"1-0",
"OK"
],
"since": "5.0.0"
},
{
"name": "xgroup create with MKSTREAM",
"command": [
"xgroup create mystream mygroup 0 mkstream"
],
"result": [
"OK"
],
"since": "5.0.0"
},
{
"name": "xgroup create with ENTRIESREAD",
"command": [
"xadd mystream 1 myfield mydata",
"xgroup create mystream mygroup 1-0 entriesread 1"
],
"result": [
"1-0",
"OK"
],
"since": "7.0.0"
},
{
"name": "xgroup createconsumer command",
"command": [
"xadd mystream 1 myfield mydata",
"xgroup create mystream mygroup 0",
"xgroup createconsumer mystream mygroup myconsumer"
],
"result": [
"1-0",
"OK",
1
],
"since": "6.2.0"
},
{
"name": "xgroup delconsumer command",
"command": [
"xadd mystream 1 myfield mydata",
"xgroup create mystream mygroup 0",
"xgroup delconsumer mystream mygroup myconsumer"
],
"result": [
"1-0",
"OK",
0
],
"since": "5.0.0"
},
{
"name": "xgroup destroy command",
"command": [
"xadd mystream 1 myfield mydata",
"xgroup create mystream mygroup 0",
"xgroup destroy mystream mygroup"
],
"result": [
"1-0",
"OK",
1
],
"since": "5.0.0"
},
{
"name": "xgroup setid command",
"command": [
"xadd mystream 1 myfield mydata",
"xgroup create mystream mygroup 0",
"xgroup setid mystream mygroup 1-0"
],
"result": [
"1-0",
"OK",
"OK"
],
"since": "5.0.0"
},
{
"name": "xgroup setid with ENTRIESREAD",
"command": [
"xadd mystream 1 myfield mydata",
"xgroup create mystream mygroup 0",
"xgroup setid mystream mygroup 1-0 entriesread 0"
],
"result": [
"1-0",
"OK",
"OK"
],
"since": "7.0.0"
},
{
"name": "xlen command",
"command": [
"xadd mystream 1 myfield mydata",
"xlen mystream"
],
"result": [
"1-0",
1
],
"since": "5.0.0"
},
{
"name": "xpending command",
"command": [
"xadd mystream 1 myfield mydata",
"xgroup create mystream mygroup 0",
"xreadgroup group mygroup myconsumer streams mystream >",
"xpending mystream mygroup"
],
"result": [
"1-0",
"OK",
[
[
"mystream",
[
[
"1-0",
[
"myfield",
"mydata"
]
]
]
]
],
[
1,
"1-0",
"1-0",
[
[
"myconsumer",
"1"
]
]
]
],
"since": "5.0.0"
},
{
"name": "xrange command",
"command": [
"xadd mystream 1 myfield mydata",
"xrange mystream - +"
],
"result": [
"1-0",
[
[
"1-0",
[
"myfield",
"mydata"
]
]
]
],
"since": "5.0.0"
},
{
"name": "xread command",
"command": [
"xadd mystream 1 myfield mydata",
"xread count 2 block 1 streams mystream 1-0"
],
"result": [
"1-0",
null
],
"since": "5.0.0"
},
{
"name": "xreadgroup command",
"command": [
"xadd mystream 1 myfield mydata",
"xgroup create mystream mygroup 0",
"xreadgroup group mygroup myconsumer streams mystream >"
],
"result": [
"1-0",
"OK",
[
[
"mystream",
[
[
"1-0",
[
"myfield",
"mydata"
]
]
]
]
]
],
"since": "5.0.0"
},
{
"name": "xrevrange command",
"command": [
"xrevrange somestream + -"
],
"result": [
[]
],
"since": "5.0.0"
},
{
"name": "xrevrange command with EXCLUSIVE RANGES",
"command": [
"xrevrange somestream + - count 10"
],
"result": [
[]
],
"since": "6.2.0"
},
{
"name": "xtrim command",
"command": [
"xtrim mystream maxlen ~ 1000"
],
"result": [
0
],
"since": "5.0.0"
},
{
"name": "xtrim command with MINID/LIMIT",
"command": [
"xtrim mystream minid ~ 649085820",
"xtrim mystream minid ~ 1000 limit 10"
],
"result": [
0,
0
],
"since": "6.2.0"
}
]

0 comments on commit 90ae83d

Please sign in to comment.