Skip to content

[Brook K8] Served reads with long polls, Topic filters, last-N reads and byte caps. - #49

Closed
moetemp wants to merge 1 commit into
moe/brook/review/k6-service-writesfrom
moe/brook/review/k8-reads
Closed

moetemp wants to merge 1 commit into
moe/brook/review/k6-service-writesfrom
moe/brook/review/k8-reads

Conversation

@moetemp

@moetemp moetemp commented Oct 25, 2026 •

Copy link
Copy Markdown
Owner

What changed?

This PR serves ReadRecords, with long polls, Topic filters, last-N reads and byte caps.

  • A read long-polls up to 60 s. A filtered read scans at most 10,000 entries, then returns.
  • A gap that retention or expiry left fails the read, so a Reader can't miss it.
  • to_offset and wake_only fail with stream_unsupported, since only the native server
    serves them.

Depends on #48 (K6), and K7 is based on it. Review lane is the Rust reviewers.
Part of the Brook review series.

Why?

Reads are about half of the service. The long poll and the scan cap need the most review time.

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/k8-reads branch from 7005750 to 008f1c7 Compare October 25, 2026 22:10
@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/k8-reads branch 2 times, most recently from 6941b5e to 7c47aa6 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
A read waits for the create and for new Records, scans a bounded part
of the log per page, and fails on a gap that the Retention left. The
service tests that read back what the writes stored come here too.
@moetemp
moetemp force-pushed the moe/brook/review/k6-service-writes branch from 7bf983c to e34b7eb Compare October 26, 2026 08:00
@moetemp
moetemp force-pushed the moe/brook/review/k8-reads branch from 7c47aa6 to 5a80b63 Compare October 26, 2026 08:00
@moetemp

moetemp commented Oct 27, 2026

Copy link
Copy Markdown
Owner Author

Moved to moetemp/sdk-rust#217 (K8). 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