Commit bddb75b9 authored by 黎博's avatar 黎博

新增修改服务类型接口

parent f94dfa1e
...@@ -234,6 +234,34 @@ public class K8sController { ...@@ -234,6 +234,34 @@ public class K8sController {
} }
} }
/**
* 修改服务类型:ClusterIP 或者 NodePort
* @param namespace
* @param serviceName
* @param type
* @return
*/
@PostMapping("/service/changeType")
public JsonResult changeServiceType(String namespace, String serviceName, Integer type) {
Service service = tkeService.getServiceDetail(namespace, serviceName);
if (service == null) {
return JsonResult.buildErrorStateResult("Service不存在!", false);
}
if (type == 1) {
service.getSpec().setType("ClusterIP");
service.getSpec().getPorts().forEach(servicePort -> servicePort.setNodePort(null));
service.getSpec().setClusterIP(null);
service.getSpec().setExternalTrafficPolicy(null);
} else if (type == 2) {
service.getSpec().setType("NodePort");
service.getSpec().setClusterIP(null);
} else {
return JsonResult.buildErrorStateResult("暂不支持此类型!", false);
}
boolean modifyResult = tkeService.modifyK8sService(service);
return modifyResult?JsonResult.buildSuccessResult("Service修改成功!"):JsonResult.buildErrorStateResult("Service修改失败!", false);
}
/** /**
* 根据类型获取所有的镜像名 * 根据类型获取所有的镜像名
* @param namespace qa-base,qa-ui,qa-java等 * @param namespace qa-base,qa-ui,qa-java等
......
...@@ -873,4 +873,7 @@ public class TkeService { ...@@ -873,4 +873,7 @@ public class TkeService {
return kubernetesClient.services().inNamespace(namespace).createOrReplace(service) != null; return kubernetesClient.services().inNamespace(namespace).createOrReplace(service) != null;
} }
public boolean modifyK8sService(Service service) {
return kubernetesClient.services().inNamespace(service.getMetadata().getNamespace()).createOrReplace(service) != null;
}
} }
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment