Package com.linkedin.venice.router.httpclient

Interface StorageNodeClient

All Superinterfaces:

AutoCloseable, Closeable

All Known Implementing Classes:

ApacheHttpAsyncStorageNodeClient, HttpClient5StorageNodeClient

public interface StorageNodeClient
extends Closeable

Method Summary

Modifier and Type	Method	Description
void	close()	Close the client and release all resources held by the client
default boolean	isInstanceReadyToServe(String instanceId)
void	query(Instance host, VenicePath path, Consumer<PortableHttpResponse> completedCallBack, Consumer<Throwable> failedCallBack, BooleanSupplier cancelledCallBack)	Send a request to storage node
default void	sendRequest(VeniceMetaDataRequest request, CompletableFuture<PortableHttpResponse> responseConsumer)
void	start()	Start the client and prepare the required resources.

Method Details

start

void start()

Start the client and prepare the required resources.

close

void close()

Close the client and release all resources held by the client

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

query

void query(Instance host,
 VenicePath path,
 Consumer<PortableHttpResponse> completedCallBack,
 Consumer<Throwable> failedCallBack,
 BooleanSupplier cancelledCallBack)
    throws RouterException

Send a request to storage node

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

isInstanceReadyToServe

default boolean isInstanceReadyToServe(String instanceId)

sendRequest

default void sendRequest(VeniceMetaDataRequest request,
 CompletableFuture<PortableHttpResponse> responseConsumer)