wow-elasticsearch/me.ahoo.wow.elasticsearch.query.snapshot/ElasticsearchSnapshotQueryService

ElasticsearchSnapshotQueryService

class ElasticsearchSnapshotQueryService<S : Any>(val namedAggregate: NamedAggregate, val elasticsearchClient: ReactiveElasticsearchClient, val conditionConverter: ConditionConverter<Query> = SnapshotConditionConverter) : AbstractElasticsearchQueryService<MaterializedSnapshot<S>> , SnapshotQueryService<S>

Constructors

constructor(namedAggregate: NamedAggregate, elasticsearchClient: ReactiveElasticsearchClient, conditionConverter: ConditionConverter<Query> = SnapshotConditionConverter)

Properties

aggregateName

open override val aggregateName: String

conditionConverter

open override val conditionConverter: ConditionConverter<Query>

contextName

open override val contextName: String

elasticsearchClient

open override val elasticsearchClient: ReactiveElasticsearchClient

indexName

open override val indexName: String

namedAggregate

open override val namedAggregate: NamedAggregate

Functions

count

open override fun count(condition: Condition): Mono<Long>

dynamicList

open override fun dynamicList(listQuery: IListQuery): Flux<DynamicDocument>

dynamicPaged

open override fun dynamicPaged(pagedQuery: IPagedQuery): Mono<PagedList<DynamicDocument>>

dynamicSingle

open override fun dynamicSingle(singleQuery: ISingleQuery): Mono<DynamicDocument>

isSameAggregateName

open fun isSameAggregateName(other: NamedAggregate): Boolean

isSameBoundedContext

open fun isSameBoundedContext(other: NamedBoundedContext): Boolean

list

open override fun list(listQuery: IListQuery): Flux<MaterializedSnapshot<S>>

paged

open override fun paged(pagedQuery: IPagedQuery): Mono<PagedList<MaterializedSnapshot<S>>>

single

open override fun single(singleQuery: ISingleQuery): Mono<MaterializedSnapshot<S>>

toEventStreamIndexName

fun NamedAggregate.toEventStreamIndexName(): String

toSnapshotIndexName

fun NamedAggregate.toSnapshotIndexName(): String

toTypedResult

open override fun toTypedResult(document: DynamicDocument): MaterializedSnapshot<S>