Struct evento::MemoryEngine

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

Implementations

impl MemoryEngine

pub fn new<S: StoreEngine + Sync + Send + 'static>( store: EventStore<S> ) -> Evento<Self, S>

Trait Implementations

impl Clone for MemoryEngine

fn clone(&self) -> MemoryEngine

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Default for MemoryEngine

fn default() -> MemoryEngine

Returns the “default value” for a type.

impl Engine for MemoryEngine

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 + '_>>