init4-bin-base 0.19.1

Internal utilities for binaries produced by the init4 team
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69

use axum::extract::{MatchedPath, Request};
use tower::{Layer, Service};
use tracing::{info_span, instrument::Instrumented, Instrument};
use tracing_opentelemetry::OpenTelemetrySpanExt;

/// A [`Layer`] that adds OpenTelemetry spans to Axum requests.
#[derive(Debug, Clone, Copy)]
pub struct OtelAxumSpanLayer;

/// A simple service
#[derive(Debug, Clone)]
pub struct OtelAxumSpanner<S> {
    inner: S,
}

impl<S> Layer<S> for OtelAxumSpanLayer {
    type Service = OtelAxumSpanner<S>;

    fn layer(&self, inner: S) -> Self::Service {
        OtelAxumSpanner { inner }
    }
}

impl<S, Body> Service<Request<Body>> for OtelAxumSpanner<S>
where
    S: Service<Request<Body>>,
{
    type Response = S::Response;
    type Error = S::Error;
    type Future = Instrumented<S::Future>;

    fn poll_ready(
        &mut self,
        cx: &mut std::task::Context<'_>,
    ) -> std::task::Poll<Result<(), Self::Error>> {
        self.inner.poll_ready(cx)
    }

    fn call(&mut self, req: Request<Body>) -> Self::Future {
        let parent_context = opentelemetry::global::get_text_map_propagator(|propagator| {
            propagator.extract(&opentelemetry_http::HeaderExtractor(req.headers()))
        });

        let method = req.method().to_string();
        let uri = req.uri().clone();
        let route = req
            .extensions()
            .get::<MatchedPath>()
            .map(|r| r.as_str())
            .unwrap_or_else(|| uri.path());
        let name = format!("{method} {route}");
        let name = name.trim();

        let span = info_span!(
            "Http Request",
            "otel.name" = name,
            "otel.target" = name,
            "otel.kind" = "server",
            "http.request.method" = method,
            "url.path" = uri.path(),
            "url.scheme" = uri.scheme_str().unwrap_or(""),
            "http.route" = route,
            "http.response.status_code" = tracing::field::Empty,
        );
        span.set_parent(parent_context);

        self.inner.call(req).instrument(span)
    }
}