Function: createTelemetryBus()
ts
function createTelemetryBus(config?): Promise<TelemetryBusInstance>;Defined in: packages/core/src/observability/TelemetryBus.ts:343
Create an out-of-band telemetry bus for MCP Fusion.
The returned emit function is the TelemetrySink to pass to AttachOptions.telemetry. It broadcasts events as NDJSON to all connected TUI clients via IPC.
When no clients are connected, emit() is a no-op — zero overhead.
Parameters
| Parameter | Type | Description |
|---|---|---|
config? | TelemetryBusConfig | Optional configuration |
Returns
Promise<TelemetryBusInstance>
A promise that resolves to the running bus instance
Example
typescript
import { createTelemetryBus } from '@vinkius-core/mcp-fusion/observability';
const bus = await createTelemetryBus();
// Pass to server attachment
registry.attachToServer(server, {
contextFactory: createContext,
telemetry: bus.emit,
});
// On shutdown
await bus.close();