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 | |
org.eclipse.jetty.client.util |
Jetty Client : Utility Classes
|
org.eclipse.jetty.io |
Jetty IO : Core classes for Jetty IO subsystem
|
org.eclipse.jetty.io.ssl |
Jetty IO : Core SSL Support
|
org.eclipse.jetty.server |
Jetty Server : Core Server API
|
org.eclipse.jetty.server.handler |
Jetty Server : Core Handler API
|
org.eclipse.jetty.server.handler.gzip |
Jetty GZIP Handler
|
org.eclipse.jetty.util |
Jetty Util : Common Utility Classes
|
Modifier and Type | Class and Description |
---|---|
class |
HttpContent
HttpContent is a stateful, linear representation of the request content provided
by a ContentProvider that can be traversed one-way to obtain content buffers to
send to a HTTP server. |
class |
HttpDestination |
private class |
HttpReceiver.Decoder |
private class |
HttpSender.CommitCallback |
private class |
HttpSender.ContentCallback |
private class |
HttpSender.LastCallback |
private class |
HttpSender.TrailersCallback |
class |
MultiplexHttpDestination |
class |
PoolingHttpDestination |
private static class |
Socks4Proxy.Socks4ProxyConnection |
Modifier and Type | Field and Description |
---|---|
private Callback |
HttpSender.commitCallback |
private Callback |
HttpSender.lastCallback |
private Callback |
AbstractConnectionPool.requester |
private Callback |
HttpSender.trailersCallback |
Modifier and Type | Method and Description |
---|---|
void |
ResponseNotifier.notifyContent(java.util.List<Response.ResponseListener> listeners,
Response response,
java.nio.ByteBuffer buffer,
Callback callback) |
private void |
ResponseNotifier.notifyContent(Response.AsyncContentListener listener,
Response response,
java.nio.ByteBuffer buffer,
Callback callback) |
void |
ResponseNotifier.notifyContent(Response response,
java.nio.ByteBuffer buffer,
Callback callback,
java.util.List<Response.AsyncContentListener> contentListeners) |
protected boolean |
HttpReceiver.responseContent(HttpExchange exchange,
java.nio.ByteBuffer buffer,
Callback callback)
Method to be invoked when response HTTP content is available.
|
protected abstract void |
HttpSender.sendContent(HttpExchange exchange,
HttpContent content,
Callback callback)
Implementations should send the content at the
HttpContent cursor position over the wire. |
protected abstract void |
HttpSender.sendHeaders(HttpExchange exchange,
HttpContent content,
Callback callback)
Implementations should send the HTTP headers over the wire, possibly with some content,
in a single write, and notify the given
callback of the result of this operation. |
protected abstract void |
HttpSender.sendTrailers(HttpExchange exchange,
Callback callback)
Implementations should send the HTTP trailers and notify the given
callback of the
result of this operation. |
Constructor and Description |
---|
AbstractConnectionPool(Destination destination,
int maxConnections,
Callback requester) |
Decoder(ResponseNotifier notifier,
HttpResponse response,
ContentDecoder decoder,
java.nio.ByteBuffer buffer,
Callback callback) |
DuplexConnectionPool(Destination destination,
int maxConnections,
Callback requester) |
LeakTrackingConnectionPool(Destination destination,
int maxConnections,
Callback requester) |
MultiplexConnectionPool(HttpDestination destination,
int maxConnections,
Callback requester,
int maxMultiplex) |
RoundRobinConnectionPool(Destination destination,
int maxConnections,
Callback requester) |
RoundRobinConnectionPool(Destination destination,
int maxConnections,
Callback requester,
int maxMultiplex) |
ValidatingConnectionPool(Destination destination,
int maxConnections,
Callback requester,
Scheduler scheduler,
long timeout) |
Modifier and Type | Method and Description |
---|---|
void |
Response.AsyncContentListener.onContent(Response response,
java.nio.ByteBuffer content,
Callback callback)
Callback method invoked asynchronously when the response content has been received.
|
void |
Response.Listener.Adapter.onContent(Response response,
java.nio.ByteBuffer content,
Callback callback) |
Modifier and Type | Class and Description |
---|---|
class |
HttpDestinationOverHTTP |
private class |
HttpSenderOverHTTP.ByteBufferRecyclerCallback |
private class |
HttpSenderOverHTTP.HeadersCallback |
private class |
HttpSenderOverHTTP.TrailersCallback |
Modifier and Type | Field and Description |
---|---|
private Callback |
HttpSenderOverHTTP.HeadersCallback.callback |
private Callback |
HttpSenderOverHTTP.TrailersCallback.callback |
Modifier and Type | Method and Description |
---|---|
protected void |
HttpSenderOverHTTP.sendContent(HttpExchange exchange,
HttpContent content,
Callback callback) |
protected void |
HttpSenderOverHTTP.sendHeaders(HttpExchange exchange,
HttpContent content,
Callback callback) |
protected void |
HttpSenderOverHTTP.sendTrailers(HttpExchange exchange,
Callback callback) |
Constructor and Description |
---|
ByteBufferRecyclerCallback(Callback callback,
ByteBufferPool pool,
java.nio.ByteBuffer... buffers) |
HeadersCallback(HttpExchange exchange,
HttpContent content,
Callback callback,
HttpConnectionOverHTTP httpConnectionOverHTTP) |
TrailersCallback(Callback callback) |
Modifier and Type | Class and Description |
---|---|
class |
DeferredContentProvider
A
ContentProvider that allows to add content after Request.send(Response.CompleteListener)
has been called, therefore providing the request content at a later time. |
private class |
DeferredContentProvider.DeferredContentProviderIterator |
class |
InputStreamContentProvider
A
ContentProvider for an InputStream . |
private class |
MultiPartContentProvider.MultiPartIterator |
class |
OutputStreamContentProvider
A
ContentProvider that provides content asynchronously through an OutputStream
similar to DeferredContentProvider . |
Modifier and Type | Field and Description |
---|---|
Callback |
DeferredContentProvider.Chunk.callback |
Modifier and Type | Method and Description |
---|---|
private java.util.List<Callback> |
InputStreamResponseListener.drain() |
Modifier and Type | Method and Description |
---|---|
boolean |
DeferredContentProvider.offer(java.nio.ByteBuffer buffer,
Callback callback) |
void |
InputStreamResponseListener.onContent(Response response,
java.nio.ByteBuffer content,
Callback callback) |
Constructor and Description |
---|
Chunk(java.nio.ByteBuffer buffer,
Callback callback) |
Modifier and Type | Class and Description |
---|---|
private class |
AbstractConnection.ReadCallback |
Modifier and Type | Field and Description |
---|---|
private Callback |
WriteFlusher.PendingState._callback |
private Callback |
AbstractConnection._readCallback |
Modifier and Type | Field and Description |
---|---|
private java.util.concurrent.atomic.AtomicReference<Callback> |
FillInterest._interested |
Modifier and Type | Method and Description |
---|---|
private void |
WriteFlusher.fail(Callback callback,
java.lang.Throwable... suppressed) |
protected void |
AbstractConnection.failedCallback(Callback callback,
java.lang.Throwable x) |
void |
AbstractEndPoint.fillInterested(Callback callback) |
void |
EndPoint.fillInterested(Callback callback)
Requests callback methods to be invoked when a call to
EndPoint.fill(ByteBuffer) would return data or EOF. |
void |
FillInterest.register(Callback callback)
Call to register interest in a callback when a read is possible.
|
boolean |
AbstractEndPoint.tryFillInterested(Callback callback) |
void |
AbstractConnection.tryFillInterested(Callback callback) |
boolean |
EndPoint.tryFillInterested(Callback callback)
Requests callback methods to be invoked when a call to
EndPoint.fill(ByteBuffer) would return data or EOF. |
boolean |
FillInterest.tryRegister(Callback callback)
Call to register interest in a callback when a read is possible.
|
void |
AbstractEndPoint.write(Callback callback,
java.nio.ByteBuffer... buffers) |
void |
WriteFlusher.write(Callback callback,
java.nio.ByteBuffer... buffers)
Tries to switch state to WRITING.
|
void |
EndPoint.write(Callback callback,
java.nio.ByteBuffer... buffers)
Writes the given buffers via
EndPoint.flush(ByteBuffer...) and invokes callback methods when either
all the data has been flushed or an error occurs. |
Constructor and Description |
---|
PendingState(java.nio.ByteBuffer[] buffers,
Callback callback) |
Modifier and Type | Class and Description |
---|---|
private class |
SslConnection.DecryptedEndPoint.IncompleteWriteCallback |
Modifier and Type | Field and Description |
---|---|
private Callback |
SslConnection.DecryptedEndPoint._incompleteWriteCallback |
private Callback |
SslConnection._sslReadCallback |
Modifier and Type | Class and Description |
---|---|
private class |
HttpChannel.Send100Callback |
private class |
HttpChannel.SendCallback |
private class |
HttpConnection.AsyncReadCallback |
private class |
HttpConnection.BlockingReadCallback |
private class |
HttpConnection.Content |
private class |
HttpConnection.SendCallback |
static class |
HttpInput.Content |
static class |
HttpInput.EofContent |
static class |
HttpInput.SentinelContent
A Sentinel Content, which has zero length content but
indicates some other event in the input stream (eg EOF)
|
private class |
HttpOutput.AsyncFlush |
private class |
HttpOutput.AsyncICB |
private class |
HttpOutput.AsyncWrite |
private class |
HttpOutput.InputStreamWritingCB
An iterating callback that will take content from an
InputStream and write it to the associated
HttpChannel . |
private class |
HttpOutput.ReadableByteChannelWritingCB
An iterating callback that will take content from a
ReadableByteChannel and write it to the
HttpChannel . |
Modifier and Type | Field and Description |
---|---|
private Callback |
HttpConnection.SendCallback._callback |
Modifier and Type | Method and Description |
---|---|
void |
ProxyConnectionFactory.ProxyEndPoint.fillInterested(Callback callback) |
private boolean |
HttpConnection.SendCallback.reset(MetaData.Response info,
boolean head,
java.nio.ByteBuffer content,
boolean last,
Callback callback) |
void |
HttpTransport.send(MetaData.Response info,
boolean head,
java.nio.ByteBuffer content,
boolean lastContent,
Callback callback)
Asynchronous call to send a response (or part) over the transport
|
void |
HttpConnection.send(MetaData.Response info,
boolean head,
java.nio.ByteBuffer content,
boolean lastContent,
Callback callback) |
void |
HttpOutput.sendContent(java.nio.ByteBuffer content,
Callback callback)
Asynchronous send of whole content.
|
void |
HttpOutput.sendContent(HttpContent httpContent,
Callback callback)
Asynchronous send of HTTP content.
|
void |
HttpOutput.sendContent(java.io.InputStream in,
Callback callback)
Asynchronous send of stream content.
|
void |
HttpOutput.sendContent(java.nio.channels.ReadableByteChannel in,
Callback callback)
Asynchronous send of channel content.
|
protected boolean |
HttpChannel.sendResponse(MetaData.Response info,
java.nio.ByteBuffer content,
boolean complete,
Callback callback) |
boolean |
ProxyConnectionFactory.ProxyEndPoint.tryFillInterested(Callback callback) |
protected void |
HttpOutput.write(java.nio.ByteBuffer content,
boolean complete,
Callback callback) |
void |
HttpOutput.Interceptor.write(java.nio.ByteBuffer content,
boolean last,
Callback callback)
Write content.
|
void |
HttpChannel.write(java.nio.ByteBuffer content,
boolean complete,
Callback callback)
Non-Blocking write, committing the response if needed.
|
void |
ProxyConnectionFactory.ProxyEndPoint.write(Callback callback,
java.nio.ByteBuffer... buffers) |
Constructor and Description |
---|
InputStreamWritingCB(java.io.InputStream in,
Callback callback) |
ReadableByteChannelWritingCB(java.nio.channels.ReadableByteChannel in,
Callback callback) |
Send100Callback(Callback callback) |
SendCallback(Callback callback,
java.nio.ByteBuffer content,
boolean commit,
boolean complete) |
Modifier and Type | Method and Description |
---|---|
protected void |
BufferedResponseHandler.BufferedInterceptor.commit(java.util.Queue<java.nio.ByteBuffer> buffers,
Callback callback) |
void |
ContextHandlerCollection.deployHandler(Handler handler,
Callback callback)
Thread safe deploy of a Handler.
|
void |
ContextHandlerCollection.undeployHandler(Handler handler,
Callback callback)
Thread safe undeploy of a Handler.
|
void |
BufferedResponseHandler.BufferedInterceptor.write(java.nio.ByteBuffer content,
boolean last,
Callback callback) |
Modifier and Type | Class and Description |
---|---|
private class |
GzipHttpOutputInterceptor.GzipBufferCB |
Modifier and Type | Method and Description |
---|---|
protected void |
GzipHttpOutputInterceptor.commit(java.nio.ByteBuffer content,
boolean complete,
Callback callback) |
private void |
GzipHttpOutputInterceptor.gzip(java.nio.ByteBuffer content,
boolean complete,
Callback callback) |
void |
GzipHttpOutputInterceptor.write(java.nio.ByteBuffer content,
boolean complete,
Callback callback) |
Constructor and Description |
---|
GzipBufferCB(java.nio.ByteBuffer content,
boolean complete,
Callback callback) |
Modifier and Type | Class and Description |
---|---|
static class |
Callback.Completable
A CompletableFuture that is also a Callback.
|
static class |
Callback.Completing |
static class |
Callback.Nested
Nested Completing Callback that completes after
completing the nested callback
|
class |
CompletableCallback
A callback to be used by driver code that needs to know whether the callback has been
succeeded or failed (that is, completed) just after the asynchronous operation or not,
typically because further processing depends on the callback being completed.
|
class |
CountingCallback
A callback wrapper that succeeds the wrapped callback when the count is
reached, or on first failure.
|
class |
FutureCallback |
class |
IteratingCallback
This specialized callback implements a pattern that allows
a large job to be broken into smaller tasks using iteration
rather than recursion.
|
class |
IteratingNestedCallback
Iterating Nested Callback.
|
class |
SharedBlockingCallback.Blocker
A Closeable Callback.
|
Modifier and Type | Field and Description |
---|---|
(package private) Callback |
IteratingNestedCallback._callback |
private Callback |
Callback.Nested.callback |
static Callback |
Callback.NOOP
Instance of Adapter that can be used when the callback methods need an empty
implementation without incurring in the cost of allocating a new Adapter object.
|
Modifier and Type | Method and Description |
---|---|
static Callback |
Callback.from(Callback callback,
java.lang.Runnable completed)
Create a nested callback that runs completed after
completing the nested callback.
|
static Callback |
Callback.from(java.util.concurrent.CompletableFuture<?> completable)
Creates a non-blocking callback from the given incomplete CompletableFuture.
|
static Callback |
Callback.from(java.util.concurrent.CompletableFuture<?> completable,
Invocable.InvocationType invocation)
Creates a callback from the given incomplete CompletableFuture,
with the given
blocking characteristic. |
static Callback |
Callback.from(java.lang.Runnable completed)
Creaste a callback that runs completed when it succeeds or fails
|
static Callback |
Callback.from(java.lang.Runnable completed,
Callback callback)
Create a nested callback that runs completed before
completing the nested callback.
|
static Callback |
Callback.from(java.lang.Runnable success,
java.util.function.Consumer<java.lang.Throwable> failure)
Create a callback from the passed success and failure
|
Callback |
Callback.Nested.getCallback() |
Modifier and Type | Method and Description |
---|---|
static Callback |
Callback.from(Callback callback,
java.lang.Runnable completed)
Create a nested callback that runs completed after
completing the nested callback.
|
static Callback |
Callback.from(java.lang.Runnable completed,
Callback callback)
Create a nested callback that runs completed before
completing the nested callback.
|
Constructor and Description |
---|
CountingCallback(Callback callback,
int count) |
IteratingNestedCallback(Callback callback) |
Nested(Callback callback) |