Struct CommandHandlerRouter 

pub struct CommandHandlerRouter<S, H>
where
    H: CommandHandlerDomainHandler<State = S>,
{ /* private fields */ }

Router for command handler components (commands → events, single domain).

Domain is set at construction time. No .domain() method exists, enforcing single-domain constraint at compile time.

Factory Pattern (per-request handlers)

let db_pool = Arc::new(DbPool::new());
let router = CommandHandlerRouter::with_factory(
    "agg-player",
    "player",
    move || PlayerHandler::new(db_pool.clone())
);

Implementations

impl<S: Default + Send + Sync + 'static, H: CommandHandlerDomainHandler<State = S> + Clone> CommandHandlerRouter<S, H>

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

Create a new command handler router with a static handler.

Command handlers accept commands and emit events. Single domain enforced at construction. The handler is shared across all requests.

pub fn with_factory<F>( name: impl Into<String>, domain: impl Into<String>, factory: F, ) -> Self

where F: Fn() -> H + Send + Sync + 'static,

Create a new command handler router with a factory.

The factory is called per-request to create fresh handler instances. Use this for dependency injection.

Example

let db_pool = Arc::new(DbPool::new());
let router = CommandHandlerRouter::with_factory(
    "agg-player",
    "player",
    move || PlayerHandler::new(db_pool.clone())
);

pub fn name(&self) -> &str

Get the router name.

pub fn domain(&self) -> &str

Get the domain.

pub fn command_types(&self) -> Vec<String>

Get command types from the handler.

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

Get subscriptions for this command handler.

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

Rebuild state from events using the handler’s state router.

pub fn dispatch( &self, cmd: &ContextualCommand, ) -> Result<BusinessResponse, Status>

Dispatch a contextual command to the handler.