wow-mongo/me.ahoo.wow.mongo/MongoEventStore

MongoEventStore

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

Constructors

MongoEventStore

constructor(database: MongoDatabase, batchOptions: MongoEventStoreBatchOptions = MongoEventStoreBatchOptions(), metrics: WowMetrics = WowMetrics.NONE)

Properties

batchOptions

val batchOptions: MongoEventStoreBatchOptions

Functions

open override fun close()

existsRequestId

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

last

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

scanAggregateId

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