Struct BusBridge 

pub struct BusBridge { /* private fields */ }

A read-only bridge from the HTTP bus SSE stream into the MCP process.

Call BusBridge::spawn to start the background reader, then query via BusBridge::recent_events or BusBridge::status.

Implementations

impl BusBridge

pub fn new(bus_url: String) -> Self

Create a new bridge (does not start the background task).

pub fn spawn(self) -> Arc<Self>

Spawn the SSE reader as a background tokio task.

Returns Self wrapped in an Arc for sharing with tool handlers.

pub async fn recent_events( &self, topic_filter: Option<&str>, limit: usize, since: Option<DateTime<Utc>>, ) -> Vec<BusEnvelope>

Query recent events with optional topic filter and limit.

pub fn status(&self) -> BusBridgeStatus

Current bridge status summary (JSON-friendly).

pub async fn buffer_len(&self) -> usize

Buffer size (number of envelopes currently held).

Trait Implementations

impl Debug for BusBridge

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.