Struct DatabaseStorage 

pub struct DatabaseStorage { /* private fields */ }

PostgreSQL 存储实现

Implementations

impl DatabaseStorage

pub async fn new(database_url: &str) -> Result<DatabaseStorage, StorageError>

连接数据库并确保表结构存在

pub fn from_pool(pool: Pool<Postgres>) -> DatabaseStorage

使用已有连接池

pub async fn migrate(&self) -> Result<(), StorageError>

执行内嵌 DDL（幂等）

Trait Implementations

impl Clone for DatabaseStorage

fn clone(&self) -> DatabaseStorage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DatabaseStorage

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl SaStorage for DatabaseStorage

fn get<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<String>, StorageError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, DatabaseStorage: 'async_trait,

Read value by key | 按键读取值

fn set<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, key: &'life1 str, value: &'life2 str, ttl: Option<Duration>, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, DatabaseStorage: 'async_trait,

Write value with optional TTL | 写入值（可选 TTL）

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, DatabaseStorage: 'async_trait,

Delete a key | 删除键

fn exists<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<bool, StorageError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, DatabaseStorage: 'async_trait,

Whether the key exists | 键是否存在

fn expire<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ttl: Duration, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, DatabaseStorage: 'async_trait,

Update key TTL | 更新键过期时间

fn ttl<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Duration>, StorageError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, DatabaseStorage: 'async_trait,

Remaining TTL, if any | 剩余过期时间（若有）

fn clear<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

where 'life0: 'async_trait, DatabaseStorage: 'async_trait,

Remove all keys | 清空全部键

fn set_if_absent<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _key: &'life1 str, _value: &'life2 str, _ttl: Option<Duration>, ) -> Pin<Box<dyn Future<Output = Result<bool, StorageError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, DatabaseStorage: 'async_trait,

仅当键不存在（或已过期）时写入；成功占位返回 true

fn get_del<'life0, 'life1, 'async_trait>( &'life0 self, _key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<String>, StorageError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, DatabaseStorage: 'async_trait,

读取并删除；保证单次消费者语义

fn compare_and_swap<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, _key: &'life1 str, _expected: Option<&'life2 str>, _new_value: &'life3 str, _ttl: Option<Duration>, ) -> Pin<Box<dyn Future<Output = Result<bool, StorageError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, DatabaseStorage: 'async_trait,

比较并交换：当且仅当当前值等于 expected 时，写入 new_value

fn compare_and_delete<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _key: &'life1 str, _expected: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<bool, StorageError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, DatabaseStorage: 'async_trait,

比较并删除：仅当当前值等于 expected 时删除

fn list_push<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _key: &'life1 str, _member: &'life2 str, _unique: bool, _ttl: Option<Duration>, ) -> Pin<Box<dyn Future<Output = Result<usize, StorageError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, DatabaseStorage: 'async_trait,

向集合追加成员；unique=true 时跳过重复项

fn list_remove<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _key: &'life1 str, _member: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<bool, StorageError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, DatabaseStorage: 'async_trait,

从集合移除成员；返回是否确实移除

fn list_range<'life0, 'life1, 'async_trait>( &'life0 self, _key: &'life1 str, _start: usize, _limit: Option<usize>, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, StorageError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, DatabaseStorage: 'async_trait,

分页读取集合成员

fn list_len<'life0, 'life1, 'async_trait>( &'life0 self, _key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<usize, StorageError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, DatabaseStorage: 'async_trait,

集合长度

fn scan<'life0, 'life1, 'async_trait>( &'life0 self, _pattern: &'life1 str, _cursor: u64, _limit: usize, ) -> Pin<Box<dyn Future<Output = Result<ScanPage, StorageError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, DatabaseStorage: 'async_trait,

游标扫描：pattern 为 glob（* / ?），cursor 为上一页 next_cursor

fn mget<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, keys: &'life1 [&'life2 str], ) -> Pin<Box<dyn Future<Output = Result<Vec<Option<String>>, StorageError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, Self: 'async_trait,

批量读：默认逐键 get，具体后端可覆盖为 mget

fn mset<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, items: &'life1 [(&'life2 str, &'life3 str)], ttl: Option<Duration>, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, Self: 'async_trait,

批量写：默认逐键 set

fn mdel<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, keys: &'life1 [&'life2 str], ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, Self: 'async_trait,

批量删：默认逐键 delete

fn incr<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<i64, StorageError>> + Send + 'async_trait>>

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

自增：默认实现非原子（读-改-写），并发环境下计数不准确

fn decr<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<i64, StorageError>> + Send + 'async_trait>>

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

自减：默认实现非原子（读-改-写），语义同 incr