Connectum API Reference / @connectum/otel / interceptor / createOtelInterceptor

Function: createOtelInterceptor()

createOtelInterceptor(options?): Interceptor

Defined in: interceptor.ts:61

Creates a ConnectRPC interceptor that instruments RPC calls with OpenTelemetry tracing and/or metrics.

The interceptor follows OpenTelemetry semantic conventions for RPC:

• Creates server spans with standard RPC attributes
• Records call duration, request size, and response size metrics
• Supports context propagation with configurable trust mode
• Handles both unary and streaming calls

Parameters

options?

OtelInterceptorOptions = {}

Configuration options for the interceptor

Returns

Interceptor

A ConnectRPC Interceptor function

Example

import { createOtelInterceptor } from '@connectum/otel';
import { createServer } from '@connectum/core';

const server = createServer({
    services: [routes],
    interceptors: [createOtelInterceptor({
        serverPort: 5000,
        filter: ({ service }) => !service.includes("Health"),
    })],
});