Struct LiveLogDirReader

pub struct LiveLogDirReader { /* private fields */ }

Available on crate feature asynchronous only.

The async variant of [super::blocking::LiveLogDirReader]. Watches the whole journal dir and reads all files. Once all historic files have been read the current read will only resolve once the newest log file is changed at which it will read the active log file and return the entry.

use std::path::PathBuf;
use ed_journals::logs::asynchronous::LiveLogDirReader;

let path = PathBuf::from("somePath");
let mut live_dir_reader = LiveLogDirReader::open(path)
    .unwrap();

// At first this will read all existing lines from the journal logs, after which it will wait
// until it detects new entries in the latest log file.
while let Some(entry) = live_dir_reader.next().await {
    // Do something with the entry
}

Implementations

impl LiveLogDirReader

pub fn open<P: AsRef<Path>>( dir_path: P, ) -> Result<LiveLogDirReader, LiveLogDirReaderError>

pub async fn next(&mut self) -> Option<Result<LogEvent, LiveLogDirReaderError>>

Trait Implementations

impl Debug for LiveLogDirReader

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.