aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorQuentin Dufour <quentin@deuxfleurs.fr>2024-02-23 17:09:47 +0100
committerQuentin Dufour <quentin@deuxfleurs.fr>2024-02-23 17:09:47 +0100
commit8b35a946d9f6b31b26b9783acbfab984316051f4 (patch)
tree41480d1485dee1fd4c7736097683dbfc3237cca4
parent61758ce0f91b930542bd2ee3c72735000cc12e75 (diff)
downloadgarage-8b35a946d9f6b31b26b9783acbfab984316051f4.tar.gz
garage-8b35a946d9f6b31b26b9783acbfab984316051f4.zip
Allow external HTTP clientk2v/shared_http_client
-rw-r--r--src/k2v-client/lib.rs10
1 files changed, 10 insertions, 0 deletions
diff --git a/src/k2v-client/lib.rs b/src/k2v-client/lib.rs
index 852274a7..5b6d7f58 100644
--- a/src/k2v-client/lib.rs
+++ b/src/k2v-client/lib.rs
@@ -72,6 +72,16 @@ impl K2vClient {
.enable_http2()
.build();
let client = HttpClient::builder(TokioExecutor::new()).build(connector);
+ Self::new_with_client(config, client)
+ }
+
+ /// Create a new K2V client with an external client.
+ /// Useful for example if you plan on creating many clients but you want to mutualize the
+ /// underlying thread pools & co.
+ pub fn new_with_client(
+ config: K2vClientConfig,
+ client: HttpClient<HttpsConnector<HttpConnector>, Body>,
+ ) -> Result<Self, Error> {
let user_agent: std::borrow::Cow<str> = match &config.user_agent {
Some(ua) => ua.into(),
None => format!("k2v/{}", env!("CARGO_PKG_VERSION")).into(),