diff options
| author | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2019-01-24 10:52:14 +0100 |
|---|---|---|
| committer | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2019-01-24 10:52:14 +0100 |
| commit | 1e9a95c3eb65d58b2d4ce291025804ddea61e1a8 (patch) | |
| tree | 5c557a7db88e76c8da166fd6ab31ab79ef1b69b3 /deps/rabbitmq_management_agent | |
| parent | 55843136d1bfa185b5ea1096610fbe600273225a (diff) | |
| download | rabbitmq-server-git-1e9a95c3eb65d58b2d4ce291025804ddea61e1a8.tar.gz | |
Add activity status to consumer metrics
[#163298456]
References rabbitmq/rabbitmq-server#1838
Diffstat (limited to 'deps/rabbitmq_management_agent')
| -rw-r--r-- | deps/rabbitmq_management_agent/src/rabbit_mgmt_metrics_collector.erl | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/deps/rabbitmq_management_agent/src/rabbit_mgmt_metrics_collector.erl b/deps/rabbitmq_management_agent/src/rabbit_mgmt_metrics_collector.erl index ecf68351de..372434a5b7 100644 --- a/deps/rabbitmq_management_agent/src/rabbit_mgmt_metrics_collector.erl +++ b/deps/rabbitmq_management_agent/src/rabbit_mgmt_metrics_collector.erl @@ -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), |