Struct PostgresStore 

pub struct PostgresStore { /* private fields */ }

Implementations

impl PostgresStore

pub fn connect(connection_string: &str) -> Result<Self, Error>

pub fn bootstrap( options: PostgresBootstrapOptions, ) -> Result<Self, EventStoreError>

Trait Implementations

impl Drop for PostgresStore

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl EventStore for PostgresStore

fn query( &self, event_query: &EventQuery, ) -> Result<QueryResult, EventStoreError>

fn append( &self, new_events: Vec<NewEvent>, ) -> Result<AppendResult, EventStoreError>

fn append_if( &self, new_events: Vec<NewEvent>, context_query: &EventQuery, expected_context_version: Option<u64>, ) -> Result<AppendResult, EventStoreError>

fn stream_all( &self, handle: HandleStream, ) -> Result<EventStream, EventStoreError>

fn stream_to( &self, event_query: &EventQuery, handle: HandleStream, ) -> Result<EventStream, EventStoreError>

fn stream_all_durable( &self, durable_stream: &DurableStream, handle: HandleStream, ) -> Result<EventStream, EventStoreError>

fn stream_to_durable( &self, durable_stream: &DurableStream, event_query: &EventQuery, handle: HandleStream, ) -> Result<EventStream, EventStoreError>