File tree Expand file tree Collapse file tree 5 files changed +5
-27
lines changed
crates/connectors/ndc-postgres/src Expand file tree Collapse file tree 5 files changed +5
-27
lines changed Original file line number Diff line number Diff line change @@ -54,7 +54,7 @@ pub async fn mutation(
54
54
55
55
let pool = state
56
56
. pool
57
- . aquire ( & request_arguments, & state. query_metrics )
57
+ . acquire ( & request_arguments, & state. query_metrics )
58
58
. await
59
59
. map_err ( |err| {
60
60
record:: pool_aquisition_error ( & err, & state. query_metrics ) ;
Original file line number Diff line number Diff line change @@ -44,7 +44,7 @@ pub async fn explain(
44
44
} ) ?;
45
45
let pool = state
46
46
. pool
47
- . aquire ( & request_arguments, & state. query_metrics )
47
+ . acquire ( & request_arguments, & state. query_metrics )
48
48
. await
49
49
. map_err ( |err| {
50
50
record:: pool_aquisition_error ( & err, & state. query_metrics ) ;
Original file line number Diff line number Diff line change @@ -54,7 +54,7 @@ pub async fn query(
54
54
55
55
let pool = state
56
56
. pool
57
- . aquire ( & request_arguments, & state. query_metrics )
57
+ . acquire ( & request_arguments, & state. query_metrics )
58
58
. await
59
59
. map_err ( |err| {
60
60
record:: pool_aquisition_error ( & err, & state. query_metrics ) ;
Original file line number Diff line number Diff line change @@ -43,7 +43,7 @@ pub async fn explain(
43
43
. await ?;
44
44
let pool = state
45
45
. pool
46
- . aquire ( & request_arguments, & state. query_metrics )
46
+ . acquire ( & request_arguments, & state. query_metrics )
47
47
. await
48
48
. map_err ( |err| {
49
49
record:: pool_aquisition_error ( & err, & state. query_metrics ) ;
Original file line number Diff line number Diff line change @@ -195,7 +195,7 @@ impl Pool {
195
195
}
196
196
}
197
197
198
- pub async fn aquire (
198
+ pub async fn acquire (
199
199
& self ,
200
200
request_arguments : & Option < BTreeMap < ArgumentName , serde_json:: Value > > ,
201
201
metrics : & metrics:: Metrics ,
@@ -427,28 +427,6 @@ impl Pool {
427
427
}
428
428
}
429
429
430
- /// Given the database info, return a label for metrics purposes
431
- /// This label is derived from the connection string, but with the password redacted
432
- /// Note that we do not guarantee uniqueness: two connection strings to the same db could have different query parameters
433
- /// This would result in each potentially getting their own pool, but sharing a label. I'm unsure what the concrete impact would be.
434
- fn get_pool_label ( database_info : & DatabaseInfo ) -> String {
435
- format ! (
436
- "{}@{}:{}/{}" ,
437
- database_info
438
- . server_username
439
- . as_deref( )
440
- . unwrap_or( "<username>" ) ,
441
- database_info. server_host. as_deref( ) . unwrap_or( "<host>" ) ,
442
- database_info
443
- . server_port
444
- . map_or( "<port>" . to_string( ) , |port| port. to_string( ) ) ,
445
- database_info
446
- . server_database
447
- . as_deref( )
448
- . unwrap_or( "<database>" )
449
- )
450
- }
451
-
452
430
#[ derive( Debug , thiserror:: Error ) ]
453
431
pub enum PoolAquisitionError {
454
432
#[ error( "Missing required request argument: {0}" ) ]
You can’t perform that action at this time.
0 commit comments