Skip to main content

Module bus_bridge

Module bus_bridge 

Source
Expand description

MCP-to-Bus bridge

Connects to the HTTP server’s /v1/bus/stream SSE endpoint and buffers recent BusEnvelopes in a ring buffer. The MCP server exposes this data through tools (bus_events, bus_status) and resources (codetether://bus/events/recent).

The bridge runs as a background tokio task and reconnects automatically on transient failures.

Structs§

BusBridge
A read-only bridge from the HTTP bus SSE stream into the MCP process.
BusBridgeStatus
Status snapshot returned by BusBridge::status.

Functions§

resolve_default_worker_bus_url
Resolve the default worker bus connection when the control plane has exactly one active worker advertising a first-class bus/http interface.
resolve_worker_bus_url
Resolve a worker’s first-class bus connection via the control plane.
resolve_worker_bus_url_for_workspace
resolve_workspace_id_from_path