Skip to content

Commit 8fb6700

Browse files
committed
feat: add XACKDEL command with support for Keepref, Delref, and Acked actions
1 parent dad42a2 commit 8fb6700

File tree

3 files changed

+140
-0
lines changed

3 files changed

+140
-0
lines changed

hack/cmds/commands.json

Lines changed: 42 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -6027,6 +6027,48 @@
60276027
"since": "5.0.0",
60286028
"group": "stream"
60296029
},
6030+
"XACKDEL": {
6031+
"summary": "Acknowledges specified message IDs in a consumer group and attempts to delete corresponding stream entries.",
6032+
"complexity": "O(1) for each message ID processed.",
6033+
"arguments": [
6034+
{
6035+
"name": "key",
6036+
"type": "key"
6037+
},
6038+
{
6039+
"name": "group",
6040+
"type": "string"
6041+
},
6042+
{
6043+
"name": "action",
6044+
"type": "oneof",
6045+
"enum": ["KEEPREF", "DELREF", "ACKED"],
6046+
"optional": true
6047+
},
6048+
{
6049+
"name": "ids-block",
6050+
"type": "block",
6051+
"arguments": [
6052+
{
6053+
"name": "ids",
6054+
"type": "pure-token",
6055+
"token": "IDS"
6056+
},
6057+
{
6058+
"name": "numids",
6059+
"type": "integer"
6060+
},
6061+
{
6062+
"name": "id",
6063+
"type": "string",
6064+
"multiple": true
6065+
}
6066+
]
6067+
}
6068+
],
6069+
"since": "8.2.0",
6070+
"group": "stream"
6071+
},
60306072
"XADD": {
60316073
"summary": "Appends a new entry to a stream",
60326074
"complexity": "O(1) when adding a new entry, O(N) when trimming where N being the number of entries evicted.",

internal/cmds/gen_stream.go

Lines changed: 94 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

internal/cmds/gen_stream_test.go

Lines changed: 4 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

0 commit comments

Comments
 (0)