Skip to content

Commit cdd956c

Browse files
authored
Update PodTerminationMonitor.java
1 parent ee85cc3 commit cdd956c

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

src/main/java/com/uid2/shared/health/PodTerminationMonitor.java

+6
Original file line numberDiff line numberDiff line change
@@ -2,8 +2,11 @@
22

33
import java.io.File;
44
import java.util.concurrent.atomic.AtomicReference;
5+
import org.slf4j.Logger;
6+
import org.slf4j.LoggerFactory;
57

68
public class PodTerminationMonitor implements IHealthComponent{
9+
private static final Logger LOGGER = LoggerFactory.getLogger(PodTerminationMonitor.class);
710
private AtomicReference<Boolean> cachedPodTerminating = new AtomicReference<>(false);
811
private long lastPodCheckTime = 0;
912
private long fileCheckIntervalMs = 3000;
@@ -35,6 +38,9 @@ private boolean checkPodTerminating() {
3538
if (currentTime - lastPodCheckTime >= fileCheckIntervalMs) {
3639
File file = new File(File.separator + "app" + File.separator + "pod_terminating");
3740
boolean newStatus = file.exists();
41+
if (newStatus) {
42+
LOGGER.info("pod will terminate soon")
43+
}
3844
cachedPodTerminating.set(newStatus);
3945
lastPodCheckTime = currentTime;
4046
}

0 commit comments

Comments
 (0)