Struct HostStorage 

pub struct HostStorage { /* private fields */ }

内存数据库若未启用 shared cache，第二个连接会得到独立空库；文件 WAL 库与显式 cache=shared 的内存库才启用只读池。

Implementations

impl HostStorage

pub async fn open_sqlite_url(db_url: &str) -> Result<Self, PortError>

pub fn with_metric_sink(self, metrics: Arc<dyn AsyncMetricSink>) -> Self

pub async fn execute_raw(&self, sql: &'static str) -> Result<(), PortError>

Trait Implementations

impl Clone for HostStorage

fn clone(&self) -> HostStorage

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Storage for HostStorage

fn scoped_guarded_bump<'life0, 'async_trait>( &'life0 self, spec: ScopedGuardedBumpSpec, ) -> Pin<Box<dyn Future<Output = Result<(), PortError>> + Send + 'async_trait>>

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

在复合主键作用域内兑现单条守卫式计数更新。

fn scoped_get<'life0, 'async_trait>( &'life0 self, spec: ScopedGetSpec, ) -> Pin<Box<dyn Future<Output = Result<Option<HelixRow>, PortError>> + Send + 'async_trait>>

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

在复合主键作用域内读取唯一行。

fn batch_upsert<'life0, 'async_trait>( &'life0 self, spec: UpsertSpec, ) -> Pin<Box<dyn Future<Output = Result<(), PortError>> + Send + 'async_trait>>

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

batch upsert：整批一事务 INSERT，按 conflict_key 解决唯一冲突（B6 语义真源）。

fn batch_update<'life0, 'async_trait>( &'life0 self, spec: BatchUpdateSpec, ) -> Pin<Box<dyn Future<Output = Result<(), PortError>> + Send + 'async_trait>>

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

batch update：UPDATE table SET patch WHERE key_col IN (key_vals)

fn monotonic_upsert<'life0, 'async_trait>( &'life0 self, spec: MonotonicUpsertSpec, ) -> Pin<Box<dyn Future<Output = Result<(), PortError>> + Send + 'async_trait>>

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

通用单调 MAX-guard 写：仅在 new value > 当前值时才写入（CAS / 单调寄存器语义）。

fn guarded_bump<'life0, 'async_trait>( &'life0 self, spec: GuardedBumpSpec, ) -> Pin<Box<dyn Future<Output = Result<(), PortError>> + Send + 'async_trait>>

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

守卫式自增：UPDATE … SET bump_col = bump_col + delta[, set…] WHERE key=? AND ? > guard_col。

fn get<'life0, 'async_trait>( &'life0 self, spec: GetSpec, ) -> Pin<Box<dyn Future<Output = Result<Option<HelixRow>, PortError>> + Send + 'async_trait>>

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

get：单行查询

fn scan<'life0, 'async_trait>( &'life0 self, spec: ScanSpec, ) -> Pin<Box<dyn Future<Output = Result<Vec<HelixRow>, PortError>> + Send + 'async_trait>>

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

scan：多行扫描读（评审待办 C3）。limit = None 表示全表，driver 应设硬上限防御。

fn batch_delete<'life0, 'async_trait>( &'life0 self, spec: BatchDeleteSpec, ) -> Pin<Box<dyn Future<Output = Result<(), PortError>> + Send + 'async_trait>>

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

batch delete：DELETE FROM table WHERE scope_col = ? AND key_col IN (key_vals)。

fn atomic_write<'life0, 'async_trait>( &'life0 self, ops: Vec<StorageOp>, ) -> Pin<Box<dyn Future<Output = Result<(), PortError>> + Send + 'async_trait>>

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

在一个 storage transaction 中提交一批写操作。