1

core/src/services/mod.rs

@@ -213,3 +213,6 @@ pub use webhdfs::*;
 
 mod yandex_disk;
 pub use yandex_disk::*;
+
+mod lakefs;
+pub use lakefs::*;

core/src/types/operator/builder.rs

@@ -290,6 +290,8 @@ impl Operator {
             Scheme::Mongodb => Self::from_iter::<services::Mongodb>(iter)?.finish(),
             #[cfg(feature = "services-hdfs-native")]
             Scheme::HdfsNative => Self::from_iter::<services::HdfsNative>(iter)?.finish(),
+            #[cfg(feature = "services-lakefs")]
+            Scheme::Lakefs => Self::from_iter::<services::Lakefs>(iter)?.finish(),
             v => {
                 return Err(Error::new(
                     ErrorKind::Unsupported,

core/src/types/scheme.rs

@@ -163,6 +163,8 @@ pub enum Scheme {
     HdfsNative,
     /// [surrealdb](crate::services::Surrealdb): Surrealdb Services
     Surrealdb,
+    /// [lakefs](crate::services::Lakefs): LakeFS Services
+    Lakefs,
     /// Custom that allow users to implement services outside of OpenDAL.
     ///
     /// # NOTE
@@ -311,6 +313,8 @@ impl Scheme {
             Scheme::HdfsNative,
             #[cfg(feature = "services-surrealdb")]
             Scheme::Surrealdb,
+            #[cfg(feature = "services-lakefs")]
+            Scheme::Lakefs,
         ])
     }
 }
@@ -401,6 +405,7 @@ impl FromStr for Scheme {
             "mongodb" => Ok(Scheme::Mongodb),
             "hdfs_native" => Ok(Scheme::HdfsNative),
             "surrealdb" => Ok(Scheme::Surrealdb),
+            "lakefs" => Ok(Scheme::Lakefs),
             _ => Ok(Scheme::Custom(Box::leak(s.into_boxed_str()))),
         }
     }
@@ -474,6 +479,7 @@ impl From<Scheme> for &'static str {
             Scheme::Pcloud => "pcloud",
             Scheme::HdfsNative => "hdfs_native",
             Scheme::Surrealdb => "surrealdb",
+            Scheme::Lakefs => "lakefs",
             Scheme::Custom(v) => v,
         }
     }