Constructors

Link copied to clipboard
constructor(delegate: SnapshotRepository)

Properties

Link copied to clipboard
Link copied to clipboard
open override val name: String

Functions

Link copied to clipboard
open override 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
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>
Link copied to clipboard
fun <M> Flux<M>.tagSource(): Flux<M>
fun <M> Mono<M>.tagSource(): Mono<M>