Struct ZrecWriter 

pub struct ZrecWriter<W: Write> { /* private fields */ }

A .zrec writer over any byte sink: header first, then rows as they arrive, drop records in place. Wrap the sink in a BufWriter — the writer emits line-at-a-time and never buffers samples itself, so a capture streams in bounded memory.

Implementations

impl<W: Write> ZrecWriter<W>

pub fn new(out: W, header: &ZrecHeader) -> Result<Self>

Write the header line and hand back a row writer.

pub fn write_sample(&mut self, view: &SampleView) -> Result<()>

Write one observed sample as a row.

The payload rides lossless ("bytes"), the pacing offset is the observer’s arrival clock ("t", µs since the capture epoch), and the publisher’s HLC — when one rode the sample — is carried informatively ("timestamp"): replay re-stamps (RFC 09 §5.2). QoS is stored as a profile name only when the wire’s actual axes match one (RFC 04 §3); axes matching no profile are not approximated.

pub fn write_dropped(&mut self, n: u64) -> Result<()>

Write a drop record where the gap happened (O6 on a file).

pub fn counts(&self) -> (u64, u64)

Samples and drops written so far — the progress line’s numbers.

pub fn finish(self) -> Result<W>

Flush and hand the sink back.