summaryrefslogtreecommitdiff
path: root/src/stream.h
diff options
context:
space:
mode:
authorGuy Benoish <guy.benoish@redislabs.com>2019-11-06 15:48:46 +0530
committerGuy Benoish <guy.benoish@redislabs.com>2019-11-06 15:52:19 +0530
commit1833d008b3af8628835b5f082c5b4b1359557893 (patch)
treedf433169797ed146931d79096b4900b412ac44a9 /src/stream.h
parenta15a5d70976cc185389b0d515265b443e5a3a0f3 (diff)
downloadredis-1833d008b3af8628835b5f082c5b4b1359557893.tar.gz
Support streams in general module API functions
Fixes GitHub issue #6492 Added stream support in RM_KeyType and RM_ValueLength. Also moduleDelKeyIfEmpty was updated, even though it has no effect now (It will be relevant when stream type direct API will be coded - i.e. RM_StreamAdd)
Diffstat (limited to 'src/stream.h')
-rw-r--r--src/stream.h1
1 files changed, 1 insertions, 0 deletions
diff --git a/src/stream.h b/src/stream.h
index 1163b3527..7de769ba1 100644
--- a/src/stream.h
+++ b/src/stream.h
@@ -98,6 +98,7 @@ struct client;
stream *streamNew(void);
void freeStream(stream *s);
+unsigned long streamLength(const robj *subject);
size_t streamReplyWithRange(client *c, stream *s, streamID *start, streamID *end, size_t count, int rev, streamCG *group, streamConsumer *consumer, int flags, streamPropInfo *spi);
void streamIteratorStart(streamIterator *si, stream *s, streamID *start, streamID *end, int rev);
int streamIteratorGetID(streamIterator *si, streamID *id, int64_t *numfields);