Commit Graph

  • 038488c0c4 CG: XCLAIM now updates the idle time of the message. antirez 2018-02-21 11:42:51 +01:00
  • 0c4a8532c6 CG: XCLAIM now updates the idle time of the message. antirez 2018-02-21 11:42:51 +01:00
  • b26f03bd69 CG: XCLAIM now updates the idle time of the message. antirez 2018-02-21 11:42:51 +01:00
  • 2966aac16d Streams: trap more errors in stream loading + RDB check type name. antirez 2018-02-21 11:17:46 +01:00
  • 4c1db9b9e7 Streams: trap more errors in stream loading + RDB check type name. antirez 2018-02-21 11:17:46 +01:00
  • f7d4c3acdf Streams: trap more errors in stream loading + RDB check type name. antirez 2018-02-21 11:17:46 +01:00
  • 18f8c34d4a CG: XCLAIM, use minidle and fix array len. antirez 2018-02-21 10:51:43 +01:00
  • bebd33993c CG: XCLAIM, use minidle and fix array len. antirez 2018-02-21 10:51:43 +01:00
  • 8727b4845b CG: XCLAIM, use minidle and fix array len. antirez 2018-02-21 10:51:43 +01:00
  • 8348d92e56 CG: remove unused argument from streamReplyWithRangeFromConsumerPEL(). antirez 2018-02-21 10:50:32 +01:00
  • 106eb6adcc CG: remove unused argument from streamReplyWithRangeFromConsumerPEL(). antirez 2018-02-21 10:50:32 +01:00
  • 09e3b3b975 CG: remove unused argument from streamReplyWithRangeFromConsumerPEL(). antirez 2018-02-21 10:50:32 +01:00
  • 431e12a033 CG: fix RDB saving when there are no consumer groups. antirez 2018-02-18 23:13:41 +01:00
  • 3ecf2a1005 CG: fix RDB saving when there are no consumer groups. antirez 2018-02-18 23:13:41 +01:00
  • 13ff7bc3ef CG: fix RDB saving when there are no consumer groups. antirez 2018-02-18 23:13:41 +01:00
  • 591e3f031d Streams: fix error description for XADD when specified ID is small. antirez 2018-02-18 23:12:49 +01:00
  • fe9a0b9d6d Streams: fix error description for XADD when specified ID is small. antirez 2018-02-18 23:12:49 +01:00
  • 267f7f2c97 Streams: fix error description for XADD when specified ID is small. antirez 2018-02-18 23:12:49 +01:00
  • 096350cf33 CG: XCLAIM initial draft. antirez 2018-02-16 17:25:35 +01:00
  • d3c15ef886 CG: XCLAIM initial draft. antirez 2018-02-16 17:25:35 +01:00
  • 0a6780e560 CG: XCLAIM initial draft. antirez 2018-02-16 17:25:35 +01:00
  • bab33460ab Make addReplyError...() family functions able to get error codes. antirez 2018-02-16 16:18:01 +01:00
  • 535c016ddf Make addReplyError...() family functions able to get error codes. antirez 2018-02-16 16:18:01 +01:00
  • 00a29b1a81 Make addReplyError...() family functions able to get error codes. antirez 2018-02-16 16:18:01 +01:00
  • 75ad54c9a2 CG: test XACK remaining features. antirez 2018-02-16 12:13:04 +01:00
  • 72282c440b CG: test XACK remaining features. antirez 2018-02-16 12:13:04 +01:00
  • 54b9a0e612 CG: test XACK remaining features. antirez 2018-02-16 12:13:04 +01:00
  • c3396a6c8d CG: test XACK ability to remove items from the PELs. antirez 2018-02-16 12:10:40 +01:00
  • c72389ef0f CG: test XACK ability to remove items from the PELs. antirez 2018-02-16 12:10:40 +01:00
  • 5f8c57f28a CG: test XACK ability to remove items from the PELs. antirez 2018-02-16 12:10:40 +01:00
  • 08ea1440cf CG: test XPENDING ability to return pending items. antirez 2018-02-16 12:03:40 +01:00
  • 862c29fc1b CG: test XPENDING ability to return pending items. antirez 2018-02-16 12:03:40 +01:00
  • f5799e728a CG: test XPENDING ability to return pending items. antirez 2018-02-16 12:03:40 +01:00
  • b1aa4a5c8b CG: test XGROUPREAD abilities. antirez 2018-02-16 11:57:27 +01:00
  • 0a5272cea8 CG: test XGROUPREAD abilities. antirez 2018-02-16 11:57:27 +01:00
  • c2ecac4746 CG: test XGROUPREAD abilities. antirez 2018-02-16 11:57:27 +01:00
  • e780693add CG: test group creation. antirez 2018-02-16 11:56:31 +01:00
  • b3ae33b2ad CG: test group creation. antirez 2018-02-16 11:56:31 +01:00
  • 18ab0e31f3 CG: test group creation. antirez 2018-02-16 11:56:31 +01:00
  • dfff06af91 CG: More specific duplicated group error. antirez 2018-02-16 11:55:51 +01:00
  • 8d3c0e4186 CG: More specific duplicated group error. antirez 2018-02-16 11:55:51 +01:00
  • c9d86c2b16 CG: More specific duplicated group error. antirez 2018-02-16 11:55:51 +01:00
  • 81f45896d0 CG: RDB loading, fix inverted conditional. antirez 2018-02-14 18:34:08 +01:00
  • bd4dd842ea CG: RDB loading, fix inverted conditional. antirez 2018-02-14 18:34:08 +01:00
  • 9f60a6bcee CG: RDB loading, fix inverted conditional. antirez 2018-02-14 18:34:08 +01:00
  • 84667bff70 CG: RDB loading first implementation. antirez 2018-02-14 16:37:24 +01:00
  • f979275a2a CG: RDB loading first implementation. antirez 2018-02-14 16:37:24 +01:00
  • f4e1a4de25 CG: RDB loading first implementation. antirez 2018-02-14 16:37:24 +01:00
  • 76b264dd7e CG: RDB saving part 2, consumers. antirez 2018-01-31 17:06:32 +01:00
  • 80da510011 CG: RDB saving part 2, consumers. antirez 2018-01-31 17:06:32 +01:00
  • db7a5f23b4 CG: RDB saving part 2, consumers. antirez 2018-01-31 17:06:32 +01:00
  • 3763d5c164 CG: RDB saving part 1, metadata and PEL. antirez 2018-01-31 12:05:04 +01:00
  • 9a686b82cd CG: RDB saving part 1, metadata and PEL. antirez 2018-01-31 12:05:04 +01:00
  • 8fb6048ed0 CG: RDB saving part 1, metadata and PEL. antirez 2018-01-31 12:05:04 +01:00
  • ec0faf1bd9 CG: XPENDING should not create consumers and obey to count. antirez 2018-01-29 18:32:38 +01:00
  • 922b74828b CG: XPENDING should not create consumers and obey to count. antirez 2018-01-29 18:32:38 +01:00
  • e76fb4ab25 CG: XPENDING should not create consumers and obey to count. antirez 2018-01-29 18:32:38 +01:00
  • c0cf16f988 CG: XPENDING with start/stop/count variant implemented. antirez 2018-01-29 18:23:26 +01:00
  • c139073709 CG: XPENDING with start/stop/count variant implemented. antirez 2018-01-29 18:23:26 +01:00
  • f3708af7f9 CG: XPENDING with start/stop/count variant implemented. antirez 2018-01-29 18:23:26 +01:00
  • af40a25c52 CG: XPENDING without start/stop variant implemented. antirez 2018-01-26 17:27:34 +01:00
  • a85f0fc571 CG: XPENDING without start/stop variant implemented. antirez 2018-01-26 17:27:34 +01:00
  • 1bc31666da CG: XPENDING without start/stop variant implemented. antirez 2018-01-26 17:27:34 +01:00
  • 505520ab09 CG: Now XREADGROUP + blocking operations work. antirez 2018-01-26 11:57:19 +01:00
  • f49cbaf84c CG: Now XREADGROUP + blocking operations work. antirez 2018-01-26 11:57:19 +01:00
  • b65fe09bb8 CG: Now XREADGROUP + blocking operations work. antirez 2018-01-26 11:57:19 +01:00
  • 797d4df6fd CG: XACK should return zero when nothing is processed. antirez 2018-01-26 11:18:34 +01:00
  • 55b705689f CG: XACK should return zero when nothing is processed. antirez 2018-01-26 11:18:34 +01:00
  • 5ad29325fe CG: XACK should return zero when nothing is processed. antirez 2018-01-26 11:18:34 +01:00
  • c6ec6fb82a CG: XACK implementation. antirez 2018-01-25 16:39:49 +01:00
  • 9b2223cebd CG: XACK implementation. antirez 2018-01-25 16:39:49 +01:00
  • 388c69fe4e CG: XACK implementation. antirez 2018-01-25 16:39:49 +01:00
  • 34d41d8aa5 CG: XREADGROUP can fetch data from the consumer PEL. antirez 2018-01-25 11:30:28 +01:00
  • d82968ece2 CG: XREADGROUP can fetch data from the consumer PEL. antirez 2018-01-25 11:30:28 +01:00
  • 5bbd117c29 CG: XREADGROUP can fetch data from the consumer PEL. antirez 2018-01-25 11:30:28 +01:00
  • 68a8dbb256 CG: first draft of streamReplyWithRangeFromConsumerPEL(). antirez 2018-01-24 18:51:23 +01:00
  • 018f8a3c1d CG: first draft of streamReplyWithRangeFromConsumerPEL(). antirez 2018-01-24 18:51:23 +01:00
  • aa808394f6 CG: first draft of streamReplyWithRangeFromConsumerPEL(). antirez 2018-01-24 18:51:23 +01:00
  • 9292fee76f CG: Fix order of calls in streamReplyWithRange(). antirez 2018-01-24 16:47:39 +01:00
  • 391e1082a4 CG: Fix order of calls in streamReplyWithRange(). antirez 2018-01-24 16:47:39 +01:00
  • bbec4569a5 CG: Fix order of calls in streamReplyWithRange(). antirez 2018-01-24 16:47:39 +01:00
  • 4a5eaaeb76 CG: creation of NACK entries in PELs. antirez 2018-01-23 18:52:24 +01:00
  • 840ad8cec6 CG: creation of NACK entries in PELs. antirez 2018-01-23 18:52:24 +01:00
  • 41809fd969 CG: creation of NACK entries in PELs. antirez 2018-01-23 18:52:24 +01:00
  • 4de6308f6e CG: fix XREADGROUP ">" special ID parsing due to missing "continue". antirez 2018-01-22 12:09:35 +01:00
  • 28d36e3aa3 CG: fix XREADGROUP ">" special ID parsing due to missing "continue". antirez 2018-01-22 12:09:35 +01:00
  • 1ffb6723f5 CG: fix XREADGROUP ">" special ID parsing due to missing "continue". antirez 2018-01-22 12:09:35 +01:00
  • 5fa401d531 CG: streamCompareID() + group last_id updating. antirez 2018-01-22 11:58:18 +01:00
  • e0733ff7f8 CG: streamCompareID() + group last_id updating. antirez 2018-01-22 11:58:18 +01:00
  • 6c0af37b6e CG: streamCompareID() + group last_id updating. antirez 2018-01-22 11:58:18 +01:00
  • 6648d60246 CG: consumer lookup + initial streamReplyWithRange() work to supprot CG. antirez 2018-01-19 17:18:06 +01:00
  • 0f43a908f9 CG: consumer lookup + initial streamReplyWithRange() work to supprot CG. antirez 2018-01-19 17:18:06 +01:00
  • 86fe8fde20 CG: consumer lookup + initial streamReplyWithRange() work to supprot CG. antirez 2018-01-19 17:18:06 +01:00
  • f7fbc91be3 CG: add & populate group+consumer in the blocking state. antirez 2018-01-19 16:39:09 +01:00
  • 23dc98ac52 CG: add & populate group+consumer in the blocking state. antirez 2018-01-19 16:39:09 +01:00
  • ccdae09046 CG: add & populate group+consumer in the blocking state. antirez 2018-01-19 16:39:09 +01:00
  • 2cf40e99f2 CG: fix parsing in XREADGROUP and streamLookupCG() NULL check. antirez 2018-01-19 11:11:52 +01:00
  • 20bc183ef8 CG: fix parsing in XREADGROUP and streamLookupCG() NULL check. antirez 2018-01-19 11:11:52 +01:00
  • b8e5232161 CG: fix parsing in XREADGROUP and streamLookupCG() NULL check. antirez 2018-01-19 11:11:52 +01:00
  • 7d3280143c CG: add XREADGROUP in the command table. antirez 2018-01-19 11:06:39 +01:00