update source to Ceph Pacific 16.2.2

[ceph.git] / ceph / src / pybind / mgr / diskprediction_cloud / agent / metrics / ceph_pool.py

diff --git a/ceph/src/pybind/mgr/diskprediction_cloud/agent/metrics/ceph_pool.py b/ceph/src/pybind/mgr/diskprediction_cloud/agent/metrics/ceph_pool.py
deleted file mode 100644 (file)
index e8b3956..0000000
--- a/ceph/src/pybind/mgr/diskprediction_cloud/agent/metrics/ceph_pool.py
+++ /dev/null
@@ -1,57 +0,0 @@
-from __future__ import absolute_import\r
-\r
-import socket\r
-\r
-from . import MetricsAgent, MetricsField\r
-from ...common.clusterdata import ClusterAPI\r
-\r
-\r
-class CephPool(MetricsField):\r
-    """ Ceph pool structure """\r
-    measurement = 'ceph_pool'\r
-\r
-    def __init__(self):\r
-        super(CephPool, self).__init__()\r
-        self.tags['cluster_id'] = None\r
-        self.tags['pool_id'] = None\r
-        self.fields['agenthost'] = None\r
-        self.tags['agenthost_domain_id'] = None\r
-        self.fields['bytes_used'] = None\r
-        self.fields['max_avail'] = None\r
-        self.fields['objects'] = None\r
-        self.fields['wr_bytes'] = None\r
-        self.fields['dirty'] = None\r
-        self.fields['rd_bytes'] = None\r
-        self.fields['stored_raw'] = None\r
-\r
-\r
-class CephPoolAgent(MetricsAgent):\r
-    measurement = 'ceph_pool'\r
-\r
-    def _collect_data(self):\r
-        # process data and save to 'self.data'\r
-        obj_api = ClusterAPI(self._module_inst)\r
-        df_data = obj_api.module.get('df')\r
-        cluster_id = obj_api.get_cluster_id()\r
-        for pool in df_data.get('pools', []):\r
-            d_pool = CephPool()\r
-            p_id = pool.get('id')\r
-            d_pool.tags['cluster_id'] = cluster_id\r
-            d_pool.tags['pool_id'] = p_id\r
-            d_pool.fields['agenthost'] = socket.gethostname()\r
-            d_pool.tags['agenthost_domain_id'] = cluster_id\r
-            d_pool.fields['bytes_used'] = \\r
-                pool.get('stats', {}).get('bytes_used', 0)\r
-            d_pool.fields['max_avail'] = \\r
-                pool.get('stats', {}).get('max_avail', 0)\r
-            d_pool.fields['objects'] = \\r
-                pool.get('stats', {}).get('objects', 0)\r
-            d_pool.fields['wr_bytes'] = \\r
-                pool.get('stats', {}).get('wr_bytes', 0)\r
-            d_pool.fields['dirty'] = \\r
-                pool.get('stats', {}).get('dirty', 0)\r
-            d_pool.fields['rd_bytes'] = \\r
-                pool.get('stats', {}).get('rd_bytes', 0)\r
-            d_pool.fields['stored_raw'] = \\r
-                pool.get('stats', {}).get('stored_raw', 0)\r
-            self.data.append(d_pool)\r