Struct PgEventStore

pub struct PgEventStore<Tls>
where
    Tls: MakeTlsConnect<Socket> + Clone + Send + Sync + 'static,
    <Tls as MakeTlsConnect<Socket>>::Stream: Send + Sync,
    <Tls as MakeTlsConnect<Socket>>::TlsConnect: Send,
    <<Tls as MakeTlsConnect<Socket>>::TlsConnect as TlsConnect<Socket>>::Future: Send,
{ /* private fields */ }

Postgres event store implementation.

Implementations

impl<Tls> PgEventStore<Tls>

where Tls: MakeTlsConnect<Socket> + Clone + Send + Sync + 'static, <Tls as MakeTlsConnect<Socket>>::Stream: Send + Sync, <Tls as MakeTlsConnect<Socket>>::TlsConnect: Send, <<Tls as MakeTlsConnect<Socket>>::TlsConnect as TlsConnect<Socket>>::Future: Send,

pub async fn connect(uri: impl ToString, tls: Tls) -> Result<Self, Error>

Connects to an event store.

Trait Implementations

impl<Tls> Clone for PgEventStore<Tls>

where Tls: MakeTlsConnect<Socket> + Clone + Send + Sync + 'static + Clone, <Tls as MakeTlsConnect<Socket>>::Stream: Send + Sync, <Tls as MakeTlsConnect<Socket>>::TlsConnect: Send, <<Tls as MakeTlsConnect<Socket>>::TlsConnect as TlsConnect<Socket>>::Future: Send,

fn clone(&self) -> PgEventStore<Tls>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<Tls> EventStore for PgEventStore<Tls>

where Tls: MakeTlsConnect<Socket> + Clone + Send + Sync + 'static, <Tls as MakeTlsConnect<Socket>>::Stream: Send + Sync, <Tls as MakeTlsConnect<Socket>>::TlsConnect: Send, <<Tls as MakeTlsConnect<Socket>>::TlsConnect as TlsConnect<Socket>>::Future: Send,

type Error = Error

The error type.

fn load_events<'life0, 'life1, 'async_trait, A>( &'life0 self, id: Option<&'life1 <A as Aggregate>::ID>, ) -> Pin<Box<dyn Future<Output = Result<Vec<AggregateEventEnvelope<A>>, Self::Error>> + Send + 'async_trait>>

where A: Aggregate + 'async_trait, <A as Aggregate>::Event: DeserializeOwned, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Load events for a given aggregate.

fn load_events_by_id<'life0, 'life1, 'async_trait, A>( &'life0 self, ids: &'life1 [usize], ) -> Pin<Box<dyn Future<Output = Result<Vec<AggregateEventEnvelope<A>>, Self::Error>> + Send + 'async_trait>>

where A: Aggregate + 'async_trait, <A as Aggregate>::Event: DeserializeOwned, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Load events by ids.

fn load_aggregate_sequence<'life0, 'life1, 'async_trait, A>( &'life0 self, id: &'life1 <A as Aggregate>::ID, ) -> Pin<Box<dyn Future<Output = Result<Option<usize>, Self::Error>> + Send + 'async_trait>>

where A: Aggregate + 'async_trait, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Loads an aggregates latest sequence.

fn save_events<'life0, 'life1, 'life2, 'async_trait, A>( &'life0 self, id: &'life1 <A as Aggregate>::ID, events: &'life2 [<A as Aggregate>::Event], ) -> Pin<Box<dyn Future<Output = Result<Vec<usize>, Self::Error>> + Send + 'async_trait>>

where A: Aggregate + 'async_trait, <A as Aggregate>::Event: Serialize, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Saves events for a given aggregate instance.

fn execute<'life0, 'async_trait, A, C, R>( &'life0 self, id: <A as Aggregate>::ID, cmd: C, ) -> Pin<Box<dyn Future<Output = Result<R, Self::Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, A: Aggregate + Send + Sync + 'async_trait, <A as Aggregate>::ID: Clone, <A as Aggregate>::Event: Clone + DeserializeOwned + Serialize, C: FnOnce(&A) -> R + Send + 'async_trait, R: Clone + IntoEvents<<A as Aggregate>::Event> + Send + 'async_trait, Self: Sync + 'async_trait,

Loads an aggregate by replaying all events.

fn load_event_by_id<'life0, 'async_trait, A>( &'life0 self, id: usize, ) -> Pin<Box<dyn Future<Output = Result<Option<EventEnvelope<<A as Aggregate>::Event>>, Self::Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, A: Aggregate + 'async_trait, <A as Aggregate>::Event: DeserializeOwned, Self: Sync + 'async_trait,

Load events by ids.

fn load_aggregate<'life0, 'async_trait, A>( &'life0 self, id: <A as Aggregate>::ID, ) -> Pin<Box<dyn Future<Output = Result<Option<A>, Self::Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, A: Aggregate + 'async_trait, <A as Aggregate>::Event: DeserializeOwned, Self: Sync + 'async_trait,

Loads an aggregate by replaying all events.