31 releases (16 breaking)

0.18.0 Mar 9, 2024
0.16.0 Dec 30, 2023
0.15.2 Feb 11, 2024
0.15.0 Nov 25, 2023
0.2.1 Jun 11, 2022

#223 in Debugging

Download history 13046/week @ 2023-12-02 11524/week @ 2023-12-09 18492/week @ 2023-12-16 2142/week @ 2023-12-23 6990/week @ 2023-12-30 8931/week @ 2024-01-06 9166/week @ 2024-01-13 13109/week @ 2024-01-20 10225/week @ 2024-01-27 11463/week @ 2024-02-03 14503/week @ 2024-02-10 9173/week @ 2024-02-17 16905/week @ 2024-02-24 10257/week @ 2024-03-02 14492/week @ 2024-03-09 11403/week @ 2024-03-16

54,806 downloads per month
Used in 8 crates (7 directly)

CC0 license

48KB
684 lines

axum-tracing-opentelemetry

crates license crate version

Project Status: Active – The project has reached a stable, usable state and is being actively developed.

Middlewares to integrate axum + tracing + opentelemetry.

  • Read OpenTelemetry header from incoming request
  • Start a new trace if no trace found in the incoming request
  • Trace is attached into tracing'span
  • OpenTelemetry Span is created on close of the tracing's span (behavior from [tracing-opentelemetry])

For examples, you can look at the examples folder.

//...
use axum_tracing_opentelemetry::opentelemetry_tracing_layer;

#[tokio::main]
async fn main() -> Result<(), axum::BoxError> {
    // very opinionated init of tracing, look as is source to make your own
    init_tracing_opentelemetry::tracing_subscriber_ext::init_subscribers()?;

    let app = app();
    // run it
    let addr = &"0.0.0.0:3000".parse::<SocketAddr>()?;
    tracing::warn!("listening on {}", addr);
    let listener = tokio::net::TcpListener::bind(addr).await?;
    axum::serve(listener, app.into_make_service())
        //FIXME .with_graceful_shutdown(shutdown_signal())
        .await?;
    Ok(())
}

fn app() -> Router {
    Router::new()
        .route("/", get(index)) // request processed inside span
        // include trace context as header into the response
        .layer(OtelInResponseLayer::default())
        //start OpenTelemetry trace on incoming request
        .layer(OtelAxumLayer::default())
        .route("/health", get(health)) // request processed without span / trace
}

async fn shutdown_signal() {
    //...
    opentelemetry::global::shutdown_tracer_provider();
}

For more info about how to initialize, you can look at crate init-tracing-opentelemetry or tracing-opentelemetry.

Changelog - History

CHANGELOG.md

Dependencies

~11MB
~193K SLoC