Package com.linkedin.venice.fastclient.transport

Class GrpcTransportClient

java.lang.Object

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

com.linkedin.venice.fastclient.transport.InternalTransportClient

com.linkedin.venice.fastclient.transport.GrpcTransportClient

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class GrpcTransportClient
extends InternalTransportClient

Field Summary

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

HTTPS

Constructor Summary

Constructors

Constructor	Description
GrpcTransportClient(GrpcClientConfig grpcClientConfig)

Method Summary

Modifier and Type	Method	Description
void	close()
java.util.concurrent.CompletableFuture<TransportClientResponse>	get(java.lang.String requestPath, java.util.Map<java.lang.String,java.lang.String> headers)
java.util.concurrent.CompletableFuture<TransportClientResponse>	post(java.lang.String requestPath, 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

GrpcTransportClient

public GrpcTransportClient(GrpcClientConfig grpcClientConfig)

Method Detail

get

public java.util.concurrent.CompletableFuture<TransportClientResponse> get(java.lang.String requestPath,
                                                                           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 requestPath,
                                                                            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