Package com.linkedin.venice.router.httpclient

Class ApacheHttpAsyncStorageNodeClient

java.lang.Object

com.linkedin.venice.router.httpclient.ApacheHttpAsyncStorageNodeClient

All Implemented Interfaces:

StorageNodeClient, Closeable, AutoCloseable

public class ApacheHttpAsyncStorageNodeClient
extends Object
implements StorageNodeClient

Constructor Summary

Constructors

Constructor	Description
ApacheHttpAsyncStorageNodeClient(VeniceRouterConfig config, Optional<SSLFactory> sslFactory, io.tehuti.metrics.MetricsRepository metricsRepository, LiveInstanceMonitor monitor)

Method Summary

Modifier and Type	Method	Description
void	close()	Close the client and release all resources held by the client
org.apache.http.impl.nio.client.CloseableHttpAsyncClient	getHttpClientForHost(String host)
boolean	isInstanceReadyToServe(String instanceId)
void	query(Instance host, VenicePath path, Consumer<PortableHttpResponse> completedCallBack, Consumer<Throwable> failedCallBack, BooleanSupplier cancelledCallBack)	Send a request to storage node
void	sendRequest(VeniceMetaDataRequest request, 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

Constructor Details

ApacheHttpAsyncStorageNodeClient

public ApacheHttpAsyncStorageNodeClient(VeniceRouterConfig config,
 Optional<SSLFactory> sslFactory,
 io.tehuti.metrics.MetricsRepository metricsRepository,
 LiveInstanceMonitor monitor)

Method Details

getHttpClientForHost

public org.apache.http.impl.nio.client.CloseableHttpAsyncClient getHttpClientForHost(String host)

start

public void start()

Description copied from interface: StorageNodeClient

Start the client and prepare the required resources.

Specified by:

start in interface StorageNodeClient

isInstanceReadyToServe

public boolean isInstanceReadyToServe(String instanceId)

Specified by:

isInstanceReadyToServe 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 AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface StorageNodeClient

sendRequest

public void sendRequest(VeniceMetaDataRequest request,
 CompletableFuture<PortableHttpResponse> responseFuture)

Specified by:

sendRequest in interface StorageNodeClient

query

public void query(Instance host,
 VenicePath path,
 Consumer<PortableHttpResponse> completedCallBack,
 Consumer<Throwable> failedCallBack,
 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