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

Open

moedash wants to merge 37 commits into

mainfrom

moe/AI-198-server-side-streams

Commits on Sep 14, 2026

Added the stream protos, commands, and API surface.
moedash
committed
938bf8b
Added the stream log store and kept the scavenger off it.
moedash
committed
4e9314b
Added the CHASM stream component with floor-aware retention.
moedash
committed
2ea6176
Added the stream service RPCs and the frontend wiring.
moedash
committed
cd3307e
Let a workflow publish and subscribe to its stream with commands.
moedash
committed
d014cf3
Delivered consumed ranges through Workflow Tasks, routed across hosts.
moedash
committed
53e99e9
Added the functional tests and the SDK validation server host.
moedash
committed
27ae8a3

Commits on Sep 16, 2026

Formatted the stream proto and the cross-host test.
moedash
committed
03a12b1
Regenerated the execution store wrappers.
moedash
committed
083ad12
Restored the v1.10 and v0.10 schema manifests.
moedash
committed
9682147
Added the stream_log schema as a new version per database.
moedash
committed
197f878
Made the publish cost measurement opt-in.
moedash
committed
fac8b43
Fixed the MySQL stream log read bounds.
moedash
committed
8f255ca
Regenerated the stream state proto.
moedash
committed
d56c986
Re-pinned api-go to the branch head.
moedash
committed
989b303
Regenerated the getproto import map.
moedash
committed
c9afe90
Tidied the mixed brain test module.
moedash
committed
8bb1ad0
Fixed the build-tests target for the mixed brain module.
moedash
committed
04d7060

Commits on Sep 17, 2026

Made the otel handler test tolerate empty exemplar slices.
moedash
committed
e33d2d4
Cleared the stale test log between local test runs.
moedash
committed
ed1d612
Required protobuf payloads from the system Nexus endpoint.
moedash
committed
95719ed

Commits on Sep 18, 2026

Re-pinned api-go to the documented stream protos.
moedash
committed
ed762e1
Removed the unused stream log store and its schema.
moedash
committed
40f54b0
Routed the command-path subscription through the stream service.
moedash
committed
bf40768

Commits on Sep 19, 2026

Failed the workflow task when a stream range cannot be served.
moedash
committed
dee9c68
Failed the workflow task on a refused stream command.
moedash
committed
524dcec
Proved that a failed workflow task publishes nothing.
moedash
committed
73fccdf
Regenerated the stream protos after the comment edits.
moedash
committed
18a053d
Treated a stream message with no kind as data.
moedash
committed
ee89886
Dropped the implicit head pin from the RPC append handlers.
moedash
committed
cf37d21
Moved the stream limits to dynamic config and budgeted owned streams.
moedash
committed
31ab971
Keyed consumer pins by run and released them when the run closes.
moedash
committed
774751d
Made retention and deletion respect an active consumer.
moedash
committed
d3602ee
Stopped a filtered stream read from skipping unexamined offsets.
moedash
committed
98320c4
Validated stream ids, names, offsets and page sizes on the frontend.
moedash
committed
b6c8b0c
Wrapped long lines, tagged every handler and rewrote stale comments.
moedash
committed
fb3567d
Cleared the linter findings in the stream code.
moedash
committed
edfba28