diff --git a/src/main/java/com/uid2/shared/health/PodTerminationMonitor.java b/src/main/java/com/uid2/shared/health/PodTerminationMonitor.java index 4b6ef50c..fc4e7115 100644 --- a/src/main/java/com/uid2/shared/health/PodTerminationMonitor.java +++ b/src/main/java/com/uid2/shared/health/PodTerminationMonitor.java @@ -2,8 +2,11 @@ import java.io.File; import java.util.concurrent.atomic.AtomicReference; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; public class PodTerminationMonitor implements IHealthComponent{ + private static final Logger LOGGER = LoggerFactory.getLogger(PodTerminationMonitor.class); private AtomicReference cachedPodTerminating = new AtomicReference<>(false); private long lastPodCheckTime = 0; private long fileCheckIntervalMs = 3000; @@ -33,8 +36,11 @@ public boolean isHealthy() { private boolean checkPodTerminating() { long currentTime = System.currentTimeMillis(); if (currentTime - lastPodCheckTime >= fileCheckIntervalMs) { - File file = new File(File.separator + "app" + File.separator + "pod_terminating"); + File file = new File(File.separator + "app" + File.separator + "pod_terminating" + File.separator +"pod_terminating"); boolean newStatus = file.exists(); + if (newStatus) { + LOGGER.info("pod will terminate soon"); + } cachedPodTerminating.set(newStatus); lastPodCheckTime = currentTime; }