Function postgres_client

src/testdrive/src/util/postgres.rs:52–74

(
    url: &str,
    default_timeout: Duration,
)

}

pub async fn postgres_client(
    url: &str,
    default_timeout: Duration,
) -> Result<(Client, task::JoinHandle<Result<(), tokio_postgres::Error>>), anyhow::Error> {
    let (client, connection) = Retry::default()
        .max_duration(default_timeout)
        .retry_async_canceling(|_| async move {
            let pgconfig = &mut Config::from_str(url)?;
            pgconfig.connect_timeout(default_timeout);
            let tls = make_tls(pgconfig)?;
            pgconfig.connect(tls).await.map_err(|e| anyhow!(e))
        })
        .await?;

    if url.contains("mzp_") {
        println!("Connecting to PostgreSQL server at [REDACTED]...");
    } else {
        println!("Connecting to PostgreSQL server at {}...", url);
    }
    let handle = task::spawn(|| "postgres_client_task", connection);

    Ok((client, handle))
}