Package | Description |
---|---|
alluxio.grpc |
Modifier and Type | Method and Description |
---|---|
static GrpcManagedChannelPool.ChannelKey |
GrpcManagedChannelPool.ChannelKey.create(AlluxioConfiguration conf)
Creates a
GrpcManagedChannelPool.ChannelKey . |
GrpcManagedChannelPool.ChannelKey |
GrpcManagedChannelPool.ChannelKey.setAddress(SocketAddress address) |
GrpcManagedChannelPool.ChannelKey |
GrpcManagedChannelPool.ChannelKey.setChannelType(Class<? extends io.netty.channel.Channel> channelType) |
GrpcManagedChannelPool.ChannelKey |
GrpcManagedChannelPool.ChannelKey.setEventLoopGroup(io.netty.channel.EventLoopGroup eventLoopGroup) |
GrpcManagedChannelPool.ChannelKey |
GrpcManagedChannelPool.ChannelKey.setFlowControlWindow(int flowControlWindow) |
GrpcManagedChannelPool.ChannelKey |
GrpcManagedChannelPool.ChannelKey.setKeepAliveTime(long keepAliveTime,
TimeUnit timeUnit) |
GrpcManagedChannelPool.ChannelKey |
GrpcManagedChannelPool.ChannelKey.setKeepAliveTimeout(long keepAliveTimeout,
TimeUnit timeUnit) |
GrpcManagedChannelPool.ChannelKey |
GrpcManagedChannelPool.ChannelKey.setMaxInboundMessageSize(int maxInboundMessageSize) |
GrpcManagedChannelPool.ChannelKey |
GrpcManagedChannelPool.ChannelKey.setPoolingStrategy(GrpcManagedChannelPool.PoolingStrategy strategy) |
Modifier and Type | Method and Description |
---|---|
io.grpc.ManagedChannel |
GrpcManagedChannelPool.acquireManagedChannel(GrpcManagedChannelPool.ChannelKey channelKey,
long healthCheckTimeoutMs,
long shutdownTimeoutMs)
Acquires and increases the ref-count for the
ManagedChannel . |
void |
GrpcManagedChannelPool.releaseManagedChannel(GrpcManagedChannelPool.ChannelKey channelKey,
long shutdownTimeoutMs)
Decreases the ref-count of the
ManagedChannel for the given address. |
Constructor and Description |
---|
GrpcChannel(GrpcManagedChannelPool.ChannelKey channelKey,
AuthenticatedChannel channel,
long shutdownTimeoutMs)
Create a new instance of
GrpcChannel with an authenticated channel. |
GrpcChannel(GrpcManagedChannelPool.ChannelKey channelKey,
io.grpc.Channel channel,
long shutdownTimeoutMs)
Create a new instance of
GrpcChannel . |
Copyright © 2023. All Rights Reserved.