@@ -16,6 +16,7 @@ use crate::{
16
16
AcknowledgementsConfig , GenerateConfig , Input , ProxyConfig , SinkConfig , SinkContext ,
17
17
SinkHealthcheckOptions ,
18
18
} ,
19
+ http:: build_proxy_connector,
19
20
proto:: vector as proto,
20
21
sinks:: {
21
22
util:: {
@@ -24,7 +25,7 @@ use crate::{
24
25
} ,
25
26
Healthcheck , VectorSink as VectorSinkType ,
26
27
} ,
27
- tls:: { tls_connector_builder , MaybeTlsSettings , TlsEnableableConfig } ,
28
+ tls:: { MaybeTlsSettings , TlsEnableableConfig } ,
28
29
} ;
29
30
30
31
/// Configuration for the `vector` sink.
@@ -209,23 +210,7 @@ fn new_client(
209
210
tls_settings : & MaybeTlsSettings ,
210
211
proxy_config : & ProxyConfig ,
211
212
) -> crate :: Result < hyper:: Client < ProxyConnector < HttpsConnector < HttpConnector > > , BoxBody > > {
212
- let mut http = HttpConnector :: new ( ) ;
213
- http. enforce_http ( false ) ;
214
-
215
- let tls = tls_connector_builder ( tls_settings) ?;
216
- let mut https = HttpsConnector :: with_connector ( http, tls) ?;
217
-
218
- let settings = tls_settings. tls ( ) . cloned ( ) ;
219
- https. set_callback ( move |c, _uri| {
220
- if let Some ( settings) = & settings {
221
- settings. apply_connect_configuration ( c) ;
222
- }
223
-
224
- Ok ( ( ) )
225
- } ) ;
226
-
227
- let mut proxy = ProxyConnector :: new ( https) . unwrap ( ) ;
228
- proxy_config. configure ( & mut proxy) ?;
213
+ let proxy = build_proxy_connector ( tls_settings. clone ( ) , proxy_config) ?;
229
214
230
215
Ok ( hyper:: Client :: builder ( ) . http2_only ( true ) . build ( proxy) )
231
216
}
0 commit comments