| 
									
										
										
										
											2019-11-06 07:54:37 +01:00
										 |  |  | import ./make-test-python.nix ({ pkgs, ...} : { | 
					
						
							| 
									
										
										
										
											2017-11-02 13:59:10 -04:00
										 |  |  |   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 = ''
 | 
					
						
							| 
									
										
										
										
											2019-11-06 07:54:37 +01:00
										 |  |  |     start_all() | 
					
						
							| 
									
										
										
										
											2017-11-02 13:59:10 -04:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2019-11-06 07:54:37 +01:00
										 |  |  |     server.wait_for_unit("zookeeper") | 
					
						
							|  |  |  |     server.wait_for_unit("network.target") | 
					
						
							|  |  |  |     server.wait_for_open_port(2181) | 
					
						
							| 
									
										
										
										
											2017-11-02 13:59:10 -04:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2019-11-06 07:54:37 +01:00
										 |  |  |     server.wait_until_succeeds( | 
					
						
							|  |  |  |         "${pkgs.zookeeper}/bin/zkCli.sh -server localhost:2181 create /foo bar" | 
					
						
							|  |  |  |     ) | 
					
						
							|  |  |  |     server.wait_until_succeeds( | 
					
						
							|  |  |  |         "${pkgs.zookeeper}/bin/zkCli.sh -server localhost:2181 set /foo hello" | 
					
						
							|  |  |  |     ) | 
					
						
							|  |  |  |     server.wait_until_succeeds( | 
					
						
							|  |  |  |         "${pkgs.zookeeper}/bin/zkCli.sh -server localhost:2181 get /foo | grep hello" | 
					
						
							|  |  |  |     ) | 
					
						
							| 
									
										
										
										
											2017-11-02 13:59:10 -04:00
										 |  |  |   '';
 | 
					
						
							|  |  |  | }) |