public void run()

in src/main/java/com/aliyun/dts/subscribe/clients/metrics/LogMetricsReporter.java [169:186]

• 17 lines of code
• 3 McCabe index (conditional complexity)

        public void run() {
            long now = time.milliseconds();
            final List<MetricValue> samples;
            synchronized (lock) {
                samples = new ArrayList<>(metrics.size());
                for (KafkaMetric metric : metrics.values()) {
                    MetricName name = metric.metricName();
                    samples.add(new MetricValue(name.name(), name.group(), name.tags(), metric.metricValue()));
                }
            }

            MetricsReport report = new MetricsReport(now, samples);
            LOG.trace("Reporting {} metrics", samples.size());
            String content = genContent(report.metrics());
            if (!StringUtils.isEmpty(content)) {
                METRICS_LOG.info(content);
            }
        }