From 4ca1ece8a725c35a025392d087eeaf766b444c2e Mon Sep 17 00:00:00 2001
From: erabii <eugen.rabii@gmail.com>
Date: Tue, 23 May 2023 15:39:45 +0300
Subject: [PATCH] Add cluster logs (#1353)

---
 .../tests/commons/native_client/Util.java     | 24 ++++++++++++++++++-
 1 file changed, 23 insertions(+), 1 deletion(-)

diff --git a/spring-cloud-kubernetes-test-support/src/main/java/org/springframework/cloud/kubernetes/integration/tests/commons/native_client/Util.java b/spring-cloud-kubernetes-test-support/src/main/java/org/springframework/cloud/kubernetes/integration/tests/commons/native_client/Util.java
index 12638032..fc9d5769 100644
--- a/spring-cloud-kubernetes-test-support/src/main/java/org/springframework/cloud/kubernetes/integration/tests/commons/native_client/Util.java
+++ b/spring-cloud-kubernetes-test-support/src/main/java/org/springframework/cloud/kubernetes/integration/tests/commons/native_client/Util.java
@@ -136,6 +136,8 @@ public final class Util {
 				System.out.println(apiException.getResponseBody());
 			}
 			e.printStackTrace();
+			LOG.info("events : " + events());
+			LOG.info("describe deployment : " + describeDeployment(deployment));
 			throw new RuntimeException(e);
 		}
 	}
@@ -532,7 +534,7 @@ public final class Util {
 	}
 
 	private void waitForDeploymentToBeDeleted(String deploymentName, String namespace) {
-		await().timeout(Duration.ofSeconds(90)).until(() -> {
+		await().timeout(Duration.ofSeconds(180)).until(() -> {
 			try {
 				appsV1Api.readNamespacedDeployment(deploymentName, namespace, null);
 				return false;
@@ -609,6 +611,26 @@ public final class Util {
 		return labels.entrySet().stream().map(en -> en.getKey() + "=" + en.getValue()).collect(Collectors.joining(","));
 	}
 
+	private String events() {
+		try {
+			return container.execInContainer("sh", "-c", "kubectl get events").getStdout();
+		}
+		catch (Exception e) {
+			throw new RuntimeException(e);
+		}
+	}
+
+	private String describeDeployment(V1Deployment deployment) {
+		try {
+			return container
+					.execInContainer("sh", "-c", "kubectl describe deployment " + deployment.getMetadata().getName())
+					.getStdout();
+		}
+		catch (Exception e) {
+			throw new RuntimeException(e);
+		}
+	}
+
 	private interface CheckedSupplier<T> {
 
 		T get() throws Exception;