private void collectGroupNums()

in src/main/java/org/apache/rocketmq/exporter/collector/RMQMetricsCollector.java [592:636]
38 lines of code
8 McCabe index (conditional complexity)

    private void collectGroupNums(List<MetricFamilySamples> mfs) {
        GaugeMetricFamily groupGetNumsGauge = new GaugeMetricFamily("rocketmq_consumer_tps", "GroupGetNums", GROUP_NUMS_LABEL_NAMES);
        for (Map.Entry<ConsumerMetric, Double> entry : groupGetNums.asMap().entrySet()) {
            loadGroupNumsMetric(groupGetNumsGauge, entry);
        }
        mfs.add(groupGetNumsGauge);

        GaugeMetricFamily groupConsumeTPSF = new GaugeMetricFamily("rocketmq_group_consume_tps", "GroupConsumeTPS", GROUP_NUMS_LABEL_NAMES);
        for (Map.Entry<ConsumerMetric, Double> entry : groupConsumeTPS.asMap().entrySet()) {
            loadGroupNumsMetric(groupConsumeTPSF, entry);
        }
        mfs.add(groupConsumeTPSF);

        GaugeMetricFamily groupBrokerTotalOffsetF = new GaugeMetricFamily("rocketmq_consumer_offset", "GroupBrokerTotalOffset", GROUP_NUMS_LABEL_NAMES);
        for (Map.Entry<ConsumerMetric, Long> entry : groupBrokerTotalOffset.asMap().entrySet()) {
            loadGroupNumsMetric(groupBrokerTotalOffsetF, entry);
        }
        mfs.add(groupBrokerTotalOffsetF);

        GaugeMetricFamily groupConsumeTotalOffsetF = new GaugeMetricFamily("rocketmq_group_consume_total_offset", "GroupConsumeTotalOffset", GROUP_NUMS_LABEL_NAMES);
        for (Map.Entry<ConsumerMetric, Long> entry : groupConsumeTotalOffset.asMap().entrySet()) {
            loadGroupNumsMetric(groupConsumeTotalOffsetF, entry);
        }
        mfs.add(groupConsumeTotalOffsetF);

        GaugeMetricFamily groupGetSizeGauge = new GaugeMetricFamily("rocketmq_consumer_message_size", "GroupGetMessageSize", GROUP_NUMS_LABEL_NAMES);
        for (Map.Entry<ConsumerMetric, Double> entry : groupGetSize.asMap().entrySet()) {
            loadGroupNumsMetric(groupGetSizeGauge, entry);
        }
        mfs.add(groupGetSizeGauge);

        GaugeMetricFamily sendBackNumsGauge = new GaugeMetricFamily("rocketmq_send_back_nums", "SendBackNums", GROUP_NUMS_LABEL_NAMES);
        for (Map.Entry<ConsumerMetric, Double> entry : sendBackNums.asMap().entrySet()) {
            loadGroupNumsMetric(sendBackNumsGauge, entry);
        }
        mfs.add(sendBackNumsGauge);

        GaugeMetricFamily groupLatencyByTimeF = new GaugeMetricFamily("rocketmq_group_get_latency_by_storetime",
            "GroupGetLatencyByStoreTime", GROUP_LATENCY_BY_STORETIME_LABEL_NAMES);
        for (Map.Entry<ConsumerMetric, Long> entry : groupLatencyByTime.asMap().entrySet()) {
            loadGroupNumsMetric(groupLatencyByTimeF, entry);
        }
        mfs.add(groupLatencyByTimeF);

    }