private void addCommitLogDirCapacity()

in src/main/java/org/apache/rocketmq/exporter/collector/RMQMetricsCollector.java [1043:1056]

• 14 lines of code
• 1 McCabe index (conditional complexity)

    private void addCommitLogDirCapacity(String clusterName, String brokerAddress, String brokerHost, BrokerRuntimeStats stats) {
        brokerRuntimeCommitLogDirCapacityTotal.put(new BrokerRuntimeMetric(
            clusterName,
            brokerAddress, brokerHost,
            stats.getBrokerVersionDesc(),
            stats.getBootTimestamp(),
            stats.getBrokerVersion()), stats.getCommitLogDirCapacityTotal());
        brokerRuntimeCommitLogDirCapacityFree.put(new BrokerRuntimeMetric(
            clusterName,
            brokerAddress, brokerHost,
            stats.getBrokerVersionDesc(),
            stats.getBootTimestamp(),
            stats.getBrokerVersion()), stats.getCommitLogDirCapacityFree());
    }