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

ElasticsearchEventStreamQueryBackend

class ElasticsearchEventStreamQueryBackend(val namedAggregate: NamedAggregate, val elasticsearchClient: ReactiveElasticsearchClient, val filterCompiler: AbstractElasticsearchFilterCompiler = EventStreamFilterCompiler, queryBatchSize: Int = DEFAULT_SEARCH_BATCH_SIZE, queryKeepAlive: Duration = DEFAULT_PIT_KEEP_ALIVE) : AbstractElasticsearchQueryBackend, EventStreamQueryBackend

Constructors

constructor(namedAggregate: NamedAggregate, elasticsearchClient: ReactiveElasticsearchClient, filterCompiler: AbstractElasticsearchFilterCompiler = EventStreamFilterCompiler, queryBatchSize: Int = DEFAULT_SEARCH_BATCH_SIZE, queryKeepAlive: Duration = DEFAULT_PIT_KEEP_ALIVE)

Properties

elasticsearchClient

open override val elasticsearchClient: ReactiveElasticsearchClient

filterCompiler

open override val filterCompiler: AbstractElasticsearchFilterCompiler

indexName

open override val indexName: String

namedAggregate

open override val namedAggregate: NamedAggregate