Add workflow RPC (#57)

indeedeng · May 19, 2023 · fbc0fdc · fbc0fdc
1 parent 96018c1
commit fbc0fdc
Show file tree

Hide file tree

Showing 25 changed files with 470 additions and 9 deletions.
diff --git a/gen/iwfidl/api/openapi.yaml b/gen/iwfidl/api/openapi.yaml
@@ -213,6 +213,12 @@ paths:
               schema:
                 $ref: '#/components/schemas/ErrorResponse'
           description: Invalid input
+        "420":
+          content:
+            application/json:
+              schema:
+                $ref: '#/components/schemas/ErrorResponse'
+          description: RPC execution error
       summary: execute an RPC of a workflow
   /api/v1/workflow/timer/skip:
     post:
@@ -454,6 +460,9 @@ components:
     WorkflowStateOptions:
       example:
         searchAttributesLoadingPolicy:
+          lockingKeys:
+          - lockingKeys
+          - lockingKeys
           partialLoadingKeys:
           - partialLoadingKeys
           - partialLoadingKeys
@@ -477,6 +486,9 @@ components:
           maximumIntervalSeconds: 2
           backoffCoefficient: 5.637377
         dataAttributesLoadingPolicy:
+          lockingKeys:
+          - lockingKeys
+          - lockingKeys
           partialLoadingKeys:
           - partialLoadingKeys
           - partialLoadingKeys
@@ -556,6 +568,9 @@ components:
       type: string
     PersistenceLoadingPolicy:
       example:
+        lockingKeys:
+        - lockingKeys
+        - lockingKeys
         partialLoadingKeys:
         - partialLoadingKeys
         - partialLoadingKeys
@@ -567,11 +582,16 @@ components:
           items:
             type: string
           type: array
+        lockingKeys:
+          items:
+            type: string
+          type: array
       type: object
     PersistenceLoadingType:
       enum:
       - LOAD_ALL_WITHOUT_LOCKING
       - LOAD_PARTIAL_WITHOUT_LOCKING
+      - LOAD_PARTIAL_WITH_EXCLUSIVE_LOCK
       type: string
     CommandCarryOverPolicy:
       example:
@@ -617,6 +637,9 @@ components:
         workflowTimeoutSeconds: 0
         stateOptions:
           searchAttributesLoadingPolicy:
+            lockingKeys:
+            - lockingKeys
+            - lockingKeys
             partialLoadingKeys:
             - partialLoadingKeys
             - partialLoadingKeys
@@ -640,6 +663,9 @@ components:
             maximumIntervalSeconds: 2
             backoffCoefficient: 5.637377
           dataAttributesLoadingPolicy:
+            lockingKeys:
+            - lockingKeys
+            - lockingKeys
             partialLoadingKeys:
             - partialLoadingKeys
             - partialLoadingKeys
@@ -1068,6 +1094,9 @@ components:
           data: data
           encoding: encoding
         searchAttributesLoadingPolicy:
+          lockingKeys:
+          - lockingKeys
+          - lockingKeys
           partialLoadingKeys:
           - partialLoadingKeys
           - partialLoadingKeys
@@ -1077,6 +1106,9 @@ components:
         rpcName: rpcName
         workflowId: workflowId
         dataAttributesLoadingPolicy:
+          lockingKeys:
+          - lockingKeys
+          - lockingKeys
           partialLoadingKeys:
           - partialLoadingKeys
           - partialLoadingKeys
@@ -1211,6 +1243,9 @@ components:
           - stateId: stateId
             stateOptions:
               searchAttributesLoadingPolicy:
+                lockingKeys:
+                - lockingKeys
+                - lockingKeys
                 partialLoadingKeys:
                 - partialLoadingKeys
                 - partialLoadingKeys
@@ -1234,6 +1269,9 @@ components:
                 maximumIntervalSeconds: 2
                 backoffCoefficient: 5.637377
               dataAttributesLoadingPolicy:
+                lockingKeys:
+                - lockingKeys
+                - lockingKeys
                 partialLoadingKeys:
                 - partialLoadingKeys
                 - partialLoadingKeys
@@ -1244,6 +1282,9 @@ components:
           - stateId: stateId
             stateOptions:
               searchAttributesLoadingPolicy:
+                lockingKeys:
+                - lockingKeys
+                - lockingKeys
                 partialLoadingKeys:
                 - partialLoadingKeys
                 - partialLoadingKeys
@@ -1267,6 +1308,9 @@ components:
                 maximumIntervalSeconds: 2
                 backoffCoefficient: 5.637377
               dataAttributesLoadingPolicy:
+                lockingKeys:
+                - lockingKeys
+                - lockingKeys
                 partialLoadingKeys:
                 - partialLoadingKeys
                 - partialLoadingKeys
@@ -1684,6 +1728,9 @@ components:
           - stateId: stateId
             stateOptions:
               searchAttributesLoadingPolicy:
+                lockingKeys:
+                - lockingKeys
+                - lockingKeys
                 partialLoadingKeys:
                 - partialLoadingKeys
                 - partialLoadingKeys
@@ -1707,6 +1754,9 @@ components:
                 maximumIntervalSeconds: 2
                 backoffCoefficient: 5.637377
               dataAttributesLoadingPolicy:
+                lockingKeys:
+                - lockingKeys
+                - lockingKeys
                 partialLoadingKeys:
                 - partialLoadingKeys
                 - partialLoadingKeys
@@ -1717,6 +1767,9 @@ components:
           - stateId: stateId
             stateOptions:
               searchAttributesLoadingPolicy:
+                lockingKeys:
+                - lockingKeys
+                - lockingKeys
                 partialLoadingKeys:
                 - partialLoadingKeys
                 - partialLoadingKeys
@@ -1740,6 +1793,9 @@ components:
                 maximumIntervalSeconds: 2
                 backoffCoefficient: 5.637377
               dataAttributesLoadingPolicy:
+                lockingKeys:
+                - lockingKeys
+                - lockingKeys
                 partialLoadingKeys:
                 - partialLoadingKeys
                 - partialLoadingKeys
@@ -1804,6 +1860,9 @@ components:
         - stateId: stateId
           stateOptions:
             searchAttributesLoadingPolicy:
+              lockingKeys:
+              - lockingKeys
+              - lockingKeys
               partialLoadingKeys:
               - partialLoadingKeys
               - partialLoadingKeys
@@ -1827,6 +1886,9 @@ components:
               maximumIntervalSeconds: 2
               backoffCoefficient: 5.637377
             dataAttributesLoadingPolicy:
+              lockingKeys:
+              - lockingKeys
+              - lockingKeys
               partialLoadingKeys:
               - partialLoadingKeys
               - partialLoadingKeys
@@ -1837,6 +1899,9 @@ components:
         - stateId: stateId
           stateOptions:
             searchAttributesLoadingPolicy:
+              lockingKeys:
+              - lockingKeys
+              - lockingKeys
               partialLoadingKeys:
               - partialLoadingKeys
               - partialLoadingKeys
@@ -1860,6 +1925,9 @@ components:
               maximumIntervalSeconds: 2
               backoffCoefficient: 5.637377
             dataAttributesLoadingPolicy:
+              lockingKeys:
+              - lockingKeys
+              - lockingKeys
               partialLoadingKeys:
               - partialLoadingKeys
               - partialLoadingKeys
@@ -1878,6 +1946,9 @@ components:
         stateId: stateId
         stateOptions:
           searchAttributesLoadingPolicy:
+            lockingKeys:
+            - lockingKeys
+            - lockingKeys
             partialLoadingKeys:
             - partialLoadingKeys
             - partialLoadingKeys
@@ -1901,6 +1972,9 @@ components:
             maximumIntervalSeconds: 2
             backoffCoefficient: 5.637377
           dataAttributesLoadingPolicy:
+            lockingKeys:
+            - lockingKeys
+            - lockingKeys
             partialLoadingKeys:
             - partialLoadingKeys
             - partialLoadingKeys

diff --git a/gen/iwfidl/api_default.go b/gen/iwfidl/api_default.go
diff --git a/gen/iwfidl/docs/PersistenceLoadingPolicy.md b/gen/iwfidl/docs/PersistenceLoadingPolicy.md
@@ -6,6 +6,7 @@ Name | Type | Description | Notes
 ------------ | ------------- | ------------- | -------------
 **PersistenceLoadingType** | Pointer to [**PersistenceLoadingType**](PersistenceLoadingType.md) |  | [optional] 
 **PartialLoadingKeys** | Pointer to **[]string** |  | [optional] 
+**LockingKeys** | Pointer to **[]string** |  | [optional] 
 
 ## Methods
 
@@ -76,6 +77,31 @@ SetPartialLoadingKeys sets PartialLoadingKeys field to given value.
 
 HasPartialLoadingKeys returns a boolean if a field has been set.
 
+### GetLockingKeys
+
+`func (o *PersistenceLoadingPolicy) GetLockingKeys() []string`
+
+GetLockingKeys returns the LockingKeys field if non-nil, zero value otherwise.
+
+### GetLockingKeysOk
+
+`func (o *PersistenceLoadingPolicy) GetLockingKeysOk() (*[]string, bool)`
+
+GetLockingKeysOk returns a tuple with the LockingKeys field if it's non-nil, zero value otherwise
+and a boolean to check if the value has been set.
+
+### SetLockingKeys
+
+`func (o *PersistenceLoadingPolicy) SetLockingKeys(v []string)`
+
+SetLockingKeys sets LockingKeys field to given value.
+
+### HasLockingKeys
+
+`func (o *PersistenceLoadingPolicy) HasLockingKeys() bool`
+
+HasLockingKeys returns a boolean if a field has been set.
+
 
 [[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md)
 

diff --git a/gen/iwfidl/docs/PersistenceLoadingType.md b/gen/iwfidl/docs/PersistenceLoadingType.md
@@ -7,6 +7,8 @@
 
 * `PARTIAL_WITHOUT_LOCKING` (value: `"LOAD_PARTIAL_WITHOUT_LOCKING"`)
 
+* `PARTIAL_WITH_EXCLUSIVE_LOCK` (value: `"LOAD_PARTIAL_WITH_EXCLUSIVE_LOCK"`)
+
 
 [[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md)
 

diff --git a/gen/iwfidl/model_persistence_loading_policy.go b/gen/iwfidl/model_persistence_loading_policy.go
diff --git a/gen/iwfidl/model_persistence_loading_type.go b/gen/iwfidl/model_persistence_loading_type.go
diff --git a/integ/init.go b/integ/init.go
@@ -21,6 +21,7 @@ func init() {
 		&stateApiTimeoutWorkflow{},
 		&skipWaitUntilWorkflow{},
 		skipWaitUntilWorkflow2{}, // test register by struct
+		rpcWorkflow{},
 	)
 	if err != nil {
 		panic(err)