in src/main/java/org/apache/rocketmq/exporter/collector/RMQMetricsCollector.java [483:495]
private void collectBrokerNums(List<MetricFamilySamples> mfs) {
GaugeMetricFamily brokerPutNumsGauge = new GaugeMetricFamily("rocketmq_broker_tps", "BrokerPutNums", BROKER_NUMS_LABEL_NAMES);
for (Map.Entry<BrokerMetric, Double> entry : brokerPutNums.asMap().entrySet()) {
loadBrokerNums(brokerPutNumsGauge, entry);
}
mfs.add(brokerPutNumsGauge);
GaugeMetricFamily brokerGetNumsGauge = new GaugeMetricFamily("rocketmq_broker_qps", "BrokerGetNums", BROKER_NUMS_LABEL_NAMES);
for (Map.Entry<BrokerMetric, Double> entry : brokerGetNums.asMap().entrySet()) {
loadBrokerNums(brokerGetNumsGauge, entry);
}
mfs.add(brokerGetNumsGauge);
}