This is an automated email from the ASF dual-hosted git repository. xuanwo pushed a commit to branch cleanup-config in repository https://gitbox.apache.org/repos/asf/opendal.git
commit 8df3e6e2118711e285c5b040ee9c9197b86a907e Author: Xuanwo <[email protected]> AuthorDate: Tue Oct 14 18:05:32 2025 +0800 Rename scheme Signed-off-by: Xuanwo <[email protected]> --- core/src/services/aliyun_drive/backend.rs | 4 ++-- core/src/services/aliyun_drive/mod.rs | 2 +- core/src/services/alluxio/backend.rs | 4 ++-- core/src/services/alluxio/mod.rs | 2 +- core/src/services/azdls/backend.rs | 4 ++-- core/src/services/azdls/mod.rs | 2 +- core/src/services/azfile/backend.rs | 4 ++-- core/src/services/azfile/mod.rs | 2 +- core/src/services/cacache/backend.rs | 4 ++-- core/src/services/cacache/mod.rs | 2 +- core/src/services/cloudflare_kv/backend.rs | 4 ++-- core/src/services/cloudflare_kv/mod.rs | 2 +- core/src/services/compfs/backend.rs | 4 ++-- core/src/services/compfs/mod.rs | 2 +- core/src/services/dashmap/backend.rs | 4 ++-- core/src/services/dashmap/mod.rs | 2 +- core/src/services/dbfs/backend.rs | 4 ++-- core/src/services/dbfs/mod.rs | 2 +- core/src/services/dropbox/builder.rs | 4 ++-- core/src/services/dropbox/mod.rs | 2 +- core/src/services/etcd/backend.rs | 4 ++-- core/src/services/etcd/mod.rs | 2 +- core/src/services/ftp/backend.rs | 6 +++--- core/src/services/ftp/mod.rs | 2 +- core/src/services/gdrive/builder.rs | 4 ++-- core/src/services/gdrive/mod.rs | 2 +- core/src/services/ghac/backend.rs | 4 ++-- core/src/services/ghac/mod.rs | 2 +- core/src/services/github/backend.rs | 4 ++-- core/src/services/github/mod.rs | 2 +- core/src/services/hdfs/backend.rs | 4 ++-- core/src/services/hdfs/mod.rs | 2 +- core/src/services/hdfs_native/backend.rs | 4 ++-- core/src/services/hdfs_native/mod.rs | 2 +- core/src/services/http/backend.rs | 4 ++-- core/src/services/http/mod.rs | 2 +- core/src/services/huggingface/backend.rs | 4 ++-- core/src/services/huggingface/mod.rs | 2 +- core/src/services/ipfs/backend.rs | 4 ++-- core/src/services/ipfs/mod.rs | 2 +- core/src/services/ipmfs/builder.rs | 4 ++-- core/src/services/ipmfs/mod.rs | 2 +- core/src/services/koofr/backend.rs | 4 ++-- core/src/services/koofr/mod.rs | 2 +- core/src/services/lakefs/backend.rs | 4 ++-- core/src/services/lakefs/mod.rs | 2 +- core/src/services/mini_moka/backend.rs | 4 ++-- core/src/services/mini_moka/mod.rs | 2 +- core/src/services/moka/backend.rs | 4 ++-- core/src/services/moka/mod.rs | 2 +- core/src/services/monoiofs/core.rs | 4 ++-- core/src/services/monoiofs/mod.rs | 2 +- core/src/services/onedrive/builder.rs | 4 ++-- core/src/services/onedrive/mod.rs | 2 +- core/src/services/pcloud/backend.rs | 4 ++-- core/src/services/pcloud/mod.rs | 2 +- core/src/services/redis/backend.rs | 4 ++-- core/src/services/redis/mod.rs | 2 +- core/src/services/seafile/backend.rs | 4 ++-- core/src/services/seafile/mod.rs | 2 +- core/src/services/sftp/backend.rs | 4 ++-- core/src/services/sftp/mod.rs | 2 +- core/src/services/swift/backend.rs | 4 ++-- core/src/services/swift/mod.rs | 2 +- core/src/services/vercel_artifacts/builder.rs | 4 ++-- core/src/services/vercel_artifacts/mod.rs | 2 +- core/src/services/vercel_blob/backend.rs | 4 ++-- core/src/services/vercel_blob/mod.rs | 2 +- core/src/services/webdav/backend.rs | 4 ++-- core/src/services/webdav/mod.rs | 2 +- core/src/services/webhdfs/backend.rs | 4 ++-- core/src/services/webhdfs/mod.rs | 2 +- core/src/services/yandex_disk/backend.rs | 4 ++-- core/src/services/yandex_disk/mod.rs | 2 +- 74 files changed, 112 insertions(+), 112 deletions(-) diff --git a/core/src/services/aliyun_drive/backend.rs b/core/src/services/aliyun_drive/backend.rs index 362aac6fe..220544784 100644 --- a/core/src/services/aliyun_drive/backend.rs +++ b/core/src/services/aliyun_drive/backend.rs @@ -25,7 +25,7 @@ use http::StatusCode; use log::debug; use tokio::sync::Mutex; -use super::DEFAULT_SCHEME; +use super::ALIYUN_DRIVE_SCHEME; use super::core::*; use super::delete::AliyunDriveDeleter; use super::error::parse_error; @@ -175,7 +175,7 @@ impl Builder for AliyunDriveBuilder { core: Arc::new(AliyunDriveCore { info: { let am = AccessorInfo::default(); - am.set_scheme(DEFAULT_SCHEME) + am.set_scheme(ALIYUN_DRIVE_SCHEME) .set_root(&root) .set_native_capability(Capability { stat: true, diff --git a/core/src/services/aliyun_drive/mod.rs b/core/src/services/aliyun_drive/mod.rs index 2ab6e5624..2b3b8e39e 100644 --- a/core/src/services/aliyun_drive/mod.rs +++ b/core/src/services/aliyun_drive/mod.rs @@ -16,7 +16,7 @@ // under the License. /// Default scheme for aliyun_drive service. -pub(super) const DEFAULT_SCHEME: &str = "aliyun_drive"; +pub(super) const ALIYUN_DRIVE_SCHEME: &str = "aliyun_drive"; mod core; mod backend; diff --git a/core/src/services/alluxio/backend.rs b/core/src/services/alluxio/backend.rs index c3feb6ac7..b383ef963 100644 --- a/core/src/services/alluxio/backend.rs +++ b/core/src/services/alluxio/backend.rs @@ -22,7 +22,7 @@ use std::sync::Arc; use http::Response; use log::debug; -use super::DEFAULT_SCHEME; +use super::ALLUXIO_SCHEME; use super::core::AlluxioCore; use super::delete::AlluxioDeleter; use super::error::parse_error; @@ -125,7 +125,7 @@ impl Builder for AlluxioBuilder { core: Arc::new(AlluxioCore { info: { let am = AccessorInfo::default(); - am.set_scheme(DEFAULT_SCHEME) + am.set_scheme(ALLUXIO_SCHEME) .set_root(&root) .set_native_capability(Capability { stat: true, diff --git a/core/src/services/alluxio/mod.rs b/core/src/services/alluxio/mod.rs index 8ac90bd24..d0af06b3b 100644 --- a/core/src/services/alluxio/mod.rs +++ b/core/src/services/alluxio/mod.rs @@ -16,7 +16,7 @@ // under the License. /// Default scheme for alluxio service. -pub(super) const DEFAULT_SCHEME: &str = "alluxio"; +pub(super) const ALLUXIO_SCHEME: &str = "alluxio"; mod core; mod delete; mod error; diff --git a/core/src/services/azdls/backend.rs b/core/src/services/azdls/backend.rs index f42e76ce0..629823e8f 100644 --- a/core/src/services/azdls/backend.rs +++ b/core/src/services/azdls/backend.rs @@ -26,7 +26,7 @@ use reqsign::AzureStorageConfig; use reqsign::AzureStorageLoader; use reqsign::AzureStorageSigner; -use super::DEFAULT_SCHEME; +use super::AZDLS_SCHEME; use super::core::AzdlsCore; use super::core::DIRECTORY; use super::delete::AzdlsDeleter; @@ -295,7 +295,7 @@ impl Builder for AzdlsBuilder { core: Arc::new(AzdlsCore { info: { let am = AccessorInfo::default(); - am.set_scheme(DEFAULT_SCHEME) + am.set_scheme(AZDLS_SCHEME) .set_root(&root) .set_name(filesystem) .set_native_capability(Capability { diff --git a/core/src/services/azdls/mod.rs b/core/src/services/azdls/mod.rs index a046c3e9c..79ce34f12 100644 --- a/core/src/services/azdls/mod.rs +++ b/core/src/services/azdls/mod.rs @@ -16,7 +16,7 @@ // under the License. /// Default scheme for azdls service. -pub(super) const DEFAULT_SCHEME: &str = "azdls"; +pub(super) const AZDLS_SCHEME: &str = "azdls"; mod backend; mod core; mod delete; diff --git a/core/src/services/azfile/backend.rs b/core/src/services/azfile/backend.rs index f92912105..6ab518926 100644 --- a/core/src/services/azfile/backend.rs +++ b/core/src/services/azfile/backend.rs @@ -26,7 +26,7 @@ use reqsign::AzureStorageConfig; use reqsign::AzureStorageLoader; use reqsign::AzureStorageSigner; -use super::DEFAULT_SCHEME; +use super::AZFILE_SCHEME; use super::core::AzfileCore; use super::delete::AzfileDeleter; use super::error::parse_error; @@ -225,7 +225,7 @@ impl Builder for AzfileBuilder { core: Arc::new(AzfileCore { info: { let am = AccessorInfo::default(); - am.set_scheme(DEFAULT_SCHEME) + am.set_scheme(AZFILE_SCHEME) .set_root(&root) .set_native_capability(Capability { stat: true, diff --git a/core/src/services/azfile/mod.rs b/core/src/services/azfile/mod.rs index 55bb87234..fbd6826a4 100644 --- a/core/src/services/azfile/mod.rs +++ b/core/src/services/azfile/mod.rs @@ -16,7 +16,7 @@ // under the License. /// Default scheme for azfile service. -pub(super) const DEFAULT_SCHEME: &str = "azfile"; +pub(super) const AZFILE_SCHEME: &str = "azfile"; mod core; mod delete; mod error; diff --git a/core/src/services/cacache/backend.rs b/core/src/services/cacache/backend.rs index 297c0dafb..eeecb57b8 100644 --- a/core/src/services/cacache/backend.rs +++ b/core/src/services/cacache/backend.rs @@ -21,7 +21,7 @@ use crate::*; use std::fmt::Debug; use std::sync::Arc; -use super::DEFAULT_SCHEME; +use super::CACACHE_SCHEME; use super::core::CacacheCore; use super::delete::CacacheDeleter; use super::writer::CacacheWriter; @@ -61,7 +61,7 @@ impl Builder for CacacheBuilder { }; let info = AccessorInfo::default(); - info.set_scheme(DEFAULT_SCHEME); + info.set_scheme(CACACHE_SCHEME); info.set_name(&datadir_path); info.set_root("/"); info.set_native_capability(Capability { diff --git a/core/src/services/cacache/mod.rs b/core/src/services/cacache/mod.rs index 96f94b71a..bb618f4e4 100644 --- a/core/src/services/cacache/mod.rs +++ b/core/src/services/cacache/mod.rs @@ -16,7 +16,7 @@ // under the License. /// Default scheme for cacache service. -pub(super) const DEFAULT_SCHEME: &str = "cacache"; +pub(super) const CACACHE_SCHEME: &str = "cacache"; mod backend; mod core; mod delete; diff --git a/core/src/services/cloudflare_kv/backend.rs b/core/src/services/cloudflare_kv/backend.rs index e0f5043a6..5c42e1b2f 100644 --- a/core/src/services/cloudflare_kv/backend.rs +++ b/core/src/services/cloudflare_kv/backend.rs @@ -20,7 +20,7 @@ use std::fmt::Formatter; use std::sync::Arc; use std::time::Duration; -use super::DEFAULT_SCHEME; +use super::CLOUDFLARE_KV_SCHEME; use crate::ErrorKind; use crate::raw::*; use crate::services::CloudflareKvConfig; @@ -160,7 +160,7 @@ impl Builder for CloudflareKvBuilder { expiration_ttl: self.config.default_ttl, info: { let am = AccessorInfo::default(); - am.set_scheme(DEFAULT_SCHEME) + am.set_scheme(CLOUDFLARE_KV_SCHEME) .set_root(&root) .set_native_capability(Capability { create_dir: true, diff --git a/core/src/services/cloudflare_kv/mod.rs b/core/src/services/cloudflare_kv/mod.rs index 0e1b2a9f5..099549b5e 100644 --- a/core/src/services/cloudflare_kv/mod.rs +++ b/core/src/services/cloudflare_kv/mod.rs @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -pub(super) const DEFAULT_SCHEME: &str = "cloudflare_kv"; +pub(super) const CLOUDFLARE_KV_SCHEME: &str = "cloudflare_kv"; mod error; mod backend; diff --git a/core/src/services/compfs/backend.rs b/core/src/services/compfs/backend.rs index 61e53928f..592055d22 100644 --- a/core/src/services/compfs/backend.rs +++ b/core/src/services/compfs/backend.rs @@ -21,7 +21,7 @@ use std::sync::Arc; use compio::dispatcher::Dispatcher; use compio::fs::OpenOptions; -use super::DEFAULT_SCHEME; +use super::COMPFS_SCHEME; use super::core::CompfsCore; use super::delete::CompfsDeleter; use super::lister::CompfsLister; @@ -90,7 +90,7 @@ impl Builder for CompfsBuilder { let core = CompfsCore { info: { let am = AccessorInfo::default(); - am.set_scheme(DEFAULT_SCHEME) + am.set_scheme(COMPFS_SCHEME) .set_root(&root) .set_native_capability(Capability { stat: true, diff --git a/core/src/services/compfs/mod.rs b/core/src/services/compfs/mod.rs index 7e9052f95..9a4ad4f63 100644 --- a/core/src/services/compfs/mod.rs +++ b/core/src/services/compfs/mod.rs @@ -16,7 +16,7 @@ // under the License. /// Default scheme for compfs service. -pub(super) const DEFAULT_SCHEME: &str = "compfs"; +pub(super) const COMPFS_SCHEME: &str = "compfs"; mod core; mod delete; mod lister; diff --git a/core/src/services/dashmap/backend.rs b/core/src/services/dashmap/backend.rs index edf92837a..2b0c540a8 100644 --- a/core/src/services/dashmap/backend.rs +++ b/core/src/services/dashmap/backend.rs @@ -22,7 +22,7 @@ use std::sync::Arc; use dashmap::DashMap; use log::debug; -use super::DEFAULT_SCHEME; +use super::DASHMAP_SCHEME; use super::core::DashmapCore; use super::delete::DashmapDeleter; use super::lister::DashmapLister; @@ -100,7 +100,7 @@ pub struct DashmapAccessor { impl DashmapAccessor { fn new(core: DashmapCore, root: String) -> Self { let info = AccessorInfo::default(); - info.set_scheme(DEFAULT_SCHEME); + info.set_scheme(DASHMAP_SCHEME); info.set_name("dashmap"); info.set_root(&root); info.set_native_capability(Capability { diff --git a/core/src/services/dashmap/mod.rs b/core/src/services/dashmap/mod.rs index 4fe62b61a..6f24ca5f9 100644 --- a/core/src/services/dashmap/mod.rs +++ b/core/src/services/dashmap/mod.rs @@ -16,7 +16,7 @@ // under the License. /// Default scheme for dashmap service. -pub(super) const DEFAULT_SCHEME: &str = "dashmap"; +pub(super) const DASHMAP_SCHEME: &str = "dashmap"; mod backend; mod core; mod delete; diff --git a/core/src/services/dbfs/backend.rs b/core/src/services/dbfs/backend.rs index 55414d3cc..2a6ed5a8b 100644 --- a/core/src/services/dbfs/backend.rs +++ b/core/src/services/dbfs/backend.rs @@ -24,7 +24,7 @@ use http::StatusCode; use log::debug; use serde::Deserialize; -use super::DEFAULT_SCHEME; +use super::DBFS_SCHEME; use super::core::DbfsCore; use super::delete::DbfsDeleter; use super::error::parse_error; @@ -149,7 +149,7 @@ impl Access for DbfsBackend { fn info(&self) -> Arc<AccessorInfo> { let am = AccessorInfo::default(); - am.set_scheme(DEFAULT_SCHEME) + am.set_scheme(DBFS_SCHEME) .set_root(&self.core.root) .set_native_capability(Capability { stat: true, diff --git a/core/src/services/dbfs/mod.rs b/core/src/services/dbfs/mod.rs index 221b9f096..a2f81b9cd 100644 --- a/core/src/services/dbfs/mod.rs +++ b/core/src/services/dbfs/mod.rs @@ -16,7 +16,7 @@ // under the License. /// Default scheme for dbfs service. -pub(super) const DEFAULT_SCHEME: &str = "dbfs"; +pub(super) const DBFS_SCHEME: &str = "dbfs"; mod core; mod delete; mod error; diff --git a/core/src/services/dropbox/builder.rs b/core/src/services/dropbox/builder.rs index 1b8e794ad..520b28004 100644 --- a/core/src/services/dropbox/builder.rs +++ b/core/src/services/dropbox/builder.rs @@ -20,7 +20,7 @@ use std::fmt::Formatter; use std::sync::Arc; use tokio::sync::Mutex; -use super::DEFAULT_SCHEME; +use super::DROPBOX_SCHEME; use super::backend::DropboxBackend; use super::core::DropboxCore; use super::core::DropboxSigner; @@ -178,7 +178,7 @@ impl Builder for DropboxBuilder { core: Arc::new(DropboxCore { info: { let am = AccessorInfo::default(); - am.set_scheme(DEFAULT_SCHEME) + am.set_scheme(DROPBOX_SCHEME) .set_root(&root) .set_native_capability(Capability { stat: true, diff --git a/core/src/services/dropbox/mod.rs b/core/src/services/dropbox/mod.rs index c504f0d58..bd487630b 100644 --- a/core/src/services/dropbox/mod.rs +++ b/core/src/services/dropbox/mod.rs @@ -16,7 +16,7 @@ // under the License. /// Default scheme for dropbox service. -pub(super) const DEFAULT_SCHEME: &str = "dropbox"; +pub(super) const DROPBOX_SCHEME: &str = "dropbox"; mod backend; mod core; mod delete; diff --git a/core/src/services/etcd/backend.rs b/core/src/services/etcd/backend.rs index 7c0ed93f8..3dcd0a0c8 100644 --- a/core/src/services/etcd/backend.rs +++ b/core/src/services/etcd/backend.rs @@ -25,7 +25,7 @@ use etcd_client::Identity; use etcd_client::TlsOptions; use tokio::sync::OnceCell; -use super::DEFAULT_SCHEME; +use super::ETCD_SCHEME; use super::core::EtcdCore; use super::core::constants::DEFAULT_ETCD_ENDPOINTS; use super::deleter::EtcdDeleter; @@ -204,7 +204,7 @@ pub struct EtcdAccessor { impl EtcdAccessor { fn new(core: EtcdCore, root: &str) -> Self { let info = AccessorInfo::default(); - info.set_scheme(DEFAULT_SCHEME); + info.set_scheme(ETCD_SCHEME); info.set_name("etcd"); info.set_root(root); info.set_native_capability(Capability { diff --git a/core/src/services/etcd/mod.rs b/core/src/services/etcd/mod.rs index 829b70ea4..b317d0626 100644 --- a/core/src/services/etcd/mod.rs +++ b/core/src/services/etcd/mod.rs @@ -15,7 +15,7 @@ // specific language governing permissions and limitations // under the License. -pub(super) const DEFAULT_SCHEME: &str = "etcd"; +pub(super) const ETCD_SCHEME: &str = "etcd"; mod backend; mod core; mod deleter; diff --git a/core/src/services/ftp/backend.rs b/core/src/services/ftp/backend.rs index 4b5362a95..9195c033a 100644 --- a/core/src/services/ftp/backend.rs +++ b/core/src/services/ftp/backend.rs @@ -30,7 +30,7 @@ use suppaftp::list::File; use suppaftp::types::Response; use tokio::sync::OnceCell; -use super::DEFAULT_SCHEME; +use super::FTP_SCHEME; use super::core::FtpCore; use super::delete::FtpDeleter; use super::err::parse_error; @@ -53,7 +53,7 @@ impl Configurator for FtpConfig { let mut map = uri.options().clone(); map.insert( "endpoint".to_string(), - format!("{DEFAULT_SCHEME}://{authority}"), + format!("{FTP_SCHEME}://{authority}"), ); if let Some(root) = uri.root() { @@ -182,7 +182,7 @@ impl Builder for FtpBuilder { let accessor_info = AccessorInfo::default(); accessor_info - .set_scheme(DEFAULT_SCHEME) + .set_scheme(FTP_SCHEME) .set_root(&root) .set_native_capability(Capability { stat: true, diff --git a/core/src/services/ftp/mod.rs b/core/src/services/ftp/mod.rs index 21ac3fb2e..0e2a0d167 100644 --- a/core/src/services/ftp/mod.rs +++ b/core/src/services/ftp/mod.rs @@ -16,7 +16,7 @@ // under the License. /// Default scheme for ftp service. -pub(super) const DEFAULT_SCHEME: &str = "ftp"; +pub(super) const FTP_SCHEME: &str = "ftp"; mod delete; mod err; mod lister; diff --git a/core/src/services/gdrive/builder.rs b/core/src/services/gdrive/builder.rs index e6425e4fc..9b604d102 100644 --- a/core/src/services/gdrive/builder.rs +++ b/core/src/services/gdrive/builder.rs @@ -21,7 +21,7 @@ use std::fmt::Formatter; use std::sync::Arc; use tokio::sync::Mutex; -use super::DEFAULT_SCHEME; +use super::GDRIVE_SCHEME; use super::backend::GdriveBackend; use super::core::GdriveCore; use super::core::GdrivePathQuery; @@ -140,7 +140,7 @@ impl Builder for GdriveBuilder { debug!("backend use root {root}"); let info = AccessorInfo::default(); - info.set_scheme(DEFAULT_SCHEME) + info.set_scheme(GDRIVE_SCHEME) .set_root(&root) .set_native_capability(Capability { stat: true, diff --git a/core/src/services/gdrive/mod.rs b/core/src/services/gdrive/mod.rs index 20e8a4b6a..3be25b77d 100644 --- a/core/src/services/gdrive/mod.rs +++ b/core/src/services/gdrive/mod.rs @@ -16,7 +16,7 @@ // under the License. /// Default scheme for gdrive service. -pub(super) const DEFAULT_SCHEME: &str = "gdrive"; +pub(super) const GDRIVE_SCHEME: &str = "gdrive"; mod backend; mod core; mod delete; diff --git a/core/src/services/ghac/backend.rs b/core/src/services/ghac/backend.rs index 2b9405860..c63677ece 100644 --- a/core/src/services/ghac/backend.rs +++ b/core/src/services/ghac/backend.rs @@ -23,7 +23,7 @@ use http::StatusCode; use log::debug; use sha2::Digest; -use super::DEFAULT_SCHEME; +use super::GHAC_SCHEME; use super::core::*; use super::error::parse_error; use super::writer::GhacWriter; @@ -173,7 +173,7 @@ impl Builder for GhacBuilder { let core = GhacCore { info: { let am = AccessorInfo::default(); - am.set_scheme(DEFAULT_SCHEME) + am.set_scheme(GHAC_SCHEME) .set_root(&root) .set_name(&version) .set_native_capability(Capability { diff --git a/core/src/services/ghac/mod.rs b/core/src/services/ghac/mod.rs index 4d7253fdc..0b01d29b2 100644 --- a/core/src/services/ghac/mod.rs +++ b/core/src/services/ghac/mod.rs @@ -16,7 +16,7 @@ // under the License. /// Default scheme for ghac service. -pub(super) const DEFAULT_SCHEME: &str = "ghac"; +pub(super) const GHAC_SCHEME: &str = "ghac"; mod error; mod writer; diff --git a/core/src/services/github/backend.rs b/core/src/services/github/backend.rs index 0bedeaa90..7faa1f5c6 100644 --- a/core/src/services/github/backend.rs +++ b/core/src/services/github/backend.rs @@ -24,7 +24,7 @@ use http::Response; use http::StatusCode; use log::debug; -use super::DEFAULT_SCHEME; +use super::GITHUB_SCHEME; use super::core::Entry; use super::core::GithubCore; use super::delete::GithubDeleter; @@ -150,7 +150,7 @@ impl Builder for GithubBuilder { core: Arc::new(GithubCore { info: { let am = AccessorInfo::default(); - am.set_scheme(DEFAULT_SCHEME) + am.set_scheme(GITHUB_SCHEME) .set_root(&root) .set_native_capability(Capability { stat: true, diff --git a/core/src/services/github/mod.rs b/core/src/services/github/mod.rs index bba40e498..210675eef 100644 --- a/core/src/services/github/mod.rs +++ b/core/src/services/github/mod.rs @@ -16,7 +16,7 @@ // under the License. /// Default scheme for github service. -pub(super) const DEFAULT_SCHEME: &str = "github"; +pub(super) const GITHUB_SCHEME: &str = "github"; mod core; mod delete; mod error; diff --git a/core/src/services/hdfs/backend.rs b/core/src/services/hdfs/backend.rs index 14613cfa2..269042e1e 100644 --- a/core/src/services/hdfs/backend.rs +++ b/core/src/services/hdfs/backend.rs @@ -24,7 +24,7 @@ use std::sync::Arc; use log::debug; -use super::DEFAULT_SCHEME; +use super::HDFS_SCHEME; use super::delete::HdfsDeleter; use super::lister::HdfsLister; use super::reader::HdfsReader; @@ -173,7 +173,7 @@ impl Builder for HdfsBuilder { Ok(HdfsBackend { info: { let am = AccessorInfo::default(); - am.set_scheme(DEFAULT_SCHEME) + am.set_scheme(HDFS_SCHEME) .set_root(&root) .set_native_capability(Capability { stat: true, diff --git a/core/src/services/hdfs/mod.rs b/core/src/services/hdfs/mod.rs index 88b8e1c67..240d1474a 100644 --- a/core/src/services/hdfs/mod.rs +++ b/core/src/services/hdfs/mod.rs @@ -16,7 +16,7 @@ // under the License. /// Default scheme for hdfs service. -pub(super) const DEFAULT_SCHEME: &str = "hdfs"; +pub(super) const HDFS_SCHEME: &str = "hdfs"; mod delete; mod lister; mod reader; diff --git a/core/src/services/hdfs_native/backend.rs b/core/src/services/hdfs_native/backend.rs index 0848c3059..364759d86 100644 --- a/core/src/services/hdfs_native/backend.rs +++ b/core/src/services/hdfs_native/backend.rs @@ -23,7 +23,7 @@ use hdfs_native::HdfsError; use hdfs_native::WriteOptions; use log::debug; -use super::DEFAULT_SCHEME; +use super::HDFS_NATIVE_SCHEME; use super::delete::HdfsNativeDeleter; use super::error::parse_hdfs_error; use super::lister::HdfsNativeLister; @@ -152,7 +152,7 @@ impl Access for HdfsNativeBackend { fn info(&self) -> Arc<AccessorInfo> { let am = AccessorInfo::default(); - am.set_scheme(DEFAULT_SCHEME) + am.set_scheme(HDFS_NATIVE_SCHEME) .set_root(&self.root) .set_native_capability(Capability { stat: true, diff --git a/core/src/services/hdfs_native/mod.rs b/core/src/services/hdfs_native/mod.rs index f606ab6fe..625971426 100644 --- a/core/src/services/hdfs_native/mod.rs +++ b/core/src/services/hdfs_native/mod.rs @@ -16,7 +16,7 @@ // under the License. /// Default scheme for hdfs_native service. -pub(super) const DEFAULT_SCHEME: &str = "hdfs_native"; +pub(super) const HDFS_NATIVE_SCHEME: &str = "hdfs_native"; mod delete; mod error; mod lister; diff --git a/core/src/services/http/backend.rs b/core/src/services/http/backend.rs index 99675cbf5..0f62af61a 100644 --- a/core/src/services/http/backend.rs +++ b/core/src/services/http/backend.rs @@ -23,7 +23,7 @@ use http::Response; use http::StatusCode; use log::debug; -use super::DEFAULT_SCHEME; +use super::HTTP_SCHEME; use super::core::HttpCore; use super::error::parse_error; use crate::raw::*; @@ -177,7 +177,7 @@ impl Builder for HttpBuilder { } let info = AccessorInfo::default(); - info.set_scheme(DEFAULT_SCHEME) + info.set_scheme(HTTP_SCHEME) .set_root(&root) .set_native_capability(Capability { stat: true, diff --git a/core/src/services/http/mod.rs b/core/src/services/http/mod.rs index 7b95d3fff..ace61580d 100644 --- a/core/src/services/http/mod.rs +++ b/core/src/services/http/mod.rs @@ -16,7 +16,7 @@ // under the License. /// Default scheme for http service. -pub(super) const DEFAULT_SCHEME: &str = "http"; +pub(super) const HTTP_SCHEME: &str = "http"; mod error; mod backend; diff --git a/core/src/services/huggingface/backend.rs b/core/src/services/huggingface/backend.rs index 17817b2b5..b81b763f7 100644 --- a/core/src/services/huggingface/backend.rs +++ b/core/src/services/huggingface/backend.rs @@ -24,7 +24,7 @@ use http::Response; use http::StatusCode; use log::debug; -use super::DEFAULT_SCHEME; +use super::HUGGINGFACE_SCHEME; use super::core::HuggingfaceCore; use super::core::HuggingfaceStatus; use super::error::parse_error; @@ -172,7 +172,7 @@ impl Builder for HuggingfaceBuilder { core: Arc::new(HuggingfaceCore { info: { let am = AccessorInfo::default(); - am.set_scheme(DEFAULT_SCHEME) + am.set_scheme(HUGGINGFACE_SCHEME) .set_native_capability(Capability { stat: true, diff --git a/core/src/services/huggingface/mod.rs b/core/src/services/huggingface/mod.rs index 58a2d40df..63bb4423b 100644 --- a/core/src/services/huggingface/mod.rs +++ b/core/src/services/huggingface/mod.rs @@ -16,7 +16,7 @@ // under the License. /// Default scheme for huggingface service. -pub(super) const DEFAULT_SCHEME: &str = "huggingface"; +pub(super) const HUGGINGFACE_SCHEME: &str = "huggingface"; mod core; mod error; mod lister; diff --git a/core/src/services/ipfs/backend.rs b/core/src/services/ipfs/backend.rs index 2ce750fe8..c82bda2f1 100644 --- a/core/src/services/ipfs/backend.rs +++ b/core/src/services/ipfs/backend.rs @@ -24,7 +24,7 @@ use http::StatusCode; use log::debug; use prost::Message; -use super::DEFAULT_SCHEME; +use super::IPFS_SCHEME; use super::core::IpfsCore; use super::error::parse_error; use super::ipld::PBNode; @@ -131,7 +131,7 @@ impl Builder for IpfsBuilder { debug!("backend use endpoint {}", &endpoint); let info = AccessorInfo::default(); - info.set_scheme(DEFAULT_SCHEME) + info.set_scheme(IPFS_SCHEME) .set_root(&root) .set_native_capability(Capability { stat: true, diff --git a/core/src/services/ipfs/mod.rs b/core/src/services/ipfs/mod.rs index 0812677a8..5cdce35b8 100644 --- a/core/src/services/ipfs/mod.rs +++ b/core/src/services/ipfs/mod.rs @@ -16,7 +16,7 @@ // under the License. /// Default scheme for ipfs service. -pub(super) const DEFAULT_SCHEME: &str = "ipfs"; +pub(super) const IPFS_SCHEME: &str = "ipfs"; mod error; mod ipld; diff --git a/core/src/services/ipmfs/builder.rs b/core/src/services/ipmfs/builder.rs index 1e6885703..02172c960 100644 --- a/core/src/services/ipmfs/builder.rs +++ b/core/src/services/ipmfs/builder.rs @@ -19,7 +19,7 @@ use std::sync::Arc; use log::debug; -use super::DEFAULT_SCHEME; +use super::IPMFS_SCHEME; use super::backend::IpmfsBackend; use super::core::IpmfsCore; use crate::raw::*; @@ -137,7 +137,7 @@ impl Builder for IpmfsBuilder { .unwrap_or_else(|| "http://localhost:5001".to_string()); let info = AccessorInfo::default(); - info.set_scheme(DEFAULT_SCHEME) + info.set_scheme(IPMFS_SCHEME) .set_root(&root) .set_native_capability(Capability { stat: true, diff --git a/core/src/services/ipmfs/mod.rs b/core/src/services/ipmfs/mod.rs index 97fd37694..0ef6ce78a 100644 --- a/core/src/services/ipmfs/mod.rs +++ b/core/src/services/ipmfs/mod.rs @@ -16,7 +16,7 @@ // under the License. /// Default scheme for ipmfs service. -pub(super) const DEFAULT_SCHEME: &str = "ipmfs"; +pub(super) const IPMFS_SCHEME: &str = "ipmfs"; mod backend; mod core; mod delete; diff --git a/core/src/services/koofr/backend.rs b/core/src/services/koofr/backend.rs index 3984bec6f..491e1e387 100644 --- a/core/src/services/koofr/backend.rs +++ b/core/src/services/koofr/backend.rs @@ -26,7 +26,7 @@ use log::debug; use tokio::sync::Mutex; use tokio::sync::OnceCell; -use super::DEFAULT_SCHEME; +use super::KOOFR_SCHEME; use super::core::File; use super::core::KoofrCore; use super::core::KoofrSigner; @@ -174,7 +174,7 @@ impl Builder for KoofrBuilder { core: Arc::new(KoofrCore { info: { let am = AccessorInfo::default(); - am.set_scheme(DEFAULT_SCHEME) + am.set_scheme(KOOFR_SCHEME) .set_root(&root) .set_native_capability(Capability { stat: true, diff --git a/core/src/services/koofr/mod.rs b/core/src/services/koofr/mod.rs index e12b4ca1a..228ffb0e6 100644 --- a/core/src/services/koofr/mod.rs +++ b/core/src/services/koofr/mod.rs @@ -16,7 +16,7 @@ // under the License. /// Default scheme for koofr service. -pub(super) const DEFAULT_SCHEME: &str = "koofr"; +pub(super) const KOOFR_SCHEME: &str = "koofr"; mod core; mod delete; mod error; diff --git a/core/src/services/lakefs/backend.rs b/core/src/services/lakefs/backend.rs index 068579963..41bca1e02 100644 --- a/core/src/services/lakefs/backend.rs +++ b/core/src/services/lakefs/backend.rs @@ -24,7 +24,7 @@ use http::Response; use http::StatusCode; use log::debug; -use super::DEFAULT_SCHEME; +use super::LAKEFS_SCHEME; use super::core::LakefsCore; use super::core::LakefsStatus; use super::delete::LakefsDeleter; @@ -173,7 +173,7 @@ impl Builder for LakefsBuilder { core: Arc::new(LakefsCore { info: { let am = AccessorInfo::default(); - am.set_scheme(DEFAULT_SCHEME) + am.set_scheme(LAKEFS_SCHEME) .set_native_capability(Capability { stat: true, diff --git a/core/src/services/lakefs/mod.rs b/core/src/services/lakefs/mod.rs index 57a699cea..d448a409d 100644 --- a/core/src/services/lakefs/mod.rs +++ b/core/src/services/lakefs/mod.rs @@ -16,7 +16,7 @@ // under the License. /// Default scheme for lakefs service. -pub(super) const DEFAULT_SCHEME: &str = "lakefs"; +pub(super) const LAKEFS_SCHEME: &str = "lakefs"; mod core; mod delete; mod error; diff --git a/core/src/services/mini_moka/backend.rs b/core/src/services/mini_moka/backend.rs index d1a45b44b..67f768b2a 100644 --- a/core/src/services/mini_moka/backend.rs +++ b/core/src/services/mini_moka/backend.rs @@ -22,7 +22,7 @@ use std::time::Duration; use log::debug; -use super::DEFAULT_SCHEME; +use super::MINI_MOKA_SCHEME; use super::core::*; use super::delete::MiniMokaDeleter; use super::lister::MiniMokaLister; @@ -155,7 +155,7 @@ impl Access for MiniMokaBackend { fn info(&self) -> Arc<AccessorInfo> { let info = AccessorInfo::default(); - info.set_scheme(DEFAULT_SCHEME) + info.set_scheme(MINI_MOKA_SCHEME) .set_root(&self.root) .set_native_capability(Capability { stat: true, diff --git a/core/src/services/mini_moka/mod.rs b/core/src/services/mini_moka/mod.rs index 437766d7c..40aa2cbba 100644 --- a/core/src/services/mini_moka/mod.rs +++ b/core/src/services/mini_moka/mod.rs @@ -16,7 +16,7 @@ // under the License. /// Default scheme for mini_moka service. -pub(super) const DEFAULT_SCHEME: &str = "mini_moka"; +pub(super) const MINI_MOKA_SCHEME: &str = "mini_moka"; mod backend; mod core; mod delete; diff --git a/core/src/services/moka/backend.rs b/core/src/services/moka/backend.rs index 807aeaacd..a1a3ef5e5 100644 --- a/core/src/services/moka/backend.rs +++ b/core/src/services/moka/backend.rs @@ -22,7 +22,7 @@ use std::time::Duration; use log::debug; -use super::DEFAULT_SCHEME; +use super::MOKA_SCHEME; use super::core::*; use super::delete::MokaDeleter; use super::lister::MokaLister; @@ -200,7 +200,7 @@ pub struct MokaAccessor { impl MokaAccessor { fn new(core: MokaCore) -> Self { let info = AccessorInfo::default(); - info.set_scheme(DEFAULT_SCHEME); + info.set_scheme(MOKA_SCHEME); info.set_name(core.cache.name().unwrap_or("moka")); info.set_root("/"); info.set_native_capability(Capability { diff --git a/core/src/services/moka/mod.rs b/core/src/services/moka/mod.rs index 9393cdb89..c4c39172a 100644 --- a/core/src/services/moka/mod.rs +++ b/core/src/services/moka/mod.rs @@ -16,7 +16,7 @@ // under the License. /// Default scheme for moka service. -pub(super) const DEFAULT_SCHEME: &str = "moka"; +pub(super) const MOKA_SCHEME: &str = "moka"; mod backend; mod core; mod delete; diff --git a/core/src/services/monoiofs/core.rs b/core/src/services/monoiofs/core.rs index c86be1840..eee84568c 100644 --- a/core/src/services/monoiofs/core.rs +++ b/core/src/services/monoiofs/core.rs @@ -28,7 +28,7 @@ use futures::channel::oneshot; use monoio::FusionDriver; use monoio::RuntimeBuilder; -use super::DEFAULT_SCHEME; +use super::MONOIOFS_SCHEME; use crate::raw::*; use crate::*; pub const BUFFER_SIZE: usize = 2 * 1024 * 1024; // 2 MiB @@ -69,7 +69,7 @@ impl MonoiofsCore { Self { info: { let am = AccessorInfo::default(); - am.set_scheme(DEFAULT_SCHEME) + am.set_scheme(MONOIOFS_SCHEME) .set_root(&root.to_string_lossy()) .set_native_capability(Capability { stat: true, diff --git a/core/src/services/monoiofs/mod.rs b/core/src/services/monoiofs/mod.rs index 87b3b778e..a2849437c 100644 --- a/core/src/services/monoiofs/mod.rs +++ b/core/src/services/monoiofs/mod.rs @@ -16,7 +16,7 @@ // under the License. /// Default scheme for monoiofs service. -pub(super) const DEFAULT_SCHEME: &str = "monoiofs"; +pub(super) const MONOIOFS_SCHEME: &str = "monoiofs"; mod core; mod delete; mod reader; diff --git a/core/src/services/onedrive/builder.rs b/core/src/services/onedrive/builder.rs index 7dd856548..28df66c2c 100644 --- a/core/src/services/onedrive/builder.rs +++ b/core/src/services/onedrive/builder.rs @@ -23,7 +23,7 @@ use std::fmt::Formatter; use std::sync::Arc; use tokio::sync::Mutex; -use super::DEFAULT_SCHEME; +use super::ONEDRIVE_SCHEME; use super::backend::OnedriveBackend; use crate::Scheme; use crate::raw::Access; @@ -142,7 +142,7 @@ impl Builder for OnedriveBuilder { debug!("backend use root {root}"); let info = AccessorInfo::default(); - info.set_scheme(DEFAULT_SCHEME) + info.set_scheme(ONEDRIVE_SCHEME) .set_root(&root) .set_native_capability(Capability { read: true, diff --git a/core/src/services/onedrive/mod.rs b/core/src/services/onedrive/mod.rs index 8183f3dd1..fa140b345 100644 --- a/core/src/services/onedrive/mod.rs +++ b/core/src/services/onedrive/mod.rs @@ -16,7 +16,7 @@ // under the License. /// Default scheme for onedrive service. -pub(super) const DEFAULT_SCHEME: &str = "onedrive"; +pub(super) const ONEDRIVE_SCHEME: &str = "onedrive"; mod backend; mod core; mod delete; diff --git a/core/src/services/pcloud/backend.rs b/core/src/services/pcloud/backend.rs index 7e9e5cf06..38bc2ef81 100644 --- a/core/src/services/pcloud/backend.rs +++ b/core/src/services/pcloud/backend.rs @@ -24,7 +24,7 @@ use http::Response; use http::StatusCode; use log::debug; -use super::DEFAULT_SCHEME; +use super::PCLOUD_SCHEME; use super::core::*; use super::delete::PcloudDeleter; use super::error::PcloudError; @@ -168,7 +168,7 @@ impl Builder for PcloudBuilder { core: Arc::new(PcloudCore { info: { let am = AccessorInfo::default(); - am.set_scheme(DEFAULT_SCHEME) + am.set_scheme(PCLOUD_SCHEME) .set_root(&root) .set_native_capability(Capability { stat: true, diff --git a/core/src/services/pcloud/mod.rs b/core/src/services/pcloud/mod.rs index fdcf2bb2f..715a7f393 100644 --- a/core/src/services/pcloud/mod.rs +++ b/core/src/services/pcloud/mod.rs @@ -16,7 +16,7 @@ // under the License. /// Default scheme for pcloud service. -pub(super) const DEFAULT_SCHEME: &str = "pcloud"; +pub(super) const PCLOUD_SCHEME: &str = "pcloud"; mod core; mod delete; mod error; diff --git a/core/src/services/redis/backend.rs b/core/src/services/redis/backend.rs index 31740c1f3..3731aa59a 100644 --- a/core/src/services/redis/backend.rs +++ b/core/src/services/redis/backend.rs @@ -29,7 +29,7 @@ use redis::RedisConnectionInfo; use redis::cluster::ClusterClientBuilder; use tokio::sync::OnceCell; -use super::DEFAULT_SCHEME; +use super::REDIS_SCHEME; use super::core::*; use super::delete::RedisDeleter; use super::writer::RedisWriter; @@ -277,7 +277,7 @@ pub struct RedisAccessor { impl RedisAccessor { fn new(core: RedisCore) -> Self { let info = AccessorInfo::default(); - info.set_scheme(DEFAULT_SCHEME); + info.set_scheme(REDIS_SCHEME); info.set_name(&core.addr); info.set_root("/"); info.set_native_capability(Capability { diff --git a/core/src/services/redis/mod.rs b/core/src/services/redis/mod.rs index 91de87438..4ddb2c545 100644 --- a/core/src/services/redis/mod.rs +++ b/core/src/services/redis/mod.rs @@ -16,7 +16,7 @@ // under the License. /// Default scheme for redis service. -pub(super) const DEFAULT_SCHEME: &str = "redis"; +pub(super) const REDIS_SCHEME: &str = "redis"; mod backend; mod core; mod delete; diff --git a/core/src/services/seafile/backend.rs b/core/src/services/seafile/backend.rs index 778b3969c..3d88ac808 100644 --- a/core/src/services/seafile/backend.rs +++ b/core/src/services/seafile/backend.rs @@ -24,7 +24,7 @@ use http::StatusCode; use log::debug; use tokio::sync::RwLock; -use super::DEFAULT_SCHEME; +use super::SEAFILE_SCHEME; use super::core::SeafileCore; use super::core::SeafileSigner; use super::core::parse_dir_detail; @@ -188,7 +188,7 @@ impl Builder for SeafileBuilder { core: Arc::new(SeafileCore { info: { let am = AccessorInfo::default(); - am.set_scheme(DEFAULT_SCHEME) + am.set_scheme(SEAFILE_SCHEME) .set_root(&root) .set_native_capability(Capability { stat: true, diff --git a/core/src/services/seafile/mod.rs b/core/src/services/seafile/mod.rs index ac371b4e2..12abb6686 100644 --- a/core/src/services/seafile/mod.rs +++ b/core/src/services/seafile/mod.rs @@ -16,7 +16,7 @@ // under the License. /// Default scheme for seafile service. -pub(super) const DEFAULT_SCHEME: &str = "seafile"; +pub(super) const SEAFILE_SCHEME: &str = "seafile"; mod core; mod delete; mod error; diff --git a/core/src/services/sftp/backend.rs b/core/src/services/sftp/backend.rs index c3f592c9a..8b7f49541 100644 --- a/core/src/services/sftp/backend.rs +++ b/core/src/services/sftp/backend.rs @@ -27,7 +27,7 @@ use openssh::KnownHosts; use tokio::io::AsyncSeekExt; use tokio::sync::OnceCell; -use super::DEFAULT_SCHEME; +use super::SFTP_SCHEME; use super::core::SftpCore; use super::delete::SftpDeleter; use super::error::is_not_found; @@ -198,7 +198,7 @@ impl Builder for SftpBuilder { let info = AccessorInfo::default(); info.set_root(root.as_str()) - .set_scheme(DEFAULT_SCHEME) + .set_scheme(SFTP_SCHEME) .set_native_capability(Capability { stat: true, diff --git a/core/src/services/sftp/mod.rs b/core/src/services/sftp/mod.rs index e513792d1..fa31d4a6f 100644 --- a/core/src/services/sftp/mod.rs +++ b/core/src/services/sftp/mod.rs @@ -16,7 +16,7 @@ // under the License. /// Default scheme for sftp service. -pub(super) const DEFAULT_SCHEME: &str = "sftp"; +pub(super) const SFTP_SCHEME: &str = "sftp"; mod delete; mod error; mod lister; diff --git a/core/src/services/swift/backend.rs b/core/src/services/swift/backend.rs index 9fc1c56a7..8a6b64918 100644 --- a/core/src/services/swift/backend.rs +++ b/core/src/services/swift/backend.rs @@ -23,7 +23,7 @@ use http::Response; use http::StatusCode; use log::debug; -use super::DEFAULT_SCHEME; +use super::SWIFT_SCHEME; use super::core::*; use super::delete::SwfitDeleter; use super::error::parse_error; @@ -155,7 +155,7 @@ impl Builder for SwiftBuilder { core: Arc::new(SwiftCore { info: { let am = AccessorInfo::default(); - am.set_scheme(DEFAULT_SCHEME) + am.set_scheme(SWIFT_SCHEME) .set_root(&root) .set_native_capability(Capability { stat: true, diff --git a/core/src/services/swift/mod.rs b/core/src/services/swift/mod.rs index fd8277ab9..8f3b8c8b9 100644 --- a/core/src/services/swift/mod.rs +++ b/core/src/services/swift/mod.rs @@ -16,7 +16,7 @@ // under the License. /// Default scheme for swift service. -pub(super) const DEFAULT_SCHEME: &str = "swift"; +pub(super) const SWIFT_SCHEME: &str = "swift"; mod core; mod delete; mod error; diff --git a/core/src/services/vercel_artifacts/builder.rs b/core/src/services/vercel_artifacts/builder.rs index baf11fecf..ce0ab2af9 100644 --- a/core/src/services/vercel_artifacts/builder.rs +++ b/core/src/services/vercel_artifacts/builder.rs @@ -19,7 +19,7 @@ use std::fmt::Debug; use std::fmt::Formatter; use std::sync::Arc; -use super::DEFAULT_SCHEME; +use super::VERCEL_ARTIFACTS_SCHEME; use super::backend::VercelArtifactsBackend; use super::core::VercelArtifactsCore; use crate::raw::Access; @@ -85,7 +85,7 @@ impl Builder for VercelArtifactsBuilder { fn build(self) -> Result<impl Access> { let info = AccessorInfo::default(); - info.set_scheme(DEFAULT_SCHEME) + info.set_scheme(VERCEL_ARTIFACTS_SCHEME) .set_native_capability(Capability { stat: true, diff --git a/core/src/services/vercel_artifacts/mod.rs b/core/src/services/vercel_artifacts/mod.rs index 60b9774c7..7fb310891 100644 --- a/core/src/services/vercel_artifacts/mod.rs +++ b/core/src/services/vercel_artifacts/mod.rs @@ -16,7 +16,7 @@ // under the License. /// Default scheme for vercel_artifacts service. -pub(super) const DEFAULT_SCHEME: &str = "vercel_artifacts"; +pub(super) const VERCEL_ARTIFACTS_SCHEME: &str = "vercel_artifacts"; mod backend; mod core; mod error; diff --git a/core/src/services/vercel_blob/backend.rs b/core/src/services/vercel_blob/backend.rs index 4eefe7134..e6e337dae 100644 --- a/core/src/services/vercel_blob/backend.rs +++ b/core/src/services/vercel_blob/backend.rs @@ -24,7 +24,7 @@ use http::Response; use http::StatusCode; use log::debug; -use super::DEFAULT_SCHEME; +use super::VERCEL_BLOB_SCHEME; use super::core::Blob; use super::core::VercelBlobCore; use super::core::parse_blob; @@ -127,7 +127,7 @@ impl Builder for VercelBlobBuilder { core: Arc::new(VercelBlobCore { info: { let am = AccessorInfo::default(); - am.set_scheme(DEFAULT_SCHEME) + am.set_scheme(VERCEL_BLOB_SCHEME) .set_root(&root) .set_native_capability(Capability { stat: true, diff --git a/core/src/services/vercel_blob/mod.rs b/core/src/services/vercel_blob/mod.rs index 5658cf65c..f1912de4f 100644 --- a/core/src/services/vercel_blob/mod.rs +++ b/core/src/services/vercel_blob/mod.rs @@ -16,7 +16,7 @@ // under the License. /// Default scheme for vercel_blob service. -pub(super) const DEFAULT_SCHEME: &str = "vercel_blob"; +pub(super) const VERCEL_BLOB_SCHEME: &str = "vercel_blob"; mod core; mod delete; mod error; diff --git a/core/src/services/webdav/backend.rs b/core/src/services/webdav/backend.rs index c3dc48b64..ca64329c7 100644 --- a/core/src/services/webdav/backend.rs +++ b/core/src/services/webdav/backend.rs @@ -24,7 +24,7 @@ use http::Response; use http::StatusCode; use log::debug; -use super::DEFAULT_SCHEME; +use super::WEBDAV_SCHEME; use super::core::*; use super::delete::WebdavDeleter; use super::error::parse_error; @@ -192,7 +192,7 @@ impl Builder for WebdavBuilder { let core = Arc::new(WebdavCore { info: { let am = AccessorInfo::default(); - am.set_scheme(DEFAULT_SCHEME) + am.set_scheme(WEBDAV_SCHEME) .set_root(&root) .set_native_capability(Capability { stat: true, diff --git a/core/src/services/webdav/mod.rs b/core/src/services/webdav/mod.rs index 0fd91e5bf..bd2c4406a 100644 --- a/core/src/services/webdav/mod.rs +++ b/core/src/services/webdav/mod.rs @@ -16,7 +16,7 @@ // under the License. /// Default scheme for webdav service. -pub(super) const DEFAULT_SCHEME: &str = "webdav"; +pub(super) const WEBDAV_SCHEME: &str = "webdav"; mod core; mod delete; mod error; diff --git a/core/src/services/webhdfs/backend.rs b/core/src/services/webhdfs/backend.rs index 30e468824..369a458c3 100644 --- a/core/src/services/webhdfs/backend.rs +++ b/core/src/services/webhdfs/backend.rs @@ -25,7 +25,7 @@ use http::StatusCode; use log::debug; use tokio::sync::OnceCell; -use super::DEFAULT_SCHEME; +use super::WEBHDFS_SCHEME; use super::core::WebhdfsCore; use super::delete::WebhdfsDeleter; use super::error::parse_error; @@ -180,7 +180,7 @@ impl Builder for WebhdfsBuilder { let auth = self.config.delegation.map(|dt| format!("delegation={dt}")); let info = AccessorInfo::default(); - info.set_scheme(DEFAULT_SCHEME) + info.set_scheme(WEBHDFS_SCHEME) .set_root(&root) .set_native_capability(Capability { stat: true, diff --git a/core/src/services/webhdfs/mod.rs b/core/src/services/webhdfs/mod.rs index 2e83c6fb9..672806433 100644 --- a/core/src/services/webhdfs/mod.rs +++ b/core/src/services/webhdfs/mod.rs @@ -16,7 +16,7 @@ // under the License. /// Default scheme for webhdfs service. -pub(super) const DEFAULT_SCHEME: &str = "webhdfs"; +pub(super) const WEBHDFS_SCHEME: &str = "webhdfs"; mod delete; mod error; mod lister; diff --git a/core/src/services/yandex_disk/backend.rs b/core/src/services/yandex_disk/backend.rs index a4edb395a..133db49ae 100644 --- a/core/src/services/yandex_disk/backend.rs +++ b/core/src/services/yandex_disk/backend.rs @@ -24,7 +24,7 @@ use http::Response; use http::StatusCode; use log::debug; -use super::DEFAULT_SCHEME; +use super::YANDEX_DISK_SCHEME; use super::core::*; use super::delete::YandexDiskDeleter; use super::error::parse_error; @@ -126,7 +126,7 @@ impl Builder for YandexDiskBuilder { core: Arc::new(YandexDiskCore { info: { let am = AccessorInfo::default(); - am.set_scheme(DEFAULT_SCHEME) + am.set_scheme(YANDEX_DISK_SCHEME) .set_root(&root) .set_native_capability(Capability { stat: true, diff --git a/core/src/services/yandex_disk/mod.rs b/core/src/services/yandex_disk/mod.rs index ed15e07ee..f3741a777 100644 --- a/core/src/services/yandex_disk/mod.rs +++ b/core/src/services/yandex_disk/mod.rs @@ -16,7 +16,7 @@ // under the License. /// Default scheme for yandex_disk service. -pub(super) const DEFAULT_SCHEME: &str = "yandex_disk"; +pub(super) const YANDEX_DISK_SCHEME: &str = "yandex_disk"; mod core; mod delete; mod error;
