1 files changed, 134 insertions, 0 deletions
diff --git a/src/pybind/mgr/dashboard/controllers/monitor.py b/src/pybind/mgr/dashboard/controllers/monitor.py
new file mode 100644
index 000000000..c880859d2
--- /dev/null
+++ b/src/pybind/mgr/dashboard/controllers/monitor.py
@@ -0,0 +1,134 @@
+# -*- coding: utf-8 -*-
+from __future__ import absolute_import
+
+import json
+
+from .. import mgr
+from ..security import Scope
+from . import APIDoc, APIRouter, BaseController, Endpoint, EndpointDoc, ReadPermission
+
+MONITOR_SCHEMA = {
+    "mon_status": ({
+        "name": (str, ""),
+        "rank": (int, ""),
+        "state": (str, ""),
+        "election_epoch": (int, ""),
+        "quorum": ([int], ""),
+        "quorum_age": (int, ""),
+        "features": ({
+            "required_con": (str, ""),
+            "required_mon": ([int], ""),
+            "quorum_con": (str, ""),
+            "quorum_mon": ([str], "")
+        }, ""),
+        "outside_quorum": ([str], ""),
+        "extra_probe_peers": ([str], ""),
+        "sync_provider": ([str], ""),
+        "monmap": ({
+            "epoch": (int, ""),
+            "fsid": (str, ""),
+            "modified": (str, ""),
+            "created": (str, ""),
+            "min_mon_release": (int, ""),
+            "min_mon_release_name": (str, ""),
+            "features": ({
+                "persistent": ([str], ""),
+                "optional": ([str], "")
+            }, ""),
+            "mons": ([{
+                "rank": (int, ""),
+                "name": (str, ""),
+                "public_addrs": ({
+                    "addrvec": ([{
+                        "type": (str, ""),
+                        "addr": (str, ""),
+                        "nonce": (int, "")
+                    }], "")
+                }, ""),
+                "addr": (str, ""),
+                "public_addr": (str, ""),
+                "priority": (int, ""),
+                "weight": (int, ""),
+                "stats": ({
+                    "num_sessions": ([int], ""),
+                }, "")
+            }], "")
+        }, ""),
+        "feature_map": ({
+            "mon": ([{
+                "features": (str, ""),
+                "release": (str, ""),
+                "num": (int, "")
+            }], ""),
+            "mds": ([{
+                "features": (str, ""),
+                "release": (str, ""),
+                "num": (int, "")
+            }], ""),
+            "client": ([{
+                "features": (str, ""),
+                "release": (str, ""),
+                "num": (int, "")
+            }], ""),
+            "mgr": ([{
+                "features": (str, ""),
+                "release": (str, ""),
+                "num": (int, "")
+            }], ""),
+        }, "")
+    }, ""),
+    "in_quorum": ([{
+        "rank": (int, ""),
+        "name": (str, ""),
+        "public_addrs": ({
+            "addrvec": ([{
+                "type": (str, ""),
+                "addr": (str, ""),
+                "nonce": (int, "")
+            }], "")
+        }, ""),
+        "addr": (str, ""),
+        "public_addr": (str, ""),
+        "priority": (int, ""),
+        "weight": (int, ""),
+        "stats": ({
+            "num_sessions": ([int], "")
+        }, "")
+    }], ""),
+    "out_quorum": ([int], "")
+}
+
+
+@APIRouter('/monitor', Scope.MONITOR)
+@APIDoc("Get Monitor Details", "Monitor")
+class Monitor(BaseController):
+    @Endpoint()
+    @ReadPermission
+    @EndpointDoc("Get Monitor Details",
+                 responses={200: MONITOR_SCHEMA})
+    def __call__(self):
+        in_quorum, out_quorum = [], []
+
+        counters = ['mon.num_sessions']
+
+        mon_status_json = mgr.get("mon_status")
+        mon_status = json.loads(mon_status_json['json'])
+
+        for mon in mon_status["monmap"]["mons"]:
+            mon["stats"] = {}
+            for counter in counters:
+                data = mgr.get_counter("mon", mon["name"], counter)
+                if data is not None:
+                    mon["stats"][counter.split(".")[1]] = data[counter]
+                else:
+                    mon["stats"][counter.split(".")[1]] = []
+            if mon["rank"] in mon_status["quorum"]:
+                in_quorum.append(mon)
+            else:
+                out_quorum.append(mon)
+
+        return {
+            'mon_status': mon_status,
+            'in_quorum': in_quorum,
+            'out_quorum': out_quorum
+        }