Package | Description |
---|---|
alluxio.grpc | |
alluxio.security.authentication |
Modifier and Type | Method and Description |
---|---|
static GrpcChannelKey |
GrpcChannelKey.create(AlluxioConfiguration conf)
Creates a
GrpcChannelKey . |
GrpcChannelKey |
GrpcChannelKey.setChannelType(Class<? extends io.netty.channel.Channel> channelType) |
GrpcChannelKey |
GrpcChannelKey.setClientType(String clientType)
Sets human readable name for the channel's client.
|
GrpcChannelKey |
GrpcChannelKey.setEventLoopGroup(io.netty.channel.EventLoopGroup eventLoopGroup) |
GrpcChannelKey |
GrpcChannelKey.setFlowControlWindow(int flowControlWindow) |
GrpcChannelKey |
GrpcChannelKey.setKeepAliveTime(long keepAliveTime,
TimeUnit timeUnit) |
GrpcChannelKey |
GrpcChannelKey.setKeepAliveTimeout(long keepAliveTimeout,
TimeUnit timeUnit) |
GrpcChannelKey |
GrpcChannelKey.setMaxInboundMessageSize(int maxInboundMessageSize) |
GrpcChannelKey |
GrpcChannelKey.setPoolingStrategy(GrpcChannelKey.PoolingStrategy strategy) |
GrpcChannelKey |
GrpcChannelKey.setServerAddress(GrpcServerAddress address) |
Modifier and Type | Method and Description |
---|---|
io.grpc.ManagedChannel |
GrpcManagedChannelPool.acquireManagedChannel(GrpcChannelKey channelKey,
long healthCheckTimeoutMs,
long shutdownTimeoutMs)
Acquires and increases the ref-count for the
ManagedChannel . |
void |
GrpcManagedChannelPool.releaseManagedChannel(GrpcChannelKey channelKey,
long shutdownTimeoutMs)
Decreases the ref-count of the
ManagedChannel for the given address. |
Constructor and Description |
---|
GrpcChannel(GrpcChannelKey channelKey,
AuthenticatedChannel channel,
long shutdownTimeoutMs)
Create a new instance of
GrpcChannel with an authenticated channel. |
GrpcChannel(GrpcChannelKey channelKey,
io.grpc.Channel channel,
long shutdownTimeoutMs)
Create a new instance of
GrpcChannel . |
Modifier and Type | Field and Description |
---|---|
protected GrpcChannelKey |
ChannelAuthenticator.mChannelKey
Key for to-be-authenticated channel.
|
Constructor and Description |
---|
ChannelAuthenticator(GrpcChannelKey channelKey,
String userName,
String password,
String impersonationUser,
AuthType authType,
long grpcAuthTimeoutMs)
Creates
ChannelAuthenticator instance. |
ChannelAuthenticator(GrpcChannelKey channelKey,
Subject subject,
AlluxioConfiguration conf)
Creates
ChannelAuthenticator instance. |
SaslStreamClientDriver(SaslHandshakeClientHandler handshakeClient,
AtomicBoolean authenticated,
GrpcChannelKey channelKey,
long grpcAuthTimeoutMs)
Creates client driver with given handshake handler.
|
Copyright © 2023. All Rights Reserved.