Package | Description |
---|---|
alluxio | |
alluxio.client.block.stream | |
alluxio.grpc |
Modifier and Type | Field and Description |
---|---|
protected GrpcServerAddress |
AbstractClient.mServerAddress
Grpc Address of the remote server.
|
Modifier and Type | Method and Description |
---|---|
protected GrpcServerAddress |
AbstractMasterClient.queryGrpcServerAddress() |
protected abstract GrpcServerAddress |
AbstractClient.queryGrpcServerAddress()
AbstractClient works with Grpc Servers. |
Modifier and Type | Method and Description |
---|---|
protected GrpcServerAddress |
BlockWorkerClientPool.getAddress() |
Modifier and Type | Method and Description |
---|---|
static BlockWorkerClient |
BlockWorkerClient.Factory.create(UserState userState,
GrpcServerAddress address,
AlluxioConfiguration alluxioConf)
Creates a new block worker client.
|
Constructor and Description |
---|
BlockWorkerClientPool(UserState userState,
GrpcServerAddress address,
int minCapacity,
int maxCapacity,
AlluxioConfiguration alluxioConf)
Creates a new block master client pool.
|
DefaultBlockWorkerClient(UserState userState,
GrpcServerAddress address,
AlluxioConfiguration alluxioConf)
Creates a client instance for communicating with block worker.
|
DefaultBlockWorkerClient(UserState userState,
GrpcServerAddress address,
AlluxioConfiguration alluxioConf,
GrpcChannel streamingChannel,
GrpcChannel rpcChannel) |
Modifier and Type | Method and Description |
---|---|
static GrpcServerAddress |
GrpcServerAddress.create(InetSocketAddress socketAddress) |
static GrpcServerAddress |
GrpcServerAddress.create(String hostName,
SocketAddress socketAddress) |
protected GrpcServerAddress |
GrpcChannelBuilder.getAddress() |
GrpcServerAddress |
GrpcChannelKey.getServerAddress() |
Modifier and Type | Method and Description |
---|---|
GrpcChannel |
GrpcChannelPool.acquireChannel(GrpcNetworkGroup networkGroup,
GrpcServerAddress serverAddress,
AlluxioConfiguration conf,
boolean alwaysEnableTLS)
Acquires and increases the ref-count for the
ManagedChannel . |
static GrpcServerBuilder |
GrpcServerBuilder.forAddress(GrpcServerAddress serverAddress,
AlluxioConfiguration conf)
Create an new instance of
GrpcServerBuilder with authentication support. |
static GrpcServerBuilder |
GrpcServerBuilder.forAddress(GrpcServerAddress serverAddress,
AuthenticationServer authenticationServer,
AlluxioConfiguration conf)
Create a new instance of
GrpcServerBuilder with authentication support. |
static GrpcChannelBuilder |
GrpcChannelBuilder.newBuilder(GrpcServerAddress address,
AlluxioConfiguration conf)
Create a channel builder for given address using the given configuration.
|
static GrpcChannelBuilder |
GrpcChannelBuilder.newBuilder(GrpcServerAddress address,
AlluxioConfiguration conf,
AuthType authType,
boolean alwaysEnableTLS)
Create a channel builder for given address using the given configuration.
|
static GrpcChannelBuilder |
GrpcChannelBuilder.newBuilder(GrpcServerAddress address,
AlluxioConfiguration conf,
boolean alwaysEnableTLS)
Create a channel builder for given address using the given configuration.
|
Constructor and Description |
---|
GrpcChannelBuilder(GrpcServerAddress address,
AlluxioConfiguration conf,
AuthType authType,
boolean alwaysEnableTLS) |
GrpcChannelKey(GrpcNetworkGroup networkGroup,
GrpcServerAddress serverAddress,
int groupIndex)
Constructor.
|
Copyright © 2023. All Rights Reserved.