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

RoutingSnapshotStore

class RoutingSnapshotStore(registry: AggregateSnapshotStoreRegistry) : SnapshotStore

Routes operations to aggregate-specific stores and owns their lifecycle.

Closing the router closes every distinct registered store once.

Constructors

RoutingSnapshotStore

constructor(registry: AggregateSnapshotStoreRegistry)

Types

object Companion

Properties

open override val name: String

Functions

open override fun close()

Closes this snapshot store and releases owned resources.

open override 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 the latest snapshot for the specified aggregate.

fun SnapshotStore.metrizable(): SnapshotStore

Wraps a SnapshotStore with metrics collection capabilities. Returns a MetricSnapshotStore that collects metrics on snapshot storage operations. RoutingSnapshotStore remains transparent because the selected leaf store owns storage metrics.

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

Saves a snapshot to the store.