Struct NativeStorage 

pub struct NativeStorage { /* private fields */ }

Implementations

impl NativeStorage

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

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

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

Trait Implementations

impl Clone for NativeStorage

fn clone(&self) -> NativeStorage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Storage for NativeStorage

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,

将复合作用域守卫更新委托给共享 HostStorage。

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,

将复合作用域读取委托给共享 HostStorage。

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

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

将作用域集合最大值读取委托给共享 HostStorage。

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

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

将作用域集合有界多行读取委托给共享 HostStorage。

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 中提交一批写操作。