Return Ra counters from /metrics/per-object

Author: mkuratczyk

deps/rabbitmq_prometheus/src/collectors/prometheus_rabbitmq_raft_metrics_collector.erl

@@ -0,0 +1,46 @@
+%% This Source Code Form is subject to the terms of the Mozilla Public
+%% License, v. 2.0. If a copy of the MPL was not distributed with this
+%% file, You can obtain one at https://mozilla.org/MPL/2.0/.
+%%
+%% Copyright (c) 2007-2025 Broadcom. All Rights Reserved. The term “Broadcom” refers to Broadcom Inc. and/or its subsidiaries. All rights reserved.
+%%
+-module(prometheus_rabbitmq_raft_metrics_collector).
+
+-behaviour(prometheus_collector).
+-include_lib("prometheus/include/prometheus.hrl").
+
+-export([register/0,
+         deregister_cleanup/1,
+         collect_mf/2]).
+
+-import(prometheus_model_helpers, [create_mf/4,
+                                   counter_metric/2]).
+
+-define(METRIC_NAME_PREFIX, "rabbitmq_raft_").
+
+%%====================================================================
+%% Collector API
+%%====================================================================
+
+register() ->
+    ok = prometheus_registry:register_collector(?MODULE).
+
+deregister_cleanup(_) ->
+    ok.
+
+collect_mf(_Registry, Callback) ->
+    maps:foreach(
+      fun(Name, #{type := Type, help := Help, values := Values}) ->
+              Callback(
+                create_mf(?METRIC_NAME(Name),
+                          Help,
+                          Type,
+                          maps:to_list(Values)))
+      end,
+      seshat:format(ra, [term,
+			 snapshot_index,
+			 last_applied,
+			 commit_index,
+			 last_written_index,
+			 commit_latency,
+			 num_segments])).

deps/rabbitmq_prometheus/src/rabbit_prometheus_dispatcher.erl

@@ -29,6 +29,7 @@ build_dispatcher() ->
         prometheus_vm_msacc_collector,
         prometheus_rabbitmq_core_metrics_collector,
         prometheus_rabbitmq_global_metrics_collector,
+        prometheus_rabbitmq_raft_metrics_collector,
         prometheus_rabbitmq_message_size_metrics_collector
         ]),
     prometheus_registry:register_collectors('detailed', [