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

ElasticsearchEventStore

class ElasticsearchEventStore(elasticsearchClient: ReactiveElasticsearchClient, refreshPolicy: Refresh = Refresh.True, batchSize: Int = DEFAULT_BATCH_SIZE) : AbstractEventStore

Constructors

Link copied to clipboard
constructor(elasticsearchClient: ReactiveElasticsearchClient, refreshPolicy: Refresh = Refresh.True, batchSize: Int = DEFAULT_BATCH_SIZE)

Types

Link copied to clipboard
object Companion

Functions

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