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

ElasticsearchSnapshotStore

class ElasticsearchSnapshotStore(elasticsearchClient: ReactiveElasticsearchClient, val batchOptions: BatchOptions? = null, refreshPolicy: Refresh = Refresh.True, metrics: WowMetrics = WowMetrics.NONE, indexNaming: ElasticsearchIndexNaming) : SnapshotStore

Constructors

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

constructor(elasticsearchClient: ReactiveElasticsearchClient, batchOptions: BatchOptions? = null, refreshPolicy: Refresh = Refresh.True, metrics: WowMetrics = WowMetrics.NONE)

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

Types

Companion

object Companion

Properties

batchOptions

val batchOptions: BatchOptions?

name

open override val name: String

runtimeResource

val runtimeResource: RuntimeResource

The batch writer of this store's snapshots, 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()

load

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

save

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