Method vshard_for_op

nodedb/src/control/array_sync/inbound_propose.rs:182–210

Compute the vShard that owns this op's tile. Extracts tile extents from the schema registry and casts the op's coord to `u64` for tile routing. Falls back to collection-level routing with a warning when the schema is unavailable or coord cannot be cast.

(&self, op: &ArrayOp)

    /// to `u64` for tile routing. Falls back to collection-level routing with
    /// a warning when the schema is unavailable or coord cannot be cast.
    pub(super) fn vshard_for_op(&self, op: &ArrayOp) -> VShardId {
        use nodedb_array::types::coord::value::CoordValue;

        let tile_extents = self.schemas().tile_extents(&op.header.array);

        let Some(tile_extents) = tile_extents else {
            warn!(
                array = %op.header.array,
                "array_inbound: schema unavailable; routing by name only"
            );
            return VShardId::new(array_vshard_for_name(&op.header.array));
        };

        let coord_u64: Vec<u64> = op
            .coord
            .iter()
            .map(|c| match c {
                CoordValue::Int64(v) | CoordValue::TimestampMs(v) => *v as u64,
                CoordValue::Float64(v) => v.to_bits(),
                CoordValue::String(_) => 0,
            })
            .collect();

        VShardId::new(vshard_for_array_coord(
            &op.header.array,
            &coord_u64,
            &tile_extents,
        ))
    }

    /// Convert a decoded `ArrayOp` (from sync) into a `PhysicalPlan::Array` variant.
    pub(super) fn op_to_data_plane_plan(