feat: Implement huaweicloud obs service read support

Cargo.toml

@@ -80,7 +80,8 @@ percent-encoding = "2.1"
 pin-project = "1.0"
 quick-xml = { version = "0.23", features = ["serialize"] }
 radix_trie = { version = "0.2", optional = true }
-reqsign = "0.3"
+regex = "1.6"
+reqsign = "0.4"
 serde = { version = "1.0", features = ["derive"] }
 serde_json = "1.0"
 thiserror = "1.0"

src/operator.rs

@@ -130,6 +130,7 @@ impl Operator {
  Scheme::Memory => services::memory::Builder::default().build()?.into(),
  Scheme::Gcs => services::gcs::Backend::from_iter(it)?.into(),
  Scheme::S3 => services::s3::Backend::from_iter(it)?.into(),
+ Scheme::Obs => services::obs::Backend::from_iter(it)?.into(),
  };
 
  Ok(op)

src/scheme.rs

@@ -40,6 +40,8 @@ pub enum Scheme {
  Memory,
  /// [s3][crate::services::s3]: AWS S3 alike services.
  S3,
+ /// [obs][crate::services::obs]: Huaweicloud OBS services.
+ Obs,
 }
 
 impl Scheme {
@@ -67,6 +69,7 @@ impl Display for Scheme {
  Scheme::Http => write!(f, "http"),
  Scheme::Memory => write!(f, "memory"),
  Scheme::S3 => write!(f, "s3"),
+ Scheme::Obs => write!(f, "obs"),
  }
  }
 }
@@ -86,6 +89,7 @@ impl FromStr for Scheme {
  "gcs" => Ok(Scheme::Gcs),
  "memory" => Ok(Scheme::Memory),
  "s3" => Ok(Scheme::S3),
+ "obs" => Ok(Scheme::Obs),
  v => Err(other(BackendError::new(
  Default::default(),
  anyhow!("{} is not supported", v),
@@ -106,6 +110,7 @@ impl From<Scheme> for &'static str {
  Scheme::Gcs => "gcs",
  Scheme::Memory => "memory",
  Scheme::S3 => "s3",
+ Scheme::Obs => "obs",
  }
  }
 }

src/services/mod.rs

@@ -27,4 +27,5 @@ pub mod hdfs;
 #[cfg(feature = "services-http")]
 pub mod http;
 pub mod memory;
+pub mod obs;
 pub mod s3;