ElasticsearchCluster
class ElasticsearchCluster(val transport: ElasticsearchTransport, val apiSerde: Serde, val bulkSerde: Serde.OneLineJson, compilers: CompilerSet? = null)
Constructors
Link copied to clipboard
fun ElasticsearchCluster(transport: ElasticsearchTransport, serde: Serde.OneLineJson, compilers: CompilerSet? = null)
Link copied to clipboard
fun ElasticsearchCluster(transport: ElasticsearchTransport, apiSerde: Serde, bulkSerde: Serde.OneLineJson, compilers: CompilerSet? = null)
Functions
Link copied to clipboard
Link copied to clipboard
suspend fun createIndex(indexName: String, mapping: Document, settings: Params = Params(), aliases: Params = Params(), waitForActiveShards: Boolean? = null, masterTimeout: String? = null, timeout: String? = null): CreateIndexResult
Link copied to clipboard
suspend fun deleteIndex(indexName: String, allowNoIndices: Boolean? = null, masterTimeout: String? = null, timeout: String? = null): DeleteIndexResult
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
suspend fun indexExists(indexName: String, allowNoIndices: Boolean? = null, ignoreUnavailable: Boolean? = null): Boolean
Link copied to clipboard
suspend fun multiSearch(searchQueries: List<WithIndex<SearchQuery.Search<*>>>): MultiSearchQueryResult
Link copied to clipboard
Link copied to clipboard
suspend fun updateMapping(indexName: String, mapping: Document, allowNoIndices: Boolean? = null, ignoreUnavailable: Boolean? = null, writeIndexOnly: Boolean? = null, masterTimeout: String? = null, timeout: String? = null): UpdateMappingResult
Link copied to clipboard