diff options
author | gjoranv <gv@verizonmedia.com> | 2019-12-19 11:02:34 +0100 |
---|---|---|
committer | gjoranv <gv@verizonmedia.com> | 2019-12-19 11:02:34 +0100 |
commit | fdb3dc9c329252764a1fa45ec4eb38c199a19827 (patch) | |
tree | f57ac79b06758409720b3b205a403d5f03afb015 /metrics-proxy | |
parent | ed9bf1ee31f28295fc920984e0e0cbf492d49e65 (diff) |
Simplify HttpHandlerBase to make it more generic and reusable.
Diffstat (limited to 'metrics-proxy')
4 files changed, 14 insertions, 10 deletions
diff --git a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/http/HttpHandlerBase.java b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/http/HttpHandlerBase.java index d582abdba57..ccc93d559ed 100644 --- a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/http/HttpHandlerBase.java +++ b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/http/HttpHandlerBase.java @@ -32,14 +32,8 @@ import static java.util.logging.Level.WARNING; */ public abstract class HttpHandlerBase extends ThreadedHttpRequestHandler { - protected final ValuesFetcher valuesFetcher; - - protected HttpHandlerBase(Executor executor, - MetricsManager metricsManager, - VespaServices vespaServices, - MetricsConsumers metricsConsumers) { + protected HttpHandlerBase(Executor executor) { super(executor); - valuesFetcher = new ValuesFetcher(metricsManager, vespaServices, metricsConsumers); } protected abstract Optional<HttpResponse> doHandle(URI requestUri, Path apiPath, String consumer); diff --git a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/http/MetricsHandler.java b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/http/MetricsHandler.java index ac89faad8d8..63a79d93b07 100644 --- a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/http/MetricsHandler.java +++ b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/http/MetricsHandler.java @@ -32,12 +32,15 @@ public class MetricsHandler extends HttpHandlerBase { public static final String V1_PATH = "/metrics/v1"; static final String VALUES_PATH = V1_PATH + "/values"; + private final ValuesFetcher valuesFetcher; + @Inject public MetricsHandler(Executor executor, MetricsManager metricsManager, VespaServices vespaServices, MetricsConsumers metricsConsumers) { - super(executor, metricsManager, vespaServices, metricsConsumers); + super(executor); + valuesFetcher = new ValuesFetcher(metricsManager, vespaServices, metricsConsumers); } @Override diff --git a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/http/prometheus/PrometheusHandler.java b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/http/prometheus/PrometheusHandler.java index aeea15ee87e..03b349c293b 100644 --- a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/http/prometheus/PrometheusHandler.java +++ b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/http/prometheus/PrometheusHandler.java @@ -8,6 +8,7 @@ import ai.vespa.metricsproxy.core.MetricsConsumers; import ai.vespa.metricsproxy.core.MetricsManager; import ai.vespa.metricsproxy.http.HttpHandlerBase; import ai.vespa.metricsproxy.http.TextResponse; +import ai.vespa.metricsproxy.http.ValuesFetcher; import ai.vespa.metricsproxy.metric.model.MetricsPacket; import ai.vespa.metricsproxy.service.VespaServices; import com.google.inject.Inject; @@ -32,12 +33,15 @@ public class PrometheusHandler extends HttpHandlerBase { public static final String V1_PATH = "/prometheus/v1"; static final String VALUES_PATH = V1_PATH + "/values"; + private final ValuesFetcher valuesFetcher; + @Inject public PrometheusHandler(Executor executor, MetricsManager metricsManager, VespaServices vespaServices, MetricsConsumers metricsConsumers) { - super(executor, metricsManager, vespaServices, metricsConsumers); + super(executor); + valuesFetcher = new ValuesFetcher(metricsManager, vespaServices, metricsConsumers); } @Override diff --git a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/http/yamas/YamasHandler.java b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/http/yamas/YamasHandler.java index 4c25796907a..38011d089d4 100644 --- a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/http/yamas/YamasHandler.java +++ b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/http/yamas/YamasHandler.java @@ -3,6 +3,7 @@ package ai.vespa.metricsproxy.http.yamas; import ai.vespa.metricsproxy.core.MetricsConsumers; import ai.vespa.metricsproxy.core.MetricsManager; +import ai.vespa.metricsproxy.http.ValuesFetcher; import ai.vespa.metricsproxy.node.NodeMetricGatherer; import ai.vespa.metricsproxy.http.ErrorResponse; import ai.vespa.metricsproxy.http.HttpHandlerBase; @@ -34,6 +35,7 @@ public class YamasHandler extends HttpHandlerBase { public static final String V1_PATH = "/yamas/v1"; private static final String VALUES_PATH = V1_PATH + "/values"; + private final ValuesFetcher valuesFetcher; private final NodeMetricGatherer nodeMetricGatherer; @Inject @@ -43,7 +45,8 @@ public class YamasHandler extends HttpHandlerBase { MetricsConsumers metricsConsumers, ApplicationDimensions applicationDimensions, NodeDimensions nodeDimensions) { - super(executor, metricsManager, vespaServices, metricsConsumers); + super(executor); + valuesFetcher = new ValuesFetcher(metricsManager, vespaServices, metricsConsumers); this.nodeMetricGatherer = new NodeMetricGatherer(metricsManager, vespaServices, applicationDimensions, nodeDimensions); } |