public void run()

in collector/prometheus/src/main/java/org/apache/karaf/decanter/collector/prometheus/PrometheusCollector.java [74:113]
39 lines of code
7 McCabe index (conditional complexity)

    public void run() {
        try {
            URLConnection connection = prometheusURL.openConnection();
            String topic = (properties.get(EventConstants.EVENT_TOPIC) != null) ? (String) properties.get(EventConstants.EVENT_TOPIC) : "decanter/collect/prometheus";
            try (BufferedReader reader = new BufferedReader(new InputStreamReader(connection.getInputStream()))) {
                String line;
                while ((line = reader.readLine()) != null) {
                    if (!line.matches("# .*")) {
                        Map<String, Object> data = new HashMap<>();
                        data.put("type", type);
                        if (line.contains("{")) {
                            final String name = line.substring(0, line.indexOf("{"));
                            String[] labels = line.substring(line.indexOf("{")+1, line.indexOf("}")).split(",");
                            Stream.of(labels).forEach(it -> {
                                String labelName = it.substring(0, it.indexOf("=")).replace("\"", "");
                                String labelValue = it.substring(it.indexOf("=")+1).replace("\"", "");
                                data.put(labelName, labelValue);
                            });

                            String value = line.substring(line.indexOf("}")+2);
                            Double parseValue = Double.parseDouble(value);
                            data.put(name, parseValue);
                        } else {
                            String[] split = line.split(" ");
                            if (split.length == 2) {
                                String property = split[0];
                                double value = Double.parseDouble(split[1]);
                                data.put(property, value);
                            }
                        }
                        PropertiesPreparator.prepare(data, properties);
                        dispatcher.postEvent(new Event(topic, data));
                    }
                }
            }
        } catch (Exception e) {
            LOGGER.warn("Can't get Prometheus metrics", e);
            e.printStackTrace();
        }
    }