Package | Description |
---|---|
alluxio.client.block.stream | |
alluxio.grpc | |
alluxio.security.authentication |
Modifier and Type | Method and Description |
---|---|
static BlockWorkerClient |
BlockWorkerClient.Factory.create(Subject subject,
GrpcServerAddress address,
AlluxioConfiguration alluxioConf,
io.netty.channel.EventLoopGroup workerGroup)
Creates a new block worker client.
|
Constructor and Description |
---|
BlockWorkerClientPool(Subject subject,
GrpcServerAddress address,
int maxCapacity,
AlluxioConfiguration alluxioConf,
io.netty.channel.EventLoopGroup workerGroup)
Creates a new block master client pool.
|
DefaultBlockWorkerClient(Subject subject,
GrpcServerAddress address,
AlluxioConfiguration alluxioConf,
io.netty.channel.EventLoopGroup workerGroup)
Creates a client instance for communicating with block worker.
|
Modifier and Type | Method and Description |
---|---|
static GrpcChannelBuilder |
GrpcChannelBuilder.newBuilder(GrpcServerAddress address,
AlluxioConfiguration conf)
Create a channel builder for given address using the given configuration.
|
Modifier and Type | Method and Description |
---|---|
AuthenticatedChannel |
ChannelAuthenticator.authenticate(GrpcServerAddress serverAddress,
io.grpc.ManagedChannel managedChannel)
Authenticates given
NettyChannelBuilder instance. |
Copyright © 2023. All Rights Reserved.