Function dispatch_async

nodedb/src/control/server/pgwire/ddl/sync_dispatch.rs:17–33

Send `plan` to the Data Plane and await the response. This is async — it yields the Tokio thread while waiting, so the response poller can deliver the result without deadlocking.

(
    state: &SharedState,
    tenant_id: TenantId,
    collection: &str,
    plan: PhysicalPlan,
    timeout: Duration,
)

/// This is async — it yields the Tokio thread while waiting, so the
/// response poller can deliver the result without deadlocking.
pub async fn dispatch_async(
    state: &SharedState,
    tenant_id: TenantId,
    collection: &str,
    plan: PhysicalPlan,
    timeout: Duration,
) -> crate::Result<Vec<u8>> {
    dispatch_async_with_source(
        state,
        tenant_id,
        collection,
        plan,
        timeout,
        crate::event::EventSource::User,
    )
    .await
}

/// Send `plan` to the Data Plane with an explicit event source.
///