Struct cala_ledger::entity::EntityEvents

pub struct EntityEvents<T: EntityEvent> {
    pub entity_first_persisted_at: Option<DateTime<Utc>>,
    pub latest_event_persisted_at: Option<DateTime<Utc>>,
    /* private fields */
}

Fields

entity_first_persisted_at: Option<DateTime<Utc>>

latest_event_persisted_at: Option<DateTime<Utc>>

Implementations

impl<T> EntityEvents<T>

where T: DeserializeOwned + Serialize + 'static + EntityEvent,

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

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

pub async fn persist( &mut self, db: &mut Transaction<'_, Postgres>, ) -> Result<usize, Error>

pub async fn persisted_at( &mut self, db: &mut Transaction<'_, Postgres>, data_source: DataSourceId, recorded_at: DateTime<Utc>, ) -> Result<usize, Error>

pub async fn batch_persist( db: &mut Transaction<'_, Postgres>, entities: impl IntoIterator<Item = Self>, ) -> Result<(), Error>

pub fn load_first<E: Entity<Event = T>>( events: impl IntoIterator<Item = GenericEvent>, ) -> Result<E, EntityError>

pub fn load_n<E: Entity<Event = T>>( events: impl IntoIterator<Item = GenericEvent>, n: usize, ) -> Result<(Vec<E>, bool), EntityError>

pub fn last_persisted(&self) -> impl Iterator<Item = &T>

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

Trait Implementations

impl<T> IntoIterator for EntityEvents<T>

where T: DeserializeOwned + Serialize + 'static + EntityEvent,

type Item = T

The type of the elements being iterated over.

type IntoIter = Chain<IntoIter<T>, IntoIter<T>>

Which kind of iterator are we turning this into?

fn into_iter(self) -> Self::IntoIter

Creates an iterator from a value.

impl TryFrom<EntityEvents<AccountEvent>> for Account

type Error = EntityError

The type returned in the event of a conversion error.

fn try_from(events: EntityEvents<AccountEvent>) -> Result<Self, Self::Error>

Performs the conversion.

impl TryFrom<EntityEvents<AccountSetEvent>> for AccountSet

type Error = EntityError

The type returned in the event of a conversion error.

fn try_from(events: EntityEvents<AccountSetEvent>) -> Result<Self, Self::Error>

Performs the conversion.

impl TryFrom<EntityEvents<EntryEvent>> for Entry

type Error = EntityError

The type returned in the event of a conversion error.

fn try_from(events: EntityEvents<EntryEvent>) -> Result<Self, Self::Error>

Performs the conversion.

impl TryFrom<EntityEvents<JournalEvent>> for Journal

type Error = EntityError

The type returned in the event of a conversion error.

fn try_from(events: EntityEvents<JournalEvent>) -> Result<Self, Self::Error>

Performs the conversion.

impl TryFrom<EntityEvents<TransactionEvent>> for Transaction

type Error = EntityError

The type returned in the event of a conversion error.

fn try_from(events: EntityEvents<TransactionEvent>) -> Result<Self, Self::Error>

Performs the conversion.

impl TryFrom<EntityEvents<TxTemplateEvent>> for TxTemplate

type Error = EntityError

The type returned in the event of a conversion error.

fn try_from(events: EntityEvents<TxTemplateEvent>) -> Result<Self, Self::Error>

Performs the conversion.