Struct LogTailer 

pub struct LogTailer { /* private fields */ }

Follows one node’s log directory.

Implementations

impl LogTailer

pub fn new(node_id: u32, log_dir: PathBuf) -> Self

pub fn node_id(&self) -> u32

pub fn log_dir(&self) -> &Path

pub fn mark_primed(&mut self)

Adopt existing offsets rather than joining at the end.

Called when the persisted offsets already mention this node, i.e. the daemon is restarting rather than the user enabling forwarding for the first time.

pub async fn poll( &mut self, offsets: &mut OffsetStore, min_level: LogLevel, ) -> Result<PollOutcome>

Read whatever has been appended since the last poll.

Events below min_level are dropped here rather than downstream, so they never occupy queue space: the endpoint discards them on arrival anyway, and shipping them would spend the user’s bandwidth for nothing.