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

ElasticsearchEventStore

class ElasticsearchEventStore(elasticsearchClient: ReactiveElasticsearchClient, val batchOptions: BatchOptions? = null, refreshPolicy: Refresh = Refresh.True, batchSize: Int = DEFAULT_BATCH_SIZE, metrics: WowMetrics = WowMetrics.NONE, indexNaming: ElasticsearchIndexNaming) : AbstractEventStore

Constructors

constructor(elasticsearchClient: ReactiveElasticsearchClient, batchOptions: BatchOptions? = null, refreshPolicy: Refresh = Refresh.True, batchSize: Int = DEFAULT_BATCH_SIZE, metrics: WowMetrics = WowMetrics.NONE, indexNaming: ElasticsearchIndexNaming)

The constructor from before the index prefix, kept for binary compatibility: Wow's unprefixed names.

Types

Companion

object Companion

Properties

batchOptions

val batchOptions: BatchOptions?

runtimeResource

val runtimeResource: RuntimeResource

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.

Functions

open override fun close()

existsRequestId

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

A bounded lookup on the indexed requestId field instead of the interface default, which loads the whole stream. The idempotency check calls it on the command path.

last

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

scanAggregateId

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