Packages

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
Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Elasticsearch
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def bulkExecuteRequest(requests: Seq[BulkCompatibleRequest]): Task[Response[BulkResponse]]

    Execute bulk requests

    Execute bulk requests

    requests

    some BulkCompatibleRequest

    returns

    a Task with Response with BulkResponse

  6. 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

  7. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  8. def close: Task[Unit]

    Closes the underlying ElasticClient.

  9. 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

  10. 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

  11. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  12. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  13. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  14. 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

  15. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  16. 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

  17. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  18. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  19. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  20. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  21. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  22. def refresh(first: String, rest: String*): Task[Response[RefreshIndexResponse]]
  23. def refresh(indexes: Iterable[String]): Task[Response[RefreshIndexResponse]]

    Refresh indexes

    Refresh indexes

    indexes

    names of indexes

    returns

    a Task with Response with RefreshIndexResponse

  24. 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

  25. 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

  26. 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

  27. 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

  28. 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

  29. 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

  30. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  31. def toString(): String
    Definition Classes
    AnyRef → Any
  32. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  33. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  34. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()

Inherited from AnyRef

Inherited from Any

Ungrouped