Merge branch 'feat/support_setConcurrentAndFlow' into 'master' (merge request !56)

feat/support_setConcurrentAndFlow

Author: lukejyhuang

lib/function/index.js

@@ -628,6 +628,121 @@ class FunctionService {
             LayerVersion: version
         });
     }
+    /**
+     * 设置预置并发
+     * @private
+     * @param {IProvisionedConcurrencyConfig} concurrencyConfig
+     * @returns
+     * @memberof FunctionService
+     */
+    async setProvisionedConcurrencyConfig(concurrencyConfig) {
+        const { namespace } = this.getFunctionConfig();
+        const { functionName: FunctionName, qualifier: Qualifier, versionProvisionedConcurrencyNum: VersionProvisionedConcurrencyNum } = concurrencyConfig;
+        return this.scfService.request('PutProvisionedConcurrencyConfig', {
+            FunctionName,
+            Qualifier,
+            VersionProvisionedConcurrencyNum,
+            Namespace: namespace
+        });
+    }
+    /**
+     * 获取函数预置并发详情
+     * @private
+     * @param {IGetProvisionedConcurrencyConfig} concurrencyConfig
+     * @returns {Promise<IGetProvisionedConcurrencyRes>}
+     * @memberof FunctionService
+     */
+    async getProvisionedConcurrencyConfig(concurrencyConfig) {
+        const { namespace } = this.getFunctionConfig();
+        const { functionName: FunctionName, qualifier: Qualifier } = concurrencyConfig;
+        return this.scfService.request('GetProvisionedConcurrencyConfig', {
+            FunctionName,
+            Qualifier,
+            Namespace: namespace
+        });
+    }
+    /**
+     * 删除预置并发
+     * @private
+     * @param {IGetProvisionedConcurrencyConfig} concurrencyConfig
+     * @returns {Promise<IResponseInfo>}
+     * @memberof FunctionService
+     */
+    async deleteProvisionedConcurrencyConfig(concurrencyConfig) {
+        const { namespace } = this.getFunctionConfig();
+        const { functionName: FunctionName, qualifier: Qualifier } = concurrencyConfig;
+        return this.scfService.request('DeleteProvisionedConcurrencyConfig', {
+            FunctionName,
+            Qualifier,
+            Namespace: namespace
+        });
+    }
+    /**
+     * 发布新版本
+     * @param {IPublishVersionParams} publishParams
+     * @returns {Promise<IPublishVersionRes>}
+     * @memberof FunctionService
+     */
+    async publishVersion(publishParams) {
+        const { namespace } = this.getFunctionConfig();
+        const { functionName: FunctionName, description: Description } = publishParams;
+        return this.scfService.request('PublishVersion', {
+            FunctionName,
+            Description,
+            Namespace: namespace
+        });
+    }
+    /**
+     * 查询函数版本详情
+     * @param {IListFunctionVersionParams} listVersionParams
+     * @returns {Promise<IFunctionVersionsRes>}
+     * @memberof FunctionService
+     */
+    async listVersionByFunction(listVersionParams) {
+        const { namespace } = this.getFunctionConfig();
+        const { functionName: FunctionName, offset: Offset, limit: Limit, order: Order, orderBy: OrderBy } = listVersionParams;
+        return this.scfService.request('ListVersionByFunction', {
+            FunctionName,
+            Namespace: namespace,
+            Offset,
+            Limit,
+            Order,
+            OrderBy
+        });
+    }
+    /**
+     *
+     * @param {IUpdateFunctionAliasConfig} updateVersionConfigParams
+     * @returns {Promise<IResponseInfo>}
+     * @memberof FunctionService
+     */
+    async updateFunctionAliasConfig(updateVersionConfigParams) {
+        const { namespace } = this.getFunctionConfig();
+        const { functionName: FunctionName, name: Name, functionVersion: FunctionVersion, routingConfig: RoutingConfig, description: Description } = updateVersionConfigParams;
+        return this.scfService.request('UpdateAlias', {
+            FunctionName,
+            Name,
+            Namespace: namespace,
+            FunctionVersion,
+            RoutingConfig,
+            Description
+        });
+    }
+    /**
+     * 查询函数别名详情
+     * @param {IGetFunctionAlias} params
+     * @returns {Promise<IGetFunctionAliasRes>}
+     * @memberof FunctionService
+     */
+    async getFunctionAlias(params) {
+        const { namespace } = this.getFunctionConfig();
+        const { functionName: FunctionName, name: Name } = params;
+        return this.scfService.request('GetAlias', {
+            FunctionName,
+            Name,
+            Namespace: namespace
+        });
+    }
     async createAccessPath(name, path) {
         const access = this.environment.getAccessService();
         try {
@@ -856,6 +971,27 @@ __decorate([
 __decorate([
     utils_1.preLazy()
 ], FunctionService.prototype, "getLayerVersion", null);
+__decorate([
+    utils_1.preLazy()
+], FunctionService.prototype, "setProvisionedConcurrencyConfig", null);
+__decorate([
+    utils_1.preLazy()
+], FunctionService.prototype, "getProvisionedConcurrencyConfig", null);
+__decorate([
+    utils_1.preLazy()
+], FunctionService.prototype, "deleteProvisionedConcurrencyConfig", null);
+__decorate([
+    utils_1.preLazy()
+], FunctionService.prototype, "publishVersion", null);
+__decorate([
+    utils_1.preLazy()
+], FunctionService.prototype, "listVersionByFunction", null);
+__decorate([
+    utils_1.preLazy()
+], FunctionService.prototype, "updateFunctionAliasConfig", null);
+__decorate([
+    utils_1.preLazy()
+], FunctionService.prototype, "getFunctionAlias", null);
 __decorate([
     utils_1.preLazy()
 ], FunctionService.prototype, "createAccessPath", null);