Issues

• Per-stream max message size, configurable like max_backlog / max_inbound / max_in_flight

  nhobin219/streamcast#170 · Filter by author nhobin219 opened on Oct 20, 2026

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

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

• connect(catch_up=True): no way to set memory_limit on the snapshot the catch-up opens

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

• catch_up: first recv holds up to 1M rows of the gap in memory; connect scans every row's offset

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

• Declared identity columns: a hidden xxh3_128 key filled on ingest, so a composite key costs nothing to filter on

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

• 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

• Split new and open for Stream and Store: an ordinary startup creates an empty stream or store where a replica exists

  nhobin219/streamcast#146 · Filter by author nhobin219 opened on Oct 14, 2026
  1

• serve mints a new stream_id for an existing stream whose local metadata is gone, and overwrites the published copy's

  nhobin219/streamcast#144 · Filter by author nhobin219 opened on Oct 14, 2026
  1

• 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

• publish: a send on a connection the server already closed can raise AttributeError (from websockets' transport.abort) instead of ConnectionClosed; a client that reconnects on ConnectionClosed dies

  nhobin219/streamcast#106 · Filter by author nhobin219 opened on Oct 5, 2026

• 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