Struct SqliteEventStore 

pub struct SqliteEventStore { /* private fields */ }

Implementations

impl SqliteEventStore

pub fn new(config: SqliteConfig) -> Result<Self, SqliteEventStoreError>

pub fn in_memory() -> Result<Self, SqliteEventStoreError>

pub async fn migrate(&self) -> Result<(), SqliteEventStoreError>

Trait Implementations

impl CheckpointStore for SqliteEventStore

type Error = SqliteCheckpointError

Error type returned by checkpoint operations.

async fn load(&self, name: &str) -> Result<Option<StreamPosition>, Self::Error>

Load the last saved checkpoint position for a subscription.

async fn save( &self, name: &str, position: StreamPosition, ) -> Result<(), Self::Error>

Save a checkpoint position for a subscription.

impl Debug for SqliteEventStore

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

Formats the value using the given formatter.

impl EventReader for SqliteEventStore

type Error = EventStoreError

Error type returned by read operations.

async fn read_events<E: Event>( &self, filter: EventFilter, page: EventPage, ) -> Result<Vec<(E, StreamPosition)>, Self::Error>

Read events matching filter criteria with pagination.

impl EventStore for SqliteEventStore

async fn read_stream<E: Event>( &self, stream_id: StreamId, ) -> Result<EventStreamReader<E>, EventStoreError>

Read all events from a stream.

async fn append_events( &self, writes: StreamWrites, ) -> Result<EventStreamSlice, EventStoreError>

Atomically append events to multiple streams with optimistic concurrency control.

impl ProjectorCoordinator for SqliteEventStore

type Error = SqliteCoordinationError

Error type returned when leadership acquisition fails.

type Guard = SqliteCoordinationGuard

Guard type that releases leadership when dropped.

async fn try_acquire( &self, subscription_name: &str, ) -> Result<Self::Guard, Self::Error>

Attempt to acquire leadership for a subscription.