wow-r2dbc/me.ahoo.wow.r2dbc/R2dbcEventStore

R2dbcEventStore

class R2dbcEventStore(database: Database, eventStreamSchema: EventStreamSchema) : AbstractEventStore

Constructors

Link copied to clipboard
constructor(database: Database, eventStreamSchema: EventStreamSchema)

Functions

Link copied to clipboard
open override fun append(eventStream: DomainEventStream): Mono<Void>
Link copied to clipboard
open override fun appendStream(eventStream: DomainEventStream): Mono<Void>
Link copied to clipboard
open override fun load(aggregateId: AggregateId, headVersion: Int, tailVersion: Int): Flux<DomainEventStream>
Link copied to clipboard
open override fun loadStream(aggregateId: AggregateId, headVersion: Int, tailVersion: Int): Flux<DomainEventStream>