libobservability-rs 0.1.1

A library for observability
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
48
49
50
51
52
53
54
55

use slog::{Drain, Logger};

#[derive(Debug, Clone)]
pub struct Log {
    logger: Option<Logger>,
    level: log::Level,
}

impl Default for Log {
    fn default() -> Self {
        Self::new()
    }
}

impl Log {
    pub fn new() -> Self {
        Log {
            logger: None,
            level: log::Level::Info,
        }
    }
    pub fn logger(&self) -> Self {
        let logger = if true {
            // opts.json
            let drain = slog_json::Json::new(std::io::stdout())
                .add_default_keys()
                .build()
                .fuse();
            let drain = slog_async::Async::new(drain).build().fuse();
            slog::Logger::root(drain, slog::o!())
        } else {
            let decorator = slog_term::TermDecorator::new().build();
            let drain = slog_term::FullFormat::new(decorator).build().fuse();
            let drain = slog_async::Async::new(drain).build().fuse();
            slog::Logger::root(drain, slog::o!())
        };

        Self {
            logger: Some(logger),
            level: self.level,
        }
    }
    pub fn guard(&self) -> slog_scope::GlobalLoggerGuard {
        slog_scope::set_global_logger(self.logger.clone().unwrap())
    }

    pub fn set_level(&mut self, debug: bool) -> Self {
        if debug {
            self.level = log::Level::Debug;
        }
        slog_stdlog::init_with_level(self.level).expect("Could not set log level");

        self.clone()
    }
}