summaryrefslogtreecommitdiffstats
path: root/nixos/tests/cassandra.nix
diff options
context:
space:
mode:
authorDaniel Schaefer <git@danielschaefer.me>2019-04-23 04:59:53 +0200
committerDaniel Schaefer <git@danielschaefer.me>2019-06-13 04:36:41 +0200
commit4c880fd7426cafbc5091561d20062511e5eb967f (patch)
treec9421f9de4b7f0b419c5cf80e4349be247df28d1 /nixos/tests/cassandra.nix
parent35531f40164fe5876a484a7f213fb029fd2f927d (diff)
nixos/cassandra: Use ipAddress and capital letters
Diffstat (limited to 'nixos/tests/cassandra.nix')
-rw-r--r--nixos/tests/cassandra.nix26
1 files changed, 15 insertions, 11 deletions
diff --git a/nixos/tests/cassandra.nix b/nixos/tests/cassandra.nix
index 40d6b238dc02..208e94c64c96 100644
--- a/nixos/tests/cassandra.nix
+++ b/nixos/tests/cassandra.nix
@@ -2,10 +2,11 @@ import ./make-test.nix ({ pkgs, ...}:
let
# Change this to test a different version of Cassandra:
testPackage = pkgs.cassandra;
- cassandraCfg = hostname:
+
+ cassandraCfg = ipAddress:
{ enable = true;
- listenAddress = hostname;
- rpcAddress = hostname;
+ listenAddress = ipAddress;
+ rpcAddress = ipAddress;
extraConfig =
{ start_native_transport = true;
seed_provider =
@@ -15,10 +16,10 @@ let
};
package = testPackage;
};
- nodeCfg = hostname: extra: {pkgs, config, ...}:
+ nodeCfg = ipAddress: extra: {pkgs, config, ...}:
{ environment.systemPackages = [ testPackage ];
networking.firewall.enable = false;
- services.cassandra = cassandraCfg hostname // extra;
+ services.cassandra = cassandraCfg ipAddress // extra;
virtualisation.memorySize = 1024;
};
in
@@ -32,26 +33,29 @@ in
};
testScript = ''
- subtest "timers exist", sub {
+ # Check configuration
+ subtest "Timers exist", sub {
$cass0->succeed("systemctl list-timers | grep cassandra-full-repair.timer");
$cass0->succeed("systemctl list-timers | grep cassandra-incremental-repair.timer");
};
- subtest "can connect via cqlsh", sub {
+ subtest "Can connect via cqlsh", sub {
$cass0->waitForUnit("cassandra.service");
$cass0->waitUntilSucceeds("nc -z cass0 9042");
$cass0->succeed("echo 'show version;' | cqlsh cass0");
};
- subtest "nodetool is operational", sub {
+ subtest "Nodetool is operational", sub {
$cass0->waitForUnit("cassandra.service");
$cass0->waitUntilSucceeds("nc -z localhost 7199");
$cass0->succeed("nodetool status --resolve-ip | egrep '^UN[[:space:]]+cass0'");
};
- subtest "bring up cluster", sub {
+
+ # Check cluster interaction
+ subtest "Bring up cluster", sub {
$cass1->waitForUnit("cassandra.service");
$cass1->waitUntilSucceeds("nodetool status | egrep -c '^UN' | grep 2");
$cass0->succeed("nodetool status --resolve-ip | egrep '^UN[[:space:]]+cass1'");
};
- subtest "break and fix node", sub {
+ subtest "Break and fix node", sub {
$cass1->block;
$cass0->waitUntilSucceeds("nodetool status --resolve-ip | egrep -c '^DN[[:space:]]+cass1'");
$cass0->succeed("nodetool status | egrep -c '^UN' | grep 1");
@@ -59,7 +63,7 @@ in
$cass1->waitUntilSucceeds("nodetool status | egrep -c '^UN' | grep 2");
$cass0->succeed("nodetool status | egrep -c '^UN' | grep 2");
};
- subtest "replace crashed node", sub {
+ subtest "Replace crashed node", sub {
$cass1->crash;
$cass2->waitForUnit("cassandra.service");
$cass0->waitUntilFails("nodetool status --resolve-ip | egrep '^UN[[:space:]]+cass1'");