[−][src]Trait actor_es::CommitStore

pub trait CommitStore<M: Model>: Debug + Clone + Send + Sync + 'static {
    fn keys(&self) -> BoxStream<'_, CommitResult<EntityId>>;

    fn change_list(
        &self, 
        id: EntityId
    ) -> BoxStream<'_, CommitResult<Commit<M>>>;

#[must_use]    fn commit<'life0, 'async_trait>(
        &'life0 self, 
        c: Commit<M>
    ) -> Pin<Box<dyn Future<Output = CommitResult<()>> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: 'async_trait;

    fn entities(&self) -> BoxStream<'_, CommitResult<TimeTraveler<'_, M>>> { ... }

#[must_use]    fn get<'life0, 'async_trait>(
        &'life0 self, 
        id: EntityId
    ) -> Pin<Box<dyn Future<Output = CommitResult<TimeTraveler<'_, M>>> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: 'async_trait,
    { ... }

#[must_use]    fn snapshot<'life0, 'async_trait>(
        &'life0 self, 
        id: EntityId, 
        time: DateTime<Utc>
    ) -> Pin<Box<dyn Future<Output = CommitResult<M>> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: 'async_trait,
    { ... }
}

Required methods

fn keys(&self) -> BoxStream<'_, CommitResult<EntityId>>

fn change_list(&self, id: EntityId) -> BoxStream<'_, CommitResult<Commit<M>>>

#[must_use]fn commit<'life0, 'async_trait>(
    &'life0 self,
    c: Commit<M>
) -> Pin<Box<dyn Future<Output = CommitResult<()>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Loading content...

Provided methods

fn entities(&self) -> BoxStream<'_, CommitResult<TimeTraveler<'_, M>>>

#[must_use]fn get<'life0, 'async_trait>(
    &'life0 self,
    id: EntityId
) -> Pin<Box<dyn Future<Output = CommitResult<TimeTraveler<'_, M>>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

#[must_use]fn snapshot<'life0, 'async_trait>(
    &'life0 self,
    id: EntityId,
    time: DateTime<Utc>
) -> Pin<Box<dyn Future<Output = CommitResult<M>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Loading content...

Implementors

impl<M: Model> CommitStore<M> for MemStore<M>[src]

Loading content...