public void addBrokerRuntimeStatsMetric()

in src/main/java/org/apache/rocketmq/exporter/collector/RMQMetricsCollector.java [761:942]
174 lines of code
1 McCabe index (conditional complexity)

    public void addBrokerRuntimeStatsMetric(BrokerRuntimeStats stats, String clusterName, String brokerAddress, String brokerHost) {
        addBrokerRuntimePutMessageDistributeTimeMap(
            clusterName, brokerAddress, brokerHost,
            stats.getBrokerVersionDesc(),
            stats.getBootTimestamp(),
            stats.getBrokerVersion(), stats);
        addCommitLogDirCapacity(clusterName, brokerAddress, brokerHost, stats);
        addAllKindOfTps(clusterName, brokerAddress, brokerHost, stats);

        brokerRuntimePutLatency99.put(new BrokerRuntimeMetric(
                clusterName, brokerAddress, brokerHost,
                stats.getBrokerVersionDesc(),
                stats.getBootTimestamp(),
                stats.getBrokerVersion()), stats.getPutLatency99());

        brokerRuntimePutLatency999.put(new BrokerRuntimeMetric(
                clusterName, brokerAddress, brokerHost,
                stats.getBrokerVersionDesc(),
                stats.getBootTimestamp(),
                stats.getBrokerVersion()), stats.getPutLatency999());

        brokerRuntimeMsgPutTotalTodayNow.put(new BrokerRuntimeMetric(
            clusterName, brokerAddress, brokerHost,
            stats.getBrokerVersionDesc(),
            stats.getBootTimestamp(),
            stats.getBrokerVersion()), stats.getMsgPutTotalTodayNow());

        brokerRuntimeMsgGetTotalTodayNow.put(new BrokerRuntimeMetric(
            clusterName, brokerAddress, brokerHost,
            stats.getBrokerVersionDesc(),
            stats.getBootTimestamp(),
            stats.getBrokerVersion()), stats.getMsgGetTotalTodayNow());

        brokerRuntimeMsgPutTotalTodayMorning.put(new BrokerRuntimeMetric(
            clusterName, brokerAddress, brokerHost,
            stats.getBrokerVersionDesc(),
            stats.getBootTimestamp(),
            stats.getBrokerVersion()), stats.getMsgPutTotalTodayMorning());
        brokerRuntimeMsgGetTotalTodayMorning.put(new BrokerRuntimeMetric(
            clusterName, brokerAddress, brokerHost,
            stats.getBrokerVersionDesc(),
            stats.getBootTimestamp(),
            stats.getBrokerVersion()), stats.getMsgGetTotalTodayMorning());
        brokerRuntimeMsgPutTotalYesterdayMorning.put(new BrokerRuntimeMetric(
            clusterName, brokerAddress, brokerHost,
            stats.getBrokerVersionDesc(),
            stats.getBootTimestamp(),
            stats.getBrokerVersion()), stats.getMsgPutTotalYesterdayMorning());
        brokerRuntimeMsgGetTotalYesterdayMorning.put(new BrokerRuntimeMetric(
            clusterName, brokerAddress, brokerHost,
            stats.getBrokerVersionDesc(),
            stats.getBootTimestamp(),
            stats.getBrokerVersion()), stats.getMsgGetTotalYesterdayMorning());
        brokerRuntimeSendThreadPoolQueueHeadWaitTimeMills.put(new BrokerRuntimeMetric(
            clusterName, brokerAddress, brokerHost,
            stats.getBrokerVersionDesc(),
            stats.getBootTimestamp(),
            stats.getBrokerVersion()), stats.getSendThreadPoolQueueHeadWaitTimeMills());
        brokerRuntimeQueryThreadPoolQueueHeadWaitTimeMills.put(new BrokerRuntimeMetric(
            clusterName, brokerAddress, brokerHost,
            stats.getBrokerVersionDesc(),
            stats.getBootTimestamp(),
            stats.getBrokerVersion()), stats.getQueryThreadPoolQueueHeadWaitTimeMills());
        brokerRuntimePullThreadPoolQueueHeadWaitTimeMills.put(new BrokerRuntimeMetric(
            clusterName, brokerAddress, brokerHost,
            stats.getBrokerVersionDesc(),
            stats.getBootTimestamp(),
            stats.getBrokerVersion()), stats.getPullThreadPoolQueueHeadWaitTimeMills());
        brokerRuntimeQueryThreadPoolQueueSize.put(new BrokerRuntimeMetric(
            clusterName, brokerAddress, brokerHost,
            stats.getBrokerVersionDesc(),
            stats.getBootTimestamp(),
            stats.getBrokerVersion()), stats.getQueryThreadPoolQueueSize());
        brokerRuntimePullThreadPoolQueueSize.put(new BrokerRuntimeMetric(
            clusterName, brokerAddress, brokerHost,
            stats.getBrokerVersionDesc(),
            stats.getBootTimestamp(),
            stats.getBrokerVersion()), stats.getPullThreadPoolQueueSize());
        brokerRuntimeSendThreadPoolQueueCapacity.put(new BrokerRuntimeMetric(
            clusterName, brokerAddress, brokerHost,
            stats.getBrokerVersionDesc(),
            stats.getBootTimestamp(),
            stats.getBrokerVersion()), stats.getSendThreadPoolQueueCapacity());
        brokerRuntimePullThreadPoolQueueCapacity.put(new BrokerRuntimeMetric(
            clusterName, brokerAddress, brokerHost,
            stats.getBrokerVersionDesc(),
            stats.getBootTimestamp(),
            stats.getBrokerVersion()), stats.getPullThreadPoolQueueCapacity());

        brokerRuntimeRemainHowManyDataToFlush.put(new BrokerRuntimeMetric(
            clusterName, brokerAddress, brokerHost,
            stats.getBrokerVersionDesc(),
            stats.getBootTimestamp(),
            stats.getBrokerVersion()), stats.getRemainHowManyDataToFlush());
        brokerRuntimeCommitLogMinOffset.put(new BrokerRuntimeMetric(
            clusterName, brokerAddress, brokerHost,
            stats.getBrokerVersionDesc(),
            stats.getBootTimestamp(),
            stats.getBrokerVersion()), stats.getCommitLogMinOffset());
        brokerRuntimeCommitLogMaxOffset.put(new BrokerRuntimeMetric(
            clusterName, brokerAddress, brokerHost,
            stats.getBrokerVersionDesc(),
            stats.getBootTimestamp(),
            stats.getBrokerVersion()), stats.getCommitLogMaxOffset());


        brokerRuntimeDispatchMaxBuffer.put(new BrokerRuntimeMetric(
            clusterName, brokerAddress, brokerHost,
            stats.getBrokerVersionDesc(),
            stats.getBootTimestamp(),
            stats.getBrokerVersion()), stats.getDispatchMaxBuffer());
        brokerRuntimeConsumeQueueDiskRatio.put(new BrokerRuntimeMetric(
            clusterName, brokerAddress, brokerHost,
            stats.getBrokerVersionDesc(),
            stats.getBootTimestamp(),
            stats.getBrokerVersion()), stats.getConsumeQueueDiskRatio());
        brokerRuntimeCommitLogDiskRatio.put(new BrokerRuntimeMetric(
            clusterName, brokerAddress, brokerHost,
            stats.getBrokerVersionDesc(),
            stats.getBootTimestamp(),
            stats.getBrokerVersion()), stats.getCommitLogDiskRatio());
        brokerRuntimePageCacheLockTimeMills.put(new BrokerRuntimeMetric(
            clusterName, brokerAddress, brokerHost,
            stats.getBrokerVersionDesc(),
            stats.getBootTimestamp(),
            stats.getBrokerVersion()), stats.getPageCacheLockTimeMills());
        brokerRuntimeGetMessageEntireTimeMax.put(new BrokerRuntimeMetric(
            clusterName, brokerAddress, brokerHost,
            stats.getBrokerVersionDesc(),
            stats.getBootTimestamp(),
            stats.getBrokerVersion()), stats.getGetMessageEntireTimeMax());
        brokerRuntimePutMessageTimesTotal.put(new BrokerRuntimeMetric(
            clusterName, brokerAddress, brokerHost,
            stats.getBrokerVersionDesc(),
            stats.getBootTimestamp(),
            stats.getBrokerVersion()), stats.getPutMessageTimesTotal());
        brokerRuntimeSendThreadPoolQueueSize.put(new BrokerRuntimeMetric(
            clusterName, brokerAddress, brokerHost,
            stats.getBrokerVersionDesc(),
            stats.getBootTimestamp(),
            stats.getBrokerVersion()), stats.getSendThreadPoolQueueSize());
        brokerRuntimeStartAcceptSendRequestTimeStamp.put(new BrokerRuntimeMetric(
            clusterName, brokerAddress, brokerHost,
            stats.getBrokerVersionDesc(),
            stats.getBootTimestamp(),
            stats.getBrokerVersion()), stats.getStartAcceptSendRequestTimeStamp());
        brokerRuntimePutMessageEntireTimeMax.put(new BrokerRuntimeMetric(
            clusterName, brokerAddress, brokerHost,
            stats.getBrokerVersionDesc(),
            stats.getBootTimestamp(),
            stats.getBrokerVersion()), stats.getPutMessageEntireTimeMax());
        brokerRuntimeEarliestMessageTimeStamp.put(new BrokerRuntimeMetric(
            clusterName, brokerAddress, brokerHost,
            stats.getBrokerVersionDesc(),
            stats.getBootTimestamp(),
            stats.getBrokerVersion()), stats.getEarliestMessageTimeStamp());
        brokerRuntimeRemainTransientStoreBufferNumbs.put(new BrokerRuntimeMetric(
            clusterName, brokerAddress, brokerHost,
            stats.getBrokerVersionDesc(),
            stats.getBootTimestamp(),
            stats.getBrokerVersion()), stats.getRemainTransientStoreBufferNumbs());
        brokerRuntimeQueryThreadPoolQueueCapacity.put(new BrokerRuntimeMetric(
            clusterName, brokerAddress, brokerHost,
            stats.getBrokerVersionDesc(),
            stats.getBootTimestamp(),
            stats.getBrokerVersion()), stats.getQueryThreadPoolQueueCapacity());
        brokerRuntimePutMessageAverageSize.put(new BrokerRuntimeMetric(
            clusterName, brokerAddress, brokerHost,
            stats.getBrokerVersionDesc(),
            stats.getBootTimestamp(),
            stats.getBrokerVersion()), stats.getPutMessageAverageSize());
        brokerRuntimePutMessageSizeTotal.put(new BrokerRuntimeMetric(
            clusterName, brokerAddress, brokerHost,
            stats.getBrokerVersionDesc(),
            stats.getBootTimestamp(),
            stats.getBrokerVersion()), stats.getPutMessageSizeTotal());
        brokerRuntimeDispatchBehindBytes.put(new BrokerRuntimeMetric(
            clusterName, brokerAddress, brokerHost,
            stats.getBrokerVersionDesc(),
            stats.getBootTimestamp(),
            stats.getBrokerVersion()), stats.getDispatchBehindBytes());
    }