Struct evento_store::PgEngine

pub struct PgEngine(/* private fields */);

Implementations

impl PgEngine

pub fn new(pool: PgPool) -> EventStore<Self>

pub fn new_prefix( pool: PgPool, table_prefix: impl Into<String> ) -> EventStore<Self>

Trait Implementations

impl Clone for PgEngine

fn clone(&self) -> PgEngine

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Engine for PgEngine

fn save<A: Aggregate, I: Into<String>>( &self, id: I, events: Vec<Event>, original_version: i32 ) -> Pin<Box<dyn Future<Output = Result<Vec<Event>, Error>> + Send + '_>>

fn load<A: Aggregate, I: Into<String>>( &self, id: I ) -> Pin<Box<dyn Future<Output = EngineResult<A>> + Send + '_>>

fn read_all<F: Serialize>( &self, first: usize, after: Option<Uuid>, filters: Option<Vec<F>> ) -> Pin<Box<dyn Future<Output = Result<Vec<Event>, Error>> + Send + '_>>

fn get<A: Aggregate, I: Into<String>>( &self, id: I ) -> Pin<Box<dyn Future<Output = Result<Option<Event>, Error>> + Send + '_>>

fn get_last( &self ) -> Pin<Box<dyn Future<Output = Result<Option<Event>, Error>> + Send + '_>>