Package | Description |
---|---|
alluxio.network.netty | |
alluxio.network.protocol | |
alluxio.util.proto |
Modifier and Type | Method and Description |
---|---|
static ProtoMessage |
NettyRPC.call(NettyRPCContext context,
ProtoMessage request)
Sends a request and waits for a response.
|
Modifier and Type | Method and Description |
---|---|
static ProtoMessage |
NettyRPC.call(NettyRPCContext context,
ProtoMessage request)
Sends a request and waits for a response.
|
static void |
NettyRPC.fireAndForget(NettyRPCContext context,
ProtoMessage request)
Sends a request and waits until the request is flushed to network.
|
Constructor and Description |
---|
RPCHandler(io.netty.util.concurrent.Promise<ProtoMessage> promise)
Creates an instance of
NettyRPC.RPCHandler . |
Modifier and Type | Method and Description |
---|---|
ProtoMessage |
RPCProtoMessage.getMessage() |
Modifier and Type | Method and Description |
---|---|
static RPCProtoMessage |
RPCProtoMessage.decode(io.netty.buffer.ByteBuf in,
ProtoMessage prototype)
Decodes the message from a buffer.
|
Constructor and Description |
---|
RPCProtoMessage(byte[] serialized,
ProtoMessage prototype,
DataBuffer data)
Creates an instance of
RPCProtoMessage from a serialized proto message. |
RPCProtoMessage(ProtoMessage message)
Creates an instance of
RPCProtoMessage without data part. |
RPCProtoMessage(ProtoMessage message,
DataBuffer data)
Creates an instance of
RPCProtoMessage . |
Modifier and Type | Method and Description |
---|---|
static ProtoMessage |
ProtoMessage.parseFrom(byte[] serialized,
ProtoMessage prototype)
Parses proto message from bytes given a prototype.
|
Modifier and Type | Method and Description |
---|---|
static ProtoMessage |
ProtoMessage.parseFrom(byte[] serialized,
ProtoMessage prototype)
Parses proto message from bytes given a prototype.
|
Copyright © 2023. All Rights Reserved.