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

Streams: fix redis-cli to understand the stream type.

Browse Source
This commit is contained in:
antirez 2017-11-08 22:59:15 +01:00
parent 671b1f6a9d
commit abab0b7817
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/redis-cli.c
View File

@ -2074,7 +2074,8 @@ static void pipeMode(void) {
#define TYPE_SET 2 #define TYPE_SET 2
#define TYPE_HASH 3 #define TYPE_HASH 3
#define TYPE_ZSET 4 #define TYPE_ZSET 4
#define TYPE_NONE 5 #define TYPE_STREAM 5
#define TYPE_NONE 6
static redisReply *sendScan(unsigned long long *it) { static redisReply *sendScan(unsigned long long *it) {
redisReply *reply = redisCommand(context, "SCAN %llu", *it); redisReply *reply = redisCommand(context, "SCAN %llu", *it);
@ -2133,6 +2134,8 @@ static int toIntType(char *key, char *type) {
return TYPE_HASH; return TYPE_HASH;
} else if(!strcmp(type, "zset")) { } else if(!strcmp(type, "zset")) {
return TYPE_ZSET; return TYPE_ZSET;
} else if(!strcmp(type, "stream")) {
return TYPE_STREAM;
} else if(!strcmp(type, "none")) { } else if(!strcmp(type, "none")) {
return TYPE_NONE; return TYPE_NONE;
} else { } else {
@ -2221,7 +2224,7 @@ static void findBigKeys(void) {
unsigned long long biggest[5] = {0}, counts[5] = {0}, totalsize[5] = {0}; unsigned long long biggest[5] = {0}, counts[5] = {0}, totalsize[5] = {0};
unsigned long long sampled = 0, total_keys, totlen=0, *sizes=NULL, it=0; unsigned long long sampled = 0, total_keys, totlen=0, *sizes=NULL, it=0;
sds maxkeys[5] = {0}; sds maxkeys[5] = {0};
char *typename[] = {"string","list","set","hash","zset"}; char *typename[] = {"string","list","set","hash","zset","stream"};
char *typeunit[] = {"bytes","items","members","fields","members"}; char *typeunit[] = {"bytes","items","members","fields","members"};
redisReply *reply, *keys; redisReply *reply, *keys;
unsigned int arrsize=0, i; unsigned int arrsize=0, i;