Struct TestEventLog 

pub struct TestEventLog<I> { /* private fields */ }

Available on crate feature test only.

An in-memory implementation of EventLog for testing purposes.

Trait Implementations

impl<I: Clone> Clone for TestEventLog<I>

fn clone(&self) -> TestEventLog<I>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<I: Debug> Debug for TestEventLog<I>

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

Formats the value using the given formatter.

impl<I> Default for TestEventLog<I>

fn default() -> Self

Returns the “default value” for a type.

impl<I> EventLog for TestEventLog<I>

where I: Debug + Clone + Eq + Hash + Send + Sync + 'static,

type Id = I

type Error = Error

async fn persist<E, ToBytes, ToBytesError>( &mut self, type_name: &'static str, id: &Self::Id, _last_seq_no: Option<NonZeroU64>, event: &E, to_bytes: &ToBytes, ) -> Result<NonZeroU64, Self::Error>

where E: Sync, ToBytes: Fn(&E) -> Result<Bytes, ToBytesError> + Sync, ToBytesError: StdError + Send + Sync + 'static,

Persist the given event and optional tag for the given entity ID and return the sequence number for the persisted event. The given last sequence number is used for optimistic locking, i.e. it must match the current last sequence number of the event log.

async fn last_seq_no( &self, type_name: &'static str, id: &Self::Id, ) -> Result<Option<NonZeroU64>, Self::Error>

Get the last sequence number for the given type name and entity ID.

async fn events_by_id<E, FromBytes, FromBytesError>( &self, type_name: &'static str, id: &Self::Id, seq_no: NonZeroU64, from_bytes: FromBytes, ) -> Result<impl Stream<Item = Result<(NonZeroU64, E), Self::Error>> + Send, Self::Error>

where E: Send, FromBytes: Fn(Bytes) -> Result<E, FromBytesError> + Copy + Send + Sync, FromBytesError: StdError + Send + Sync + 'static,

Get the events for the given type name and entity ID starting at the given sequence number.

async fn events_by_type<E, FromBytes, FromBytesError>( &self, type_name: &'static str, seq_no: NonZeroU64, from_bytes: FromBytes, ) -> Result<impl Stream<Item = Result<(NonZeroU64, E), Self::Error>> + Send, Self::Error>

where E: Send, FromBytes: Fn(Bytes) -> Result<E, FromBytesError> + Copy + Send + Sync, FromBytesError: StdError + Send + Sync + 'static,

Get the events for the given entity type starting at the given sequence number.

const MAX_SEQ_NO: NonZeroU64 = NonZeroU64::MAX

The maximum value for sequence numbers. Defaults to NonZeroU64::MAX unless overriden by an implementation.