Struct EventLog 

pub struct EventLog<E> { /* private fields */ }

In-memory append-only event log with interior mutability.

Implementations

impl<E> EventLog<E>

pub fn new() -> Self

pub fn append(&self, event: E)

pub fn iter(&self) -> Vec<LoggedEvent<E>>

where E: Clone,

pub fn apply_all<S, F>(&self, state: &mut S, apply_fn: F)

where F: Fn(&E, &mut S), E: Clone,

Applies all events in order to the given state using the provided closure.

pub fn apply_all_default<S, F>(&self, apply_fn: F) -> S

where S: Default, F: Fn(&E, &mut S), E: Clone,

Creates a state using Default, applies all events using the provided closure, and returns the resulting state.

Trait Implementations

impl<E: Clone> Clone for EventLog<E>

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

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<E: Debug + Clone> Debug for EventLog<E>

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

Formats the value using the given formatter.

impl<E> Default for EventLog<E>

fn default() -> Self

Returns the “default value” for a type.

impl<'de, E: Deserialize<'de>> Deserialize<'de> for EventLog<E>

fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>

where D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<E: Clone> Merge for EventLog<E>

fn merge(&mut self, other: Self)

Merges another EventLog into this one, deduplicating by UUID and ordering by (timestamp, uuid).

Deadlock Prevention

• If self and other are the same Arc, merging is a no-op (prevents self-deadlock).
• Otherwise, always lock the two logs in a consistent order (by pointer address) to prevent lock order inversion deadlocks.

impl<E: Serialize> Serialize for EventLog<E>

fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>

where S: Serializer,

Serialize this value into the given Serde serializer.