harald/teepot
1
0
Fork 0
mirror of https://github.com/matter-labs/teepot.git synced 2025-07-22 23:44:48 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

Merge pull request #294 from matter-labs/proper_otlp_http_logging

Browse source 
feat(config): update OTLP endpoint and protocol handling
This commit is contained in:
Harald Hoyer 2025-03-26 16:21:07 +01:00 • committed by GitHub
commit 7258452b79
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 26 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

36
crates/teepot/src/config/mod.rs
View file

@ -147,8 +147,8 @@ impl Default for TelemetryOtlpConfig {
fn default() -> Self { fn default() -> Self {
Self { Self {
enable: true, enable: true,
endpoint: "http://127.0.0.1:4317".to_string(), endpoint: "http://127.0.0.1:4318/v1/logs".to_string(),
protocol: "grpc".to_string(), protocol: "http/json".to_string(),
} }
} }
} }
@ -269,15 +269,31 @@ fn init_telemetry(
) )
.build(); .build();
// Configure the OTLP exporter // Parse the protocol from the configuration
let logging_provider = SdkLoggerProvider::builder() let protocol = protocol_from_string(&config.otlp.protocol)?;
.with_batch_exporter(
opentelemetry_otlp::LogExporter::builder() // Configure the OTLP exporter based on the protocol
.with_tonic() let exporter_builder = opentelemetry_otlp::LogExporter::builder();
// Choose transport based on protocol
let exporter = match protocol {
opentelemetry_otlp::Protocol::Grpc => exporter_builder
.with_tonic()
.with_endpoint(&config.otlp.endpoint)
.with_protocol(protocol)
.build()?,
opentelemetry_otlp::Protocol::HttpBinary | opentelemetry_otlp::Protocol::HttpJson => {
exporter_builder
.with_http()
.with_endpoint(&config.otlp.endpoint) .with_endpoint(&config.otlp.endpoint)
.with_protocol(protocol_from_string(&config.otlp.protocol)?) .with_protocol(protocol)
.build()?, .build()?
) }
};
// Configure the logging provider with the exporter
let logging_provider = SdkLoggerProvider::builder()
.with_batch_exporter(exporter)
.with_resource(resource) .with_resource(resource)
.build(); .build();