Skip to content

[Brook K10] Added the Stream service WIT. #220

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
moetemp wants to merge 12 commits into from
Closed

[Brook K10] Added the Stream service WIT. #220

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
12 commits
Select commit Hold shift + click to select a range
a2acd1d
Added the Stream service WIT.
moetemp Oct 27, 2026
c8d16eb
Added the close status to the stream's close.
moetemp Oct 27, 2026
4dbc757
Typed the read item and made each request's Stream required.
moetemp Oct 27, 2026
76f84a2
Matched the Stream service WIT to the create and read fixes.
moetemp Oct 28, 2026
bb35335
Added the nexgen directives to the Stream service WIT.
moetemp Oct 28, 2026
88adfdf
Kept `last` out of Workflow reads and renamed the error base keys.
moetemp Oct 29, 2026
5209862
Merged K9 into K10.
moetemp Oct 30, 2026
3b8ac8b
Omitted the close task fields from the WIT, as native only.
moetemp Oct 30, 2026
c524555
Merged K9 into K10.
moetemp Oct 30, 2026
9dc337d
Added the TypeScript and .NET helpers to the read poll.
moetemp Oct 29, 2026
66af1ee
Merged K9 into K10.
moetemp Oct 30, 2026
e0d0155
Made sequence a parameter and withdraw-run a source in the WIT.
moetemp Oct 30, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 3 additions & 0 deletions crates/streams/README.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -15,6 +15,9 @@ Workflow makes each Stream call from a Local Activity. Core has no Stream code.
needs no file outside itself.
- `protos/temporal/sdk/streams/v1/runtime.proto` has the crate's own calls, such as the writer
calls.
- `nexus/stream-service.wit` is the Stream service as a System Nexus service, with the messages of
the protos above. Each SDK copies it and generates its bindings with nexgen. A test checks that
every line is at most 100 columns.
- `testdata/*.json` are the shared vectors. They cover Stream ids, Producer ids, Store keys and
meta fields, offsets, epoch keys, the withdrawal rule and the batch digest of a dedupe entry.
`testdata/gen_vectors.py` writes them from a second implementation, and the crate's tests read
Expand Down
Loading
Loading