@NotThreadSafe public final class ProxyWebServer extends WebServer
Modifier and Type | Field and Description |
---|---|
static String |
ALLUXIO_PROXY_AUDIT_LOG_WRITER_KEY |
static String |
ALLUXIO_PROXY_SERVLET_RESOURCE_KEY |
static String |
FILE_SYSTEM_SERVLET_RESOURCE_KEY |
static String |
GLOBAL_RATE_LIMITER_SERVLET_RESOURCE_KEY |
ConcurrentHashMap<org.eclipse.jetty.server.Request,S3Handler> |
mS3HandlerMap |
static String |
PROXY_S3_HANDLER_MAP |
static String |
SERVER_CONFIGURATION_RESOURCE_KEY |
static String |
STREAM_CACHE_SERVLET_RESOURCE_KEY |
mServletContextHandler
Constructor and Description |
---|
ProxyWebServer(String serviceName,
InetSocketAddress address,
ProxyProcess proxyProcess)
Creates a new instance of
ProxyWebServer . |
Modifier and Type | Method and Description |
---|---|
static void |
logAccess(javax.servlet.http.HttpServletRequest request,
javax.servlet.http.HttpServletResponse response,
com.google.common.base.Stopwatch stopWatch,
S3BaseTask.OpType opType)
Log the access of every single http request.
|
void |
stop()
Shuts down the web server.
|
addHandler, getBindHost, getLocalPort, getServer, getServerConnector, setHandler, start
public static final String ALLUXIO_PROXY_SERVLET_RESOURCE_KEY
public static final String FILE_SYSTEM_SERVLET_RESOURCE_KEY
public static final String STREAM_CACHE_SERVLET_RESOURCE_KEY
public static final String SERVER_CONFIGURATION_RESOURCE_KEY
public static final String ALLUXIO_PROXY_AUDIT_LOG_WRITER_KEY
public static final String GLOBAL_RATE_LIMITER_SERVLET_RESOURCE_KEY
public static final String PROXY_S3_HANDLER_MAP
public ConcurrentHashMap<org.eclipse.jetty.server.Request,S3Handler> mS3HandlerMap
public ProxyWebServer(String serviceName, InetSocketAddress address, ProxyProcess proxyProcess)
ProxyWebServer
.serviceName
- the service nameaddress
- the service addressproxyProcess
- the Alluxio proxy processpublic void stop() throws Exception
WebServer
public static void logAccess(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response, com.google.common.base.Stopwatch stopWatch, S3BaseTask.OpType opType)
request
- response
- stopWatch
- opType
- Copyright © 2023. All Rights Reserved.