tracing-loki 0.2.6

A tracing layer for shipping logs to Grafana Loki
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

use std::error::Error;
use tokio::task::JoinHandle;
use tracing::info;
use tracing::info_span;
use tracing_subscriber::filter::LevelFilter;
use tracing_subscriber::fmt::Layer;
use tracing_subscriber::layer::SubscriberExt;
use tracing_subscriber::util::SubscriberInitExt;
use url::Url;

fn tracing_setup(
) -> Result<(tracing_loki::BackgroundTaskController, JoinHandle<()>), Box<dyn Error>> {
    let (layer, controller, task) = tracing_loki::builder()
        .label("host", "mine")?
        .build_controller_url(Url::parse("http://127.0.0.1:3100").unwrap())?;

    tracing_subscriber::registry()
        .with(LevelFilter::INFO)
        .with(layer)
        .with(Layer::new())
        .init();
    Ok((controller, tokio::spawn(task)))
}

#[tokio::main(flavor = "current_thread")]
async fn main() -> Result<(), Box<dyn Error>> {
    let (controller, task) = tracing_setup()?;

    info_span!("report", output = "tracing").in_scope(|| {
        info!(
            task = "tracing_setup",
            result = "success",
            "tracing successfully set up"
        );
    });

    controller.shutdown().await;
    task.await.unwrap();

    Ok(())
}