feat: putFunctionAsyncConfig statefulInvocation

alibaba · Jun 1, 2021 · 76cdf23 · 76cdf23
1 parent b63d93c
commit 76cdf23
Show file tree

Hide file tree

Showing 3 changed files with 14 additions and 0 deletions.
diff --git a/src/lib/function-async-config.js b/src/lib/function-async-config.js
@@ -23,6 +23,7 @@ async function makeDestination(serviceName, functionName, asyncConfiguration, qu
   const asyncConfig = {
     maxAsyncRetryAttempts: asyncConfiguration.MaxAsyncRetryAttempts,
     maxAsyncEventAgeInSeconds: asyncConfiguration.MaxAsyncEventAgeInSeconds,
+    statefulInvocation: asyncConfiguration.StatefulInvocation,
     destinationConfig
   };
 
@@ -33,6 +34,7 @@ async function makeDestination(serviceName, functionName, asyncConfiguration, qu
     const asyncConfigCache = {
       destinationConfig: data.destinationConfig,
       maxAsyncEventAgeInSeconds: data.maxAsyncEventAgeInSeconds,
+      statefulInvocation: data.statefulInvocation,
       maxAsyncRetryAttempts: data.maxAsyncRetryAttempts
     };
     if (_.isEqual(asyncConfig, asyncConfigCache)) {

diff --git a/src/lib/language-service/schema/rosSchema.ts b/src/lib/language-service/schema/rosSchema.ts
@@ -237,6 +237,9 @@ export const rosSchema = {
                         }
                       }
                     },
+                    "StatefulInvocation": {
+                      "type": "boolean"
+                    },
                     "MaxAsyncEventAgeInSeconds": {
                       "type": "integer"
                     },
@@ -349,6 +352,9 @@ export const rosSchema = {
                         }
                       }
                     },
+                    "StatefulInvocation": {
+                      "type": "boolean"
+                    },
                     "MaxAsyncEventAgeInSeconds": {
                       "type": "integer"
                     },

diff --git a/src/lib/validate/schema/function.js b/src/lib/validate/schema/function.js
@@ -87,6 +87,9 @@ const functionSchema = {
                 'MaxAsyncEventAgeInSeconds': {
                   'type': 'integer'
                 },
+                'StatefulInvocation': {
+                  'type': 'boolean'
+                },
                 'MaxAsyncRetryAttempts': {
                   'type': 'integer'
                 }
@@ -182,6 +185,9 @@ const functionSchema = {
                 'MaxAsyncEventAgeInSeconds': {
                   'type': 'integer'
                 },
+                'StatefulInvocation': {
+                  'type': 'boolean'
+                },
                 'MaxAsyncRetryAttempts': {
                   'type': 'integer'
                 }