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)
protected io.grpc.ManagedChannel	getChannel(java.lang.String serverAddress)
protected VeniceReadServiceGrpc.VeniceReadServiceStub	getStub(io.grpc.ManagedChannel channel)
java.util.concurrent.CompletableFuture<TransportClientResponse>	handleRequest(java.lang.String requestPath, java.util.Map<java.lang.String,java.lang.String> headers, byte[] requestBody, boolean isSingleGet)
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

getChannel

protected io.grpc.ManagedChannel getChannel(java.lang.String serverAddress)

getStub

protected VeniceReadServiceGrpc.VeniceReadServiceStub getStub(io.grpc.ManagedChannel channel)

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

handleRequest

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