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

AbstractElasticsearchQueryBackend

abstract class AbstractElasticsearchQueryBackend : QueryBackend

Inheritors

ElasticsearchEventStreamQueryBackend

ElasticsearchSnapshotQueryBackend

Constructors

AbstractElasticsearchQueryBackend

constructor()

Properties

cursorPositions

open override val cursorPositions: CursorPositionCodec

elasticsearchClient

abstract val elasticsearchClient: ReactiveElasticsearchClient

abstract val indexName: String

Functions

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

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

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

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