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

SnapshotRepository

interface SnapshotRepository : AggregateIdScanner

Snapshot Repository.

Inheritors

Functions

Link copied to clipboard
open fun getVersion(aggregateId: AggregateId): Mono<Int>
Link copied to clipboard
abstract fun <S : Any> load(aggregateId: AggregateId): Mono<Snapshot<S>>
Link copied to clipboard
Link copied to clipboard
abstract fun <S : Any> save(snapshot: Snapshot<S>): Mono<Void>
Link copied to clipboard
abstract fun scanAggregateId(namedAggregate: NamedAggregate, afterId: String = FIRST_ID, limit: Int = 10): Flux<AggregateId>