Repository navigation

Added server-side streams for workflows and external clients. - #2

Closed

moetemp wants to merge 47 commits into

mainfrom

moe/AI-198-server-side-streams

Commits on Sep 14, 2026
Commits on Sep 16, 2026
- Formatted the stream proto and the cross-host test.
  moetemp
  committed
  03a12b1
- Regenerated the execution store wrappers.
  moetemp
  committed
  083ad12
- Restored the v1.10 and v0.10 schema manifests.
  moetemp
  committed
  9682147
- Added the stream_log schema as a new version per database.
  moetemp
  committed
  197f878
- Made the publish cost measurement opt-in.
  moetemp
  committed
  fac8b43
- Fixed the MySQL stream log read bounds.
  moetemp
  committed
  8f255ca
- Regenerated the stream state proto.
  moetemp
  committed
  d56c986
- Re-pinned api-go to the branch head.
  moetemp
  committed
  989b303
- Regenerated the getproto import map.
  moetemp
  committed
  c9afe90
- Tidied the mixed brain test module.
  moetemp
  committed
  8bb1ad0
- Fixed the build-tests target for the mixed brain module.
  moetemp
  committed
  04d7060
Commits on Sep 17, 2026
- Made the otel handler test tolerate empty exemplar slices.
  moetemp
  committed
  e33d2d4
- Cleared the stale test log between local test runs.
  moetemp
  committed
  ed1d612
- Required protobuf payloads from the system Nexus endpoint.
  moetemp
  committed
  95719ed
Commits on Sep 18, 2026
- Re-pinned api-go to the documented stream protos.
  moetemp
  committed
  ed762e1
- Removed the unused stream log store and its schema.
  moetemp
  committed
  40f54b0
- Routed the command-path subscription through the stream service.
  moetemp
  committed
  bf40768
Commits on Sep 19, 2026
- Failed the workflow task when a stream range cannot be served.
  moetemp
  committed
  dee9c68
- Failed the workflow task on a refused stream command.
  moetemp
  committed
  524dcec
- Proved that a failed workflow task publishes nothing.
  moetemp
  committed
  73fccdf
- Regenerated the stream protos after the comment edits.
  moetemp
  committed
  18a053d
- Treated a stream message with no kind as data.
  moetemp
  committed
  ee89886
- Dropped the implicit head pin from the RPC append handlers.
  moetemp
  committed
  cf37d21
- Moved the stream limits to dynamic config and budgeted owned streams.
  moetemp
  committed
  31ab971
- Keyed consumer pins by run and released them when the run closes.
  moetemp
  committed
  774751d
- Made retention and deletion respect an active consumer.
  moetemp
  committed
  d3602ee
- Stopped a filtered stream read from skipping unexamined offsets.
  moetemp
  committed
  98320c4
- Validated stream ids, names, offsets and page sizes on the frontend.
  moetemp
  committed
  b6c8b0c
- Wrapped long lines, tagged every handler and rewrote stale comments.
  moetemp
  committed
  fb3567d
- Cleared the linter findings in the stream code.
  moetemp
  committed
  edfba28
Commits on Sep 21, 2026