Method execute

nodedb/src/control/cluster/array_cluster_exec.rs:241–311

Execute a `ClusterArrayOp` and return raw response bytes ready to be returned to the client. The response format mirrors local `ArrayOp` responses so downstream decode logic is unchanged.

(&self, op: &ClusterArrayOp)

    /// returned to the client. The response format mirrors local `ArrayOp`
    /// responses so downstream decode logic is unchanged.
    pub async fn execute(&self, op: &ClusterArrayOp) -> crate::Result<Vec<u8>> {
        match op {
            ClusterArrayOp::Slice {
                array_id,
                slice_msgpack,
                attr_projection,
                limit,
                slice_hilbert_ranges,
                prefix_bits,
                system_as_of,
                valid_at_ms,
            } => {
                self.execute_slice(SliceArgs {
                    array_id,
                    slice_msgpack,
                    attr_projection,
                    limit: *limit,
                    slice_hilbert_ranges,
                    prefix_bits: *prefix_bits,
                    system_as_of: *system_as_of,
                    valid_at_ms: *valid_at_ms,
                })
                .await
            }

            ClusterArrayOp::Agg {
                array_id,
                attr_idx,
                reducer_msgpack,
                group_by_dim,
                slice_hilbert_ranges,
                prefix_bits,
                system_as_of,
                valid_at_ms,
            } => {
                self.execute_agg(AggArgs {
                    array_id,
                    attr_idx: *attr_idx,
                    reducer_msgpack,
                    group_by_dim: *group_by_dim,
                    slice_hilbert_ranges,
                    prefix_bits: *prefix_bits,
                    system_as_of: *system_as_of,
                    valid_at_ms: *valid_at_ms,
                })
                .await
            }

            ClusterArrayOp::Put {
                array_id_msgpack,
                cells,
                wal_lsn,
                prefix_bits,
                ..
            } => {
                self.execute_put(array_id_msgpack, cells, *wal_lsn, *prefix_bits)
                    .await
            }