Struct Store 

pub struct Store<Id, Pos> { /* private fields */ }

Implementations

impl<Id, Pos> Store<Id, Pos>

pub fn always() -> Self

Create a snapshot store that saves after every command.

Best for aggregates with expensive replay or many events. See the policy guidelines above for choosing an appropriate cadence.

pub fn every(n: u64) -> Self

Create a snapshot store that saves every N events.

Recommended for most use cases. Start with n = 50-100 and tune based on your aggregate’s replay cost. See the policy guidelines above for choosing a policy.

pub fn never() -> Self

Create a snapshot store that never saves (load-only).

Use for read replicas, short-lived aggregates, or when managing snapshots externally. See the policy guidelines above for when this fits.

Trait Implementations

impl<Id: Clone, Pos: Clone> Clone for Store<Id, Pos>

fn clone(&self) -> Store<Id, Pos>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<Id: Debug, Pos: Debug> Debug for Store<Id, Pos>

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

Formats the value using the given formatter.

impl<Id, Pos> Default for Store<Id, Pos>

fn default() -> Self

Returns the “default value” for a type.

impl<Id, Pos> SnapshotStore<Id> for Store<Id, Pos>

where Id: Clone + Eq + Hash + Send + Sync, Pos: Clone + Ord + Send + Sync,

type Error = Error

Error type for snapshot operations.

type Position = Pos

Position type for tracking snapshot positions.

async fn load<T>( &self, kind: &str, id: &Id, ) -> Result<Option<Snapshot<Pos, T>>, Self::Error>

where T: DeserializeOwned,

Load the most recent snapshot for an aggregate.

async fn offer_snapshot<CE, T, Create>( &self, kind: &str, id: &Id, events_since_last_snapshot: u64, create_snapshot: Create, ) -> Result<SnapshotOffer, OfferSnapshotError<Self::Error, CE>>

where CE: Error + Send + Sync + 'static, T: Serialize, Create: FnOnce() -> Result<Snapshot<Pos, T>, CE>,

Whether to store a snapshot, with lazy snapshot creation.