summaryrefslogtreecommitdiff
path: root/src/stream.h
Commit message (Expand)AuthorAgeFilesLines
* Stream consumers: Re-purpose seen-time, add active-time (#11099)guybe72022-11-301-6/+3
* Add stream consumer group lag tracking and reporting (#9127)Itamar Haber2022-02-231-2/+15
* Adds auto-seq-only-generation via `XADD ... <ms>-*` (#9217)Itamar Haber2021-11-301-1/+1
* Fix if consumer is created as a side effect without notify and dirty++ (#9263)menwen2021-08-021-4/+9
* Fixed some typos, add a spell check ci and others minor fix (#8890)Binbin2021-06-101-1/+1
* Add modules API for streams (#8288)Viktor Söderqvist2021-01-281-0/+7
* Sanitize dump payload: ziplist, listpack, zipmap, intset, streamOran Agra2020-12-061-0/+1
* Adds exclusive ranges to X[REV]RANGE (#8072)Itamar Haber2020-12-031-1/+2
* Add COPY command (#7953)swamp04072020-11-171-0/+1
* Stream: Inconsistency between master and replica some XREADGROUP case (#7526)valentinogeron2020-09-241-1/+2
* Squash merging 125 typo/grammar/comment/doc PRs (#7773)Oran Agra2020-09-101-1/+1
* XPENDING should not update consumer's seen-timeGuy Benoish2020-05-041-1/+6
* Stream: Handle streamID-related edge casesGuy Benoish2019-12-261-0/+1
* Support streams in general module API functionsGuy Benoish2019-11-061-0/+1
* stream.h: fix typoJamison Judge2019-10-071-1/+1
* prevent diskless replica from terminating on short readOran Agra2019-07-171-0/+1
* Streams: add streamCompareID() declaration in stream.h.dejun.xdj2018-07-141-0/+1
* Streams: iterator entry deletion abilities.antirez2018-04-171-0/+2
* CG: AOF rewriting implemented.antirez2018-03-231-0/+1
* CG: Replication WIP 1: XREADGROUP and XCLAIM propagated as XCLAIM.antirez2018-03-191-1/+8
* CG: RDB loading first implementation.antirez2018-03-151-0/+2
* CG: XPENDING should not create consumers and obey to count.antirez2018-03-151-1/+1
* CG: Now XREADGROUP + blocking operations work.antirez2018-03-151-0/+2
* CG: first draft of streamReplyWithRangeFromConsumerPEL().antirez2018-03-151-1/+1
* CG: creation of NACK entries in PELs.antirez2018-03-151-5/+5
* CG: consumer lookup + initial streamReplyWithRange() work to supprot CG.antirez2018-03-151-2/+2
* CG: XGROUPREAD group option parsing and groups lookup.antirez2018-03-151-1/+1
* CG: data structures design + XGROUP CREATE implementation.antirez2018-03-151-1/+40
* Streams: state machine for reverse iteration WIP 1.antirez2017-12-011-3/+4
* Streams: items compression implemented.antirez2017-12-011-0/+5
* Streams: export iteration API.antirez2017-12-011-0/+31
* Streams: RDB saving.antirez2017-12-011-0/+1
* Streams: 12 commits squashed into the initial Streams implementation.antirez2017-12-011-0/+21