diff options
Diffstat (limited to 'metrics-proxy/src/main/java/ai/vespa/metricsproxy/node/ServiceHealthGatherer.java')
-rw-r--r-- | metrics-proxy/src/main/java/ai/vespa/metricsproxy/node/ServiceHealthGatherer.java | 36 |
1 files changed, 0 insertions, 36 deletions
diff --git a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/node/ServiceHealthGatherer.java b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/node/ServiceHealthGatherer.java deleted file mode 100644 index d09f2aff3e5..00000000000 --- a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/node/ServiceHealthGatherer.java +++ /dev/null @@ -1,36 +0,0 @@ -// Copyright Yahoo. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root. -package ai.vespa.metricsproxy.node; - -import ai.vespa.metricsproxy.metric.HealthMetric; -import ai.vespa.metricsproxy.metric.model.ConsumerId; -import ai.vespa.metricsproxy.metric.model.DimensionId; -import ai.vespa.metricsproxy.metric.model.MetricsPacket; -import ai.vespa.metricsproxy.service.VespaServices; - -import java.time.Instant; -import java.util.List; -import java.util.Set; -import java.util.stream.Collectors; - -/** - * @author olaa - */ -public class ServiceHealthGatherer { - - protected static List<MetricsPacket.Builder> gatherServiceHealthMetrics(VespaServices vespaServices) { - return vespaServices.getVespaServices() - .stream() - .map(service -> { - HealthMetric healt = service.getHealth(); - return new MetricsPacket.Builder(service.getMonitoringName()) - .timestamp(Instant.now().getEpochSecond()) - .statusMessage(healt.getStatus().status) - .statusCode(healt.getStatus().code) - .putDimension(DimensionId.toDimensionId("instance"), service.getInstanceName()) - .putDimension(DimensionId.toDimensionId("metrictype"), "health") - .addConsumers(Set.of(ConsumerId.toConsumerId("Vespa"))); - }) - .toList(); - } - -} |