Struct Store 

pub struct Store { /* private fields */ }

存储层的统一入口。按 URL 前缀自动选后端：

sqlite:...     / postgres://...  / mysql://...   → SQL 后端
redis://...    / rediss://...                    → Redis 后端（要开 redis feature）

⚠ Redis 后端跟 SQL 后端有实打实的语义差异（持久性更弱、终态会过期）， 用之前务必读 [redis_store] 的模块说明。

Implementations

impl Store

pub async fn open(url: &str) -> Result<Self>

按 URL 选后端并连上。

pub fn is_redis(&self) -> bool

底层是不是 Redis

pub fn pool(&self) -> Option<&AnyPool>

SQL 后端的连接池。Redis 后端返回 None —— 调用方（主要是测试和屏障）要自己处理这种情况

pub fn backend(&self) -> Option<Backend>

SQL 方言。Redis 后端没有方言可言，返回 None

impl Store

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

建表（Redis 后端是空操作）

pub async fn create_global( &self, g: &GlobalRow, branches: &[BranchRow], ) -> Result<bool>

建全局事务 + 分支。已存在返回 false，不覆盖

pub async fn get_global(&self, gid: &str) -> Result<Option<GlobalRow>>

pub async fn list_branches(&self, gid: &str) -> Result<Vec<BranchRow>>

pub async fn lock_one_due( &self, owner: &str, lease: i64, ) -> Result<Option<GlobalRow>>

抢一个到期事务。多实例不重复推进就靠它的原子性

pub async fn set_global_status( &self, gid: &str, status: GlobalStatus, reason: &str, ) -> Result<()>

pub async fn set_branch_result( &self, gid: &str, branch_id: &str, op: BranchOp, status: BranchStatus, payload: &str, ) -> Result<()>

pub async fn set_branch_status( &self, gid: &str, branch_id: &str, op: BranchOp, status: BranchStatus, ) -> Result<()>

pub async fn schedule_retry(&self, gid: &str, interval: i64) -> Result<()>

pub async fn schedule_now(&self, gid: &str) -> Result<()>

pub async fn register_branch( &self, gid: &str, branch_id: &str, ops: &[(BranchOp, String)], ) -> Result<()>

pub async fn list_recent(&self, limit: i64) -> Result<Vec<GlobalRow>>

Trait Implementations

impl Clone for Store

fn clone(&self) -> Store

Returns a duplicate of the value.

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

Performs copy-assignment from source.