Package com.linkedin.venice.fastclient.transport

Class R2TransportClient

java.lang.Object

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

com.linkedin.venice.fastclient.transport.InternalTransportClient

com.linkedin.venice.fastclient.transport.R2TransportClient

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class R2TransportClient
extends InternalTransportClient

R2 based Transport Client Interface. So far, this class doesn't do anything special about the connection management, such as connection pool (size), and connection warming and so on, and we will rely on the features offered by R2. If we notice anything specific required to be implemented outside of R2, we will improve the implementation here.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	R2TransportClient.R2TransportClientCallback

Field Summary

Fields inherited from class com.linkedin.venice.client.store.transport.TransportClient

HTTPS

Constructor Summary

Constructors

Constructor	Description
R2TransportClient(com.linkedin.r2.transport.common.Client r2Client)

Method Summary

Modifier and Type	Method	Description
void	close()
java.util.concurrent.CompletableFuture<TransportClientResponse>	get(java.lang.String requestUrl, java.util.Map<java.lang.String,java.lang.String> headers)
java.util.concurrent.CompletableFuture<TransportClientResponse>	post(java.lang.String requestUrl, java.util.Map<java.lang.String,java.lang.String> headers, byte[] requestBody)

Methods inherited from class com.linkedin.venice.fastclient.transport.InternalTransportClient

streamPost

Methods inherited from class com.linkedin.venice.client.store.transport.TransportClient

get, getCopyIfNotUsableInCallback, post

Methods inherited from class java.lang.Object

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

Constructor Detail

R2TransportClient

public R2TransportClient(com.linkedin.r2.transport.common.Client r2Client)

Method Detail

get

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

Specified by:

get in class TransportClient

post

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

Specified by:

post in class TransportClient

close

public void close()
           throws java.io.IOException

Throws:

java.io.IOException