alluxio.master.transport

Class GrpcMessagingServer

java.lang.Object

alluxio.master.transport.GrpcMessagingServer

All Implemented Interfaces:

io.atomix.catalyst.transport.Server

public class GrpcMessagingServer
extends Object
implements io.atomix.catalyst.transport.Server

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()
CompletableFuture<Void>	listen(io.atomix.catalyst.transport.Address address, java.util.function.Consumer<io.atomix.catalyst.transport.Connection> listener)

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(io.atomix.catalyst.transport.Address address,
                                      java.util.function.Consumer<io.atomix.catalyst.transport.Connection> listener)

Specified by:

listen in interface io.atomix.catalyst.transport.Server

close

public CompletableFuture<Void> close()

Specified by:

close in interface io.atomix.catalyst.transport.Server