Package com.linkedin.venice.router.httpclient

Class HttpClient5StorageNodeClient

java.lang.Object

com.linkedin.venice.router.httpclient.HttpClient5StorageNodeClient

All Implemented Interfaces:

StorageNodeClient, java.io.Closeable, java.lang.AutoCloseable

public class HttpClient5StorageNodeClient
extends java.lang.Object
implements StorageNodeClient

Constructor Summary

Constructors

Constructor	Description
HttpClient5StorageNodeClient(java.util.Optional<SSLFactory> sslFactory, VeniceRouterConfig routerConfig)

Method Summary

Modifier and Type	Method	Description
void	close()	Close the client and release all resources held by the client
void	query(Instance host, VenicePath path, java.util.function.Consumer<PortableHttpResponse> completedCallBack, java.util.function.Consumer<java.lang.Throwable> failedCallBack, java.util.function.BooleanSupplier cancelledCallBack)	Send a request to storage node
void	sendRequest(VeniceMetaDataRequest request, java.util.concurrent.CompletableFuture<PortableHttpResponse> responseFuture)
void	start()	Start the client and prepare the required resources.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.linkedin.venice.router.httpclient.StorageNodeClient

isInstanceReadyToServe

Constructor Detail

HttpClient5StorageNodeClient

public HttpClient5StorageNodeClient(java.util.Optional<SSLFactory> sslFactory,
                                    VeniceRouterConfig routerConfig)

Method Detail

start

public void start()

Description copied from interface: StorageNodeClient

Start the client and prepare the required resources.

Specified by:

start in interface StorageNodeClient

close

public void close()

Description copied from interface: StorageNodeClient

Close the client and release all resources held by the client

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface StorageNodeClient

query

public void query(Instance host,
                  VenicePath path,
                  java.util.function.Consumer<PortableHttpResponse> completedCallBack,
                  java.util.function.Consumer<java.lang.Throwable> failedCallBack,
                  java.util.function.BooleanSupplier cancelledCallBack)
           throws RouterException

Description copied from interface: StorageNodeClient

Send a request to storage node

Specified by:

query in interface StorageNodeClient

Parameters:

host - The target host to which the request will be sent

path - contains information like URI, request content, HTTP method, etc.

completedCallBack - Callback function for a complete response

failedCallBack - if any exception thrown in the channel

cancelledCallBack - for requests that are cancelled by the channel

Throws:

RouterException

sendRequest

public void sendRequest(VeniceMetaDataRequest request,
                        java.util.concurrent.CompletableFuture<PortableHttpResponse> responseFuture)

Specified by:

sendRequest in interface StorageNodeClient