This is an automated email from the ASF dual-hosted git repository.
xuanwo pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/opendal.git
The following commit(s) were added to refs/heads/main by this push:
new 917b83028 fix(services/cloudflare_kv): Use DEFAULT_SCHEME constant for
Cloudflare KV scheme (#6568)
917b83028 is described below
commit 917b83028dd2ba5659c28f6642e205eb2c49fa1b
Author: Kingsword <[email protected]>
AuthorDate: Tue Sep 9 14:38:53 2025 +0800
fix(services/cloudflare_kv): Use DEFAULT_SCHEME constant for Cloudflare KV
scheme (#6568)
---
core/src/raw/adapters/kv/api.rs | 6 +-----
core/src/raw/adapters/kv/mod.rs | 6 +-----
core/src/services/cloudflare_kv/backend.rs | 3 ++-
core/src/services/cloudflare_kv/mod.rs | 2 ++
4 files changed, 6 insertions(+), 11 deletions(-)
diff --git a/core/src/raw/adapters/kv/api.rs b/core/src/raw/adapters/kv/api.rs
index 24eb93444..161ed8e18 100644
--- a/core/src/raw/adapters/kv/api.rs
+++ b/core/src/raw/adapters/kv/api.rs
@@ -44,11 +44,7 @@ impl Scan for () {
/// A Scan implementation for all trivial non-async iterators
pub struct ScanStdIter<I>(I);
-#[cfg(any(
- feature = "services-cloudflare-kv",
- feature = "services-rocksdb",
- feature = "services-sled"
-))]
+#[cfg(any(feature = "services-rocksdb", feature = "services-sled"))]
impl<I> ScanStdIter<I>
where
I: Iterator<Item = Result<String>> + Unpin + Send + Sync,
diff --git a/core/src/raw/adapters/kv/mod.rs b/core/src/raw/adapters/kv/mod.rs
index 6a79f01ae..d1f55b179 100644
--- a/core/src/raw/adapters/kv/mod.rs
+++ b/core/src/raw/adapters/kv/mod.rs
@@ -23,11 +23,7 @@ mod api;
pub use api::Adapter;
pub use api::Info;
pub use api::Scan;
-#[cfg(any(
- feature = "services-cloudflare-kv",
- feature = "services-rocksdb",
- feature = "services-sled"
-))]
+#[cfg(any(feature = "services-rocksdb", feature = "services-sled"))]
pub(crate) use api::ScanStdIter;
pub use api::Scanner;
diff --git a/core/src/services/cloudflare_kv/backend.rs
b/core/src/services/cloudflare_kv/backend.rs
index 7752f1e06..3bb43573c 100644
--- a/core/src/services/cloudflare_kv/backend.rs
+++ b/core/src/services/cloudflare_kv/backend.rs
@@ -23,6 +23,7 @@ use std::time::Duration;
use bytes::Buf;
use http::StatusCode;
+use super::DEFAULT_SCHEME;
use crate::raw::*;
use crate::services::cloudflare_kv::core::CloudflareKvCore;
use crate::services::cloudflare_kv::delete::CloudflareKvDeleter;
@@ -160,7 +161,7 @@ impl Builder for CloudflareKvBuilder {
expiration_ttl: self.config.default_ttl,
info: {
let am = AccessorInfo::default();
- am.set_scheme(Scheme::CloudflareKv)
+ am.set_scheme(DEFAULT_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 3b1172ba3..0de5f36a1 100644
--- a/core/src/services/cloudflare_kv/mod.rs
+++ b/core/src/services/cloudflare_kv/mod.rs
@@ -15,6 +15,8 @@
// specific language governing permissions and limitations
// under the License.
+#[cfg(feature = "services-cloudflare-kv")]
+pub(super) const DEFAULT_SCHEME: &str = "cloudflare_kv";
#[cfg(feature = "services-cloudflare-kv")]
mod error;