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

ElasticsearchEventStreamQueryService

class ElasticsearchEventStreamQueryService(val namedAggregate: NamedAggregate, elasticsearchClient: ReactiveElasticsearchClient) : EventStreamQueryService

Constructors

ElasticsearchEventStreamQueryService

constructor(namedAggregate: NamedAggregate, elasticsearchClient: ReactiveElasticsearchClient)

Properties

open override val aggregateName: String

open override val contextName: String

open override val namedAggregate: NamedAggregate

Functions

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

isSameAggregateName

open fun isSameAggregateName(other: NamedAggregate): Boolean

isSameBoundedContext

open fun isSameBoundedContext(other: NamedBoundedContext): Boolean

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

toEventStreamIndexName

fun NamedAggregate.toEventStreamIndexName(): String

toSnapshotIndexName

fun NamedAggregate.toSnapshotIndexName(): String