Package org.springframework.data.elasticsearch.client.erhlc

Class DefaultReactiveElasticsearchClient

java.lang.Object
org.springframework.data.elasticsearch.client.erhlc.DefaultReactiveElasticsearchClient
All Implemented Interfaces:
ReactiveElasticsearchClient, ReactiveElasticsearchClient.Cluster, ReactiveElasticsearchClient.Indices
@Deprecated public class DefaultReactiveElasticsearchClient extends Object implements ReactiveElasticsearchClient, ReactiveElasticsearchClient.Indices, ReactiveElasticsearchClient.Cluster
Deprecated.
since 5.0
A WebClient based ReactiveElasticsearchClient that connects to an Elasticsearch cluster using HTTP.
Since:
3.2
Author:
Christoph Strobl, Mark Paluch, Peter-Josef Meisch, Huw Ayling-Miller, Henrique Amaral, Roman Puchkovskiy, Russell Parry, Thomas Geese, Brian Clozel, Farid Faoudi, George Popides, Sijia Liu
See Also:

  • Nested Class Summary

    Nested classes/interfaces inherited from interface org.springframework.data.elasticsearch.client.erhlc.ReactiveElasticsearchClient

    ReactiveElasticsearchClient.Cluster, ReactiveElasticsearchClient.Indices, ReactiveElasticsearchClient.ReactiveElasticsearchClientCallback<T>, ReactiveElasticsearchClient.Status

  • Constructor Summary

    Constructors
    Constructor
    Description
    DefaultReactiveElasticsearchClient(HostProvider<?> hostProvider)
    Deprecated.
    Create a new DefaultReactiveElasticsearchClient using the given HostProvider to obtain server connections.
    DefaultReactiveElasticsearchClient(HostProvider<?> hostProvider, RequestCreator requestCreator)
    Deprecated.
    Create a new DefaultReactiveElasticsearchClient using the given HostProvider to obtain server connections and the given RequestCreator.

  • Method Summary

    Modifier and Type
    Method
    Description
    reactor.core.publisher.Flux<org.elasticsearch.search.aggregations.Aggregation>
    aggregate(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.search.SearchRequest searchRequest)
    Deprecated.
    Execute the given SearchRequest with aggregations against the search API.
    reactor.core.publisher.Mono<org.elasticsearch.action.bulk.BulkResponse>
    bulk(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.bulk.BulkRequest bulkRequest)
    Deprecated.
    Execute a BulkRequest against the bulk API.
    reactor.core.publisher.Mono<Void>
    closeIndex(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.admin.indices.close.CloseIndexRequest closeIndexRequest)
    Deprecated.
    Execute the given CloseIndexRequest against the indices API.
    ReactiveElasticsearchClient.Cluster
    cluster()
    Deprecated.
    Gain Access to cluster related commands.
    reactor.core.publisher.Mono<Long>
    count(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.search.SearchRequest searchRequest)
    Deprecated.
    Execute a SearchRequest against the search API.
    static ReactiveElasticsearchClient
    create(ClientConfiguration clientConfiguration)
    Deprecated.
    Create a new DefaultReactiveElasticsearchClient given ClientConfiguration.
    static ReactiveElasticsearchClient
    create(ClientConfiguration clientConfiguration, RequestCreator requestCreator)
    Deprecated.
    Create a new DefaultReactiveElasticsearchClient given ClientConfiguration and RequestCreator.
    static ReactiveElasticsearchClient
    create(org.springframework.http.HttpHeaders headers, String... hosts)
    Deprecated.
    Create a new DefaultReactiveElasticsearchClient aware of the given nodes in the cluster.
    reactor.core.publisher.Mono<Boolean>
    createIndex(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.admin.indices.create.CreateIndexRequest createIndexRequest)
    Deprecated.
    Execute the given CreateIndexRequest against the indices API.
    reactor.core.publisher.Mono<Boolean>
    createIndex(org.springframework.http.HttpHeaders headers, org.elasticsearch.client.indices.CreateIndexRequest createIndexRequest)
    Deprecated.
    Execute the given CreateIndexRequest against the indices API.
    reactor.core.publisher.Mono<org.elasticsearch.action.delete.DeleteResponse>
    delete(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.delete.DeleteRequest deleteRequest)
    Deprecated.
    Execute the given DeleteRequest against the delete API to remove a document.
    reactor.core.publisher.Mono<org.elasticsearch.index.reindex.BulkByScrollResponse>
    deleteBy(org.springframework.http.HttpHeaders headers, org.elasticsearch.index.reindex.DeleteByQueryRequest deleteRequest)
    Deprecated.
    Execute a DeleteByQueryRequest against the delete by query API.
    reactor.core.publisher.Mono<Boolean>
    deleteIndex(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest request)
    Deprecated.
    Execute the given DeleteIndexRequest against the indices API.
    reactor.core.publisher.Mono<Boolean>
    deleteTemplate(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.admin.indices.template.delete.DeleteIndexTemplateRequest deleteIndexTemplateRequest)
    Deprecated.
    Execute the given DeleteIndexTemplateRequest against the indices API.
    <T> reactor.core.publisher.Mono<T>
    execute(ReactiveElasticsearchClient.ReactiveElasticsearchClientCallback<T> callback)
    Deprecated.
    Compose the actual command/s to run against Elasticsearch using the underlying connection.
    reactor.core.publisher.Mono<Boolean>
    exists(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.get.GetRequest getRequest)
    Deprecated.
    Checks for the existence of a document.
    reactor.core.publisher.Mono<Boolean>
    existsIndex(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.admin.indices.get.GetIndexRequest request)
    Deprecated.
    Execute the given GetIndexRequest against the indices API.
    reactor.core.publisher.Mono<Boolean>
    existsIndex(org.springframework.http.HttpHeaders headers, org.elasticsearch.client.indices.GetIndexRequest request)
    Deprecated.
    Execute the given GetIndexRequest against the indices API.
    reactor.core.publisher.Mono<Boolean>
    existsTemplate(org.springframework.http.HttpHeaders headers, org.elasticsearch.client.indices.IndexTemplatesExistRequest indexTemplatesExistRequest)
    Deprecated.
    Execute the given IndexTemplatesExistRequest against the indices API.
    reactor.core.publisher.Mono<Void>
    flushIndex(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.admin.indices.flush.FlushRequest flushRequest)
    Deprecated.
    Execute the given RefreshRequest against the indices API.
    reactor.core.publisher.Mono<org.elasticsearch.index.get.GetResult>
    get(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.get.GetRequest getRequest)
    Deprecated.
    Execute the given GetRequest against the get API to retrieve a document by id.
    reactor.core.publisher.Mono<org.elasticsearch.client.GetAliasesResponse>
    getAliases(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.admin.indices.alias.get.GetAliasesRequest getAliasesRequest)
    Deprecated.
    Execute the given GetAliasesRequest against the indices API.
    reactor.core.publisher.Mono<org.elasticsearch.client.indices.GetFieldMappingsResponse>
    getFieldMapping(org.springframework.http.HttpHeaders headers, org.elasticsearch.client.indices.GetFieldMappingsRequest getFieldMappingsRequest)
    Deprecated.
    Execute the given GetFieldMappingsRequest against the indices API.
    reactor.core.publisher.Mono<org.elasticsearch.client.indices.GetIndexResponse>
    getIndex(org.springframework.http.HttpHeaders headers, org.elasticsearch.client.indices.GetIndexRequest getIndexRequest)
    Deprecated.
    Execute the given GetIndexRequest against the indices API.
    reactor.core.publisher.Mono<org.elasticsearch.action.admin.indices.mapping.get.GetMappingsResponse>
    getMapping(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.admin.indices.mapping.get.GetMappingsRequest getMappingsRequest)
    Deprecated.
    reactor.core.publisher.Mono<org.elasticsearch.client.indices.GetMappingsResponse>
    getMapping(org.springframework.http.HttpHeaders headers, org.elasticsearch.client.indices.GetMappingsRequest getMappingsRequest)
    Deprecated.
    Execute the given GetMappingsRequest against the indices API.
    reactor.core.publisher.Mono<org.elasticsearch.action.admin.indices.settings.get.GetSettingsResponse>
    getSettings(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.admin.indices.settings.get.GetSettingsRequest getSettingsRequest)
    Deprecated.
    Execute the given GetSettingsRequest against the indices API.
    reactor.core.publisher.Mono<org.elasticsearch.client.indices.GetIndexTemplatesResponse>
    getTemplate(org.springframework.http.HttpHeaders headers, org.elasticsearch.client.indices.GetIndexTemplatesRequest getIndexTemplatesRequest)
    Deprecated.
    Execute the given GetIndexTemplatesRequest against the indices API.
    reactor.core.publisher.Mono<org.elasticsearch.action.admin.cluster.health.ClusterHealthResponse>
    health(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.admin.cluster.health.ClusterHealthRequest clusterHealthRequest)
    Deprecated.
    Execute the given {ClusterHealthRequest} against the cluster API.
    reactor.core.publisher.Mono<org.elasticsearch.action.index.IndexResponse>
    index(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.index.IndexRequest indexRequest)
    Deprecated.
    Execute the given IndexRequest against the index API to index a document.
    ReactiveElasticsearchClient.Indices
    indices()
    Deprecated.
    Gain access to index related commands.
    reactor.core.publisher.Mono<org.elasticsearch.action.main.MainResponse>
    info(org.springframework.http.HttpHeaders headers)
    Deprecated.
    Get the cluster info otherwise provided when sending an HTTP request to port 9200.
    reactor.core.publisher.Flux<org.elasticsearch.action.get.MultiGetItemResponse>
    multiGet(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.get.MultiGetRequest multiGetRequest)
    Deprecated.
    Execute the given MultiGetRequest against the multi-get API to retrieve multiple documents by id.
    reactor.core.publisher.Mono<Void>
    openIndex(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.admin.indices.open.OpenIndexRequest request)
    Deprecated.
    Execute the given OpenIndexRequest against the indices API.
    reactor.core.publisher.Mono<Boolean>
    ping(org.springframework.http.HttpHeaders headers)
    Deprecated.
    Pings the remote Elasticsearch cluster and emits true if the ping succeeded, false otherwise.
    reactor.core.publisher.Mono<Boolean>
    putMapping(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.admin.indices.mapping.put.PutMappingRequest putMappingRequest)
    Deprecated.
    Execute the given PutMappingRequest against the indices API.
    reactor.core.publisher.Mono<Boolean>
    putMapping(org.springframework.http.HttpHeaders headers, org.elasticsearch.client.indices.PutMappingRequest putMappingRequest)
    Deprecated.
    Execute the given PutMappingRequest against the indices API.
    reactor.core.publisher.Mono<Boolean>
    putTemplate(org.springframework.http.HttpHeaders headers, org.elasticsearch.client.indices.PutIndexTemplateRequest putIndexTemplateRequest)
    Deprecated.
    Execute the given PutIndexTemplateRequest against the indices API.
    reactor.core.publisher.Mono<Void>
    refreshIndex(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.admin.indices.refresh.RefreshRequest refreshRequest)
    Deprecated.
    Execute the given RefreshRequest against the indices API.
    reactor.core.publisher.Mono<org.elasticsearch.index.reindex.BulkByScrollResponse>
    reindex(org.springframework.http.HttpHeaders headers, org.elasticsearch.index.reindex.ReindexRequest reindexRequest)
    Deprecated.
    Execute the given ReindexRequest against the reindex API.
    reactor.core.publisher.Flux<org.elasticsearch.search.SearchHit>
    scroll(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.search.SearchRequest searchRequest)
    Deprecated.
    Execute the given SearchRequest against the search scroll API.
    reactor.core.publisher.Flux<org.elasticsearch.search.SearchHit>
    search(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.search.SearchRequest searchRequest)
    Deprecated.
    Execute the given SearchRequest against the search API.
    reactor.core.publisher.Mono<org.elasticsearch.action.search.SearchResponse>
    searchForResponse(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.search.SearchRequest searchRequest)
    Deprecated.
    Execute the given SearchRequest against the search API returning the whole response in one Mono.
    reactor.core.publisher.Flux<org.elasticsearch.search.SearchHit>
    searchTemplate(org.springframework.http.HttpHeaders headers, org.elasticsearch.script.mustache.SearchTemplateRequest searchTemplateRequest)
    Deprecated.
    Executes a SearchTemplateRequest against the search template API.
    void
    setHeadersSupplier(Supplier<HttpHeaders> headersSupplier)
    Deprecated.
     
    reactor.core.publisher.Mono<ReactiveElasticsearchClient.Status>
    status()
    Deprecated.
    Get the current client ReactiveElasticsearchClient.Status.
    reactor.core.publisher.Mono<String>
    submitReindex(org.springframework.http.HttpHeaders headers, org.elasticsearch.index.reindex.ReindexRequest reindexRequest)
    Deprecated.
    Execute the given ReindexRequest against the reindex API.
    reactor.core.publisher.Flux<org.elasticsearch.search.suggest.Suggest>
    suggest(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.search.SearchRequest searchRequest)
    Deprecated.
    Execute the given SearchRequest against the search API.
    reactor.core.publisher.Mono<org.elasticsearch.action.update.UpdateResponse>
    update(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.update.UpdateRequest updateRequest)
    Deprecated.
    Execute the given UpdateRequest against the update API to alter a document.
    reactor.core.publisher.Mono<Boolean>
    updateAliases(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.admin.indices.alias.IndicesAliasesRequest indicesAliasesRequest)
    Deprecated.
    Execute the given IndicesAliasesRequest against the indices API.
    reactor.core.publisher.Mono<ByQueryResponse>
    updateBy(org.springframework.http.HttpHeaders headers, org.elasticsearch.index.reindex.UpdateByQueryRequest updateRequest)
    Deprecated.
    Execute a UpdateByQueryRequest against the update by query API.

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface org.springframework.data.elasticsearch.client.erhlc.ReactiveElasticsearchClient

    aggregate, aggregate, bulk, bulk, count, count, delete, delete, deleteBy, deleteBy, exists, exists, get, get, index, index, info, multiGet, multiGet, ping, reindex, reindex, scroll, search, search, searchForResponse, searchTemplate, searchTemplate, submitReindex, submitReindex, suggest, suggest, update, update, updateBy, updateBy

    Methods inherited from interface org.springframework.data.elasticsearch.client.erhlc.ReactiveElasticsearchClient.Cluster

    health, health

    Methods inherited from interface org.springframework.data.elasticsearch.client.erhlc.ReactiveElasticsearchClient.Indices

    closeIndex, closeIndex, createIndex, createIndex, createIndex, deleteIndex, deleteIndex, deleteTemplate, deleteTemplate, existsIndex, existsIndex, existsIndex, existsTemplate, existsTemplate, flushIndex, flushIndex, getAliases, getAliases, getFieldMapping, getFieldMapping, getIndex, getIndex, getMapping, getMapping, getMapping, getSettings, getSettings, getTemplate, getTemplate, openIndex, openIndex, putMapping, putMapping, putMapping, putTemplate, putTemplate, refreshIndex, refreshIndex, updateAliases, updateAliases

  • Constructor Details

  • Method Details

    • create

      public static ReactiveElasticsearchClient create(org.springframework.http.HttpHeaders headers, String... hosts)
      Deprecated.
      Create a new DefaultReactiveElasticsearchClient aware of the given nodes in the cluster.
      NOTE If the cluster requires authentication be sure to provide the according HttpHeaders correctly.
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      hosts - must not be null nor empty!
      Returns:
      new instance of DefaultReactiveElasticsearchClient.

    • create

      public static ReactiveElasticsearchClient create(ClientConfiguration clientConfiguration)
      Deprecated.
      Create a new DefaultReactiveElasticsearchClient given ClientConfiguration.
      NOTE If the cluster requires authentication be sure to provide the according HttpHeaders correctly.
      Parameters:
      clientConfiguration - Client configuration. Must not be null.
      Returns:
      new instance of DefaultReactiveElasticsearchClient.

    • create

      public static ReactiveElasticsearchClient create(ClientConfiguration clientConfiguration, RequestCreator requestCreator)
      Deprecated.
      Create a new DefaultReactiveElasticsearchClient given ClientConfiguration and RequestCreator.
      NOTE If the cluster requires authentication be sure to provide the according HttpHeaders correctly.
      Parameters:
      clientConfiguration - Client configuration. Must not be null.
      requestCreator - Request creator. Must not be null.
      Returns:
      new instance of DefaultReactiveElasticsearchClient.

    • setHeadersSupplier

      public void setHeadersSupplier(Supplier<HttpHeaders> headersSupplier)
      Deprecated.

    • ping

      public reactor.core.publisher.Mono<Boolean> ping(org.springframework.http.HttpHeaders headers)
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient
      Pings the remote Elasticsearch cluster and emits true if the ping succeeded, false otherwise.
      Specified by:
      ping in interface ReactiveElasticsearchClient
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      Returns:
      the Mono emitting the result of the ping attempt.

    • info

      public reactor.core.publisher.Mono<org.elasticsearch.action.main.MainResponse> info(org.springframework.http.HttpHeaders headers)
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient
      Get the cluster info otherwise provided when sending an HTTP request to port 9200.
      Specified by:
      info in interface ReactiveElasticsearchClient
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      Returns:
      the Mono emitting the result of the info request.

    • get

      public reactor.core.publisher.Mono<org.elasticsearch.index.get.GetResult> get(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.get.GetRequest getRequest)
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient
      Execute the given GetRequest against the get API to retrieve a document by id.
      Specified by:
      get in interface ReactiveElasticsearchClient
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      getRequest - must not be null.
      Returns:
      the Mono emitting the result.
      See Also:

    • multiGet

      public reactor.core.publisher.Flux<org.elasticsearch.action.get.MultiGetItemResponse> multiGet(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.get.MultiGetRequest multiGetRequest)
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient
      Execute the given MultiGetRequest against the multi-get API to retrieve multiple documents by id.
      Specified by:
      multiGet in interface ReactiveElasticsearchClient
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      multiGetRequest - must not be null.
      Returns:
      the Flux emitting the result.
      See Also:

    • exists

      public reactor.core.publisher.Mono<Boolean> exists(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.get.GetRequest getRequest)
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient
      Checks for the existence of a document. Emits true if it exists, false otherwise.
      Specified by:
      exists in interface ReactiveElasticsearchClient
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      getRequest - must not be null.
      Returns:
      the Mono emitting true if it exists, false otherwise.

    • index

      public reactor.core.publisher.Mono<org.elasticsearch.action.index.IndexResponse> index(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.index.IndexRequest indexRequest)
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient
      Execute the given IndexRequest against the index API to index a document.
      Specified by:
      index in interface ReactiveElasticsearchClient
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      indexRequest - must not be null.
      Returns:
      the Mono emitting the IndexResponse.
      See Also:

    • indices

      public ReactiveElasticsearchClient.Indices indices()
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient
      Gain access to index related commands.
      Specified by:
      indices in interface ReactiveElasticsearchClient
      Returns:
      access to index related commands.

    • cluster

      public ReactiveElasticsearchClient.Cluster cluster()
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient
      Gain Access to cluster related commands.
      Specified by:
      cluster in interface ReactiveElasticsearchClient
      Returns:
      Cluster implementations

    • update

      public reactor.core.publisher.Mono<org.elasticsearch.action.update.UpdateResponse> update(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.update.UpdateRequest updateRequest)
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient
      Execute the given UpdateRequest against the update API to alter a document.
      Specified by:
      update in interface ReactiveElasticsearchClient
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      updateRequest - must not be null.
      Returns:
      the Mono emitting the UpdateResponse.
      See Also:

    • delete

      public reactor.core.publisher.Mono<org.elasticsearch.action.delete.DeleteResponse> delete(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.delete.DeleteRequest deleteRequest)
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient
      Execute the given DeleteRequest against the delete API to remove a document.
      Specified by:
      delete in interface ReactiveElasticsearchClient
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      deleteRequest - must not be null.
      Returns:
      the Mono emitting the DeleteResponse.
      See Also:

    • count

      public reactor.core.publisher.Mono<Long> count(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.search.SearchRequest searchRequest)
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient
      Execute a SearchRequest against the search API.
      Specified by:
      count in interface ReactiveElasticsearchClient
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      searchRequest - must not be null.
      Returns:
      the Mono emitting the count result.
      See Also:

    • searchTemplate

      public reactor.core.publisher.Flux<org.elasticsearch.search.SearchHit> searchTemplate(org.springframework.http.HttpHeaders headers, org.elasticsearch.script.mustache.SearchTemplateRequest searchTemplateRequest)
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient
      Executes a SearchTemplateRequest against the search template API.
      Specified by:
      searchTemplate in interface ReactiveElasticsearchClient
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      searchTemplateRequest - must not be null.
      Returns:
      the Flux emitting hits one by one.
      See Also:

    • search

      public reactor.core.publisher.Flux<org.elasticsearch.search.SearchHit> search(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.search.SearchRequest searchRequest)
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient
      Execute the given SearchRequest against the search API.
      Specified by:
      search in interface ReactiveElasticsearchClient
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      searchRequest - must not be null.
      Returns:
      the Flux emitting hits one by one.
      See Also:

    • searchForResponse

      public reactor.core.publisher.Mono<org.elasticsearch.action.search.SearchResponse> searchForResponse(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.search.SearchRequest searchRequest)
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient
      Execute the given SearchRequest against the search API returning the whole response in one Mono.
      Specified by:
      searchForResponse in interface ReactiveElasticsearchClient
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      searchRequest - must not be null.
      Returns:
      the Mono emitting the whole SearchResponse.
      See Also:

    • suggest

      public reactor.core.publisher.Flux<org.elasticsearch.search.suggest.Suggest> suggest(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.search.SearchRequest searchRequest)
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient
      Execute the given SearchRequest against the search API.
      Specified by:
      suggest in interface ReactiveElasticsearchClient
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      searchRequest - must not be null.
      Returns:
      the Flux emitting suggestions one by one.

    • aggregate

      public reactor.core.publisher.Flux<org.elasticsearch.search.aggregations.Aggregation> aggregate(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.search.SearchRequest searchRequest)
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient
      Execute the given SearchRequest with aggregations against the search API.
      Specified by:
      aggregate in interface ReactiveElasticsearchClient
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      searchRequest - must not be null.
      Returns:
      the Flux emitting Aggregation one by one.
      See Also:

    • scroll

      public reactor.core.publisher.Flux<org.elasticsearch.search.SearchHit> scroll(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.search.SearchRequest searchRequest)
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient
      Execute the given SearchRequest against the search scroll API.
      Scroll keeps track of scrollIds returned by the server and provides them when requesting more results via _search/scroll. All bound server resources are freed on completion.
      Specified by:
      scroll in interface ReactiveElasticsearchClient
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      searchRequest - must not be null.
      Returns:
      the Flux emitting hits one by one.
      See Also:

    • deleteBy

      public reactor.core.publisher.Mono<org.elasticsearch.index.reindex.BulkByScrollResponse> deleteBy(org.springframework.http.HttpHeaders headers, org.elasticsearch.index.reindex.DeleteByQueryRequest deleteRequest)
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient
      Execute a DeleteByQueryRequest against the delete by query API.
      Specified by:
      deleteBy in interface ReactiveElasticsearchClient
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      deleteRequest - must not be null.
      Returns:
      a Mono emitting operation response.
      See Also:

    • updateBy

      public reactor.core.publisher.Mono<ByQueryResponse> updateBy(org.springframework.http.HttpHeaders headers, org.elasticsearch.index.reindex.UpdateByQueryRequest updateRequest)
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient
      Execute a UpdateByQueryRequest against the update by query API.
      Specified by:
      updateBy in interface ReactiveElasticsearchClient
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      updateRequest - must not be null.
      Returns:
      a Mono emitting operation response.
      See Also:

    • bulk

      public reactor.core.publisher.Mono<org.elasticsearch.action.bulk.BulkResponse> bulk(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.bulk.BulkRequest bulkRequest)
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient
      Execute a BulkRequest against the bulk API.
      Specified by:
      bulk in interface ReactiveElasticsearchClient
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      bulkRequest - must not be null.
      Returns:
      a Mono emitting operation response.
      See Also:

    • reindex

      public reactor.core.publisher.Mono<org.elasticsearch.index.reindex.BulkByScrollResponse> reindex(org.springframework.http.HttpHeaders headers, org.elasticsearch.index.reindex.ReindexRequest reindexRequest)
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient
      Execute the given ReindexRequest against the reindex API.
      Specified by:
      reindex in interface ReactiveElasticsearchClient
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      reindexRequest - must not be null
      Returns:
      the Mono emitting the response

    • submitReindex

      public reactor.core.publisher.Mono<String> submitReindex(org.springframework.http.HttpHeaders headers, org.elasticsearch.index.reindex.ReindexRequest reindexRequest)
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient
      Execute the given ReindexRequest against the reindex API.
      Specified by:
      submitReindex in interface ReactiveElasticsearchClient
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      reindexRequest - must not be null
      Returns:
      the Mono emitting the task id

    • execute

      public <T> reactor.core.publisher.Mono<T> execute(ReactiveElasticsearchClient.ReactiveElasticsearchClientCallback<T> callback)
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient
      Compose the actual command/s to run against Elasticsearch using the underlying connection. Execute selects an active server from the available ones and retries operations that fail with a ConnectException on another node if the previously selected one becomes unavailable.
      Specified by:
      execute in interface ReactiveElasticsearchClient
      Type Parameters:
      T - the type emitted by the returned Mono.
      Parameters:
      callback - the callback wielding the actual command to run.
      Returns:
      the Mono emitting the ClientResponse once subscribed.

    • status

      public reactor.core.publisher.Mono<ReactiveElasticsearchClient.Status> status()
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient
      Get the current client ReactiveElasticsearchClient.Status.
      NOTE the actual implementation might choose to actively check the current cluster state by pinging known nodes.
      Specified by:
      status in interface ReactiveElasticsearchClient
      Returns:
      the actual ReactiveElasticsearchClient.Status information.

    • createIndex

      public reactor.core.publisher.Mono<Boolean> createIndex(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.admin.indices.create.CreateIndexRequest createIndexRequest)
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient.Indices
      Execute the given CreateIndexRequest against the indices API.
      Specified by:
      createIndex in interface ReactiveElasticsearchClient.Indices
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      createIndexRequest - must not be null.
      Returns:
      a Mono signalling successful operation completion or an error if eg. the index already exist.
      See Also:

    • createIndex

      public reactor.core.publisher.Mono<Boolean> createIndex(org.springframework.http.HttpHeaders headers, org.elasticsearch.client.indices.CreateIndexRequest createIndexRequest)
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient.Indices
      Execute the given CreateIndexRequest against the indices API.
      Specified by:
      createIndex in interface ReactiveElasticsearchClient.Indices
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      createIndexRequest - must not be null.
      Returns:
      a Mono signalling successful operation completion or an error if eg. the index already exist.
      See Also:

    • closeIndex

      public reactor.core.publisher.Mono<Void> closeIndex(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.admin.indices.close.CloseIndexRequest closeIndexRequest)
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient.Indices
      Execute the given CloseIndexRequest against the indices API.
      Specified by:
      closeIndex in interface ReactiveElasticsearchClient.Indices
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      closeIndexRequest - must not be null.
      Returns:
      a Mono signalling operation completion or an error if eg. the index does not exist.
      See Also:

    • existsIndex

      public reactor.core.publisher.Mono<Boolean> existsIndex(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.admin.indices.get.GetIndexRequest request)
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient.Indices
      Execute the given GetIndexRequest against the indices API.
      Specified by:
      existsIndex in interface ReactiveElasticsearchClient.Indices
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      request - must not be null.
      Returns:
      the Mono emitting true if the index exists, false otherwise.
      See Also:

    • existsIndex

      public reactor.core.publisher.Mono<Boolean> existsIndex(org.springframework.http.HttpHeaders headers, org.elasticsearch.client.indices.GetIndexRequest request)
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient.Indices
      Execute the given GetIndexRequest against the indices API.
      Specified by:
      existsIndex in interface ReactiveElasticsearchClient.Indices
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      request - must not be null.
      Returns:
      the Mono emitting true if the index exists, false otherwise.
      See Also:

    • deleteIndex

      public reactor.core.publisher.Mono<Boolean> deleteIndex(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest request)
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient.Indices
      Execute the given DeleteIndexRequest against the indices API.
      Specified by:
      deleteIndex in interface ReactiveElasticsearchClient.Indices
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      request - must not be null.
      Returns:
      a Mono signalling operation completion or an error if eg. the index does not exist.
      See Also:

    • flushIndex

      public reactor.core.publisher.Mono<Void> flushIndex(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.admin.indices.flush.FlushRequest flushRequest)
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient.Indices
      Execute the given RefreshRequest against the indices API.
      Specified by:
      flushIndex in interface ReactiveElasticsearchClient.Indices
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      flushRequest - must not be null.
      Returns:
      a Mono signalling operation completion or an error if eg. the index does not exist.
      See Also:

    • getMapping

      @Deprecated public reactor.core.publisher.Mono<org.elasticsearch.action.admin.indices.mapping.get.GetMappingsResponse> getMapping(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.admin.indices.mapping.get.GetMappingsRequest getMappingsRequest)
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient.Indices
      Execute the given GetMappingsRequest against the indices API.
      Specified by:
      getMapping in interface ReactiveElasticsearchClient.Indices
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      getMappingsRequest - must not be null.
      Returns:
      a Mono signalling operation completion or an error if eg. the index does not exist.
      See Also:

    • getMapping

      public reactor.core.publisher.Mono<org.elasticsearch.client.indices.GetMappingsResponse> getMapping(org.springframework.http.HttpHeaders headers, org.elasticsearch.client.indices.GetMappingsRequest getMappingsRequest)
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient.Indices
      Execute the given GetMappingsRequest against the indices API.
      Specified by:
      getMapping in interface ReactiveElasticsearchClient.Indices
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      getMappingsRequest - must not be null.
      Returns:
      a Mono signalling operation completion or an error if eg. the index does not exist.
      See Also:

    • getFieldMapping

      public reactor.core.publisher.Mono<org.elasticsearch.client.indices.GetFieldMappingsResponse> getFieldMapping(org.springframework.http.HttpHeaders headers, org.elasticsearch.client.indices.GetFieldMappingsRequest getFieldMappingsRequest)
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient.Indices
      Execute the given GetFieldMappingsRequest against the indices API.
      Specified by:
      getFieldMapping in interface ReactiveElasticsearchClient.Indices
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      getFieldMappingsRequest - must not be null.
      Returns:
      a Mono signalling operation completion or an error if eg. the index does not exist.
      See Also:

    • getSettings

      public reactor.core.publisher.Mono<org.elasticsearch.action.admin.indices.settings.get.GetSettingsResponse> getSettings(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.admin.indices.settings.get.GetSettingsRequest getSettingsRequest)
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient.Indices
      Execute the given GetSettingsRequest against the indices API.
      Specified by:
      getSettings in interface ReactiveElasticsearchClient.Indices
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      getSettingsRequest - must not be null.
      Returns:
      a Mono signalling operation completion or an error if eg. the index does not exist.
      See Also:

    • putMapping

      public reactor.core.publisher.Mono<Boolean> putMapping(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.admin.indices.mapping.put.PutMappingRequest putMappingRequest)
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient.Indices
      Execute the given PutMappingRequest against the indices API.
      Specified by:
      putMapping in interface ReactiveElasticsearchClient.Indices
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      putMappingRequest - must not be null.
      Returns:
      a Mono signalling operation completion or an error if eg. the index does not exist.
      See Also:

    • putMapping

      public reactor.core.publisher.Mono<Boolean> putMapping(org.springframework.http.HttpHeaders headers, org.elasticsearch.client.indices.PutMappingRequest putMappingRequest)
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient.Indices
      Execute the given PutMappingRequest against the indices API.
      Specified by:
      putMapping in interface ReactiveElasticsearchClient.Indices
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      putMappingRequest - must not be null.
      Returns:
      a Mono signalling operation completion or an error if eg. the index does not exist.
      See Also:

    • openIndex

      public reactor.core.publisher.Mono<Void> openIndex(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.admin.indices.open.OpenIndexRequest request)
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient.Indices
      Execute the given OpenIndexRequest against the indices API.
      Specified by:
      openIndex in interface ReactiveElasticsearchClient.Indices
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      request - must not be null.
      Returns:
      a Mono signalling operation completion or an error if eg. the index does not exist.
      See Also:

    • refreshIndex

      public reactor.core.publisher.Mono<Void> refreshIndex(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.admin.indices.refresh.RefreshRequest refreshRequest)
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient.Indices
      Execute the given RefreshRequest against the indices API.
      Specified by:
      refreshIndex in interface ReactiveElasticsearchClient.Indices
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      refreshRequest - must not be null.
      Returns:
      a Mono signalling operation completion or an error if eg. the index does not exist.
      See Also:

    • updateAliases

      public reactor.core.publisher.Mono<Boolean> updateAliases(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.admin.indices.alias.IndicesAliasesRequest indicesAliasesRequest)
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient.Indices
      Execute the given IndicesAliasesRequest against the indices API.
      Specified by:
      updateAliases in interface ReactiveElasticsearchClient.Indices
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      indicesAliasesRequest - must not be null
      Returns:
      a Mono signalling operation completion.

    • getAliases

      public reactor.core.publisher.Mono<org.elasticsearch.client.GetAliasesResponse> getAliases(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.admin.indices.alias.get.GetAliasesRequest getAliasesRequest)
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient.Indices
      Execute the given GetAliasesRequest against the indices API.
      Specified by:
      getAliases in interface ReactiveElasticsearchClient.Indices
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      getAliasesRequest - must not be null
      Returns:
      a Mono signalling operation completion.

    • putTemplate

      public reactor.core.publisher.Mono<Boolean> putTemplate(org.springframework.http.HttpHeaders headers, org.elasticsearch.client.indices.PutIndexTemplateRequest putIndexTemplateRequest)
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient.Indices
      Execute the given PutIndexTemplateRequest against the indices API.
      Specified by:
      putTemplate in interface ReactiveElasticsearchClient.Indices
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      putIndexTemplateRequest - must not be null
      Returns:
      a Mono signalling operation completion.

    • getTemplate

      public reactor.core.publisher.Mono<org.elasticsearch.client.indices.GetIndexTemplatesResponse> getTemplate(org.springframework.http.HttpHeaders headers, org.elasticsearch.client.indices.GetIndexTemplatesRequest getIndexTemplatesRequest)
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient.Indices
      Execute the given GetIndexTemplatesRequest against the indices API.
      Specified by:
      getTemplate in interface ReactiveElasticsearchClient.Indices
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      getIndexTemplatesRequest - must not be null
      Returns:
      a Mono with the GetIndexTemplatesResponse.

    • existsTemplate

      public reactor.core.publisher.Mono<Boolean> existsTemplate(org.springframework.http.HttpHeaders headers, org.elasticsearch.client.indices.IndexTemplatesExistRequest indexTemplatesExistRequest)
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient.Indices
      Execute the given IndexTemplatesExistRequest against the indices API.
      Specified by:
      existsTemplate in interface ReactiveElasticsearchClient.Indices
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      indexTemplatesExistRequest - must not be null
      Returns:
      the Mono emitting true if the template exists, false otherwise.

    • deleteTemplate

      public reactor.core.publisher.Mono<Boolean> deleteTemplate(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.admin.indices.template.delete.DeleteIndexTemplateRequest deleteIndexTemplateRequest)
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient.Indices
      Execute the given DeleteIndexTemplateRequest against the indices API.
      Specified by:
      deleteTemplate in interface ReactiveElasticsearchClient.Indices
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      deleteIndexTemplateRequest - must not be null
      Returns:
      the Mono emitting true if the template exists, false otherwise.

    • getIndex

      public reactor.core.publisher.Mono<org.elasticsearch.client.indices.GetIndexResponse> getIndex(org.springframework.http.HttpHeaders headers, org.elasticsearch.client.indices.GetIndexRequest getIndexRequest)
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient.Indices
      Execute the given GetIndexRequest against the indices API.
      Specified by:
      getIndex in interface ReactiveElasticsearchClient.Indices
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      getIndexRequest - must not be null
      Returns:
      the Mono emitting the response

    • health

      public reactor.core.publisher.Mono<org.elasticsearch.action.admin.cluster.health.ClusterHealthResponse> health(org.springframework.http.HttpHeaders headers, org.elasticsearch.action.admin.cluster.health.ClusterHealthRequest clusterHealthRequest)
      Deprecated.
      Description copied from interface: ReactiveElasticsearchClient.Cluster
      Execute the given {ClusterHealthRequest} against the cluster API.
      Specified by:
      health in interface ReactiveElasticsearchClient.Cluster
      Parameters:
      headers - Use HttpHeaders to provide eg. authentication data. Must not be null.
      clusterHealthRequest - must not be null // * @return Mono emitting the ClusterHealthResponse.