Modifier and Type	Class and Description
private static class	LoadBalancingProxyClient.ExclusiveConnectionHolder
public class	LoadBalancingProxyClient.Host
public static interface	LoadBalancingProxyClient.HostSelector
pack-priv static class	LoadBalancingProxyClient.RoundRobinHostSelector

Field Summary

Modifier and Type	Field and Description
private static final AttachmentKey<AttachmentList<LoadBalancingProxyClient.Host>>	ATTEMPTED_HOSTS
private final UndertowClient	client
private volatile int	connectionsPerThread The number of connections to create per thread
private final AttachmentKey<LoadBalancingProxyClient.ExclusiveConnectionHolder>	exclusiveConnectionKey The attachment key that is used to attach the proxy connection to the exchange.
private final ExclusivityChecker	exclusivityChecker
private volatile LoadBalancingProxyClient.Host[]	hosts The hosts list.
private final LoadBalancingProxyClient.HostSelector	hostSelector
private volatile int	maxQueueSize
private volatile int	problemServerRetry Time in seconds between retries for problem servers
private static final ProxyClient.ProxyTarget	PROXY_TARGET
private RouteIteratorFactory	routeIteratorFactory
private final Map<String, LoadBalancingProxyClient.Host>	routes
private final Set<String>	sessionCookieNames
private volatile int	softMaxConnectionsPerThread
private volatile int	ttl

Constructor Summary

Access	Constructor and Description
public	LoadBalancingProxyClient()
public	LoadBalancingProxyClient(UndertowClient client)
public	LoadBalancingProxyClient(ExclusivityChecker client)
public	LoadBalancingProxyClient(UndertowClient client, ExclusivityChecker exclusivityChecker)
public	LoadBalancingProxyClient(UndertowClient client, ExclusivityChecker exclusivityChecker, LoadBalancingProxyClient.HostSelector hostSelector)

Method Summary

Modifier and Type	Method and Description
public synchronized LoadBalancingProxyClient	addHost(final URI host)
public synchronized LoadBalancingProxyClient	addHost(final URI host, XnioSsl ssl)
public synchronized LoadBalancingProxyClient	addHost(final URI host, String jvmRoute)
public synchronized LoadBalancingProxyClient	addHost(final URI host, String jvmRoute, XnioSsl ssl)
public synchronized LoadBalancingProxyClient	addHost(final URI host, String jvmRoute, XnioSsl ssl, OptionMap options)
public synchronized LoadBalancingProxyClient	addHost(final InetSocketAddress bindAddress, final URI host, String jvmRoute, XnioSsl ssl, OptionMap options)
public LoadBalancingProxyClient	addSessionCookieName(final String sessionCookieName)
public void	closeCurrentConnections() Should only be used for tests DO NOT CALL THIS METHOD WHEN REQUESTS ARE IN PROGRESS It is not thread safe so internal state can get messed up.
public ProxyClient.ProxyTarget	findTarget(HttpServerExchange The exchange exchange) Implements io.undertow.server.handlers.proxy.ProxyClient.findTarget. Finds a proxy target for this request, returning null if none can be found.
public List<ProxyClient.ProxyTarget>	getAllTargets() Overrides default io.undertow.server.handlers.proxy.ProxyClient.getAllTargets.
public void	getConnection(ProxyClient.ProxyTarget target, HttpServerExchange The exchange exchange, final ProxyCallback<ProxyConnection> The callback callback, long The timeout timeout, TimeUnit Time unit for the timeout timeUnit) Implements io.undertow.server.handlers.proxy.ProxyClient.getConnection. Gets a proxy connection for the given request.
public int	getConnectionsPerThread()
public int	getMaxQueueSize()
public int	getProblemServerRetry()
protected Iterator<CharSequence>	parseRoutes(HttpServerExchange exchange)
public synchronized LoadBalancingProxyClient	removeHost(final URI uri)
public LoadBalancingProxyClient	removeSessionCookieName(final String sessionCookieName)
protected LoadBalancingProxyClient.Host	selectHost(HttpServerExchange exchange)
public LoadBalancingProxyClient	setConnectionsPerThread(int connectionsPerThread)
public LoadBalancingProxyClient	setMaxQueueSize(int maxQueueSize)
public LoadBalancingProxyClient	setProblemServerRetry(int problemServerRetry)
public LoadBalancingProxyClient	setRankedRoutingDelimiter(String rankedRoutingDelimiter) Configures ranked route delimiter, enabling ranked routing parsing strategy.
public LoadBalancingProxyClient	setRouteParsingStrategy(RouteParsingStrategy routeParsingStrategy)
public LoadBalancingProxyClient	setSoftMaxConnectionsPerThread(int softMaxConnectionsPerThread)
public LoadBalancingProxyClient	setTtl(int ttl)

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

Field Detail

ATTEMPTED_HOSTS	back to summary
private static final AttachmentKey<AttachmentList<LoadBalancingProxyClient.Host>> ATTEMPTED_HOSTS

client	back to summary
private final UndertowClient client

connectionsPerThread	back to summary
private volatile int connectionsPerThread The number of connections to create per thread

exclusiveConnectionKey	back to summary
private final AttachmentKey<LoadBalancingProxyClient.ExclusiveConnectionHolder> exclusiveConnectionKey The attachment key that is used to attach the proxy connection to the exchange. This cannot be static as otherwise a connection from a different client could be re-used.

exclusiveConnectionKey

back to summary

private final AttachmentKey<LoadBalancingProxyClient.ExclusiveConnectionHolder> exclusiveConnectionKey

The attachment key that is used to attach the proxy connection to the exchange.

This cannot be static as otherwise a connection from a different client could be re-used.

exclusivityChecker	back to summary
private final ExclusivityChecker exclusivityChecker

hosts	back to summary
private volatile LoadBalancingProxyClient.Host[] hosts The hosts list.

hostSelector	back to summary
private final LoadBalancingProxyClient.HostSelector hostSelector

maxQueueSize	back to summary
private volatile int maxQueueSize

problemServerRetry	back to summary
private volatile int problemServerRetry Time in seconds between retries for problem servers

PROXY_TARGET	back to summary
private static final ProxyClient.ProxyTarget PROXY_TARGET

routeIteratorFactory	back to summary
private RouteIteratorFactory routeIteratorFactory

routes	back to summary
private final Map<String, LoadBalancingProxyClient.Host> routes

sessionCookieNames	back to summary
private final Set<String> sessionCookieNames

softMaxConnectionsPerThread	back to summary
private volatile int softMaxConnectionsPerThread

ttl	back to summary
private volatile int ttl

Constructor Detail

LoadBalancingProxyClient	back to summary
public LoadBalancingProxyClient()

LoadBalancingProxyClient	back to summary
public LoadBalancingProxyClient(UndertowClient client)

LoadBalancingProxyClient	back to summary
public LoadBalancingProxyClient(ExclusivityChecker client)

LoadBalancingProxyClient	back to summary
public LoadBalancingProxyClient(UndertowClient client, ExclusivityChecker exclusivityChecker)

LoadBalancingProxyClient	back to summary
public LoadBalancingProxyClient(UndertowClient client, ExclusivityChecker exclusivityChecker, LoadBalancingProxyClient.HostSelector hostSelector)

Method Detail

addHost	back to summary
public synchronized LoadBalancingProxyClient addHost(final URI host)

addHost	back to summary
public synchronized LoadBalancingProxyClient addHost(final URI host, XnioSsl ssl)

addHost	back to summary
public synchronized LoadBalancingProxyClient addHost(final URI host, String jvmRoute)

addHost	back to summary
public synchronized LoadBalancingProxyClient addHost(final URI host, String jvmRoute, XnioSsl ssl)

addHost	back to summary
public synchronized LoadBalancingProxyClient addHost(final URI host, String jvmRoute, XnioSsl ssl, OptionMap options)

addHost	back to summary
public synchronized LoadBalancingProxyClient addHost(final InetSocketAddress bindAddress, final URI host, String jvmRoute, XnioSsl ssl, OptionMap options)

addSessionCookieName	back to summary
public LoadBalancingProxyClient addSessionCookieName(final String sessionCookieName)

closeCurrentConnections	back to summary
public void closeCurrentConnections() Should only be used for tests DO NOT CALL THIS METHOD WHEN REQUESTS ARE IN PROGRESS It is not thread safe so internal state can get messed up.

findTarget	back to summary
public ProxyClient.ProxyTarget findTarget(HttpServerExchange exchange) Implements io.undertow.server.handlers.proxy.ProxyClient.findTarget. Doc from io.undertow.server.handlers.proxy.ProxyClient.findTarget. Finds a proxy target for this request, returning null if none can be found. If this method returns null it means that there is no backend available to handle this request, and it should proceed as normal. Parameters exchange:HttpServerExchange The exchange Returns:ProxyClient.ProxyTarget The proxy target Annotations @Override

findTarget

back to summary

public ProxyClient.ProxyTarget findTarget(HttpServerExchange exchange)

Implements io.undertow.server.handlers.proxy.ProxyClient.findTarget.

Doc from io.undertow.server.handlers.proxy.ProxyClient.findTarget.

Finds a proxy target for this request, returning null if none can be found. If this method returns null it means that there is no backend available to handle this request, and it should proceed as normal.

Parameters

exchange:HttpServerExchange: The exchange

Returns:ProxyClient.ProxyTarget

The proxy target

Annotations

@Override

getAllTargets	back to summary
public List<ProxyClient.ProxyTarget> getAllTargets() Overrides default io.undertow.server.handlers.proxy.ProxyClient.getAllTargets. Annotations @Override

getAllTargets

back to summary

public List<ProxyClient.ProxyTarget> getAllTargets()

Overrides default io.undertow.server.handlers.proxy.ProxyClient.getAllTargets.

Annotations

@Override

getConnection	back to summary
public void getConnection(ProxyClient.ProxyTarget target, HttpServerExchange exchange, final ProxyCallback<ProxyConnection> callback, long timeout, TimeUnit timeUnit) Implements io.undertow.server.handlers.proxy.ProxyClient.getConnection. Doc from io.undertow.server.handlers.proxy.ProxyClient.getConnection. Gets a proxy connection for the given request. Parameters exchange:HttpServerExchange The exchange callback:ProxyCallback<ProxyConnection> The callback timeout:long The timeout timeUnit:TimeUnit Time unit for the timeout Annotations @Override

getConnection

back to summary

public void getConnection(ProxyClient.ProxyTarget target, HttpServerExchange exchange, final ProxyCallback<ProxyConnection> callback, long timeout, TimeUnit timeUnit)

Implements io.undertow.server.handlers.proxy.ProxyClient.getConnection.

Doc from io.undertow.server.handlers.proxy.ProxyClient.getConnection.

Gets a proxy connection for the given request.

Parameters

exchange:HttpServerExchange: The exchange
callback:ProxyCallback<ProxyConnection>: The callback
timeout:long: The timeout
timeUnit:TimeUnit: Time unit for the timeout

Annotations

@Override

getConnectionsPerThread	back to summary
public int getConnectionsPerThread()

getMaxQueueSize	back to summary
public int getMaxQueueSize()

getProblemServerRetry	back to summary
public int getProblemServerRetry()

parseRoutes	back to summary
protected Iterator<CharSequence> parseRoutes(HttpServerExchange exchange)

removeHost	back to summary
public synchronized LoadBalancingProxyClient removeHost(final URI uri)

removeSessionCookieName	back to summary
public LoadBalancingProxyClient removeSessionCookieName(final String sessionCookieName)

selectHost	back to summary
protected LoadBalancingProxyClient.Host selectHost(HttpServerExchange exchange)

setConnectionsPerThread	back to summary
public LoadBalancingProxyClient setConnectionsPerThread(int connectionsPerThread)

setMaxQueueSize	back to summary
public LoadBalancingProxyClient setMaxQueueSize(int maxQueueSize)

setProblemServerRetry	back to summary
public LoadBalancingProxyClient setProblemServerRetry(int problemServerRetry)

setRankedRoutingDelimiter	back to summary
public LoadBalancingProxyClient setRankedRoutingDelimiter(String rankedRoutingDelimiter) Configures ranked route delimiter, enabling ranked routing parsing strategy.

setRouteParsingStrategy	back to summary
public LoadBalancingProxyClient setRouteParsingStrategy(RouteParsingStrategy routeParsingStrategy)

setSoftMaxConnectionsPerThread	back to summary
public LoadBalancingProxyClient setSoftMaxConnectionsPerThread(int softMaxConnectionsPerThread)

setTtl	back to summary
public LoadBalancingProxyClient setTtl(int ttl)

io.undertow.server.handlers.proxy back to summary

private Class LoadBalancingProxyClient.ExclusiveConnectionHolder

Class Inheritance

extends Object

java.lang.Object
io.undertow.server.handlers.proxy.LoadBalancingProxyClient.ExclusiveConnectionHolder

Field Summary

Modifier and Type	Field and Description
private ProxyConnection	connection

Constructor Summary

Access	Constructor and Description
private	ExclusiveConnectionHolder()

Method Summary

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

Field Detail

connection	back to summary
private ProxyConnection connection

Constructor Detail

ExclusiveConnectionHolder	back to summary
private ExclusiveConnectionHolder()

io.undertow.server.handlers.proxy back to summary

public final Class LoadBalancingProxyClient.Host

Class Inheritance

extends SimpleConnectionPoolErrorHandler
implements ConnectionPoolManager

java.lang.Object
io.undertow.server.handlers.proxy.ConnectionPoolErrorHandler.SimpleConnectionPoolErrorHandler
io.undertow.server.handlers.proxy.LoadBalancingProxyClient.Host

All Implemented Interfaces

io.undertow.server.handlers.proxy.ConnectionPoolManager, io.undertow.server.handlers.proxy.ConnectionPoolErrorHandler, io.undertow.server.handlers.proxy.ProxyConnectionPoolConfig

Field Summary

Modifier and Type	Field and Description
pack-priv final ProxyConnectionPool	connectionPool
pack-priv final String	jvmRoute
pack-priv final XnioSsl	ssl
pack-priv final URI	uri

Constructor Summary

Access	Constructor and Description
private	Host(String jvmRoute, InetSocketAddress bindAddress, URI uri, XnioSsl ssl, OptionMap options)

Method Summary

Modifier and Type	Method and Description
pack-priv void	closeCurrentConnections()
public int	getMaxCachedConnections() Implements io.undertow.server.handlers.proxy.ProxyConnectionPoolConfig.getMaxCachedConnections. Get the maximum number of cached (idle) connections per thread.
public int	getMaxConnections() Implements io.undertow.server.handlers.proxy.ProxyConnectionPoolConfig.getMaxConnections. Get the maximum number of connections per thread.
public int	getMaxQueueSize() Implements io.undertow.server.handlers.proxy.ProxyConnectionPoolConfig.getMaxQueueSize. Get the maximum number of requests which can be queued if there are no connections available.
public int	getProblemServerRetry() Implements io.undertow.server.handlers.proxy.ConnectionPoolManager.getProblemServerRetry.
public int	getSMaxConnections() Implements io.undertow.server.handlers.proxy.ProxyConnectionPoolConfig.getSMaxConnections. Get number of cached connections above which are closed after the time to live.
public long	getTtl() Implements io.undertow.server.handlers.proxy.ProxyConnectionPoolConfig.getTtl. Get the time to live for idle connections.
public URI	getUri()

Inherited from io.undertow.server.handlers.proxy.ConnectionPoolErrorHandler.SimpleConnectionPoolErrorHandler:: clearError handleError isAvailable

Field Detail

connectionPool	back to summary
pack-priv final ProxyConnectionPool connectionPool

jvmRoute	back to summary
pack-priv final String jvmRoute

ssl	back to summary
pack-priv final XnioSsl ssl

uri	back to summary
pack-priv final URI uri

Constructor Detail

Host	back to summary
private Host(String jvmRoute, InetSocketAddress bindAddress, URI uri, XnioSsl ssl, OptionMap options)

Method Detail

closeCurrentConnections	back to summary
pack-priv void closeCurrentConnections()

getMaxCachedConnections

back to summary

public int getMaxCachedConnections()

Implements io.undertow.server.handlers.proxy.ProxyConnectionPoolConfig.getMaxCachedConnections.

Doc from io.undertow.server.handlers.proxy.ProxyConnectionPoolConfig.getMaxCachedConnections.

Get the maximum number of cached (idle) connections per thread.

Annotations

@Override

getMaxConnections

back to summary

public int getMaxConnections()

Implements io.undertow.server.handlers.proxy.ProxyConnectionPoolConfig.getMaxConnections.

Doc from io.undertow.server.handlers.proxy.ProxyConnectionPoolConfig.getMaxConnections.

Get the maximum number of connections per thread.

Annotations

@Override

getMaxQueueSize

back to summary

public int getMaxQueueSize()

Implements io.undertow.server.handlers.proxy.ProxyConnectionPoolConfig.getMaxQueueSize.

Doc from io.undertow.server.handlers.proxy.ProxyConnectionPoolConfig.getMaxQueueSize.

Get the maximum number of requests which can be queued if there are no connections available.

Annotations

@Override

getProblemServerRetry

back to summary

public int getProblemServerRetry()

Implements io.undertow.server.handlers.proxy.ConnectionPoolManager.getProblemServerRetry.

Returns:int

Doc from io.undertow.server.handlers.proxy.ConnectionPoolManager.getProblemServerRetry.

The amount of time that we should wait before re-testing a problem server

Annotations

@Override

getSMaxConnections

back to summary

public int getSMaxConnections()

Implements io.undertow.server.handlers.proxy.ProxyConnectionPoolConfig.getSMaxConnections.

Doc from io.undertow.server.handlers.proxy.ProxyConnectionPoolConfig.getSMaxConnections.

Get number of cached connections above which are closed after the time to live.

Annotations

@Override

getTtl

back to summary

public long getTtl()

Implements io.undertow.server.handlers.proxy.ProxyConnectionPoolConfig.getTtl.

Doc from io.undertow.server.handlers.proxy.ProxyConnectionPoolConfig.getTtl.

Get the time to live for idle connections.

Annotations

@Override

getUri	back to summary
public URI getUri()

io.undertow.server.handlers.proxy back to summary

public Interface LoadBalancingProxyClient.HostSelector

Known Direct Implementers: io.undertow.server.handlers.proxy.LoadBalancingProxyClient.RoundRobinHostSelector

Method Summary

Modifier and Type	Method and Description
public int	selectHost(LoadBalancingProxyClient.Host[] availableHosts)

Method Detail

selectHost	back to summary
public int selectHost(LoadBalancingProxyClient.Host[] availableHosts)

io.undertow.server.handlers.proxy back to summary

pack-priv Class LoadBalancingProxyClient.RoundRobinHostSelector

Class Inheritance

extends Object
implements HostSelector

java.lang.Object
io.undertow.server.handlers.proxy.LoadBalancingProxyClient.RoundRobinHostSelector

All Implemented Interfaces

io.undertow.server.handlers.proxy.LoadBalancingProxyClient.HostSelector

Field Summary

Modifier and Type	Field and Description
private final AtomicInteger	currentHost

Constructor Summary

Access	Constructor and Description
pack-priv	RoundRobinHostSelector()

Method Summary

Modifier and Type	Method and Description
public int	selectHost(LoadBalancingProxyClient.Host[] availableHosts) Implements io.undertow.server.handlers.proxy.LoadBalancingProxyClient.HostSelector.selectHost.

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

Field Detail

currentHost	back to summary
private final AtomicInteger currentHost

Constructor Detail

RoundRobinHostSelector	back to summary
pack-priv RoundRobinHostSelector()

Method Detail

selectHost

back to summary

public int selectHost(LoadBalancingProxyClient.Host[] availableHosts)

Implements io.undertow.server.handlers.proxy.LoadBalancingProxyClient.HostSelector.selectHost.

Annotations

@Override

public Class LoadBalancingProxyClient

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class LoadBalancingProxyClient.ExclusiveConnectionHolder

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

public final Class LoadBalancingProxyClient.Host

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

public Interface LoadBalancingProxyClient.HostSelector

Method Summary

Method Detail

pack-priv Class LoadBalancingProxyClient.RoundRobinHostSelector

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail