Struct PostgresEventLog

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

An EventLog implementation based on PostgreSQL.

Implementations

impl<I> PostgresEventLog<I>

where I: ToSql + Sync,

pub async fn new(config: Config) -> Result<Self, Error>

Trait Implementations

impl<I: Clone> Clone for PostgresEventLog<I>

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

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<I> Debug for PostgresEventLog<I>

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

Formats the value using the given formatter.

impl<I> EventLog for PostgresEventLog<I>

where I: Clone + ToSql + Send + Sync + 'static,

const MAX_SEQ_NO: NonZeroU64

The maximum value for sequence numbers. As PostgreSQL does not support unsigned integers, this is i64::MAX or 9_223_372_036_854_775_807.

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 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 + 'static, 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 + 'static, FromBytesError: StdError + Send + Sync + 'static,

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