mockforge_tracing/
tracer.rs

1//! OpenTelemetry tracer initialization and configuration
2
3use crate::exporter::ExporterType;
4use opentelemetry::global;
5use opentelemetry_otlp::WithExportConfig;
6use opentelemetry_sdk::trace::TracerProvider;
7use opentelemetry_sdk::Resource;
8use std::error::Error;
9use std::time::Duration;
10
11/// Tracing configuration
12#[derive(Debug, Clone)]
13pub struct TracingConfig {
14    /// Service name for traces
15    pub service_name: String,
16    /// Exporter type (Jaeger or OTLP)
17    pub exporter_type: ExporterType,
18    /// Jaeger endpoint (e.g., "http://localhost:14268/api/traces")
19    pub jaeger_endpoint: Option<String>,
20    /// OTLP endpoint (e.g., "http://localhost:4317")
21    pub otlp_endpoint: Option<String>,
22    /// Sampling rate (0.0 to 1.0)
23    pub sampling_rate: f64,
24    /// Environment (e.g., "development", "production")
25    pub environment: String,
26    /// Service version
27    pub service_version: Option<String>,
28}
29
30impl Default for TracingConfig {
31    fn default() -> Self {
32        Self {
33            service_name: "mockforge".to_string(),
34            exporter_type: ExporterType::Jaeger,
35            jaeger_endpoint: Some("http://localhost:14268/api/traces".to_string()),
36            otlp_endpoint: None,
37            sampling_rate: 1.0,
38            environment: "development".to_string(),
39            service_version: None,
40        }
41    }
42}
43
44impl TracingConfig {
45    /// Create config for Jaeger exporter
46    pub fn with_jaeger(service_name: String, endpoint: String) -> Self {
47        Self {
48            service_name,
49            exporter_type: ExporterType::Jaeger,
50            jaeger_endpoint: Some(endpoint),
51            otlp_endpoint: None,
52            ..Default::default()
53        }
54    }
55
56    /// Create config for OTLP exporter
57    pub fn with_otlp(service_name: String, endpoint: String) -> Self {
58        Self {
59            service_name,
60            exporter_type: ExporterType::Otlp,
61            jaeger_endpoint: None,
62            otlp_endpoint: Some(endpoint),
63            ..Default::default()
64        }
65    }
66
67    /// Set sampling rate
68    pub fn with_sampling_rate(mut self, rate: f64) -> Self {
69        self.sampling_rate = rate;
70        self
71    }
72
73    /// Set environment
74    pub fn with_environment(mut self, env: String) -> Self {
75        self.environment = env;
76        self
77    }
78
79    /// Set service version
80    pub fn with_service_version(mut self, version: String) -> Self {
81        self.service_version = Some(version);
82        self
83    }
84}
85
86/// Initialize the OpenTelemetry tracer
87pub fn init_tracer(
88    config: TracingConfig,
89) -> Result<global::BoxedTracer, Box<dyn Error + Send + Sync>> {
90    match config.exporter_type {
91        ExporterType::Jaeger => init_jaeger_tracer(config),
92        ExporterType::Otlp => init_otlp_tracer(config),
93    }
94}
95
96/// Initialize Jaeger tracer
97fn init_jaeger_tracer(
98    config: TracingConfig,
99) -> Result<global::BoxedTracer, Box<dyn Error + Send + Sync>> {
100    let endpoint = config.jaeger_endpoint.ok_or("Jaeger endpoint not configured")?;
101
102    // Install the tracer provider (this sets it as global)
103    // opentelemetry-jaeger 0.21 uses a different runtime API
104    #[allow(deprecated)]
105    let _tracer_provider = opentelemetry_jaeger::new_agent_pipeline()
106        .with_service_name(&config.service_name)
107        .with_endpoint(&endpoint)
108        .install_simple()?;
109
110    // Get the tracer from the global provider
111    let tracer = global::tracer("mockforge");
112    Ok(tracer)
113}
114
115/// Initialize OTLP tracer
116fn init_otlp_tracer(
117    config: TracingConfig,
118) -> Result<global::BoxedTracer, Box<dyn Error + Send + Sync>> {
119    let endpoint = config.otlp_endpoint.ok_or("OTLP endpoint not configured")?;
120
121    // Build resource attributes
122    // Note: In opentelemetry_sdk 0.22, Resource creation API
123    let resource = Resource::default();
124
125    // Create OTLP exporter with gRPC protocol (opentelemetry-otlp 0.22 API)
126    // Build the exporter configuration
127    let mut exporter_builder = opentelemetry_otlp::TonicExporterBuilder::default();
128    exporter_builder = exporter_builder.with_endpoint(endpoint);
129    exporter_builder = exporter_builder.with_timeout(Duration::from_secs(10));
130
131    // Build the exporter
132    let exporter = exporter_builder.build_span_exporter()?;
133
134    // Build tracer provider using opentelemetry_sdk directly
135    let tracer_provider = TracerProvider::builder()
136        .with_batch_exporter(exporter, opentelemetry_sdk::runtime::Tokio)
137        .with_config(
138            opentelemetry_sdk::trace::Config::default()
139                .with_resource(resource)
140                .with_sampler(opentelemetry_sdk::trace::Sampler::TraceIdRatioBased(
141                    config.sampling_rate,
142                )),
143        )
144        .build();
145
146    // Set the tracer provider as global
147    global::set_tracer_provider(tracer_provider.clone());
148
149    // Get the tracer from the global provider
150    let tracer = global::tracer("mockforge");
151
152    Ok(tracer)
153}
154
155/// Shutdown the tracer and flush pending spans
156pub fn shutdown_tracer() {
157    global::shutdown_tracer_provider();
158}
159
160#[cfg(test)]
161mod tests {
162    use super::*;
163
164    #[test]
165    fn test_default_config() {
166        let config = TracingConfig::default();
167        assert_eq!(config.service_name, "mockforge");
168        assert_eq!(config.sampling_rate, 1.0);
169        assert_eq!(config.environment, "development");
170        assert_eq!(config.exporter_type, ExporterType::Jaeger);
171        assert!(config.jaeger_endpoint.is_some());
172        assert!(config.otlp_endpoint.is_none());
173    }
174
175    #[test]
176    fn test_jaeger_config() {
177        let config = TracingConfig::with_jaeger(
178            "test-service".to_string(),
179            "http://custom:14268/api/traces".to_string(),
180        )
181        .with_sampling_rate(0.5)
182        .with_environment("staging".to_string())
183        .with_service_version("1.0.0".to_string());
184
185        assert_eq!(config.service_name, "test-service");
186        assert_eq!(config.exporter_type, ExporterType::Jaeger);
187        assert_eq!(config.jaeger_endpoint, Some("http://custom:14268/api/traces".to_string()));
188        assert_eq!(config.sampling_rate, 0.5);
189        assert_eq!(config.environment, "staging");
190        assert_eq!(config.service_version, Some("1.0.0".to_string()));
191    }
192
193    #[test]
194    fn test_otlp_config() {
195        let config = TracingConfig::with_otlp(
196            "test-service".to_string(),
197            "http://otel-collector:4317".to_string(),
198        )
199        .with_sampling_rate(0.8)
200        .with_environment("production".to_string())
201        .with_service_version("2.0.0".to_string());
202
203        assert_eq!(config.service_name, "test-service");
204        assert_eq!(config.exporter_type, ExporterType::Otlp);
205        assert_eq!(config.otlp_endpoint, Some("http://otel-collector:4317".to_string()));
206        assert!(config.jaeger_endpoint.is_none());
207        assert_eq!(config.sampling_rate, 0.8);
208        assert_eq!(config.environment, "production");
209        assert_eq!(config.service_version, Some("2.0.0".to_string()));
210    }
211}
mockforge_tracing/tracer.rs

mockforge_tracing/
tracer.rs
