Browse Source

Merge branch 'dev' of https://gitlink.org.cn/ci4s/ci4sManagement-cloud into dev

dev-restore_mount
fanshuai 1 year ago
parent
commit
2386d0d9d6
3 changed files with 4 additions and 13 deletions
  1. +1
    -1
      ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/service/impl/TensorBoardServiceImpl.java
  2. +3
    -3
      ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/utils/K8sClientUtil.java
  3. +0
    -9
      ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/vo/FrameLogPathVo.java

+ 1
- 1
ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/service/impl/TensorBoardServiceImpl.java View File

@@ -68,7 +68,7 @@ public class TensorBoardServiceImpl implements TensorBoardService {
LoginUser loginUser = SecurityUtils.getLoginUser();
String podName = loginUser.getUsername().toLowerCase()+"-"+frameLogPathVo.getPath().split("/")[2]+ "-tensorboard-pod";

Integer podPort = k8sClientUtil.createPodWithSubPath(podName, StringUtils.isEmpty(frameLogPathVo.getNamespace()) ? "default" : frameLogPathVo.getNamespace(), port, mountPath, frameLogPathVo.getPath(), frameLogPathVo.getPvcName(), image);
Integer podPort = k8sClientUtil.createPodWithSubPath(podName, StringUtils.isEmpty(frameLogPathVo.getNamespace()) ? "default" : frameLogPathVo.getNamespace(), port, mountPath, frameLogPathVo.getPath(), image);
redisService.setCacheObject(podName, masterIp + ":" + podPort);
return masterIp + ":" + podPort;
}


+ 3
- 3
ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/utils/K8sClientUtil.java View File

@@ -315,9 +315,9 @@ public class K8sClientUtil {
* @return 创建成功的pod,的nodePort端口
*/

public Integer createPodWithSubPath(String podName, String namespace, Integer port, String mountPath, String subPath, String pvcName, String image) {
public Integer createPodWithSubPath(String podName, String namespace, Integer port, String mountPath, String subPath, String image) {

Map<String, String> selector = new LinkedHashMap<String, String>();
Map<String, String> selector = new LinkedHashMap<>();
selector.put("k8s-jupyter", podName);

CoreV1Api api = new CoreV1Api(apiClient);
@@ -366,7 +366,7 @@ public class K8sClientUtil {
.endContainer()
.addNewVolume()
.withName("workspace")
.withHostPath(new V1HostPathVolumeSource().path(pvcName).type("DirectoryOrCreate"))
.withHostPath(new V1HostPathVolumeSource().path(hostPath).type("DirectoryOrCreate"))
// .withPersistentVolumeClaim(new V1PersistentVolumeClaimVolumeSource().claimName(pvcName))
.endVolume()
.withTerminationGracePeriodSeconds(14400L)


+ 0
- 9
ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/vo/FrameLogPathVo.java View File

@@ -9,7 +9,6 @@ import java.io.Serializable;
public class FrameLogPathVo implements Serializable {
String path;
String namespace;
String pvcName;

public String getPath() {
return path;
@@ -26,12 +25,4 @@ public class FrameLogPathVo implements Serializable {
public void setNamespace(String namespace) {
this.namespace = namespace;
}

public String getPvcName() {
return pvcName;
}

public void setPvcName(String pvcName) {
this.pvcName = pvcName;
}
}

Loading…
Cancel
Save