nixos/tests/zookeeper.nix

   1 import ./make-test-python.nix ({ pkgs, ...} :
   2 let
   3
   4   perlEnv = pkgs.perl.withPackages (p: [p.NetZooKeeper]);
   5
   6 in {
   7   name = "zookeeper";
   8   meta = with pkgs.lib.maintainers; {
   9     maintainers = [ nequissimus ztzg ];
  10   };
  11
  12   nodes = {
  13     server = { ... }: {
  14       services.zookeeper = {
  15         enable = true;
  16       };
  17
  18       networking.firewall.allowedTCPPorts = [ 2181 ];
  19     };
  20   };
  21
  22   testScript = ''
  23     start_all()
  24
  25     server.wait_for_unit("zookeeper")
  26     server.wait_for_unit("network.target")
  27     server.wait_for_open_port(2181)
  28
  29     server.wait_until_succeeds(
  30         "${pkgs.zookeeper}/bin/zkCli.sh -server localhost:2181 create /foo bar"
  31     )
  32     server.wait_until_succeeds(
  33         "${pkgs.zookeeper}/bin/zkCli.sh -server localhost:2181 set /foo hello"
  34     )
  35     server.wait_until_succeeds(
  36         "${pkgs.zookeeper}/bin/zkCli.sh -server localhost:2181 get /foo | grep hello"
  37     )
  38
  39     server.wait_until_succeeds(
  40         "${perlEnv}/bin/perl -E 'use Net::ZooKeeper qw(:acls); $z=Net::ZooKeeper->new(q(localhost:2181)); $z->create(qw(/perl foo acl), ZOO_OPEN_ACL_UNSAFE) || die $z->get_error()'"
  41     )
  42     server.wait_until_succeeds(
  43         "${perlEnv}/bin/perl -E 'use Net::ZooKeeper qw(:acls); $z=Net::ZooKeeper->new(q(localhost:2181)); $z->get(qw(/perl)) eq qw(foo) || die $z->get_error()'"
  44     )
  45   '';
  46 })