Struct Recorder 

pub struct Recorder {
    pub frames_written: u64,
    pub decode_errors: u64,
    /* private fields */
}

An active recording of one device’s CSI stream to a Parquet file.

Decodes each incoming frame against the device’s chip layout and appends it to the sink. Lives outside crate::state::AppState (which is Clone) because the underlying file writer is not cloneable.

Fields

frames_written: u64

Frames successfully decoded and written.

decode_errors: u64

Frames that failed to decode (wire drift, truncation, wrong chip).

Implementations

impl Recorder

pub fn start( path: &str, chip: &str, profile: Arc<dyn ClientProfile>, ) -> Result<Self, String>

Open a Parquet file at path for a stream from the given chip string.

profile labels the data_format column from the numeric cur_bb_format where it can (see ClientProfile::label_format).

Returns Err if the chip is unrecognized (no known wire layout) or the file cannot be created.

pub fn path(&self) -> &str

The output file path being written.

pub fn record_frame( &mut self, bytes: &[u8], host_rx_micros: i64, ) -> Result<(), ParquetSinkError>

Decode one raw WebSocket frame and append it, stamped with host_rx_micros (UTC microseconds). Decode failures are counted, not propagated, so a single malformed frame never aborts a recording.

pub fn finish(self) -> Result<(), ParquetSinkError>

Flush remaining rows and finalize the Parquet footer.