load

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

Loads a snapshot for the specified aggregate ID and collects metrics on the operation. Metrics collected include timing, success/failure rates, and tags for aggregate identification.

Return

a Mono containing the snapshot, or empty if no snapshot exists

Parameters

S

the type of the snapshot state

aggregateId

the aggregate ID to load the snapshot for