Something went wrong. Try again.
What happens if I push all of nixpkgs
Something went wrong. Try again.
Nix
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160{ pkgs, lib, getPackage ? pkgs: pkgs.cassandra_4, ...}:let testPackage = getPackage pkgs; clusterName = "NixOS Automated-Test Cluster"; testRemoteAuth = lib.versionAtLeast testPackage.version "3.11"; jmxRoles = [ { username = "me"; password = "password"; } ]; jmxRolesFile = ./cassandra-jmx-roles; jmxAuthArgs = "-u ${(builtins.elemAt jmxRoles 0).username} -pw ${(builtins.elemAt jmxRoles 0).password}"; jmxPort = 7200; # Non-standard port so it doesn't accidentally work jmxPortStr = toString jmxPort;
# Would usually be assigned to 512M. # Set it to a different value, so that we can check whether our config # actually changes it. numMaxHeapSize = "400"; getHeapLimitCommand = '' nodetool info -p ${jmxPortStr} | grep "^Heap Memory" | awk '{print $NF}' ''; checkHeapLimitCommand = pkgs.writeShellScript "check-heap-limit.sh" '' [ 1 -eq "$(echo "$(${getHeapLimitCommand}) < ${numMaxHeapSize}" | ${pkgs.bc}/bin/bc)" ] '';
cassandraCfg = pkgs: ipAddress: { enable = true; inherit clusterName; listenAddress = ipAddress; rpcAddress = ipAddress; seedAddresses = [ "192.168.1.1" ]; package = getPackage pkgs; maxHeapSize = "${numMaxHeapSize}M"; heapNewSize = "100M"; inherit jmxPort; }; nodeCfg = ipAddress: extra: { pkgs, config, ... }: rec { environment.systemPackages = [ (getPackage pkgs) ]; networking = { firewall.allowedTCPPorts = [ 7000 9042 services.cassandra.jmxPort ]; useDHCP = false; interfaces.eth1.ipv4.addresses = pkgs.lib.mkOverride 0 [ { address = ipAddress; prefixLength = 24; } ]; }; services.cassandra = cassandraCfg pkgs ipAddress // extra; };in{ name = "cassandra-${testPackage.version}"; meta = { maintainers = with lib.maintainers; [ johnazoidberg ]; };
nodes = { cass0 = nodeCfg "192.168.1.1" { }; cass1 = nodeCfg "192.168.1.2" ( lib.optionalAttrs testRemoteAuth { inherit jmxRoles; remoteJmx = true; } ); cass2 = nodeCfg "192.168.1.3" { jvmOpts = [ "-Dcassandra.replace_address=cass1" ]; }; };
testScript = '' # Check configuration with subtest("Timers exist"): cass0.succeed("systemctl list-timers | grep cassandra-full-repair.timer") cass0.succeed("systemctl list-timers | grep cassandra-incremental-repair.timer")
with subtest("Can connect via cqlsh"): cass0.wait_for_unit("cassandra.service") cass0.wait_until_succeeds("nc -z cass0 9042") cass0.succeed("echo 'show version;' | cqlsh cass0")
with subtest("Nodetool is operational"): cass0.wait_for_unit("cassandra.service") cass0.wait_until_succeeds("nc -z localhost ${jmxPortStr}") cass0.succeed("nodetool status -p ${jmxPortStr} --resolve-ip | egrep '^UN[[:space:]]+cass0'")
with subtest("Cluster name was set"): cass0.wait_for_unit("cassandra.service") cass0.wait_until_succeeds("nc -z localhost ${jmxPortStr}") cass0.wait_until_succeeds( "nodetool describecluster -p ${jmxPortStr} | grep 'Name: ${clusterName}'" )
with subtest("Heap limit set correctly"): # Nodetool takes a while until it can display info cass0.wait_until_succeeds("nodetool info -p ${jmxPortStr}") cass0.succeed("${checkHeapLimitCommand}")
# Check cluster interaction with subtest("Bring up cluster"): cass1.wait_for_unit("cassandra.service") cass1.wait_until_succeeds( "nodetool -p ${jmxPortStr} ${jmxAuthArgs} status | egrep -c '^UN' | grep 2" ) cass0.succeed("nodetool status -p ${jmxPortStr} --resolve-ip | egrep '^UN[[:space:]]+cass1'") '' + lib.optionalString testRemoteAuth '' with subtest("Remote authenticated jmx"): # Doesn't work if not enabled cass0.wait_until_succeeds("nc -z localhost ${jmxPortStr}") cass1.fail("nc -z 192.168.1.1 ${jmxPortStr}") cass1.fail("nodetool -p ${jmxPortStr} -h 192.168.1.1 status")
# Works if enabled cass1.wait_until_succeeds("nc -z localhost ${jmxPortStr}") cass0.succeed("nodetool -p ${jmxPortStr} -h 192.168.1.2 ${jmxAuthArgs} status") '' + '' with subtest("Break and fix node"): cass1.block() cass0.wait_until_succeeds( "nodetool status -p ${jmxPortStr} --resolve-ip | egrep -c '^DN[[:space:]]+cass1'" ) cass0.succeed("nodetool status -p ${jmxPortStr} | egrep -c '^UN' | grep 1") cass1.unblock() cass1.wait_until_succeeds( "nodetool -p ${jmxPortStr} ${jmxAuthArgs} status | egrep -c '^UN' | grep 2" ) cass0.succeed("nodetool status -p ${jmxPortStr} | egrep -c '^UN' | grep 2")
with subtest("Replace crashed node"): cass1.block() # .crash() waits until it's fully shutdown cass2.start() cass0.wait_until_fails( "nodetool status -p ${jmxPortStr} --resolve-ip | egrep '^UN[[:space:]]+cass1'" )
cass2.wait_for_unit("cassandra.service") cass0.wait_until_succeeds( "nodetool status -p ${jmxPortStr} --resolve-ip | egrep '^UN[[:space:]]+cass2'" ) '';
passthru = { inherit testPackage; };}