diff options
author | Guy Benoish <guy.benoish@redislabs.com> | 2019-11-06 15:48:46 +0530 |
---|---|---|
committer | Guy Benoish <guy.benoish@redislabs.com> | 2019-11-06 15:52:19 +0530 |
commit | 1833d008b3af8628835b5f082c5b4b1359557893 (patch) | |
tree | df433169797ed146931d79096b4900b412ac44a9 /src/stream.h | |
parent | a15a5d70976cc185389b0d515265b443e5a3a0f3 (diff) | |
download | redis-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.h | 1 |
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); |