Struct eventsourced_postgres::PostgresEvtLog

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

An EvtLog implementation based on PostgreSQL.

Implementations

impl<I> PostgresEvtLog<I>

where I: ToSql + Sync,

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

Trait Implementations

impl<I: Clone> Clone for PostgresEvtLog<I>

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

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<I> Debug for PostgresEvtLog<I>

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

Formats the value using the given formatter.

impl<I> EvtLog for PostgresEvtLog<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>, evt: &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 evts_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 evts_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.