Skip to content

Commit

Permalink
Support WaitForCompletionStateIds and add local activity input debug (#…
Browse files Browse the repository at this point in the history
  • Loading branch information
longquanzheng authored Jul 26, 2024
1 parent 47b58da commit 9000724
Show file tree
Hide file tree
Showing 17 changed files with 263 additions and 28 deletions.
14 changes: 14 additions & 0 deletions gen/iwfidl/api/openapi.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -783,6 +783,9 @@ components:
WorkflowStartRequest:
example:
startStateId: startStateId
waitForCompletionStateIds:
- waitForCompletionStateIds
- waitForCompletionStateIds
workflowTimeoutSeconds: 0
waitForCompletionStateExecutionIds:
- waitForCompletionStateExecutionIds
Expand Down Expand Up @@ -903,6 +906,10 @@ components:
type: string
startStateId:
type: string
waitForCompletionStateIds:
items:
type: string
type: array
waitForCompletionStateExecutionIds:
items:
type: string
Expand Down Expand Up @@ -1777,6 +1784,7 @@ components:
data: data
encoding: encoding
key: key
localActivityInput: localActivityInput
commandRequest:
signalCommands:
- signalChannelName: signalChannelName
Expand Down Expand Up @@ -1840,6 +1848,8 @@ components:
encoding: encoding
key: key
properties:
localActivityInput:
type: string
upsertSearchAttributes:
items:
$ref: '#/components/schemas/SearchAttribute'
Expand Down Expand Up @@ -2147,6 +2157,7 @@ components:
encoding: encoding
channelName: channelName
conditionalCloseType: null
localActivityInput: localActivityInput
publishToInterStateChannel:
- channelName: channelName
value:
Expand Down Expand Up @@ -2175,6 +2186,8 @@ components:
encoding: encoding
key: key
properties:
localActivityInput:
type: string
stateDecision:
$ref: '#/components/schemas/StateDecision'
upsertSearchAttributes:
Expand Down Expand Up @@ -2632,6 +2645,7 @@ components:
format: int64
type: integer
durationSeconds:
format: int64
type: integer
required:
- commandId
Expand Down
8 changes: 4 additions & 4 deletions gen/iwfidl/docs/TimerCommand.md
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ Name | Type | Description | Notes
------------ | ------------- | ------------- | -------------
**CommandId** | **string** | |
**FiringUnixTimestampSeconds** | Pointer to **int64** | | [optional]
**DurationSeconds** | Pointer to **int32** | | [optional]
**DurationSeconds** | Pointer to **int64** | | [optional]

## Methods

Expand Down Expand Up @@ -74,20 +74,20 @@ HasFiringUnixTimestampSeconds returns a boolean if a field has been set.

### GetDurationSeconds

`func (o *TimerCommand) GetDurationSeconds() int32`
`func (o *TimerCommand) GetDurationSeconds() int64`

GetDurationSeconds returns the DurationSeconds field if non-nil, zero value otherwise.

### GetDurationSecondsOk

`func (o *TimerCommand) GetDurationSecondsOk() (*int32, bool)`
`func (o *TimerCommand) GetDurationSecondsOk() (*int64, bool)`

GetDurationSecondsOk returns a tuple with the DurationSeconds field if it's non-nil, zero value otherwise
and a boolean to check if the value has been set.

### SetDurationSeconds

`func (o *TimerCommand) SetDurationSeconds(v int32)`
`func (o *TimerCommand) SetDurationSeconds(v int64)`

SetDurationSeconds sets DurationSeconds field to given value.

Expand Down
26 changes: 26 additions & 0 deletions gen/iwfidl/docs/WorkflowStartRequest.md
Original file line number Diff line number Diff line change
Expand Up @@ -9,6 +9,7 @@ Name | Type | Description | Notes
**WorkflowTimeoutSeconds** | **int32** | |
**IwfWorkerUrl** | **string** | |
**StartStateId** | Pointer to **string** | | [optional]
**WaitForCompletionStateIds** | Pointer to **[]string** | | [optional]
**WaitForCompletionStateExecutionIds** | Pointer to **[]string** | | [optional]
**StateInput** | Pointer to [**EncodedObject**](EncodedObject.md) | | [optional]
**StateOptions** | Pointer to [**WorkflowStateOptions**](WorkflowStateOptions.md) | | [optional]
Expand Down Expand Up @@ -138,6 +139,31 @@ SetStartStateId sets StartStateId field to given value.

HasStartStateId returns a boolean if a field has been set.

### GetWaitForCompletionStateIds

`func (o *WorkflowStartRequest) GetWaitForCompletionStateIds() []string`

GetWaitForCompletionStateIds returns the WaitForCompletionStateIds field if non-nil, zero value otherwise.

### GetWaitForCompletionStateIdsOk

`func (o *WorkflowStartRequest) GetWaitForCompletionStateIdsOk() (*[]string, bool)`

GetWaitForCompletionStateIdsOk returns a tuple with the WaitForCompletionStateIds field if it's non-nil, zero value otherwise
and a boolean to check if the value has been set.

### SetWaitForCompletionStateIds

`func (o *WorkflowStartRequest) SetWaitForCompletionStateIds(v []string)`

SetWaitForCompletionStateIds sets WaitForCompletionStateIds field to given value.

### HasWaitForCompletionStateIds

`func (o *WorkflowStartRequest) HasWaitForCompletionStateIds() bool`

HasWaitForCompletionStateIds returns a boolean if a field has been set.

### GetWaitForCompletionStateExecutionIds

`func (o *WorkflowStartRequest) GetWaitForCompletionStateExecutionIds() []string`
Expand Down
26 changes: 26 additions & 0 deletions gen/iwfidl/docs/WorkflowStateDecideResponse.md
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@

Name | Type | Description | Notes
------------ | ------------- | ------------- | -------------
**LocalActivityInput** | Pointer to **string** | | [optional]
**StateDecision** | Pointer to [**StateDecision**](StateDecision.md) | | [optional]
**UpsertSearchAttributes** | Pointer to [**[]SearchAttribute**](SearchAttribute.md) | | [optional]
**UpsertDataObjects** | Pointer to [**[]KeyValue**](KeyValue.md) | | [optional]
Expand All @@ -30,6 +31,31 @@ NewWorkflowStateDecideResponseWithDefaults instantiates a new WorkflowStateDecid
This constructor will only assign default values to properties that have it defined,
but it doesn't guarantee that properties required by API are set

### GetLocalActivityInput

`func (o *WorkflowStateDecideResponse) GetLocalActivityInput() string`

GetLocalActivityInput returns the LocalActivityInput field if non-nil, zero value otherwise.

### GetLocalActivityInputOk

`func (o *WorkflowStateDecideResponse) GetLocalActivityInputOk() (*string, bool)`

GetLocalActivityInputOk returns a tuple with the LocalActivityInput field if it's non-nil, zero value otherwise
and a boolean to check if the value has been set.

### SetLocalActivityInput

`func (o *WorkflowStateDecideResponse) SetLocalActivityInput(v string)`

SetLocalActivityInput sets LocalActivityInput field to given value.

### HasLocalActivityInput

`func (o *WorkflowStateDecideResponse) HasLocalActivityInput() bool`

HasLocalActivityInput returns a boolean if a field has been set.

### GetStateDecision

`func (o *WorkflowStateDecideResponse) GetStateDecision() StateDecision`
Expand Down
26 changes: 26 additions & 0 deletions gen/iwfidl/docs/WorkflowStateStartResponse.md
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@

Name | Type | Description | Notes
------------ | ------------- | ------------- | -------------
**LocalActivityInput** | Pointer to **string** | | [optional]
**UpsertSearchAttributes** | Pointer to [**[]SearchAttribute**](SearchAttribute.md) | | [optional]
**UpsertDataObjects** | Pointer to [**[]KeyValue**](KeyValue.md) | | [optional]
**CommandRequest** | Pointer to [**CommandRequest**](CommandRequest.md) | | [optional]
Expand All @@ -30,6 +31,31 @@ NewWorkflowStateStartResponseWithDefaults instantiates a new WorkflowStateStartR
This constructor will only assign default values to properties that have it defined,
but it doesn't guarantee that properties required by API are set

### GetLocalActivityInput

`func (o *WorkflowStateStartResponse) GetLocalActivityInput() string`

GetLocalActivityInput returns the LocalActivityInput field if non-nil, zero value otherwise.

### GetLocalActivityInputOk

`func (o *WorkflowStateStartResponse) GetLocalActivityInputOk() (*string, bool)`

GetLocalActivityInputOk returns a tuple with the LocalActivityInput field if it's non-nil, zero value otherwise
and a boolean to check if the value has been set.

### SetLocalActivityInput

`func (o *WorkflowStateStartResponse) SetLocalActivityInput(v string)`

SetLocalActivityInput sets LocalActivityInput field to given value.

### HasLocalActivityInput

`func (o *WorkflowStateStartResponse) HasLocalActivityInput() bool`

HasLocalActivityInput returns a boolean if a field has been set.

### GetUpsertSearchAttributes

`func (o *WorkflowStateStartResponse) GetUpsertSearchAttributes() []SearchAttribute`
Expand Down
12 changes: 6 additions & 6 deletions gen/iwfidl/model_timer_command.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

36 changes: 36 additions & 0 deletions gen/iwfidl/model_workflow_start_request.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

36 changes: 36 additions & 0 deletions gen/iwfidl/model_workflow_state_decide_response.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

Loading

0 comments on commit 9000724

Please sign in to comment.