fluencelabs/redis
1
0
Fork 0
mirror of https://github.com/fluencelabs/redis synced 2025-03-19 09:00:51 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #5129 from soloestoy/xinfo-show-last-id

Browse Source 
Streams: show last id for streams and groups
This commit is contained in:
Salvatore Sanfilippo 2018-07-16 12:24:14 +02:00 committed by GitHub
commit 4215e74be5
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/t_stream.c
View File

@ -2279,18 +2279,20 @@ NULL
raxSeek(&ri,"^",NULL,0); raxSeek(&ri,"^",NULL,0);
while(raxNext(&ri)) { while(raxNext(&ri)) {
streamCG *cg = ri.data; streamCG *cg = ri.data;
addReplyMultiBulkLen(c,6); addReplyMultiBulkLen(c,8);
addReplyStatus(c,"name"); addReplyStatus(c,"name");
addReplyBulkCBuffer(c,ri.key,ri.key_len); addReplyBulkCBuffer(c,ri.key,ri.key_len);
addReplyStatus(c,"consumers"); addReplyStatus(c,"consumers");
addReplyLongLong(c,raxSize(cg->consumers)); addReplyLongLong(c,raxSize(cg->consumers));
addReplyStatus(c,"pending"); addReplyStatus(c,"pending");
addReplyLongLong(c,raxSize(cg->pel)); addReplyLongLong(c,raxSize(cg->pel));
addReplyStatus(c,"last-delivered-id");
addReplyStreamID(c,&cg->last_id);
} }
raxStop(&ri); raxStop(&ri);
} else if (!strcasecmp(opt,"STREAM") && c->argc == 3) { } else if (!strcasecmp(opt,"STREAM") && c->argc == 3) {
/* XINFO STREAM <key> (or the alias XINFO <key>). */ /* XINFO STREAM <key> (or the alias XINFO <key>). */
addReplyMultiBulkLen(c,12); addReplyMultiBulkLen(c,14);
addReplyStatus(c,"length"); addReplyStatus(c,"length");
addReplyLongLong(c,s->length); addReplyLongLong(c,s->length);
addReplyStatus(c,"radix-tree-keys"); addReplyStatus(c,"radix-tree-keys");
@ -2299,6 +2301,8 @@ NULL
addReplyLongLong(c,s->rax->numnodes); addReplyLongLong(c,s->rax->numnodes);
addReplyStatus(c,"groups"); addReplyStatus(c,"groups");
addReplyLongLong(c,s->cgroups ? raxSize(s->cgroups) : 0); addReplyLongLong(c,s->cgroups ? raxSize(s->cgroups) : 0);
addReplyStatus(c,"last-id");
addReplyStreamID(c,&s->last_id);
/* To emit the first/last entry we us the streamReplyWithRange() /* To emit the first/last entry we us the streamReplyWithRange()
* API. */ * API. */