root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions Packages Projects Releases Wiki Activity

Add activity status to consumer metrics 

[#163298456]

References rabbitmq/rabbitmq-server#1838
This commit is contained in:
Arnaud Cogoluègnes 2019-01-24 10:52:14 +01:00
parent 55843136d1
commit 1e9a95c3eb
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
deps/rabbitmq_management_agent/src/rabbit_mgmt_metrics_collector.erl vendored
View File

@ -403,7 +403,8 @@ aggregate_entry({Id, Reductions}, NextStats, Ops0,
Ops = insert_entry_ops(channel_process_stats, Id, false,
Entry, Ops0, BPolicies),
{NextStats, Ops, State};
aggregate_entry({Id, Exclusive, AckRequired, PrefetchCount, Active, Args},
aggregate_entry({Id, Exclusive, AckRequired, PrefetchCount,
Active, ActivityStatus, Args},
NextStats, Ops0,
#state{table = consumer_created} = State) ->
case ets:lookup(consumer_stats, Id) of
@ -412,6 +413,7 @@ aggregate_entry({Id, Exclusive, AckRequired, PrefetchCount, Active, Args},
{ack_required, AckRequired},
{prefetch_count, PrefetchCount},
{active, Active},
{activity_status, ActivityStatus},
{arguments, Args}], {[], false}),
Entry = ?consumer_stats(Id, Fmt),
Ops = insert_with_index_op(consumer_stats, Id, Entry, Ops0),
@ -424,6 +426,7 @@ aggregate_entry({Id, Exclusive, AckRequired, PrefetchCount, Active, Args},
{ack_required, AckRequired},
{prefetch_count, PrefetchCount},
{active, Active},
{activity_status, ActivityStatus},
{arguments, Args}], {[], false}),
Entry = ?consumer_stats(Id, Fmt),
Ops = insert_with_index_op(consumer_stats, Id, Entry, Ops0),