Struct TxnBridge 

pub struct TxnBridge<S: KVStore> { /* private fields */ }

TxnBridge provides SQL-friendly transaction handles on top of a KVStore.

Implementations

impl<S: KVStore> TxnBridge<S>

pub fn new(store: Arc<S>) -> Self

Create a new bridge for the given store.

pub fn runtime_stats(&self) -> Option<RuntimeStats>

Returns the underlying store’s runtime statistics.

pub fn set_memory_limit_bytes(&self, limit: Option<usize>) -> CoreResult<()>

Applies a memory-limit setting to the underlying store.

pub fn set_cache_capacity_bytes(&self, capacity: usize) -> CoreResult<()>

Applies a cache-capacity setting to the underlying store.

pub fn clear_cache(&self) -> CoreResult<usize>

Clears the underlying cache.

pub fn begin_read(&self) -> Result<SqlTransaction<'_, S>>

Begin a read-only transaction.

pub fn begin_write(&self) -> Result<SqlTransaction<'_, S>>

Begin a read-write transaction.

pub fn wrap_external<'a, 'b, 'c>( txn: &'a mut S::Transaction<'b>, mode: TxnMode, overlay: &'c mut CatalogOverlay, ) -> BorrowedSqlTransaction<'a, 'b, 'c, S>

pub fn with_read_txn<R, F>(&self, f: F) -> Result<R>

where F: FnOnce(&mut SqlTransaction<'_, S>) -> Result<R>,

Execute a read-only transaction with automatic commit.

The closure receives a SqlTransaction that provides access to table and index storage. The transaction is automatically committed on success or rolled back on error.

pub fn with_write_txn<R, F>(&self, f: F) -> Result<R>

where F: FnOnce(&mut SqlTransaction<'_, S>) -> Result<R>,

Execute a read-write transaction with automatic commit.

The closure receives a SqlTransaction that provides access to table and index storage. The transaction is automatically committed on success or rolled back on error.

pub fn with_write_txn_explicit<R, F>(&self, f: F) -> Result<R>

where F: FnOnce(&mut SqlTransaction<'_, S>) -> Result<(R, bool)>,

Execute a read-write transaction with explicit commit control.

Returns (result, should_commit) from the closure. If should_commit is true, the transaction is committed; otherwise it is rolled back.