支持一个容器的一次性日志输出

Author: syswu

pom.xml

@@ -4,16 +4,17 @@
 	<modelVersion>4.0.0</modelVersion>
 	<groupId>io.github.kubesys</groupId>
 	<artifactId>client-java</artifactId>
-	<version>1.3.0</version>
+	<version>1.3.1</version>
 	<packaging>jar</packaging>
 	<name>client-java</name>
 	<url>http://maven.apache.org</url>
 	<properties>
 		<!-- project.version -->
 		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
 		<!-- code -->
-		<jackson.version>2.16.1</jackson.version>
+		<jackson.version>2.17.1</jackson.version>
 		<httpclient.version>5.3.1</httpclient.version>
+		<commons.io.version>2.16.1</commons.io.version>
 		<!-- test -->
 		<junit.version>5.10.2</junit.version>
 		<!-- build -->
@@ -34,6 +35,12 @@
 		</license>
 	</licenses>
 	<dependencies>
+		<!-- https://mvnrepository.com/artifact/commons-io/commons-io -->
+		<dependency>
+			<groupId>commons-io</groupId>
+			<artifactId>commons-io</artifactId>
+			<version>${commons.io.version}</version>
+		</dependency>
 		<!-- https://mvnrepository.com/artifact/com.fasterxml.jackson.core/jackson-core -->
 		<dependency>
 			<groupId>com.fasterxml.jackson.core</groupId>

src/main/java/io/github/kubesys/client/KubernetesClient.java

@@ -22,6 +22,7 @@
 import java.util.Map;
 import java.util.logging.Logger;
 
+import org.apache.commons.io.IOUtils;
 import org.apache.hc.client5.http.classic.methods.HttpDelete;
 import org.apache.hc.client5.http.classic.methods.HttpGet;
 import org.apache.hc.client5.http.classic.methods.HttpPost;
@@ -1297,6 +1298,31 @@ public KubernetesAdminConfig getKubernetesAdminConfig() {
 		return kubernetesAdminConfig;
 	}
 
+	/**
+	 * 
+	 * @param pod  pod
+	 * @return json json from Kubernetes
+	 * @throws Exception Kubernetes cannot parsing this jsonStr
+	 */
+	@Deprecated
+	public String getPodLog(String pod) throws Exception {
+		return getPodLog("default", pod);
+	}
+
+	/**
+	 * 
+	 * @param namespace namespace
+	 * @param pod  pod
+	 * @return json json from Kubernetes
+	 * @throws Exception Kubernetes cannot parsing this jsonStr
+	 */
+	@Deprecated
+	public String getPodLog(String namespace, String pod) throws Exception {
+		final String uri = analyzer.getConvertor().getUrl("Pod", namespace, pod) + "/log";
+		HttpGet request = ReqUtil.get(kubernetesAdminConfig, uri);
+		return IOUtils.toString(httpClient.execute(request).getEntity().getContent());
+	}
+	
 	/**
 	 * create a new HttpCaller for each WatchResource or WatchResources API
 	 * 

src/test/java/io/github/kubesys/client/examples/GetLogExample.java

@@ -0,0 +1,28 @@
+/**
+ * Copyright (2020, ) Institute of Software, Chinese Academy of Sciences
+ */
+package io.github.kubesys.client.examples;
+
+import java.nio.charset.StandardCharsets;
+import java.nio.file.Files;
+import java.nio.file.Paths;
+
+import io.github.kubesys.client.KubernetesClient;
+
+/**
+ * @author wuheng@iscas.ac.cn
+ * @since  2023.12.05
+ *
+ */
+public class GetLogExample {
+
+	/**
+	 * see KubernetesCertClientExample or KubernetesTokenClientExample
+	 */
+	static KubernetesClient client = null;
+	
+	public static void main(String[] args) throws Exception {
+		System.out.print(client.getPodLog("kube-flannel", "kube-flannel-ds-cthfj"));
+	}
+
+}