Struct SqlBridge 

pub struct SqlBridge { /* private fields */ }

Bridges ConnectionPool to khive_storage::SqlAccess.

Dispatches based on whether the pool is file-backed or in-memory:

• File-backed: standalone connections per reader/writer/tx (high concurrency).
• In-memory: pool-backed connections per query (single shared connection).

Implementations

impl SqlBridge

pub fn new(pool: Arc<ConnectionPool>, is_file_backed: bool) -> Self

Create a new bridge wrapping the given pool.

Trait Implementations

impl SqlAccess for SqlBridge

fn reader<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = StorageResult<Box<dyn SqlReader>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Acquire a read-only connection from the pool.

fn writer<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = StorageResult<Box<dyn SqlWriter>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Acquire a read-write connection from the pool.

fn begin_tx<'life0, 'async_trait>( &'life0 self, options: SqlTxOptions, ) -> Pin<Box<dyn Future<Output = StorageResult<Box<dyn SqlTransaction>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Begin a transaction with the given isolation options.