This is an automated email from the ASF dual-hosted git repository. koushiro pushed a commit to branch some-renaming in repository https://gitbox.apache.org/repos/asf/opendal.git
commit 728080ea3f39f6514d28367c66d74441482364bd Author: koushiro <[email protected]> AuthorDate: Wed Nov 5 15:52:41 2025 +0800 chore: rename ServiceAccessor => ServiceBackend --- core/src/services/cacache/backend.rs | 6 +++--- core/src/services/cloudflare_kv/backend.rs | 10 +++++----- core/src/services/dashmap/backend.rs | 8 ++++---- core/src/services/etcd/backend.rs | 8 ++++---- core/src/services/memory/backend.rs | 8 ++++---- core/src/services/moka/backend.rs | 8 ++++---- core/src/services/redis/backend.rs | 21 +++++++++++---------- core/src/services/sqlite/backend.rs | 24 ++++++++++++------------ 8 files changed, 47 insertions(+), 46 deletions(-) diff --git a/core/src/services/cacache/backend.rs b/core/src/services/cacache/backend.rs index 5094f723a..fd8fd1db3 100644 --- a/core/src/services/cacache/backend.rs +++ b/core/src/services/cacache/backend.rs @@ -68,7 +68,7 @@ impl Builder for CacacheBuilder { ..Default::default() }); - Ok(CacacheAccessor { + Ok(CacacheBackend { core: Arc::new(core), info: Arc::new(info), }) @@ -77,12 +77,12 @@ impl Builder for CacacheBuilder { /// Backend for cacache services. #[derive(Debug, Clone)] -pub struct CacacheAccessor { +pub struct CacacheBackend { core: Arc<CacacheCore>, info: Arc<AccessorInfo>, } -impl Access for CacacheAccessor { +impl Access for CacacheBackend { type Reader = Buffer; type Writer = CacacheWriter; type Lister = (); diff --git a/core/src/services/cloudflare_kv/backend.rs b/core/src/services/cloudflare_kv/backend.rs index e7a1faf90..a02515654 100644 --- a/core/src/services/cloudflare_kv/backend.rs +++ b/core/src/services/cloudflare_kv/backend.rs @@ -142,7 +142,7 @@ impl Builder for CloudflareKvBuilder { .as_str(), ); - Ok(CloudflareKvAccessor { + Ok(CloudflareKvBackend { core: Arc::new(CloudflareKvCore { api_token, account_id, @@ -197,17 +197,17 @@ impl Builder for CloudflareKvBuilder { } #[derive(Debug, Clone)] -pub struct CloudflareKvAccessor { - core: std::sync::Arc<CloudflareKvCore>, +pub struct CloudflareKvBackend { + core: Arc<CloudflareKvCore>, } -impl Access for CloudflareKvAccessor { +impl Access for CloudflareKvBackend { type Reader = Buffer; type Writer = oio::OneShotWriter<CloudflareWriter>; type Lister = oio::PageLister<CloudflareKvLister>; type Deleter = oio::BatchDeleter<CloudflareKvDeleter>; - fn info(&self) -> std::sync::Arc<AccessorInfo> { + fn info(&self) -> Arc<AccessorInfo> { self.core.info.clone() } diff --git a/core/src/services/dashmap/backend.rs b/core/src/services/dashmap/backend.rs index b16d7a44d..638631f0e 100644 --- a/core/src/services/dashmap/backend.rs +++ b/core/src/services/dashmap/backend.rs @@ -69,18 +69,18 @@ impl Builder for DashmapBuilder { cache: DashMap::new(), }; - Ok(DashmapAccessor::new(core, root)) + Ok(DashmapBackend::new(core, root)) } } #[derive(Debug, Clone)] -pub struct DashmapAccessor { +pub struct DashmapBackend { core: Arc<DashmapCore>, root: String, info: Arc<AccessorInfo>, } -impl DashmapAccessor { +impl DashmapBackend { fn new(core: DashmapCore, root: String) -> Self { let info = AccessorInfo::default(); info.set_scheme(DASHMAP_SCHEME); @@ -111,7 +111,7 @@ impl DashmapAccessor { } } -impl Access for DashmapAccessor { +impl Access for DashmapBackend { type Reader = Buffer; type Writer = DashmapWriter; type Lister = oio::HierarchyLister<DashmapLister>; diff --git a/core/src/services/etcd/backend.rs b/core/src/services/etcd/backend.rs index 4a106226e..77002ca33 100644 --- a/core/src/services/etcd/backend.rs +++ b/core/src/services/etcd/backend.rs @@ -166,7 +166,7 @@ impl Builder for EtcdBuilder { options, }; - Ok(EtcdAccessor::new(core, &root)) + Ok(EtcdBackend::new(core, &root)) } } @@ -178,12 +178,12 @@ impl EtcdBuilder { } #[derive(Debug, Clone)] -pub struct EtcdAccessor { +pub struct EtcdBackend { core: Arc<EtcdCore>, info: Arc<AccessorInfo>, } -impl EtcdAccessor { +impl EtcdBackend { fn new(core: EtcdCore, root: &str) -> Self { let info = AccessorInfo::default(); info.set_scheme(ETCD_SCHEME); @@ -211,7 +211,7 @@ impl EtcdAccessor { } } -impl Access for EtcdAccessor { +impl Access for EtcdBackend { type Reader = Buffer; type Writer = EtcdWriter; type Lister = oio::HierarchyLister<EtcdLister>; diff --git a/core/src/services/memory/backend.rs b/core/src/services/memory/backend.rs index cfffd1208..4788d14b6 100644 --- a/core/src/services/memory/backend.rs +++ b/core/src/services/memory/backend.rs @@ -50,19 +50,19 @@ impl Builder for MemoryBuilder { let root = normalize_root(self.config.root.as_deref().unwrap_or("/")); let core = MemoryCore::new(); - Ok(MemoryAccessor::new(core).with_normalized_root(root)) + Ok(MemoryBackend::new(core).with_normalized_root(root)) } } /// MemoryAccessor implements Access trait directly #[derive(Debug, Clone)] -pub struct MemoryAccessor { +pub struct MemoryBackend { core: Arc<MemoryCore>, root: String, info: Arc<AccessorInfo>, } -impl MemoryAccessor { +impl MemoryBackend { fn new(core: MemoryCore) -> Self { let info = AccessorInfo::default(); info.set_scheme(MEMORY_SCHEME); @@ -98,7 +98,7 @@ impl MemoryAccessor { } } -impl Access for MemoryAccessor { +impl Access for MemoryBackend { type Reader = Buffer; type Writer = MemoryWriter; type Lister = oio::HierarchyLister<MemoryLister>; diff --git a/core/src/services/moka/backend.rs b/core/src/services/moka/backend.rs index dd83b029e..c7a8be49a 100644 --- a/core/src/services/moka/backend.rs +++ b/core/src/services/moka/backend.rs @@ -178,19 +178,19 @@ impl Builder for MokaBuilder { cache: builder.build(), }; - Ok(MokaAccessor::new(core).with_normalized_root(root)) + Ok(MokaBackend::new(core).with_normalized_root(root)) } } /// MokaAccessor implements Access trait directly #[derive(Debug, Clone)] -pub struct MokaAccessor { +pub struct MokaBackend { core: Arc<MokaCore>, root: String, info: Arc<AccessorInfo>, } -impl MokaAccessor { +impl MokaBackend { fn new(core: MokaCore) -> Self { let info = AccessorInfo::default(); info.set_scheme(MOKA_SCHEME); @@ -225,7 +225,7 @@ impl MokaAccessor { } } -impl Access for MokaAccessor { +impl Access for MokaBackend { type Reader = Buffer; type Writer = MokaWriter; type Lister = oio::HierarchyLister<MokaLister>; diff --git a/core/src/services/redis/backend.rs b/core/src/services/redis/backend.rs index 102e1a4ef..73b60150c 100644 --- a/core/src/services/redis/backend.rs +++ b/core/src/services/redis/backend.rs @@ -16,6 +16,7 @@ // under the License. use std::path::PathBuf; +use std::sync::Arc; use std::time::Duration; use http::Uri; @@ -153,7 +154,7 @@ impl Builder for RedisBuilder { let conn = OnceCell::new(); - Ok(RedisAccessor::new(RedisCore { + Ok(RedisBackend::new(RedisCore { addr: endpoints, client: None, cluster_client: Some(client), @@ -178,7 +179,7 @@ impl Builder for RedisBuilder { })?; let conn = OnceCell::new(); - Ok(RedisAccessor::new(RedisCore { + Ok(RedisBackend::new(RedisCore { addr: endpoint, client: Some(client), cluster_client: None, @@ -250,13 +251,13 @@ impl RedisBuilder { /// RedisAccessor implements Access trait directly #[derive(Debug, Clone)] -pub struct RedisAccessor { - core: std::sync::Arc<RedisCore>, +pub struct RedisBackend { + core: Arc<RedisCore>, root: String, - info: std::sync::Arc<AccessorInfo>, + info: Arc<AccessorInfo>, } -impl RedisAccessor { +impl RedisBackend { fn new(core: RedisCore) -> Self { let info = AccessorInfo::default(); info.set_scheme(REDIS_SCHEME); @@ -273,9 +274,9 @@ impl RedisAccessor { }); Self { - core: std::sync::Arc::new(core), + core: Arc::new(core), root: "/".to_string(), - info: std::sync::Arc::new(info), + info: Arc::new(info), } } @@ -286,13 +287,13 @@ impl RedisAccessor { } } -impl Access for RedisAccessor { +impl Access for RedisBackend { type Reader = Buffer; type Writer = RedisWriter; type Lister = (); type Deleter = oio::OneShotDeleter<RedisDeleter>; - fn info(&self) -> std::sync::Arc<AccessorInfo> { + fn info(&self) -> Arc<AccessorInfo> { self.info.clone() } diff --git a/core/src/services/sqlite/backend.rs b/core/src/services/sqlite/backend.rs index 34b13f370..c6330b840 100644 --- a/core/src/services/sqlite/backend.rs +++ b/core/src/services/sqlite/backend.rs @@ -15,8 +15,8 @@ // specific language governing permissions and limitations // under the License. -use std::fmt::Debug; use std::str::FromStr; +use std::sync::Arc; use sqlx::sqlite::SqliteConnectOptions; use tokio::sync::OnceCell; @@ -136,7 +136,7 @@ impl Builder for SqliteBuilder { let root = normalize_root(self.config.root.as_deref().unwrap_or("/")); - Ok(SqliteAccessor::new(SqliteCore { + Ok(SqliteBackend::new(SqliteCore { pool: OnceCell::new(), config, table, @@ -168,13 +168,13 @@ pub fn parse_sqlite_error(err: sqlx::Error) -> Error { /// SqliteAccessor implements Access trait directly #[derive(Debug, Clone)] -pub struct SqliteAccessor { - core: std::sync::Arc<SqliteCore>, +pub struct SqliteBackend { + core: Arc<SqliteCore>, root: String, - info: std::sync::Arc<AccessorInfo>, + info: Arc<AccessorInfo>, } -impl SqliteAccessor { +impl SqliteBackend { fn new(core: SqliteCore) -> Self { let info = AccessorInfo::default(); info.set_scheme(Scheme::Sqlite.into()); @@ -193,9 +193,9 @@ impl SqliteAccessor { }); Self { - core: std::sync::Arc::new(core), + core: Arc::new(core), root: "/".to_string(), - info: std::sync::Arc::new(info), + info: Arc::new(info), } } @@ -206,13 +206,13 @@ impl SqliteAccessor { } } -impl Access for SqliteAccessor { +impl Access for SqliteBackend { type Reader = Buffer; type Writer = SqliteWriter; type Lister = (); type Deleter = oio::OneShotDeleter<SqliteDeleter>; - fn info(&self) -> std::sync::Arc<AccessorInfo> { + fn info(&self) -> Arc<AccessorInfo> { self.info.clone() } @@ -331,7 +331,7 @@ mod test { value_field: "value".to_string(), }; - let accessor = SqliteAccessor::new(core); + let accessor = SqliteBackend::new(core); // Verify basic properties assert_eq!(accessor.root, "/"); @@ -355,7 +355,7 @@ mod test { value_field: "value".to_string(), }; - let accessor = SqliteAccessor::new(core).with_normalized_root("/test/".to_string()); + let accessor = SqliteBackend::new(core).with_normalized_root("/test/".to_string()); assert_eq!(accessor.root, "/test/"); assert_eq!(accessor.info.root(), "/test/".into());
