pub fn spawn_log_watcher( path: String, format: LogFormat, start_offset: u64, stop: Arc<AtomicBool>, tx: impl Sender<(String, Vec<LogEntry>)> + 'static, )