From b53e4c36d56adfb83974a18438c92dc282e3a7e2 Mon Sep 17 00:00:00 2001 From: Ola Aunrønning Date: Thu, 20 Feb 2020 15:50:06 +0100 Subject: Add some info and debug logging --- .../src/main/java/ai/vespa/metricsproxy/telegraf/Telegraf.java | 5 +++++ .../main/java/ai/vespa/metricsproxy/telegraf/TelegrafRegistry.java | 7 +++++++ 2 files changed, 12 insertions(+) (limited to 'metrics-proxy') 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 bf4f0d4c49b..1c8401d003a 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 @@ -11,6 +11,7 @@ import java.io.FileWriter; import java.io.InputStreamReader; import java.io.Reader; import java.io.Writer; +import java.util.logging.Logger; import static com.yahoo.yolean.Exceptions.uncheck; @@ -23,6 +24,8 @@ public class Telegraf extends AbstractComponent { private static final String TELEGRAF_CONFIG_TEMPLATE_PATH = "templates/telegraf.conf.vm"; private final TelegrafRegistry telegrafRegistry; + private static final Logger logger = Logger.getLogger(Telegraf.class.getName()); + @Inject public Telegraf(TelegrafRegistry telegrafRegistry, TelegrafConfig telegrafConfig) { this.telegrafRegistry = telegrafRegistry; @@ -44,10 +47,12 @@ public class Telegraf extends AbstractComponent { } private void restartTelegraf() { + logger.info("Restarting Telegraf"); executeCommand("service telegraf restart"); } private void stopTelegraf() { + logger.info("Stopping Telegraf"); executeCommand("service telegraf stop"); } 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 429da5bb933..5736766dbab 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 @@ -1,9 +1,12 @@ // Copyright 2020 Oath Inc. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root. package ai.vespa.metricsproxy.telegraf; +import com.yahoo.log.LogLevel; + import java.util.ArrayList; import java.util.Collections; import java.util.List; +import java.util.logging.Logger; /** * @author olaa @@ -12,11 +15,15 @@ public class TelegrafRegistry { private static final List telegrafInstances = Collections.synchronizedList(new ArrayList<>()); + private static final Logger logger = Logger.getLogger(TelegrafRegistry.class.getName()); + public void addInstance(Telegraf telegraf) { + logger.log(LogLevel.DEBUG, () -> "Adding Telegraf instance to registry"); telegrafInstances.add(telegraf); } public void removeInstance(Telegraf telegraf) { + logger.log(LogLevel.DEBUG, () -> "Removing Telegraf instance from registry"); telegrafInstances.remove(telegraf); } -- cgit v1.2.3