diff options
| author | dcorbacho <dparracorbacho@piotal.io> | 2021-01-25 16:30:28 +0100 |
|---|---|---|
| committer | dcorbacho <dparracorbacho@piotal.io> | 2021-01-25 16:30:28 +0100 |
| commit | d100f40927e7895557e55c7520867e664e0c7d6d (patch) | |
| tree | 1d8d16592e5338dbf6eac052c1dcef33b1adf320 | |
| parent | b5315c0166d95c75cb856d353e76d4d7b3a00377 (diff) | |
| download | rabbitmq-server-git-rabbitmq-stream-prometheus.tar.gz | |
Filter out gauges from per-object metricsrabbitmq-stream-prometheus
| -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}) -> |