Marco

Marco Agent Bridge

HTTP+SSE process controller -- start/stop/restart services via plugin.json manifests + Mx bus.

Marco Agent Bridge (v2026-08-02T101544Z-ab2bbdebf5) 2026-08-01 | HTTP+SSE process controller -- start/stop/restart services via plugin.json manifests + Mx bus. 1 - HTTP+SSE Controller marco_agent_bridge.py GET /api/marco/vault/* POST /api/health MARCO_URL MARCO_AGENT_PORT _registry AgentRecord _prune_stale() last_heartbeat HTTP request 2 - Process Controller ProcessController dispatch() _start() _stop() _services ManagedService name cmd control message 3 - SSE Fan-out _broadcast() json.dumps(event) asyncio.Queue.put_nowait(data) _sse_queues asyncio.Queue event event data 1. Receive HTTP request 2. Process control message via dispa… 3. Start/stop/restart service using… 4. Broadcast event to SSE subscribers 5. Prune stale agents HTTP Request Example { "method": "POST", "url": "/api/marco/vault/thing" } SSE Event Example { "type": "heartbeat", "agent_id": "12345" } The source does not show any direct interaction with the Mx bus or Hank vault, only proxying through HTTP requests. Legend actor = initiates work · process = code path · store = state on disk · bus = durable queue · dashed = separate process cyan = request flow · pink = state read/write · dashed green = pull / return path · red = refusal

Provenance

This drawing is generated, not drawn. It is rebuilt from the source files below, so when they change the picture changes — a diagram here cannot quietly describe a system that no longer works this way.

Owner
Marco
Slug
marco-agent-bridge
Rendered
2026-08-02T101544Z
From commit
ab2bbdebf5
Watches
1 path
  • daemon/src/marco_agent_bridge.py