summaryrefslogtreecommitdiff
path: root/src/t_stream.c
Commit message (Expand)AuthorAgeFilesLines
* Add XAUTOCLAIM (#7973)guybe72021-01-061-0/+159
* HELP subcommand, continued (#5531)Itamar Haber2021-01-041-26/+29
* Flow through the error handling path for most errors (#8226)Madelyn Olson2020-12-231-8/+7
* Adds exclusive range query intervals to XPENDING (#8130)Itamar Haber2020-12-081-3/+16
* More efficient self-XCLAIM (#8098)guybe72020-12-071-9/+12
* Sanitize dump payload: fuzz tester and fixes for segfaults and leaks it exposedOran Agra2020-12-061-0/+2
* Sanitize dump payload: ziplist, listpack, zipmap, intset, streamOran Agra2020-12-061-5/+104
* Adds exclusive ranges to X[REV]RANGE (#8072)Itamar Haber2020-12-031-6/+72
* XPENDING with IDLE (#7972)guybe72020-11-291-12/+34
* Unified MULTI, LUA, and RM_Call with respect to blocking commands (#8025)Meir Shpilraien (Spielrein)2020-11-171-3/+6
* Add COPY command (#7953)swamp04072020-11-171-0/+104
* support NOMKSTREAM option in xadd command (#7910)Wen Hui2020-10-181-3/+10
* Adds new pop-push commands (LMOVE, BLMOVE) (#6929)Felipe Machado2020-10-081-1/+1
* Stream: Inconsistency between master and replica some XREADGROUP case (#7526)valentinogeron2020-09-241-16/+61
* Squash merging 125 typo/grammar/comment/doc PRs (#7773)Oran Agra2020-09-101-3/+3
* Replace usage of wrongtypeerr with helper (#7633)Madelyn Olson2020-08-111-7/+3
* Avoid redundant calls to signalKeyAsReady (#7625)杨博东2020-08-111-3/+2
* Removes dead code (#7642)Itamar Haber2020-08-111-4/+2
* Add SignalModifiedKey hook in XGROUP CREATE with MKSTREAM option (#7562)Wen Hui2020-07-291-0/+1
* Refactor streamAppendItem() by deleting redundancy condition. (#7487)WuYunlong2020-07-201-1/+1
* Stream avoid duplicate parse id (#7450)杨博东2020-07-161-21/+37
* Fix command help for unexpected options (#7476)WuYunlong2020-07-151-1/+1
* XPENDING should not update consumer's seen-timeGuy Benoish2020-05-041-14/+21
* XINFO STREAM FULL should have a default COUNT of 10Guy Benoish2020-04-281-4/+8
* Merge pull request #7134 from guybe7/xstate_commandSalvatore Sanfilippo2020-04-281-34/+192
|\
| * Extend XINFO STREAM outputGuy Benoish2020-04-281-34/+192
* | Also use propagate() in streamPropagateGroupID().antirez2020-04-241-1/+11
* | Minor aesthetic changes to #7135.antirez2020-04-231-7/+5
* | Merge pull request #7135 from valentinogeron/optimize-xreadgroup-noackSalvatore Sanfilippo2020-04-231-7/+13
|\ \
| * | XREADGROUP with NOACK should propagate only one XGROUP SETID commandValentino Geron2020-04-221-7/+13
| |/
* | Tracking: NOLOOP internals implementation.antirez2020-04-211-3/+3
|/
* Fix XCLAIM propagation in AOF/replicas for blocking XREADGROUP.antirez2020-04-171-1/+1
* RESP3: change streams items from maps to arrays.antirez2020-04-101-1/+1
* Merge pull request #7030 from valentinogeron/xread-in-luaSalvatore Sanfilippo2020-04-031-0/+5
|\
| * XREAD and XREADGROUP should not be allowed from scripts when BLOCK option is ...Valentino Geron2020-03-261-0/+5
* | Merge pull request #7029 from valentinogeron/fix-xackSalvatore Sanfilippo2020-04-021-1/+11
|\ \
| * | XACK should be executed in a "all or nothing" fashion.Valentino Geron2020-03-261-1/+11
| |/
* | streamReplyWithRange: Redundant XSETIDs to replicaGuy Benoish2020-03-301-1/+2
|/
* Merge pull request #6677 from guybe7/deocde_id_onceSalvatore Sanfilippo2020-02-271-3/+1
|\
| * streamReplyWithRangeFromConsumerPEL: Redundant streamDecodeIDGuy Benoish2019-12-181-3/+1
* | Merge pull request #6921 from guybe7/fix_xclaim_propagateSalvatore Sanfilippo2020-02-271-2/+2
|\ \
| * | XREADGROUP should propagate XCALIM/SETID in MULTI/EXECGuy Benoish2020-02-231-2/+2
* | | XGROUP DESTROY should unblock XREADGROUP with -NOGROUPGuy Benoish2020-02-191-0/+2
|/ /
* | Merge pull request #6703 from guybe7/blocking_xread_empty_replySalvatore Sanfilippo2020-01-091-10/+19
|\ \
| * | Blocking XREAD[GROUP] should always reply with valid data (or timeout)Guy Benoish2019-12-301-10/+19
| |/
* | XCLAIM: Create the consumer only on successful claims.antirez2020-01-081-2/+4
* | Stream: Handle streamID-related edge casesGuy Benoish2019-12-261-3/+25
|/
* Merge branch 'unstable' into rm_get_server_infoSalvatore Sanfilippo2019-11-211-10/+27
|\
| * Merge pull request #6547 from guybe7/module_api_streamsSalvatore Sanfilippo2019-11-211-0/+6
| |\
| | * Support streams in general module API functionsGuy Benoish2019-11-061-0/+6