diff options
| author | Jean-Sébastien Pédron <jean-sebastien@rabbitmq.com> | 2019-02-04 17:22:24 +0100 |
|---|---|---|
| committer | Jean-Sébastien Pédron <jean-sebastien@rabbitmq.com> | 2019-02-04 17:22:24 +0100 |
| commit | 2201f35425218dec5751cd32506ff519b1e7dcea (patch) | |
| tree | 2fa1fd0a5b548d46bed51c09ee7ad9fd5dee396e /deps/rabbitmq_management_agent | |
| parent | c66c9e80f4e43c8c0db14ad3f666fafffcb463dd (diff) | |
| download | rabbitmq-server-git-2201f35425218dec5751cd32506ff519b1e7dcea.tar.gz | |
rabbit_mgmt_data_compat: New `fill_consumer_active_fields()` function
... to add the new `active` and `activity_status` fields in consumer
stats if they are missing.
This is the case for consumer stats returned by a RabbitMQ 3.7.x node.
[#163298456]
Diffstat (limited to 'deps/rabbitmq_management_agent')
| -rw-r--r-- | deps/rabbitmq_management_agent/src/rabbit_mgmt_data_compat.erl | 14 |
1 files changed, 13 insertions, 1 deletions
diff --git a/deps/rabbitmq_management_agent/src/rabbit_mgmt_data_compat.erl b/deps/rabbitmq_management_agent/src/rabbit_mgmt_data_compat.erl index 9d48e1f336..ad610a5786 100644 --- a/deps/rabbitmq_management_agent/src/rabbit_mgmt_data_compat.erl +++ b/deps/rabbitmq_management_agent/src/rabbit_mgmt_data_compat.erl @@ -17,7 +17,8 @@ -module(rabbit_mgmt_data_compat). -export([fill_get_empty_queue_metric/1, - drop_get_empty_queue_metric/1]). + drop_get_empty_queue_metric/1, + fill_consumer_active_fields/1]). fill_get_empty_queue_metric(Slide) -> exometer_slide:map( @@ -47,3 +48,14 @@ drop_get_empty_queue_metric(Slide) -> (Value) -> Value end, Slide). + +fill_consumer_active_fields(ConsumersStats) -> + [case proplists:get_value(active, ConsumerStats) of + undefined -> + [{active, true}, + {activity_status, up} + | ConsumerStats]; + _ -> + ConsumerStats + end + || ConsumerStats <- ConsumersStats]. |