Uses of Class
alluxio.master.transport.GrpcMessagingConnection

Packages that use GrpcMessagingConnection

Package	Description
alluxio.master.backup
alluxio.master.transport

Uses of GrpcMessagingConnection in alluxio.master.backup

Methods in alluxio.master.backup that return GrpcMessagingConnection

Modifier and Type	Method and Description
GrpcMessagingConnection	BackupHandshakeMessage.getConnection()

Methods in alluxio.master.backup with parameters of type GrpcMessagingConnection

Modifier and Type	Method and Description
protected void	AbstractBackupRole.sendMessageBlocking(GrpcMessagingConnection connection, Object message) Used to send message via connection and wait until response is received.
void	BackupHandshakeMessage.setConnection(GrpcMessagingConnection connection)

Uses of GrpcMessagingConnection in alluxio.master.transport

Subclasses of GrpcMessagingConnection in alluxio.master.transport

Modifier and Type	Class and Description
class	GrpcMessagingClientConnection GrpcMessagingConnection implementation for clients.
class	GrpcMessagingServerConnection GrpcMessagingConnection implementation for server.

Methods in alluxio.master.transport that return GrpcMessagingConnection

Modifier and Type	Method and Description
<T,U> GrpcMessagingConnection	GrpcMessagingConnection.handler(Class<T> type, java.util.function.Consumer<T> handler) Registers a new message handler.
<T,U> GrpcMessagingConnection	GrpcMessagingConnection.handler(Class<T> type, java.util.function.Function<T,CompletableFuture<U>> handler) Registers a new message handler.

Methods in alluxio.master.transport that return types with arguments of type GrpcMessagingConnection

Modifier and Type	Method and Description
CompletableFuture<GrpcMessagingConnection>	GrpcMessagingClient.connect(InetSocketAddress address) Creates a client and connects to the given address.
Listener<GrpcMessagingConnection>	GrpcMessagingConnection.onClose(java.util.function.Consumer<GrpcMessagingConnection> listener) Adds a close listener.

Method parameters in alluxio.master.transport with type arguments of type GrpcMessagingConnection

Modifier and Type	Method and Description
CompletableFuture<Void>	GrpcMessagingServer.listen(InetSocketAddress address, java.util.function.Consumer<GrpcMessagingConnection> listener) Listens to the given address.
Listener<GrpcMessagingConnection>	GrpcMessagingConnection.onClose(java.util.function.Consumer<GrpcMessagingConnection> listener) Adds a close listener.

Constructor parameters in alluxio.master.transport with type arguments of type GrpcMessagingConnection

Constructor and Description
GrpcMessagingServiceClientHandler(InetSocketAddress serverAddress, java.util.function.Consumer<GrpcMessagingConnection> listener, GrpcMessagingContext context, ExecutorService executor, long requestTimeoutMs)