Issues

• Refactor the package layout: _broker/, _client/, _core/, and split _stream.py

  nhobin219/streamcast#202 · Filter by author nhobin219 opened on Oct 25, 2026

• Outbox backlog visibility: pending_rows, pending_bytes, oldest pending age, and a backlog callback

  nhobin219/streamcast#195 · Filter by author nhobin219 opened on Oct 24, 2026

• Consolidate the FastAPI broker, simplify inbox backpressure and measure configurable fairness

  nhobin219/streamcast#194 · Filter by author nhobin219 opened on Oct 24, 2026
  4

• Immediate inbox context exit can leave its subscription open

  nhobin219/streamcast#191 · Filter by author nhobin219 opened on Oct 24, 2026

• Design a dynamic stream lifecycle and HTTP control plane

  nhobin219/streamcast#189 · Filter by author nhobin219 opened on Oct 23, 2026
  8

• Writer lease (conditional-write lease with self-stop), then flip Stream.open restore=True

  nhobin219/streamcast#184 · Filter by author nhobin219 opened on Oct 21, 2026
  7

• Postgres-backed logs for the broker (via litelink), later HA Postgres

  nhobin219/streamcast#165 · Filter by author nhobin219 opened on Oct 18, 2026

• A query the manifests cannot prune reads every data file one after another

  nhobin219/streamcast#155 · Filter by author nhobin219 opened on Oct 17, 2026
  1

• publish: a send racing the connection's close raises IndexError('pop from an empty deque') instead of ConnectionClosed

  nhobin219/streamcast#154 · Filter by author nhobin219 opened on Oct 16, 2026

• snapshot: a failed S3 read names the endpoint and region it tried

  nhobin219/streamcast#153 · Filter by author nhobin219 opened on Oct 16, 2026

• connect(cursor=): a cursor that saves only on commit, for a consumer that reads ahead of its work

  nhobin219/streamcast#122 · Filter by author nhobin219 opened on Oct 9, 2026
  1

• Relay: a read-only broker that fans out an upstream stream

  nhobin219/streamcast#87 · Filter by author nhobin219 opened on Oct 3, 2026
  1

• A config class for serve's settings

  nhobin219/streamcast#84 · Filter by author nhobin219 opened on Oct 3, 2026

• Expose a bulk-load path: Stream.ingest(...) wrapping litelink ingest(publish=True), and a Stream.flush() for short-lived writers

  nhobin219/streamcast#75 · Filter by author nhobin219 opened on Oct 2, 2026

• Stream.snapshot / scan / sql / live: accept a caller-owned DuckDB connection (or a cache setting) so repeated reads stay local

  nhobin219/streamcast#74 · Filter by author nhobin219 opened on Oct 2, 2026
  2

• serve(replicate=True) by default puts a litestream sidecar on every served log; the cost is a bucket-level surprise

  nhobin219/streamcast#73 · Filter by author nhobin219 opened on Oct 2, 2026

• Online migrations: buffer sends while the next log is created

  enhancement
  nhobin219/streamcast#67 · Filter by author nhobin219 opened on Oct 1, 2026
  3

• Announce publishes on a second WebSocket stream, so live views rebase on publish

  enhancement
  nhobin219/streamcast#63 · Filter by author nhobin219 opened on Oct 1, 2026

• Compact a migrated stream's retired logs

  enhancement
  nhobin219/streamcast#58 · Filter by author nhobin219 opened on Oct 1, 2026

• Prune retired logs from where= and the SQL WHERE clause, soundly

  enhancement
  nhobin219/streamcast#57 · Filter by author nhobin219 opened on Oct 1, 2026

• Manifest pruning: a seeded generative test beside the exhaustive table

  enhancement
  nhobin219/streamcast#54 · Filter by author nhobin219 opened on Oct 1, 2026

• Support JSON, Arrow or Protobuf on the wire, negotiated per direction

  nhobin219/streamcast#29 · Filter by author nhobin219 opened on Sep 29, 2026

• Stream.rewrite: merge sealed logs, so a stream does not become a query over hundreds of tables

  nhobin219/streamcast#28 · Filter by author nhobin219 opened on Sep 29, 2026
  1

• Bound what a pipelined publisher holds outbound, and never drop a publish

  nhobin219/streamcast#26 · Filter by author nhobin219 opened on Sep 29, 2026

• Change a subscription's where= without reconnecting

  nhobin219/streamcast#23 · Filter by author nhobin219 opened on Sep 26, 2026