|
2 | 2 |
|
3 | 3 | namespace overlaybd_otel { |
4 | 4 |
|
5 | | -void InitTracer() |
6 | | -{ |
7 | | - auto exporter = opentelemetry::exporter::trace::OStreamSpanExporterFactory::Create(); |
| 5 | +void InitTracer() { |
| 6 | + // Create OTLP HTTP exporter configuration |
| 7 | + opentelemetry::exporter::otlp::OtlpHttpExporterOptions opts; |
| 8 | + |
| 9 | + // Create OTLP/HTTP exporter using the factory |
| 10 | + auto exporter = opentelemetry::exporter::otlp::OtlpHttpExporterFactory::Create(opts); |
| 11 | + |
| 12 | + opentelemetry::sdk::trace::BatchSpanProcessorOptions bspOpts{}; |
8 | 13 | auto processor = |
9 | | - opentelemetry::sdk::trace::SimpleSpanProcessorFactory::Create(std::move(exporter)); |
| 14 | + opentelemetry::sdk::trace::BatchSpanProcessorFactory::Create(std::move(exporter), bspOpts); |
| 15 | + |
| 16 | + // Create a simple processor (we'll use simple instead of batch for now) |
| 17 | + // auto processor = |
| 18 | + // opentelemetry::sdk::trace::SimpleSpanProcessorFactory::Create(std::move(exporter)); |
10 | 19 | std::vector<std::unique_ptr<opentelemetry::sdk::trace::SpanProcessor>> processors; |
11 | 20 | processors.push_back(std::move(processor)); |
12 | | - // Default is an always-on sampler. |
| 21 | + |
| 22 | + // Default is an always-on sampler |
13 | 23 | std::unique_ptr<opentelemetry::sdk::trace::TracerContext> context = |
14 | 24 | opentelemetry::sdk::trace::TracerContextFactory::Create(std::move(processors)); |
15 | 25 | std::shared_ptr<opentelemetry::trace::TracerProvider> provider = |
16 | 26 | opentelemetry::sdk::trace::TracerProviderFactory::Create(std::move(context)); |
| 27 | + |
17 | 28 | // Set the global trace provider |
18 | 29 | opentelemetry::sdk::trace::Provider::SetTracerProvider(provider); |
19 | 30 |
|
20 | | - // set global propagator |
21 | | - opentelemetry::context::propagation::GlobalTextMapPropagator::SetGlobalPropagator( |
22 | | - opentelemetry::nostd::shared_ptr<opentelemetry::context::propagation::TextMapPropagator>( |
23 | | - new opentelemetry::trace::propagation::HttpTraceContext())); |
| 31 | + // // set global propagator |
| 32 | + // opentelemetry::context::propagation::GlobalTextMapPropagator::SetGlobalPropagator( |
| 33 | + // opentelemetry::nostd::shared_ptr<opentelemetry::context::propagation::TextMapPropagator>( |
| 34 | + // new opentelemetry::trace::propagation::HttpTraceContext())); |
24 | 35 | } |
25 | 36 |
|
26 | | -void CleanupTracer() |
27 | | -{ |
| 37 | +void CleanupTracer() { |
28 | 38 | std::shared_ptr<opentelemetry::trace::TracerProvider> none; |
29 | 39 | opentelemetry::sdk::trace::Provider::SetTracerProvider(none); |
30 | 40 | } |
31 | 41 |
|
32 | | -opentelemetry::nostd::shared_ptr<opentelemetry::trace::Tracer> get_tracer(std::string tracer_name) |
33 | | -{ |
| 42 | +opentelemetry::nostd::shared_ptr<opentelemetry::trace::Tracer> get_tracer(std::string tracer_name) { |
34 | 43 | auto provider = opentelemetry::trace::Provider::GetTracerProvider(); |
35 | 44 | return provider->GetTracer(tracer_name); |
36 | 45 | } |
|
0 commit comments