From: Mykola Golub <mgolub@suse.com>
Date: Wed, 3 Oct 2018 12:25:27 +0000 (+0300)
Subject: mgr: module to test osd_perf_query methods
X-Git-Tag: v14.0.1~123^2
X-Git-Url: http://git.apps.os.sepia.ceph.com/?a=commitdiff_plain;h=264ad39ff66907909d174f2f4a401c2998b3755b;p=ceph.git

mgr: module to test osd_perf_query methods

Signed-off-by: Mykola Golub <mgolub@suse.com>
---

diff --git a/src/pybind/mgr/osd_perf_query/__init__.py b/src/pybind/mgr/osd_perf_query/__init__.py
new file mode 100644
index 0000000000000..691ef4dd8b6ed
--- /dev/null
+++ b/src/pybind/mgr/osd_perf_query/__init__.py
@@ -0,0 +1 @@
+from .module import OSDPerfQuery
diff --git a/src/pybind/mgr/osd_perf_query/module.py b/src/pybind/mgr/osd_perf_query/module.py
new file mode 100644
index 0000000000000..668feed619c80
--- /dev/null
+++ b/src/pybind/mgr/osd_perf_query/module.py
@@ -0,0 +1,34 @@
+
+"""
+osd_perf_query module
+"""
+
+from mgr_module import MgrModule
+
+
+class OSDPerfQuery(MgrModule):
+    COMMANDS = [
+        {
+            "cmd": "osd perf query add "
+                   "name=query,type=CephString,req=true",
+            "desc": "add osd perf query",
+            "perm": "w"
+        },
+        {
+            "cmd": "osd perf query remove "
+                   "name=query_id,type=CephInt,req=true",
+            "desc": "remove osd perf query",
+            "perm": "w"
+        },
+    ]
+
+    def handle_command(self, inbuf, cmd):
+        if cmd['prefix'] == "osd perf query add":
+            query_id = self.add_osd_perf_query(cmd['query'])
+            return 0, str(query_id), "added query " + cmd['query'] + " with id " + str(query_id)
+        elif cmd['prefix'] == "osd perf query remove":
+            self.remove_osd_perf_query(cmd['query_id'])
+            return 0, "", "removed query with id " + str(cmd['query_id'])
+        else:
+            raise NotImplementedError(cmd['prefix'])
+