5.1.5

wow-elasticsearch/me.ahoo.wow.elasticsearch.query/AbstractElasticsearchQueryService

AbstractElasticsearchQueryService

abstract class AbstractElasticsearchQueryService<R : Any> : QueryService<R>

Inheritors

ElasticsearchEventStreamQueryService

ElasticsearchSnapshotQueryService

Constructors

AbstractElasticsearchQueryService

constructor()

Properties

open override val aggregateName: String

conditionConverter

abstract val conditionConverter: ConditionConverter<Query>

open override val contextName: String

elasticsearchClient

abstract val elasticsearchClient: ReactiveElasticsearchClient

abstract val indexName: String

abstract val namedAggregate: NamedAggregate

Functions

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

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

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

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

isSameAggregateName

open fun isSameAggregateName(other: NamedAggregate): Boolean

isSameBoundedContext

open fun isSameBoundedContext(other: NamedBoundedContext): Boolean

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

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

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

toEventStreamIndexName

fun NamedAggregate.toEventStreamIndexName(): String

toSnapshotIndexName

fun NamedAggregate.toSnapshotIndexName(): String

abstract fun toTypedResult(document: DynamicDocument): R