log4rs-fluentd 0.2.0

Fluentd appender for log4rs
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

extern crate log4rs;
extern crate log4rs_fluentd;
#[macro_use]
extern crate log;

fn main() {
    // Use custom PatternEncoder to keep only the log itself (no filename, timestamp...).
    let encoder = Box::new(log4rs::encode::pattern::PatternEncoder::new("{m}"));
    let fluentd_appender = Box::new(
        log4rs_fluentd::FluentdAppender::builder()
            .encoder(encoder)
            .tag("manually.event")
            .build("127.0.0.1:24224".to_string()),
    );

    let config = log4rs::config::Config::builder()
        .appender(log4rs::config::Appender::builder().build("fluentd", fluentd_appender))
        .logger(
            log4rs::config::Logger::builder()
                .appender("fluentd")
                .additive(true)
                .build("manually", log::LevelFilter::Trace),
        )
        .build(log4rs::config::Root::builder().build(log::LevelFilter::Off))
        .unwrap();
    log4rs::init_config(config).unwrap();

    for i in 0..5 {
        trace!("Example trace message: {}", i);
        debug!("Example debug message: {}", i);
        info!("Example information message: {}", i);
        warn!("Example warning message: {}", i);
        error!("Example error message: {}", i);
        ::std::thread::sleep(::std::time::Duration::from_secs(5));
    }

    println!("Check your logs for new messages");
}