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 call (high concurrency); atomic units drive a single registered raw transaction span instead of a caller-held per-tx connection.
• 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 atomic_unit<'life0, 'async_trait>( &'life0 self, op: AtomicUnitOp, ) -> Pin<Box<dyn Future<Output = StorageResult<Box<dyn Any + Send>>> + Send + 'async_trait>>

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

Implements the trait’s atomic-unit suspend-free invariant (SqlAccess::atomic_unit’s doc comment): on the flag-on branch below, op is driven through block_on_sync on an InlineWriter — a single-poll driver that returns Err the instant op’s future is Pending instead of ever actually suspending. op must therefore issue only synchronous DML; see InlineWriter’s and block_on_sync’s doc comments for the full mechanics and why this restriction is load-bearing (a suspended poll inside the writer task’s spawn_blocking would otherwise block that task on external async work while holding the single write connection).

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.