Package org.opensearch.data.client.osc

Class ReactiveOpenSearchClient

java.lang.Object
org.opensearch.client.ApiClient<org.opensearch.client.transport.OpenSearchTransport,ReactiveOpenSearchClient>
org.opensearch.data.client.osc.ReactiveOpenSearchClient
All Implemented Interfaces:
AutoCloseable
public class ReactiveOpenSearchClient extends org.opensearch.client.ApiClient<org.opensearch.client.transport.OpenSearchTransport,ReactiveOpenSearchClient> implements AutoCloseable
Reactive version of OpenSearchClient.

  • Field Summary

    Fields inherited from class org.opensearch.client.ApiClient

    transport, transportOptions

  • Constructor Summary

    Constructors
    Constructor
    Description
    ReactiveOpenSearchClient(org.opensearch.client.transport.OpenSearchTransport transport)
     
    ReactiveOpenSearchClient(org.opensearch.client.transport.OpenSearchTransport transport, org.opensearch.client.transport.TransportOptions transportOptions)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.BulkResponse>
    bulk(Function<org.opensearch.client.opensearch.core.BulkRequest.Builder,org.opensearch.client.util.ObjectBuilder<org.opensearch.client.opensearch.core.BulkRequest>> fn)
     
    reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.BulkResponse>
    bulk(org.opensearch.client.opensearch.core.BulkRequest request)
     
    reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.ClearScrollResponse>
    clearScroll(Function<org.opensearch.client.opensearch.core.ClearScrollRequest.Builder,org.opensearch.client.util.ObjectBuilder<org.opensearch.client.opensearch.core.ClearScrollRequest>> fn)
     
    reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.ClearScrollResponse>
    clearScroll(org.opensearch.client.opensearch.core.ClearScrollRequest request)
     
    void
    close()
     
    reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.pit.DeletePitResponse>
    closePointInTime(Function<org.opensearch.client.opensearch.core.pit.DeletePitRequest.Builder,org.opensearch.client.util.ObjectBuilder<org.opensearch.client.opensearch.core.pit.DeletePitRequest>> fn)
     
    reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.pit.DeletePitResponse>
    closePointInTime(org.opensearch.client.opensearch.core.pit.DeletePitRequest request)
     
    ReactiveOpenSearchClusterClient
    cluster()
     
    reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.CountResponse>
    count(Function<org.opensearch.client.opensearch.core.CountRequest.Builder,org.opensearch.client.util.ObjectBuilder<org.opensearch.client.opensearch.core.CountRequest>> fn)
     
    reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.CountResponse>
    count(org.opensearch.client.opensearch.core.CountRequest request)
     
    reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.DeleteResponse>
    delete(Function<org.opensearch.client.opensearch.core.DeleteRequest.Builder,org.opensearch.client.util.ObjectBuilder<org.opensearch.client.opensearch.core.DeleteRequest>> fn)
     
    reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.DeleteResponse>
    delete(org.opensearch.client.opensearch.core.DeleteRequest request)
     
    reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.DeleteByQueryResponse>
    deleteByQuery(Function<org.opensearch.client.opensearch.core.DeleteByQueryRequest.Builder,org.opensearch.client.util.ObjectBuilder<org.opensearch.client.opensearch.core.DeleteByQueryRequest>> fn)
     
    reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.DeleteByQueryResponse>
    deleteByQuery(org.opensearch.client.opensearch.core.DeleteByQueryRequest request)
     
    reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.DeleteScriptResponse>
    deleteScript(Function<org.opensearch.client.opensearch.core.DeleteScriptRequest.Builder,org.opensearch.client.util.ObjectBuilder<org.opensearch.client.opensearch.core.DeleteScriptRequest>> fn)
     
    reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.DeleteScriptResponse>
    deleteScript(org.opensearch.client.opensearch.core.DeleteScriptRequest request)
     
    reactor.core.publisher.Mono<org.opensearch.client.transport.endpoints.BooleanResponse>
    exists(org.opensearch.client.opensearch.core.ExistsRequest request)
     
    <T> reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.GetResponse<T>>
    get(Function<org.opensearch.client.opensearch.core.GetRequest.Builder,org.opensearch.client.util.ObjectBuilder<org.opensearch.client.opensearch.core.GetRequest>> fn, Class<T> tClass)
     
    <T> reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.GetResponse<T>>
    get(org.opensearch.client.opensearch.core.GetRequest request, Class<T> tClass)
     
    reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.GetScriptResponse>
    getScript(Function<org.opensearch.client.opensearch.core.GetScriptRequest.Builder,org.opensearch.client.util.ObjectBuilder<org.opensearch.client.opensearch.core.GetScriptRequest>> fn)
     
    reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.GetScriptResponse>
    getScript(org.opensearch.client.opensearch.core.GetScriptRequest request)
     
    <T> reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.IndexResponse>
    index(Function<org.opensearch.client.opensearch.core.IndexRequest.Builder<T>,org.opensearch.client.util.ObjectBuilder<org.opensearch.client.opensearch.core.IndexRequest<T>>> fn)
     
    <T> reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.IndexResponse>
    index(org.opensearch.client.opensearch.core.IndexRequest<T> request)
     
    ReactiveOpenSearchIndicesClient
    indices()
     
    reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.InfoResponse>
    info()
     
    <T> reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.MgetResponse<T>>
    mget(Function<org.opensearch.client.opensearch.core.MgetRequest.Builder,org.opensearch.client.util.ObjectBuilder<org.opensearch.client.opensearch.core.MgetRequest>> fn, Class<T> clazz)
     
    <T> reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.MgetResponse<T>>
    mget(org.opensearch.client.opensearch.core.MgetRequest request, Class<T> clazz)
     
    reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.pit.CreatePitResponse>
    openPointInTime(org.opensearch.client.opensearch.core.pit.CreatePitRequest request)
     
    reactor.core.publisher.Mono<org.opensearch.client.transport.endpoints.BooleanResponse>
    ping()
     
    reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.PutScriptResponse>
    putScript(Function<org.opensearch.client.opensearch.core.PutScriptRequest.Builder,org.opensearch.client.util.ObjectBuilder<org.opensearch.client.opensearch.core.PutScriptRequest>> fn)
     
    reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.PutScriptResponse>
    putScript(org.opensearch.client.opensearch.core.PutScriptRequest request)
     
    reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.ReindexResponse>
    reindex(Function<org.opensearch.client.opensearch.core.ReindexRequest.Builder,org.opensearch.client.util.ObjectBuilder<org.opensearch.client.opensearch.core.ReindexRequest>> fn)
     
    reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.ReindexResponse>
    reindex(org.opensearch.client.opensearch.core.ReindexRequest request)
     
    <T> reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.ScrollResponse<T>>
    scroll(Function<org.opensearch.client.opensearch.core.ScrollRequest.Builder,org.opensearch.client.util.ObjectBuilder<org.opensearch.client.opensearch.core.ScrollRequest>> fn, Class<T> tDocumentClass)
     
    <T> reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.ScrollResponse<T>>
    scroll(org.opensearch.client.opensearch.core.ScrollRequest request, Class<T> tDocumentClass)
     
    <T> reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.SearchResponse<T>>
    search(Function<org.opensearch.client.opensearch.core.SearchRequest.Builder,org.opensearch.client.util.ObjectBuilder<org.opensearch.client.opensearch.core.SearchRequest>> fn, Class<T> tDocumentClass)
     
    <T> reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.SearchResponse<T>>
    search(org.opensearch.client.opensearch.core.SearchRequest request, Class<T> tDocumentClass)
     
    <T> reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.SearchTemplateResponse<T>>
    searchTemplate(Function<org.opensearch.client.opensearch.core.SearchTemplateRequest.Builder,org.opensearch.client.util.ObjectBuilder<org.opensearch.client.opensearch.core.SearchTemplateRequest>> fn, Class<T> tDocumentClass)
     
    <T> reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.SearchTemplateResponse<T>>
    searchTemplate(org.opensearch.client.opensearch.core.SearchTemplateRequest request, Class<T> tDocumentClass)
     
    <T, P> reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.UpdateResponse<T>>
    update(Function<org.opensearch.client.opensearch.core.UpdateRequest.Builder<T,P>,org.opensearch.client.util.ObjectBuilder<org.opensearch.client.opensearch.core.UpdateRequest<T,P>>> fn, Class<T> clazz)
     
    <T, P> reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.UpdateResponse<T>>
    update(org.opensearch.client.opensearch.core.UpdateRequest<T,P> request, Class<T> clazz)
     
    ReactiveOpenSearchClient
    withTransportOptions(org.opensearch.client.transport.TransportOptions transportOptions)
     

    Methods inherited from class org.opensearch.client.ApiClient

    _transport, _transportOptions, getDeserializer

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • ReactiveOpenSearchClient

      public ReactiveOpenSearchClient(org.opensearch.client.transport.OpenSearchTransport transport)

    • ReactiveOpenSearchClient

      public ReactiveOpenSearchClient(org.opensearch.client.transport.OpenSearchTransport transport, @Nullable org.opensearch.client.transport.TransportOptions transportOptions)

  • Method Details

    • withTransportOptions

      public ReactiveOpenSearchClient withTransportOptions(@Nullable org.opensearch.client.transport.TransportOptions transportOptions)
      Specified by:
      withTransportOptions in class org.opensearch.client.ApiClient<org.opensearch.client.transport.OpenSearchTransport,ReactiveOpenSearchClient>

    • close

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

    • cluster

      public ReactiveOpenSearchClusterClient cluster()

    • indices

      public ReactiveOpenSearchIndicesClient indices()

    • info

      public reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.InfoResponse> info()

    • ping

      public reactor.core.publisher.Mono<org.opensearch.client.transport.endpoints.BooleanResponse> ping()

    • index

      public <T> reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.IndexResponse> index(org.opensearch.client.opensearch.core.IndexRequest<T> request)

    • index

      public <T> reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.IndexResponse> index(Function<org.opensearch.client.opensearch.core.IndexRequest.Builder<T>,org.opensearch.client.util.ObjectBuilder<org.opensearch.client.opensearch.core.IndexRequest<T>>> fn)

    • bulk

      public reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.BulkResponse> bulk(org.opensearch.client.opensearch.core.BulkRequest request)

    • bulk

      public reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.BulkResponse> bulk(Function<org.opensearch.client.opensearch.core.BulkRequest.Builder,org.opensearch.client.util.ObjectBuilder<org.opensearch.client.opensearch.core.BulkRequest>> fn)

    • get

      public <T> reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.GetResponse<T>> get(org.opensearch.client.opensearch.core.GetRequest request, Class<T> tClass)

    • exists

      public reactor.core.publisher.Mono<org.opensearch.client.transport.endpoints.BooleanResponse> exists(org.opensearch.client.opensearch.core.ExistsRequest request)

    • update

      public <T, P> reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.UpdateResponse<T>> update(org.opensearch.client.opensearch.core.UpdateRequest<T,P> request, Class<T> clazz)

    • update

      public <T, P> reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.UpdateResponse<T>> update(Function<org.opensearch.client.opensearch.core.UpdateRequest.Builder<T,P>,org.opensearch.client.util.ObjectBuilder<org.opensearch.client.opensearch.core.UpdateRequest<T,P>>> fn, Class<T> clazz)

    • get

      public <T> reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.GetResponse<T>> get(Function<org.opensearch.client.opensearch.core.GetRequest.Builder,org.opensearch.client.util.ObjectBuilder<org.opensearch.client.opensearch.core.GetRequest>> fn, Class<T> tClass)

    • mget

      public <T> reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.MgetResponse<T>> mget(org.opensearch.client.opensearch.core.MgetRequest request, Class<T> clazz)

    • mget

      public <T> reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.MgetResponse<T>> mget(Function<org.opensearch.client.opensearch.core.MgetRequest.Builder,org.opensearch.client.util.ObjectBuilder<org.opensearch.client.opensearch.core.MgetRequest>> fn, Class<T> clazz)

    • reindex

      public reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.ReindexResponse> reindex(org.opensearch.client.opensearch.core.ReindexRequest request)

    • reindex

      public reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.ReindexResponse> reindex(Function<org.opensearch.client.opensearch.core.ReindexRequest.Builder,org.opensearch.client.util.ObjectBuilder<org.opensearch.client.opensearch.core.ReindexRequest>> fn)

    • delete

      public reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.DeleteResponse> delete(org.opensearch.client.opensearch.core.DeleteRequest request)

    • delete

      public reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.DeleteResponse> delete(Function<org.opensearch.client.opensearch.core.DeleteRequest.Builder,org.opensearch.client.util.ObjectBuilder<org.opensearch.client.opensearch.core.DeleteRequest>> fn)

    • deleteByQuery

      public reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.DeleteByQueryResponse> deleteByQuery(org.opensearch.client.opensearch.core.DeleteByQueryRequest request)

    • deleteByQuery

      public reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.DeleteByQueryResponse> deleteByQuery(Function<org.opensearch.client.opensearch.core.DeleteByQueryRequest.Builder,org.opensearch.client.util.ObjectBuilder<org.opensearch.client.opensearch.core.DeleteByQueryRequest>> fn)

    • count

      public reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.CountResponse> count(org.opensearch.client.opensearch.core.CountRequest request)
      Since:
      5.4

    • count

      public reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.CountResponse> count(Function<org.opensearch.client.opensearch.core.CountRequest.Builder,org.opensearch.client.util.ObjectBuilder<org.opensearch.client.opensearch.core.CountRequest>> fn)
      Since:
      5.4

    • search

      public <T> reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.SearchResponse<T>> search(org.opensearch.client.opensearch.core.SearchRequest request, Class<T> tDocumentClass)

    • search

      public <T> reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.SearchResponse<T>> search(Function<org.opensearch.client.opensearch.core.SearchRequest.Builder,org.opensearch.client.util.ObjectBuilder<org.opensearch.client.opensearch.core.SearchRequest>> fn, Class<T> tDocumentClass)

    • searchTemplate

      public <T> reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.SearchTemplateResponse<T>> searchTemplate(org.opensearch.client.opensearch.core.SearchTemplateRequest request, Class<T> tDocumentClass)
      Since:
      5.1

    • searchTemplate

      public <T> reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.SearchTemplateResponse<T>> searchTemplate(Function<org.opensearch.client.opensearch.core.SearchTemplateRequest.Builder,org.opensearch.client.util.ObjectBuilder<org.opensearch.client.opensearch.core.SearchTemplateRequest>> fn, Class<T> tDocumentClass)
      Since:
      5.1

    • scroll

      public <T> reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.ScrollResponse<T>> scroll(org.opensearch.client.opensearch.core.ScrollRequest request, Class<T> tDocumentClass)

    • scroll

      public <T> reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.ScrollResponse<T>> scroll(Function<org.opensearch.client.opensearch.core.ScrollRequest.Builder,org.opensearch.client.util.ObjectBuilder<org.opensearch.client.opensearch.core.ScrollRequest>> fn, Class<T> tDocumentClass)

    • clearScroll

      public reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.ClearScrollResponse> clearScroll(org.opensearch.client.opensearch.core.ClearScrollRequest request)

    • clearScroll

      public reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.ClearScrollResponse> clearScroll(Function<org.opensearch.client.opensearch.core.ClearScrollRequest.Builder,org.opensearch.client.util.ObjectBuilder<org.opensearch.client.opensearch.core.ClearScrollRequest>> fn)

    • putScript

      public reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.PutScriptResponse> putScript(org.opensearch.client.opensearch.core.PutScriptRequest request)
      Since:
      5.1

    • putScript

      public reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.PutScriptResponse> putScript(Function<org.opensearch.client.opensearch.core.PutScriptRequest.Builder,org.opensearch.client.util.ObjectBuilder<org.opensearch.client.opensearch.core.PutScriptRequest>> fn)
      Since:
      5.1

    • getScript

      public reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.GetScriptResponse> getScript(org.opensearch.client.opensearch.core.GetScriptRequest request)
      Since:
      5.1

    • getScript

      public reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.GetScriptResponse> getScript(Function<org.opensearch.client.opensearch.core.GetScriptRequest.Builder,org.opensearch.client.util.ObjectBuilder<org.opensearch.client.opensearch.core.GetScriptRequest>> fn)
      Since:
      5.1

    • deleteScript

      public reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.DeleteScriptResponse> deleteScript(org.opensearch.client.opensearch.core.DeleteScriptRequest request)
      Since:
      5.1

    • deleteScript

      public reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.DeleteScriptResponse> deleteScript(Function<org.opensearch.client.opensearch.core.DeleteScriptRequest.Builder,org.opensearch.client.util.ObjectBuilder<org.opensearch.client.opensearch.core.DeleteScriptRequest>> fn)
      Since:
      5.1

    • openPointInTime

      public reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.pit.CreatePitResponse> openPointInTime(org.opensearch.client.opensearch.core.pit.CreatePitRequest request)
      Since:
      5.0

    • closePointInTime

      public reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.pit.DeletePitResponse> closePointInTime(org.opensearch.client.opensearch.core.pit.DeletePitRequest request)

    • closePointInTime

      public reactor.core.publisher.Mono<org.opensearch.client.opensearch.core.pit.DeletePitResponse> closePointInTime(Function<org.opensearch.client.opensearch.core.pit.DeletePitRequest.Builder,org.opensearch.client.util.ObjectBuilder<org.opensearch.client.opensearch.core.pit.DeletePitRequest>> fn)
      Since:
      5.0