src/main/java/web/kubernetes/controllers/PVCController.java - master - timpson/k8_loader_vaadin

src/main/java/web/kubernetes/controllers/PVCController.java

57 строк2 KB

root

added ingress endpoint job pvc pv sc info views

10 июн 2022, 16:59

10 июн 2022, 16:59951dc08

package web.kubernetes.controllers;

import io.kubernetes.client.openapi.JSON;
import io.kubernetes.client.openapi.models.V1Job;
import io.kubernetes.client.openapi.models.V1PersistentVolumeClaim;
import io.kubernetes.client.openapi.models.V1Pod;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import web.kubernetes.payloads.responses.CommonDeleteResponse;
import web.kubernetes.payloads.responses.CommonObjectResponse;
import web.kubernetes.payloads.responses.CommonObjectsResponse;

@Component
public class PVCController {

    JSON json;

    @Value("${k8s.url}")
    private String SERVER;

    private final String PVCs_URL_PATH = "/pvcs";
    private final String PVC_URL_PATH = "/pvc";
    private final String PVC_DELETE_URL_PATH = "/deletepvc";
    private final String PODS_BY_PVC_URL_PATH = "/podsbypvc";
    private final String PVC_BY_SC_URL_PATH = "/pvcsbysc";

    CommonController<V1PersistentVolumeClaim> commonController = new CommonController();
    CommonController<V1Pod> commonPodController = new CommonController();

    public CommonObjectsResponse<V1PersistentVolumeClaim> getPVCsByNamespace(String namespace) {
        return commonController.getObjectsByNamespace(namespace,
                SERVER + PVCs_URL_PATH, V1PersistentVolumeClaim.class);
    }

    public CommonObjectResponse<V1PersistentVolumeClaim> getPVCByName(String name, String namespace) {
        return commonController.getObjectByName(name, namespace,
                SERVER + PVC_URL_PATH, V1PersistentVolumeClaim.class);
    }

    public CommonObjectResponse<V1PersistentVolumeClaim> getPVCBySC(String name, String namespace) {
        return commonController.getObjectByName(name, namespace,
                SERVER + PVC_BY_SC_URL_PATH, V1PersistentVolumeClaim.class);
    }

    public CommonObjectsResponse<V1Pod> getPodsByPVC(String name, String namespace) {
        return commonPodController.getObjectsByObjects(name,namespace,
                SERVER + PODS_BY_PVC_URL_PATH, V1Pod.class);
    }


    public CommonDeleteResponse deletePVCByName(String name, String namespace) {
        return commonController.deleteObjectByName(name, namespace,
                SERVER + PVC_DELETE_URL_PATH, V1PersistentVolumeClaim.class);
    }


}