reductionist 0.12.0

S3 Active Storage server
Documentation 
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

//! Tracing (logging)

use crate::cli::CommandLineArgs;

use opentelemetry::runtime::Tokio;
use opentelemetry::sdk::trace::Tracer;
use opentelemetry::trace::TraceError;
use tracing_subscriber::{layer::SubscriberExt, util::SubscriberInitExt};

/// Initialise and return a Jaeger tracer.
fn init_tracer() -> Result<Tracer, TraceError> {
    opentelemetry_jaeger::new_agent_pipeline()
        .with_service_name("reductionist")
        // Avoid over-sized UDP packets with automatic batching.
        .with_auto_split_batch(true)
        .install_batch(Tokio)
}

/// Initlialise tracing (logging)
///
/// Applies a filter based on the `RUST_LOG` environment variable, falling back to enable debug
/// logging for this crate and tower_http if not set.
///
/// # Arguments
///
/// * `args`: Command line arguments.
pub fn init_tracing(args: &CommandLineArgs) {
    let tracer = init_tracer().expect("Failed to initialize tracer");
    let subscriber = tracing_subscriber::registry()
        .with(
            tracing_subscriber::EnvFilter::try_from_default_env()
                .unwrap_or_else(|_| "reductionist=debug,tower_http=debug".into()),
        )
        .with(tracing_subscriber::fmt::layer());
    if args.enable_jaeger {
        subscriber
            .with(tracing_opentelemetry::layer().with_tracer(tracer))
            .init();
    } else {
        subscriber.init();
    }
}

/// Shutdown tracing (logging)
pub fn shutdown_tracing() {
    opentelemetry::global::shutdown_tracer_provider();
}