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

Package-level declarations

Types

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

class ElasticsearchEventStreamQueryBackendFactory(elasticsearchClient: ReactiveElasticsearchClient, queryBatchSize: Int = DEFAULT_SEARCH_BATCH_SIZE, queryKeepAlive: Duration = DEFAULT_PIT_KEEP_ALIVE, indexMappingResolver: ElasticsearchIndexMappingResolver = ElasticsearchIndexMappingResolver(elasticsearchClient), schemaSources: List<QuerySchemaSource> = emptyList()) : AbstractEventStreamQueryBackendFactory