Repository navigation

Streams API: combined branch for review - #381

Closed

moetemp wants to merge 49 commits into

moe/streams/generated-codefrom

moe/brook/streams-combined

Closed

Streams API: combined branch for review#381
moetemp wants to merge 49 commits into
moe/streams/generated-codefrom
moe/brook/streams-combined

Commits on Nov 13, 2026
- Pointed Core at a commit that vendors the Stream API.
  moetemp
  committed
  ccd0e97
- Taught the generator scripts to build the Stream package.
  moetemp
  committed
  b874f86
- Generated the Stream protos, bindings, visitor and Workflow exports.
  moetemp
  committed
  02645de
- Added the support functions that the generated Stream code calls.
  moetemp
  committed
  7f2eca0
- Routed a client's Stream operations to a Stream Store.
  moetemp
  committed
  20815db
- Ran Workflow Stream operations in a Local Activity with a Store.
  moetemp
  committed
  a92a582
- Gave an Activity's info the Workflow Task of a Local Activity.
  moetemp
  committed
  0c0f2e1
- Wrote a Workflow's Stream append as its Local Activity's Producer.
  moetemp
  committed
  e4c2b32
- Pointed Core at the commit with the Stream crate.
  moetemp
  committed
  a644cf5
- Bound the Stream runtime in the bridge behind a `streams` feature.
  moetemp
  committed
  1f154d7
- Raised one `StreamError` for every failed Stream call.
  moetemp
  committed
  1f0993a
- Added a memory Stream Store and moved the Stream tests to it.
  moetemp
  committed
  43654eb
- Gave a Workflow's Stream create the chain's first run id.
  moetemp
  committed
  7337df1
- Moved Core to the head of the Stream crate.
  moetemp
  committed
  7c89321
- Kept the linters out of the Core submodule.
  moetemp
  committed
  e83221c
- Bound the Redis Stream runtime in the bridge.
  moetemp
  committed
  7f4efeb
- Added the Redis Stream Store with its tests.
  moetemp
  committed
  307a5cd
- Started a Redis in CI for the Redis Stream Store tests.
  moetemp
  committed
  6b1cf02
- Kept the base of the bridge Stores next to `StreamStore`.
  moetemp
  committed
  4c3e86b
- Turned on Streams in a FIPS build.
  moetemp
  committed
  8911d75
- Pointed the Core submodule at the fork that has the Stream crate.
  moetemp
  committed
  01a154f
- Gave the Redis Stream Store a cargo feature of its own.
  moetemp
  committed
  e70dff4
- Sent a Workflow's Stream append with a sequence, so its retry writes once.
  moetemp
  committed
  41a3c2b
- Moved Core to the API files with the sequence parameter of append.
  moetemp
  committed
  57d1473
- Moved the Redis Store pin to the commit that follows the new Core.
  moetemp
  committed
  2bf62e7
- Regenerated the Stream code for the sequence parameter of append.
  moetemp
  committed
  5bc79ea
- Refused an append and a close from Workflow code on a Store.
  moetemp
  committed
  b097176
- Merged the branch of the generated Stream code.
  moetemp
  committed
  f491efb
- Moved the Worker side of a Stream Store into one module.
  moetemp
  committed
  1c836c8
- Made the call of a Stream Store private.
  moetemp
  committed
  f1fdc70
- Said why stream_stores is a list, and named the Redis step in CI.
  moetemp
  committed
  ed82555
- Took the Stream Stores of a client as one config with a selector.
  moetemp
  committed
  9fa615e
- Let WorkflowEnvironment take a Stream config for its client.
  moetemp
  committed
  fa62ab2
- Let a Worker serve every Stream Store of its client.
  moetemp
  committed
  f1629bb
- Moved the options of the Stream Local Activity to the Stream config.
  moetemp
  committed
  dfa007b
- Read the ref of a Stream call from its request object.
  moetemp
  committed
  2d86f5b
- Added BufferedAppender, which batches the appends of one Stream.
  moetemp
  committed
  d0fba10
- Moved Core to the API files with the Workflow Stream marks.
  moetemp
  committed
  51a7d0b
- Merged the regenerated Stream code.
  moetemp
  committed
  ea1523d
- Followed the Workflow Stream that has no append, close or read.
  moetemp
  committed
  2c8b049
- Let a module of the Stream Workflow package be the first import.
  moetemp
  committed
  336dbed
- Let the user's Activity interceptors see the Stream Local Activity.
  moetemp
  committed
  56c9937
- Raised an error for a Stream call when the client has no Store.
  moetemp
  committed
  63180a3
- Gave StreamStore the five Stream operations as methods.
  moetemp
  committed
  6427a7f
- Moved the Worker side of a Stream call into the Store.
  moetemp
  committed
  e2d3bf8
- Moved Core to the Stream crate that has no Python script.
  moetemp
  committed
  419fc75
- Dropped the lint excludes for the Core submodule.
  moetemp
  committed
  a69aef6
- Removed a stale sentence from the StreamStore docstring.
  moetemp
  committed
  138f338
- Merged the generated-code branch, which sits on the Workflow Task info.
  moetemp
  committed
  51fe79d

Commits

Commits on Nov 13, 2026