 antirez
|
f24d3a7de0
Streams: delta encode IDs based on key. Add count + deleted fields.
|
7 years ago |
|
antirez
|
cea421a021
Streams: specify better how the master enty works.
|
7 years ago |
|
antirez
|
7d0d9693c1
Streams: modify tests to stress compression.
|
7 years ago |
|
antirez
|
3f2d7e277e
Streams: items compression implemented.
|
7 years ago |
|
antirez
|
8f00cf85a7
Streams: fixed memory leaks when blocking again for same stream.
|
7 years ago |
|
antirez
|
ae9065d808
Streams: tests for blocking and non-blocking XREAD.
|
7 years ago |
|
antirez
|
eb1230c999
Streams: XRANGE fuzz testing.
|
7 years ago |
|
antirez
|
fa707ca154
Streams: more advanced XADD and XRANGE tests.
|
7 years ago |
|
antirez
|
7a41b402c1
Streams: basic XADD tests.
|
7 years ago |
|
antirez
|
26d4f8e3ec
Streams: AOF rewriting + minor iterator improvements.
|
7 years ago |
|
antirez
|
01ea018c40
Streams: export iteration API.
|
7 years ago |
|
antirez
|
9ed40f0fc3
Streams: implement streamReplyWithRange() in terms of the iterator.
|
7 years ago |
|
antirez
|
a58733cacf
Streams: stream iteration refactoring, WIP 2.
|
7 years ago |
|
antirez
|
b1ec333633
Streams: stream iteration refactoring, WIP 1.
|
7 years ago |
|
antirez
|
1a603e1a87
Streams: fix bug in XREAD last received ID processing.
|
7 years ago |
|
antirez
|
94af55c5ea
Streams: fix memory leak in freeStream().
|
7 years ago |
|
antirez
|
3a0b78bc52
Streams: rewrite XADD ID argument for AOF/slaves.
|
7 years ago |
|
antirez
|
19b06935d5
Streams: fix XADD API and keyspace notifications.
|
7 years ago |
|
antirez
|
db89f7474d
Streams: When XREAD blocks without COUNT, set a default one.
|
7 years ago |
|
antirez
|
c128190026
Streams: fix handleClientsBlockedOnKeys() access to invalid ID.
|
7 years ago |
|
antirez
|
6468cb2e82
Streams: fix XREAD ready-key signaling.
|
7 years ago |
|
antirez
|
b5be5093fe
Streams: fix XREAD timeout handling, zero is valid.
|
7 years ago |
|
antirez
|
2cacdcd6f8
Streams: XREAD related code to serve blocked clients.
|
7 years ago |
|
antirez
|
0adb43b68f
Streams: XREAD ability to block fixed.
|
7 years ago |
|
antirez
|
6a1c92d52d
Streams: synchronous xread fixes and improvements.
|
7 years ago |
|
antirez
|
a7d898334a
Streams: XREAD get-key method fixed.
|
7 years ago |
|
antirez
|
110041825c
Streams: XREAD get-keys method.
|
7 years ago |
|
antirez
|
fa61720d30
Streams: XREAD, first draft. Handling of blocked clients still missing.
|
7 years ago |
|
antirez
|
e65b4825f0
Streams: XREAD arguments parsing.
|
7 years ago |
|
antirez
|
4086dff477
Streams: augment client.bpop with XREAD specific fields.
|
7 years ago |
