in src/main/java/org/apache/rocketmq/exporter/collector/RMQMetricsCollector.java [944:1041]
private void addAllKindOfTps(String clusterName, String brokerAddress, String brokerHost, BrokerRuntimeStats stats) {
brokerRuntimePutTps10.put(new BrokerRuntimeMetric(
clusterName,
brokerAddress, brokerHost,
stats.getBrokerVersionDesc(),
stats.getBootTimestamp(),
stats.getBrokerVersion()), stats.getPutTps().getTen());
brokerRuntimePutTps60.put(new BrokerRuntimeMetric(
clusterName,
brokerAddress, brokerHost,
stats.getBrokerVersionDesc(),
stats.getBootTimestamp(),
stats.getBrokerVersion()), stats.getPutTps().getSixty());
brokerRuntimePutTps600.put(new BrokerRuntimeMetric(
clusterName,
brokerAddress, brokerHost,
stats.getBrokerVersionDesc(),
stats.getBootTimestamp(),
stats.getBrokerVersion()), stats.getPutTps().getSixHundred());
brokerRuntimeGetMissTps10.put(new BrokerRuntimeMetric(
clusterName,
brokerAddress, brokerHost,
stats.getBrokerVersionDesc(),
stats.getBootTimestamp(),
stats.getBrokerVersion()), stats.getGetMissTps().getTen());
brokerRuntimeGetMissTps60.put(new BrokerRuntimeMetric(
clusterName,
brokerAddress, brokerHost,
stats.getBrokerVersionDesc(),
stats.getBootTimestamp(),
stats.getBrokerVersion()), stats.getGetMissTps().getSixty());
brokerRuntimeGetMissTps600.put(new BrokerRuntimeMetric(
clusterName,
brokerAddress, brokerHost,
stats.getBrokerVersionDesc(),
stats.getBootTimestamp(),
stats.getBrokerVersion()), stats.getGetMissTps().getSixHundred());
brokerRuntimeGetTransferedTps10.put(new BrokerRuntimeMetric(
clusterName,
brokerAddress, brokerHost,
stats.getBrokerVersionDesc(),
stats.getBootTimestamp(),
stats.getBrokerVersion()), stats.getGetTransferedTps().getTen());
brokerRuntimeGetTransferedTps60.put(new BrokerRuntimeMetric(
clusterName,
brokerAddress, brokerHost,
stats.getBrokerVersionDesc(),
stats.getBootTimestamp(),
stats.getBrokerVersion()), stats.getGetTransferedTps().getSixty());
brokerRuntimeGetTransferedTps600.put(new BrokerRuntimeMetric(
clusterName,
brokerAddress, brokerHost,
stats.getBrokerVersionDesc(),
stats.getBootTimestamp(),
stats.getBrokerVersion()), stats.getGetTransferedTps().getSixHundred());
brokerRuntimeGetTotalTps10.put(new BrokerRuntimeMetric(
clusterName,
brokerAddress, brokerHost,
stats.getBrokerVersionDesc(),
stats.getBootTimestamp(),
stats.getBrokerVersion()), stats.getGetTotalTps().getTen());
brokerRuntimeGetTotalTps60.put(new BrokerRuntimeMetric(
clusterName,
brokerAddress, brokerHost,
stats.getBrokerVersionDesc(),
stats.getBootTimestamp(),
stats.getBrokerVersion()), stats.getGetTotalTps().getSixty());
brokerRuntimeGetTotalTps600.put(new BrokerRuntimeMetric(
clusterName,
brokerAddress, brokerHost,
stats.getBrokerVersionDesc(),
stats.getBootTimestamp(),
stats.getBrokerVersion()), stats.getGetTotalTps().getSixHundred());
brokerRuntimeGetFoundTps10.put(new BrokerRuntimeMetric(
clusterName,
brokerAddress, brokerHost,
stats.getBrokerVersionDesc(),
stats.getBootTimestamp(),
stats.getBrokerVersion()), stats.getGetFoundTps().getTen());
brokerRuntimeGetFoundTps60.put(new BrokerRuntimeMetric(
clusterName,
brokerAddress, brokerHost,
stats.getBrokerVersionDesc(),
stats.getBootTimestamp(),
stats.getBrokerVersion()), stats.getGetFoundTps().getSixty());
brokerRuntimeGetFoundTps600.put(new BrokerRuntimeMetric(
clusterName,
brokerAddress, brokerHost,
stats.getBrokerVersionDesc(),
stats.getBootTimestamp(),
stats.getBrokerVersion()), stats.getGetFoundTps().getSixHundred());
brokerRuntimeGetFoundTps600.put(new BrokerRuntimeMetric(
clusterName,
brokerAddress, brokerHost,
stats.getBrokerVersionDesc(),
stats.getBootTimestamp(),
stats.getBrokerVersion()), stats.getGetFoundTps().getSixHundred());
}