private void addAllKindOfTps()

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());
    }