Struct AsyncSnapshotter 

pub struct AsyncSnapshotter<S: SnapshotStore + ?Sized> { /* private fields */ }

Helper that wraps a SnapshotStore with a retention policy.

Implementations

impl<S: SnapshotStore + ?Sized> AsyncSnapshotter<S>

pub fn new(store: Arc<S>, policy: SnapshotPolicy) -> Self

pub fn with_keep_last(self, n: usize) -> Self

pub fn should_snapshot(&self, sequence_nr: u64) -> bool

Should the actor save a snapshot at sequence_nr?

pub async fn save( &self, persistence_id: impl Into<String>, sequence_nr: u64, payload: Vec<u8>, )

Persist payload as the snapshot for (persistence_id, sequence_nr) and prune older snapshots beyond keep_last.