Struct Registry 

pub struct Registry { /* private fields */ }

Implementations

impl Registry

pub fn new() -> Self

pub fn register<F, Fut>(&mut self, name: &str, f: F) -> &mut Self

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

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

pub fn get( &self, name: &str, ) -> Option<Arc<dyn Fn(BranchCtx) -> Pin<Box<dyn Future<Output = BranchResult> + Send>> + Send + Sync>>

pub fn names(&self) -> Vec<&str>

pub fn check_all(&self, targets: &[String]) -> Result<(), Vec<String>>

提交前自查：所有 local:// 分支都注册了吗？

宁可在提交时就报错，也不要等事务推到一半才发现分支不存在 —— 那时候已经有副作用落地了，只能靠补偿收拾。

Trait Implementations

impl Debug for Registry

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for Registry

fn default() -> Registry

Returns the “default value” for a type.