Package org.opensearch.client.base

Class RestClientTransport

java.lang.Object
org.opensearch.client.base.RestClientTransport
All Implemented Interfaces:
Transport
public class RestClientTransport
extends java.lang.Object
implements Transport

  • Constructor Summary

    Constructors 
    Constructor Description
    RestClientTransport​(org.opensearch.client.RestClient restClient, JsonpMapper mapper)  

  • Method Summary

    Modifier and Type Method Description
    JsonpMapper jsonpMapper()  
    <RequestT,​ ResponseT,​ ErrorT>
    ResponseT    		 performRequest​(RequestT request, Endpoint<RequestT,​ResponseT,​ErrorT> endpoint, org.opensearch.client.RequestOptions options)  
    <RequestT,​ ResponseT,​ ErrorT>
    java.util.concurrent.CompletableFuture<ResponseT>    		 performRequestAsync​(RequestT request, Endpoint<RequestT,​ResponseT,​ErrorT> endpoint, org.opensearch.client.RequestOptions options)  

    Methods inherited from class java.lang.Object

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

  • Constructor Details

  • Method Details

    • jsonpMapper

      public JsonpMapper jsonpMapper()
      Specified by:
      jsonpMapper in interface Transport

    • performRequest

      public <RequestT,​ ResponseT,​ ErrorT> ResponseT performRequest​(RequestT request, Endpoint<RequestT,​ResponseT,​ErrorT> endpoint, org.opensearch.client.RequestOptions options) throws java.io.IOException
      Specified by:
      performRequest in interface Transport
      Throws:
      java.io.IOException

    • performRequestAsync

      public <RequestT,​ ResponseT,​ ErrorT> java.util.concurrent.CompletableFuture<ResponseT> performRequestAsync​(RequestT request, Endpoint<RequestT,​ResponseT,​ErrorT> endpoint, org.opensearch.client.RequestOptions options)
      Specified by:
      performRequestAsync in interface Transport