Skip to content

Commit 63b5859

Browse files
committed
RMQ-1263: readd lost shovel_prometheus parts
1 parent c2569d2 commit 63b5859

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

deps/rabbitmq_shovel_prometheus/src/rabbit_shovel_prometheus_collector.erl

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -29,9 +29,9 @@ deregister_cleanup(_) -> ok.
2929

3030
collect_mf(_Registry, Callback) ->
3131
Status = rabbit_shovel_status:status(500),
32-
{StaticStatusGroups, DynamicStatusGroups} = lists:foldl(fun({_,static,{S, _}, _}, {SMap, DMap}) ->
32+
{StaticStatusGroups, DynamicStatusGroups} = lists:foldl(fun({_,static,{S, _}, _, _}, {SMap, DMap}) ->
3333
{maps:update_with(S, fun(C) -> C + 1 end, 1, SMap), DMap};
34-
({_,dynamic,{S, _}, _}, {SMap, DMap}) ->
34+
({_,dynamic,{S, _}, _, _}, {SMap, DMap}) ->
3535
{SMap, maps:update_with(S, fun(C) -> C + 1 end, 1, DMap)}
3636
end, {#{}, #{}}, Status),
3737

deps/rabbitmq_shovel_prometheus/test/prometheus_rabbitmq_shovel_collector_SUITE.erl

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -226,10 +226,10 @@ await_shovel(Name, Type) ->
226226

227227
shovels_from_status(ExpectedState, dynamic) ->
228228
S = rabbit_shovel_status:status(),
229-
[N || {{<<"/">>, N}, dynamic, {State, _}, _} <- S, State == ExpectedState];
229+
[N || {{<<"/">>, N}, dynamic, {State, _}, _, _} <- S, State == ExpectedState];
230230
shovels_from_status(ExpectedState, static) ->
231231
S = rabbit_shovel_status:status(),
232-
[N || {N, static, {State, _}, _} <- S, State == ExpectedState].
232+
[N || {N, static, {State, _}, _, _} <- S, State == ExpectedState].
233233

234234
get_shovel_status(Config, Name) ->
235235
get_shovel_status(Config, 0, Name).

0 commit comments

Comments
 (0)