checkstyle

Signed-off-by: wind57 <[email protected]>

Author: wind57

spring-cloud-kubernetes-commons/src/main/java/org/springframework/cloud/kubernetes/commons/CachedSingleThreadScheduler.java

@@ -24,23 +24,24 @@
 import java.util.concurrent.locks.ReentrantLock;
 
 /**
- * This is taken from fabric8 with some minor changes
- * (we need it, so it could be placed in the common package)
+ * This is taken from fabric8 with some minor changes (we need it, so it could be placed
+ * in the common package).
+ *
  * @author wind57
  */
 public final class CachedSingleThreadScheduler {
 
 	private final ReentrantLock lock = new ReentrantLock();
 
 	private final long ttlMillis;
+
 	private ScheduledThreadPoolExecutor executor;
 
 	public CachedSingleThreadScheduler(long ttlMillis) {
 		this.ttlMillis = ttlMillis;
 	}
 
-	public ScheduledFuture<?> scheduleWithFixedDelay(Runnable command, long initialDelay,
-			long delay, TimeUnit unit) {
+	public ScheduledFuture<?> scheduleWithFixedDelay(Runnable command, long initialDelay, long delay, TimeUnit unit) {
 		try {
 			lock.lock();
 			this.startExecutor();
@@ -66,7 +67,8 @@ private void startExecutor() {
 		if (this.executor == null) {
 			this.executor = new ScheduledThreadPoolExecutor(1, threadFactory());
 			this.executor.setRemoveOnCancelPolicy(true);
-			this.executor.scheduleWithFixedDelay(this::shutdownCheck, this.ttlMillis, this.ttlMillis, TimeUnit.MILLISECONDS);
+			this.executor.scheduleWithFixedDelay(this::shutdownCheck, this.ttlMillis, this.ttlMillis,
+					TimeUnit.MILLISECONDS);
 		}
 
 	}

spring-cloud-kubernetes-commons/src/main/java/org/springframework/cloud/kubernetes/commons/PodReady.java

@@ -16,12 +16,12 @@
 
 package org.springframework.cloud.kubernetes.commons;
 
-import org.springframework.core.log.LogAccessor;
-
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.TimeUnit;
 import java.util.function.BooleanSupplier;
 
+import org.springframework.core.log.LogAccessor;
+
 /**
  * @author wind57
  */
@@ -30,8 +30,7 @@ public final class PodReady {
 	private static final LogAccessor LOG = new LogAccessor(PodReady.class);
 
 	private final CachedSingleThreadScheduler podReadyScheduler = new CachedSingleThreadScheduler(
-		TimeUnit.SECONDS.toMillis(10)
-	);
+			TimeUnit.SECONDS.toMillis(10));
 
 	public CompletableFuture<Void> podReady(BooleanSupplier isPodReady, String holderIdentity, String podNamespace) {
 
@@ -41,14 +40,14 @@ public CompletableFuture<Void> podReady(BooleanSupplier isPodReady, String holde
 
 			try {
 				LOG.info(() -> "waiting for pod : " + holderIdentity + " in namespace : " + podNamespace
-					+ " to be ready");
+						+ " to be ready");
 				if (isPodReady.getAsBoolean()) {
 					LOG.info(() -> "Pod : " + holderIdentity + " in namespace : " + podNamespace + " is ready");
 					podReadyFuture.complete(null);
 				}
 				else {
-					LOG.debug(() -> "Pod : " + holderIdentity + " in namespace : " + podNamespace
-						+ " is not ready, " + "will retry in one second");
+					LOG.debug(() -> "Pod : " + holderIdentity + " in namespace : " + podNamespace + " is not ready, "
+							+ "will retry in one second");
 				}
 			}
 			catch (Exception e) {

spring-cloud-kubernetes-fabric8-leader/src/main/java/org/springframework/cloud/kubernetes/fabric8/leader/election/Fabric8LeaderElectionInitiator.java

@@ -29,7 +29,6 @@
 import io.fabric8.kubernetes.client.extended.leaderelection.LeaderElectionConfig;
 import io.fabric8.kubernetes.client.extended.leaderelection.LeaderElector;
 import io.fabric8.kubernetes.client.readiness.Readiness;
-import io.fabric8.kubernetes.client.utils.CachedSingleThreadScheduler;
 import jakarta.annotation.PostConstruct;
 import jakarta.annotation.PreDestroy;
 
@@ -97,7 +96,8 @@ void postConstruct() {
 				return Readiness.isPodReady(pod);
 			}, holderIdentity, podNamespace);
 
-		} else {
+		}
+		else {
 			podReadyFuture = new CompletableFuture<>();
 		}