summaryrefslogtreecommitdiffstats
path: root/metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/VespaService.java
diff options
context:
space:
mode:
Diffstat (limited to 'metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/VespaService.java')
-rw-r--r--metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/VespaService.java6
1 files changed, 3 insertions, 3 deletions
diff --git a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/VespaService.java b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/VespaService.java
index 666fa31b7ed..8dd8d002c84 100644
--- a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/VespaService.java
+++ b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/VespaService.java
@@ -137,15 +137,15 @@ public class VespaService implements Comparable<VespaService> {
* Get the Metrics registered for this service. Metrics are fetched over HTTP
* if a metric http port has been defined, otherwise from log file
*/
- public void consumeMetrics(MetricsParser.Consumer consumer) {
+ public void consumeMetrics(MetricsParser.Collector consumer) {
remoteMetricsFetcher.getMetrics(consumer, metricsFetchCount.get());
metricsFetchCount.getAndIncrement();
}
- private static class CollectMetrics implements MetricsParser.Consumer {
+ private static class CollectMetrics implements MetricsParser.Collector {
private final Metrics metrics = new Metrics();
@Override
- public void consume(Metric metric) {
+ public void accept(Metric metric) {
metrics.add(metric);
}
}