diff options
| author | antirez <antirez@gmail.com> | 2018-01-26 11:57:19 +0100 |
|---|---|---|
| committer | antirez <antirez@gmail.com> | 2018-03-15 12:54:10 +0100 |
| commit | b65fe09bb8d00d9edf07f29274e0405a9d802fe3 (patch) | |
| tree | fae5697b203a7e30335e6f69082ecfa6a4ca8799 /src/stream.h | |
| parent | 5ad29325fed710011236763b3b73256ef8319103 (diff) | |
| download | redis-b65fe09bb8d00d9edf07f29274e0405a9d802fe3.tar.gz | |
CG: Now XREADGROUP + blocking operations work.
Diffstat (limited to 'src/stream.h')
| -rw-r--r-- | src/stream.h | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/stream.h b/src/stream.h index 917392076..908e9ff72 100644 --- a/src/stream.h +++ b/src/stream.h @@ -94,5 +94,7 @@ void streamIteratorStart(streamIterator *si, stream *s, streamID *start, streamI int streamIteratorGetID(streamIterator *si, streamID *id, int64_t *numfields); void streamIteratorGetField(streamIterator *si, unsigned char **fieldptr, unsigned char **valueptr, int64_t *fieldlen, int64_t *valuelen); void streamIteratorStop(streamIterator *si); +streamCG *streamLookupCG(stream *s, sds groupname); +streamConsumer *streamLookupConsumer(streamCG *cg, sds name); #endif |