Commit Graph

  • 3f8ed9a516 Streams: export iteration API. antirez 2017-09-15 12:17:25 +02:00
  • 01ea018c40 Streams: export iteration API. antirez 2017-09-15 12:17:25 +02:00
  • 1b0b5fa224 Streams: implement streamReplyWithRange() in terms of the iterator. antirez 2017-09-14 14:46:31 +02:00
  • 84af6ec436 Streams: implement streamReplyWithRange() in terms of the iterator. antirez 2017-09-14 14:46:31 +02:00
  • 9ed40f0fc3 Streams: implement streamReplyWithRange() in terms of the iterator. antirez 2017-09-14 14:46:31 +02:00
  • e630b17282 Streams: stream iteration refactoring, WIP 2. antirez 2017-09-14 14:23:27 +02:00
  • 0f48b7436d Streams: stream iteration refactoring, WIP 2. antirez 2017-09-14 14:23:27 +02:00
  • a58733cacf Streams: stream iteration refactoring, WIP 2. antirez 2017-09-14 14:23:27 +02:00
  • 11045c4399 Streams: stream iteration refactoring, WIP 1. antirez 2017-09-13 18:05:34 +02:00
  • 6556a208e6 Streams: stream iteration refactoring, WIP 1. antirez 2017-09-13 18:05:34 +02:00
  • b1ec333633 Streams: stream iteration refactoring, WIP 1. antirez 2017-09-13 18:05:34 +02:00
  • ba13aba3a0 Streams: fix bug in XREAD last received ID processing. antirez 2017-09-12 16:19:26 +02:00
  • d436d38155 Streams: fix bug in XREAD last received ID processing. antirez 2017-09-12 16:19:26 +02:00
  • 1a603e1a87 Streams: fix bug in XREAD last received ID processing. antirez 2017-09-12 16:19:26 +02:00
  • 110e66b0c2 Streams: fix memory leak in freeStream(). antirez 2017-09-12 10:54:20 +02:00
  • df8e92d763 Streams: fix memory leak in freeStream(). antirez 2017-09-12 10:54:20 +02:00
  • 94af55c5ea Streams: fix memory leak in freeStream(). antirez 2017-09-12 10:54:20 +02:00
  • 91e09d0959 Streams: rewrite XADD ID argument for AOF/slaves. antirez 2017-09-12 10:48:27 +02:00
  • 6887a8e963 Streams: rewrite XADD ID argument for AOF/slaves. antirez 2017-09-12 10:48:27 +02:00
  • 3a0b78bc52 Streams: rewrite XADD ID argument for AOF/slaves. antirez 2017-09-12 10:48:27 +02:00
  • eb8d0671f8 Streams: fix XADD API and keyspace notifications. antirez 2017-09-11 18:02:57 +02:00
  • 541b1a7cc3 Streams: fix XADD API and keyspace notifications. antirez 2017-09-11 18:02:57 +02:00
  • 19b06935d5 Streams: fix XADD API and keyspace notifications. antirez 2017-09-11 18:02:57 +02:00
  • 6410396372 Streams: When XREAD blocks without COUNT, set a default one. antirez 2017-09-11 11:20:36 +02:00
  • 433624adda Streams: When XREAD blocks without COUNT, set a default one. antirez 2017-09-11 11:20:36 +02:00
  • db89f7474d Streams: When XREAD blocks without COUNT, set a default one. antirez 2017-09-11 11:20:36 +02:00
  • 789f74bba2 Streams: fix handleClientsBlockedOnKeys() access to invalid ID. antirez 2017-09-11 11:06:53 +02:00
  • 2f2a810b52 Streams: fix handleClientsBlockedOnKeys() access to invalid ID. antirez 2017-09-11 11:06:53 +02:00
  • c128190026 Streams: fix handleClientsBlockedOnKeys() access to invalid ID. antirez 2017-09-11 11:06:53 +02:00
  • 06a30111a8 Streams: fix XREAD ready-key signaling. antirez 2017-09-09 11:10:59 +02:00
  • 799eaab940 Streams: fix XREAD ready-key signaling. antirez 2017-09-09 11:10:59 +02:00
  • 6468cb2e82 Streams: fix XREAD ready-key signaling. antirez 2017-09-09 11:10:59 +02:00
  • f3b3ca41f7 Streams: fix XREAD timeout handling, zero is valid. antirez 2017-09-08 20:48:28 +02:00
  • 671c1a2251 Streams: fix XREAD timeout handling, zero is valid. antirez 2017-09-08 20:48:28 +02:00
  • b5be5093fe Streams: fix XREAD timeout handling, zero is valid. antirez 2017-09-08 20:48:28 +02:00
  • ea5ea8da3d Streams: XREAD related code to serve blocked clients. antirez 2017-09-08 16:57:32 +02:00
  • 3aa11e22a4 Streams: XREAD related code to serve blocked clients. antirez 2017-09-08 16:57:32 +02:00
  • 2cacdcd6f8 Streams: XREAD related code to serve blocked clients. antirez 2017-09-08 16:57:32 +02:00
  • 6d54ec5e24 Streams: XREAD ability to block fixed. antirez 2017-09-08 12:25:06 +02:00
  • 9290ad3cb9 Streams: XREAD ability to block fixed. antirez 2017-09-08 12:25:06 +02:00
  • 0adb43b68f Streams: XREAD ability to block fixed. antirez 2017-09-08 12:25:06 +02:00
  • b6f1106630 Streams: synchronous xread fixes and improvements. antirez 2017-09-08 12:09:02 +02:00
  • 539d8747b2 Streams: synchronous xread fixes and improvements. antirez 2017-09-08 12:09:02 +02:00
  • 6a1c92d52d Streams: synchronous xread fixes and improvements. antirez 2017-09-08 12:09:02 +02:00
  • bfeeeb9f34 Streams: XREAD get-key method fixed. antirez 2017-09-08 11:51:53 +02:00
  • dd857e945e Streams: XREAD get-key method fixed. antirez 2017-09-08 11:51:53 +02:00
  • a7d898334a Streams: XREAD get-key method fixed. antirez 2017-09-08 11:51:53 +02:00
  • 084a871019 Streams: XREAD get-keys method. antirez 2017-09-08 11:40:16 +02:00
  • d783126316 Streams: XREAD get-keys method. antirez 2017-09-08 11:40:16 +02:00
  • 110041825c Streams: XREAD get-keys method. antirez 2017-09-08 11:40:16 +02:00
  • 6f79b52dfa Streams: XREAD, first draft. Handling of blocked clients still missing. antirez 2017-09-07 17:45:34 +02:00
  • 004a8b8712 Streams: XREAD, first draft. Handling of blocked clients still missing. antirez 2017-09-07 17:45:34 +02:00
  • fa61720d30 Streams: XREAD, first draft. Handling of blocked clients still missing. antirez 2017-09-07 17:45:34 +02:00
  • 54e221af43 Streams: XREAD arguments parsing. antirez 2017-09-07 16:48:20 +02:00
  • 7ccc80d503 Streams: XREAD arguments parsing. antirez 2017-09-07 16:48:20 +02:00
  • e65b4825f0 Streams: XREAD arguments parsing. antirez 2017-09-07 16:48:20 +02:00
  • 428bb7cca0 Streams: augment client.bpop with XREAD specific fields. antirez 2017-09-07 09:30:50 +02:00
  • a477b95b01 Streams: augment client.bpop with XREAD specific fields. antirez 2017-09-07 09:30:50 +02:00
  • 4086dff477 Streams: augment client.bpop with XREAD specific fields. antirez 2017-09-07 09:30:50 +02:00
  • 6195349b50 Streams: more internal preparation for blocking XREAD. antirez 2017-09-06 17:50:11 +02:00
  • 53600c7fd5 Streams: more internal preparation for blocking XREAD. antirez 2017-09-06 17:50:11 +02:00
  • f80dfbf464 Streams: more internal preparation for blocking XREAD. antirez 2017-09-06 17:50:11 +02:00
  • 896300be30 Streams: initial work to use blocking lists logic for streams XREAD. antirez 2017-09-06 15:43:28 +02:00
  • f6179c38b0 Streams: initial work to use blocking lists logic for streams XREAD. antirez 2017-09-06 15:43:28 +02:00
  • 4a377cecd8 Streams: initial work to use blocking lists logic for streams XREAD. antirez 2017-09-06 15:43:28 +02:00
  • a168cbef13 Streams: implement stream object release. antirez 2017-09-06 13:11:47 +02:00
  • 8016093ee9 Streams: implement stream object release. antirez 2017-09-06 13:11:47 +02:00
  • 439120c620 Streams: implement stream object release. antirez 2017-09-06 13:11:47 +02:00
  • 760ad8f65c Streams: XLEN command. antirez 2017-09-06 12:03:17 +02:00
  • 6a4fd95478 Streams: XLEN command. antirez 2017-09-06 12:03:17 +02:00
  • ec9bbe96bf Streams: XLEN command. antirez 2017-09-06 12:03:17 +02:00
  • 64a7ad038d Streams: Save stream->length in RDB. antirez 2017-09-06 12:00:18 +02:00
  • 1157127d8e Streams: Save stream->length in RDB. antirez 2017-09-06 12:00:18 +02:00
  • 98d184db12 Streams: Save stream->length in RDB. antirez 2017-09-06 12:00:18 +02:00
  • fac8b716ab Streams: change listpack allocator to zmalloc. antirez 2017-09-06 12:00:03 +02:00
  • aa8acb476b Streams: change listpack allocator to zmalloc. antirez 2017-09-06 12:00:03 +02:00
  • cd18f06e9c Streams: change listpack allocator to zmalloc. antirez 2017-09-06 12:00:03 +02:00
  • 90c980b105 Streams: RDB loading. RDB saving modified. antirez 2017-09-05 16:24:11 +02:00
  • 5a9ec523f5 Streams: RDB loading. RDB saving modified. antirez 2017-09-05 16:24:11 +02:00
  • edd70c1993 Streams: RDB loading. RDB saving modified. antirez 2017-09-05 16:24:11 +02:00
  • f028e4e68e Streams: RDB saving. antirez 2017-09-05 13:14:13 +02:00
  • fac980c6d1 Streams: RDB saving. antirez 2017-09-05 13:14:13 +02:00
  • 485014cc74 Streams: RDB saving. antirez 2017-09-05 13:14:13 +02:00
  • e4e216f8cc Streams: assign value of 6 to OBJ_STREAM + some refactoring. antirez 2017-09-05 12:13:16 +02:00
  • 27fd469a8d Streams: assign value of 6 to OBJ_STREAM + some refactoring. antirez 2017-09-05 12:13:16 +02:00
  • 100d43c1ac Streams: assign value of 6 to OBJ_STREAM + some refactoring. antirez 2017-09-05 12:13:16 +02:00
  • 71ad8ff26e Streams: 12 commits squashed into the initial Streams implementation. antirez 2017-08-30 12:40:27 +02:00
  • 1850ff43f4 Streams: 12 commits squashed into the initial Streams implementation. antirez 2017-08-30 12:40:27 +02:00
  • 79866a6361 Streams: 12 commits squashed into the initial Streams implementation. antirez 2017-08-30 12:40:27 +02:00
  • 95eaf3aada PSYNC2: Fix off by one buffer size in luaCreateFunction(). antirez 2017-11-29 17:11:46 +01:00
  • 77c4f82b55 PSYNC2: Fix off by one buffer size in luaCreateFunction(). antirez 2017-11-29 17:11:46 +01:00
  • 045d65c3af PSYNC2: Fix off by one buffer size in luaCreateFunction(). antirez 2017-11-29 17:11:46 +01:00
  • 6051ebea33 PSYNC2: just store script bodies into RDB. antirez 2017-11-29 16:38:16 +01:00
  • 4f1b09e79a PSYNC2: just store script bodies into RDB. antirez 2017-11-29 16:38:16 +01:00
  • 452ad2e928 PSYNC2: just store script bodies into RDB. antirez 2017-11-29 16:38:16 +01:00
  • d14beab331 PSYNC2: luaCreateFunction() should handle NULL client parameter. antirez 2017-11-29 16:21:14 +01:00
  • 29427aa85c PSYNC2: luaCreateFunction() should handle NULL client parameter. antirez 2017-11-29 16:21:14 +01:00
  • 28dfdca733 PSYNC2: luaCreateFunction() should handle NULL client parameter. antirez 2017-11-29 16:21:14 +01:00
  • 445d37f24d PSYNC2: Save Lua scripts state into RDB file. antirez 2017-11-29 15:09:07 +01:00
  • 35773a3295 PSYNC2: Save Lua scripts state into RDB file. antirez 2017-11-29 15:09:07 +01:00