// use tracing_subscriber::layer::SubscriberExt; // use tracing_subscriber::util::SubscriberInitExt; // use tracing_subscriber::EnvFilter; pub fn init_telemetry() -> Result<(), Box> { // let env_filter = EnvFilter::try_from_default_env().unwrap_or(EnvFilter::new("warn")); // let stdout = tracing_subscriber::fmt::Layer::new() // .pretty() // .with_file(true) // .with_line_number(true) // .with_thread_ids(false) // .with_target(false); // opentelemetry::global::set_text_map_propagator(opentelemetry_jaeger::Propagator::new()); // let tracer = opentelemetry_jaeger::new_pipeline() // .with_service_name("organic") // .install_simple()?; // let opentelemetry = tracing_opentelemetry::layer().with_tracer(tracer); // tracing_subscriber::registry() // // .with(env_filter) // .with(opentelemetry) // // .with(stdout) // .try_init()?; Ok(()) } pub fn shutdown_telemetry() -> Result<(), Box> { // opentelemetry::global::shutdown_tracer_provider(); Ok(()) }