--- /dev/null
+
+class TestMons(object):
+
+ def test_mon_listens_on_6789(self, CephNode, Socket):
+ assert Socket("tcp://%s:6789" % CephNode["address"]).is_listening
+
+ def test_mon_service_is_running(self, CephNode, Service):
+ service_name = "ceph-mon@ceph-%s" % CephNode["vars"]["inventory_hostname"]
+ assert Service(service_name).is_running
+
+ def test_mon_service_is_enabled(self, CephNode, Service):
+ service_name = "ceph-mon@ceph-%s" % CephNode["vars"]["inventory_hostname"]
+ assert Service(service_name).is_enabled
+
+ def test_can_get_cluster_health(self, CephNode, Command):
+ output = Command.check_output("sudo ceph -s")
+ assert output.strip().startswith("cluster")