Skip to content

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

ParameterTypeDescription
config?TelemetryBusConfigOptional 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();