Struct BranchBuilder 

pub struct BranchBuilder<'a> { /* private fields */ }

Implementations

impl BranchBuilder<'_>

pub fn on_rollback(self, compensate: &str) -> Self

登记这个分支的补偿。地址跟 saga 的补偿一样，可以是 local://名字 / http://... / grpc://...。

不登记补偿的分支在回滚时不会被补偿 —— 只适合本来就没副作用的步骤 （比如纯查询）。有副作用就一定要给。

pub async fn run<F, Fut>(self, f: F) -> WorkflowResult<()>

where F: FnOnce() -> Fut, Fut: Future<Output = BranchResult>,

跑这个分支（不带返回数据）。

pub async fn run_with<F, Fut>(self, f: F) -> WorkflowResult<String>

where F: FnOnce() -> Fut, Fut: Future<Output = (BranchResult, String)>,

跑这个分支，并记住它的返回数据。重放时原样还回来，不会重新执行。

数据大小受 trans_branch_op.payload 列限制（MySQL 上是 VARCHAR）， 放个 id 或一小段 JSON 就好，别塞大对象。