RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-01-10 21:20:46 +00:00
Code Issues Packages Projects Releases Wiki Activity

mgr/prometheus: expose num objects repaired in pool

Browse Source 
Signed-off-by: Pere Diaz Bou <pdiazbou@redhat.com>
This commit is contained in:
Pere Diaz Bou 2022-08-08 12:51:16 +02:00
parent bd8b7aa4da
commit a84620552a
1 changed files with 17 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/pybind/mgr/prometheus/module.py
View File

@ -929,7 +929,8 @@ class Module(MgrModule):
for stat in DF_CLUSTER:
self.metrics['cluster_{}'.format(stat)].set(df['stats'][stat])
for device_class in df['stats_by_class']:
self.metrics['cluster_by_class_{}'.format(stat)].set(df['stats_by_class'][device_class][stat], (device_class,))
self.metrics['cluster_by_class_{}'.format(stat)].set(
df['stats_by_class'][device_class][stat], (device_class,))
for pool in df['pools']:
for stat in DF_POOL:
@ -1562,6 +1563,20 @@ class Module(MgrModule):
cast(MetricCounter, sum_metric).add(duration, (method_name,))
cast(MetricCounter, count_metric).add(1, (method_name,))
def get_pg_repaired_objects(self) -> None:
dump = self.get('pg_dump')
for stats in dump['pool_stats']:
path = f'pg_objects_repaired{stats["poolid"]}'
self.metrics[path] = Metric(
'counter',
'pg_objects_repaired',
'Number of objects repaired in a pool Count',
('poolid',)
)
self.metrics[path].set(stats['stat_sum']['num_objects_repaired'],
labelvalues=(stats['poolid'],))
@profile_method(True)
def collect(self) -> str:
# Clear the metrics before scraping
@ -1577,6 +1592,7 @@ class Module(MgrModule):
self.get_mgr_status()
self.get_metadata_and_osd_status()
self.get_pg_status()
self.get_pg_repaired_objects()
self.get_num_objects()
for daemon, counters in self.get_all_perf_counters().items():