Package com.linkedin.venice.client.store.transport

Class TransportClient

java.lang.Object

com.linkedin.venice.client.store.transport.TransportClient

All Implemented Interfaces:

Closeable, AutoCloseable

Direct Known Subclasses:

D2TransportClient, HttpTransportClient, InternalTransportClient

public abstract class TransportClient
extends Object
implements Closeable

Define interfaces for TransportClient, and the target customer is the sub-classes of AvroGenericStoreClient

Field Summary

Fields

Modifier and Type	Field	Description
protected static final String	HTTPS

Constructor Summary

Constructors

Constructor	Description
TransportClient()

Method Summary

Modifier and Type	Method	Description
CompletableFuture<TransportClientResponse>	get(String requestPath)
abstract CompletableFuture<TransportClientResponse>	get(String requestPath, Map<String,String> headers)
TransportClient	getCopyIfNotUsableInCallback()	If the internal client could not be used by its callback function, implementation of this function should return a new copy.
CompletableFuture<TransportClientResponse>	post(String requestPath, byte[] requestBody)
abstract CompletableFuture<TransportClientResponse>	post(String requestPath, Map<String,String> headers, byte[] requestBody)
abstract void	streamPost(String requestPath, Map<String,String> headers, byte[] requestBody, TransportClientStreamingCallback callback, int keyCount)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.io.Closeable

close

Field Details

HTTPS

protected static final String HTTPS

See Also:

• Constant Field Values

Constructor Details

TransportClient

public TransportClient()

Method Details

get

public CompletableFuture<TransportClientResponse> get(String requestPath)

post

public CompletableFuture<TransportClientResponse> post(String requestPath,
 byte[] requestBody)

get

public abstract CompletableFuture<TransportClientResponse> get(String requestPath,
 Map<String,String> headers)

post

public abstract CompletableFuture<TransportClientResponse> post(String requestPath,
 Map<String,String> headers,
 byte[] requestBody)

streamPost

public abstract void streamPost(String requestPath,
 Map<String,String> headers,
 byte[] requestBody,
 TransportClientStreamingCallback callback,
 int keyCount)

getCopyIfNotUsableInCallback

public TransportClient getCopyIfNotUsableInCallback()

If the internal client could not be used by its callback function, implementation of this function should return a new copy. The default implementation is to return itself.

Returns: