Function dispatch_to_data_plane

nodedb/src/control/server/http/routes/query.rs:256–271

Dispatch a physical plan locally (single-node fallback path). Called only when `shared.gateway` is `None` (pre-cluster-init boot).

(
    state: &AppState,
    tenant_id: crate::types::TenantId,
    vshard_id: VShardId,
    plan: PhysicalPlan,
    trace_id: TraceId,
)

///
/// Called only when `shared.gateway` is `None` (pre-cluster-init boot).
async fn dispatch_to_data_plane(
    state: &AppState,
    tenant_id: crate::types::TenantId,
    vshard_id: VShardId,
    plan: PhysicalPlan,
    trace_id: TraceId,
) -> crate::Result<crate::bridge::envelope::Response> {
    crate::control::server::dispatch_utils::dispatch_to_data_plane(
        &state.shared,
        tenant_id,
        vshard_id,
        plan,
        trace_id,
    )
    .await
}

/// Decode a Data Plane response payload to JSON.
///