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.fcgi.client.http | |
org.eclipse.jetty.fcgi.generator | |
org.eclipse.jetty.fcgi.server | |
org.eclipse.jetty.http2 | |
org.eclipse.jetty.http2.api | |
org.eclipse.jetty.http2.client.http | |
org.eclipse.jetty.http2.server | |
org.eclipse.jetty.io |
Jetty IO : Core classes for Jetty IO subsystem
|
org.eclipse.jetty.proxy |
Jetty Proxy : Async Proxy Support
|
org.eclipse.jetty.server |
Jetty Server : Core Server API
|
org.eclipse.jetty.server.handler.gzip |
Jetty GZIP Handler
|
org.eclipse.jetty.util |
Jetty Util : Common Utility Classes
|
org.eclipse.jetty.websocket.client.io |
Jetty WebSocket Client : I/O Implementation [Internal Use Only]
|
org.eclipse.jetty.websocket.common |
Jetty WebSocket Common : Implementation [Internal Use Only]
|
org.eclipse.jetty.websocket.common.io |
Jetty WebSocket Common : I/O Implementation
|
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 |
PoolingHttpDestination<C extends Connection> |
Modifier and Type | Method and Description |
---|---|
void |
ResponseNotifier.notifyContent(List<Response.ResponseListener> listeners,
Response response,
ByteBuffer buffer,
Callback callback) |
protected boolean |
HttpReceiver.responseContent(HttpExchange exchange,
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. |
Constructor and Description |
---|
ConnectionPool(Destination destination,
int maxConnections,
Callback requester) |
LeakTrackingConnectionPool(Destination destination,
int maxConnections,
Callback requester) |
Modifier and Type | Method and Description |
---|---|
void |
Response.AsyncContentListener.onContent(Response response,
ByteBuffer content,
Callback callback)
Callback method invoked asynchronously when the response content has been received.
|
void |
Response.Listener.Adapter.onContent(Response response,
ByteBuffer content,
Callback callback) |
Modifier and Type | Class and Description |
---|---|
class |
HttpDestinationOverHTTP |
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) |
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. |
class |
InputStreamContentProvider
A
ContentProvider for an InputStream . |
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 |
---|---|
boolean |
DeferredContentProvider.offer(ByteBuffer buffer,
Callback callback) |
Constructor and Description |
---|
Chunk(ByteBuffer buffer,
Callback callback) |
Modifier and Type | Class and Description |
---|---|
class |
HttpDestinationOverFCGI |
Modifier and Type | Method and Description |
---|---|
protected boolean |
HttpChannelOverFCGI.content(ByteBuffer buffer,
Callback callback) |
protected boolean |
HttpReceiverOverFCGI.responseContent(HttpExchange exchange,
ByteBuffer buffer,
Callback callback) |
protected void |
HttpSenderOverFCGI.sendContent(HttpExchange exchange,
HttpContent content,
Callback callback) |
protected void |
HttpSenderOverFCGI.sendHeaders(HttpExchange exchange,
HttpContent content,
Callback callback) |
Modifier and Type | Class and Description |
---|---|
static class |
Generator.Result |
Modifier and Type | Method and Description |
---|---|
protected Generator.Result |
Generator.generateContent(int id,
ByteBuffer content,
boolean recycle,
boolean lastContent,
Callback callback,
FCGI.FrameType frameType) |
Generator.Result |
ClientGenerator.generateRequestContent(int request,
ByteBuffer content,
boolean lastContent,
Callback callback) |
Generator.Result |
ClientGenerator.generateRequestHeaders(int request,
HttpFields fields,
Callback callback) |
Generator.Result |
ServerGenerator.generateResponseContent(int request,
ByteBuffer content,
boolean lastContent,
boolean aborted,
Callback callback) |
Generator.Result |
ServerGenerator.generateResponseHeaders(int request,
int code,
String reason,
HttpFields fields,
Callback callback) |
Constructor and Description |
---|
Result(ByteBufferPool byteBufferPool,
Callback callback) |
Modifier and Type | Method and Description |
---|---|
protected Generator.Result |
HttpTransportOverFCGI.generateResponseContent(ByteBuffer buffer,
boolean lastContent,
Callback callback) |
protected Generator.Result |
HttpTransportOverFCGI.generateResponseHeaders(MetaData.Response info,
Callback callback) |
void |
HttpTransportOverFCGI.send(MetaData.Response info,
boolean head,
ByteBuffer content,
boolean lastContent,
Callback callback) |
Modifier and Type | Class and Description |
---|---|
class |
HTTP2Flusher |
static class |
HTTP2Flusher.Entry |
Modifier and Type | Field and Description |
---|---|
protected Callback |
HTTP2Flusher.Entry.callback |
Modifier and Type | Method and Description |
---|---|
boolean |
HTTP2Session.close(int error,
String reason,
Callback callback)
Invoked internally and by applications to send a GO_AWAY frame to the
other peer.
|
void |
HTTP2Stream.data(DataFrame frame,
Callback callback) |
void |
ISession.data(IStream stream,
Callback callback,
DataFrame frame)
Enqueues the given DATA frame to be written to the connection.
|
void |
HTTP2Session.data(IStream stream,
Callback callback,
DataFrame frame) |
void |
ISession.frames(IStream stream,
Callback callback,
Frame frame,
Frame... frames)
Enqueues the given frames to be written to the connection.
|
void |
HTTP2Session.frames(IStream stream,
Callback callback,
Frame frame,
Frame... frames) |
void |
HTTP2Stream.headers(HeadersFrame frame,
Callback callback) |
void |
HTTP2Session.ping(PingFrame frame,
Callback callback) |
void |
IStream.process(Frame frame,
Callback callback)
Processes the given
frame , belonging to this stream. |
void |
HTTP2Stream.process(Frame frame,
Callback callback) |
void |
HTTP2Stream.reset(ResetFrame frame,
Callback callback) |
protected void |
HTTP2Session.reset(ResetFrame frame,
Callback callback) |
void |
HTTP2Session.settings(SettingsFrame frame,
Callback callback) |
Constructor and Description |
---|
Entry(Frame frame,
IStream stream,
Callback callback) |
Modifier and Type | Method and Description |
---|---|
boolean |
Session.close(int error,
String payload,
Callback callback)
Closes the session by sending a GOAWAY frame with the given error code
and payload.
|
void |
Stream.data(DataFrame frame,
Callback callback)
Sends the given DATA
frame . |
void |
Stream.headers(HeadersFrame frame,
Callback callback)
Sends the given HEADERS
frame representing a HTTP response. |
void |
Stream.Listener.onData(Stream stream,
DataFrame frame,
Callback callback)
Callback method invoked when a DATA frame has been received.
|
void |
Stream.Listener.Adapter.onData(Stream stream,
DataFrame frame,
Callback callback) |
void |
Session.ping(PingFrame frame,
Callback callback)
Sends the given PING
frame . |
void |
Stream.reset(ResetFrame frame,
Callback callback)
Sends the given RST_STREAM
frame . |
void |
Session.settings(SettingsFrame frame,
Callback callback)
Sends the given SETTINGS
frame to configure the session. |
Modifier and Type | Method and Description |
---|---|
void |
HttpReceiverOverHTTP2.onData(Stream stream,
DataFrame frame,
Callback callback) |
protected void |
HttpSenderOverHTTP2.sendContent(HttpExchange exchange,
HttpContent content,
Callback callback) |
protected void |
HttpSenderOverHTTP2.sendHeaders(HttpExchange exchange,
HttpContent content,
Callback callback) |
Modifier and Type | Class and Description |
---|---|
class |
ByteBufferCallback |
Modifier and Type | Method and Description |
---|---|
void |
HTTP2ServerConnection.onData(IStream stream,
DataFrame frame,
Callback callback) |
Runnable |
HttpChannelOverHTTP2.requestContent(DataFrame frame,
Callback callback) |
void |
HttpTransportOverHTTP2.send(MetaData.Response info,
boolean isHeadRequest,
ByteBuffer content,
boolean lastContent,
Callback callback) |
Constructor and Description |
---|
ByteBufferCallback(ByteBufferPool byteBufferPool,
ByteBuffer buffer,
Callback callback) |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractConnection.failedCallback(Callback callback,
Throwable x) |
void |
EndPoint.fillInterested(Callback callback)
Requests callback methods to be invoked when a call to
EndPoint.fill(ByteBuffer) would return data or EOF. |
void |
AbstractEndPoint.fillInterested(Callback callback) |
void |
FillInterest.register(Callback callback)
Call to register interest in a callback when a read is possible.
|
void |
WriteFlusher.write(Callback callback,
ByteBuffer... buffers)
Tries to switch state to WRITING.
|
void |
EndPoint.write(Callback callback,
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 |
AbstractEndPoint.write(Callback callback,
ByteBuffer... buffers) |
Modifier and Type | Class and Description |
---|---|
protected class |
AsyncMiddleManServlet.ProxyReader |
protected class |
AsyncMiddleManServlet.ProxyResponseListener |
protected class |
AsyncProxyServlet.StreamReader |
protected class |
ProxyServlet.ProxyInputStreamContentProvider |
Modifier and Type | Method and Description |
---|---|
protected void |
AsyncProxyServlet.StreamWriter.data(byte[] bytes,
int offset,
int length,
Callback callback) |
boolean |
AsyncMiddleManServlet.ProxyWriter.offer(ByteBuffer content,
Callback callback) |
void |
ProxyServlet.ProxyResponseListener.onContent(Response proxyResponse,
ByteBuffer content,
Callback callback) |
void |
AsyncMiddleManServlet.ProxyResponseListener.onContent(Response serverResponse,
ByteBuffer content,
Callback callback) |
protected void |
AsyncProxyServlet.StreamReader.onRequestContent(HttpServletRequest request,
Request proxyRequest,
DeferredContentProvider provider,
byte[] buffer,
int offset,
int length,
Callback callback) |
protected void |
ProxyServlet.onResponseContent(HttpServletRequest request,
HttpServletResponse response,
Response proxyResponse,
byte[] buffer,
int offset,
int length,
Callback callback) |
protected void |
AsyncProxyServlet.onResponseContent(HttpServletRequest request,
HttpServletResponse response,
Response proxyResponse,
byte[] buffer,
int offset,
int length,
Callback callback) |
protected abstract void |
ProxyConnection.write(EndPoint endPoint,
ByteBuffer buffer,
Callback callback) |
protected void |
ConnectHandler.write(EndPoint endPoint,
ByteBuffer buffer,
Callback callback)
Writes (with non-blocking semantic) the given buffer of data onto the given endPoint.
|
protected void |
ConnectHandler.UpstreamConnection.write(EndPoint endPoint,
ByteBuffer buffer,
Callback callback) |
protected void |
ConnectHandler.DownstreamConnection.write(EndPoint endPoint,
ByteBuffer buffer,
Callback callback) |
Modifier and Type | Class and Description |
---|---|
static class |
HttpInput.Content |
static class |
HttpInput.EofContent |
static class |
HttpInput.PoisonPillContent |
Modifier and Type | Method and Description |
---|---|
void |
ProxyConnectionFactory.ProxyEndPoint.fillInterested(Callback callback) |
void |
HttpTransport.send(MetaData.Response info,
boolean head,
ByteBuffer content,
boolean lastContent,
Callback callback) |
void |
HttpConnection.send(MetaData.Response info,
boolean head,
ByteBuffer content,
boolean lastContent,
Callback callback) |
void |
HttpOutput.sendContent(ByteBuffer content,
Callback callback)
Asynchronous send of whole content.
|
void |
HttpOutput.sendContent(HttpContent httpContent,
Callback callback)
Asynchronous send of HTTP content.
|
void |
HttpOutput.sendContent(InputStream in,
Callback callback)
Asynchronous send of stream content.
|
void |
HttpOutput.sendContent(ReadableByteChannel in,
Callback callback)
Asynchronous send of channel content.
|
protected boolean |
HttpChannel.sendResponse(MetaData.Response info,
ByteBuffer content,
boolean complete,
Callback callback) |
protected void |
HttpOutput.write(ByteBuffer content,
boolean complete,
Callback callback) |
void |
HttpOutput.Interceptor.write(ByteBuffer content,
boolean complete,
Callback callback) |
void |
HttpChannel.write(ByteBuffer content,
boolean complete,
Callback callback)
Non-Blocking write, committing the response if needed.
|
void |
ProxyConnectionFactory.ProxyEndPoint.write(Callback callback,
ByteBuffer... buffers) |
Modifier and Type | Method and Description |
---|---|
protected void |
GzipHttpOutputInterceptor.commit(ByteBuffer content,
boolean complete,
Callback callback) |
void |
GzipHttpOutputInterceptor.write(ByteBuffer content,
boolean complete,
Callback callback) |
Modifier and Type | Interface and Description |
---|---|
static interface |
Callback.NonBlocking
A marker interface for a callback that is guaranteed not to
block and thus does not need a dispatch
|
Modifier and Type | Class and Description |
---|---|
class |
BlockingCallback
An implementation of Callback that blocks until success or failure.
|
static class |
Callback.Adapter
Empty implementation of
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.
|
Constructor and Description |
---|
CountingCallback(Callback callback,
int count) |
IteratingNestedCallback(Callback callback) |
Modifier and Type | Class and Description |
---|---|
class |
UpgradeConnection.SendUpgradeRequest |
Modifier and Type | Class and Description |
---|---|
static class |
BlockingWriteCallback.WriteBlocker |
Modifier and Type | Class and Description |
---|---|
class |
FutureWriteCallback
Allows events to a
WriteCallback to drive a Future for the user. |
class |
WriteCallbackWrapper
Wraps the exposed
WriteCallback WebSocket API with a Jetty Callback . |
Modifier and Type | Method and Description |
---|---|
static Callback |
WriteCallbackWrapper.wrap(WriteCallback callback) |
Copyright © 1995-2015 Webtide. All Rights Reserved.