3f2dd0e681
Zookeeper supports a number of "4 letter" commands [0] which are useful for debugging and general diagnostics. By default only srvr is enabled, but we want to add stat and dump to see details on server and client connection statuses. We do this via the 4lw.commands.whitelist configuration option [1] and not the docker image env vars because we're mounting a zoo.cfg in already. [0] https://zookeeper.apache.org/doc/current/zookeeperAdmin.html#sc_4lw [1] https://zookeeper.apache.org/doc/current/zookeeperAdmin.html#sc_clusterOptions Change-Id: I24ea9b37cd5766c9d393106e8eab34623cad1624
44 lines
1.5 KiB
Python
44 lines
1.5 KiB
Python
# Copyright 2020 Red Hat, Inc.
|
|
#
|
|
# Licensed under the Apache License, Version 2.0 (the "License"); you may
|
|
# not use this file except in compliance with the License. You may obtain
|
|
# a copy of the License at
|
|
#
|
|
# http://www.apache.org/licenses/LICENSE-2.0
|
|
#
|
|
# Unless required by applicable law or agreed to in writing, software
|
|
# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
|
# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
|
# License for the specific language governing permissions and limitations
|
|
# under the License.
|
|
|
|
|
|
testinfra_hosts = ['zk01.opendev.org']
|
|
|
|
|
|
def test_id_file(host):
|
|
# Test that wacky hostname regex works
|
|
myid = host.file('/var/zookeeper/data/myid')
|
|
assert myid.content == b'1\n'
|
|
|
|
def test_zk_listening(host):
|
|
zk = host.socket("tcp://0.0.0.0:2181")
|
|
assert zk.is_listening
|
|
|
|
def test_zk_listening_ssl(host):
|
|
zk = host.socket("tcp://0.0.0.0:2281")
|
|
assert zk.is_listening
|
|
|
|
def test_l4_commands(host):
|
|
cmd = host.run("echo srvr | nc localhost 2181")
|
|
assert "Zookeeper version" in cmd.stdout
|
|
assert "not executed because it is not in the whitelist" not in cmd.stdout
|
|
|
|
cmd = host.run("echo stat | nc localhost 2181")
|
|
assert "Zookeeper version" in cmd.stdout
|
|
assert "not executed because it is not in the whitelist" not in cmd.stdout
|
|
|
|
cmd = host.run("echo dump | nc localhost 2181")
|
|
assert "SessionTracker dump" in cmd.stdout
|
|
assert "not executed because it is not in the whitelist" not in cmd.stdout
|