log4rs-gelf 0.1.3

TCP Handler and GELF Encoder to use with the log4rs logging framework.
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

// Use of this source code is governed by a BSD-style
// license that can be found in the LICENSE file.
// Copyright 2009 The log4rs-gelf Authors. All rights reserved.

use log4rs::append::Append;
use log4rs::file::{Deserialize, Deserializers};

use appender::BufferAppenderBuilder;

struct BufferAppenderDeserializer;

impl Deserialize for BufferAppenderDeserializer {
    type Trait = dyn Append;
    type Config = gelf_logger::Config;

    fn deserialize(
        &self,
        config: gelf_logger::Config,
        _deserializers: &Deserializers,
    ) -> Result<Box<dyn Append>, Box<dyn std::error::Error + Sync + Send>> {
        let appender = BufferAppenderBuilder::default()
            .set_level(config.level().clone())
            .set_hostname(config.hostname())
            .set_port(config.port().clone())
            .set_use_tls(config.use_tls().clone())
            .set_null_character(config.null_character().clone())
            .set_buffer_size(config.buffer_size().clone())
            .set_buffer_duration(config.buffer_duration().clone())
            .extend_additional_field(config.additional_fields().clone())
            ;

        Ok(Box::new(appender.build()?))
    }
}

pub fn deserializers() -> Deserializers {
    let mut d = Deserializers::default();
    d.insert("buffer", BufferAppenderDeserializer);
    d
}