ProxyClient
public class LoadBalancingProxyClient extends java.lang.Object implements ProxyClient
Modifier and Type | Class | Description |
---|---|---|
class |
LoadBalancingProxyClient.Host |
|
static interface |
LoadBalancingProxyClient.HostSelector |
ProxyClient.MaxRetriesProxyTarget, ProxyClient.ProxyTarget
Constructor | Description |
---|---|
LoadBalancingProxyClient() |
|
LoadBalancingProxyClient(UndertowClient client) |
|
LoadBalancingProxyClient(UndertowClient client,
ExclusivityChecker exclusivityChecker) |
|
LoadBalancingProxyClient(UndertowClient client,
ExclusivityChecker exclusivityChecker,
LoadBalancingProxyClient.HostSelector hostSelector) |
|
LoadBalancingProxyClient(ExclusivityChecker client) |
Modifier and Type | Method | Description |
---|---|---|
LoadBalancingProxyClient |
addHost(java.net.InetSocketAddress bindAddress,
java.net.URI host,
java.lang.String jvmRoute,
org.xnio.ssl.XnioSsl ssl,
org.xnio.OptionMap options) |
|
LoadBalancingProxyClient |
addHost(java.net.URI host) |
|
LoadBalancingProxyClient |
addHost(java.net.URI host,
java.lang.String jvmRoute) |
|
LoadBalancingProxyClient |
addHost(java.net.URI host,
java.lang.String jvmRoute,
org.xnio.ssl.XnioSsl ssl) |
|
LoadBalancingProxyClient |
addHost(java.net.URI host,
java.lang.String jvmRoute,
org.xnio.ssl.XnioSsl ssl,
org.xnio.OptionMap options) |
|
LoadBalancingProxyClient |
addHost(java.net.URI host,
org.xnio.ssl.XnioSsl ssl) |
|
LoadBalancingProxyClient |
addSessionCookieName(java.lang.String sessionCookieName) |
|
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.
|
protected LoadBalancingProxyClient.Host |
findStickyHost(HttpServerExchange exchange) |
|
ProxyClient.ProxyTarget |
findTarget(HttpServerExchange exchange) |
Finds a proxy target for this request, returning null if none can be found.
|
void |
getConnection(ProxyClient.ProxyTarget target,
HttpServerExchange exchange,
ProxyCallback<ProxyConnection> callback,
long timeout,
java.util.concurrent.TimeUnit timeUnit) |
Gets a proxy connection for the given request.
|
int |
getConnectionsPerThread() |
|
int |
getMaxQueueSize() |
|
int |
getProblemServerRetry() |
|
LoadBalancingProxyClient |
removeHost(java.net.URI uri) |
|
LoadBalancingProxyClient |
removeSessionCookieName(java.lang.String sessionCookieName) |
|
protected LoadBalancingProxyClient.Host |
selectHost(HttpServerExchange exchange) |
|
LoadBalancingProxyClient |
setConnectionsPerThread(int connectionsPerThread) |
|
LoadBalancingProxyClient |
setMaxQueueSize(int maxQueueSize) |
|
LoadBalancingProxyClient |
setProblemServerRetry(int problemServerRetry) |
|
LoadBalancingProxyClient |
setSoftMaxConnectionsPerThread(int softMaxConnectionsPerThread) |
|
LoadBalancingProxyClient |
setTtl(int ttl) |
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)
public LoadBalancingProxyClient addSessionCookieName(java.lang.String sessionCookieName)
public LoadBalancingProxyClient removeSessionCookieName(java.lang.String sessionCookieName)
public LoadBalancingProxyClient setProblemServerRetry(int problemServerRetry)
public int getProblemServerRetry()
public int getConnectionsPerThread()
public LoadBalancingProxyClient setConnectionsPerThread(int connectionsPerThread)
public int getMaxQueueSize()
public LoadBalancingProxyClient setMaxQueueSize(int maxQueueSize)
public LoadBalancingProxyClient setTtl(int ttl)
public LoadBalancingProxyClient setSoftMaxConnectionsPerThread(int softMaxConnectionsPerThread)
public LoadBalancingProxyClient addHost(java.net.URI host)
public LoadBalancingProxyClient addHost(java.net.URI host, org.xnio.ssl.XnioSsl ssl)
public LoadBalancingProxyClient addHost(java.net.URI host, java.lang.String jvmRoute)
public LoadBalancingProxyClient addHost(java.net.URI host, java.lang.String jvmRoute, org.xnio.ssl.XnioSsl ssl)
public LoadBalancingProxyClient addHost(java.net.URI host, java.lang.String jvmRoute, org.xnio.ssl.XnioSsl ssl, org.xnio.OptionMap options)
public LoadBalancingProxyClient addHost(java.net.InetSocketAddress bindAddress, java.net.URI host, java.lang.String jvmRoute, org.xnio.ssl.XnioSsl ssl, org.xnio.OptionMap options)
public LoadBalancingProxyClient removeHost(java.net.URI uri)
public ProxyClient.ProxyTarget findTarget(HttpServerExchange exchange)
ProxyClient
findTarget
in interface ProxyClient
exchange
- The exchangepublic void getConnection(ProxyClient.ProxyTarget target, HttpServerExchange exchange, ProxyCallback<ProxyConnection> callback, long timeout, java.util.concurrent.TimeUnit timeUnit)
ProxyClient
getConnection
in interface ProxyClient
exchange
- The exchangecallback
- The callbacktimeout
- The timeouttimeUnit
- Time unit for the timeoutprotected LoadBalancingProxyClient.Host selectHost(HttpServerExchange exchange)
protected LoadBalancingProxyClient.Host findStickyHost(HttpServerExchange exchange)
public void closeCurrentConnections()
Copyright © 2018. All rights reserved.