Function encode_structural

nodedb-array/src/codec/tile_encode.rs:79–121

(tile: &SparseTile, out: &mut Vec<u8>)

}

fn encode_structural(tile: &SparseTile, out: &mut Vec<u8>) -> ArrayResult<()> {
    let cell_count = tile.surrogates.len() as u32;
    let axis_count = tile.dim_dicts.len() as u32;
    out.extend_from_slice(&cell_count.to_le_bytes());
    out.extend_from_slice(&axis_count.to_le_bytes());

    // Coordinate axes.
    for dict in &tile.dim_dicts {
        let mut axis_buf = Vec::new();
        encode_coord_axis_rle(dict, &mut axis_buf)?;
        write_framed(&axis_buf, out);
    }

    // Surrogates.
    let surr_bytes = encode_surrogates(&tile.surrogates);
    write_framed(&surr_bytes, out);

    // Row kinds.
    let rk_bytes = encode_row_kinds(&tile.row_kinds);
    write_framed(&rk_bytes, out);

    // Timestamp columns.
    let sys_bytes = encode_timestamps_col(&[]);
    // system_from_ms is not stored in SparseTile (it's the tile_id's field).
    // We emit an empty placeholder to keep the format symmetric.
    write_framed(&sys_bytes, out);

    let vf_bytes = encode_timestamps_col(&tile.valid_from_ms);
    write_framed(&vf_bytes, out);

    let vu_bytes = encode_timestamps_col(&tile.valid_until_ms);
    write_framed(&vu_bytes, out);

    // Attr columns.
    let attr_count = tile.attr_cols.len() as u32;
    out.extend_from_slice(&attr_count.to_le_bytes());
    for col in &tile.attr_cols {
        let col_bytes = encode_attr_col(col)?;
        write_framed(&col_bytes, out);
    }

    Ok(())
}

#[cfg(test)]
mod tests {