Function start_prepared_update_pglite_server

xtask/src/main.rs:3001–3022

(endpoint: PglitePreparedEndpoint)

}

fn start_prepared_update_pglite_server(endpoint: PglitePreparedEndpoint) -> Result<PgliteServer> {
    match endpoint {
        PglitePreparedEndpoint::Tcp => PgliteServer::temporary_tcp(),
        #[cfg(unix)]
        PglitePreparedEndpoint::Unix => {
            let socket_dir = env::current_dir()
                .context("read current directory")?
                .join("target/perf")
                .join(format!(
                    "pglite-prepared-unix-{}-{}",
                    std::process::id(),
                    now_micros()?
                ));
            let port = 5432;
            let socket_path = socket_dir.join(format!(".s.PGSQL.{port}"));
            PgliteServer::builder()
                .temporary()
                .unix(socket_path)
                .start()
        }
    }
}

enum PreparedPgliteConnection {
    Tcp(std::net::SocketAddr),