| 
									
										
										
										
											2017-11-02 13:59:10 -04:00
										 |  |  | import ./make-test.nix ({ pkgs, ...} : { | 
					
						
							|  |  |  |   name = "zookeeper"; | 
					
						
							|  |  |  |   meta = with pkgs.stdenv.lib.maintainers; { | 
					
						
							|  |  |  |     maintainers = [ nequissimus ]; | 
					
						
							|  |  |  |   }; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  |   nodes = { | 
					
						
							| 
									
										
										
										
											2018-07-20 20:56:59 +00:00
										 |  |  |     server = { ... }: { | 
					
						
							| 
									
										
										
										
											2017-11-02 13:59:10 -04:00
										 |  |  |       services.zookeeper = { | 
					
						
							|  |  |  |         enable = true; | 
					
						
							|  |  |  |       }; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  |       networking.firewall.allowedTCPPorts = [ 2181 ]; | 
					
						
							|  |  |  |     }; | 
					
						
							|  |  |  |   }; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  |   testScript = ''
 | 
					
						
							|  |  |  |     startAll; | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  |     $server->waitForUnit("zookeeper"); | 
					
						
							|  |  |  |     $server->waitForUnit("network.target"); | 
					
						
							|  |  |  |     $server->waitForOpenPort(2181); | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  |     $server->waitUntilSucceeds("${pkgs.zookeeper}/bin/zkCli.sh -server localhost:2181 create /foo bar"); | 
					
						
							|  |  |  |     $server->waitUntilSucceeds("${pkgs.zookeeper}/bin/zkCli.sh -server localhost:2181 set /foo hello"); | 
					
						
							|  |  |  |     $server->waitUntilSucceeds("${pkgs.zookeeper}/bin/zkCli.sh -server localhost:2181 get /foo | grep hello"); | 
					
						
							|  |  |  |   '';
 | 
					
						
							|  |  |  | }) |