Nested and Inner Type Summary

Modifier and Type	Class and Description
pack-priv static class	ClientTransportConfig.ClientTransportChannelInitializer
pack-priv static class	ClientTransportConfig.ClientTransportDoOn

Modifier and Type	Field and Description
pack-priv final ConnectionProvider	connectionProvider
pack-priv static final NameResolverProvider	DEFAULT_NAME_RESOLVER_PROVIDER
pack-priv BiConsumer<? super Connection, ? super SocketAddress>	doAfterResolve
pack-priv Consumer<? super CONF>	doOnConnect
pack-priv Consumer<? super Connection>	doOnConnected
pack-priv Consumer<? super Connection>	doOnDisconnected
pack-priv Consumer<? super Connection>	doOnResolve
pack-priv BiConsumer<? super Connection, ? super Throwable>	doOnResolveError
pack-priv NameResolverProvider	nameResolverProvider
pack-priv ProxyProvider	proxyProvider
pack-priv Supplier<? extends SocketAddress>	remoteAddress
pack-priv AddressResolverGroup<?>	resolver
pack-priv static final ConcurrentMap<Integer, DnsAddressResolverGroup>	RESOLVERS_CACHE

Constructor Summary

Access	Constructor and Description
protected	ClientTransportConfig(ConnectionProvider connectionProvider, Map<ChannelOption<?>, ?> options, Supplier<? extends SocketAddress> remoteAddress)
protected	ClientTransportConfig(ClientTransportConfig<CONF> parent)

Method Summary

Modifier and Type	Method and Description
public int	channelHash() Overrides reactor.netty5.transport.TransportConfig.channelHash.
public ConnectionProvider	Returns: the `ConnectionProvider` connectionProvider() Return the `ConnectionProvider`
protected abstract AddressResolverGroup<?>	Returns: the global `AddressResolverGroup` defaultAddressResolverGroup() Provides a global `AddressResolverGroup` that is shared amongst all clients.
protected ConnectionObserver	defaultConnectionObserver() Implements abstract reactor.netty5.transport.TransportConfig.defaultConnectionObserver. Return the configured default `ConnectionObserver`.
protected ChannelPipelineConfigurer	defaultOnChannelInit() Implements abstract reactor.netty5.transport.TransportConfig.defaultOnChannelInit. Return the default callback if any or `ChannelPipelineConfigurer#emptyConfigurer()`
public final Consumer<? super CONF>	Returns: the configured callback or null doOnConnect() Return the configured callback or null
public final Consumer<? super Connection>	Returns: the configured callback or null doOnConnected() Return the configured callback or null
public final Consumer<? super Connection>	Returns: the configured callback or null doOnDisconnected() Return the configured callback or null
protected EventLoopGroup	eventLoopGroup() Implements abstract reactor.netty5.transport.TransportConfig.eventLoopGroup. Return the configured `EventLoopGroup`.
public NameResolverProvider	Returns: the configured `NameResolverProvider` or null getNameResolverProvider() Return the configured `NameResolverProvider` or null
pack-priv static DnsAddressResolverGroup	getOrCreateResolver(NameResolverProvider nameResolverProvider, LoopResources loopResources, boolean preferNative)
public final boolean	Returns: true if that `ClientTransportConfig` is configured with a proxy hasProxy() Return true if that `ClientTransportConfig` is configured with a proxy
public final ProxyProvider	Returns: the `ProxyProvider` if any or null proxyProvider() Return the `ProxyProvider` if any or null
protected void	proxyProvider(ProxyProvider proxyProvider)
public final Supplier<? extends SocketAddress>	Returns: the remote configured `SocketAddress` remoteAddress() Return the remote configured `SocketAddress`
public final AddressResolverGroup<?>	Returns: the configured `AddressResolverGroup` or null resolver() Return the configured `AddressResolverGroup` or null.
protected AddressResolverGroup<?>	resolverInternal()
protected Class<? extends ServerChannel>	serverChannelType() Overrides reactor.netty5.transport.TransportConfig.serverChannelType. Return the channel type this configuration is associated with, it can be one of the following: `io.netty5.channel.socket.ServerSocketChannel`
protected ServerChannelFactory<? extends ServerChannel>	serverConnectionFactory(ProtocolFamily the configured `ProtocolFamily` to run with protocolFamily) Overrides reactor.netty5.transport.TransportConfig.serverConnectionFactory. Return the `ServerChannelFactory` which is used to create `ServerChannel` instances.

Field Detail

connectionProvider	back to summary
pack-priv final ConnectionProvider connectionProvider

DEFAULT_NAME_RESOLVER_PROVIDER	back to summary
pack-priv static final NameResolverProvider DEFAULT_NAME_RESOLVER_PROVIDER

doAfterResolve	back to summary
pack-priv BiConsumer<? super Connection, ? super SocketAddress> doAfterResolve

doOnConnect	back to summary
pack-priv Consumer<? super CONF> doOnConnect

doOnConnected	back to summary
pack-priv Consumer<? super Connection> doOnConnected

doOnDisconnected	back to summary
pack-priv Consumer<? super Connection> doOnDisconnected

doOnResolve	back to summary
pack-priv Consumer<? super Connection> doOnResolve

doOnResolveError	back to summary
pack-priv BiConsumer<? super Connection, ? super Throwable> doOnResolveError

nameResolverProvider	back to summary
pack-priv NameResolverProvider nameResolverProvider

proxyProvider	back to summary
pack-priv ProxyProvider proxyProvider

remoteAddress	back to summary
pack-priv Supplier<? extends SocketAddress> remoteAddress

resolver	back to summary
pack-priv AddressResolverGroup<?> resolver

RESOLVERS_CACHE	back to summary
pack-priv static final ConcurrentMap<Integer, DnsAddressResolverGroup> RESOLVERS_CACHE

Constructor Detail

ClientTransportConfig	back to summary
protected ClientTransportConfig(ConnectionProvider connectionProvider, Map<ChannelOption<?>, ?> options, Supplier<? extends SocketAddress> remoteAddress)

ClientTransportConfig	back to summary
protected ClientTransportConfig(ClientTransportConfig<CONF> parent)

Method Detail

channelHash	back to summary
public int channelHash() Overrides reactor.netty5.transport.TransportConfig.channelHash. Annotations @Override

channelHash

back to summary

public int channelHash()

Overrides reactor.netty5.transport.TransportConfig.channelHash.

Annotations

@Override

connectionProvider back to summary

connectionProvider	back to summary
public ConnectionProvider connectionProvider() Return the `ConnectionProvider` Returns:ConnectionProvider the `ConnectionProvider`

public ConnectionProvider connectionProvider()

Return the ConnectionProvider

Returns:ConnectionProvider: the ConnectionProvider

defaultAddressResolverGroup back to summary

defaultAddressResolverGroup	back to summary
protected abstract AddressResolverGroup<?> defaultAddressResolverGroup() Provides a global `AddressResolverGroup` that is shared amongst all clients. Returns:AddressResolverGroup<?> the global `AddressResolverGroup`

protected abstract AddressResolverGroup<?> defaultAddressResolverGroup()

Provides a global AddressResolverGroup that is shared amongst all clients.

Returns:AddressResolverGroup<?>: the global AddressResolverGroup

defaultConnectionObserver back to summary

defaultConnectionObserver	back to summary
protected ConnectionObserver defaultConnectionObserver() Implements abstract reactor.netty5.transport.TransportConfig.defaultConnectionObserver. Doc from reactor.netty5.transport.TransportConfig.defaultConnectionObserver. Return the configured default `ConnectionObserver`. Returns:ConnectionObserver the configured default `ConnectionObserver` Annotations @Override

protected ConnectionObserver defaultConnectionObserver()

Implements abstract reactor.netty5.transport.TransportConfig.defaultConnectionObserver.

Doc from reactor.netty5.transport.TransportConfig.defaultConnectionObserver.

Return the configured default ConnectionObserver.

Returns:ConnectionObserver

the configured default ConnectionObserver

Annotations

@Override

defaultOnChannelInit back to summary

defaultOnChannelInit	back to summary
protected ChannelPipelineConfigurer defaultOnChannelInit() Implements abstract reactor.netty5.transport.TransportConfig.defaultOnChannelInit. Doc from reactor.netty5.transport.TransportConfig.defaultOnChannelInit. Return the default callback if any or `ChannelPipelineConfigurer#emptyConfigurer()` Returns:ChannelPipelineConfigurer the default callback if any or `ChannelPipelineConfigurer#emptyConfigurer()` Annotations @Override

protected ChannelPipelineConfigurer defaultOnChannelInit()

Implements abstract reactor.netty5.transport.TransportConfig.defaultOnChannelInit.

Doc from reactor.netty5.transport.TransportConfig.defaultOnChannelInit.

Return the default callback if any or ChannelPipelineConfigurer#emptyConfigurer()

Returns:ChannelPipelineConfigurer

the default callback if any or ChannelPipelineConfigurer#emptyConfigurer()

Annotations

@Override

doOnConnect	back to summary
public final Consumer<? super CONF> doOnConnect() Return the configured callback or null Returns:Consumer<? super CONF> the configured callback or null Annotations @Nullable

doOnConnect

back to summary

public final Consumer<? super CONF> doOnConnect()

Return the configured callback or null

Returns:Consumer<? super CONF>

the configured callback or null

Annotations

@Nullable

doOnConnected	back to summary
public final Consumer<? super Connection> doOnConnected() Return the configured callback or null Returns:Consumer<? super Connection> the configured callback or null Annotations @Nullable

doOnConnected

back to summary

public final Consumer<? super Connection> doOnConnected()

Return the configured callback or null

Returns:Consumer<? super Connection>

the configured callback or null

Annotations

@Nullable

doOnDisconnected	back to summary
public final Consumer<? super Connection> doOnDisconnected() Return the configured callback or null Returns:Consumer<? super Connection> the configured callback or null Annotations @Nullable

doOnDisconnected

back to summary

public final Consumer<? super Connection> doOnDisconnected()

Return the configured callback or null

Returns:Consumer<? super Connection>

the configured callback or null

Annotations

@Nullable

eventLoopGroup back to summary

eventLoopGroup	back to summary
protected EventLoopGroup eventLoopGroup() Implements abstract reactor.netty5.transport.TransportConfig.eventLoopGroup. Doc from reactor.netty5.transport.TransportConfig.eventLoopGroup. Return the configured `EventLoopGroup`. Returns:EventLoopGroup the configured `EventLoopGroup` Annotations @Override

protected EventLoopGroup eventLoopGroup()

Implements abstract reactor.netty5.transport.TransportConfig.eventLoopGroup.

Doc from reactor.netty5.transport.TransportConfig.eventLoopGroup.

Return the configured EventLoopGroup.

Returns:EventLoopGroup

the configured EventLoopGroup

Annotations

@Override

getNameResolverProvider back to summary

getNameResolverProvider	back to summary
public NameResolverProvider getNameResolverProvider() Return the configured `NameResolverProvider` or null Returns:NameResolverProvider the configured `NameResolverProvider` or null Annotations @Nullable

public NameResolverProvider getNameResolverProvider()

Return the configured NameResolverProvider or null

Returns:NameResolverProvider

the configured NameResolverProvider or null

Annotations

@Nullable

getOrCreateResolver	back to summary
pack-priv static DnsAddressResolverGroup getOrCreateResolver(NameResolverProvider nameResolverProvider, LoopResources loopResources, boolean preferNative)

hasProxy back to summary

hasProxy	back to summary
public final boolean hasProxy() Return true if that `ClientTransportConfig` is configured with a proxy Returns:boolean true if that `ClientTransportConfig` is configured with a proxy

public final boolean hasProxy()

Return true if that ClientTransportConfig is configured with a proxy

Returns:boolean: true if that ClientTransportConfig is configured with a proxy

proxyProvider back to summary

proxyProvider	back to summary
public final ProxyProvider proxyProvider() Return the `ProxyProvider` if any or null Returns:ProxyProvider the `ProxyProvider` if any or null Annotations @Nullable

public final ProxyProvider proxyProvider()

Return the ProxyProvider if any or null

Returns:ProxyProvider

the ProxyProvider if any or null

Annotations

@Nullable

proxyProvider	back to summary
protected void proxyProvider(ProxyProvider proxyProvider)

remoteAddress back to summary

remoteAddress	back to summary
public final Supplier<? extends SocketAddress> remoteAddress() Return the remote configured `SocketAddress` Returns:Supplier<? extends SocketAddress> the remote configured `SocketAddress`

public final Supplier<? extends SocketAddress> remoteAddress()

Return the remote configured SocketAddress

Returns:Supplier<? extends SocketAddress>: the remote configured SocketAddress

resolver back to summary

resolver	back to summary
public final AddressResolverGroup<?> resolver() Return the configured `AddressResolverGroup` or null. If there is no `AddressResolverGroup` configured, the default will be used. Returns:AddressResolverGroup<?> the configured `AddressResolverGroup` or null Annotations @Nullable

public final AddressResolverGroup<?> resolver()

Return the configured AddressResolverGroup or null. If there is no AddressResolverGroup configured, the default will be used.

Returns:AddressResolverGroup<?>

the configured AddressResolverGroup or null

Annotations

@Nullable

resolverInternal	back to summary
protected AddressResolverGroup<?> resolverInternal()

serverChannelType back to summary

serverChannelType	back to summary
protected Class<? extends ServerChannel> serverChannelType() Overrides reactor.netty5.transport.TransportConfig.serverChannelType. Doc from reactor.netty5.transport.TransportConfig.serverChannelType. Return the channel type this configuration is associated with, it can be one of the following: `io.netty5.channel.socket.ServerSocketChannel` Returns:Class<? extends ServerChannel> the channel type this configuration is associated with Annotations @Override

protected Class<? extends ServerChannel> serverChannelType()

Overrides reactor.netty5.transport.TransportConfig.serverChannelType.

Doc from reactor.netty5.transport.TransportConfig.serverChannelType.

Return the channel type this configuration is associated with, it can be one of the following:

io.netty5.channel.socket.ServerSocketChannel

Returns:Class<? extends ServerChannel>

the channel type this configuration is associated with

Annotations

@Override

serverConnectionFactory back to summary

serverConnectionFactory	back to summary
protected ServerChannelFactory<? extends ServerChannel> serverConnectionFactory(ProtocolFamily protocolFamily) Overrides reactor.netty5.transport.TransportConfig.serverConnectionFactory. Doc from reactor.netty5.transport.TransportConfig.serverConnectionFactory. Return the `ServerChannelFactory` which is used to create `ServerChannel` instances. Parameters protocolFamily:ProtocolFamily the configured `ProtocolFamily` to run with Returns:ServerChannelFactory<? extends ServerChannel> the `ServerChannelFactory` which is used to create `ServerChannel` instances. Annotations @Override

protected ServerChannelFactory<? extends ServerChannel> serverConnectionFactory(ProtocolFamily protocolFamily)

Overrides reactor.netty5.transport.TransportConfig.serverConnectionFactory.

Doc from reactor.netty5.transport.TransportConfig.serverConnectionFactory.

Return the ServerChannelFactory which is used to create ServerChannel instances.

Parameters

protocolFamily:ProtocolFamily: the configured ProtocolFamily to run with

Returns:ServerChannelFactory<? extends ServerChannel>

the ServerChannelFactory which is used to create ServerChannel instances.

Annotations

@Override

reactor.netty5.transport back to summary

pack-priv final Class ClientTransportConfig.ClientTransportChannelInitializer

Class Inheritance

extends Object
implements ChannelPipelineConfigurer

java.lang.Object
reactor.netty5.transport.ClientTransportConfig.ClientTransportChannelInitializer

All Implemented Interfaces

reactor.netty5.ChannelPipelineConfigurer

Field Summary

Modifier and Type	Field and Description
pack-priv final ProxyProvider	proxyProvider

Constructor Summary

Access	Constructor and Description
pack-priv	ClientTransportChannelInitializer(ProxyProvider proxyProvider)

Method Summary

Modifier and Type	Method and Description
public void	onChannelInit(ConnectionObserver the configured `ConnectionObserver` connectionObserver, Channel the channel channel, SocketAddress the remote address remoteAddress) Implements reactor.netty5.ChannelPipelineConfigurer.onChannelInit. Configure the channel pipeline while initializing the channel.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

proxyProvider	back to summary
pack-priv final ProxyProvider proxyProvider

Constructor Detail

ClientTransportChannelInitializer	back to summary
pack-priv ClientTransportChannelInitializer(ProxyProvider proxyProvider)

Method Detail

onChannelInit back to summary

onChannelInit	back to summary
public void onChannelInit(ConnectionObserver connectionObserver, Channel channel, SocketAddress remoteAddress) Implements reactor.netty5.ChannelPipelineConfigurer.onChannelInit. Doc from reactor.netty5.ChannelPipelineConfigurer.onChannelInit. Configure the channel pipeline while initializing the channel. Parameters connectionObserver:ConnectionObserver the configured `ConnectionObserver` channel:Channel the channel remoteAddress:SocketAddress the remote address Annotations @Override

public void onChannelInit(ConnectionObserver connectionObserver, Channel channel, SocketAddress remoteAddress)

Implements reactor.netty5.ChannelPipelineConfigurer.onChannelInit.

Doc from reactor.netty5.ChannelPipelineConfigurer.onChannelInit.

Configure the channel pipeline while initializing the channel.

Parameters

connectionObserver:ConnectionObserver: the configured ConnectionObserver
channel:Channel: the channel
remoteAddress:SocketAddress: the remote address

Annotations

@Override

reactor.netty5.transport back to summary

pack-priv final Class ClientTransportConfig.ClientTransportDoOn

Class Inheritance

extends Object
implements ConnectionObserver

java.lang.Object
reactor.netty5.transport.ClientTransportConfig.ClientTransportDoOn

All Implemented Interfaces

reactor.netty5.ConnectionObserver

Field Summary

Modifier and Type	Field and Description
pack-priv final ChannelGroup	channelGroup
pack-priv final Consumer<? super Connection>	doOnConnected
pack-priv final Consumer<? super Connection>	doOnDisconnected

Constructor Summary

Access	Constructor and Description
pack-priv	ClientTransportDoOn(ChannelGroup channelGroup, Consumer<? super Connection> doOnConnected, Consumer<? super Connection> doOnDisconnected)

Method Summary

Modifier and Type	Method and Description
public void	onStateChange(Connection the connection reference connection, ConnectionObserver.State the new State newState) Implements reactor.netty5.ConnectionObserver.onStateChange. React on connection state change (e.g. http request or response)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

channelGroup	back to summary
pack-priv final ChannelGroup channelGroup

doOnConnected	back to summary
pack-priv final Consumer<? super Connection> doOnConnected

doOnDisconnected	back to summary
pack-priv final Consumer<? super Connection> doOnDisconnected

Constructor Detail

ClientTransportDoOn	back to summary
pack-priv ClientTransportDoOn(ChannelGroup channelGroup, Consumer<? super Connection> doOnConnected, Consumer<? super Connection> doOnDisconnected)

Method Detail

onStateChange

back to summary

public void onStateChange(Connection connection, ConnectionObserver.State newState)

Implements reactor.netty5.ConnectionObserver.onStateChange.

Doc from reactor.netty5.ConnectionObserver.onStateChange.

React on connection state change (e.g. http request or response)

Parameters

connection:Connection: the connection reference
newState:ConnectionObserver.State: the new State

Annotations

@Override

public abstract Class ClientTransportConfig<CONF extends reactor.netty5.transport.TransportConfig>

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class ClientTransportConfig.ClientTransportChannelInitializer

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class ClientTransportConfig.ClientTransportDoOn

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail