Struct AuditLog 

pub struct AuditLog<E: DomainEvent> { /* private fields */ }

A reader that records every event it sees into an AuditProjection. Construct via AuditLog::with_capacity.

Implementations

impl<E: DomainEvent> AuditLog<E>

pub fn with_capacity(capacity: usize) -> Self

Construct an audit log with the given ring capacity. Wire decoding via crate::cqrs::CqrsBuilder::with_event_codecs — the registry takes priority over Reader::decode.

pub fn named(self, name: impl Into<String>) -> Self

Trait Implementations

impl<E: DomainEvent + Sync> Reader for AuditLog<E>

type Event = E

The event type this reader projects. Must match the aggregate’s event type when wired into a super::CqrsPattern.

type Projection = AuditProjection<E>

The read-model state this reader builds.

type Error = Error

Domain error type for projection failures. Failures are logged at warn level; the runner advances past the offending event so it doesn’t get stuck.

fn name(&self) -> &str

Stable name of this reader. Used for tracing spans and dashboard child-actor naming. Must be unique per CQRS instance.

fn decode(_bytes: &[u8]) -> Result<Self::Event, String>

Decode a journal payload back into the event type. The codec must be the inverse of the aggregate’s encode_event. Used as the fallback when no crate::cqrs::EventCodecRegistry is configured for the relevant manifest.

fn apply<'life0, 'life1, 'async_trait>( &'life0 mut self, p: &'life1 mut AuditProjection<E>, event: E, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Apply one event to the projection.

fn tag(&self) -> Option<String>

Legacy tag filter. Default None. Implemented in terms of Self::filter so existing v1 readers keep working unchanged. Prefer Self::filter in new code.

fn filter(&self) -> ReaderFilter

What stream of events this reader follows. Default returns ReaderFilter::Tag when Self::tag is Some, else ReaderFilter::All.