alluxio.master.transport

Class GrpcMessagingClient

java.lang.Object

alluxio.master.transport.GrpcMessagingClient

public class GrpcMessagingClient
extends Object

Client implementation based on Alluxio gRPC messaging. Listen should be called once for each distinct address. Pending futures should all be closed prior to calling close().

Constructor Summary

Constructors

Constructor and Description
GrpcMessagingClient(AlluxioConfiguration conf, UserState userState, ExecutorService executor, String clientType) Creates messaging client that can be used to connect to remote messaging servers.

Method Summary

Modifier and Type	Method and Description
CompletableFuture<Void>	close() Closes the client.
CompletableFuture<GrpcMessagingConnection>	connect(InetSocketAddress address) Creates a client and connects to the given address.

Methods inherited from class java.lang.Object

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

Constructor Detail

GrpcMessagingClient

public GrpcMessagingClient(AlluxioConfiguration conf,
                           UserState userState,
                           ExecutorService executor,
                           String clientType)

Creates messaging client that can be used to connect to remote messaging servers.

Parameters:

conf - Alluxio configuration

userState - authentication user

executor - messaging executor

clientType - transport client type

Method Detail

connect

public CompletableFuture<GrpcMessagingConnection> connect(InetSocketAddress address)

Creates a client and connects to the given address.

Parameters:

address - the server address

Returns:

future of connection result

close

public CompletableFuture<Void> close()

Closes the client.

Returns:

future of result