feat: add the request sdk in dragonfly-client-util

Signed-off-by: chlins <[email protected]>

Author: chlins

Cargo.lock

@@ -12,7 +12,6 @@ edition.workspace = true
 [dependencies]
 dragonfly-client-core.workspace = true
 dragonfly-api.workspace = true
-reqwest.workspace = true
 http-range-header.workspace = true
 http.workspace = true
 tracing.workspace = true
@@ -31,9 +30,25 @@ lazy_static.workspace = true
 bytesize.workspace = true
 lru.workspace = true
 tokio.workspace = true
+tokio-util.workspace = true
+tonic.workspace = true
+reqwest.workspace = true
+reqwest-middleware.workspace = true
+futures.workspace = true
+thiserror.workspace = true
 rustix = { version = "1.0.8", features = ["fs"] }
 base64 = "0.22.1"
 pnet = "0.35.0"
+bytes = "1.0.0"
+protobuf = "3.7.2"
+hashring = "0.3.6"
+tonic-health = "0.12.3"
+local-ip-address = "0.6.5"
+hostname = "^0.4"
+dashmap = "6.1.0"
 
 [dev-dependencies]
 tempfile.workspace = true
+wiremock = "0.6.4"
+mockall = "0.13"
+mockito = "1.0"

dragonfly-client-util/Cargo.toml

@@ -19,4 +19,6 @@ pub mod fs;
 pub mod http;
 pub mod id_generator;
 pub mod net;
+pub mod request;
+pub mod selector;
 pub mod tls;

dragonfly-client-util/src/lib.rs

@@ -0,0 +1,80 @@
+/*
+ *     Copyright 2025 The Dragonfly Authors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+use dragonfly_client_core::Error as DFError;
+use reqwest;
+use std::collections::HashMap;
+use tonic::transport::Error as TonicTransportError;
+
+#[derive(Debug, thiserror::Error)]
+pub enum Error {
+    #[error(transparent)]
+    Base(#[from] DFError),
+
+    #[allow(clippy::enum_variant_names)]
+    #[error(transparent)]
+    BackendError(#[from] BackendError),
+
+    #[allow(clippy::enum_variant_names)]
+    #[error(transparent)]
+    ProxyError(#[from] ProxyError),
+
+    #[allow(clippy::enum_variant_names)]
+    #[error(transparent)]
+    DfdaemonError(#[from] DfdaemonError),
+}
+
+impl From<TonicTransportError> for Error {
+    fn from(err: TonicTransportError) -> Self {
+        Error::Base(DFError::TonicTransportError(err))
+    }
+}
+
+// BackendError is error detail for Backend.
+#[derive(Debug, thiserror::Error)]
+#[error("error occurred in the backend server, message: {message:?}, header: {header:?}, status_code: {status_code:?}")]
+pub struct BackendError {
+    // Backend error message.
+    pub message: Option<String>,
+
+    // Backend HTTP response header.
+    pub header: HashMap<String, String>,
+
+    // Backend HTTP status code.
+    pub status_code: Option<reqwest::StatusCode>,
+}
+
+// ProxyError is error detail for Proxy.
+#[derive(Debug, thiserror::Error)]
+#[error("error occurred in the proxy server, message: {message:?}, header: {header:?}, status_code: {status_code:?}")]
+pub struct ProxyError {
+    // Proxy error message.
+    pub message: Option<String>,
+
+    // Proxy HTTP response header.
+    pub header: HashMap<String, String>,
+
+    // Proxy HTTP status code.
+    pub status_code: Option<reqwest::StatusCode>,
+}
+
+// DfdaemonError is error detail for Dfdaemon.
+#[derive(Debug, thiserror::Error)]
+#[error("error occurred in the dfdaemon, message: {message:?}")]
+pub struct DfdaemonError {
+    // Dfdaemon error message.
+    pub message: Option<String>,
+}