1 // -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
2 // vim: ts=8 sw=2 smarttab
4 #include "common/ceph_context.h"
5 #include "global/global_context.h"
9 #include "opentelemetry/sdk/trace/batch_span_processor.h"
10 #include "opentelemetry/sdk/trace/tracer_provider.h"
11 #include "opentelemetry/exporters/jaeger/jaeger_exporter.h"
15 const opentelemetry::nostd::shared_ptr
<opentelemetry::trace::Tracer
> Tracer::noop_tracer
= opentelemetry::trace::Provider::GetTracerProvider()->GetTracer("no-op", OPENTELEMETRY_SDK_VERSION
);
16 const jspan
Tracer::noop_span
= noop_tracer
->StartSpan("noop");
18 using bufferlist
= ceph::buffer::list
;
20 Tracer::Tracer(opentelemetry::nostd::string_view service_name
) {
24 void Tracer::init(opentelemetry::nostd::string_view service_name
) {
26 opentelemetry::exporter::jaeger::JaegerExporterOptions exporter_options
;
28 exporter_options
.server_port
= g_ceph_context
->_conf
.get_val
<int64_t>("jaeger_agent_port");
30 const opentelemetry::sdk::trace::BatchSpanProcessorOptions processor_options
;
31 const auto jaeger_resource
= opentelemetry::sdk::resource::Resource::Create(std::move(opentelemetry::sdk::resource::ResourceAttributes
{{"service.name", service_name
}}));
32 auto jaeger_exporter
= std::unique_ptr
<opentelemetry::sdk::trace::SpanExporter
>(new opentelemetry::exporter::jaeger::JaegerExporter(exporter_options
));
33 auto processor
= std::unique_ptr
<opentelemetry::sdk::trace::SpanProcessor
>(new opentelemetry::sdk::trace::BatchSpanProcessor(std::move(jaeger_exporter
), processor_options
));
34 const auto provider
= opentelemetry::nostd::shared_ptr
<opentelemetry::trace::TracerProvider
>(new opentelemetry::sdk::trace::TracerProvider(std::move(processor
), jaeger_resource
));
35 opentelemetry::trace::Provider::SetTracerProvider(provider
);
36 tracer
= provider
->GetTracer(service_name
, OPENTELEMETRY_SDK_VERSION
);
40 jspan
Tracer::start_trace(opentelemetry::nostd::string_view trace_name
) {
42 return tracer
->StartSpan(trace_name
);
47 jspan
Tracer::start_trace(opentelemetry::nostd::string_view trace_name
, bool trace_is_enabled
) {
48 if (trace_is_enabled
) {
49 return tracer
->StartSpan(trace_name
);
51 return noop_tracer
->StartSpan(trace_name
);
54 jspan
Tracer::add_span(opentelemetry::nostd::string_view span_name
, const jspan
& parent_span
) {
55 if (is_enabled() && parent_span
->IsRecording()) {
56 opentelemetry::trace::StartSpanOptions span_opts
;
57 span_opts
.parent
= parent_span
->GetContext();
58 return tracer
->StartSpan(span_name
, span_opts
);
63 jspan
Tracer::add_span(opentelemetry::nostd::string_view span_name
, const jspan_context
& parent_ctx
) {
64 if (is_enabled() && parent_ctx
.IsValid()) {
65 opentelemetry::trace::StartSpanOptions span_opts
;
66 span_opts
.parent
= parent_ctx
;
67 return tracer
->StartSpan(span_name
, span_opts
);
72 bool Tracer::is_enabled() const {
73 return g_ceph_context
->_conf
->jaeger_tracing_enable
;
76 void encode(const jspan_context
& span_ctx
, bufferlist
& bl
, uint64_t f
) {
77 ENCODE_START(1, 1, bl
);
78 using namespace opentelemetry
;
79 using namespace trace
;
80 auto is_valid
= span_ctx
.IsValid();
83 encode_nohead(std::string_view(reinterpret_cast<const char*>(span_ctx
.trace_id().Id().data()), TraceId::kSize
), bl
);
84 encode_nohead(std::string_view(reinterpret_cast<const char*>(span_ctx
.span_id().Id().data()), SpanId::kSize
), bl
);
85 encode(span_ctx
.trace_flags().flags(), bl
);
90 void decode(jspan_context
& span_ctx
, bufferlist::const_iterator
& bl
) {
91 using namespace opentelemetry
;
92 using namespace trace
;
97 std::array
<uint8_t, TraceId::kSize
> trace_id
;
98 std::array
<uint8_t, SpanId::kSize
> span_id
;
100 decode(trace_id
, bl
);
103 span_ctx
= SpanContext(
104 TraceId(nostd::span
<uint8_t, TraceId::kSize
>(trace_id
)),
105 SpanId(nostd::span
<uint8_t, SpanId::kSize
>(span_id
)),
111 } // namespace tracing
113 #endif // HAVE_JAEGER