Package | Description |
---|---|
alluxio.master.backup | |
alluxio.master.transport |
Modifier and Type | Field and Description |
---|---|
protected GrpcMessagingContext |
AbstractBackupRole.mGrpcMessagingContext
Catalyst context used for sending/receiving messages.
|
Modifier and Type | Method and Description |
---|---|
GrpcMessagingContext |
GrpcMessagingThread.getContext() |
Modifier and Type | Method and Description |
---|---|
void |
GrpcMessagingThread.setContext(GrpcMessagingContext context)
Sets the Grpc messaging context.
|
Constructor and Description |
---|
GrpcMessagingClientConnection(GrpcMessagingContext context,
ExecutorService executor,
GrpcChannel channel,
long requestTimeoutMs)
Creates a messaging connection for client.
|
GrpcMessagingConnection(GrpcMessagingConnection.ConnectionOwner connectionOwner,
String transportId,
GrpcMessagingContext context,
ExecutorService executor,
long requestTimeoutMs)
Creates a connection object.
|
GrpcMessagingServerConnection(String transportId,
GrpcMessagingContext context,
ExecutorService executor,
long requestTimeoutMs)
Creates a messaging connection for server.
|
GrpcMessagingServiceClientHandler(InetSocketAddress serverAddress,
java.util.function.Consumer<GrpcMessagingConnection> listener,
GrpcMessagingContext context,
ExecutorService executor,
long requestTimeoutMs) |
Copyright © 2023. All Rights Reserved.