Skip to content

Commit

Permalink
IWF-385: return channel sizes for RPC (#502)
Browse files Browse the repository at this point in the history
  • Loading branch information
longquanzheng authored Dec 4, 2024
1 parent 1352220 commit 2e02d0d
Show file tree
Hide file tree
Showing 21 changed files with 576 additions and 71 deletions.
2 changes: 2 additions & 0 deletions gen/iwfidl/.openapi-generator/FILES
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,7 @@ api/openapi.yaml
api_default.go
client.go
configuration.go
docs/ChannelInfo.md
docs/ChannelRequestStatus.md
docs/CommandCombination.md
docs/CommandRequest.md
Expand Down Expand Up @@ -91,6 +92,7 @@ docs/WorkflowWorkerRpcResponse.md
git_push.sh
go.mod
go.sum
model_channel_info.go
model_channel_request_status.go
model_command_combination.go
model_command_request.go
Expand Down
1 change: 1 addition & 0 deletions gen/iwfidl/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -102,6 +102,7 @@ Class | Method | HTTP request | Description

## Documentation For Models

- [ChannelInfo](docs/ChannelInfo.md)
- [ChannelRequestStatus](docs/ChannelRequestStatus.md)
- [CommandCombination](docs/CommandCombination.md)
- [CommandRequest](docs/CommandRequest.md)
Expand Down
21 changes: 21 additions & 0 deletions gen/iwfidl/api/openapi.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -1686,9 +1686,15 @@ components:
type: object
WorkflowWorkerRpcRequest:
example:
internalChannelInfos:
key:
size: 0
input:
data: data
encoding: encoding
signalChannelInfos:
key:
size: 0
context:
firstAttemptTimestamp: 6
workflowStartedTimestamp: 0
Expand Down Expand Up @@ -1743,11 +1749,26 @@ components:
items:
$ref: '#/components/schemas/KeyValue'
type: array
signalChannelInfos:
additionalProperties:
$ref: '#/components/schemas/ChannelInfo'
type: object
internalChannelInfos:
additionalProperties:
$ref: '#/components/schemas/ChannelInfo'
type: object
required:
- context
- rpcName
- workflowType
type: object
ChannelInfo:
example:
size: 0
properties:
size:
type: integer
type: object
WorkflowWorkerRpcResponse:
example:
output:
Expand Down
56 changes: 56 additions & 0 deletions gen/iwfidl/docs/ChannelInfo.md
Original file line number Diff line number Diff line change
@@ -0,0 +1,56 @@
# ChannelInfo

## Properties

Name | Type | Description | Notes
------------ | ------------- | ------------- | -------------
**Size** | Pointer to **int32** | | [optional]

## Methods

### NewChannelInfo

`func NewChannelInfo() *ChannelInfo`

NewChannelInfo instantiates a new ChannelInfo object
This constructor will assign default values to properties that have it defined,
and makes sure properties required by API are set, but the set of arguments
will change when the set of required properties is changed

### NewChannelInfoWithDefaults

`func NewChannelInfoWithDefaults() *ChannelInfo`

NewChannelInfoWithDefaults instantiates a new ChannelInfo object
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

### GetSize

`func (o *ChannelInfo) GetSize() int32`

GetSize returns the Size field if non-nil, zero value otherwise.

### GetSizeOk

`func (o *ChannelInfo) GetSizeOk() (*int32, bool)`

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

### SetSize

`func (o *ChannelInfo) SetSize(v int32)`

SetSize sets Size field to given value.

### HasSize

`func (o *ChannelInfo) HasSize() bool`

HasSize 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)


52 changes: 52 additions & 0 deletions gen/iwfidl/docs/WorkflowWorkerRpcRequest.md
Original file line number Diff line number Diff line change
Expand Up @@ -10,6 +10,8 @@ Name | Type | Description | Notes
**Input** | Pointer to [**EncodedObject**](EncodedObject.md) | | [optional]
**SearchAttributes** | Pointer to [**[]SearchAttribute**](SearchAttribute.md) | | [optional]
**DataAttributes** | Pointer to [**[]KeyValue**](KeyValue.md) | | [optional]
**SignalChannelInfos** | Pointer to [**map[string]ChannelInfo**](ChannelInfo.md) | | [optional]
**InternalChannelInfos** | Pointer to [**map[string]ChannelInfo**](ChannelInfo.md) | | [optional]

## Methods

Expand Down Expand Up @@ -165,6 +167,56 @@ SetDataAttributes sets DataAttributes field to given value.

HasDataAttributes returns a boolean if a field has been set.

### GetSignalChannelInfos

`func (o *WorkflowWorkerRpcRequest) GetSignalChannelInfos() map[string]ChannelInfo`

GetSignalChannelInfos returns the SignalChannelInfos field if non-nil, zero value otherwise.

### GetSignalChannelInfosOk

`func (o *WorkflowWorkerRpcRequest) GetSignalChannelInfosOk() (*map[string]ChannelInfo, bool)`

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

### SetSignalChannelInfos

`func (o *WorkflowWorkerRpcRequest) SetSignalChannelInfos(v map[string]ChannelInfo)`

SetSignalChannelInfos sets SignalChannelInfos field to given value.

### HasSignalChannelInfos

`func (o *WorkflowWorkerRpcRequest) HasSignalChannelInfos() bool`

HasSignalChannelInfos returns a boolean if a field has been set.

### GetInternalChannelInfos

`func (o *WorkflowWorkerRpcRequest) GetInternalChannelInfos() map[string]ChannelInfo`

GetInternalChannelInfos returns the InternalChannelInfos field if non-nil, zero value otherwise.

### GetInternalChannelInfosOk

`func (o *WorkflowWorkerRpcRequest) GetInternalChannelInfosOk() (*map[string]ChannelInfo, bool)`

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

### SetInternalChannelInfos

`func (o *WorkflowWorkerRpcRequest) SetInternalChannelInfos(v map[string]ChannelInfo)`

SetInternalChannelInfos sets InternalChannelInfos field to given value.

### HasInternalChannelInfos

`func (o *WorkflowWorkerRpcRequest) HasInternalChannelInfos() bool`

HasInternalChannelInfos 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)

Expand Down
124 changes: 124 additions & 0 deletions gen/iwfidl/model_channel_info.go

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

Loading

0 comments on commit 2e02d0d

Please sign in to comment.