private void collectClientGroupMetric()

in src/main/java/org/apache/rocketmq/exporter/collector/RMQMetricsCollector.java [417:453]

• 32 lines of code
• 7 McCabe index (conditional complexity)

    private void collectClientGroupMetric(List<MetricFamilySamples> mfs) {
        GaugeMetricFamily consumerClientFailedMsgCountsF = new GaugeMetricFamily("rocketmq_client_consume_fail_msg_count", "consumerClientFailedMsgCounts", GROUP_CLIENT_METRIC_LABEL_NAMES);
        for (Map.Entry<ConsumerRuntimeConsumeFailedMsgsMetric, Long> entry : consumerClientFailedMsgCounts.asMap().entrySet()) {
            loadClientRuntimeStatsMetric(consumerClientFailedMsgCountsF, entry);
        }
        mfs.add(consumerClientFailedMsgCountsF);

        GaugeMetricFamily consumerClientFailedTPSF = new GaugeMetricFamily("rocketmq_client_consume_fail_msg_tps", "consumerClientFailedTPS", GROUP_CLIENT_METRIC_LABEL_NAMES);
        for (Map.Entry<ConsumerRuntimeConsumeFailedTPSMetric, Double> entry : consumerClientFailedTPS.asMap().entrySet()) {
            loadClientRuntimeStatsMetric(consumerClientFailedTPSF, entry);
        }
        mfs.add(consumerClientFailedTPSF);

        GaugeMetricFamily consumerClientOKTPSF = new GaugeMetricFamily("rocketmq_client_consume_ok_msg_tps", "consumerClientOKTPS", GROUP_CLIENT_METRIC_LABEL_NAMES);
        for (Map.Entry<ConsumerRuntimeConsumeOKTPSMetric, Double> entry : consumerClientOKTPS.asMap().entrySet()) {
            loadClientRuntimeStatsMetric(consumerClientOKTPSF, entry);
        }
        mfs.add(consumerClientOKTPSF);

        GaugeMetricFamily consumerClientRTF = new GaugeMetricFamily("rocketmq_client_consume_rt", "consumerClientRT", GROUP_CLIENT_METRIC_LABEL_NAMES);
        for (Map.Entry<ConsumerRuntimeConsumeRTMetric, Double> entry : consumerClientRT.asMap().entrySet()) {
            loadClientRuntimeStatsMetric(consumerClientRTF, entry);
        }
        mfs.add(consumerClientRTF);

        GaugeMetricFamily consumerClientPullRTF = new GaugeMetricFamily("rocketmq_client_consumer_pull_rt", "consumerClientPullRT", GROUP_CLIENT_METRIC_LABEL_NAMES);
        for (Map.Entry<ConsumerRuntimePullRTMetric, Double> entry : consumerClientPullRT.asMap().entrySet()) {
            loadClientRuntimeStatsMetric(consumerClientPullRTF, entry);
        }
        mfs.add(consumerClientPullRTF);

        GaugeMetricFamily consumerClientPullTPSF = new GaugeMetricFamily("rocketmq_client_consumer_pull_tps", "consumerClientPullTPS", GROUP_CLIENT_METRIC_LABEL_NAMES);
        for (Map.Entry<ConsumerRuntimePullTPSMetric, Double> entry : consumerClientPullTPS.asMap().entrySet()) {
            loadClientRuntimeStatsMetric(consumerClientPullTPSF, entry);
        }
        mfs.add(consumerClientPullTPSF);
    }