mon: Add 'ceph df' pool stats

Signed-off-by: Zack Cerza <zack@redhat.com>

diff --git a/collectors/mon.py b/collectors/mon.py
index 4dd2f3871a657b03b4b3bb531c892bfba269a542..d6052a86f5d195e2b9de1469d924286995ada9ec 100644 (file)
--- a/collectors/mon.py
+++ b/collectors/mon.py
@@ -429,6 +429,11 @@ class Mon(BaseCollector):
         return {metric_format[k][0]: metrics[k]
                 for k in metrics} if metrics else {}
 
+    def _get_df_stats(self):
+        """ get 'ceph df' stats from rados """
+        raw_stats = self._mon_command('df')
+        return raw_stats
+
     def _get_pool_stats(self):
         """ get pool stats from rados """
 
@@ -589,6 +594,11 @@ class Mon(BaseCollector):
             # read from the admin socket was OK, so process the data
             cluster_state = self.get_mon_health(cluster_data)
             pool_stats = self._get_pool_stats()
+            df_stats = self._get_df_stats()
+            for df_obj in df_stats['pools']:
+                pool_name = df_obj['name']
+                pool_stats[pool_name] = merge_dicts(
+                    pool_stats[pool_name], df_obj['stats'])
             num_osd_hosts, osd_states = self._get_osd_states()
 
             cluster_state['num_osd_hosts'] = num_osd_hosts