Function coord_put

nodedb-cluster/src/distributed_array/coordinator/write.rs:88–118

Partition a flat cell list by Hilbert tile and fan out to owning shards. `cells` — each element is `(hilbert_prefix, zerompk-encoded single-cell bytes)`. The Hilbert prefix is computed by the caller (the Control Plane planner) from the cell's coord tuple and the array schema; this function does not decode cell bytes. `prefix_bits` — routing granularity (1–16) from the array catalog entry. `wal_l

(
    params: &ArrayWriteCoordParams,
    array_id_msgpack: Vec<u8>,
    prefix_bits: u8,
    wal_lsn: u64,
    cells: &[(u64, Vec<u8>)],
    dispatch: &Arc<dyn ShardRpcDispatch>,
    circuit_breaker:

/// is committed independently. A partial failure returns the first error encountered;
/// cells that were already committed to other shards are not rolled back.
pub async fn coord_put(
    params: &ArrayWriteCoordParams,
    array_id_msgpack: Vec<u8>,
    prefix_bits: u8,
    wal_lsn: u64,
    cells: &[(u64, Vec<u8>)],
    dispatch: &Arc<dyn ShardRpcDispatch>,
    circuit_breaker: &Arc<CircuitBreaker>,
) -> Result<Vec<ArrayShardPutResp>> {
    if cells.is_empty() {
        return Ok(Vec::new());
    }

    let buckets = partition_put_cells(cells, prefix_bits)?;

    let per_shard: Vec<(u32, ArrayShardPutReq)> = buckets
        .into_iter()
        .map(|b| {
            let req = ArrayShardPutReq {
                array_id_msgpack: array_id_msgpack.clone(),
                cells_msgpack: b.cells_msgpack,
                wal_lsn,
                representative_hilbert_prefix: b.representative_hilbert_prefix,
                prefix_bits,
            };
            (b.vshard_id, req)
        })
        .collect();

    coord_put_partitioned(params, per_shard, dispatch, circuit_breaker).await
}

/// Partition a flat coord list by Hilbert tile and fan delete requests to owning shards.
///