Struct Embedded 

pub struct Embedded { /* private fields */ }

Implementations

impl Embedded

pub fn builder(db: &str) -> EmbeddedBuilder

pub fn saga(&self, gid: &str) -> SagaBuilder<'_>

pub async fn submit_workflow( &self, gid: &str, name: &str, input: &str, ) -> Result<()>

提交一个 workflow 事务。

name 必须是 EmbeddedBuilder::workflow 注册过的名字 —— 这里就检查，宁可提交报错，也别等推到一半才发现函数不存在。

input 原样透传给函数（WorkflowCtx::input）。gid 本身通常就是业务单号， 简单场景可以传空串。

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

pub async fn wait_final( &self, gid: &str, timeout: Duration, ) -> Result<GlobalStatus>

等到事务落终态。只是为了测试和“同步等结果“的场景方便 —— 生产上事务是异步推进的，别在请求路径里等。

pub fn store(&self) -> &Store

Trait Implementations

impl Drop for Embedded

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.