Struct CommandBus 

pub struct CommandBus { /* private fields */ }

Typed command router that maps concrete command types to aggregate handlers.

Unlike the CommandEnvelope-based dispatch used by process managers, CommandBus routes commands by their Rust TypeId at zero runtime cost (single HashMap lookup). Commands do not need to be serializable.

Usage

use eventfold_es::{AggregateStore, CommandBus, CommandContext};

let store = AggregateStore::open("/tmp/my-app").await?;
let mut bus = CommandBus::new(store);
// bus.register::<MyAggregate>();
// bus.dispatch("instance-1", MyCommand { .. }, CommandContext::default()).await?;

Implementations

impl CommandBus

pub fn new(store: AggregateStore) -> Self

Create a new CommandBus backed by the given store.

Arguments

• store - The AggregateStore used to look up and spawn aggregate actors.

pub fn register<A: Aggregate>(&mut self)

Register an aggregate type for command routing.

After registration, commands of type A::Command can be dispatched via dispatch. The route is keyed by TypeId::of::<A::Command>().

Type Parameters

• A - An aggregate whose Command type will be routed.

pub async fn dispatch<C: Send + 'static>( &self, instance_id: &str, cmd: C, ctx: CommandContext, ) -> Result<(), DispatchError>

Dispatch a command to the appropriate aggregate instance.

Looks up the route by TypeId::of::<C>() and delegates to the registered aggregate’s actor.

Arguments

• instance_id - The target aggregate instance identifier.
• cmd - The concrete command to dispatch.
• ctx - Cross-cutting metadata (actor, correlation ID, etc.).

Errors

• DispatchError::UnknownCommand – no aggregate registered for C.
• DispatchError::Io – actor spawning or I/O failure.
• DispatchError::Execution – the aggregate rejected the command.