Struct WorkflowRegistry 

pub struct WorkflowRegistry { /* private fields */ }

按名字存 workflow 函数。

跟 local:// 分支同一个道理：函数没法持久化，库里存的是名字， 重启后靠这张表把名字解析回函数。所以重启后必须注册同名的 workflow。

Implementations

impl WorkflowRegistry

pub fn new() -> Self

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

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

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

pub fn contains(&self, name: &str) -> bool

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

Trait Implementations

impl Debug for WorkflowRegistry

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

Formats the value using the given formatter.

impl Default for WorkflowRegistry

fn default() -> WorkflowRegistry

Returns the “default value” for a type.