antirez
0cf6b1e3ae
CG: XINFO CONSUMERS implemented.
2018-03-15 12:54:10 +01:00
antirez
67eeeb0b10
Streams: fix XREAD missing check for NULL object.
2018-03-15 12:54:10 +01:00
antirez
8d8755c7b5
CG: throw an error if XREADGROUP is used without GROUP.
2018-03-15 12:54:10 +01:00
antirez
d4f81ebdba
CG: XGROUP DELCONSUMER implemented.
2018-03-15 12:54:10 +01:00
antirez
9b423ae237
CG: remove stale comment. XREADGROUP is now implemented.
2018-03-15 12:54:10 +01:00
antirez
e6d434c167
CG: implement RETRYCOUNT in XCLAIM.
2018-03-15 12:54:10 +01:00
antirez
f3d9520ccb
CG: fix CG RDB loading not found conditional.
2018-03-15 12:54:10 +01:00
antirez
34614a1508
CG: NACK created by XCLAIM FORCE must be set in global PEL.
2018-03-15 12:54:10 +01:00
antirez
596264aee9
CG: implement XCLAIM FORCE option.
2018-03-15 12:54:10 +01:00
antirez
b26f03bd69
CG: XCLAIM now updates the idle time of the message.
2018-03-15 12:54:10 +01:00
antirez
f7d4c3acdf
Streams: trap more errors in stream loading + RDB check type name.
2018-03-15 12:54:10 +01:00
antirez
8727b4845b
CG: XCLAIM, use minidle and fix array len.
2018-03-15 12:54:10 +01:00
antirez
09e3b3b975
CG: remove unused argument from streamReplyWithRangeFromConsumerPEL().
2018-03-15 12:54:10 +01:00
antirez
13ff7bc3ef
CG: fix RDB saving when there are no consumer groups.
2018-03-15 12:54:10 +01:00
antirez
267f7f2c97
Streams: fix error description for XADD when specified ID is small.
2018-03-15 12:54:10 +01:00
antirez
0a6780e560
CG: XCLAIM initial draft.
2018-03-15 12:54:10 +01:00
antirez
00a29b1a81
Make addReplyError...() family functions able to get error codes.
...
Now you can use:
addReplyError("-MYERRORCODE some message");
If the error code is omitted, the behavior is like in the past,
the generic -ERR will be used.
2018-03-15 12:54:10 +01:00
antirez
54b9a0e612
CG: test XACK remaining features.
2018-03-15 12:54:10 +01:00
antirez
5f8c57f28a
CG: test XACK ability to remove items from the PELs.
2018-03-15 12:54:10 +01:00
antirez
f5799e728a
CG: test XPENDING ability to return pending items.
2018-03-15 12:54:10 +01:00
antirez
c2ecac4746
CG: test XGROUPREAD abilities.
2018-03-15 12:54:10 +01:00
antirez
18ab0e31f3
CG: test group creation.
2018-03-15 12:54:10 +01:00
antirez
c9d86c2b16
CG: More specific duplicated group error.
2018-03-15 12:54:10 +01:00
antirez
9f60a6bcee
CG: RDB loading, fix inverted conditional.
2018-03-15 12:54:10 +01:00
antirez
f4e1a4de25
CG: RDB loading first implementation.
2018-03-15 12:54:10 +01:00
antirez
db7a5f23b4
CG: RDB saving part 2, consumers.
2018-03-15 12:54:10 +01:00
antirez
8fb6048ed0
CG: RDB saving part 1, metadata and PEL.
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
f3708af7f9
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
b65fe09bb8
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
388c69fe4e
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
aa808394f6
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
41809fd969
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
6c0af37b6e
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
ccdae09046
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
bd1c11dc35
CG: add XREADGROUP in the command table.
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
1fafe7def1
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
charsyam
c76f890209
fix listpack.c to listpack.o in Makefile
2018-03-15 20:32:08 +09:00
Otmar Ertl
15d7e61701
fixed compilation error when using clang as reported by michael-grunder
2018-03-14 21:00:06 +01:00
antirez
d8207d09ee
Cluster: add test for the nofailover flag.
2018-03-14 16:30:32 +01:00
antirez
432bf4770e
Cluster: ability to prevent slaves from failing over their masters.
...
This commit, in some parts derived from PR #3041 which is no longer
possible to merge (because the user deleted the original branch),
implements the ability of slaves to have a special configuration
preventing that they try to start a failover when the master is failing.
There are multiple reasons for wanting this, and the feautre was
requested in issue #3021 time ago.
The differences between this patch and the original PR are the
following:
1. The flag is saved/loaded on the nodes configuration.
2. The 'myself' node is now flag-aware, the flag is updated as needed
when the configuration is changed via CONFIG SET.
3. The flag name uses NOFAILOVER instead of NO_FAILOVER to be consistent
with existing NOADDR.
4. The redis.conf documentation was rewritten.
Thanks to @deep011 for the original patch.
2018-03-14 14:01:38 +01:00
