Struct timesource_core::event::Persisted

pub struct Persisted<T> { /* fields omitted */ }

An Event wrapper for events that have been successfully committed to the [EventStore].

[EventStream]s are composed of these events.

Implementations

impl<T> Persisted<T>

pub fn sequence(&self) -> i64

Returns the event sequence number.

pub fn aggregate_id(&self) -> Uuid

Returns the aggregate id.

pub fn utc(&self) -> DateTime<Utc>

pub fn data(&self) -> &T

pub fn into_data(self) -> T

Unwraps the inner Event from the Persisted wrapper.

Trait Implementations

impl<T: Clone> Clone for Persisted<T>

fn clone(&self) -> Persisted<T>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for Persisted<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de, T> Deserialize<'de> for Persisted<T> where
    T: Deserialize<'de>, 

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
    __D: Deserializer<'de>, 

Deserialize this value from the given Serde deserializer.

impl<T: PartialEq> PartialEq<Persisted<T>> for Persisted<T>

fn eq(&self, other: &Persisted<T>) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Persisted<T>) -> bool

This method tests for !=.

impl<T> Serialize for Persisted<T> where
    T: Serialize, 

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error> where
    __S: Serializer, 

Serialize this value into the given Serde serializer.

impl<T> TryFrom<EventRow> for Persisted<T> where
    for<'de> T: Deserialize<'de>, 

type Error = Error

The type returned in the event of a conversion error.

fn try_from(row: EventRow) -> Result<Self>

Performs the conversion.

impl<T: Eq> Eq for Persisted<T>

impl<T> StructuralEq for Persisted<T>

impl<T> StructuralPartialEq for Persisted<T>