test-version22
/
MeterSphere
mirror of https://gitee.com/fit2cloud-feizhiyun/MeterSphere.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

chore: 修改监听函数的参数

This commit is contained in:
fit2-zhao 2024-10-14 12:18:43 +08:00
parent 6a75f21754
commit 1007d7f4eb
1 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
backend/services/api-test/src/main/java/io/metersphere/api/engine/KubernetesProvider.java
View File

@ -151,14 +151,14 @@ public class KubernetesProvider {
.writingOutput(System.out) .writingOutput(System.out)
.writingError(System.err) .writingError(System.err)
.withTTY() .withTTY()
.usingListener(new SimpleListener(runRequest, client)) .usingListener(new SimpleListener(runRequest))
.exec(SHELL_COMMAND, "-c", command); .exec(SHELL_COMMAND, "-c", command);
} catch (Exception e) { } catch (Exception e) {
LogUtils.error("Failed to execute command on pod {} ", pod.getMetadata().getName(), e); LogUtils.error("Failed to execute command on pod {} ", pod.getMetadata().getName(), e);
} }
} }
private record SimpleListener(Object runRequest, KubernetesClient client) implements ExecListener { private record SimpleListener(Object runRequest) implements ExecListener {
@Override @Override
public void onOpen() { public void onOpen() {
LogUtils.info("K8s 开启监听"); LogUtils.info("K8s 开启监听");
@ -175,8 +175,6 @@ public class KubernetesProvider {
@Override @Override
public void onClose(int code, String reason) { public void onClose(int code, String reason) {
LogUtils.info("K8s 监听关闭：code=" + code + ", reason=" + reason); LogUtils.info("K8s 监听关闭：code=" + code + ", reason=" + reason);
// 关闭客户端
client.close();
} }
} }