wow-r2dbc/me.ahoo.wow.r2dbc/R2dbcSnapshotRepository

R2dbcSnapshotRepository

class R2dbcSnapshotRepository(database: Database, snapshotSchema: SnapshotSchema) : SnapshotRepository

Constructors

Link copied to clipboard
constructor(database: Database, snapshotSchema: SnapshotSchema)

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
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>