Function run_native_postgres_rtt_sqlx_benchmark

xtask/src/main.rs:2361–2404

(
    conn: &mut sqlx::PgConnection,
    iterations: usize,
    open_micros: u128,
    connect_micros: u128,
)

}

async fn run_native_postgres_rtt_sqlx_benchmark(
    conn: &mut sqlx::PgConnection,
    iterations: usize,
    open_micros: u128,
    connect_micros: u128,
) -> Result<BenchmarkRun> {
    let setup_started = Instant::now();
    conn.execute(rtt_setup_sql())
        .await
        .context("execute native Postgres RTT setup over SQLx")?;
    let setup_micros = setup_started.elapsed().as_micros();

    let mut tests = Vec::new();
    for case in rtt_cases() {
        let mut samples = Vec::with_capacity(iterations);
        for _ in 0..iterations {
            let started = Instant::now();
            conn.execute(case.sql.as_str()).await.with_context(|| {
                format!(
                    "execute native Postgres RTT benchmark {} over SQLx",
                    case.id
                )
            })?;
            samples.push(started.elapsed().as_micros());
        }
        tests.push(samples_result(
            case.id,
            format!("Test {}: {}", case.id, case.label),
            "milliseconds",
            iterations,
            samples,
        ));
    }

    Ok(BenchmarkRun {
        suite: "rtt",
        mode: "native_postgres_sqlx",
        description: "Native Postgres over TCP using one long-lived SQLx connection.",
        open_micros,
        connect_micros: Some(connect_micros),
        setup_micros,
        tests,
    })
}

async fn run_pglite_nodefs_rtt_sqlx_benchmark(
    conn: &mut sqlx::PgConnection,