ElasticsearchCluster

class ElasticsearchCluster( val transport: ElasticsearchTransport, val apiSerde: Serde, val bulkSerde: Serde.OneLineJson, compilers: CompilerSet? = null)

Constructors

suspend fun createIndex( indexName: String, mapping: Document, settings: Params = Params(), aliases: Params = Params(), waitForActiveShards: Boolean? = null, masterTimeout: String? = null, timeout: String? = null): CreateIndexResult

suspend fun deleteIndex( indexName: String, allowNoIndices: Boolean? = null, masterTimeout: String? = null, timeout: String? = null): DeleteIndexResult

operator fun get(indexName: String): ElasticsearchIndex

suspend fun getVersion(): Version<*>

suspend fun indexExists(indexName: String, allowNoIndices: Boolean? = null, ignoreUnavailable: Boolean? = null): Boolean

suspend fun ping(): PingResult

suspend fun updateMapping( indexName: String, mapping: Document, allowNoIndices: Boolean? = null, ignoreUnavailable: Boolean? = null, writeIndexOnly: Boolean? = null, masterTimeout: String? = null, timeout: String? = null): UpdateMappingResult