Package | Description |
---|---|
alluxio.network | |
alluxio.util.network | |
alluxio.worker.grpc |
Modifier and Type | Method and Description |
---|---|
static ChannelType |
ChannelType.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static ChannelType[] |
ChannelType.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Field and Description |
---|---|
static ChannelType |
NettyUtils.CHANNEL_TYPE |
Modifier and Type | Method and Description |
---|---|
static ChannelType |
NettyUtils.getChannelType(PropertyKey key,
AlluxioConfiguration conf)
Get the proper channel type.
|
static ChannelType |
NettyUtils.getUserChannel(AlluxioConfiguration conf)
Gets the ChannelType properly from the USER_NETWORK_NETTY_CHANNEL property key.
|
static ChannelType |
NettyUtils.getWorkerChannel(AlluxioConfiguration conf)
Gets the worker channel properly from the WORKER_NETWORK_NETTY_CHANNEL property key.
|
Modifier and Type | Method and Description |
---|---|
static io.netty.channel.EventLoopGroup |
NettyUtils.createEventLoop(ChannelType type,
int numThreads,
String threadPrefix,
boolean isDaemon)
Creates a Netty
EventLoopGroup based on ChannelType . |
static Class<? extends io.netty.channel.ServerChannel> |
NettyUtils.getServerChannelClass(ChannelType workerChannelType,
boolean isDomainSocket)
Returns the correct
ServerSocketChannel class for use by the
worker. |
Modifier and Type | Method and Description |
---|---|
protected GrpcServerBuilder |
GrpcDataServer.createServerBuilder(String hostName,
SocketAddress bindAddress,
ChannelType type) |
Copyright © 2023. All Rights Reserved.