Merge branch 'node' into 'master'

Node



See merge request !1

.eslintrc.json

+{
+    "extends": "standard"
+}
\ No newline at end of file

.gitignore

 .DS_Store
 node_modules
+package-lock.json
 /dist
 
 # local env files

app/commonService.js

+const Router = require('koa-router')
+const yaml = require('js-yaml')
+const templates = require('../serviceTemplate')
+
+const IMAGES = {
+  zookeeper: 'zookeeper:3.4.10',
+  rabbitmq: 'rabbitmq:3.6-management',
+  mysql: 'mysql:5.7'
+}
+
+const router = new Router()
+module.exports = router
+
+router.post('/create', async ctx => {
+  let { serviceName, namespace } = ctx.request.body
+  if (!Object.keys(IMAGES).includes(serviceName)) {
+    ctx.body = ctx.fail('不支持的服务类型')
+    return
+  }
+
+  let data = {
+    namespace,
+    image: IMAGES[serviceName]
+  }
+  let template = templates[serviceName].replace(/{{([A-Za-z0-9_]+)}}/g, function () {
+    if (data[arguments[1]] === undefined) {
+      throw new Error('缺少模板所需变量')
+    }
+    return data[arguments[1]]
+  })
+  let params = yaml.load(template)
+  await ctx.client.service_create(params)
+  ctx.body = ctx.ok('创建成功')
+})
+
+router.post('/delete', async ctx => {
+  let { serviceName, namespace } = ctx.request.body
+  await ctx.client.service_delete(serviceName, namespace)
+  ctx.body = ctx.ok('删除成功')
+})

app/index.js

+const Koa = require('koa')
+const Router = require('koa-router')
+const bodyParser = require('koa-bodyparser')
+
+const error = require('../middleware/error')
+const result = require('../middleware/result')
+
+const namespaceRoute = require('./namespace')
+const serviceRoute = require('./service')
+// const rabbitmqRoute = require('./rabbitmq')
+// const zookeeperRoute = require('./zookeeper')
+const commonServiceRoute = require('./commonService')
+const ingressRoute = require('./ingress')
+
+const client = require('../services/tke.service').create({
+  secretId: 'AKID4rY7wwNphsUcaFsy1pRtKhQvDj4CA3Ac',
+  secretKey: 'YBduRnjgVRGzmagZJbss3Vo58wWCyhgc',
+  clusterId: 'cls-acfx4pvj',
+  region: 'ap-beijing'
+})
+
+function loadRoutes (router) {
+  router
+    .use(error())
+    .use(result())
+    .use(async (ctx, next) => {
+      // 腾讯云
+      ctx.client = client
+      await next()
+    }, bodyParser())
+    .use('/namespace', namespaceRoute.routes())
+    .use('/service', serviceRoute.routes())
+    // .use('/rabbitmq', rabbitmqRoute.routes())
+    // .use('/zookeeper', zookeeperRoute.routes())
+    .use('/commonService', commonServiceRoute.routes())
+    .use('/ingress', ingressRoute.routes())
+}
+
+exports.start = function () {
+  // 加载各种服务
+  const app = new Koa()
+  const router = new Router()
+
+  // 加载所有路由
+  loadRoutes(router)
+
+  app.use(router.routes())
+  app.listen(4000)
+  console.log('app start', 4000)
+}

app/ingress.js

+const Router = require('koa-router')
+
+const router = new Router();
+module.exports = router
+
+router.get('/', async ctx => {
+  let data = await ctx.client.ingress_get(ctx.query.namespace)
+  ctx.body = ctx.ok(data)
+})
+
+/**
+namespace
+rules
+*/
+router.post('/modify', async ctx => {
+  let ingress = await ctx.client.ingress_get(ctx.request.body.namespace)
+  if (!ingress) {
+    return ctx.body = ctx.fail('namespace下没有ingress，请先创建')
+  }
+  console.log(1, ingress)
+  // let data = await ctx.client.ingress_modify()
+  ctx.body = ctx.ok(ingress)
+})
+
+router.post('/create', async ctx => {
+  let ingress = await ctx.client.ingress_get(ctx.request.body.namespace)
+  if (ingress) {
+    return ctx.body = ctx.fail('namespace下已存在ingress')
+  }
+  await ctx.client.ingress_create(ctx.request.body.namespace)
+  ctx.body = ctx.ok()
+})
+
+router.post('/delete', async ctx => {
+  await ctx.client.ingress_delete(ctx.request.body.ingressName, ctx.request.body.namespace)
+  ctx.body = ctx.ok()
+})

app/namespace.js

+const Router = require('koa-router')
+
+const router = new Router();
+module.exports = router
+
+router.get('/', async ctx => {
+  let data = await ctx.client.namespace_get()
+  ctx.body = ctx.ok(data)
+})
+
+router.post('/create', async ctx => {
+  await ctx.client.namespace_create(ctx.request.body.name)
+  await ctx.client.ingress_create(ctx.request.body.name)
+  ctx.body = ctx.ok()
+})
+
+router.post('/delete', async ctx => {
+  await ctx.client.namespace_delete(ctx.request.body.name)
+  ctx.body = ctx.ok()
+})

app/rabbitmq.js

+const Router = require('koa-router')
+const yaml = require('js-yaml')
+const templates = require('../serviceTemplate')
+
+const IMAGES = ['rabbitmq:3.6-management']
+
+const router = new Router()
+module.exports = router
+
+router.post('/create', async ctx => {
+  // let svc = await ctx.client.service_get('rabbitmq', ctx.request.body.namespace)
+  // if (svc) {
+  //   ctx.body = ctx.fail('服务已经存在')
+  //   return
+  // }
+
+  let data = {
+    namespace: ctx.request.body.namespace,
+    image: IMAGES[0]
+  }
+  let template = templates['rabbitmq'].replace(/{{([A-Za-z0-9_]+)}}/g, function () {
+    if (data[arguments[1]] === undefined) {
+      throw new Error('缺少模板所需变量')
+    }
+    return data[arguments[1]]
+  })
+  let params = yaml.load(template)
+  await ctx.client.service_create(params)
+  ctx.body = ctx.ok('创建成功')
+})
+
+router.post('/delete', async ctx => {
+  await ctx.client.service_delete('rabbitmq', ctx.request.body.namespace)
+  ctx.body = ctx.ok('删除成功')
+})

app/service.js

+const Router = require('koa-router')
+const yaml = require('js-yaml')
+const templates = require('../serviceTemplate')
+
+const TYPES = ['ui', 'java', 'nodejs', 'python', 'go']
+
+const router = new Router()
+module.exports = router
+
+router.get('/', async ctx => {
+  let data = await ctx.client.service_list(ctx.query.namespace)
+  ctx.body = ctx.ok(data)
+})
+
+router.post('/create', async ctx => {
+  let { type, serviceName, namespace, image, system_name } = ctx.request.body
+  if (!TYPES.includes(type)) {
+    return ctx.body = ctx.fail('不支持的服务类型')
+  }
+
+  // try {
+  //   let svc = await ctx.client.service_get(serviceName, namespace)
+  //   if (svc) {
+  //     return ctx.body = ctx.fail('服务已经存在')
+  //   }
+  // } catch (e) {
+  // }
+
+  let data = {
+    serviceName,
+    namespace,
+    image,
+    system_name
+  }
+  if (!system_name) {
+    // ui abTest的时候不一样
+    data.system_name = serviceName
+  }
+  let template = templates[type].replace(/{{([A-Za-z0-9_]+)}}/g, function () {
+    if (data[arguments[1]] === undefined) {
+      throw new Error('缺少模板所需变量')
+    }
+    return data[arguments[1]]
+  })
+  let params = yaml.load(template)
+  await ctx.client.service_create(params)
+  ctx.body = ctx.ok('创建成功')
+})
+
+router.post('/delete', async ctx => {
+  await ctx.client.service_delete(ctx.request.body.serviceName, ctx.request.body.namespace)
+  ctx.body = ctx.ok('删除成功')
+})
+
+router.post('/modifyImage', async ctx => {
+  await ctx.client.service_modifyImage(ctx.request.body.serviceName, ctx.request.body.image, ctx.request.body.namespace)
+  ctx.body = ctx.ok('更新成功')
+})

app/zookeeper.js

+const Router = require('koa-router')
+const yaml = require('js-yaml')
+const templates = require('../serviceTemplate')
+
+const IMAGES = ['zookeeper:3.4.10']
+
+const router = new Router()
+module.exports = router
+
+router.post('/create', async ctx => {
+  let data = {
+    namespace: ctx.request.body.namespace,
+    image: IMAGES[0]
+  }
+  let template = templates['zookeeper'].replace(/{{([A-Za-z0-9_]+)}}/g, function () {
+    if (data[arguments[1]] === undefined) {
+      throw new Error('缺少模板所需变量')
+    }
+    return data[arguments[1]]
+  })
+  let params = yaml.load(template)
+  await ctx.client.service_create(params)
+  ctx.body = ctx.ok('创建成功')
+})
+
+router.post('/delete', async ctx => {
+  await ctx.client.service_delete('zookeeper', ctx.request.body.namespace)
+  ctx.body = ctx.ok('删除成功')
+})

bin/www.js

+const app = require('../app')
+app.start()
\ No newline at end of file

images/README.md

@@ -14,3 +14,9 @@ ui项目，SYSTEM_NAME从环境变量获取，所以需要在nginx.conf中增加
 
 abTest的项目，在构建镜像时使用参数CONFIG=abTest/paycenter.conf
 ```
+
+### 问题
+
+1. 把自定义的conf加放到entrypoint中？
+
+  感觉就成了config_repository

images/nodejs/Dockerfile

+FROM node:8-alpine
+
+ARG CONFIG=conf/default.js
+ARG PROJECT=koa2-hello
+ARG TARGET=src/config/
+
+# 拷贝代码
+# todo: 从代码镜像中拷贝
+ADD code.tar.gz /home/quant_group
+
+# 拷贝配置文件
+WORKDIR /home/quant_group/${PROJECT}
+COPY ${CONFIG} ${TARGET}
+
+COPY docker-entrypoint.sh ./
+CMD ./docker-entrypoint.sh

images/nodejs/build.sh

+#!/bin/bash
+
+docker build  --build-arg CONFIG=conf/opapi2.js -t test-nodejs  .
\ No newline at end of file

images/nodejs/conf/default.js

+moduele.exports = {}
\ No newline at end of file

images/nodejs/docker-entrypoint.sh

+#!/bin/bash
+echo 192.168.4.3 git.q-gp.com >> /etc/hosts
+curl -sSL http://git.q-gp.com/QA/qg-docker-entrypoints/raw/tke-ui/tke/nodejs.sh -o run.sh 
+sh run.sh

images/test-ui/Dockerfile

+# 基于centos7
+FROM openresty/openresty:1.13.6.2-centos
+
+COPY nginx.conf /usr/local/openresty/nginx/conf/
+
+WORKDIR /home/quant_group
+COPY test-ui.conf ./conf.d/
+COPY index.html ./test-ui/
+
+CMD ["/usr/local/openresty/bin/openresty", "-g", "daemon off;"]
+

images/test-ui/build.sh

+#!/bin/bash
+
+docker build -t test-ui .
\ No newline at end of file

images/test-ui/build_tke.sh

+#!/bin/bash
+
+docker build -t test-ui .
+docker tag test-ui ccr.ccs.tencentyun.com/qa-app/test-ui:2
+docker push ccr.ccs.tencentyun.com/qa-app/test-ui:2
\ No newline at end of file

images/test-ui/index.html

+<!DOCTYPE html>
+<html>
+<head>
+  <title>2222</title>
+</head>
+<body>
+<h1>22222</h1>
+</body>
+</html>
\ No newline at end of file

images/test-ui/nginx.conf

+#user  nobody;
+worker_processes  1;
+
+error_log  logs/error.log;
+error_log  logs/error.log  notice;
+error_log  logs/error.log  info;
+
+#pid        logs/nginx.pid;
+
+env SYSTEM_NAME;
+
+
+events {
+    worker_connections  1024;
+}
+
+
+http {
+    include       mime.types;
+    default_type  application/octet-stream;
+
+    log_format  main  '$remote_addr - $remote_user [$time_local] "$request" '
+                     '$status $body_bytes_sent "$http_referer" '
+                     '"$http_user_agent" "$http_x_forwarded_for"';
+
+    access_log  logs/access.log  main;
+
+    sendfile        on;
+    #tcp_nopush     on;
+
+    #keepalive_timeout  0;
+    keepalive_timeout  65;
+
+    #gzip  on;
+
+    include /home/quant_group/conf.d/*.conf;
+}
\ No newline at end of file

images/test-ui/test-ui.conf

+server {
+  listen 80;
+  server_name _;
+
+  gzip on;
+  gzip_min_length 1k;
+  gzip_buffers 4 16k;
+  gzip_http_version 1.0;
+  gzip_comp_level 4;
+  gzip_types text/plain application/x-javascript text/css application/xml application/javascript;
+  gzip_vary on;
+  
+  location / {
+    expires -1;
+    root /home/quant_group/test-ui;
+    try_files $uri $uri/ /index.html?$query_string;
+  }
+}
\ No newline at end of file

images/ui/Dockerfile

@@ -18,10 +18,8 @@ ARG CONFIG=default.conf
 COPY conf/nginx.conf /usr/local/openresty/nginx/conf/
 COPY conf/${CONFIG} /etc/nginx/conf.d/
 
-# 拷贝代码, code/xjd-ui/dist
-# 先打包好代码镜像，然后从镜像中拷贝？？
-COPY code .
 
-COPY docker-entrypoint.sh ./
-CMD ./docker-entrypoint.sh
+
+# COPY docker-entrypoint.sh ./
+# CMD ./docker-entrypoint.sh
 

images/ui/build.sh

 #!/bin/bash
 
-tag=2.3
-docker build -t test-ui . && docker tag test-ui 192.168.4.4/tmp/test-ui:${tag} && docker push 192.168.4.4/tmp/test-ui:${tag}
+tag=2.4
+docker build -t test-ui . 
\ No newline at end of file
+# && docker tag test-ui 192.168.4.4/tmp/test-ui:${tag} && docker push 192.168.4.4/tmp/test-ui:${tag}
\ No newline at end of file

images/ui/conf/nginx.conf

@@ -33,5 +33,5 @@ http {
 
     #gzip  on;
 
-    include /etc/nginx/conf.d/*.conf;
+    include /home/quant_group/conf.d/*.conf;
 }
\ No newline at end of file

k8s/deploy/ui.deploy.yaml

-apiVersion: extensions/v1beta1
-kind: Deployment
-metadata:
-  name: test-ui
-  namespace: xuezhijie
-spec:
-  replicas: 1
-  strategy:
-    type: Recreate
-  revisionHistoryLimit: 0
-  template:
-    metadata:
-      labels:
-        app: test-ui
-    spec:
-      restartPolicy: Always
-      containers:
-      - name: test-ui-v1
-        imagePullPolicy: Always
-        env:
-        - name: SYSTEM_NAME
-          value: xjd-ui
-        - name: NAMESPACE
-          value: xuezhijie
-        image: 192.168.4.4/tmp/test-ui:2.2
-        ports:
-          - containerPort: 80
\ No newline at end of file

k8s/service/ui.svc.yaml

-apiVersion: v1
-kind: Service
-metadata:
-  name: test-ui
-  namespace: xuezhijie
-spec:
-  ports:
-  - name: tcp-80-80-fwdy6
-    port: 80
-    protocol: TCP
-    targetPort: 80
-  sessionAffinity: None
-  type: ClusterIP
\ No newline at end of file

middleware/error/index.js

+'use strict'
+// const logger = require('koa-log4').getLogger('middleware:error')
+
+module.exports = function () {
+  return async function (ctx, next) {
+    try {
+      await next()
+    } catch (e) {
+      let msg = '系统出错了哦，请稍后再试。'
+      // mongo 唯一索引冲突
+      if (e.name === 'MongoError') {
+        msg = e.errmsg
+      } else if (e.message) {
+        msg = e.message
+      }
+
+      console.error(ctx.path)
+      console.error(e)
+      ctx.respond = true
+      ctx.status = 200
+      ctx.body = {
+        code: '0001',
+        msg: msg
+      }
+    }
+  }
+}

middleware/result/code.js

+'use strict'
+
+/**
+ */
+
+module.exports = {
+  // 通用参数错误
+  ERROR_INPUT: { msg: '输入参数不正确', code: '0001' },
+  // 自定义参数错误
+  ERROR_GITPATH: { msg: 'git_path格式不正确', code: '0001' }
+}

middleware/result/index.js

+'use strict'
+
+const Code = require('./code')
+
+module.exports = function () {
+  return async function (ctx, next) {
+    if (ctx.ok || ctx.fail) return next()
+
+    ctx.ok = function (data = {}) {
+      return {
+        code: '0000',
+        data: data
+      }
+    }
+
+    ctx.Code = Code
+
+    ctx.fail = function (msg, code) {
+      if (msg && msg.code) {
+        return msg
+      }
+
+      return {
+        code: code || '0001',
+        msg: msg || '请求失败，请稍候重试'
+      }
+    }
+
+    return next()
+  }
+}

nodemon.json

+{
+  "delay": "2500",
+  "ignore": ["*.test.js", "fixtures/*"],
+  "ext": "js json txt"
+}
\ No newline at end of file

package.json

+{
+  "name": "tke-eos",
+  "version": "1.0.0",
+  "description": "",
+  "main": "bin/www.js",
+  "dependencies": {
+    "js-yaml": "^3.12.1",
+    "koa": "^2.6.2",
+    "koa-bodyparser": "^4.2.1",
+    "koa-router": "^7.4.0",
+    "lodash": "^4.17.11",
+    "request": "^2.88.0"
+  },
+  "devDependencies": {
+    "nodemon": "^1.18.9"
+  },
+  "scripts": {
+    "test": "echo \"Error: no test specified\" && exit 1",
+    "start": "NODE_DEBUG=request nodemon"
+  },
+  "repository": {
+    "type": "git",
+    "url": "git@git.quantgroup.cn:QA/tke-eos.git"
+  },
+  "keywords": [],
+  "author": "",
+  "license": "ISC"
+}

serviceTemplate/index.js

+const fs = require('fs')
+const ui = fs.readFileSync('serviceTemplate/ui.template.txt', 'utf8')
+const java = fs.readFileSync('serviceTemplate/java.template.txt', 'utf8')
+const nodejs = fs.readFileSync('serviceTemplate/nodejs.template.txt', 'utf8')
+const rabbitmq = fs.readFileSync('serviceTemplate/rabbitmq.template.txt', 'utf8')
+const zookeeper = fs.readFileSync('serviceTemplate/zookeeper.template.txt', 'utf8')
+const mysql = fs.readFileSync('serviceTemplate/mysql.template.txt', 'utf8')
+
+module.exports = {
+  ui,
+  nodejs,
+  java,
+  rabbitmq,
+  zookeeper,
+  mysql
+}

serviceTemplate/java.template.txt

+serviceName: {{serviceName}}
+namespace:  {{namespace}}
+replicas: 1
+accessType: ClusterIP
+
+portMappings.0.protocol: TCP
+portMappings.0.lbPort: 80
+portMappings.0.containerPort: 80
+
+containers.0.containerName: {{system_name}}
+containers.0.image: {{image}}
+containers.0.envs.0.name: SYSTEM_NAME
+containers.0.envs.0.value: {{system_name}}
+containers.0.envs.1.name: NAMESPACE
+containers.0.envs.1.value: {{namespace}}

serviceTemplate/mysql.template.txt

+serviceName: mysql
+namespace:  {{namespace}}
+replicas: 1
+accessType: LoadBalancer
+
+portMappings.0.protocol: TCP
+portMappings.0.lbPort: 3306
+portMappings.0.containerPort: 3306
+
+containers.0.containerName: mysql
+containers.0.image: {{image}}
+containers.0.volumeMounts.0.volumeName: mysql-vol
+containers.0.volumeMounts.0.mountPath: /var/lib/mysql
+containers.0.volumeMounts.0.mode: rw
+containers.0.envs.0.name: MYSQL_USER
+containers.0.envs.0.value: qa
+containers.0.envs.1.name: MYSQL_PASSWORD
+containers.0.envs.1.value: qatest
+containers.0.envs.2.name: MYSQL_ROOT_PASSWORD
+containers.0.envs.2.value: qatest
+
+volumes.0.name: mysql-vol
+volumes.0.volumeType: hostPath
+volumes.0.hostPath: /var/lib/data/mysql/{{namespace}}

serviceTemplate/nodejs.template.txt

+serviceName: {{serviceName}}
+namespace:  {{namespace}}
+replicas: 1
+accessType: ClusterIP
+
+portMappings.0.protocol: TCP
+portMappings.0.lbPort: 80
+portMappings.0.containerPort: 80
+
+containers.0.containerName: {{serviceName}}
+containers.0.image: {{image}}
+containers.0.envs.0.name: SYSTEM_NAME
+containers.0.envs.0.value: {{serviceName}}
+containers.0.envs.1.name: NAMESPACE
+containers.0.envs.1.value: {{namespace}}

serviceTemplate/rabbitmq.template.txt

+serviceName: rabbitmq
+namespace:  {{namespace}}
+replicas: 1
+accessType: ClusterIP
+
+portMappings.0.protocol: TCP
+portMappings.0.lbPort: 5672
+portMappings.0.containerPort: 5672
+
+portMappings.1.protocol: TCP
+portMappings.1.lbPort: 15672
+portMappings.1.containerPort: 15672
+
+containers.0.containerName: rabbitmq
+containers.0.image: {{image}}
+containers.0.volumeMounts.0.volumeName: rabbitmq-vol
+containers.0.volumeMounts.0.mountPath: /var/lib/rabbitmq
+containers.0.volumeMounts.0.mode: rw
+containers.0.envs.0.name: RABBITMQ_DEFAULT_USER
+containers.0.envs.0.value: qa
+containers.0.envs.1.name: RABBITMQ_DEFAULT_PASS
+containers.0.envs.1.value: qatest
+
+volumes.0.name: rabbitmq-vol
+volumes.0.volumeType: hostPath
+volumes.0.hostPath: /var/lib/data/rabbitmq/{{namespace}}

serviceTemplate/ui.template.txt

+serviceName: {{serviceName}}
+namespace:  {{namespace}}
+replicas: 1
+accessType: ClusterIP
+
+portMappings.0.protocol: TCP
+portMappings.0.lbPort: 80
+portMappings.0.containerPort: 80
+
+containers.0.containerName: {{system_name}}
+containers.0.image: {{image}}
+containers.0.envs.0.name: SYSTEM_NAME
+containers.0.envs.0.value: {{system_name}}
+containers.0.envs.1.name: NAMESPACE
+containers.0.envs.1.value: {{namespace}}

serviceTemplate/zookeeper.template.txt

+serviceName: zookeeper
+namespace:  {{namespace}}
+replicas: 1
+accessType: ClusterIP
+
+portMappings.0.protocol: TCP
+portMappings.0.lbPort: 2181
+portMappings.0.containerPort: 2181
+
+portMappings.1.protocol: TCP
+portMappings.1.lbPort: 9090
+portMappings.1.containerPort: 9090
+
+containers.0.containerName: zookeeper
+containers.0.image: {{image}}
+containers.0.volumeMounts.0.volumeName: zookeeper-vol
+containers.0.volumeMounts.0.mountPath: /var/lib/zookeeper
+containers.0.volumeMounts.0.mode: rw
+containers.0.envs.0.name: ZOO_USER
+containers.0.envs.0.value: zookeeper
+containers.0.envs.1.name: ZOO_PORT
+containers.0.envs.1.value: 2181
+
+volumes.0.name: zookeeper-vol
+volumes.0.volumeType: hostPath
+volumes.0.hostPath: /var/lib/data/zookeeper/{{namespace}}

services/tke.service.js

+const request = require('request')
+const crypto = require('crypto')
+
+class Client  {
+  constructor ({secretId, secretKey, region, clusterId}) {
+    this.secretId = secretId
+    this.secretKey = secretKey
+    this.region = region
+    this.clusterId = clusterId
+    this.method = 'POST'
+    this.protocal = 'https://'
+    this.endpoint = 'ccs.api.qcloud.com'
+    this.path = '/v2/index.php'
+    this.domain = ".lkbang.com"
+
+    // 禁止操作以下命名空间
+    this.defaultNamespaces = ['default', 'kube-system', 'kube-public']
+  }
+
+  sign (params, signMethod) {
+    let str = ''
+    let keys = Object.keys(params)
+    keys.sort()
+    for (let key of keys) {
+      str += '&' + key + '=' + params[key]
+    }
+    str = str.slice(1)
+    let signStr = this.method + this.endpoint + this.path + '?' + str
+
+    let signMethodMap = {
+        HmacSHA1: "sha1",
+        HmacSHA256: "sha256"
+    }
+    let hmac = crypto.createHmac(signMethodMap[signMethod], this.secretKey)
+    return hmac.update(Buffer.from(signStr, 'utf-8')).digest('base64')
+  }
+
+  // 公共参数
+  // Action: '',
+  // Region: '',
+  // Timestamp: null,
+  // Nonce: null,
+  // SecretId: '',
+  // Signature: ''
+  formatRequestData (action, params = {}) {
+    params.Action = action
+    params.Region = this.region
+    params.Timestamp = Math.round(Date.now() / 1000)
+    params.Nonce = Math.round(Math.random() * 65535)
+    params.SecretId = this.secretId
+    params.SignatureMethod = params.SignatureMethod || 'HmacSHA256'
+    params.Signature = this.sign(params, params.SignatureMethod)
+  }
+
+  post (action, params = {}) {
+    if (params.namespace && this.defaultNamespaces.includes(params.namespace)) {
+      return Promise.reject(new Error('未授权的namespace'))
+    }
+
+    this.formatRequestData(action, params)
+    let url = this.protocal + this.endpoint + this.path
+    let self = this
+    return new Promise(function (resolve, reject) {
+      request({
+        method: self.method,
+        url, 
+        json: true,
+        form: params
+      }, function (err, res, body) {
+        if (err) {
+          console.error(err)
+          reject(err)
+        } else {
+          if (body.code === 0) {
+            resolve(body.data)
+          } else {
+            reject(body)
+          }
+        }
+      })
+    })
+  }
+
+  namespace_get () {
+    return this.post('DescribeClusterNameSpaces', {clusterId: this.clusterId})
+  }
+
+  namespace_create (name) {
+    return this.post('CreateClusterNamespace', {name, description: '', clusterId: this.clusterId})
+  }
+
+  namespace_delete (name) {
+    return this.post('DeleteClusterNamespace', {"names.0": name, clusterId: this.clusterId})
+  }
+
+  service_list (namespace) {
+    return this.post('DescribeClusterService', {namespace, clusterId: this.clusterId, allnamespace: 0})
+  }
+
+  service_get (serviceName, namespace) {
+    return this.post('DescribeClusterServiceInfo', {serviceName, namespace, clusterId: this.clusterId})
+  }
+
+  async service_create (params) {
+    params.clusterId = this.clusterId
+    let str = JSON.stringify(params)
+    await this.post('CreateClusterService', params)
+    // 腾讯云api暂只能通过修改服务来改成Recreate策略
+    let modifyParams = JSON.parse(str)
+    modifyParams.strategy = 'Recreate'
+    return this.post('ModifyClusterService', modifyParams)
+  }
+
+  service_delete (serviceName, namespace) {
+    return this.post('DeleteClusterService', {serviceName, namespace, clusterId: this.clusterId})
+  }
+
+  service_modifyImage (serviceName, image, namespace) {
+    // 修改示例的第一个容器
+    return this.post('ModifyClusterServiceImage', {serviceName, namespace, image, clusterId: this.clusterId})
+  }
+
+  ingress_get (namespace) {
+    return this.post('DescribeIngress', {namespace, clusterId: this.clusterId})
+  }
+
+  ingress_create (namespace) {
+    return this.post('CreateIngress', {ingressName: `qa-${namespace}`, ingressDesc: '', namespace, clusterId: this.clusterId})
+  }
+
+  ingress_delete (ingressName, namespace) {
+    return this.post('DeleteIngress', {ingressName, namespace, clusterId: this.clusterId})
+  }
+
+  ingress_modify (ingressName, namespace, rules) {
+    return this.post('MosifyIngress', {ingressName, namespace, ...rules, clusterId: this.clusterId})
+  }
+
+}
+
+exports.create = function (config) {
+  return new Client(config)
+}
+
+// let client = new Client({
+//   secretId: 'AKID4rY7wwNphsUcaFsy1pRtKhQvDj4CA3Ac',
+//   secretKey: 'YBduRnjgVRGzmagZJbss3Vo58wWCyhgc',
+//   clusterId: 'cls-acfx4pvj',
+//   region: 'ap-beijing'
+// })
+
+// client.post('DescribeClusterNameSpaces', {clusterId: 'cls-acfx4pvj'}).then(res => {
+//   console.log(5, res)
+// })
\ No newline at end of file