fast_log 1.7.8

Rust async log High-performance asynchronous logging
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

use crate::appender::{Command, FastLogRecord, LogAppender};
use crate::error::LogError;
use std::cell::RefCell;
use std::fs::{File, OpenOptions};
use std::io::Write;

/// only write append into file
pub struct FileAppender {
    file: RefCell<File>,
}

impl FileAppender {
    pub fn new(log_file_path: &str) -> Result<FileAppender, LogError> {
        let log_file_path = log_file_path.replace("\\", "/");
        if let Some(right) = log_file_path.rfind("/") {
            let path = &log_file_path[0..right];
            let _ = std::fs::create_dir_all(path);
        }
        Ok(Self {
            file: RefCell::new(
                OpenOptions::new()
                    .create(true)
                    .append(true)
                    .open(&log_file_path)?,
            ),
        })
    }
}

impl LogAppender for FileAppender {
    fn do_logs(&mut self, records: &[FastLogRecord]) {
        let mut log_file = self.file.borrow_mut();
        let cap = records.iter().map(|record| record.formated.len()).sum();
        let mut buf = String::with_capacity(cap);
        for x in records {
            buf.push_str(&x.formated);
            match &x.command {
                Command::CommandRecord => {}
                Command::CommandExit => {}
                Command::CommandFlush(_) => {
                    let _ = log_file.write_all(buf.as_bytes());
                    let _ = log_file.flush();
                    buf.clear();
                }
            }
        }
        let _ = log_file.write_all(buf.as_bytes());
    }
}