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
suspend fun <P, T> checkAsyncResult(task: AsyncResult<P, T>): TaskResult<P, T>
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
operator fun get(indexName: String): ElasticsearchIndex
Link copied to clipboard
suspend fun getCompilers(): CompilerSet
Link copied to clipboard
suspend fun getVersion(): Version<*>
Link copied to clipboard
suspend fun indexExists(indexName: String, allowNoIndices: Boolean? = null, ignoreUnavailable: Boolean? = null): Boolean
Link copied to clipboard
Link copied to clipboard
suspend fun ping(): PingResult
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
suspend fun <P, T> waitAsyncResult(task: AsyncResult<P, T>): TaskResult<P, T & Any>

Properties

Link copied to clipboard
Link copied to clipboard
Link copied to clipboard