Struct CommandBus 

pub struct CommandBus<A: Aggregate> { /* private fields */ }

Command bus for dispatching commands to aggregates.

Implementations

impl<A: Aggregate> CommandBus<A>

pub fn new( event_store: Box<dyn EventStore>, event_bus: Box<dyn EventBus>, ) -> Self

pub fn with_snapshot_policy(self, policy: SnapshotPolicy) -> Self

Enable (or change) the snapshot policy for this bus. Snapshots are a rehydrate-path cache only; toggling this never alters command results.

pub async fn dispatch( &self, command: A::Command, context: CommandContext, ) -> CommandBusResult<Vec<Event>>

Dispatch a command with its request-scoped CommandContext.

Steps: load → reconstruct → handle → stamp audit → append → publish. The aggregate’s handle() returns events with placeholder audit; this method overwrites it with a single validated AuditMetadata per dispatch (all events from one command share the same audit stamp).

pub fn event_store(&self) -> &dyn EventStore

pub fn event_bus(&self) -> &dyn EventBus