aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorgjoranv <gv@verizonmedia.com>2019-06-11 17:02:37 +0200
committergjoranv <gv@verizonmedia.com>2019-06-11 17:17:39 +0200
commitcbbb7fee23052f78295e2687f153903422add9e2 (patch)
treea2676bbbcf121d4e49adcb890af4f10073daabf3
parent97f82e3fe82e21693cb788e6c406ccede1253fb4 (diff)
Refactoring only
-rw-r--r--metrics-proxy/src/main/java/ai/vespa/metricsproxy/metric/Metrics.java1
-rw-r--r--metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/HttpMetricFetcher.java2
-rw-r--r--metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/RemoteHealthMetricFetcher.java9
-rw-r--r--metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/RemoteMetricsFetcher.java11
-rw-r--r--metrics-proxy/src/test/java/ai/vespa/metricsproxy/service/ContainerServiceTest.java3
-rw-r--r--metrics-proxy/src/test/java/ai/vespa/metricsproxy/service/VespaServiceTest.java3
6 files changed, 12 insertions, 17 deletions
diff --git a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/metric/Metrics.java b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/metric/Metrics.java
index ca611368730..2a803062b5d 100644
--- a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/metric/Metrics.java
+++ b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/metric/Metrics.java
@@ -30,7 +30,6 @@ public class Metrics {
private void ensureNotFrozen() {
if (isFrozen) throw new IllegalStateException("Frozen Metrics cannot be modified!");
-
}
public long getTimeStamp() {
diff --git a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/HttpMetricFetcher.java b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/HttpMetricFetcher.java
index 9094ef22c20..81358041502 100644
--- a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/HttpMetricFetcher.java
+++ b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/HttpMetricFetcher.java
@@ -25,8 +25,6 @@ import java.util.logging.Logger;
public abstract class HttpMetricFetcher {
private final static Logger log = Logger.getLogger(HttpMetricFetcher.class.getPackage().getName());
public final static String STATE_PATH = "/state/v1/";
- final static String METRICS_PATH = STATE_PATH + "metrics";
- final static String HEALTH_PATH = STATE_PATH + "health";
// The call to apache will do 3 retries. As long as we check the services in series, we can't have this too high.
public static int CONNECTION_TIMEOUT = 5000;
private final static int SOCKET_TIMEOUT = 60000;
diff --git a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/RemoteHealthMetricFetcher.java b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/RemoteHealthMetricFetcher.java
index 503f582a827..16f4a5cf05b 100644
--- a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/RemoteHealthMetricFetcher.java
+++ b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/RemoteHealthMetricFetcher.java
@@ -18,13 +18,10 @@ import java.util.logging.Logger;
* @author Jo Kristian Bergum
*/
public class RemoteHealthMetricFetcher extends HttpMetricFetcher {
-
private final static Logger log = Logger.getLogger(RemoteHealthMetricFetcher.class.getPackage().getName());
- /**
- * @param service The service to fetch metrics from
- * @param port The port to use
- */
+ private final static String HEALTH_PATH = STATE_PATH + "health";
+
public RemoteHealthMetricFetcher(VespaService service, int port) {
super(service, port, HEALTH_PATH);
}
@@ -45,7 +42,7 @@ public class RemoteHealthMetricFetcher extends HttpMetricFetcher {
/**
* Connect to remote service over http and fetch metrics
*/
- HealthMetric createHealthMetrics(String data, int fetchCount) {
+ private HealthMetric createHealthMetrics(String data, int fetchCount) {
HealthMetric healthMetric = HealthMetric.getFailed("Failed fetching status page for service");
try {
healthMetric = parse(data);
diff --git a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/RemoteMetricsFetcher.java b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/RemoteMetricsFetcher.java
index a606ec7d8cd..552b4dc4010 100644
--- a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/RemoteMetricsFetcher.java
+++ b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/RemoteMetricsFetcher.java
@@ -25,10 +25,9 @@ import static ai.vespa.metricsproxy.metric.model.DimensionId.toDimensionId;
* @author Jo Kristian Bergum
*/
public class RemoteMetricsFetcher extends HttpMetricFetcher {
- /**
- * @param service The service to fetch metrics from
- * @param port The port to use
- */
+
+ final static String METRICS_PATH = STATE_PATH + "metrics";
+
RemoteMetricsFetcher(VespaService service, int port) {
super(service, port, METRICS_PATH);
}
@@ -50,7 +49,7 @@ public class RemoteMetricsFetcher extends HttpMetricFetcher {
/**
* Connect to remote service over http and fetch metrics
*/
- public Metrics createMetrics(String data, int fetchCount) {
+ Metrics createMetrics(String data, int fetchCount) {
Metrics remoteMetrics = new Metrics();
try {
remoteMetrics = parse(data);
@@ -61,7 +60,7 @@ public class RemoteMetricsFetcher extends HttpMetricFetcher {
return remoteMetrics;
}
- Metrics parse(String data) throws JSONException {
+ private Metrics parse(String data) throws JSONException {
JSONObject o = new JSONObject(data);
if (!(o.has("metrics"))) {
return new Metrics(); //empty
diff --git a/metrics-proxy/src/test/java/ai/vespa/metricsproxy/service/ContainerServiceTest.java b/metrics-proxy/src/test/java/ai/vespa/metricsproxy/service/ContainerServiceTest.java
index 0a84c03acec..725501aacaa 100644
--- a/metrics-proxy/src/test/java/ai/vespa/metricsproxy/service/ContainerServiceTest.java
+++ b/metrics-proxy/src/test/java/ai/vespa/metricsproxy/service/ContainerServiceTest.java
@@ -13,6 +13,7 @@ import org.junit.Test;
import static ai.vespa.metricsproxy.TestUtil.getFileContents;
import static ai.vespa.metricsproxy.metric.model.DimensionId.toDimensionId;
+import static ai.vespa.metricsproxy.service.RemoteMetricsFetcher.METRICS_PATH;
import static org.hamcrest.CoreMatchers.is;
import static org.junit.Assert.assertThat;
@@ -34,7 +35,7 @@ public class ContainerServiceTest {
csPort = 18637; // see factory/doc/port-ranges.txt
try {
String response = getFileContents("metrics-container-state-multi-chain.json");
- service = new MockHttpServer(csPort, response, HttpMetricFetcher.METRICS_PATH);
+ service = new MockHttpServer(csPort, response, METRICS_PATH);
} catch (Exception e) {
e.printStackTrace();
}
diff --git a/metrics-proxy/src/test/java/ai/vespa/metricsproxy/service/VespaServiceTest.java b/metrics-proxy/src/test/java/ai/vespa/metricsproxy/service/VespaServiceTest.java
index 702f741c41f..a0c6b5333cc 100644
--- a/metrics-proxy/src/test/java/ai/vespa/metricsproxy/service/VespaServiceTest.java
+++ b/metrics-proxy/src/test/java/ai/vespa/metricsproxy/service/VespaServiceTest.java
@@ -10,6 +10,7 @@ import org.junit.Before;
import org.junit.Test;
import static ai.vespa.metricsproxy.TestUtil.getFileContents;
+import static ai.vespa.metricsproxy.service.RemoteMetricsFetcher.METRICS_PATH;
import static org.hamcrest.CoreMatchers.is;
import static org.junit.Assert.assertThat;
@@ -30,7 +31,7 @@ public class VespaServiceTest {
public void setupHTTPServer() {
csPort = 18632; // see factory/doc/port-ranges.txt
try {
- service = new MockHttpServer(csPort, response, HttpMetricFetcher.METRICS_PATH);
+ service = new MockHttpServer(csPort, response, METRICS_PATH);
} catch (Exception e) {
e.printStackTrace();
}