Struct akka_persistence_rs_commitlog::EventEnvelope

pub struct EventEnvelope<E> {
    pub persistence_id: PersistenceId,
    pub seq_nr: u64,
    pub timestamp: DateTime<Utc>,
    pub event: E,
    pub offset: Offset,
    pub tags: Vec<Tag>,
}

An envelope wraps a commit log event associated with a specific entity. Tags are not presently considered useful at the edge. A remote consumer would be interested in all events from the edge in most cases, and the edge itself decides what to publish (producer defined filter).

Fields

persistence_id: PersistenceId

seq_nr: u64

timestamp: DateTime<Utc>

event: E

offset: Offset

tags: Vec<Tag>

Trait Implementations

impl<E: Clone> Clone for EventEnvelope<E>

fn clone(&self) -> EventEnvelope<E>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<E: Debug> Debug for EventEnvelope<E>

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

Formats the value using the given formatter.

impl<E: PartialEq> PartialEq for EventEnvelope<E>

fn eq(&self, other: &EventEnvelope<E>) -> bool

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

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<E> WithOffset for EventEnvelope<E>

fn offset(&self) -> Offset

impl<E> WithPersistenceId for EventEnvelope<E>

fn persistence_id(&self) -> &PersistenceId

impl<E> WithSeqNr for EventEnvelope<E>

fn seq_nr(&self) -> u64

impl<E> WithSource for EventEnvelope<E>

fn source(&self) -> Source

impl<E> WithTags for EventEnvelope<E>

fn tags(&self) -> &[Tag]

impl<E> WithTimestamp for EventEnvelope<E>

fn timestamp(&self) -> &DateTime<Utc>

impl<E> StructuralPartialEq for EventEnvelope<E>