| Package | Description |
|---|---|
| org.jredis.connector |
Native Client Interface Specification.
|
| org.jredis.protocol |
This package contains the constructs that reflect the Redis Protocol Specification
TODO: elaborate on the spec requirements.
|
| org.jredis.ri.alphazero |
This package and child packages contain reference implementation alphazero
of the
JRedis and Connection
of the optional Connector specifications. |
| org.jredis.ri.alphazero.connection | |
| org.jredis.ri.alphazero.protocol |
| Modifier and Type | Method and Description |
|---|---|
Response |
Connection.serviceRequest(Command cmd,
byte[]... args)
A blocking call to service the specified request.
|
Response |
FaultedConnection.serviceRequest(Command cmd,
byte[]... args) |
| Modifier and Type | Method and Description |
|---|---|
java.util.concurrent.Future<Response> |
Connection.queueRequest(Command cmd,
byte[]... args)
A non-blocking call to service the specified request at some point in the future.
|
java.util.concurrent.Future<Response> |
FaultedConnection.queueRequest(Command cmd,
byte[]... args) |
| Modifier and Type | Method and Description |
|---|---|
void |
RequestListener.onResponse(java.lang.Object context,
Request request,
Response response) |
| Modifier and Type | Interface and Description |
|---|---|
interface |
BulkResponse
[TODO: document me!]
|
interface |
MultiBulkResponse
[TODO: document me!]
|
interface |
StatusResponse
This is just a marker interface.
|
interface |
ValueResponse
Formally, redis only returns "integers" as values, but in fact, an operation such as
Command.RANDOMKEY will return a key in a single line reply, and not a bulk reply. |
| Modifier and Type | Field and Description |
|---|---|
java.lang.Class<? extends Response> |
Command.ResponseType.respClass |
| Modifier and Type | Method and Description |
|---|---|
Response |
Protocol.createResponse(Command cmd)
Creates a response object for the
Command specified. |
| Constructor and Description |
|---|
ResponseType(java.lang.Class<? extends Response> respClass)
For each
Command.ResponseType member, we specify the
corresponding Response extension interface. |
| Modifier and Type | Field and Description |
|---|---|
protected java.util.concurrent.Future<Response> |
JRedisFutureSupport.FutureResultBase.pendingRequest |
| Modifier and Type | Method and Description |
|---|---|
protected Response |
JRedisPipelineService.serviceRequest(Command cmd,
byte[]... args) |
protected abstract Response |
JRedisSupport.serviceRequest(Command cmd,
byte[]... args)
This method mimics the eponymous
Connection#serviceRequest(Command, byte[]...)
which defines the blocking api semantics of Synchronous connections. |
protected Response |
JRedisClient.serviceRequest(Command cmd,
byte[]... args) |
| Modifier and Type | Method and Description |
|---|---|
protected abstract java.util.concurrent.Future<Response> |
JRedisFutureSupport.queueRequest(Command cmd,
byte[]... args)
This method mimics the eponymous
Connection#queueRequest(Command, byte[]...)
which defines the blocking api semantics of Synchronous connections. |
protected java.util.concurrent.Future<Response> |
JRedisChunkedPipeline.queueRequest(Command cmd,
byte[]... args) |
protected java.util.concurrent.Future<Response> |
JRedisAsyncClient.queueRequest(Command cmd,
byte[]... args)
Requests to server are queued at this point.
|
protected java.util.concurrent.Future<Response> |
JRedisPipeline.queueRequest(Command cmd,
byte[]... args)
Requests to server are queued at this point.
|
| Constructor and Description |
|---|
FutureBit(java.util.concurrent.Future<Response> pendingRequest) |
FutureBoolean(java.util.concurrent.Future<Response> pendingRequest) |
FutureByteArray(java.util.concurrent.Future<Response> pendingRequest) |
FutureByteArrayList(java.util.concurrent.Future<Response> pendingRequest) |
FutureDataDictionary(java.util.concurrent.Future<Response> pendingRequest) |
FutureDouble(java.util.concurrent.Future<Response> pendingRequest) |
FutureInfo(java.util.concurrent.Future<Response> pendingRequest) |
FutureKeyList(java.util.concurrent.Future<Response> pendingRequest) |
FutureLong(java.util.concurrent.Future<Response> pendingRequest) |
FutureObjectInfo(java.util.concurrent.Future<Response> pendingRequest) |
FutureRedisType(java.util.concurrent.Future<Response> pendingRequest) |
FutureResultBase(java.util.concurrent.Future<Response> pendingRequest) |
FutureSortStoreResp(java.util.concurrent.Future<Response> pendingRequest) |
FutureStatus(java.util.concurrent.Future<Response> pendingRequest) |
FutureString(java.util.concurrent.Future<Response> pendingRequest) |
FutureZSetList(java.util.concurrent.Future<Response> pendingRequest) |
| Modifier and Type | Field and Description |
|---|---|
(package private) Response |
PendingRequest.response
awaited response
|
| Modifier and Type | Method and Description |
|---|---|
Response |
ChunkedPipelineConnection.PendingCPRequest.get() |
Response |
PendingRequest.get() |
Response |
ChunkedPipelineConnection.PendingCPRequest.get(long timeout,
java.util.concurrent.TimeUnit unit) |
Response |
PendingRequest.get(long timeout,
java.util.concurrent.TimeUnit unit) |
Response |
SyncConnection.serviceRequest(Command cmd,
byte[]... args) |
Response |
ConnectionBase.serviceRequest(Command cmd,
byte[]... args) |
Response |
SyncPipelineConnection.serviceRequest(Command cmd,
byte[]... args) |
| Modifier and Type | Method and Description |
|---|---|
java.util.concurrent.Future<Response> |
PipelineConnectionBase.queueRequest(Command cmd,
byte[]... args)
This is a pseudo asynchronous method.
|
java.util.concurrent.Future<Response> |
AsyncConnection.queueRequest(Command cmd,
byte[]... args) |
java.util.concurrent.Future<Response> |
ChunkedPipelineConnection.queueRequest(Command cmd,
byte[]... args)
This is a true asynchronous method.
|
java.util.concurrent.Future<Response> |
ConnectionBase.queueRequest(Command cmd,
byte[]... args) |
| Modifier and Type | Method and Description |
|---|---|
(package private) void |
PendingRequest.setResponse(Response response)
Signals completion without error.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ResponseSupport
Base for all responses.
|
class |
SyncProtocol.SyncBulkResponse |
class |
SyncProtocol.SyncLineResponse |
class |
SyncProtocol.SyncMultiBulkResponse |
class |
SyncProtocol.SyncMultiLineResponseBase
Abstract base for all multiline responses (as of now, Bulk and MultBulk).
|
class |
SyncProtocol.SyncResponseBase
Synchronous responses are guaranteed to be contiguous chunks (if the
client of this class is respecting its contract) -- meaning, it can go
ahead and read as much as it can in its first read without busy waiting
or reading one byte at a time.
|
class |
VirtualResponse
Certain requested commands do not have a corresponding response from
redis.
|
| Modifier and Type | Method and Description |
|---|---|
protected abstract Response |
ProtocolBase.createBooleanResponse(Command cmd) |
protected Response |
SyncProtocol.createBooleanResponse(Command cmd) |
protected Response |
ConcurrentSyncProtocol.createBooleanResponse(Command cmd) |
protected abstract Response |
ProtocolBase.createBulkResponse(Command cmd) |
protected Response |
SyncProtocol.createBulkResponse(Command cmd) |
protected Response |
ConcurrentSyncProtocol.createBulkResponse(Command cmd) |
protected abstract Response |
ProtocolBase.createMultiBulkResponse(Command cmd) |
protected Response |
SyncProtocol.createMultiBulkResponse(Command cmd) |
protected Response |
ConcurrentSyncProtocol.createMultiBulkResponse(Command cmd) |
protected abstract Response |
ProtocolBase.createNumberResponse(Command cmd) |
protected Response |
SyncProtocol.createNumberResponse(Command cmd) |
protected Response |
ConcurrentSyncProtocol.createNumberResponse(Command cmd) |
Response |
ProtocolBase.createResponse(Command cmd) |
protected abstract Response |
ProtocolBase.createStatusResponse(Command cmd) |
protected Response |
SyncProtocol.createStatusResponse(Command cmd) |
protected Response |
ConcurrentSyncProtocol.createStatusResponse(Command cmd) |
protected abstract Response |
ProtocolBase.createStringResponse(Command cmd) |
protected Response |
SyncProtocol.createStringResponse(Command cmd) |
protected Response |
ConcurrentSyncProtocol.createStringResponse(Command cmd) |