Struct OtlpDeserializer

pub struct OtlpDeserializer { /* private fields */ }

Deserializer that builds Events from a byte frame containing OTLP protobuf data.

This deserializer decodes events using the OTLP protobuf specification. It handles the three OTLP signal types: logs, metrics, and traces.

The implementation supports three OTLP message types:

• ExportLogsServiceRequest → Log events with resourceLogs field
• ExportMetricsServiceRequest → Log events with resourceMetrics field
• ExportTraceServiceRequest → Trace events with resourceSpans field

One major caveat here is that the incoming metrics will be parsed as logs but they will preserve the OTLP format. This means that components that work on metrics, will not be compatible with this output. However, these events can be forwarded directly to a downstream OTEL collector.

This is the inverse of what the OTLP encoder does, ensuring round-trip compatibility with the opentelemetry source when use_otlp_decoding is enabled.

Implementations

impl OtlpDeserializer

pub fn new_with_signals(signals: IndexSet<OtlpSignalType>) -> Self

Creates a new OTLP deserializer with custom signal support. During parsing, each signal type is tried in order until one succeeds.

Trait Implementations

impl Clone for OtlpDeserializer

fn clone(&self) -> OtlpDeserializer

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for OtlpDeserializer

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

Formats the value using the given formatter.

impl Default for OtlpDeserializer

fn default() -> Self

Returns the “default value” for a type.

impl Deserializer for OtlpDeserializer

fn parse( &self, bytes: Bytes, log_namespace: LogNamespace, ) -> Result<SmallVec<[Event; 1]>>

Parses structured events from bytes.