Struct EmbeddedBuilder 

pub struct EmbeddedBuilder { /* private fields */ }

Implementations

impl EmbeddedBuilder

pub fn handler<F, Fut>(self, name: &str, f: F) -> EmbeddedBuilder

where F: Fn(BranchCtx) -> Fut + Send + Sync + 'static, Fut: Future<Output = BranchResult> + Send + 'static,

注册一个进程内分支。名字对应 local://名字。

pub fn owner(self, o: &str) -> EmbeddedBuilder

pub fn tick(self, d: Duration) -> EmbeddedBuilder

推进器轮询间隔。默认 200ms —— 进程内调用很快，不需要像跨网络那样保守

pub fn workflow<F, Fut>(self, name: &str, f: F) -> EmbeddedBuilder

where F: Fn(WorkflowCtx) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<(), WorkflowError>> + Send + 'static,

注册一个 workflow：把整个事务流程写成一个普通函数。

跟 saga 的区别是步骤由函数自己决定 —— 可以有 if、有循环、 可以依赖前一步的返回值。崩溃后靠重放 + 结果记忆化续跑。

详见 crate::workflow，尤其是「你的函数必须是确定性的」那节。

pub async fn start(self) -> Result<Embedded, Error>