alluxio.master.transport

Class GrpcMessagingServer

java.lang.Object

alluxio.master.transport.GrpcMessagingServer

public class GrpcMessagingServer
extends Object

Server implementation based on Alluxio gRPC messaging. Each server should listen only one address. Outstanding listen futures should be completed before calling close().

Constructor Summary

Constructors

Constructor and Description
GrpcMessagingServer(AlluxioConfiguration conf, UserState userState, ExecutorService executor, GrpcMessagingProxy proxy) Creates a transport server that can be used to accept connections from remote clients.

Method Summary

Modifier and Type	Method and Description
CompletableFuture<Void>	close() Closes the connection to the server if exists.
CompletableFuture<Void>	listen(InetSocketAddress address, java.util.function.Consumer<GrpcMessagingConnection> listener) Listens to the given address.

Methods inherited from class java.lang.Object

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

Constructor Detail

GrpcMessagingServer

public GrpcMessagingServer(AlluxioConfiguration conf,
                           UserState userState,
                           ExecutorService executor,
                           GrpcMessagingProxy proxy)

Creates a transport server that can be used to accept connections from remote clients.

Parameters:

conf - Alluxio configuration

userState - authentication user

executor - transport executor

proxy - external proxy configuration

Method Detail

listen

public CompletableFuture<Void> listen(InetSocketAddress address,
                                      java.util.function.Consumer<GrpcMessagingConnection> listener)

Listens to the given address.

Parameters:

address - the address to connect to

listener - listener for new connections

Returns:

completable future of the connection

close

public CompletableFuture<Void> close()

Closes the connection to the server if exists.

Returns:

the close completable future