trait Elasticsearch extends AnyRef
Represents the Monix Elasticsearch client which can be created using the builders from its companion object.
- Self Type
- Elasticsearch
- Source
- Elasticsearch.scala
- Alphabetic
- By Inheritance
- Elasticsearch
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def bulkExecuteRequest(requests: Seq[BulkCompatibleRequest]): Task[Response[BulkResponse]]
Execute bulk requests
Execute bulk requests
- requests
some BulkCompatibleRequest
- returns
a Task with Response with BulkResponse
- def bulkRequestSink(es: Elasticsearch = this): Consumer[Seq[BulkCompatibleRequest], Unit]
Bulk execute es requests
Bulk execute es requests
- returns
an Consumer that receives a list of BulkCompatibleRequest
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- def close: Task[Unit]
Closes the underlying ElasticClient.
- def createIndex(request: CreateIndexRequest): Task[Response[CreateIndexResponse]]
Execute a single create index request
Execute a single create index request
- request
a create index request
- returns
a Task with Response with CreateIndexRequest
- def deleteIndex(request: DeleteIndexRequest): Task[Response[DeleteIndexResponse]]
Execute a single delete index request
Execute a single delete index request
- request
a delete index request
- returns
a Task with Response with DeleteIndexResponse
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- def getById(request: GetRequest): Task[Response[GetResponse]]
Get a document by id
Get a document by id
- request
a GetRequest
- returns
a Task with Response with GetResponse
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def getIndex(request: GetIndexRequest): Task[Response[Map[String, GetIndexResponse]]]
Get index info
Get index info
- request
a GetIndexRequest
- returns
a Task with Response with GetIndexResponse
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- def refresh(first: String, rest: String*): Task[Response[RefreshIndexResponse]]
- def refresh(indexes: Iterable[String]): Task[Response[RefreshIndexResponse]]
Refresh indexes
Refresh indexes
- indexes
names of indexes
- returns
a Task with Response with RefreshIndexResponse
- def scroll(searchRequest: SearchRequest): Observable[SearchHit]
Retrieve large sets of results from a single scrolling search request.
Retrieve large sets of results from a single scrolling search request.
- searchRequest
a SearchRequest object
- returns
an Observable that emits the SearchHit
- def search(request: SearchRequest): Task[Response[SearchResponse]]
Execute a single search request
Execute a single search request
- request
a search request
- returns
a Task with Response with SearchResponse
- def singleCount(request: CountRequest): Task[Response[CountResponse]]
Execute a single count request
Execute a single count request
- request
a count request
- returns
a Task with Response with CountResponse
- def singleDeleteById(request: DeleteByIdRequest): Task[Response[DeleteResponse]]
Execute a single delete by id request
Execute a single delete by id request
- request
a delete by id request
- returns
a Task with Response with DeleteResponse
- def singleDeleteByQuery(request: DeleteByQueryRequest): Task[Response[DeleteByQueryResponse]]
Execute a single delete by query request
Execute a single delete by query request
- request
a delete by query request
- returns
a Task with Response with DeleteByQueryResponse
- def singleUpdate(request: UpdateRequest): Task[Response[UpdateResponse]]
Execute a single update request
Execute a single update request
- request
a update request
- returns
a Task with Response with UpdateResponse
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()