Struct evento::PgEngine

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

Implementations

impl PgEngine

pub fn new(pool: PgPool) -> PgEvento

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

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 init<K: Into<String>>( &self, key: K, consumer_id: Uuid ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + '_>>

fn get_subscription<K: Into<String>>( &self, key: K ) -> Pin<Box<dyn Future<Output = Result<Subscription, StoreError>> + Send + '_>>

fn update_subscription( &self, subscription: Subscription ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + '_>>

fn add_deadletter( &self, events: Vec<Event> ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + '_>>

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