添加QKE 功能支持

app/service.js

@@ -20,7 +20,7 @@ const {
   replicaSetDelete,
   pvcDelete,
 } = require('../kubeService/service')
-const newClient = require('./../resource/getClient')
+const getClient = require('./../resource/getClient')
 
 const router = new Router()
 module.exports = router
@@ -174,12 +174,26 @@ router.get('/listEnvVars', async (ctx) => {
 })
 
 // for container
+const clientNew = {}
 router.get('/listEnvVarsNew', async (ctx) => {
   const envVars = {}
-  const { namespace, client } = newClient(ctx)
+  let cluster;
+  let namespace;
+  const parmars = ctx.request.query.namespace || ''
+  if (parmars.search('@') === -1) {
+    cluster = 'qa'
+    namespace = ctx.request.query.namespace
+  } else {
+    namespace = parmars.split('@')[0];
+    cluster = parmars.split('@')[1]
+  }
+  if (!clientNew[cluster]) {
+    console.log('为空')
+    clientNew[cluster] = getClient(cluster)
+  }
   const res = await Promise.all([
-    getPods(client, namespace),
-    getServices(client, namespace),
+    getPods(clientNew[cluster], namespace),
+    getServices(clientNew[cluster], namespace),
   ])
 
   res[0].body.items.forEach(async (item) => {

resource/getClient.js

@@ -2,17 +2,7 @@ const path = require('path')
 const Client = require('kubernetes-client').Client
 const config = require('kubernetes-client').config
 
-const newClient = function client(ctx) {
-  const parmars = ctx.request.query.namespace || ''
-  if (parmars.search('@') === -1) {
-    ctx.body = {
-      code: '0001',
-      msg: '参数传入不合法',
-    }
-    return false
-  }
-  const namespace = parmars.split('@')[0];
-  const cluster = parmars.split('@')[1]
+module.exports = function getClient(cluster) {
   let yaml = ''
   switch (cluster) {
     case 'qa':
@@ -25,17 +15,12 @@ const newClient = function client(ctx) {
       yaml = './../kubeService/kubeConfig-qke.yaml'
       break
     default:
-      ctx.body = {
-        code: '0001',
-        msg: '请选择集群的名字',
-      }
+      throw Error('未获取到Client')
   }
-  const client = new Client({
+  return new Client({
     config: config.fromKubeconfig(
       path.resolve(__dirname, yaml),
     ),
     version: '1.10',
   })
-  return { namespace, client }
 }
-module.exports = newClient

yamls/mysql.pvc.yaml

@@ -21,12 +21,12 @@ metadata:
   name: {{serviceName}}-{{namespace}}
   namespace: {{namespace}}
 spec:
-  storageClassName: cbs
+  storageClassName: cbs-3
   accessModes:
     - ReadWriteOnce
   resources:
     requests:
-      storage: 1Gi
+      storage: 20Gi
 
 ---
 
@@ -82,6 +82,8 @@ spec:
           volumeMounts:
             - mountPath: "/var/lib/mysql"
               name: {{serviceName}}
+#      nodeSelector:
+#        zone: "3"
       volumes:
         - name: {{serviceName}}
           persistentVolumeClaim:

yamls/zookeeper.pvc.yaml

@@ -35,6 +35,8 @@ spec:
         qcloud-app: {{serviceName}}
         type: base
     spec:
+      nodeSelector:
+        zone: "3"
       containers:
       - image: ccr.ccs.tencentyun.com/{{image}}
         imagePullPolicy: Always