Package | Description |
---|---|
alluxio.network.netty |
Modifier and Type | Method and Description |
---|---|
static NettyRPCContext |
NettyRPCContext.defaults() |
NettyRPCContext |
NettyRPCContext.setChannel(io.netty.channel.Channel channel) |
NettyRPCContext |
NettyRPCContext.setTimeout(long timeoutMs) |
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.
|
Copyright © 2023. All Rights Reserved.