wow-core/me.ahoo.wow.eventsourcing.snapshot/SnapshotRepository

SnapshotRepository

interface SnapshotRepository : Named, AggregateIdScanner

Repository for storing and retrieving snapshots of state aggregates. Snapshots optimize aggregate loading by providing a recent state checkpoint.

Inheritors

InMemorySnapshotRepository

NoOpSnapshotRepository

MetricSnapshotRepository

Properties

abstract val name: String

Functions

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.

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

Loads the latest snapshot for the specified aggregate.

fun SnapshotRepository.metrizable(): SnapshotRepository

Wraps a SnapshotRepository with metrics collection capabilities. Returns a MetricSnapshotRepository that collects metrics on snapshot storage operations.

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

Saves a snapshot to the repository.

scanAggregateId

abstract fun scanAggregateId(namedAggregate: NamedAggregate, afterId: String = FIRST_ID, limit: Int = 10): Flux<AggregateId>

Scans for aggregate IDs within the specified named aggregate, starting after the given ID. Returns a limited number of aggregate IDs in lexicographical order.