wow-elasticsearch/me.ahoo.wow.elasticsearch.query.event/ElasticsearchEventStreamQueryService

ElasticsearchEventStreamQueryService

class ElasticsearchEventStreamQueryService(val namedAggregate: NamedAggregate, val elasticsearchClient: ReactiveElasticsearchClient, val conditionConverter: ConditionConverter<Query> = EventStreamConditionConverter) : AbstractElasticsearchQueryService<DomainEventStream> , EventStreamQueryService

Constructors

Link copied to clipboard
constructor(namedAggregate: NamedAggregate, elasticsearchClient: ReactiveElasticsearchClient, conditionConverter: ConditionConverter<Query> = EventStreamConditionConverter)

Properties

Link copied to clipboard
open override val aggregateName: String
Link copied to clipboard
open override val conditionConverter: ConditionConverter<Query>
Link copied to clipboard
open override val contextName: String
Link copied to clipboard
open override val elasticsearchClient: ReactiveElasticsearchClient
Link copied to clipboard
open override val indexName: String
Link copied to clipboard
open override val namedAggregate: NamedAggregate

Functions

Link copied to clipboard
open override fun count(condition: Condition): Mono<Long>
Link copied to clipboard
open override fun dynamicList(listQuery: IListQuery): Flux<DynamicDocument>
Link copied to clipboard
open override fun dynamicPaged(pagedQuery: IPagedQuery): Mono<PagedList<DynamicDocument>>
Link copied to clipboard
open override fun dynamicSingle(singleQuery: ISingleQuery): Mono<DynamicDocument>
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
open override fun list(listQuery: IListQuery): Flux<DomainEventStream>
Link copied to clipboard
open override fun paged(pagedQuery: IPagedQuery): Mono<PagedList<DomainEventStream>>
Link copied to clipboard
open override fun single(singleQuery: ISingleQuery): Mono<DomainEventStream>
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
open override fun toTypedResult(document: DynamicDocument): DomainEventStream