service_map = self.get('service_map')
fs_map = self.get('fs_map')
df = self.get('df')
+ df_pools = {pool['id']: pool for pool in df['pools']}
report['created'] = mon_map['created']
# Only include default applications
if application in ['cephfs', 'mgr', 'rbd', 'rgw']:
pool_data['application'].append(application)
+ pool_stats = df_pools[pool['pool']]['stats']
+ pool_data['stats'] = { # filter out kb_used
+ 'avail_raw': pool_stats['avail_raw'],
+ 'bytes_used': pool_stats['bytes_used'],
+ 'compress_bytes_used': pool_stats['compress_bytes_used'],
+ 'compress_under_bytes': pool_stats['compress_under_bytes'],
+ 'data_bytes_used': pool_stats['data_bytes_used'],
+ 'dirty': pool_stats['dirty'],
+ 'max_avail': pool_stats['max_avail'],
+ 'objects': pool_stats['objects'],
+ 'omap_bytes_used': pool_stats['omap_bytes_used'],
+ 'percent_used': pool_stats['percent_used'],
+ 'quota_bytes': pool_stats['quota_bytes'],
+ 'quota_objects': pool_stats['quota_objects'],
+ 'rd': pool_stats['rd'],
+ 'rd_bytes': pool_stats['rd_bytes'],
+ 'stored': pool_stats['stored'],
+ 'stored_data': pool_stats['stored_data'],
+ 'stored_omap': pool_stats['stored_omap'],
+ 'stored_raw': pool_stats['stored_raw'],
+ 'wr': pool_stats['wr'],
+ 'wr_bytes': pool_stats['wr_bytes']
+ }
+
cast(List[Dict[str, Any]], report['pools']).append(pool_data)
if 'rbd' in pool['application_metadata']:
rbd_num_pools += 1