Struct FileSnapshotStore 

pub struct FileSnapshotStore<P, C> { /* private fields */ }

Implementations

impl<P, C> FileSnapshotStore<P, C>

where C: Codec<ProjectionSnapshot<P>>,

pub fn open( directory: impl AsRef<Path>, prefix: impl Into<String>, codec: C, options: SnapshotOptions, ) -> Result<Self>

Creates an immutable, generation-named snapshot store.

Errors

Rejects an invalid prefix or inaccessible directory.

pub fn with_memory_mapped_reads(self) -> Self

Enables guarded, read-only memory mapping for snapshot loads.

Generation files created by this store are immutable. Other processes must still honor advisory file locks and must never truncate a mapped generation.

Trait Implementations

impl<P, C> SnapshotStore<P> for FileSnapshotStore<P, C>

where C: Codec<ProjectionSnapshot<P>>,

fn save(&mut self, snapshot: &ProjectionSnapshot<P>) -> Result<()>

Saves an immutable projection snapshot.

fn load_latest(&self) -> Result<Option<ProjectionSnapshot<P>>>

Loads the snapshot with the greatest global event position.