Package | Description |
---|---|
org.eclipse.jetty.client |
Jetty Client : Implementation and Core Classes
This package provides APIs, utility classes and an implementation of an asynchronous HTTP client.
|
org.eclipse.jetty.client.api |
Jetty Client : API Classes
|
org.eclipse.jetty.client.http |
Modifier and Type | Class and Description |
---|---|
class |
HttpConnection |
private class |
HttpProxy.ProxyConnection |
Modifier and Type | Field and Description |
---|---|
private Connection |
HttpProxy.ProxyConnection.connection |
private Connection |
MultiplexConnectionPool.Holder.connection |
private Connection |
RoundRobinConnectionPool.Entry.connection |
private Connection |
ValidatingConnectionPool.Holder.connection |
Modifier and Type | Field and Description |
---|---|
private java.util.Set<Connection> |
DuplexConnectionPool.activeConnections |
private java.util.Map<Connection,MultiplexConnectionPool.Holder> |
MultiplexConnectionPool.busyConnections |
private java.util.Deque<Connection> |
DuplexConnectionPool.idleConnections |
private LeakDetector<Connection> |
LeakTrackingConnectionPool.leakDetector |
private java.util.Map<Connection,MultiplexConnectionPool.Holder> |
MultiplexConnectionPool.muxedConnections |
private Promise<Connection> |
HttpProxy.CreateTunnelPromise.promise |
private Promise<Connection> |
HttpProxy.ProxyConnection.promise |
private Promise<Connection> |
HttpProxy.TunnelPromise.promise |
private java.util.Map<Connection,ValidatingConnectionPool.Holder> |
ValidatingConnectionPool.quarantine |
Modifier and Type | Method and Description |
---|---|
Connection |
MultiplexConnectionPool.acquire() |
Connection |
ConnectionPool.acquire()
Returns an idle connection, if available, or schedules the opening
of a new connection and returns
null . |
Connection |
AbstractConnectionPool.acquire() |
protected Connection |
MultiplexConnectionPool.activate() |
protected Connection |
RoundRobinConnectionPool.activate() |
protected abstract Connection |
AbstractConnectionPool.activate() |
protected Connection |
DuplexConnectionPool.activate() |
protected Connection |
AbstractConnectionPool.active(Connection connection) |
Modifier and Type | Method and Description |
---|---|
java.util.Collection<Connection> |
DuplexConnectionPool.getActiveConnections() |
java.util.Queue<Connection> |
DuplexConnectionPool.getIdleConnections() |
Modifier and Type | Method and Description |
---|---|
protected void |
LeakTrackingConnectionPool.acquired(Connection connection) |
protected void |
AbstractConnectionPool.acquired(Connection connection) |
protected Connection |
AbstractConnectionPool.active(Connection connection) |
void |
HttpDestination.close(Connection connection) |
protected boolean |
DuplexConnectionPool.deactivate(Connection connection) |
protected boolean |
AbstractConnectionPool.idle(Connection connection,
boolean close) |
boolean |
MultiplexConnectionPool.isActive(Connection connection) |
boolean |
ConnectionPool.isActive(Connection connection) |
boolean |
RoundRobinConnectionPool.isActive(Connection connection) |
boolean |
DuplexConnectionPool.isActive(Connection connection) |
protected void |
MultiplexConnectionPool.onCreated(Connection connection) |
protected void |
RoundRobinConnectionPool.onCreated(Connection connection) |
protected abstract void |
AbstractConnectionPool.onCreated(Connection connection) |
protected void |
DuplexConnectionPool.onCreated(Connection connection) |
boolean |
HttpDestination.process(Connection connection) |
boolean |
MultiplexConnectionPool.release(Connection connection) |
void |
HttpDestination.release(Connection connection) |
boolean |
ConnectionPool.release(Connection connection)
Returns the given connection, previously obtained via
ConnectionPool.acquire() ,
back to this ConnectionPool. |
boolean |
RoundRobinConnectionPool.release(Connection connection) |
boolean |
ValidatingConnectionPool.release(Connection connection) |
boolean |
DuplexConnectionPool.release(Connection connection) |
protected void |
LeakTrackingConnectionPool.released(Connection connection) |
protected void |
AbstractConnectionPool.released(Connection connection) |
boolean |
MultiplexConnectionPool.remove(Connection connection) |
boolean |
HttpDestination.remove(Connection connection) |
boolean |
ConnectionPool.remove(Connection connection)
Removes the given connection from this ConnectionPool.
|
boolean |
RoundRobinConnectionPool.remove(Connection connection) |
boolean |
ValidatingConnectionPool.remove(Connection connection) |
boolean |
DuplexConnectionPool.remove(Connection connection) |
protected boolean |
MultiplexConnectionPool.remove(Connection connection,
boolean force) |
protected boolean |
DuplexConnectionPool.remove(Connection connection,
boolean force) |
protected void |
AbstractConnectionPool.removed(Connection connection) |
protected abstract SendFailure |
HttpDestination.send(Connection connection,
HttpExchange exchange) |
void |
HttpProxy.CreateTunnelPromise.succeeded(Connection connection) |
void |
HttpProxy.TunnelPromise.succeeded(Connection connection) |
private void |
HttpProxy.CreateTunnelPromise.tunnel(HttpDestination destination,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractConnectionPool.close(java.util.Collection<Connection> connections) |
protected void |
HttpDestination.createConnection(Promise<Connection> promise) |
protected void |
HttpClient.newConnection(HttpDestination destination,
Promise<Connection> promise) |
void |
HttpDestination.newConnection(Promise<Connection> promise) |
Constructor and Description |
---|
Holder(Connection connection) |
Holder(Connection connection) |
ProxyConnection(Destination destination,
Connection connection,
Promise<Connection> promise) |
Constructor and Description |
---|
CreateTunnelPromise(ClientConnectionFactory connectionFactory,
EndPoint endPoint,
Promise<Connection> promise,
java.util.Map<java.lang.String,java.lang.Object> context) |
ProxyConnection(Destination destination,
Connection connection,
Promise<Connection> promise) |
TunnelPromise(Request request,
Response.CompleteListener listener,
Promise<Connection> promise) |
Modifier and Type | Method and Description |
---|---|
void |
Destination.newConnection(Promise<Connection> promise)
Creates asynchronously a new, unpooled,
Connection that will be returned
at a later time through the given Promise . |
Modifier and Type | Class and Description |
---|---|
private class |
HttpConnectionOverHTTP.Delegate |
Modifier and Type | Field and Description |
---|---|
private Promise<Connection> |
HttpConnectionOverHTTP.promise |
Modifier and Type | Method and Description |
---|---|
protected SendFailure |
HttpDestinationOverHTTP.send(Connection connection,
HttpExchange exchange) |
Modifier and Type | Method and Description |
---|---|
protected HttpConnectionOverHTTP |
HttpClientTransportOverHTTP.newHttpConnection(EndPoint endPoint,
HttpDestination destination,
Promise<Connection> promise) |
Constructor and Description |
---|
HttpConnectionOverHTTP(EndPoint endPoint,
HttpDestination destination,
Promise<Connection> promise) |