@Test public void dead_node_yields_empty_metrics() { var config = nodesConfig("/non-existent"); Node node = new Node(config.node(0)); ApplicationMetricsRetriever retriever = new ApplicationMetricsRetriever(config); var metricsByNode = retriever.getMetrics(); assertEquals(1, metricsByNode.size()); assertEquals(0, metricsByNode.get(node).size()); }
public Map<Node, List<MetricsPacket>> getMetrics() { return getMetrics(defaultMetricsConsumerId); }
ApplicationMetricsRetriever extends AbstractComponent { public Map<Node, List<MetricsPacket>> getMetrics() { return getMetrics(defaultMetricsConsumerId); } }
ApplicationMetricsRetriever extends AbstractComponent { public Map<Node, List<MetricsPacket>> getMetrics() { return getMetrics(defaultMetricsConsumerId); } @Inject  ApplicationMetricsRetriever(MetricsNodesConfig nodesConfig); }
ApplicationMetricsRetriever extends AbstractComponent { public Map<Node, List<MetricsPacket>> getMetrics() { return getMetrics(defaultMetricsConsumerId); } @Inject  ApplicationMetricsRetriever(MetricsNodesConfig nodesConfig); @Override void deconstruct(); Map<Node, List<MetricsPacket>> getMetrics(); Map<Node, List<MetricsPacket>> getMetrics(ConsumerId consumer); }
ApplicationMetricsRetriever extends AbstractComponent { public Map<Node, List<MetricsPacket>> getMetrics() { return getMetrics(defaultMetricsConsumerId); } @Inject  ApplicationMetricsRetriever(MetricsNodesConfig nodesConfig); @Override void deconstruct(); Map<Node, List<MetricsPacket>> getMetrics(); Map<Node, List<MetricsPacket>> getMetrics(ConsumerId consumer);  }