You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@opendal.apache.org by ko...@apache.org on 2025/11/05 09:21:22 UTC
(opendal) 02/02: chore: rename ServiceAccessor => ServiceBackend
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 <ko...@gmail.com>
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());