Function dispatch_kv

nodedb/src/control/server/resp/gateway_dispatch.rs:29–62

Dispatch a read-only KV operation. Routes through the gateway when available (cluster-aware routing), falling back to direct local SPSC dispatch on single-node boot. Bridge/dispatch errors are mapped to `Error::Bridge` with a `BUSY` detail so the RESP handler can return `-BUSY` to the Redis client.

(
    state: &SharedState,
    session: &RespSession,
    plan: PhysicalPlan,
)

/// Bridge/dispatch errors are mapped to `Error::Bridge` with a `BUSY` detail
/// so the RESP handler can return `-BUSY` to the Redis client.
pub(super) async fn dispatch_kv(
    state: &SharedState,
    session: &RespSession,
    plan: PhysicalPlan,
) -> crate::Result<Response> {
    match state.gateway.as_ref() {
        Some(gw) => {
            let gw_ctx = QueryContext {
                tenant_id: session.tenant_id,
                trace_id: TraceId::generate(),
                database_id: DatabaseId::DEFAULT,
            };
            gw.execute(&gw_ctx, plan)
                .await
                .map_err(|e| crate::Error::Bridge {
                    detail: GatewayErrorMap::to_resp(&e),
                })
                .map(gateway_payloads_to_response)
        }
        None => {
            let vshard =
                VShardId::from_collection_in_database(DatabaseId::DEFAULT, &session.collection);
            dispatch_utils::dispatch_to_data_plane(
                state,
                session.tenant_id,
                vshard,
                plan,
                TraceId::ZERO,
            )
            .await
            .map_err(map_busy_error)
        }
    }
}

/// Dispatch a KV write operation: WAL append first, then gateway or Data Plane.
///