InMemorySnapshotStore

In-memory implementation of SnapshotStore for testing and development. Stores snapshots as JSON strings in a thread-safe map.

Constructors

constructor()

open override val name: String

The name of this repository.

open fun getVersion(aggregateId: AggregateId): Mono<Int>

Gets the version of the latest snapshot for the specified aggregate. Returns UNINITIALIZED_VERSION if no snapshot exists.

open override fun <S : Any> load(aggregateId: AggregateId): Mono<Snapshot<S>>

Loads a snapshot from the in-memory map by deserializing the JSON string.

Wraps a SnapshotStore with metrics collection capabilities. Returns a MetricSnapshotStore that collects metrics on snapshot storage operations.

open override fun <S : Any> save(snapshot: Snapshot<S>): Mono<Void>

Saves a snapshot to the in-memory map by serializing it to JSON.