Struct Api 

pub struct Api {
    pub store: Store,
}

Fields

store: Store

Implementations

impl Api

pub fn new(store: Store) -> Self

pub fn new_gid(&self) -> String

时间戳 + 进程内计数。生产建议客户端直接用业务单号当 gid —— 那样天然幂等，重试不会变成两笔

pub async fn submit( &self, gid: &str, trans_type: &str, steps: &[SagaStep], ) -> Result<()>

提交。

重复提交同一个 gid 必须成功而不是报错 —— 客户端网络抖动重试时 返回错误会让它以为没受理，然后换个 gid 再来一次，就成了两笔。

pub async fn prepare( &self, gid: &str, trans_type: &str, actions: &[String], query_prepared: &str, grace_secs: Option<i64>, ) -> Result<()>

第一阶段。msg 建 prepared 事务 + 正向分支；tcc / xa 只建空事务。

pub async fn register_branch(&self, r: &RegisterBranch) -> Result<()>

分支登记。必须先登记再做一阶段：反过来的话一阶段成功但登记失败， TC 就不知道有这个分支，回滚时不会处理它 —— TCC 是预留资源永久泄漏， XA 更糟，会留下一个永久持锁的 prepared 事务。

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

主动中止，触发逆序补偿

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

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

Trait Implementations

impl Clone for Api

fn clone(&self) -> Api

Returns a duplicate of the value.

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

Performs copy-assignment from source.