Struct TcService 

pub struct TcService { /* private fields */ }

Implementations

impl TcService

pub fn new(api: Api) -> Self

pub fn into_server(self) -> TcServer<Self>

包成 tonic 的 server，调用方直接挂到 Server::builder().add_service(..)

Trait Implementations

impl Tc for TcService

fn new_gid<'life0, 'async_trait>( &'life0 self, _req: Request<NewGidRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<NewGidReply>, Status>> + Send + 'async_trait>>

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

生成一个全局事务号。生产上更建议直接用业务单号当 gid

fn prepare<'life0, 'async_trait>( &'life0 self, req: Request<PrepareRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<Empty>, Status>> + Send + 'async_trait>>

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

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

fn register_branch<'life0, 'async_trait>( &'life0 self, req: Request<RegisterBranchRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<Empty>, Status>> + Send + 'async_trait>>

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

分支登记。必须先登记再做一阶段 —— 反过来的话一阶段成功但 TC 不知道 有这个分支，回滚时会漏掉它（TCC 是资源泄漏，XA 会留下永久持锁的事务）

fn submit<'life0, 'async_trait>( &'life0 self, req: Request<SubmitRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<Empty>, Status>> + Send + 'async_trait>>

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

提交。saga 在这里一次性给出全部步骤；tcc / msg / xa 是把 prepared 推成 submitted

fn abort<'life0, 'async_trait>( &'life0 self, req: Request<AbortRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<Empty>, Status>> + Send + 'async_trait>>

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

主动中止，触发逆序补偿

fn query<'life0, 'async_trait>( &'life0 self, req: Request<QueryRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<TransView>, Status>> + Send + 'async_trait>>

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

查一笔事务的当前状态和各分支明细