diff --git a/src/common/meta/src/kv_backend/chroot.rs b/src/common/meta/src/kv_backend/chroot.rs index 6f097cd83e..0cadc7b346 100644 --- a/src/common/meta/src/kv_backend/chroot.rs +++ b/src/common/meta/src/kv_backend/chroot.rs @@ -45,6 +45,10 @@ impl TxnService for ChrootKvBackend { let txn_res = self.inner.txn(txn).await?; Ok(self.chroot_txn_response(txn_res)) } + + fn max_txn_ops(&self) -> usize { + self.inner.max_txn_ops() + } } #[async_trait::async_trait] diff --git a/src/common/meta/src/kv_backend/memory.rs b/src/common/meta/src/kv_backend/memory.rs index 90a79d4456..bb8cf2d95d 100644 --- a/src/common/meta/src/kv_backend/memory.rs +++ b/src/common/meta/src/kv_backend/memory.rs @@ -323,6 +323,10 @@ impl TxnService for MemoryKvBackend { responses, }) } + + fn max_txn_ops(&self) -> usize { + usize::MAX + } } impl ResettableKvBackend for MemoryKvBackend { diff --git a/src/common/meta/src/kv_backend/txn.rs b/src/common/meta/src/kv_backend/txn.rs index f5db5a5cdb..c170b93fbe 100644 --- a/src/common/meta/src/kv_backend/txn.rs +++ b/src/common/meta/src/kv_backend/txn.rs @@ -30,7 +30,7 @@ pub trait TxnService: Sync + Send { /// Maximum number of operations permitted in a transaction. fn max_txn_ops(&self) -> usize { - usize::MAX + unimplemented!("txn is not implemented") } } diff --git a/src/log-store/src/raft_engine/backend.rs b/src/log-store/src/raft_engine/backend.rs index ab2f9896f9..86d6ae39d7 100644 --- a/src/log-store/src/raft_engine/backend.rs +++ b/src/log-store/src/raft_engine/backend.rs @@ -152,6 +152,10 @@ impl TxnService for RaftEngineBackend { responses, }) } + + fn max_txn_ops(&self) -> usize { + usize::MAX + } } #[async_trait::async_trait] diff --git a/src/meta-srv/src/service/store/cached_kv.rs b/src/meta-srv/src/service/store/cached_kv.rs index af9e0a5cec..df898164d1 100644 --- a/src/meta-srv/src/service/store/cached_kv.rs +++ b/src/meta-srv/src/service/store/cached_kv.rs @@ -380,6 +380,10 @@ impl TxnService for LeaderCachedKvBackend { Ok(res) } + + fn max_txn_ops(&self) -> usize { + self.store.max_txn_ops() + } } impl ResettableKvBackend for LeaderCachedKvBackend {