summaryrefslogtreecommitdiff
path: root/src/t_stream.c
Commit message (Expand)AuthorAgeFilesLines
* 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
| * | Remove additional space from comment.antirez2019-11-191-1/+1
| * | XADD with ID 0-0 stores an empty keyGuy Benoish2019-11-131-0/+8
| |/
| * fix unreported overflow in autogerenared stream IDsLoris Cro2019-11-041-10/+13
* | Add RM_ServerInfoGetFieldUnsignedOran Agra2019-11-041-20/+0
|/
* Fix usage of server.stream_node_max_*Guy Benoish2019-10-101-3/+3
* Fix start and end key initializeJames Rouzier2019-04-111-2/+2
* Merge pull request #5787 from soloestoy/bugfix-xgroup-create-with-mkstreamSalvatore Sanfilippo2019-03-131-5/+7
|\
| * Streams: checkType before XGROUP CREATEzhaozhao.zz2019-01-161-5/+7
* | Only increment delivery count if JUSTID option is omittedSteve Webster2019-03-121-2/+3
* | Increment delivery counter on XCLAIM unless RETRYCOUNT specifiedSteve Webster2019-03-081-2/+6
|/
* RESP3: t_stream.c updated.antirez2019-01-091-38/+43
* Stream: fix XREADGROUP history reading of deleted messages.antirez2018-11-191-1/+1
* Streams: fix XREADGROUP history reading when CG last_id is low.antirez2018-11-191-9/+12
* t_stream.c comment resized to 80 cols.antirez2018-11-191-1/+2
* Fix XCLAIM missing entry bug.antirez2018-11-051-2/+3
* Merge branch 'unstable' of github.com:/antirez/redis into unstableantirez2018-11-051-12/+12
|\
| * Use typedef'd mstime_t instead of time_tmichael-grunder2018-11-031-1/+1
| * Fix some typosGuy Korland2018-10-311-11/+11
* | Improve streamReplyWithRange() top comment.antirez2018-11-051-5/+9
|/
* Add command fingerprint comment for XSETID.antirez2018-10-251-1/+3
* Merge branch 'unstable' of github.com:/antirez/redis into unstableantirez2018-10-251-1/+2
|\
| * Merge pull request #5459 from itamarhaber/xpending_count_underflowSalvatore Sanfilippo2018-10-251-1/+2
| |\
| | * Plugs a potential underflowItamar Haber2018-10-171-0/+1
| | * Corrects inline documentation of syntaxItamar Haber2018-10-171-1/+1
* | | Fix XRANGE COUNT option for value of 0.antirez2018-10-251-2/+8
* | | Fix typo in streamReplyWithRange() top comment.antirez2018-10-241-1/+1
|/ /
* | Streams: use bulk replies instead of status replies.antirez2018-10-171-16/+16
|/
* Fix conditional in XGROUP.antirez2018-10-171-1/+1
* Fix XGROUP CREATE MKSTREAM handling of .antirez2018-10-171-2/+7
* Process MKSTREAM option of XGROUP CREATE at a later time.antirez2018-10-171-17/+28
* XGROUP CREATE: MKSTREAM option for automatic stream creation.antirez2018-10-171-5/+29
* XSETID: accept IDs based on last entry.antirez2018-10-161-5/+18
* Streams: XSTREAM SETID -> XSETID.antirez2018-10-161-65/+15
* Merge pull request #5426 from soloestoy/feature-xstreamSalvatore Sanfilippo2018-10-161-0/+69
|\
| * Streams: rewrite id in XSTREAM CREATE *zhaozhao.zz2018-10-091-0/+4
| * Streams: add a new command XTREAMzhaozhao.zz2018-10-091-0/+65
* | Make comment about nack->consumer test for minidle more obvious.antirez2018-10-151-2/+4
* | Streams: use propagate_last_id itself as streamPropagateGroupID trigger.antirez2018-10-151-2/+2