Request kube apiserver directly from frontend

kubernetes-sigs · Mar 12, 2022 · 64022a3 · 64022a3
1 parent 9b1f680
commit 64022a3
Show file tree

Hide file tree

Showing 11 changed files with 251 additions and 46 deletions.
diff --git a/docker-compose.yml b/docker-compose.yml
@@ -7,8 +7,11 @@ services:
       - PORT=1212
       - KUBE_SCHEDULER_SIMULATOR_ETCD_URL=http://simulator-etcd:2379
       - FRONTEND_URL=http://localhost:3000
+      - KUBE_API_HOST=0.0.0.0
+      - KUBE_API_PORT=3131
     ports:
       - "1212:1212"
+      - "3131:3131"
     restart: always
     tty: true
     networks:

diff --git a/k8sapiserver/k8sapiserver.go b/k8sapiserver/k8sapiserver.go
@@ -40,7 +40,7 @@ import (
 )
 
 // StartAPIServer starts API server, and it make panic when a error happen.
-func StartAPIServer(kubeAPIServerURL string, etcdURL string) (*restclient.Config, func(), error) {
+func StartAPIServer(kubeAPIServerURL, etcdURL, frontendURL string) (*restclient.Config, func(), error) {
 	h := &APIServerHolder{Initialized: make(chan struct{})}
 	handler := http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) {
 		<-h.Initialized
@@ -61,7 +61,7 @@ func StartAPIServer(kubeAPIServerURL string, etcdURL string) (*restclient.Config
 	s.Start()
 	klog.Info("kube-apiserver is started on :", s.URL)
 
-	c := NewControlPlaneConfigWithOptions(s.URL, etcdURL)
+	c := NewControlPlaneConfigWithOptions(s.URL, etcdURL, frontendURL)
 
 	_, _, closeFn, err := startAPIServer(c, s, h)
 	if err != nil {
@@ -103,7 +103,7 @@ func defaultOpenAPIConfig() *openapicommon.Config {
 }
 
 //nolint:funlen
-func NewControlPlaneConfigWithOptions(serverURL, etcdURL string) *controlplane.Config {
+func NewControlPlaneConfigWithOptions(serverURL, etcdURL, frontendURL string) *controlplane.Config {
 	etcdOptions := options.NewEtcdOptions(storagebackend.NewDefaultConfig(uuid.New().String(), nil))
 	etcdOptions.StorageConfig.Transport.ServerList = []string{etcdURL}
 
@@ -130,6 +130,8 @@ func NewControlPlaneConfigWithOptions(serverURL, etcdURL string) *controlplane.C
 
 	genericConfig.SecureServing = &genericapiserver.SecureServingInfo{Listener: fakeLocalhost443Listener{}}
 
+	genericConfig.CorsAllowedOriginList = []string{frontendURL}
+
 	err = etcdOptions.ApplyWithStorageFactoryTo(storageFactory, genericConfig)
 	if err != nil {
 		panic(err)

diff --git a/simulator.go b/simulator.go
@@ -31,7 +31,7 @@ func startSimulator() error {
 		return xerrors.Errorf("get config: %w", err)
 	}
 
-	restclientCfg, apiShutdown, err := k8sapiserver.StartAPIServer(cfg.KubeAPIServerURL, cfg.EtcdURL)
+	restclientCfg, apiShutdown, err := k8sapiserver.StartAPIServer(cfg.KubeAPIServerURL, cfg.EtcdURL, cfg.FrontendURL)
 	if err != nil {
 		return xerrors.Errorf("start API server: %w", err)
 	}

diff --git a/web/api/v1/index.ts b/web/api/v1/index.ts
@@ -5,3 +5,26 @@ export const instance = axios.create({
   baseURL,
   withCredentials: true,
 });
+
+const namespace = "default";
+export const namespaceURL = "namespaces/" + namespace;
+
+export const k8sBaseURL = process.env.KUBE_API_SERVER_URL + "/api/v1/";
+export const k8sInstance = axios.create({
+  baseURL: k8sBaseURL,
+  withCredentials: true,
+});
+
+export const k8sSchedulingBaseURL =
+  process.env.KUBE_API_SERVER_URL + "/apis/scheduling.k8s.io/v1/";
+export const k8sSchedulingInstance = axios.create({
+  baseURL: k8sSchedulingBaseURL,
+  withCredentials: true,
+});
+
+export const k8sStorageBaseURL =
+  process.env.KUBE_API_SERVER_URL + "/apis/storage.k8s.io/v1/";
+export const k8sStorageInstance = axios.create({
+  baseURL: k8sStorageBaseURL,
+  withCredentials: true,
+});
diff --git a/web/api/v1/node.ts b/web/api/v1/node.ts
@@ -1,26 +1,51 @@
 import { V1Node, V1NodeList } from "@kubernetes/client-node";
-import { instance } from "@/api/v1/index";
+import { k8sInstance } from "@/api/v1/index";
 
 export const applyNode = async (req: V1Node, onError: (_: string) => void) => {
   try {
-    const res = await instance.post<V1Node>(`/nodes`, req);
+    if (!req.metadata?.name) {
+      onError("metadata.name is not provided");
+      return;
+    }
+    const res = await k8sInstance.patch<V1Node>(
+      `/nodes/${req.metadata.name}?fieldManager=simulator`,
+      req,
+      { headers: { "Content-Type": "application/strategic-merge-patch+json" } }
+    );
     return res.data;
   } catch (e: any) {
-    onError(e);
+    try {
+      const res = await createNode(req, onError);
+      return res;
+    } catch (e: any) {
+      onError(e);
+    }
   }
 };
 
 export const listNode = async () => {
-  const res = await instance.get<V1NodeList>(`/nodes`, {});
+  const res = await k8sInstance.get<V1NodeList>(`/nodes`, {});
   return res.data;
 };
 
 export const getNode = async (name: string) => {
-  const res = await instance.get<V1Node>(`/nodes/${name}`, {});
+  const res = await k8sInstance.get<V1Node>(`/nodes/${name}`, {});
   return res.data;
 };
 
 export const deleteNode = async (name: string) => {
-  const res = await instance.delete(`/nodes/${name}`, {});
+  const res = await k8sInstance.delete(`/nodes/${name}`, {});
   return res.data;
 };
+
+const createNode = async (req: V1Node, onError: (_: string) => void) => {
+  try {
+    const res = await k8sInstance.post<V1Node>(
+      `/nodes?fieldManager=simulator`,
+      req
+    );
+    return res.data;
+  } catch (e: any) {
+    onError(e);
+  }
+};
diff --git a/web/api/v1/pod.ts b/web/api/v1/pod.ts
@@ -1,26 +1,54 @@
 import { V1Pod, V1PodList } from "@kubernetes/client-node";
-import { instance } from "@/api/v1/index";
+import { k8sInstance, namespaceURL } from "@/api/v1/index";
 
 export const applyPod = async (req: V1Pod, onError: (_: string) => void) => {
   try {
-    const res = await instance.post<V1Pod>(`/pods`, req);
+    if (!req.metadata?.name) {
+      onError("metadata.name is not provided");
+      return;
+    }
+    const res = await k8sInstance.patch<V1Pod>(
+      namespaceURL + `/pods/${req.metadata.name}?fieldManager=simulator`,
+      req,
+      { headers: { "Content-Type": "application/strategic-merge-patch+json" } }
+    );
     return res.data;
   } catch (e: any) {
-    onError(e);
+    try {
+      const res = await createPod(req, onError);
+      return res;
+    } catch (e: any) {
+      onError(e);
+    }
   }
 };
 
 export const listPod = async () => {
-  const res = await instance.get<V1PodList>(`/pods`, {});
+  const res = await k8sInstance.get<V1PodList>(namespaceURL + `/pods`, {});
   return res.data;
 };
 
 export const getPod = async (name: string) => {
-  const res = await instance.get<V1Pod>(`/pods/${name}`, {});
+  const res = await k8sInstance.get<V1Pod>(namespaceURL + `/pods/${name}`, {});
   return res.data;
 };
 
 export const deletePod = async (name: string) => {
-  const res = await instance.delete(`/pods/${name}`, {});
+  const res = await k8sInstance.delete(
+    namespaceURL + `/pods/${name}?gracePeriodSeconds=0`,
+    {}
+  );
   return res.data;
 };
+
+const createPod = async (req: V1Pod, onError: (_: string) => void) => {
+  try {
+    const res = await k8sInstance.post<V1Pod>(
+      namespaceURL + `/pods?fieldManager=simulator`,
+      req
+    );
+    return res.data;
+  } catch (e: any) {
+    onError(e);
+  }
+};
diff --git a/web/api/v1/priorityclass.ts b/web/api/v1/priorityclass.ts
@@ -1,32 +1,66 @@
 import { V1PriorityClass, V1PriorityClassList } from "@kubernetes/client-node";
-import { instance } from "@/api/v1/index";
+import { k8sSchedulingInstance } from "@/api/v1/index";
 
 export const applyPriorityClass = async (
   req: V1PriorityClass,
   onError: (_: string) => void
 ) => {
   try {
-    const res = await instance.post<V1PriorityClass>(`/priorityclasses`, req);
+    if (!req.metadata?.name) {
+      onError("metadata.name is not provided");
+      return;
+    }
+    const res = await k8sSchedulingInstance.patch<V1PriorityClass>(
+      `/priorityclasses/${req.metadata.name}?fieldManager=simulator`,
+      req,
+      { headers: { "Content-Type": "application/strategic-merge-patch+json" } }
+    );
     return res.data;
   } catch (e: any) {
-    onError(e);
+    try {
+      const res = await createPriorityClass(req, onError);
+      return res;
+    } catch (e: any) {
+      onError(e);
+    }
   }
 };
 
 export const listPriorityClass = async () => {
-  const res = await instance.get<V1PriorityClassList>(`/priorityclasses`, {});
+  const res = await k8sSchedulingInstance.get<V1PriorityClassList>(
+    `/priorityclasses`,
+    {}
+  );
   return res.data;
 };
 
 export const getPriorityClass = async (name: string) => {
-  const res = await instance.get<V1PriorityClass>(
+  const res = await k8sSchedulingInstance.get<V1PriorityClass>(
     `/priorityclasses/${name}`,
     {}
   );
   return res.data;
 };
 
 export const deletePriorityClass = async (name: string) => {
-  const res = await instance.delete(`/priorityclasses/${name}`, {});
+  const res = await k8sSchedulingInstance.delete(
+    `/priorityclasses/${name}`,
+    {}
+  );
   return res.data;
 };
+
+const createPriorityClass = async (
+  req: V1PriorityClass,
+  onError: (_: string) => void
+) => {
+  try {
+    const res = await k8sSchedulingInstance.post<V1PriorityClass>(
+      `/priorityclasses?fieldManager=simulator`,
+      req
+    );
+    return res.data;
+  } catch (e: any) {
+    onError(e);
+  }
+};
diff --git a/web/api/v1/pv.ts b/web/api/v1/pv.ts
@@ -2,40 +2,65 @@ import {
   V1PersistentVolume,
   V1PersistentVolumeList,
 } from "@kubernetes/client-node";
-import { instance } from "@/api/v1/index";
+import { k8sInstance } from "@/api/v1/index";
 
 export const applyPersistentVolume = async (
   req: V1PersistentVolume,
   onError: (_: string) => void
 ) => {
   try {
-    const res = await instance.post<V1PersistentVolume>(
-      `/persistentvolumes`,
-      req
+    if (!req.metadata?.name) {
+      onError("metadata.name is not provided");
+      return;
+    }
+    const res = await k8sInstance.patch<V1PersistentVolume>(
+      `/persistentvolumes/${req.metadata.name}?fieldManager=simulator`,
+      req,
+      { headers: { "Content-Type": "application/strategic-merge-patch+json" } }
     );
     return res.data;
   } catch (e: any) {
-    onError(e);
+    try {
+      const res = await createPersistentvolumes(req, onError);
+      return res;
+    } catch (e: any) {
+      onError(e);
+    }
   }
 };
 
 export const listPersistentVolume = async () => {
-  const res = await instance.get<V1PersistentVolumeList>(
+  const res = await k8sInstance.get<V1PersistentVolumeList>(
     `/persistentvolumes`,
     {}
   );
   return res.data;
 };
 
 export const getPersistentVolume = async (name: string) => {
-  const res = await instance.get<V1PersistentVolume>(
+  const res = await k8sInstance.get<V1PersistentVolume>(
     `/persistentvolumes/${name}`,
     {}
   );
   return res.data;
 };
 
 export const deletePersistentVolume = async (name: string) => {
-  const res = await instance.delete(`/persistentvolumes/${name}`, {});
+  const res = await k8sInstance.delete(`/persistentvolumes/${name}`, {});
   return res.data;
 };
+
+const createPersistentvolumes = async (
+  req: V1PersistentVolume,
+  onError: (_: string) => void
+) => {
+  try {
+    const res = await k8sInstance.post<V1PersistentVolume>(
+      `/persistentvolumes?fieldManager=simulator`,
+      req
+    );
+    return res.data;
+  } catch (e: any) {
+    onError(e);
+  }
+};