Struct AllSourceBackend 

pub struct AllSourceBackend<E: Event> { /* private fields */ }

Available on crate features cqrs and cqrs-allsource only.

AllSource Core backend for production event sourcing

Implementations

impl<E: Event> AllSourceBackend<E>

pub fn new() -> Result<Self, String>

Create a new AllSource backend with default configuration

pub fn with_config(config: AllSourceConfig) -> Result<Self, String>

Create a new AllSource backend with custom configuration

pub fn production(data_path: &str) -> Result<Self, String>

Create a production-ready configuration (persistence + WAL)

Trait Implementations

impl<E: Clone + Event> Clone for AllSourceBackend<E>

fn clone(&self) -> AllSourceBackend<E>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<E: Event> Default for AllSourceBackend<E>

fn default() -> Self

Returns the “default value” for a type.

impl<E: Event> EventStoreBackend<E> for AllSourceBackend<E>

fn append<'life0, 'life1, 'async_trait>( &'life0 self, aggregate_id: &'life1 str, events: Vec<E>, ) -> Pin<Box<dyn Future<Output = Result<(), String>> + Send + 'async_trait>>

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

Append events to an aggregate’s event stream

fn get_events<'life0, 'life1, 'async_trait>( &'life0 self, aggregate_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<E>, String>> + Send + 'async_trait>>

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

Get all events for a specific aggregate

fn get_all_events<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<E>, String>> + Send + 'async_trait>>

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

Get all events from all aggregates (for projection rebuild)

fn get_events_after<'life0, 'life1, 'async_trait>( &'life0 self, aggregate_id: &'life1 str, version: u64, ) -> Pin<Box<dyn Future<Output = Result<Vec<E>, String>> + Send + 'async_trait>>

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

Get events after a specific version (for snapshot optimization)

fn save_snapshot<'life0, 'life1, 'async_trait>( &'life0 self, aggregate_id: &'life1 str, _snapshot_data: Vec<u8>, _version: u64, ) -> Pin<Box<dyn Future<Output = Result<(), String>> + Send + 'async_trait>>

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

Save a snapshot (optional, return Ok(()) if not supported)

fn get_latest_snapshot<'life0, 'life1, 'async_trait>( &'life0 self, aggregate_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(Vec<u8>, u64), String>> + Send + 'async_trait>>

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

Get latest snapshot (optional, return Err if not supported)

fn flush<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), String>> + Send + 'async_trait>>

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

Flush any pending writes (optional, for write-ahead log or batching)

fn stats<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = BackendStats> + Send + 'async_trait>>

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

Get backend statistics