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

AbstractElasticsearchQueryBackend

abstract class AbstractElasticsearchQueryBackend : QueryBackend

A query backend over one index. Before the aggregate's first write its index does not exist yet; every read of a missing index answers nothing (no rows, a count of 0, no groups), as the snapshot store's load does, rather than failing.

Inheritors

ElasticsearchEventStreamQueryBackend

ElasticsearchSnapshotQueryBackend

Constructors

AbstractElasticsearchQueryBackend

constructor()

Properties

cursorPositions

open override val cursorPositions: CursorPositionCodec

elasticsearchClient

abstract val elasticsearchClient: ReactiveElasticsearchClient

indexName

abstract val indexName: String

Functions

aggregate

open override fun aggregate(query: AdmittedQuery<AggregationQuery>, window: GroupWindow): Flux<ObjectNode>

A missing index has no groups; without any, the core emits the empty summary, as it does over no records.

count

open override fun count(query: AdmittedQuery<FilterExpression>): Mono<Long>

page

open override fun page(query: AdmittedQuery<Queryable<*>>, window: PageWindow): Mono<BackendPage>

stream

open override fun stream(query: AdmittedQuery<IListQuery>): Flux<ObjectNode>