Package co.elastic.clients.transport

Interface Transport

All Superinterfaces:

AutoCloseable, Closeable

All Known Subinterfaces:

ElasticsearchTransport

All Known Implementing Classes:

ElasticsearchTransportBase, Rest5ClientTransport, RestClientTransport

public interface Transport
extends Closeable

The transport layer that allows ApiClients to send requests.

Method Summary

Modifier and Type	Method	Description
JsonpMapper	jsonpMapper()
TransportOptions	options()	Default options used by this transport if none are provided in performRequest(Object, Endpoint, TransportOptions) or performRequestAsync(Object, Endpoint, TransportOptions);
<RequestT, ResponseT, ErrorT> ResponseT	performRequest(RequestT request, Endpoint<RequestT,ResponseT,ErrorT> endpoint, TransportOptions options)
<RequestT, ResponseT, ErrorT> CompletableFuture<ResponseT>	performRequestAsync(RequestT request, Endpoint<RequestT,ResponseT,ErrorT> endpoint, TransportOptions options)
default Transport	withOptions(TransportOptions options)	Clone this transport with new options.
default Transport	withOptions(Function<TransportOptions.Builder,TransportOptions.Builder> fn)	Clone this transport with additional options.

Methods inherited from interface java.io.Closeable

close

Method Details

performRequest

<RequestT,
ResponseT,
ErrorT> ResponseT performRequest(RequestT request,
 Endpoint<RequestT,ResponseT,ErrorT> endpoint,
 @Nullable
 TransportOptions options)
                                              throws IOException

Throws:

IOException

performRequestAsync

<RequestT,
ResponseT,
ErrorT>
CompletableFuture<ResponseT> performRequestAsync(RequestT request,
 Endpoint<RequestT,ResponseT,ErrorT> endpoint,
 @Nullable
 TransportOptions options)

jsonpMapper

JsonpMapper jsonpMapper()

options

TransportOptions options()

Default options used by this transport if none are provided in performRequest(Object, Endpoint, TransportOptions) or performRequestAsync(Object, Endpoint, TransportOptions);

withOptions

default Transport withOptions(@Nullable
 TransportOptions options)

Clone this transport with new options.

Throws:

UnsupportedOperationException

withOptions

default Transport withOptions(Function<TransportOptions.Builder,TransportOptions.Builder> fn)

Clone this transport with additional options. The lambda expression is provided an options builder initialized with the transport's current options.

Parameters:

fn - a lambda expression that takes the current options as input

Throws:

UnsupportedOperationException