Struct PipeWatcher 

pub struct PipeWatcher { /* private fields */ }

Watches a pipe-pane log file and extracts events from new content.

Uses polling (seek to last position, read new bytes) which is simple and portable. The polling interval is configurable.

Implementations

impl PipeWatcher

pub fn new(path: &Path, buffer: EventBuffer) -> Self

Create a new pipe watcher for the given log file.

pub fn new_with_position( path: &Path, buffer: EventBuffer, position: u64, ) -> Self

Create a new pipe watcher starting from a specific byte offset.

Offsets beyond EOF are clamped during polling.

pub fn poll(&mut self) -> Result<usize>

Poll for new content in the log file and extract events.

Returns the number of new events extracted. Call this periodically from the supervisor loop.

pub fn checkpoint_offset(&self) -> u64

Resume-safe checkpoint offset.

This rewinds by the currently buffered partial line bytes so a resumed watcher can re-read any incomplete line safely.