antirez
|
84667bff70
|
CG: RDB loading first implementation.
|
2018-03-15 12:54:10 +01:00 |
|
antirez
|
e76fb4ab25
|
CG: XPENDING should not create consumers and obey to count.
|
2018-03-15 12:54:10 +01:00 |
|
antirez
|
ec0faf1bd9
|
CG: XPENDING should not create consumers and obey to count.
|
2018-03-15 12:54:10 +01:00 |
|
antirez
|
f3708af7f9
|
CG: XPENDING with start/stop/count variant implemented.
|
2018-03-15 12:54:10 +01:00 |
|
antirez
|
c0cf16f988
|
CG: XPENDING with start/stop/count variant implemented.
|
2018-03-15 12:54:10 +01:00 |
|
antirez
|
1bc31666da
|
CG: XPENDING without start/stop variant implemented.
|
2018-03-15 12:54:10 +01:00 |
|
antirez
|
af40a25c52
|
CG: XPENDING without start/stop variant implemented.
|
2018-03-15 12:54:10 +01:00 |
|
antirez
|
b65fe09bb8
|
CG: Now XREADGROUP + blocking operations work.
|
2018-03-15 12:54:10 +01:00 |
|
antirez
|
505520ab09
|
CG: Now XREADGROUP + blocking operations work.
|
2018-03-15 12:54:10 +01:00 |
|
antirez
|
5ad29325fe
|
CG: XACK should return zero when nothing is processed.
|
2018-03-15 12:54:10 +01:00 |
|
antirez
|
797d4df6fd
|
CG: XACK should return zero when nothing is processed.
|
2018-03-15 12:54:10 +01:00 |
|
antirez
|
388c69fe4e
|
CG: XACK implementation.
|
2018-03-15 12:54:10 +01:00 |
|
antirez
|
c6ec6fb82a
|
CG: XACK implementation.
|
2018-03-15 12:54:10 +01:00 |
|
antirez
|
5bbd117c29
|
CG: XREADGROUP can fetch data from the consumer PEL.
|
2018-03-15 12:54:10 +01:00 |
|
antirez
|
34d41d8aa5
|
CG: XREADGROUP can fetch data from the consumer PEL.
|
2018-03-15 12:54:10 +01:00 |
|
antirez
|
aa808394f6
|
CG: first draft of streamReplyWithRangeFromConsumerPEL().
|
2018-03-15 12:54:10 +01:00 |
|
antirez
|
68a8dbb256
|
CG: first draft of streamReplyWithRangeFromConsumerPEL().
|
2018-03-15 12:54:10 +01:00 |
|
antirez
|
bbec4569a5
|
CG: Fix order of calls in streamReplyWithRange().
We need to check if we are going to serve the request via the PEL before
inserting a deferred array len in the client output buffer.
|
2018-03-15 12:54:10 +01:00 |
|
antirez
|
9292fee76f
|
CG: Fix order of calls in streamReplyWithRange().
We need to check if we are going to serve the request via the PEL before
inserting a deferred array len in the client output buffer.
|
2018-03-15 12:54:10 +01:00 |
|
antirez
|
41809fd969
|
CG: creation of NACK entries in PELs.
|
2018-03-15 12:54:10 +01:00 |
|
antirez
|
4a5eaaeb76
|
CG: creation of NACK entries in PELs.
|
2018-03-15 12:54:10 +01:00 |
|
antirez
|
1ffb6723f5
|
CG: fix XREADGROUP ">" special ID parsing due to missing "continue".
|
2018-03-15 12:54:10 +01:00 |
|
antirez
|
4de6308f6e
|
CG: fix XREADGROUP ">" special ID parsing due to missing "continue".
|
2018-03-15 12:54:10 +01:00 |
|
antirez
|
6c0af37b6e
|
CG: streamCompareID() + group last_id updating.
|
2018-03-15 12:54:10 +01:00 |
|
antirez
|
5fa401d531
|
CG: streamCompareID() + group last_id updating.
|
2018-03-15 12:54:10 +01:00 |
|
antirez
|
86fe8fde20
|
CG: consumer lookup + initial streamReplyWithRange() work to supprot CG.
|
2018-03-15 12:54:10 +01:00 |
|
antirez
|
6648d60246
|
CG: consumer lookup + initial streamReplyWithRange() work to supprot CG.
|
2018-03-15 12:54:10 +01:00 |
|
antirez
|
ccdae09046
|
CG: add & populate group+consumer in the blocking state.
|
2018-03-15 12:54:10 +01:00 |
|
antirez
|
f7fbc91be3
|
CG: add & populate group+consumer in the blocking state.
|
2018-03-15 12:54:10 +01:00 |
|
antirez
|
b8e5232161
|
CG: fix parsing in XREADGROUP and streamLookupCG() NULL check.
|
2018-03-15 12:54:10 +01:00 |
|
antirez
|
2cf40e99f2
|
CG: fix parsing in XREADGROUP and streamLookupCG() NULL check.
|
2018-03-15 12:54:10 +01:00 |
|
antirez
|
2bbb2bf427
|
CG: XGROUPREAD group option parsing and groups lookup.
|
2018-03-15 12:54:10 +01:00 |
|
antirez
|
59eb392351
|
CG: XGROUPREAD group option parsing and groups lookup.
|
2018-03-15 12:54:10 +01:00 |
|
antirez
|
1fafe7def1
|
CG: fix raxFind() retval check in streamCreateCG().
|
2018-03-15 12:54:10 +01:00 |
|
antirez
|
4e65528940
|
CG: fix raxFind() retval check in streamCreateCG().
|
2018-03-15 12:54:10 +01:00 |
|
antirez
|
58f0c000a5
|
CG: data structures design + XGROUP CREATE implementation.
|
2018-03-15 12:54:10 +01:00 |
|
antirez
|
4925f7773c
|
CG: data structures design + XGROUP CREATE implementation.
|
2018-03-15 12:54:10 +01:00 |
|
antirez
|
84b281209a
|
Stream: update the listpack pointer in streamTrimByLength().
|
2018-03-01 17:26:02 +01:00 |
|
antirez
|
c277aaf3b4
|
Stream: update the listpack pointer in streamTrimByLength().
|
2018-03-01 17:26:02 +01:00 |
|
antirez
|
2869284e44
|
Streams: fix a few type mismatches in t_stream.c.
|
2017-12-04 11:59:15 +01:00 |
|
antirez
|
a135f4f52c
|
Streams: fix a few type mismatches in t_stream.c.
|
2017-12-04 11:59:15 +01:00 |
|
antirez
|
115d076d65
|
Streams: fix lp-count field for non-same-fields entries.
|
2017-12-01 10:24:25 +01:00 |
|
antirez
|
620a9086db
|
Streams: fix lp-count field for non-same-fields entries.
|
2017-12-01 10:24:25 +01:00 |
|
antirez
|
9bb18e5438
|
Streams: XRANGE REV option -> XREVRANGE command.
|
2017-12-01 10:24:25 +01:00 |
|
antirez
|
0c06581bee
|
Streams: XRANGE REV option -> XREVRANGE command.
|
2017-12-01 10:24:25 +01:00 |
|
antirez
|
9dc79c039a
|
Streams: fix reverse iterator discarding of items out of range.
|
2017-12-01 10:24:25 +01:00 |
|
antirez
|
c46aa40cca
|
Streams: fix reverse iterator discarding of items out of range.
|
2017-12-01 10:24:25 +01:00 |
|
antirez
|
6919280cc5
|
Streams: fix reverse iteration next node jumping.
|
2017-12-01 10:24:25 +01:00 |
|
antirez
|
681efe652e
|
Streams: fix reverse iteration next node jumping.
|
2017-12-01 10:24:25 +01:00 |
|
antirez
|
ee3490ec48
|
Streams: state machine for reverse iteration WIP 1.
|
2017-12-01 10:24:25 +01:00 |
|