Function export_span

nodedb/src/control/otel/exporter.rs:218–282

Export a single trace span to an OTLP collector using the shared `reqwest::Client` held on `SharedState`. Call this from the request tracker when a bridge round-trip completes.

(
    client: &reqwest::Client,
    timeout: std::time::Duration,
    params: &SpanExport<'_>,
)

///
/// Call this from the request tracker when a bridge round-trip completes.
pub async fn export_span(
    client: &reqwest::Client,
    timeout: std::time::Duration,
    params: &SpanExport<'_>,
) {
    let SpanExport {
        endpoint,
        trace_id,
        span_name,
        start_ns,
        end_ns,
        tenant_id,
        vshard_id,
        status_ok,
    } = params;
    if endpoint.is_empty() {
        return;
    }

    let span_id_bytes = rand_span_id();

    let span = Span {
        trace_id: trace_id.0.to_vec(),
        span_id: span_id_bytes.to_vec(),
        name: (*span_name).into(),
        kind: SpanKind::Server as i32,
        start_time_unix_nano: *start_ns,
        end_time_unix_nano: *end_ns,
        attributes: vec![
            kv("nodedb.tenant_id", &tenant_id.to_string()),
            kv("nodedb.vshard_id", &vshard_id.to_string()),
        ],
        status: Some(SpanStatus {
            message: String::new(),
            code: if *status_ok {
                OtelStatusCode::Ok as i32
            } else {
                OtelStatusCode::Error as i32
            },
        }),
    };

    let request = ExportTraceServiceRequest {
        resource_spans: vec![ResourceSpans {
            resource: Some(Resource {
                attributes: vec![kv("service.name", "nodedb")],
            }),
            scope_spans: vec![ScopeSpans {
                scope: Some(proto::InstrumentationScope {
                    name: "nodedb".into(),
                    version: env!("CARGO_PKG_VERSION").into(),
                }),
                spans: vec![span],
            }],
        }],
    };

    let mut buf = Vec::new();