Method execute_put

nodedb/src/control/cluster/array_cluster_exec.rs:439–466

(
        &self,
        array_id_msgpack: &[u8],
        cells: &[(u64, Vec<u8>)],
        wal_lsn: u64,
        prefix_bits: u8,
    )

    }

    async fn execute_put(
        &self,
        array_id_msgpack: &[u8],
        cells: &[(u64, Vec<u8>)],
        wal_lsn: u64,
        prefix_bits: u8,
    ) -> crate::Result<Vec<u8>> {
        let params = ArrayWriteCoordParams {
            source_node: self.source_node,
            timeout_ms: ARRAY_RPC_TIMEOUT_MS,
        };
        coord_put(
            &params,
            array_id_msgpack.to_vec(),
            prefix_bits,
            wal_lsn,
            cells,
            &self.dispatch,
            &self.circuit_breaker,
        )
        .await
        .map_err(cluster_err)?;

        // Return a simple `{"affected": N}` JSON payload — same shape as the
        // local ArrayOp::Put response so downstream decode is unchanged.
        let affected = cells.len() as u64;
        zerompk::to_msgpack_vec(&affected).map_err(encode_err)
    }

    async fn execute_delete(
        &self,