Struct PostgresBackend 

pub struct PostgresBackend { /* private fields */ }

Implementations

impl PostgresBackend

pub async fn with_url(url: &str) -> Result<Self, Error>

Errors

In case of Postgres connection error

Trait Implementations

impl Debug for PostgresBackend

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

Formats the value using the given formatter.

impl Default for PostgresBackend

fn default() -> Self

Returns the “default value” for a type.

impl Storage for PostgresBackend

fn storage_name() -> &'static str

fn create_stream( &mut self, stream: Stream, correlation_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Stream, StorageError>> + Send>>

Create a new stream with an identifier

fn delete_stream( &mut self, _: &Stream, correlation_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send>>

Delete a stream from the Backend

fn read_stream( &self, stream_uuid: String, version: usize, limit: usize, correlation_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Vec<RecordedEvent>, StorageError>> + Send>>

fn append_to_stream( &mut self, stream_uuid: &str, events: &[UnsavedEvent], correlation_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Vec<Uuid>, StorageError>> + Send>>

fn read_stream_info( &mut self, stream_uuid: String, correlation_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Stream, StorageError>> + Send>>