org.apache.paimon.service.network

Class NetworkClient<REQ extends MessageBody,RESP extends MessageBody>

java.lang.Object

org.apache.paimon.service.network.NetworkClient<REQ,RESP>

Type Parameters:

REQ - the type of request the client will send.

RESP - the type of response the client expects to receive.

public class NetworkClient<REQ extends MessageBody,RESP extends MessageBody>
extends Object

The base class for every client. It is using pure netty to send and receive messages of type MessageBody.

Constructor Summary

Constructors

Constructor and Description
NetworkClient(String clientName, int numEventLoopThreads, MessageSerializer<REQ,RESP> serializer, ServiceRequestStats stats) Creates a client with the specified number of event loop threads.

Method Summary

Modifier and Type	Method and Description
String	getClientName()
boolean	isEventGroupShutdown()
CompletableFuture<RESP>	sendRequest(InetSocketAddress serverAddress, REQ request)
CompletableFuture<Void>	shutdown() Shuts down the client and closes all connections.

Methods inherited from class java.lang.Object

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

Constructor Detail

NetworkClient

public NetworkClient(String clientName,
                     int numEventLoopThreads,
                     MessageSerializer<REQ,RESP> serializer,
                     ServiceRequestStats stats)

Creates a client with the specified number of event loop threads.

Parameters:

clientName - the name of the client.

numEventLoopThreads - number of event loop threads (minimum 1).

serializer - the serializer used to (de-)serialize messages.

stats - the statistics collector.

Method Detail

getClientName

public String getClientName()

sendRequest

public CompletableFuture<RESP> sendRequest(InetSocketAddress serverAddress,
                                           REQ request)

shutdown

public CompletableFuture<Void> shutdown()

Shuts down the client and closes all connections.

After a call to this method, all returned futures will be failed.

Returns:

A CompletableFuture that will be completed when the shutdown process is done.

isEventGroupShutdown

public boolean isEventGroupShutdown()