Struct eventsourced_postgres::PostgresEvtLog

pub struct PostgresEvtLog { /* private fields */ }

An EvtLog implementation based on PostgreSQL.

Implementations

impl PostgresEvtLog

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

Trait Implementations

impl Clone for PostgresEvtLog

fn clone(&self) -> PostgresEvtLog

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for PostgresEvtLog

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

Formats the value using the given formatter.

impl EvtLog for PostgresEvtLog

const MAX_SEQ_NO: SeqNo = _

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 Error = Error

async fn persist<E, ToBytes, ToBytesError>( &mut self, evt: &E, tag: Option<&str>, type_name: &str, id: Uuid, last_seq_no: Option<SeqNo>, to_bytes: &ToBytes ) -> Result<SeqNo, 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 type and 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: &str, id: Uuid ) -> Result<Option<SeqNo>, Self::Error>

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

async fn evts_by_id<E, FromBytes, FromBytesError>( &self, _type: &str, id: Uuid, from_seq_no: SeqNo, from_bytes: FromBytes ) -> Result<impl Stream<Item = Result<(SeqNo, 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 ID starting with the given sequence number.

async fn evts_by_type<E, FromBytes, FromBytesError>( &self, type_name: &str, from_seq_no: SeqNo, from_bytes: FromBytes ) -> Result<impl Stream<Item = Result<(SeqNo, 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 with the given sequence number.

async fn evts_by_tag<E, FromBytes, FromBytesError>( &self, tag: String, from_seq_no: SeqNo, from_bytes: FromBytes ) -> Result<impl Stream<Item = Result<(SeqNo, 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 tag starting with the given sequence number.