diff options
| author | antirez <antirez@gmail.com> | 2018-02-14 16:37:24 +0100 |
|---|---|---|
| committer | antirez <antirez@gmail.com> | 2018-03-15 12:54:10 +0100 |
| commit | f4e1a4de258b75a2ad19805a595a9fbb25e9edbf (patch) | |
| tree | 1866889e40720dc14f1904b02abb115058053396 /src/stream.h | |
| parent | db7a5f23b4674224c26628d419e8ca0919a692d9 (diff) | |
| download | redis-f4e1a4de258b75a2ad19805a595a9fbb25e9edbf.tar.gz | |
CG: RDB loading first implementation.
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 bd999d77c..a759056ea 100644 --- a/src/stream.h +++ b/src/stream.h @@ -96,5 +96,7 @@ void streamIteratorGetField(streamIterator *si, unsigned char **fieldptr, unsign void streamIteratorStop(streamIterator *si); streamCG *streamLookupCG(stream *s, sds groupname); streamConsumer *streamLookupConsumer(streamCG *cg, sds name, int create); +streamCG *streamCreateCG(stream *s, char *name, size_t namelen, streamID *id); +streamNACK *streamCreateNACK(streamConsumer *consumer); #endif |