Fix code format and new Guava usage

Signed-off-by: Dave Syer <dsyer@vmware.com>

Author: Dave Syer

extended/src/main/java/io/kubernetes/client/extended/controller/Controllers.java

@@ -16,10 +16,7 @@
 import io.kubernetes.client.extended.controller.reconciler.Request;
 import io.kubernetes.client.openapi.models.V1ObjectMeta;
 import io.kubernetes.client.util.Threads;
-
-import java.util.concurrent.Executors;
 import java.util.concurrent.ThreadFactory;
-import java.util.concurrent.atomic.AtomicInteger;
 import java.util.function.Function;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;

extended/src/main/java/io/kubernetes/client/extended/leaderelection/LeaderElector.java

@@ -12,6 +12,8 @@
 */
 package io.kubernetes.client.extended.leaderelection;
 
+import io.kubernetes.client.openapi.ApiException;
+import io.kubernetes.client.util.Threads;
 import java.net.HttpURLConnection;
 import java.time.Duration;
 import java.util.Date;
@@ -28,13 +30,9 @@
 import java.util.concurrent.TimeoutException;
 import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.function.Consumer;
-
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import io.kubernetes.client.openapi.ApiException;
-import io.kubernetes.client.util.Threads;
-
 public class LeaderElector implements AutoCloseable {
 
   private static final Logger log = LoggerFactory.getLogger(LeaderElector.class);

spring/src/main/java/io/kubernetes/client/spring/extended/manifests/KubernetesFromYamlProcessor.java

@@ -12,7 +12,6 @@
 */
 package io.kubernetes.client.spring.extended.manifests;
 
-import com.google.common.io.Resources;
 import io.kubernetes.client.spring.extended.manifests.annotation.FromYaml;
 import io.kubernetes.client.util.Yaml;
 import java.io.IOException;
@@ -91,7 +90,7 @@ private Object loadFromYaml(String targetFilePath) {
     Path targetPath = Paths.get(targetFilePath);
     if (!Files.exists(Paths.get(targetFilePath))) { // checks if it exists on the machine
       // otherwise use load from classpath resources
-      Path classPath = Paths.get(Resources.getResource(targetFilePath).getPath());
+      Path classPath = Paths.get(getClass().getClassLoader().getResource(targetFilePath).getPath());
       if (Files.exists(classPath)) { // use classpath it works
         targetPath = classPath;
       } else {

util/src/main/java/io/kubernetes/client/informer/cache/Controller.java

@@ -12,6 +12,11 @@
 */
 package io.kubernetes.client.informer.cache;
 
+import io.kubernetes.client.common.KubernetesListObject;
+import io.kubernetes.client.common.KubernetesObject;
+import io.kubernetes.client.informer.ListerWatcher;
+import io.kubernetes.client.informer.ResyncRunnable;
+import io.kubernetes.client.util.Threads;
 import java.util.Deque;
 import java.util.concurrent.Executors;
 import java.util.concurrent.RejectedExecutionException;
@@ -20,17 +25,10 @@
 import java.util.concurrent.TimeUnit;
 import java.util.function.Consumer;
 import java.util.function.Supplier;
-
 import org.apache.commons.lang3.tuple.MutablePair;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import io.kubernetes.client.common.KubernetesListObject;
-import io.kubernetes.client.common.KubernetesObject;
-import io.kubernetes.client.informer.ListerWatcher;
-import io.kubernetes.client.informer.ResyncRunnable;
-import io.kubernetes.client.util.Threads;
-
 /**
  * Controller is a java port of k/client-go's informer#Controller. It plumbs reflector and the queue
  * implementation and it runs re-sync function periodically.
@@ -84,12 +82,12 @@ public Controller(
     // starts one daemon thread for reflector
     this.reflectExecutor =
         Executors.newSingleThreadScheduledExecutor(
-          Threads.threadFactory("controller-reflector-" + apiTypeClass.getName() + "-%d"));
+            Threads.threadFactory("controller-reflector-" + apiTypeClass.getName() + "-%d"));
 
     // starts one daemon thread for resync
     this.resyncExecutor =
         Executors.newSingleThreadScheduledExecutor(
-          Threads.threadFactory("controller-reflector-" + apiTypeClass.getName() + "-%d"));
+            Threads.threadFactory("controller-reflector-" + apiTypeClass.getName() + "-%d"));
   }
 
   public Controller(

util/src/main/java/io/kubernetes/client/util/Threads.java

@@ -17,7 +17,7 @@
 import java.util.concurrent.atomic.AtomicInteger;
 
 public class Threads {
-  
+
   public static ThreadFactory threadFactory(String format) {
     final ThreadFactory defaultFactory = Executors.defaultThreadFactory();
     final AtomicInteger threadNumber = new AtomicInteger(1);