Struct FileEventStore 

pub struct FileEventStore<E, C> { /* private fields */ }

Implementations

impl<E, C> FileEventStore<E, C>

where E: Clone, C: Codec<StoredEvent<E>>,

pub fn open( path: impl AsRef<Path>, codec: C, options: FileStoreOptions, ) -> Result<Self>

Opens or creates a framed append-only event journal.

Errors

Rejects invalid headers, checksum corruption, invalid restored event sequences, and partial tails in strict mode.

pub fn path(&self) -> &Path

Trait Implementations

impl<E, C> EventStore<E> for FileEventStore<E, C>

where E: Clone, C: Codec<StoredEvent<E>>,

fn append( &mut self, stream: &StreamId, expected: ExpectedVersion, events: &[NewEvent<E>], ) -> Result<Vec<StoredEvent<E>>>

Atomically appends a batch to one stream.

fn append_owned( &mut self, stream: &StreamId, expected: ExpectedVersion, events: Vec<NewEvent<E>>, ) -> Result<Vec<StoredEvent<E>>>

Appends an owned batch without requiring callers to retain the inputs.

fn append_owned_receipt( &mut self, stream: &StreamId, expected: ExpectedVersion, events: Vec<NewEvent<E>>, ) -> Result<AppendReceipt>

Appends an owned batch and returns positions without cloning committed payloads back to the caller.

fn load_stream( &self, stream: &StreamId, after: Option<u64>, ) -> Vec<StoredEvent<E>>

fn load_all(&self, after: Option<u64>, limit: usize) -> Vec<StoredEvent<E>>

fn stream_version(&self, stream: &StreamId) -> Option<u64>

fn len(&self) -> usize

fn is_empty(&self) -> bool