diff --git a/proxy/src/compute.rs b/proxy/src/compute.rs index bb0cfb609a..69cace8b2f 100644 --- a/proxy/src/compute.rs +++ b/proxy/src/compute.rs @@ -282,7 +282,7 @@ pub struct PostgresConnection { impl ConnCfg { /// Connect to a corresponding compute node. - pub async fn connect2>( + pub async fn managed_connect>( &self, ctx: &RequestMonitoring, timeout: Duration, @@ -327,7 +327,8 @@ impl ConnCfg { let mut mk_tls = tokio_postgres_rustls::MakeRustlsConnect::new(client_config); - let (socket_addr, client, connection) = self.connect2(ctx, timeout, &mut mk_tls).await?; + let (socket_addr, client, connection) = + self.managed_connect(ctx, timeout, &mut mk_tls).await?; tracing::Span::current().record("pid", tracing::field::display(client.get_process_id())); let stream = connection.stream.into_inner(); diff --git a/proxy/src/serverless/backend.rs b/proxy/src/serverless/backend.rs index e8d1cc3b3a..6348f13cd6 100644 --- a/proxy/src/serverless/backend.rs +++ b/proxy/src/serverless/backend.rs @@ -233,7 +233,7 @@ impl ConnectMechanism for TokioMechanism { let (socket_addr, client, connection) = permit.release_result( node_info .config - .connect2(ctx, timeout, &mut tokio_postgres::NoTls) + .managed_connect(ctx, timeout, &mut tokio_postgres::NoTls) .await, )?;