Struct EntityEvents

pub struct EntityEvents<T: EsEvent> {
    pub entity_id: <T as EsEvent>::EntityId,
    /* private fields */
}

Fields

entity_id: <T as EsEvent>::EntityId

Implementations

impl<T> EntityEvents<T>

where T: EsEvent,

pub fn init( id: <T as EsEvent>::EntityId, initial_events: impl IntoIterator<Item = T>, ) -> Self

pub fn id(&self) -> &<T as EsEvent>::EntityId

pub fn entity_first_persisted_at(&self) -> Option<DateTime<Utc>>

pub fn entity_last_modified_at(&self) -> Option<DateTime<Utc>>

pub fn push(&mut self, event: T)

pub fn mark_new_events_persisted_at( &mut self, recorded_at: DateTime<Utc>, ) -> usize

pub fn serialize_new_events(&self) -> Vec<Value>

pub fn any_new(&self) -> bool

pub fn len_persisted(&self) -> usize

pub fn iter_persisted( &self, ) -> impl DoubleEndedIterator<Item = &PersistedEvent<T>>

pub fn last_persisted(&self, n: usize) -> LastPersisted<'_, T>

pub fn iter_all(&self) -> impl DoubleEndedIterator<Item = &T>

pub fn load_first<E: EsEntity<Event = T>>( events: impl IntoIterator<Item = GenericEvent<<T as EsEvent>::EntityId>>, ) -> Result<E, EsEntityError>

pub fn load_n<E: EsEntity<Event = T>>( events: impl IntoIterator<Item = GenericEvent<<T as EsEvent>::EntityId>>, n: usize, ) -> Result<(Vec<E>, bool), EsEntityError>

Trait Implementations

impl<T: Clone + EsEvent> Clone for EntityEvents<T>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.