|
|
@@ -8,6 +8,7 @@ import cn.seecoder.paas.service.facade.k8s.model.LabelSelector;
|
|
|
import cn.seecoder.paas.service.facade.k8s.model.PersistentVolumeClaim;
|
|
|
import cn.seecoder.paas.util.LoggerUtil;
|
|
|
import com.google.gson.JsonSyntaxException;
|
|
|
+import io.kubernetes.client.custom.V1Patch;
|
|
|
import io.kubernetes.client.openapi.ApiException;
|
|
|
import io.kubernetes.client.openapi.apis.CoreV1Api;
|
|
|
import io.kubernetes.client.openapi.models.*;
|
|
|
@@ -69,7 +70,8 @@ public class PersistentVolumeClaimImpl implements PersistentVolumeClaimApi {
|
|
|
try {
|
|
|
V1PersistentVolumeClaim v1PersistentVolumeClaim = getV1PersistenceVolumeClaim(persistentVolumeClaim.getNamespace(), persistentVolumeClaim.getName());
|
|
|
persistentVolumeClaim.merge(v1PersistentVolumeClaim);
|
|
|
- V1PersistentVolumeClaim result = coreV1Api.replaceNamespacedPersistentVolumeClaim(persistentVolumeClaim.getName(), persistentVolumeClaim.getNamespace(), v1PersistentVolumeClaim, PRETTY_FORMAT, null, null);
|
|
|
+ V1Patch v1Patch = new V1Patch("{\"spec\":{\"resources\":{\"requests\":{\"storage\":\""+ persistentVolumeClaim.getQuantity().toSuffixedString() +"\"}}}}}");
|
|
|
+ V1PersistentVolumeClaim result = coreV1Api.patchNamespacedPersistentVolumeClaim(persistentVolumeClaim.getName(), persistentVolumeClaim.getNamespace(), v1Patch, PRETTY_FORMAT, null, null, null);
|
|
|
return result == null ? null : new PersistentVolumeClaim(result);
|
|
|
} catch (ApiException e) {
|
|
|
LoggerUtil.error(logger, e, "persistentVolumeClaim 更新失败, persistentVolumeClaim={}, response={}", persistentVolumeClaim, e.getResponseBody());
|