#open-telemetry #tracing #tonic

tonic-tracing-opentelemetry

Middlewares and tools to integrate tonic + tracing + opentelemetry

23 releases (11 breaking)

new 0.28.1 May 19, 2025
0.28.0 Mar 31, 2025
0.26.1 Feb 26, 2025
0.24.0 Nov 17, 2024
0.12.0 Jul 2, 2023

#867 in Debugging

Download history 2791/week @ 2025-01-30 1903/week @ 2025-02-06 2149/week @ 2025-02-13 2566/week @ 2025-02-20 1856/week @ 2025-02-27 2053/week @ 2025-03-06 1925/week @ 2025-03-13 1861/week @ 2025-03-20 2415/week @ 2025-03-27 2491/week @ 2025-04-03 2786/week @ 2025-04-10 2085/week @ 2025-04-17 4047/week @ 2025-04-24 3089/week @ 2025-05-01 4003/week @ 2025-05-08 6195/week @ 2025-05-15

17,942 downloads per month

CC0 license

47KB
662 lines

tonic-tracing-opentelemetry

crates license crate version

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

Middlewares and tools to integrate tonic + tracing + opentelemetry for client and server.

Really early, missing lot of features, help is welcomed.

  • Read OpenTelemetry header from the incoming requests
  • Start a new trace if no trace is found in the incoming request
  • Trace is attached into tracing's span

For examples, you can look at the examples folder.

Extract of client.rs:

    let channel = Channel::from_static("http://127.0.0.1:50051")
        .connect()
        .await?; //Devskim: ignore DS137138
    let channel = ServiceBuilder::new()
        .layer(OtelGrpcLayer::default())
        .service(channel);

    let mut client = GreeterClient::new(channel);

    //...

    opentelemetry::global::shutdown_tracer_provider();

Extract of server.rs:

    Server::builder()
        // create trace for every request including health_service
        .layer(server::OtelGrpcLayer::default().filter(filters::reject_healthcheck))
        .add_service(health_service)
        .add_service(reflection_service)
        //.add_service(GreeterServer::new(greeter))
        .add_service(GreeterServer::new(greeter))
        .serve_with_shutdown(addr, shutdown_signal())
        .await?;

TODO

Changelog - History

CHANGELOG.md

Dependencies

~9–16MB
~199K SLoC