rhit 2.0.4

nginx log " analyzer
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
56
57
58
59
60
61
62
63
64
65
66
67

use {
    crate::*,
    std::{
        path::PathBuf,
    },
};

/// A printer writing lines as a JSON array
#[derive(Default)]
struct JsonPrinter {
    written: usize,
}

impl LineConsumer for JsonPrinter {
    fn eat_line(
        &mut self,
        line: LogLine,
        _raw_line: &str,
        filtered_out: bool,
    ) {
        if filtered_out { return; }
        if self.written > 0 {
            println!(",");
        } else {
            println!("[");
        }
        print!(r#"  {{
    "date": "{}",
    "time": "{}",
    "remote_addr": "{}",
    "method": "{}",
    "path": "{}",
    "status": "{}",
    "bytes_sent": {},
    "referer": "{}"
  }}"#,
            line.date(),
            line.time(),
            line.remote_addr,
            line.method,
            line.path,
            line.status,
            line.bytes_sent,
            line.referer,
        );
        self.written += 1;
    }
    fn end_eating(
        &mut self,
    ) {
        if self.written == 0 {
            print!("[");
        }
        println!("\n]");
    }
}

pub fn print_json_lines(
    path: &[PathBuf],
    args: &args::Args,
) -> Result<(), RhitError> {
    let mut printer = JsonPrinter::default();
    let mut file_reader = FileReader::new(path, args, &mut printer)?;
    time!("reading files", file_reader.read_all_files())?;
    Ok(())
}