Struct CommandJournal 

pub struct CommandJournal<'a, R: CommandRunner, S: EventStore> { /* private fields */ }

Wraps a CommandRunner and persists execution events to an EventStore.

Implementations

impl<'a, R: CommandRunner, S: EventStore> CommandJournal<'a, R, S>

pub fn new(runner: R, store: &'a S) -> Self

pub fn with_audit_sink(self, sink: &'a dyn AuditSink) -> Self

Set an optional audit sink for command execution events.

pub async fn execute( &self, request: CommandRequest, cancel: CancellationToken, ) -> Result<CommandResult, ExecError>

Execute a command and persist all events to the store.

Events persisted:

1. command.started — when the command begins execution.
2. command.output — one event per stream chunk (batched by configurable threshold).
3. command.completed — terminal event with exit code and timing.