| 程序包 | 说明 |
|---|---|
| org.zodiac.server.proxy | |
| org.zodiac.server.proxy.impl |
| 限定符和类型 | 字段和说明 |
|---|---|
private ProxyToServerConnection |
FullFlowContext.serverConnection |
| 限定符和类型 | 方法和说明 |
|---|---|
ProxyToServerConnection |
FullFlowContext.getServerConnection() |
| 构造器和说明 |
|---|
FullFlowContext(ClientToProxyConnection clientConnection,
ProxyToServerConnection serverConnection) |
| 限定符和类型 | 字段和说明 |
|---|---|
private ProxyToServerConnection |
ClientToProxyConnection.currentServerConnection |
private ProxyToServerConnection |
ConnectionFlow.serverConnection |
| 限定符和类型 | 字段和说明 |
|---|---|
private Map<InetSocketAddress,ProxyToServerConnection> |
ClientToProxyConnection.serverConnectionsMap |
| 限定符和类型 | 方法和说明 |
|---|---|
(专用程序包) static ProxyToServerConnection |
ProxyToServerConnection.create(ProxyConfigOptions proxyConfigOptions,
HttpProxyManager httpProxyManager,
String applicationName,
ClientToProxyConnection clientConnection,
HttpFilters initialFilters,
InetSocketAddress remoteAddress,
io.netty.handler.traffic.GlobalTrafficShapingHandler globalTrafficShapingHandler) |
| 限定符和类型 | 方法和说明 |
|---|---|
private void |
ClientToProxyConnection.closeConnectionsAfterWriteIfNecessary(ProxyToServerConnection serverConnection,
io.netty.handler.codec.http.HttpRequest currentHttpRequest,
io.netty.handler.codec.http.HttpResponse currentHttpResponse,
io.netty.handler.codec.http.HttpObject httpObject)
This method takes care of closing client to proxy and/or proxy to server connections after finishing a write.
|
private void |
ClientToProxyConnection.connectionFailedUnrecoverably(HttpRequestWrapper initialRequest,
ProxyToServerConnection serverConnection) |
private void |
ClientToProxyConnection.forceDisconnect(ProxyToServerConnection serverConnection) |
(专用程序包) void |
ClientToProxyConnection.respond(ProxyToServerConnection serverConnection,
HttpFilters filters,
io.netty.handler.codec.http.HttpRequest currentHttpRequest,
io.netty.handler.codec.http.HttpResponse currentHttpResponse,
io.netty.handler.codec.http.HttpObject httpObject)
Send a response to the client.
|
protected void |
ClientToProxyConnection.serverBecameSaturated(ProxyToServerConnection serverConnection)
When a server becomes saturated, we stop reading from the client.
|
protected void |
ClientToProxyConnection.serverBecameWriteable(ProxyToServerConnection serverConnection)
When a server becomes writeable, we check to see if all servers are writeable and if they are, we resume reading.
|
protected boolean |
ClientToProxyConnection.serverConnectionFailed(ProxyToServerConnection serverConnection,
ConnectionState lastStateBeforeFailure,
Throwable cause)
If the
ProxyToServerConnection fails to complete its connection lifecycle successfully, this method is
called to let us know about it. |
protected void |
ClientToProxyConnection.serverConnectionFlowStarted(ProxyToServerConnection serverConnection)
Called when
ProxyToServerConnection starts its connection flow. |
protected void |
ClientToProxyConnection.serverConnectionSucceeded(ProxyToServerConnection serverConnection,
boolean shouldForwardInitialRequest)
If the
ProxyToServerConnection completes its connection lifecycle successfully, this method is called to
let us know about it. |
protected void |
ClientToProxyConnection.serverDisconnected(ProxyToServerConnection serverConnection)
On disconnect of the server, track that we have one fewer connected servers and then disconnect the client if
necessary.
|
(专用程序包) void |
ClientToProxyConnection.timedOut(ProxyToServerConnection serverConnection) |
| 构造器和说明 |
|---|
ConnectionFlow(ClientToProxyConnection clientConnection,
ProxyToServerConnection serverConnection,
Object connectLock)
Construct a new
ConnectionFlow for the given client and server connections. |
Copyright © 2021 Zodiac. All rights reserved.