elasticmagic-transport/dev.evo.elasticmagic.transport

Package-level declarations

Types

class ApiRequest<ResultT>( val method: Method, val path: String, val parameters: Parameters = emptyMap(), val body: Serializer.ObjectCtx? = null, val serde: Serde, val processResponse: (ApiResponse) -> ResultT) : Request<Serializer.ObjectCtx, ApiResponse, ResultT>

ApiResponse

class ApiResponse(val statusCode: Int, val headers: Map<String, List<String>>, val content: Deserializer.ObjectCtx) : Response<Deserializer.ObjectCtx>

Auth

sealed class Auth

BaseGzipEncoder

abstract class BaseGzipEncoder : ContentEncoder

BulkRequest

class BulkRequest<ResultT>( val method: Method, val path: String, val parameters: Parameters = emptyMap(), val body: List<Serializer.ObjectCtx>, val serde: Serde.OneLineJson, val processResponse: (ApiResponse) -> ResultT) : Request<List<Serializer.ObjectCtx>, ApiResponse, ResultT>

CatRequest

class CatRequest<ResultT>( catPath: String, val parameters: Parameters = emptyMap(), val errorSerde: Serde, val processResponse: (CatResponse) -> ResultT) : Request<Nothing, CatResponse, ResultT>

CatResponse

class CatResponse(val statusCode: Int, val headers: Map<String, List<String>>, val content: List<List<String>>) : Response<List<List<String>>>

CausedBy

data class CausedBy(val type: String, val reason: String)

ContentEncoder

interface ContentEncoder : Appendable

ElasticsearchException

open class ElasticsearchException(msg: String) : Exception

ElasticsearchTransport

abstract class ElasticsearchTransport(val baseUrl: String, config: ElasticsearchTransport.Config)

ErrorCause

data class ErrorCause(val type: String, val reason: String, val resourceId: String?, val resourceType: String?, val line: Int?, val col: Int?)

ErrorReason

data class ErrorReason( val type: String, val reason: String, val resourceId: String?, val resourceType: String?, val script: String?, val scriptStack: List<String>, val causedBy: CausedBy?)

FailedShard

data class FailedShard(val shard: Int, val index: String, val node: String, val reason: ErrorReason)

GzipEncoder

expect class GzipEncoder : BaseGzipEncoder

actual class GzipEncoder : BaseGzipEncoder

IdentityEncoder

class IdentityEncoder : ContentEncoder

Method

enum Method : Enum<Method>

Parameters

typealias Parameters = Map<String, List<String>>

PlainRequest

class PlainRequest( val method: Method, val path: String, val parameters: Parameters, val content: ByteArray, val textContent: String?, val contentType: String, val contentEncoding: String?, val acceptContentType: String?)

PlainResponse

class PlainResponse(val statusCode: Int, val headers: Map<String, List<String>>, val contentType: String?, val content: String)

PreservingOriginGzipEncoder

class PreservingOriginGzipEncoder : BaseGzipEncoder

Request

abstract class Request<out BodyT, ResponseT, out ResultT>

Response

interface Response<T>

ResponseResult

sealed class ResponseResult<T>

Tracker

interface Tracker

TransportError

sealed class TransportError

Functions

Parameters

fun Parameters(vararg params: Pair<String, Any?>): Parameters

parameterToString

fun parameterToString(v: Any?): String?