Skip to content

Commit

Permalink
changed to rabbit_stream_consumer_created metric name, now works on b…
Browse files Browse the repository at this point in the history
…oth /metrics and /detailed
  • Loading branch information
markus812498 committed Dec 5, 2023
1 parent a95f18f commit 3c645e9
Showing 1 changed file with 4 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -302,6 +302,8 @@ mutually_exclusive_mf(false, auth_attempt_detailed_metrics, _) ->
%% `proplists:get_value/2` calls.
mutually_exclusive_mf(_, queue_consumer_count, MFs) ->
lists:keymember(queue_metrics, 1, MFs);
%%mutually_exclusive_mf(_, rabbit_stream_consumer, MFs) ->
%% lists:keymember(rabbit_stream_consumer_created, 1, MFs);
mutually_exclusive_mf(_, _, _) ->
false.

Expand Down Expand Up @@ -535,7 +537,8 @@ get_data(rabbit_stream_publisher_created = Table, false, _, _) ->
}
end, empty(Table), Table),
[{Table, [{published, A1}, {confirmed, A2}, {errored, A3}]}];

%%get_data(rabbit_stream_consumer, true, _, _) ->
%% ets:tab2list(rabbit_stream_consumer_created);
get_data(rabbit_stream_consumer_created = Table, false, _, _) ->
%% Table = rabbit_stream_consumer_created, %% real table name
{Table, A1, A2, A3} = ets:foldl(fun({_, Props}, {T, A1, A2, A3}) ->
Expand Down

0 comments on commit 3c645e9

Please sign in to comment.