public final class QuicClientConfig extends TransportConfig
Modifier and Type | Field and Description |
---|---|
static String |
QUIC_CLIENT_PREFIX
Name prefix that will be used for the QUIC client's metrics
registered in Micrometer's global registry.
|
Modifier and Type | Method and Description |
---|---|
long |
ackDelayExponent()
Return the configured delay exponent used for ACKs or the default.
|
protected Class<? extends Channel> |
channelType(boolean isDomainSocket)
Return the channel type this configuration is associated with, it can be one of the following.
|
QuicCongestionControlAlgorithm |
congestionControlAlgorithm()
Return the configured
QuicCongestionControlAlgorithm or the default. |
protected ConnectionObserver |
defaultConnectionObserver()
Return the configured default
ConnectionObserver . |
protected LoggingHandler |
defaultLoggingHandler()
Return the default
LoggingHandler to wiretap this transport. |
protected LoopResources |
defaultLoopResources()
Return the default
LoopResources for this transport. |
protected ChannelMetricsRecorder |
defaultMetricsRecorder()
Return the configured metrics recorder.
|
protected ChannelPipelineConfigurer |
defaultOnChannelInit()
Return the default callback if any or
ChannelPipelineConfigurer.emptyConfigurer() . |
Consumer<? super CONF> |
doOnBind()
Return the configured callback or null.
|
Consumer<? super Connection> |
doOnBound()
Return the configured callback or null.
|
Consumer<? super QuicClientConfig> |
doOnConnect()
Return the configured callback or null.
|
Consumer<? super QuicConnection> |
doOnConnected()
Return the configured callback or null.
|
Consumer<? super QuicConnection> |
doOnDisconnected()
Return the configured callback or null.
|
Consumer<? super Connection> |
doOnUnbound()
Return the configured callback or null.
|
protected EventLoopGroup |
eventLoopGroup()
Return the configured
EventLoopGroup . |
Duration |
idleTimeout()
Return the configured idle timeout or null.
|
QuicInitialSettingsSpec |
initialSettings()
Return the configured QUIC initial settings or the default.
|
boolean |
isActiveMigration()
Return true if active migration is enabled.
|
boolean |
isGrease()
Return true if greasing is enabled.
|
boolean |
isHystart()
Return true if Hystart is enabled.
|
int |
localConnectionIdLength()
Return the configured local connection id length that is used or the default.
|
Duration |
maxAckDelay()
Return the configured the max ACK delay or the default.
|
long |
maxRecvUdpPayloadSize()
Return the configured the maximum payload size or the default.
|
long |
maxSendUdpPayloadSize()
Return the configured the maximum payload size or the default.
|
protected ChannelInitializer<Channel> |
parentChannelInitializer() |
int |
recvQueueLen()
Return the configured RECV queue length.
|
Supplier<? extends SocketAddress> |
remoteAddress()
Return the remote configured
SocketAddress . |
int |
sendQueueLen()
Return the configured SEND queue length.
|
Map<AttributeKey<?>,?> |
streamAttributes()
Return the read-only default stream attributes.
|
ConnectionObserver |
streamObserver()
Return the configured
ConnectionObserver if any or
ConnectionObserver.emptyListener() for each stream. |
Map<ChannelOption<?>,?> |
streamOptions()
Return the read-only
ChannelOption map for each stream. |
protected static <K,V> Map<K,V> |
updateMap(Map<K,V> parentMap,
Object key,
Object value) |
attributes, bindAddress, bindAddress, channelGroup, channelHash, channelInitializer, channelOperationsProvider, connectionFactory, connectionObserver, doOnChannelInit, isPreferNative, loggingHandler, loggingHandler, loopResources, metricsRecorder, metricsRecorder, metricsRecorderInternal, options
public static final String QUIC_CLIENT_PREFIX
@Nullable public Consumer<? super QuicClientConfig> doOnConnect()
@Nullable public Consumer<? super QuicConnection> doOnConnected()
@Nullable public Consumer<? super QuicConnection> doOnDisconnected()
public Supplier<? extends SocketAddress> remoteAddress()
SocketAddress
.SocketAddress
protected ConnectionObserver defaultConnectionObserver()
TransportConfig
ConnectionObserver
.ConnectionObserver
protected LoggingHandler defaultLoggingHandler()
TransportConfig
LoggingHandler
to wiretap this transport.defaultLoggingHandler
in class TransportConfig
LoggingHandler
to wiretap this transportprotected ChannelMetricsRecorder defaultMetricsRecorder()
TransportConfig
defaultMetricsRecorder
in class TransportConfig
protected ChannelInitializer<Channel> parentChannelInitializer()
public final long ackDelayExponent()
public final QuicCongestionControlAlgorithm congestionControlAlgorithm()
QuicCongestionControlAlgorithm
or the default.QuicCongestionControlAlgorithm
or the default@Nullable public final Consumer<? super CONF> doOnBind()
@Nullable public final Consumer<? super Connection> doOnBound()
@Nullable public final Consumer<? super Connection> doOnUnbound()
@Nullable public final Duration idleTimeout()
public final QuicInitialSettingsSpec initialSettings()
public final boolean isActiveMigration()
public final boolean isGrease()
public final boolean isHystart()
public final int localConnectionIdLength()
public final Duration maxAckDelay()
public final long maxRecvUdpPayloadSize()
public final long maxSendUdpPayloadSize()
public final int recvQueueLen()
public final int sendQueueLen()
public final Map<AttributeKey<?>,?> streamAttributes()
public final ConnectionObserver streamObserver()
ConnectionObserver
if any or
ConnectionObserver.emptyListener()
for each stream.ConnectionObserver
if any or
ConnectionObserver.emptyListener()
for each streampublic final Map<ChannelOption<?>,?> streamOptions()
ChannelOption
map for each stream.ChannelOption
map for each streamprotected final Class<? extends Channel> channelType(boolean isDomainSocket)
TransportConfig
channelType
in class TransportConfig
isDomainSocket
- true if DomainSocketChannel
or
ServerDomainSocketChannel
is needed, false otherwiseprotected final LoopResources defaultLoopResources()
TransportConfig
LoopResources
for this transport.defaultLoopResources
in class TransportConfig
LoopResources
for this transportprotected ChannelPipelineConfigurer defaultOnChannelInit()
TransportConfig
ChannelPipelineConfigurer.emptyConfigurer()
.defaultOnChannelInit
in class TransportConfig
ChannelPipelineConfigurer.emptyConfigurer()
protected final EventLoopGroup eventLoopGroup()
TransportConfig
EventLoopGroup
.eventLoopGroup
in class TransportConfig
EventLoopGroup