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 (file)
index 0000000..691ef4d
--- /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 (file)
index 0000000..668feed
--- /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'])
+