feat: Add azdfs support

.github/workflows/service_test_azdfs.yml

@@ -0,0 +1,33 @@
+name: Service Test Azdfs
+
+on:
+  push:
+    branches:
+      - main
+  pull_request:
+    branches:
+      - main
+    paths-ignore:
+      - "docs/**"
+
+concurrency:
+  group: ${{ github.workflow }}-${{ github.ref }}-${{ github.event_name }}
+  cancel-in-progress: true
+
+jobs:
+  azure_azdfs:
+    runs-on: ubuntu-latest
+
+    steps:
+      - uses: actions/checkout@v3
+      - name: Test
+        shell: bash
+        run: cargo test azdfs --features compress -- --nocapture
+        env:
+          RUST_BACKTRACE: full
+          RUST_LOG: debug
+          OPENDAL_AZDFS_TEST: ${{ secrets.OPENDAL_AZDFS_TEST }}
+          OPENDAL_AZDFS_FILESYSTEM: ${{ secrets.OPENDAL_AZDFS_FILESYSTEM }}
+          OPENDAL_AZDFS_ENDPOINT: ${{ secrets.OPENDAL_AZDFS_ENDPOINT }}
+          OPENDAL_AZDFS_ACCOUNT_NAME: ${{ secrets.OPENDAL_AZDFS_ACCOUNT_NAME }}
+          OPENDAL_AZDFS_ACCOUNT_KEY: ${{ secrets.OPENDAL_AZDFS_ACCOUNT_KEY }}

src/operator.rs

@@ -126,6 +126,7 @@ impl Operator {
     ) -> Result<Self> {
         let op = match scheme {
             Scheme::Azblob => services::azblob::Builder::from_iter(it).build()?.into(),
+            Scheme::Azdfs => services::azdfs::Builder::from_iter(it).build()?.into(),
             Scheme::Fs => services::fs::Builder::from_iter(it).build()?.into(),
             #[cfg(feature = "services-ftp")]
             Scheme::Ftp => services::ftp::Builder::from_iter(it).build()?.into(),

src/scheme.rs

@@ -30,6 +30,8 @@ use crate::Error;
 pub enum Scheme {
     /// [azblob][crate::services::azblob]: Azure Storage Blob services.
     Azblob,
+    /// [azdls][crate::services::azdls]: Azure Data Lake Storage Gen2.
+    Azdfs,
     /// [fs][crate::services::fs]: POSIX alike file system.
     Fs,
     /// [gcs][crate::services::gcs]: Google Cloud Storage backend.
@@ -90,6 +92,7 @@ impl Display for Scheme {
     fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result {
         match self {
             Scheme::Azblob => write!(f, "azblob"),
+            Scheme::Azdfs => write!(f, "azdfs"),
             Scheme::Fs => write!(f, "fs"),
             #[cfg(feature = "services-hdfs")]
             Scheme::Hdfs => write!(f, "hdfs"),
@@ -122,6 +125,7 @@ impl FromStr for Scheme {
         let s = s.to_lowercase();
         match s.as_str() {
             "azblob" => Ok(Scheme::Azblob),
+            "azdfs" => Ok(Scheme::Azdfs),
             "fs" => Ok(Scheme::Fs),
             "gcs" => Ok(Scheme::Gcs),
             #[cfg(feature = "services-hdfs")]
@@ -151,6 +155,7 @@ impl From<Scheme> for &'static str {
     fn from(v: Scheme) -> Self {
         match v {
             Scheme::Azblob => "azblob",
+            Scheme::Azdfs => "azdfs",
             Scheme::Fs => "fs",
             Scheme::Gcs => "gcs",
             #[cfg(feature = "services-hdfs")]