Struct InMemoryCheckpointStore 

pub struct InMemoryCheckpointStore { /* private fields */ }

In-memory checkpoint store for tracking projection progress.

InMemoryCheckpointStore stores checkpoint positions in memory using a thread-safe Arc<RwLock<HashMap>>. It is primarily useful for testing and single-process deployments where persistence across restarts is not required.

For production deployments requiring durability, use a persistent checkpoint store implementation.

Example

use eventcore_memory::InMemoryCheckpointStore;

let checkpoint_store = InMemoryCheckpointStore::new();
// Use with ProjectionRunner

Implementations

impl InMemoryCheckpointStore

pub fn new() -> Self

Create a new in-memory checkpoint store.

Trait Implementations

impl CheckpointStore for InMemoryCheckpointStore

type Error = InMemoryCheckpointError

Error type returned by checkpoint operations.

async fn load(&self, name: &str) -> Result<Option<StreamPosition>, Self::Error>

Load the last saved checkpoint position for a subscription.

async fn save( &self, name: &str, position: StreamPosition, ) -> Result<(), Self::Error>

Save a checkpoint position for a subscription.

impl Clone for InMemoryCheckpointStore

fn clone(&self) -> InMemoryCheckpointStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InMemoryCheckpointStore

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

Formats the value using the given formatter.

impl Default for InMemoryCheckpointStore

fn default() -> InMemoryCheckpointStore

Returns the “default value” for a type.