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

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

55 строк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.V1Pod;
import io.kubernetes.client.openapi.models.V1ReplicaSet;
import io.kubernetes.client.openapi.models.V1StatefulSet;
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 ReplicasetController {

    JSON json;

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

    private final String REPLICASETS_URL_PATH = "/replicasets";
    private final String REPLICASET_URL_PATH = "/replicaset";
    private final String REPLICASET_DELETE_URL_PATH = "/deletereplicaset";
    private final String REPLICASET_SCALE_URL_PATH = "/scalereplicaset";
    private final String PODS_BY_REPLICASET_URL_PATH = "/podsbyreplicaset";

    CommonController<V1ReplicaSet> commonController = new CommonController();

    CommonController<V1Pod> commonPodController = new CommonController();

    public CommonObjectsResponse<V1ReplicaSet> getReplicasetsByNamespace(String namespace) {
        return commonController.getObjectsByNamespace(namespace,
                SERVER + REPLICASETS_URL_PATH, V1ReplicaSet.class);
    }

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

    public CommonObjectResponse<V1ReplicaSet> getReplicasetByName(String name, String namespace) {
        return commonController.getObjectByName(name, namespace,
                SERVER + REPLICASET_URL_PATH, V1ReplicaSet.class);
    }

    public CommonObjectResponse<V1ReplicaSet> scaleReplicasetByName(String name, String namespace, int replicas) {
        return commonController.scaleObjectByName(name, namespace, replicas,
                SERVER + REPLICASET_SCALE_URL_PATH, V1ReplicaSet.class);
    }

    public CommonDeleteResponse deleteReplicasetByName(String name, String namespace) {
        return commonController.deleteObjectByName(name, namespace,
                SERVER + REPLICASET_DELETE_URL_PATH, V1ReplicaSet.class);
    }
}