Namespace Akka.Persistence.Snapshot

Classes

LocalSnapshotStore

Local file-based SnapshotStore implementation.

MemorySnapshotStore

INTERNAL API.

In-memory SnapshotStore implementation.

Uses a channel-based drain-on-read pattern with immutable collections to handle the concurrent access pattern imposed by SnapshotStore. Writes and deletes enqueue to an unbounded channel (never blocking), and reads drain the channel first to ensure all pending operations are visible before returning results.

MemorySnapshotStore.SnapshotStorage

Storage container for snapshot data. Encapsulates the pending operations channel and immutable snapshot state.

NoSnapshotStore

Used as a default snapshot-store in case no other store was configured.

If a PersistentActor calls the SaveSnapshot(object) method, and at the same time does not configure a specific snapshot-store to be used and no default snapshot-store is available, then the NoSnapshotStore will be used to signal a snapshot store failure.

NoSnapshotStore.NoSnapshotStoreException

TBD

SnapshotEntry

INTERNAL API.

Represents a snapshot stored inside the in-memory SnapshotStore. Immutable by design to support concurrent access patterns.

SnapshotStore

Abstract snapshot store.