MongoEventStore

class MongoEventStore(database: MongoDatabase, val batchOptions: BatchOptions? = null, metrics: WowMetrics = WowMetrics.NONE) : AbstractEventStore, Closeable

Constructors

constructor(database: MongoDatabase, batchOptions: BatchOptions? = null, metrics: WowMetrics = WowMetrics.NONE)

The batch writer of this store's event streams, flushed by the runtime after its dispatchers stop (me.ahoo.wow.runtime.RuntimeResources); RuntimeResource.NONE when the store writes directly.

open override fun close()

open override fun existsRequestId(aggregateId: AggregateId, requestId: String): Mono<Boolean>

open override fun last(aggregateId: AggregateId): Mono<DomainEventStream>

open override fun scanAggregateId(namedAggregate: NamedAggregate, afterId: String, limit: Int): Flux<AggregateId>