Name Date Size

..11-Jan-20224 KiB

bucket.ccH A D11-Jan-20222.5 KiB

bucket.hH A D11-Jan-20224.4 KiB

cluster.ccH A D11-Jan-20229.9 KiB

cluster.hH A D11-Jan-20223.1 KiB

clustertest.ccH A D11-Jan-20222.9 KiB

clustertest.hH A D11-Jan-20221.9 KiB

CMakeLists.txtH A D11-Jan-20221,006

dcp_packet_filter.hH A D11-Jan-20222 KiB

dcp_replicator.ccH A D11-Jan-20229.8 KiB

dcp_replicator.hH A D11-Jan-20222.9 KiB

dcppipe.ccH A D11-Jan-20226.6 KiB

dcppipe.hH A D11-Jan-20222.2 KiB

durability_tests.ccH A D11-Jan-202210.6 KiB

durability_upgrade_tests.ccH A D11-Jan-20223.7 KiB

main.ccH A D11-Jan-20226.2 KiB

node.ccH A D11-Jan-20229.1 KiB

node.hH A D11-Jan-20221.5 KiB

readme.mdH A D11-Jan-20221.1 KiB

readme.md

1# Cluster test
2
3The cluster test framework allows you to create a cluster of 'n' nodes on the
4same machine to test cross-node functionality (replication, durability etc).
5
6## Quick howto
7
8    auto cluster = cb::test::createCluster(4);
9    auto bucket = cluster->createBucket("test", {{"replicas", 3},
10                                                 {"max_size", 67108864}});
11
12At this point you've got a cluster with a bucket named test and all of
13the replication streams should be up'n'running. The cluster provides
14a way to get a connection to a given node, or to get a connection to
15the node where a given vbucket lives (with the specified state).
16Note that you would need to authenticate and select bucket (the system
17can't select the bucket for you as that would need to happen after
18an authentication phase):
19
20    auto connection = bucket->getConnection(Vbid{0});
21    connection->authenticate("foo", "bar", "PLAIN");
22    connection->selectBucket("test");
23    conn->store("foo", Vbid(0), "value");
24
25## Limitations
26
27* Can't move vbuckets around (rebalance)
28* No support for CCCP bootstrapping (we should be able to do that)
29