log-reader 0.2.1

A Rust library for real-time log file monitoring that emits batched content as Vec<String>.
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

use log_reader::watch_log;
use std::env;
use std::process;
use tokio_stream::StreamExt;

#[tokio::main]
async fn main() {
    let args: Vec<String> = env::args().collect();

    if args.len() != 2 {
        eprintln!("Usage: {} <file_path>", args[0]);
        process::exit(1);
    }

    let file_path = &args[1];

    match watch_log(file_path, None).await {
        Ok(mut stream) => {
            println!("Watching file: {}", file_path);
            while let Some(lines_result) = stream.next().await {
                match lines_result {
                    Ok(lines) => {
                        for line in lines {
                            println!("{}", line);
                        }
                    },
                    Err(e) => {
                        eprintln!("Error reading file: {}", e);
                        process::exit(1);
                    }
                }
            }
        }
        Err(e) => {
            eprintln!("Error setting up file watcher: {}", e);
            process::exit(1);
        }
    }
}