DTaaS M3: ORBIT-pubsub stream backend — data plane inside the token domain (closes R7) - #6

Closed

andre-merzky wants to merge 34 commits into

BenCarter44:mainfrom

andre-merzky:feature/dtaas-m3

Commits on Aug 15, 2026

Namespaced topics, stream teardown, embeddable broker

andre-merzky
and
claude
committed
cfa3859
Runtime lifecycle: terminal stop, failure state, describe()

andre-merzky
and
claude
committed
655d1c6
Packaging: real dependencies, exports, pytest/tox scaffolding

andre-merzky
and
claude
committed
b2925f8
Unit tests for teardown, namespacing, streams and broker

andre-merzky
and
claude
committed
78f6357
Migrate the demos to the M0 API

andre-merzky
and
claude
committed
34ffe75
Harden the broker launcher stop path

andre-merzky
and
claude
committed
f57123b
Review findings: stream resilience and join-safe teardown

andre-merzky
and
claude
committed
1dbddfa

Commits on Aug 16, 2026

docs: add the DTaaS v1 plan and the P0 liveness-scoped-calls plan

andre-merzky
and
claude
committed
d8e42f4

Commits on Aug 17, 2026

A stream endpoint a task can carry: PubSubConfig

andre-merzky
and
claude
committed
2aba3e4
A component failure stops the twin

andre-merzky
and
claude
committed
1fe23d5
The graph opens at its input edge: external channels

andre-merzky
and
claude
committed
3fd5638
Plan: sensors are external, add_input is the entry path

andre-merzky
and
claude
committed
09eb2ba
Bounded stream connect, embedded broker addresses, public get_inference

andre-merzky
and
claude
committed
5a9f639
The dt ORBIT plugin: sessions, twins, client, wire format

andre-merzky
and
claude
committed
7aee148
Port the remote demo to the dt plugin, retire the ZMQ prototype

andre-merzky
and
claude
committed
116f9fb
Tests for the dt plugin: units plus a live-stack integration suite

andre-merzky
and
claude
committed
c5d0ab5
Check in the in-situ latency harness and document the service

andre-merzky
and
claude
committed
df7b208
Keep the service tests skippable, and propagate real cancellations

andre-merzky
and
claude
committed
e7a7648
Review findings: decode later, bound harder, own the engine build

andre-merzky
and
claude
committed
471cf75
A ROSE streaming learner that lives and dies with its twin

andre-merzky
and
claude
committed
5b0f1ac
The 'exsitu' engine: dual-engine twins, and a visible endpoint loss

andre-merzky
and
claude
committed
09bf265
A demo where the model visibly changes under the prediction

andre-merzky
and
claude
committed
353217a
Tests: a learner on a second endpoint, and a loss that is not silent

andre-merzky
and
claude
committed
ef7cc0a
Document the second engine and what a lost endpoint looks like

andre-merzky
and
claude
committed
ed73467
Review findings: a loss that outlives its announcement

andre-merzky
and
claude
committed
2a48282
A second data plane: the ORBIT-backed pubsub backend

andre-merzky
and
claude
committed
bd73279
Unit tests for the orbit backend, against a loopback event router

andre-merzky
and
claude
committed
7925544
A live stack whose data plane is ORBIT, and no ZMQ broker in it

andre-merzky
and
claude
committed
c190403
What the token domain costs a stream hop

andre-merzky
and
claude
committed
1e013d8
Document the second data plane, and what it closes

andre-merzky
and
claude
committed
c0f3de1
A waiter woken by close() gets the closed-client error

andre-merzky
and
claude
committed
e69a7b6
Review findings: the third queue, a stranded waiter, an explicit backend

andre-merzky
and
claude
committed
5d338ec
test: the travelled config gained the orbit broker field

andre-merzky
and
claude
committed
bc5c282
The ORBIT plane carries external channels too

andre-merzky
and
claude
committed
8d7b4d2