1313
1414build_dispatcher () ->
1515 {ok , _ } = application :ensure_all_started (prometheus ),
16- prometheus_registry : register_collectors ( [
16+ AggregatedCollectors = [
1717 prometheus_rabbitmq_core_metrics_collector ,
1818 prometheus_rabbitmq_global_metrics_collector ,
1919 prometheus_rabbitmq_message_size_metrics_collector ,
2020 prometheus_rabbitmq_alarm_metrics_collector ,
2121 prometheus_rabbitmq_dynamic_collector ,
22- prometheus_process_collector ]) ,
23- prometheus_registry : register_collectors ( 'per-object' , [
22+ prometheus_process_collector ],
23+ PerObjectCollectors = [
2424 prometheus_vm_system_info_collector ,
2525 prometheus_vm_dist_collector ,
2626 prometheus_vm_memory_collector ,
@@ -31,7 +31,14 @@ build_dispatcher() ->
3131 prometheus_rabbitmq_global_metrics_collector ,
3232 prometheus_rabbitmq_raft_metrics_collector ,
3333 prometheus_rabbitmq_message_size_metrics_collector
34- ]),
34+ ],
35+ prometheus_registry :register_collectors (
36+ case application :get_env (rabbitmq_prometheus , return_per_object_metrics , false ) of
37+ false -> AggregatedCollectors ;
38+ true -> PerObjectCollectors
39+ end ),
40+ prometheus_registry :register_collectors ('per-object' ,
41+ PerObjectCollectors ),
3542 prometheus_registry :register_collectors ('detailed' , [
3643 prometheus_rabbitmq_core_metrics_collector
3744 ]),
0 commit comments