search-client/com.jillesvangurp.ktsearch/KtorRestClient

KtorRestClient

class KtorRestClient(nodes: Node = arrayOf( Node( "localhost", 9200 ) ), https: Boolean = false, user: String? = null, password: String? = null, logging: Boolean = false, nodeSelector: NodeSelector = RoundRobinNodeSelector(nodes), elasticApiKey: String? = null, client: HttpClient = defaultKtorHttpClient( logging = logging, user = user, password = password, elasticApiKey = elasticApiKey )) : RestClient, Closeable

Ktor-client implementation of the RestClient.

Constructors

KtorRestClient

constructor(host: String = "localhost", port: Int = 9200, https: Boolean = false, user: String? = null, password: String? = null, logging: Boolean = false, elasticApiKey: String? = null, client: HttpClient = defaultKtorHttpClient( logging = logging, user = user, password = password, elasticApiKey = elasticApiKey ))

constructor(vararg nodes: Node = arrayOf( Node( "localhost", 9200 ) ), https: Boolean = false, user: String? = null, password: String? = null, logging: Boolean = false, nodeSelector: NodeSelector = RoundRobinNodeSelector(nodes), elasticApiKey: String? = null, client: HttpClient = defaultKtorHttpClient( logging = logging, user = user, password = password, elasticApiKey = elasticApiKey ))

Functions

open override fun close()

delete

suspend fun RestClient.delete(block: SearchAPIRequest.() -> Unit): Result<RestResponse.Status2XX>

doRequest

open suspend override fun doRequest(pathComponents: List<String>, httpMethod: HttpMethod, parameters: Map<String, Any>?, payload: String?, contentType: ContentType, headers: Map<String, Any>?): RestResponse

get

suspend fun RestClient.get(block: SearchAPIRequest.() -> Unit): Result<RestResponse.Status2XX>

head

suspend fun RestClient.head(block: SearchAPIRequest.() -> Unit): RestResponse

nextNode

open suspend override fun nextNode(): Node

post

suspend fun RestClient.post(block: SearchAPIRequest.() -> Unit): Result<RestResponse.Status2XX>

put

suspend fun RestClient.put(block: SearchAPIRequest.() -> Unit): Result<RestResponse.Status2XX>