Struct ProcessManagerRouter 

pub struct ProcessManagerRouter<S: Default + Send + Sync + 'static> { /* private fields */ }

Router for process manager components (events → commands + PM events, multi-domain).

Domains are registered via fluent .domain() calls.

Implementations

impl<S: Default + Send + Sync + 'static> ProcessManagerRouter<S>

pub fn new<R>( name: impl Into<String>, pm_domain: impl Into<String>, rebuild: R, ) -> Self

where R: Fn(&EventBook) -> S + Send + Sync + 'static,

Create a new process manager router.

Process managers correlate events across multiple domains and maintain their own state. The pm_domain is used for storing PM state.

pub fn domain<H>(self, name: impl Into<String>, handler: H) -> Self

where H: ProcessManagerDomainHandler<S> + 'static,

Register a domain handler.

Process managers can have multiple input domains.

pub fn name(&self) -> &str

Get the router name.

pub fn pm_domain(&self) -> &str

Get the PM’s own domain (for state storage).

pub fn subscriptions(&self) -> Vec<(String, Vec<String>)>

Get subscriptions (domain + event types) for this PM.

pub fn rebuild_state(&self, events: &EventBook) -> S

Rebuild PM state from events.

pub fn prepare_destinations( &self, trigger: &Option<EventBook>, process_state: &Option<EventBook>, ) -> Vec<Cover>

Get destinations needed for the given trigger and process state.

pub fn dispatch( &self, trigger: &EventBook, process_state: &EventBook, destinations: &[EventBook], ) -> Result<ProcessManagerHandleResponse, Status>

Dispatch a trigger event to the appropriate handler.