Module otel 

OpenTelemetry OTLP/gRPC source connector. OpenTelemetry (OTLP/gRPC) source connector.

Receives trace spans, metrics, or logs from OTel exporters and collectors via the standard OTLP/gRPC protocol. Each source handles one signal type on its own port.

CREATE SOURCE traces FROM OTEL (port = '4317', signals = 'traces');
CREATE SOURCE metrics FROM OTEL (port = '4318', signals = 'metrics');
CREATE SOURCE logs FROM OTEL (port = '4319', signals = 'logs');

Re-exports

pub use config::OtelSignal;

pub use config::OtelSourceConfig;

pub use source::OtelSource;

Modules

config

OTel source connector configuration.

convert

Protobuf-to-Arrow conversion for OTel traces, metrics, and logs.

schema

Arrow schemas for OTel signal types.

server

Tonic gRPC server implementing OTLP trace, metrics, and logs services.

source

SourceConnector implementation for the OTel OTLP/gRPC receiver.

Functions

register_otel_source

Registers the OTel source connector with the given registry.