Struct IsolatedEventStore 

pub struct IsolatedEventStore { /* private fields */ }

Tenant-scoped event store wrapper

Implementations

impl IsolatedEventStore

pub fn new( tenant_id: TenantId, inner_store: Arc<dyn EventStore + Send + Sync>, isolation: Arc<TenantIsolation>, ) -> Self

pub fn tenant_id(&self) -> &TenantId

Get the tenant ID this store is scoped to

Trait Implementations

impl EventStore for IsolatedEventStore

fn save_events<'life0, 'async_trait>( &'life0 self, events: Vec<Event>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

fn load_events<'life0, 'life1, 'async_trait>( &'life0 self, aggregate_id: &'life1 AggregateId, from_version: Option<AggregateVersion>, ) -> Pin<Box<dyn Future<Output = Result<Vec<Event>>> + Send + 'async_trait>>

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

fn load_events_by_type<'life0, 'life1, 'async_trait>( &'life0 self, aggregate_type: &'life1 str, from_version: Option<AggregateVersion>, ) -> Pin<Box<dyn Future<Output = Result<Vec<Event>>> + Send + 'async_trait>>

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

fn get_aggregate_version<'life0, 'life1, 'async_trait>( &'life0 self, aggregate_id: &'life1 AggregateId, ) -> Pin<Box<dyn Future<Output = Result<Option<AggregateVersion>>> + Send + 'async_trait>>

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

fn set_event_streamer( &mut self, _streamer: Arc<dyn EventStreamer + Send + Sync>, )

Set the event streamer for publishing events