summaryrefslogtreecommitdiffstats
path: root/metrics-proxy
diff options
context:
space:
mode:
authorgjoranv <gv@verizonmedia.com>2020-04-24 13:12:46 +0200
committergjoranv <gv@verizonmedia.com>2020-04-25 02:22:55 +0200
commit25f832e613bb6087327c293b527d5445babb4319 (patch)
tree8197a5b331e845bfe91f006d9cfe8bec9a28170f /metrics-proxy
parent4e6825b47270804a36e7d76b873ca6c2fe360eac (diff)
LogLevel.DEBUG -> Level.FINE
Diffstat (limited to 'metrics-proxy')
-rw-r--r--metrics-proxy/src/main/java/ai/vespa/metricsproxy/http/application/ApplicationMetricsRetriever.java4
-rw-r--r--metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/ConfigSentinelClient.java4
-rw-r--r--metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/HttpMetricFetcher.java6
-rw-r--r--metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/RemoteHealthMetricFetcher.java2
-rw-r--r--metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/SystemPoller.java12
-rw-r--r--metrics-proxy/src/main/java/ai/vespa/metricsproxy/telegraf/Telegraf.java2
-rw-r--r--metrics-proxy/src/main/java/ai/vespa/metricsproxy/telegraf/TelegrafRegistry.java4
7 files changed, 17 insertions, 17 deletions
diff --git a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/http/application/ApplicationMetricsRetriever.java b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/http/application/ApplicationMetricsRetriever.java
index 8edae823a97..4d57e89fc76 100644
--- a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/http/application/ApplicationMetricsRetriever.java
+++ b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/http/application/ApplicationMetricsRetriever.java
@@ -69,7 +69,7 @@ public class ApplicationMetricsRetriever extends AbstractComponent {
}
public Map<Node, List<MetricsPacket.Builder>> getMetrics(ConsumerId consumer) {
- log.log(LogLevel.DEBUG, () -> "Retrieving metrics from " + clients.size() + " nodes.");
+ log.log(Level.FINE, () -> "Retrieving metrics from " + clients.size() + " nodes.");
var forkJoinTask = forkJoinPool.submit(() -> clients.parallelStream()
.map(client -> getNodeMetrics(client, consumer))
.collect(toMap(Map.Entry::getKey, Map.Entry::getValue)));
@@ -77,7 +77,7 @@ public class ApplicationMetricsRetriever extends AbstractComponent {
try {
var metricsByNode = forkJoinTask.get(taskTimeout.toMillis(), TimeUnit.MILLISECONDS);
- log.log(LogLevel.DEBUG, () -> "Finished retrieving metrics from " + clients.size() + " nodes.");
+ log.log(Level.FINE, () -> "Finished retrieving metrics from " + clients.size() + " nodes.");
return metricsByNode;
} catch (Exception e) {
diff --git a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/ConfigSentinelClient.java b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/ConfigSentinelClient.java
index 449309d8a3e..06036aa90d5 100644
--- a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/ConfigSentinelClient.java
+++ b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/ConfigSentinelClient.java
@@ -58,7 +58,7 @@ public class ConfigSentinelClient extends AbstractComponent {
synchronized void ping(VespaService s) {
List<VespaService> services = new ArrayList<>();
services.add(s);
- log.log(LogLevel.DEBUG, "Ping for service " + s);
+ log.log(Level.FINE, "Ping for service " + s);
try {
setStatus(services);
} catch (Exception e) {
@@ -92,7 +92,7 @@ public class ConfigSentinelClient extends AbstractComponent {
//from the sentinel
for (VespaService s : services) {
if ((!s.getServiceName().equals("configserver")) && !updatedServices.contains(s)) {
- log.log(LogLevel.DEBUG,"Service " + s + " is no longer found with sentinel - setting alive = false");
+ log.log(Level.FINE,"Service " + s + " is no longer found with sentinel - setting alive = false");
s.setAlive(false);
}
}
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 a5c0e0e2395..0a17810d3cc 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
@@ -40,11 +40,11 @@ public abstract class HttpMetricFetcher {
String u = "http://localhost:" + port + path;
this.url = URI.create(u);
- log.log(LogLevel.DEBUG, "Fetching metrics from " + u + " with timeout " + CONNECTION_TIMEOUT);
+ log.log(Level.FINE, "Fetching metrics from " + u + " with timeout " + CONNECTION_TIMEOUT);
}
String getJson() throws IOException {
- log.log(LogLevel.DEBUG, "Connecting to url " + url + " for service '" + service + "'");
+ log.log(Level.FINE, "Connecting to url " + url + " for service '" + service + "'");
return httpClient.execute(new HttpGet(url), new BasicResponseHandler());
}
@@ -66,7 +66,7 @@ public abstract class HttpMetricFetcher {
if (service.isAlive() && timesFetched > 5) {
log.log(LogLevel.INFO, message);
} else {
- log.log(LogLevel.DEBUG, message);
+ log.log(Level.FINE, message);
}
}
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 4bc9055c6a5..1cab1a859a9 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
@@ -64,7 +64,7 @@ public class RemoteHealthMetricFetcher extends HttpMetricFetcher {
return HealthMetric.get(code, message);
} catch (JSONException e) {
- log.log(LogLevel.DEBUG, "Failed to parse json response from metrics page:" + e + ":" + data);
+ log.log(Level.FINE, "Failed to parse json response from metrics page:" + e + ":" + data);
return HealthMetric.getUnknown("Not able to parse json from status page");
}
}
diff --git a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/SystemPoller.java b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/SystemPoller.java
index 3e8eeea1268..7620e94fc9e 100644
--- a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/SystemPoller.java
+++ b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/SystemPoller.java
@@ -81,7 +81,7 @@ public class SystemPoller {
br.close();
} catch (IOException ex) {
- log.log(LogLevel.DEBUG, "Unable to read line from smaps file", ex);
+ log.log(Level.FINE, "Unable to read line from smaps file", ex);
return size;
}
@@ -101,7 +101,7 @@ public class SystemPoller {
return;
}
- log.log(LogLevel.DEBUG, "Monitoring system metrics for " + services.size() + " services");
+ log.log(Level.FINE, "Monitoring system metrics for " + services.size() + " services");
long sysJiffies = getNormalizedSystemJiffies();
for (VespaService s : services) {
@@ -112,10 +112,10 @@ public class SystemPoller {
}
Metrics metrics = new Metrics();
- log.log(LogLevel.DEBUG, "Current size of system metrics for service " + s + " is " + metrics.size());
+ log.log(Level.FINE, "Current size of system metrics for service " + s + " is " + metrics.size());
long[] size = getMemoryUsage(s);
- log.log(LogLevel.DEBUG, "Updating memory metric for service " + s);
+ log.log(Level.FINE, "Updating memory metric for service " + s);
metrics.add(new Metric("memory_virt", size[memoryTypeVirtual], startTime / 1000));
metrics.add(new Metric("memory_rss", size[memoryTypeResident], startTime / 1000));
@@ -152,7 +152,7 @@ public class SystemPoller {
try {
in = new BufferedReader(new FileReader("/proc/" + pid + "/stat"));
} catch (FileNotFoundException ex) {
- log.log(LogLevel.DEBUG, "Unable to find pid " + pid + " in proc directory, for service " + service.getInstanceName());
+ log.log(Level.FINE, "Unable to find pid " + pid + " in proc directory, for service " + service.getInstanceName());
service.setAlive(false);
return 0;
}
@@ -161,7 +161,7 @@ public class SystemPoller {
line = in.readLine();
in.close();
} catch (IOException ex) {
- log.log(LogLevel.DEBUG, "Unable to read line from process stat file", ex);
+ log.log(Level.FINE, "Unable to read line from process stat file", ex);
return 0;
}
diff --git a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/telegraf/Telegraf.java b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/telegraf/Telegraf.java
index 25e2b9068ab..5c7d8b3ce83 100644
--- a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/telegraf/Telegraf.java
+++ b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/telegraf/Telegraf.java
@@ -76,7 +76,7 @@ public class Telegraf extends AbstractComponent {
ProcessResult processResult = uncheck(() -> processExecutor.execute(command))
.orElseThrow(() -> new RuntimeException("Timed out running command: " + command));
- logger.log(LogLevel.DEBUG, () -> String.format("Exit code: %d\nstdOut: %s\nstdErr: %s",
+ logger.log(Level.FINE, () -> String.format("Exit code: %d\nstdOut: %s\nstdErr: %s",
processResult.exitCode,
processResult.stdOut,
processResult.stdErr));
diff --git a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/telegraf/TelegrafRegistry.java b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/telegraf/TelegrafRegistry.java
index 0f36bf6125e..3864d25c2a6 100644
--- a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/telegraf/TelegrafRegistry.java
+++ b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/telegraf/TelegrafRegistry.java
@@ -18,12 +18,12 @@ public class TelegrafRegistry {
private static final Logger logger = Logger.getLogger(TelegrafRegistry.class.getName());
public void addInstance(Telegraf telegraf) {
- logger.log(LogLevel.DEBUG, () -> "Adding Telegraf instance to registry: " + telegraf.hashCode());
+ logger.log(Level.FINE, () -> "Adding Telegraf instance to registry: " + telegraf.hashCode());
telegrafInstances.add(telegraf);
}
public void removeInstance(Telegraf telegraf) {
- logger.log(LogLevel.DEBUG, () -> "Removing Telegraf instance from registry: " + telegraf.hashCode());
+ logger.log(Level.FINE, () -> "Removing Telegraf instance from registry: " + telegraf.hashCode());
telegrafInstances.remove(telegraf);
}