Skip to content

[Brook K6] Served the Stream service writes and describe through the runtime. - #48

Closed
moetemp wants to merge 1 commit into
moe/brook/review/k5-redis-storefrom
moe/brook/review/k6-service-writes
Closed

moetemp wants to merge 1 commit into
moe/brook/review/k5-redis-storefrom
moe/brook/review/k6-service-writes

Conversation

@moetemp

@moetemp moetemp commented Oct 25, 2026 •

Copy link
Copy Markdown
Owner

What changed?

This PR serves the Stream service writes and describe through the runtime object.

  • A bridge builds one StreamRuntime per client and calls it with a method name and proto bytes.
    Core has no hook for it, and a Workflow makes each call from a Local Activity.
  • The service checks the request and the Store's capabilities before it calls the Store.
  • No Store declares RUN_FENCE until K7, so a retry run's write fails with stream_unsupported.

Depends on #47 (K5). Review lane is the Rust reviewers.
Part of the Brook review series.

Why?

Every SDK calls the write path first, and it needs no read code. Reads get their own PR (K8).

How did you test it?

cargo fmt, clippy (both feature sets), cargo test on memory, Redis 8 and 7.0. Fork CI passes.

Link to a test plan if any -

  • Unit Tests
  • Staging
  • End to End Tests

@moetemp
moetemp force-pushed the moe/brook/review/k6-service-writes branch from f1d79a2 to 9aac2a2 Compare October 25, 2026 22:10
@moetemp
moetemp force-pushed the moe/brook/review/k5-redis-store branch 2 times, most recently from 4be1ac8 to d351adb Compare October 25, 2026 22:17
@moetemp
moetemp force-pushed the moe/brook/review/k6-service-writes branch from 9aac2a2 to 8254580 Compare October 25, 2026 22:17
@moetemp
moetemp force-pushed the moe/brook/review/k5-redis-store branch from d351adb to efebb98 Compare October 26, 2026 01:08
@moetemp
moetemp force-pushed the moe/brook/review/k6-service-writes branch from 8254580 to 7bf983c Compare October 26, 2026 01:08
The runtime is a plain object that a bridge builds per client and
calls with a method name and proto bytes. The service checks each
request and the Store's capabilities before it writes.
@moetemp
moetemp force-pushed the moe/brook/review/k6-service-writes branch from 7bf983c to e34b7eb Compare October 26, 2026 08:00
@moetemp

moetemp commented Oct 27, 2026

Copy link
Copy Markdown
Owner Author

Moved to moetemp/sdk-rust#216 (K6). The crate split in two. The shared runtime is now the crate temporalio-streams in sdk-rust (moetemp/sdk-rust#212 to #220), and the Redis Store is temporalio-streams-redis in temporal-community/sdk-streams (#1 to #3).

@moetemp moetemp closed this Oct 27, 2026
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant