wow-elasticsearch/me.ahoo.wow.elasticsearch.eventsourcing/ElasticsearchEventStore

ElasticsearchEventStore

class ElasticsearchEventStore(elasticsearchClient: ReactiveElasticsearchClient, val batchOptions: ElasticsearchEventStoreBatchOptions = ElasticsearchEventStoreBatchOptions(), refreshPolicy: Refresh = Refresh.True, batchSize: Int = DEFAULT_BATCH_SIZE, metrics: WowMetrics = WowMetrics.NONE) : AbstractEventStore

Constructors

Link copied to clipboard
constructor(elasticsearchClient: ReactiveElasticsearchClient, batchOptions: ElasticsearchEventStoreBatchOptions = ElasticsearchEventStoreBatchOptions(), refreshPolicy: Refresh = Refresh.True, batchSize: Int = DEFAULT_BATCH_SIZE, metrics: WowMetrics = WowMetrics.NONE)

Types

Link copied to clipboard
object Companion

Properties

Link copied to clipboard

Functions

Link copied to clipboard
open override fun close()
Link copied to clipboard
open override fun last(aggregateId: AggregateId): Mono<DomainEventStream>
Link copied to clipboard
open override fun scanAggregateId(namedAggregate: NamedAggregate, afterId: String, limit: Int): Flux<AggregateId>
Generated by Dokka
© 2026 Copyright