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

InMemorySnapshotRepository

class InMemorySnapshotRepository : SnapshotRepository

Constructors

Link copied to clipboard
constructor()

Functions

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