Skip to content

Commit 5d772a4

Browse files
committed
return null when can not get IP
1 parent a4c9cb9 commit 5d772a4

2 files changed

Lines changed: 8 additions & 13 deletions

File tree

src/main/java/org/hobbit/utils/kubernetes/KubeHelper.java

Lines changed: 7 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -6,11 +6,9 @@
66

77
import java.net.InetAddress;
88
import java.net.UnknownHostException;
9-
import java.util.Optional;
109

1110
public class KubeHelper {
1211
private static final Logger LOGGER = LoggerFactory.getLogger(KubeHelper.class);
13-
private static final String DEFAULT_IP = "unknown";
1412
private static final String DOMAIN_SUFFIX = ".pod.cluster.local";
1513
private static final HobbitConfiguration HC = new HobbitConfiguration();
1614
/**
@@ -20,19 +18,16 @@ public class KubeHelper {
2018
*/
2119
public static String getDnsFriendlyIP() {
2220
String namespace = HC.getString("POD_NAMESPACE","default");
21+
2322
if(namespace.equals("default") ) {
2423
LOGGER.warn("No pod namespace found in environment variable POD_NAMESPACE use default");
2524
}
25+
2626
String ip = getPodIP();
2727

28-
if (!DEFAULT_IP.equals(ip)) {
29-
String valueToReturn = formatDnsFriendlyIp(ip, namespace);
30-
LOGGER.info("dns friendly version for {} in namespace {} is {}", ip, namespace, valueToReturn);
31-
return valueToReturn;
32-
} else {
33-
LOGGER.error("Error getting pod IP: {} in namespace: {}", ip, namespace);
34-
throw new IllegalStateException("Error getting pod IP: " + ip + " in namespace: " + namespace);
35-
}
28+
String valueToReturn = formatDnsFriendlyIp(ip, namespace);
29+
LOGGER.info("dns friendly version for {} in namespace {} is {}", ip, namespace, valueToReturn);
30+
return valueToReturn;
3631
}
3732

3833
/**
@@ -44,8 +39,8 @@ public static String getPodIP() {
4439
try {
4540
return InetAddress.getLocalHost().getHostAddress();
4641
} catch (UnknownHostException e) {
47-
LOGGER.warn("Failed to retrieve pod IP, returning default value: {}", DEFAULT_IP, e);
48-
return DEFAULT_IP;
42+
LOGGER.error("Failed to retrieve pod IP", e);
43+
throw new IllegalStateException("Failed to retrieve pod IP", e);
4944
}
5045
}
5146

src/test/java/org/hobbit/utils/kubernetes/KubeHelperTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@ public void testGetDnsFriendlyIP() {
1919
String podIP = KubeHelper.getPodIP();
2020
HobbitConfiguration HC = new HobbitConfiguration();
2121
String namespace = HC.getString("POD_NAMESPACE","default");
22-
if (!podIP.equals("unknown")) {
22+
if (podIP != null) {
2323
String dnsFriendlyIP = KubeHelper.getDnsFriendlyIP();
2424
assertTrue(dnsFriendlyIP.contains(namespace)); // Must include the namespace
2525
assertTrue(dnsFriendlyIP.contains("-")); // IP should be hyphenated

0 commit comments

Comments
 (0)