pub fn log_events(
snapshot: Vec<LogLine>,
rx: Receiver<LogMsg>,
ended: bool,
) -> impl Stream<Item = LogEvent>Available on crate feature
serve only.Expand description
Build the ordered event stream for a /logs request: replay the ring
snapshot, then forward the live tail, de-duplicating against the snapshot by
sequence number and mapping broadcast lag to LogEvent::Truncated.