Struct EventStoreBuilder

pub struct EventStoreBuilder { /* private fields */ }

Builder type for EventStore and EventSubscriber types.

The same builder instance can be used to build multiple instances of EventStore and EventSubscriber.

Implementations

impl EventStoreBuilder

pub fn new(client: Client) -> Self

Creates a new builder instance using the specified Redis client.

pub fn stream_page_size(self, size: usize) -> Self

Changes the page size used by the Stream returned in EventStore::stream and EventStore::stream_all.

pub async fn build_store<Id, Event>( &self, stream_name: &'static str, ) -> RedisResult<EventStore<Id, Event>>

Builds a new EventStore instance.

This method returns an std::future::Future completing after a connection with Redis is successfully established.

pub fn build_subscriber<Id, Event>( &self, stream_name: &'static str, ) -> EventSubscriber<Id, Event>

Builds a new EventSubscriber instance.

Trait Implementations

impl Clone for EventStoreBuilder

fn clone(&self) -> EventStoreBuilder

Returns a copy of the value.

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

Performs copy-assignment from source.