Package org.springframework.data.elasticsearch.client.elc

Class ReactiveElasticsearchClient

java.lang.Object
co.elastic.clients.ApiClient<co.elastic.clients.transport.ElasticsearchTransport,ReactiveElasticsearchClient>
org.springframework.data.elasticsearch.client.elc.ReactiveElasticsearchClient
All Implemented Interfaces:
AutoCloseable
public class ReactiveElasticsearchClient extends co.elastic.clients.ApiClient<co.elastic.clients.transport.ElasticsearchTransport,ReactiveElasticsearchClient> implements AutoCloseable
Reactive version of ElasticsearchClient.
Since:
4.4
Author:
Peter-Josef Meisch

  • Field Summary

    Fields inherited from class co.elastic.clients.ApiClient

    transport, transportOptions

  • Constructor Summary

    Constructors
    Constructor
    Description
    ReactiveElasticsearchClient(co.elastic.clients.transport.ElasticsearchTransport transport)
     
    ReactiveElasticsearchClient(co.elastic.clients.transport.ElasticsearchTransport transport, co.elastic.clients.transport.TransportOptions transportOptions)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.BulkResponse>
    bulk(co.elastic.clients.elasticsearch.core.BulkRequest request)
     
    reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.BulkResponse>
    bulk(Function<co.elastic.clients.elasticsearch.core.BulkRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.BulkRequest>> fn)
     
    reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.ClearScrollResponse>
    clearScroll(co.elastic.clients.elasticsearch.core.ClearScrollRequest request)
     
    reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.ClearScrollResponse>
    clearScroll(Function<co.elastic.clients.elasticsearch.core.ClearScrollRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.ClearScrollRequest>> fn)
     
    void
    close()
     
    reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.ClosePointInTimeResponse>
    closePointInTime(co.elastic.clients.elasticsearch.core.ClosePointInTimeRequest request)
     
    reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.ClosePointInTimeResponse>
    closePointInTime(Function<co.elastic.clients.elasticsearch.core.ClosePointInTimeRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.ClosePointInTimeRequest>> fn)
     
    ReactiveElasticsearchClusterClient
    cluster()
     
    reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.DeleteResponse>
    delete(co.elastic.clients.elasticsearch.core.DeleteRequest request)
     
    reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.DeleteResponse>
    delete(Function<co.elastic.clients.elasticsearch.core.DeleteRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.DeleteRequest>> fn)
     
    reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.DeleteByQueryResponse>
    deleteByQuery(co.elastic.clients.elasticsearch.core.DeleteByQueryRequest request)
     
    reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.DeleteByQueryResponse>
    deleteByQuery(Function<co.elastic.clients.elasticsearch.core.DeleteByQueryRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.DeleteByQueryRequest>> fn)
     
    reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.DeleteScriptResponse>
    deleteScript(co.elastic.clients.elasticsearch.core.DeleteScriptRequest request)
     
    reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.DeleteScriptResponse>
    deleteScript(Function<co.elastic.clients.elasticsearch.core.DeleteScriptRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.DeleteScriptRequest>> fn)
     
    reactor.core.publisher.Mono<co.elastic.clients.transport.endpoints.BooleanResponse>
    exists(co.elastic.clients.elasticsearch.core.ExistsRequest request)
     
    <T> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.GetResponse<T>>
    get(co.elastic.clients.elasticsearch.core.GetRequest request, Class<T> tClass)
     
    <T> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.GetResponse<T>>
    get(Function<co.elastic.clients.elasticsearch.core.GetRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.GetRequest>> fn, Class<T> tClass)
     
    reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.GetScriptResponse>
    getScript(co.elastic.clients.elasticsearch.core.GetScriptRequest request)
     
    reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.GetScriptResponse>
    getScript(Function<co.elastic.clients.elasticsearch.core.GetScriptRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.GetScriptRequest>> fn)
     
    <T> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.IndexResponse>
    index(co.elastic.clients.elasticsearch.core.IndexRequest<T> request)
     
    <T> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.IndexResponse>
    index(Function<co.elastic.clients.elasticsearch.core.IndexRequest.Builder<T>,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.IndexRequest<T>>> fn)
     
    ReactiveElasticsearchIndicesClient
    indices()
     
    reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.InfoResponse>
    info()
     
    <T> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.MgetResponse<T>>
    mget(co.elastic.clients.elasticsearch.core.MgetRequest request, Class<T> clazz)
     
    <T> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.MgetResponse<T>>
    mget(Function<co.elastic.clients.elasticsearch.core.MgetRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.MgetRequest>> fn, Class<T> clazz)
     
    reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.OpenPointInTimeResponse>
    openPointInTime(co.elastic.clients.elasticsearch.core.OpenPointInTimeRequest request)
     
    reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.OpenPointInTimeResponse>
    openPointInTime(Function<co.elastic.clients.elasticsearch.core.OpenPointInTimeRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.OpenPointInTimeRequest>> fn)
     
    reactor.core.publisher.Mono<co.elastic.clients.transport.endpoints.BooleanResponse>
    ping()
     
    reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.PutScriptResponse>
    putScript(co.elastic.clients.elasticsearch.core.PutScriptRequest request)
     
    reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.PutScriptResponse>
    putScript(Function<co.elastic.clients.elasticsearch.core.PutScriptRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.PutScriptRequest>> fn)
     
    reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.ReindexResponse>
    reindex(co.elastic.clients.elasticsearch.core.ReindexRequest request)
     
    reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.ReindexResponse>
    reindex(Function<co.elastic.clients.elasticsearch.core.ReindexRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.ReindexRequest>> fn)
     
    <T> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.ScrollResponse<T>>
    scroll(co.elastic.clients.elasticsearch.core.ScrollRequest request, Class<T> tDocumentClass)
     
    <T> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.ScrollResponse<T>>
    scroll(Function<co.elastic.clients.elasticsearch.core.ScrollRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.ScrollRequest>> fn, Class<T> tDocumentClass)
     
    <T> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.search.ResponseBody<T>>
    search(co.elastic.clients.elasticsearch.core.SearchRequest request, Class<T> tDocumentClass)
     
    <T> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.search.ResponseBody<T>>
    search(Function<co.elastic.clients.elasticsearch.core.SearchRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.SearchRequest>> fn, Class<T> tDocumentClass)
     
    <T> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.SearchTemplateResponse<T>>
    searchTemplate(co.elastic.clients.elasticsearch.core.SearchTemplateRequest request, Class<T> tDocumentClass)
     
    <T> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.SearchTemplateResponse<T>>
    searchTemplate(Function<co.elastic.clients.elasticsearch.core.SearchTemplateRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.SearchTemplateRequest>> fn, Class<T> tDocumentClass)
     
    <T, P> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.UpdateResponse<T>>
    update(co.elastic.clients.elasticsearch.core.UpdateRequest<T,P> request, Class<T> clazz)
     
    <T, P> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.UpdateResponse<T>>
    update(Function<co.elastic.clients.elasticsearch.core.UpdateRequest.Builder<T,P>,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.UpdateRequest<T,P>>> fn, Class<T> clazz)
     
    ReactiveElasticsearchClient
    withTransportOptions(co.elastic.clients.transport.TransportOptions transportOptions)
     

    Methods inherited from class co.elastic.clients.ApiClient

    _jsonpMapper, _transport, _transportOptions, getDeserializer, withTransportOptions

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • ReactiveElasticsearchClient

      public ReactiveElasticsearchClient(co.elastic.clients.transport.ElasticsearchTransport transport)

    • ReactiveElasticsearchClient

      public ReactiveElasticsearchClient(co.elastic.clients.transport.ElasticsearchTransport transport, @Nullable co.elastic.clients.transport.TransportOptions transportOptions)

  • Method Details

    • withTransportOptions

      public ReactiveElasticsearchClient withTransportOptions(@Nullable co.elastic.clients.transport.TransportOptions transportOptions)
      Specified by:
      withTransportOptions in class co.elastic.clients.ApiClient<co.elastic.clients.transport.ElasticsearchTransport,ReactiveElasticsearchClient>

    • close

      public void close() throws Exception
      Specified by:
      close in interface AutoCloseable
      Throws:
      Exception

    • cluster

      public ReactiveElasticsearchClusterClient cluster()

    • indices

      public ReactiveElasticsearchIndicesClient indices()

    • info

      public reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.InfoResponse> info()

    • ping

      public reactor.core.publisher.Mono<co.elastic.clients.transport.endpoints.BooleanResponse> ping()

    • index

      public <T> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.IndexResponse> index(co.elastic.clients.elasticsearch.core.IndexRequest<T> request)

    • index

      public <T> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.IndexResponse> index(Function<co.elastic.clients.elasticsearch.core.IndexRequest.Builder<T>,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.IndexRequest<T>>> fn)

    • bulk

      public reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.BulkResponse> bulk(co.elastic.clients.elasticsearch.core.BulkRequest request)

    • bulk

      public reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.BulkResponse> bulk(Function<co.elastic.clients.elasticsearch.core.BulkRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.BulkRequest>> fn)

    • get

      public <T> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.GetResponse<T>> get(co.elastic.clients.elasticsearch.core.GetRequest request, Class<T> tClass)

    • exists

      public reactor.core.publisher.Mono<co.elastic.clients.transport.endpoints.BooleanResponse> exists(co.elastic.clients.elasticsearch.core.ExistsRequest request)

    • update

      public <T, P> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.UpdateResponse<T>> update(co.elastic.clients.elasticsearch.core.UpdateRequest<T,P> request, Class<T> clazz)

    • update

      public <T, P> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.UpdateResponse<T>> update(Function<co.elastic.clients.elasticsearch.core.UpdateRequest.Builder<T,P>,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.UpdateRequest<T,P>>> fn, Class<T> clazz)

    • get

      public <T> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.GetResponse<T>> get(Function<co.elastic.clients.elasticsearch.core.GetRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.GetRequest>> fn, Class<T> tClass)

    • mget

      public <T> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.MgetResponse<T>> mget(co.elastic.clients.elasticsearch.core.MgetRequest request, Class<T> clazz)

    • mget

      public <T> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.MgetResponse<T>> mget(Function<co.elastic.clients.elasticsearch.core.MgetRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.MgetRequest>> fn, Class<T> clazz)

    • reindex

      public reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.ReindexResponse> reindex(co.elastic.clients.elasticsearch.core.ReindexRequest request)

    • reindex

      public reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.ReindexResponse> reindex(Function<co.elastic.clients.elasticsearch.core.ReindexRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.ReindexRequest>> fn)

    • delete

      public reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.DeleteResponse> delete(co.elastic.clients.elasticsearch.core.DeleteRequest request)

    • delete

      public reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.DeleteResponse> delete(Function<co.elastic.clients.elasticsearch.core.DeleteRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.DeleteRequest>> fn)

    • deleteByQuery

      public reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.DeleteByQueryResponse> deleteByQuery(co.elastic.clients.elasticsearch.core.DeleteByQueryRequest request)

    • deleteByQuery

      public reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.DeleteByQueryResponse> deleteByQuery(Function<co.elastic.clients.elasticsearch.core.DeleteByQueryRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.DeleteByQueryRequest>> fn)

    • search

      public <T> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.search.ResponseBody<T>> search(co.elastic.clients.elasticsearch.core.SearchRequest request, Class<T> tDocumentClass)

    • search

      public <T> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.search.ResponseBody<T>> search(Function<co.elastic.clients.elasticsearch.core.SearchRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.SearchRequest>> fn, Class<T> tDocumentClass)

    • searchTemplate

      public <T> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.SearchTemplateResponse<T>> searchTemplate(co.elastic.clients.elasticsearch.core.SearchTemplateRequest request, Class<T> tDocumentClass)
      Since:
      5.1

    • searchTemplate

      public <T> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.SearchTemplateResponse<T>> searchTemplate(Function<co.elastic.clients.elasticsearch.core.SearchTemplateRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.SearchTemplateRequest>> fn, Class<T> tDocumentClass)
      Since:
      5.1

    • scroll

      public <T> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.ScrollResponse<T>> scroll(co.elastic.clients.elasticsearch.core.ScrollRequest request, Class<T> tDocumentClass)

    • scroll

      public <T> reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.ScrollResponse<T>> scroll(Function<co.elastic.clients.elasticsearch.core.ScrollRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.ScrollRequest>> fn, Class<T> tDocumentClass)

    • clearScroll

      public reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.ClearScrollResponse> clearScroll(co.elastic.clients.elasticsearch.core.ClearScrollRequest request)

    • clearScroll

      public reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.ClearScrollResponse> clearScroll(Function<co.elastic.clients.elasticsearch.core.ClearScrollRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.ClearScrollRequest>> fn)

    • openPointInTime

      public reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.OpenPointInTimeResponse> openPointInTime(co.elastic.clients.elasticsearch.core.OpenPointInTimeRequest request)
      Since:
      5.0

    • openPointInTime

      public reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.OpenPointInTimeResponse> openPointInTime(Function<co.elastic.clients.elasticsearch.core.OpenPointInTimeRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.OpenPointInTimeRequest>> fn)
      Since:
      5.0

    • closePointInTime

      public reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.ClosePointInTimeResponse> closePointInTime(co.elastic.clients.elasticsearch.core.ClosePointInTimeRequest request)
      Since:
      5.0

    • closePointInTime

      public reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.ClosePointInTimeResponse> closePointInTime(Function<co.elastic.clients.elasticsearch.core.ClosePointInTimeRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.ClosePointInTimeRequest>> fn)
      Since:
      5.0

    • putScript

      public reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.PutScriptResponse> putScript(co.elastic.clients.elasticsearch.core.PutScriptRequest request)
      Since:
      5.1

    • putScript

      public reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.PutScriptResponse> putScript(Function<co.elastic.clients.elasticsearch.core.PutScriptRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.PutScriptRequest>> fn)
      Since:
      5.1

    • getScript

      public reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.GetScriptResponse> getScript(co.elastic.clients.elasticsearch.core.GetScriptRequest request)
      Since:
      5.1

    • getScript

      public reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.GetScriptResponse> getScript(Function<co.elastic.clients.elasticsearch.core.GetScriptRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.GetScriptRequest>> fn)
      Since:
      5.1

    • deleteScript

      public reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.DeleteScriptResponse> deleteScript(co.elastic.clients.elasticsearch.core.DeleteScriptRequest request)
      Since:
      5.1

    • deleteScript

      public reactor.core.publisher.Mono<co.elastic.clients.elasticsearch.core.DeleteScriptResponse> deleteScript(Function<co.elastic.clients.elasticsearch.core.DeleteScriptRequest.Builder,co.elastic.clients.util.ObjectBuilder<co.elastic.clients.elasticsearch.core.DeleteScriptRequest>> fn)
      Since:
      5.1