ElasticsearchSnapshotRepository

class ElasticsearchSnapshotRepository(elasticsearchClient: ReactiveElasticsearchClient, refreshPolicy: Refresh = Refresh.True) : SnapshotRepository

Constructors

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

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

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

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

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