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

Class TransportClient

java.lang.Object

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

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

Direct Known Subclasses:

D2TransportClient, HttpTransportClient, InternalTransportClient

public abstract class TransportClient
extends java.lang.Object
implements java.io.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 java.lang.String	HTTPS

Constructor Summary

Constructors

Constructor	Description
TransportClient()

Method Summary

Modifier and Type	Method	Description
java.util.concurrent.CompletableFuture<TransportClientResponse>	get(java.lang.String requestPath)
abstract java.util.concurrent.CompletableFuture<TransportClientResponse>	get(java.lang.String requestPath, java.util.Map<java.lang.String,java.lang.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.
java.util.concurrent.CompletableFuture<TransportClientResponse>	post(java.lang.String requestPath, byte[] requestBody)
abstract java.util.concurrent.CompletableFuture<TransportClientResponse>	post(java.lang.String requestPath, java.util.Map<java.lang.String,java.lang.String> headers, byte[] requestBody)
abstract void	streamPost(java.lang.String requestPath, java.util.Map<java.lang.String,java.lang.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 Detail

HTTPS

protected static final java.lang.String HTTPS

See Also:

Constant Field Values

Constructor Detail

TransportClient

public TransportClient()

Method Detail

get

public java.util.concurrent.CompletableFuture<TransportClientResponse> get(java.lang.String requestPath)

post

public java.util.concurrent.CompletableFuture<TransportClientResponse> post(java.lang.String requestPath,
                                                                            byte[] requestBody)

get

public abstract java.util.concurrent.CompletableFuture<TransportClientResponse> get(java.lang.String requestPath,
                                                                                    java.util.Map<java.lang.String,java.lang.String> headers)

post

public abstract java.util.concurrent.CompletableFuture<TransportClientResponse> post(java.lang.String requestPath,
                                                                                     java.util.Map<java.lang.String,java.lang.String> headers,
                                                                                     byte[] requestBody)

streamPost

public abstract void streamPost(java.lang.String requestPath,
                                java.util.Map<java.lang.String,java.lang.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: