public class GrpcChannelKey extends Object
GrpcChannel
.Modifier and Type | Class and Description |
---|---|
protected static interface |
GrpcChannelKey.IdentityField |
static class |
GrpcChannelKey.PoolingStrategy
Enumeration to determine the pooling strategy.
|
public static GrpcChannelKey create(AlluxioConfiguration conf)
GrpcChannelKey
.conf
- the Alluxio configurationpublic UUID getChannelId()
public GrpcServerAddress getServerAddress()
public GrpcChannelKey setServerAddress(GrpcServerAddress address)
address
- destination address of the channelGrpcChannelKey
public Optional<Integer> getMaxInboundMessageSize()
public GrpcChannelKey setMaxInboundMessageSize(int maxInboundMessageSize)
maxInboundMessageSize
- max inbound message size for the underlying channelGrpcChannelKey
public Optional<Integer> getFlowControlWindow()
public GrpcChannelKey setFlowControlWindow(int flowControlWindow)
flowControlWindow
- flow control window value for the underlying channelGrpcChannelKey
public Optional<Class<? extends io.netty.channel.Channel>> getChannelType()
public GrpcChannelKey setChannelType(Class<? extends io.netty.channel.Channel> channelType)
channelType
- channel type for the underlying channelGrpcChannelKey
public Optional<io.netty.channel.EventLoopGroup> getEventLoopGroup()
public GrpcChannelKey setEventLoopGroup(io.netty.channel.EventLoopGroup eventLoopGroup)
eventLoopGroup
- event loop group for the underlying channelGrpcChannelKey
public Optional<String> getChannelName()
public GrpcChannelKey setClientType(String clientType)
clientType
- channel client typeGrpcChannelKey
public Optional<Pair<Long,TimeUnit>> getKeepAliveTime()
public GrpcChannelKey setKeepAliveTime(long keepAliveTime, TimeUnit timeUnit)
keepAliveTime
- keep alive time for the underlying channeltimeUnit
- time unit for the keepAliveTime parameterGrpcChannelKey
public Optional<Pair<Long,TimeUnit>> getKeepAliveTimeout()
public GrpcChannelKey setKeepAliveTimeout(long keepAliveTimeout, TimeUnit timeUnit)
keepAliveTimeout
- keep alive timeout for the underlying channeltimeUnit
- time unit for the keepAliveTimeout parameterGrpcChannelKey
public GrpcChannelKey setPoolingStrategy(GrpcChannelKey.PoolingStrategy strategy)
strategy
- the pooling strategyGrpcChannelKey
public String toStringShort()
Copyright © 2023. All Rights Reserved.