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 an HTTP server. |
class |
HttpDestination |
private class |
HttpSender.CommitCallback |
private class |
HttpSender.ContentCallback |
private class |
HttpSender.LastCallback |
class |
MultiplexHttpDestination |
class |
PoolingHttpDestination |
protected static class |
ProxyProtocolClientConnectionFactory.ProxyProtocolConnection |
private static class |
ProxyProtocolClientConnectionFactory.ProxyProtocolConnectionV1 |
private static class |
ProxyProtocolClientConnectionFactory.ProxyProtocolConnectionV2 |
private static class |
Socks4Proxy.Socks4ProxyConnection |
Modifier and Type | Field and Description |
---|---|
private Callback |
HttpReceiver.Decoder.callback |
private Callback |
HttpSender.commitCallback |
private Callback |
HttpSender.lastCallback |
private Callback |
AbstractConnectionPool.requester |
Modifier and Type | Method and Description |
---|---|
private boolean |
HttpReceiver.Decoder.decode(java.nio.ByteBuffer encoded,
Callback callback) |
private void |
HttpReceiver.ContentListeners.notifyContent(HttpResponse response,
java.nio.ByteBuffer buffer,
Callback callback) |
private void |
ResponseNotifier.notifyContent(Response.DemandedContentListener listener,
Response response,
java.util.function.LongConsumer demand,
java.nio.ByteBuffer buffer,
Callback callback) |
void |
ResponseNotifier.notifyContent(Response response,
java.util.function.ObjLongConsumer<java.lang.Object> demand,
java.nio.ByteBuffer buffer,
Callback callback,
java.util.List<Response.DemandedContentListener> 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 |
ProxyProtocolClientConnectionFactory.ProxyProtocolConnection.writePROXYBytes(EndPoint endPoint,
Callback callback) |
protected void |
ProxyProtocolClientConnectionFactory.ProxyProtocolConnectionV1.writePROXYBytes(EndPoint endPoint,
Callback callback) |
protected void |
ProxyProtocolClientConnectionFactory.ProxyProtocolConnectionV2.writePROXYBytes(EndPoint endPoint,
Callback callback) |
Constructor and Description |
---|
AbstractConnectionPool(Destination destination,
int maxConnections,
Callback requester)
Deprecated.
|
AbstractConnectionPool(HttpDestination destination,
int maxConnections,
Callback requester) |
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 |
---|---|
default void |
Response.ContentListener.onContent(Response response,
java.nio.ByteBuffer content,
Callback callback) |
void |
Response.AsyncContentListener.onContent(Response response,
java.nio.ByteBuffer content,
Callback callback)
Callback method invoked when the response content has been received, parsed and there is demand.
|
default void |
Response.AsyncContentListener.onContent(Response response,
java.util.function.LongConsumer demand,
java.nio.ByteBuffer content,
Callback callback) |
void |
Response.DemandedContentListener.onContent(Response response,
java.util.function.LongConsumer demand,
java.nio.ByteBuffer content,
Callback callback)
Callback method invoked when the response content has been received.
|
Modifier and Type | Class and Description |
---|---|
class |
HttpDestinationOverHTTP |
private class |
HttpSenderOverHTTP.ByteBufferRecyclerCallback |
private class |
HttpSenderOverHTTP.HeadersCallback |
Modifier and Type | Field and Description |
---|---|
private Callback |
HttpSenderOverHTTP.HeadersCallback.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) |
Constructor and Description |
---|
ByteBufferRecyclerCallback(Callback callback,
ByteBufferPool pool,
java.nio.ByteBuffer... buffers) |
HeadersCallback(HttpExchange exchange,
HttpContent content,
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) |
boolean |
EndPoint.tryFillInterested(Callback callback)
Requests callback methods to be invoked when a call to
EndPoint.fill(ByteBuffer) would return data or EOF. |
void |
AbstractConnection.tryFillInterested(Callback callback) |
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 |
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. |
void |
WriteFlusher.write(Callback callback,
java.nio.ByteBuffer... buffers)
Tries to switch state to WRITING.
|
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.AsyncWrite |
private class |
HttpOutput.ChannelWriteCB |
private class |
HttpOutput.InputStreamWritingCB
An iterating callback that will take content from an
InputStream and write it to the associated
HttpChannel . |
private class |
HttpOutput.NestedChannelWriteCB |
private class |
HttpOutput.ReadableByteChannelWritingCB
An iterating callback that will take content from a
ReadableByteChannel and write it to the
HttpChannel . |
private class |
HttpOutput.WriteCompleteCB |
Modifier and Type | Field and Description |
---|---|
private Callback |
HttpConnection.SendCallback._callback |
(package private) Callback |
HttpOutput.NestedChannelWriteCB._callback |
private Callback |
HttpOutput._closedCallback |
Modifier and Type | Method and Description |
---|---|
private Callback |
HttpConnection.SendCallback.release() |
Modifier and Type | Method and Description |
---|---|
private void |
HttpOutput.channelWrite(java.nio.ByteBuffer content,
boolean last,
Callback callback) |
void |
ResponseWriter.complete(Callback callback) |
void |
HttpWriter.complete(Callback callback) |
void |
HttpOutput.complete(Callback callback) |
void |
Response.completeOutput(Callback callback) |
void |
ProxyConnectionFactory.ProxyEndPoint.fillInterested(Callback callback) |
private boolean |
HttpOutput.prepareSendContent(int len,
Callback callback) |
private boolean |
HttpConnection.SendCallback.reset(MetaData.Response info,
boolean head,
java.nio.ByteBuffer content,
boolean last,
Callback callback) |
void |
HttpConnection.send(MetaData.Response info,
boolean head,
java.nio.ByteBuffer content,
boolean lastContent,
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 |
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.
|
boolean |
HttpChannel.sendResponse(MetaData.Response info,
java.nio.ByteBuffer content,
boolean complete,
Callback callback) |
boolean |
ProxyConnectionFactory.ProxyEndPoint.tryFillInterested(Callback callback) |
void |
HttpChannel.write(java.nio.ByteBuffer content,
boolean complete,
Callback callback)
Non-Blocking write, committing the response if needed.
|
void |
HttpOutput.Interceptor.write(java.nio.ByteBuffer content,
boolean last,
Callback callback)
Write content.
|
void |
ProxyConnectionFactory.ProxyEndPoint.write(Callback callback,
java.nio.ByteBuffer... buffers) |
Constructor and Description |
---|
InputStreamWritingCB(java.io.InputStream in,
Callback callback) |
NestedChannelWriteCB(Callback callback,
boolean last) |
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 | Interface and Description |
---|---|
static interface |
Callback.InvocableCallback |
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
Deprecated.
not used anymore
|
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.combine(Callback cb1,
Callback cb2) |
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.combine(Callback cb1,
Callback cb2) |
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) |