Skip to content

Commit 1ff9a17

Browse files
Squashed 'sdk-core/src/main/service-protocol/' changes from fd7eb24..4378d55
4378d55 Move headers into InputStreamEntry. (#75) 433d446 Remove the old discovery. Fix #71 git-subtree-dir: sdk-core/src/main/service-protocol git-subtree-split: 4378d559db7a53a477dd091b636a64712b2b630e
1 parent d466b0d commit 1ff9a17

File tree

3 files changed

+9
-58
lines changed

3 files changed

+9
-58
lines changed

sdk-core/src/main/service-protocol/dev/restate/service/discovery.proto

Lines changed: 0 additions & 46 deletions
This file was deleted.

sdk-core/src/main/service-protocol/dev/restate/service/protocol.proto

Lines changed: 7 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -40,10 +40,8 @@ message StartMessage {
4040
repeated StateEntry state_map = 4;
4141
bool partial_state = 5;
4242

43-
repeated Header headers = 6;
44-
4543
// If this invocation has a key associated (e.g. for objects and workflows), then this key is filled in. Empty otherwise.
46-
string key = 7;
44+
string key = 6;
4745
}
4846

4947
// Type: 0x0000 + 1
@@ -106,20 +104,19 @@ message EndMessage {
106104

107105
// ------ Input and output ------
108106

109-
// Completable: Yes
107+
// Completable: No
110108
// Fallible: No
111109
// Type: 0x0400 + 0
112-
message PollInputStreamEntryMessage {
113-
oneof result {
114-
bytes value = 14;
115-
Failure failure = 15;
116-
}
110+
message InputEntryMessage {
111+
repeated Header headers = 1;
112+
113+
bytes value = 14;
117114
}
118115

119116
// Completable: No
120117
// Fallible: No
121118
// Type: 0x0400 + 1
122-
message OutputStreamEntryMessage {
119+
message OutputEntryMessage {
123120
oneof result {
124121
bytes value = 14;
125122
Failure failure = 15;

sdk-core/src/main/service-protocol/service-invocation-protocol.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -282,15 +282,15 @@ descriptions in [`protocol.proto`](dev/restate/service/protocol.proto).
282282

283283
| Message | Type | Completable | Fallible | Description |
284284
| ------------------------------- | -------- | ----------- | -------- | ---------------------------------------------------------------------------------------------------------------------------------------------------------------- |
285-
| `PollInputStreamEntryMessage` | `0x0400` | Yes | No | Carries the invocation input message(s) of the invocation. Note: currently the runtime always sends this entry completed, but this may change in future. |
285+
| `InputEntryMessage` | `0x0400` | No | No | Carries the invocation input message(s) of the invocation. |
286286
| `GetStateEntryMessage` | `0x0800` | Yes | No | Get the value of a service instance state key. |
287287
| `GetStateKeysEntryMessage` | `0x0804` | Yes | No | Get all the known state keys for this service instance. Note: the completion value for this message is a protobuf of type `GetStateKeysEntryMessage.StateKeys`. |
288288
| `SleepEntryMessage` | `0x0C00` | Yes | No | Initiate a timer that completes after the given time. |
289289
| `InvokeEntryMessage` | `0x0C01` | Yes | Yes | Invoke another Restate service. |
290290
| `AwakeableEntryMessage` | `0x0C03` | Yes | No | Arbitrary result container which can be completed from another service, given a specific id. See [Awakeable identifier](#awakeable-identifier) for more details. |
291291
| `BackgroundInvokeEntryMessage` | `0x0C02` | No | Yes | Invoke another Restate service at the given time, without waiting for the response. |
292292
| `CompleteAwakeableEntryMessage` | `0x0C04` | No | Yes | Complete an `Awakeable`, given its id. See [Awakeable identifier](#awakeable-identifier) for more details. |
293-
| `OutputStreamEntryMessage` | `0x0401` | No | No | Carries the invocation output message(s) or terminal failure of the invocation. |
293+
| `OutputEntryMessage` | `0x0401` | No | No | Carries the invocation output message(s) or terminal failure of the invocation. |
294294
| `SetStateEntryMessage` | `0x0800` | No | No | Set the value of a service instance state key. |
295295
| `ClearStateEntryMessage` | `0x0801` | No | No | Clear the value of a service instance state key. |
296296
| `ClearAllStateEntryMessage` | `0x0802` | No | No | Clear all the values of the service instance state. |

0 commit comments

Comments
 (0)