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

ElasticsearchSnapshotStore

class ElasticsearchSnapshotStore : SnapshotStore

Constructors

constructor(elasticsearchClient: ReactiveElasticsearchClient, refreshPolicy: Refresh = Refresh.True)

constructor(elasticsearchClient: ReactiveElasticsearchClient, batchOptions: ElasticsearchSnapshotStoreBatchOptions, refreshPolicy: Refresh = Refresh.True)

Types

Companion

object Companion

Properties

batchOptions

val batchOptions: ElasticsearchSnapshotStoreBatchOptions

name

open override val name: String

Functions

open override fun close()

getVersion

open fun getVersion(aggregateId: AggregateId): Mono<Int>

load

open override fun <S : Any> load(aggregateId: AggregateId): Mono<Snapshot<S>>

save

open override fun <S : Any> save(snapshot: Snapshot<S>): Mono<Void>