opinionated_telemetry 0.2.0

Opinionated configuration for tracing and metrics crates (with OpenTelemetry & Prometheus).
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

//! Glue routines for interfacing with various things.

use futures::{
    future::FutureObj,
    task::{Spawn, SpawnError},
};
use tracing::{instrument::WithSubscriber, subscriber::NoSubscriber};

pub(crate) struct TokioGlue;

impl Spawn for TokioGlue {
    fn spawn_obj(&self, future: FutureObj<'static, ()>) -> Result<(), SpawnError> {
        // Turn off `tracing` so that `tracing` on `h2` while submitting traces
        // via `h2` does not cause an infinite loop.
        let future = future.with_subscriber(NoSubscriber::default());
        tokio::spawn(future);
        Ok(())
    }
}