diff --git a/examples/pom.xml b/examples/pom.xml
index 1bddc60435..2e6169cd52 100644
--- a/examples/pom.xml
+++ b/examples/pom.xml
@@ -27,11 +27,21 @@
client-java-proto
1.0.0-beta5-SNAPSHOT
+
+ com.google.code.gson
+ gson
+ 2.6.2
+
com.google.guava
guava
- 22.0
+ 21.0
+
+ io.fabric8
+ kubernetes-api
+ 2.0.37
+
junit
diff --git a/examples/src/main/java/io/kubernetes/client/examples/WatchExample.java b/examples/src/main/java/io/kubernetes/client/examples/WatchExample.java
index 4b5afab4d0..3a1997b0a1 100644
--- a/examples/src/main/java/io/kubernetes/client/examples/WatchExample.java
+++ b/examples/src/main/java/io/kubernetes/client/examples/WatchExample.java
@@ -12,16 +12,19 @@
*/
package io.kubernetes.client.examples;
-import com.google.gson.reflect.TypeToken;
+import java.io.IOException;
+import java.util.Map;
+import java.util.concurrent.TimeUnit;
+
+import com.google.gson.Gson;
+
import io.kubernetes.client.ApiClient;
import io.kubernetes.client.ApiException;
import io.kubernetes.client.Configuration;
import io.kubernetes.client.apis.CoreV1Api;
-import io.kubernetes.client.models.V1Namespace;
+import io.kubernetes.client.models.V1Node;
+import io.kubernetes.client.models.V1NodeList;
import io.kubernetes.client.util.Config;
-import io.kubernetes.client.util.Watch;
-import java.io.IOException;
-import java.util.concurrent.TimeUnit;
/** A simple example of how to use Watch API to watch changes in Namespace list. */
public class WatchExample {
@@ -30,17 +33,34 @@ public static void main(String[] args) throws IOException, ApiException {
client.getHttpClient().setReadTimeout(60, TimeUnit.SECONDS);
Configuration.setDefaultApiClient(client);
- CoreV1Api api = new CoreV1Api();
-
- Watch watch =
- Watch.createWatch(
- client,
- api.listNamespaceCall(
- null, null, null, null, null, 5, null, null, Boolean.TRUE, null, null),
- new TypeToken>() {}.getType());
+ CoreV1Api api = new CoreV1Api(client);
- for (Watch.Response item : watch) {
- System.out.printf("%s : %s%n", item.type, item.object.getMetadata().getName());
- }
+// Watch watch =
+// Watch.createWatch(
+// client,
+// api.listNamespaceCall(
+// null, null, null, null, null, 5, null, null, Boolean.TRUE, null, null),
+// new TypeToken>() {}.getType());
+//
+// for (Watch.Response item : watch) {
+// System.out.printf("%s : %s%n", item.type, item.object.getMetadata().getName());
+// }
+
+ V1NodeList nodeList = null;
+ try {
+ nodeList = api.listNode("true", null, null, null, null, null, null, null, null);
+ for (V1Node node : nodeList.getItems()) {
+ Map map = node.getMetadata().getLabels();
+ // Map> deviceMap = new HashMap<>();
+ System.out.println(new Gson().toJson(map));
+ for (Map.Entry entry : map.entrySet()) {
+ //if(entry.getKey().indexOf("hostname") > -1 || entry.getKey().indexOf("network-device") > -1) {
+ //System.out.println(entry.getKey() + " : " + entry.getValue());
+ //}
+ }
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
}
}
diff --git a/kubernetes/src/main/java/io/kubernetes/client/ApiClient.java b/kubernetes/src/main/java/io/kubernetes/client/ApiClient.java
index c6bccd3464..4cba142b91 100644
--- a/kubernetes/src/main/java/io/kubernetes/client/ApiClient.java
+++ b/kubernetes/src/main/java/io/kubernetes/client/ApiClient.java
@@ -52,7 +52,7 @@
public class ApiClient {
- private String basePath = "https://localhost";
+ private String basePath = "https://api.system.svc.31.tess.io";
private boolean debugging = false;
private Map defaultHeaderMap = new HashMap();
private String tempFolderPath = null;
diff --git a/kubernetes/src/main/java/io/kubernetes/client/custom/SuffixFormatter.java b/kubernetes/src/main/java/io/kubernetes/client/custom/SuffixFormatter.java
index 03671cc9c1..2a219da30d 100644
--- a/kubernetes/src/main/java/io/kubernetes/client/custom/SuffixFormatter.java
+++ b/kubernetes/src/main/java/io/kubernetes/client/custom/SuffixFormatter.java
@@ -34,7 +34,7 @@ public class SuffixFormatter {
private static final Map decimalToSuffix = new HashMap() {
{
- for (Entry entry : suffixToDecimal.entrySet()) {
+ for (java.util.Map.Entry entry : suffixToDecimal.entrySet()) {
put(entry.getValue(), entry.getKey());
}
}
@@ -42,7 +42,7 @@ public class SuffixFormatter {
private static final Map binaryToSuffix = new HashMap() {
{
- for (Entry entry : suffixToBinary.entrySet()) {
+ for (java.util.Map.Entry entry : suffixToBinary.entrySet()) {
put(entry.getValue(), entry.getKey());
}
}
diff --git a/util/src/main/java/io/kubernetes/client/util/credentials/AccessTokenAuthentication.java b/util/src/main/java/io/kubernetes/client/util/credentials/AccessTokenAuthentication.java
index 9e309fe176..affd3a57e6 100644
--- a/util/src/main/java/io/kubernetes/client/util/credentials/AccessTokenAuthentication.java
+++ b/util/src/main/java/io/kubernetes/client/util/credentials/AccessTokenAuthentication.java
@@ -1,6 +1,5 @@
package io.kubernetes.client.util.credentials;
-import com.google.common.base.Preconditions;
import io.kubernetes.client.ApiClient;
/** Uses a Bearer Token to configure {@link ApiClient} authentication to the Kubernetes API. */
@@ -8,7 +7,6 @@ public class AccessTokenAuthentication implements Authentication {
private String token;
public AccessTokenAuthentication(final String token) {
- Preconditions.checkNotNull(token, "Access Token cannot be null");
this.token = token;
}