diff options
| -rw-r--r-- | deps/rabbitmq_stream_prometheus/src/collectors/prometheus_rabbitmq_stream_collector.erl | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/deps/rabbitmq_stream_prometheus/src/collectors/prometheus_rabbitmq_stream_collector.erl b/deps/rabbitmq_stream_prometheus/src/collectors/prometheus_rabbitmq_stream_collector.erl index 667bd0cdfb..2e71ccd04c 100644 --- a/deps/rabbitmq_stream_prometheus/src/collectors/prometheus_rabbitmq_stream_collector.erl +++ b/deps/rabbitmq_stream_prometheus/src/collectors/prometheus_rabbitmq_stream_collector.erl @@ -70,11 +70,17 @@ collect_mf(_Registry, Callback) -> collect(PerObjectMetrics, Callback) -> [begin Data = get_data(Table, PerObjectMetrics), - mf(Callback, Contents, Data) + mf(Callback, filter_contents(Contents, PerObjectMetrics), Data) end || {Table, Contents} <- ?METRICS_RAW], ok. +filter_contents(Contents, false) -> + Contents; +filter_contents(Contents, true) -> + [E || {_, _, Type, _, _} = E <- Contents, + Type == counter]. + get_data(?TABLE_PUBLISHER = Table, false) -> {Table, A1, A2, A3, A4} = ets:foldl(fun({_, Props}, {T, A1, A2, A3, A4}) -> |