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 |
FaultedConnection.serviceRequest(Command cmd,
byte[]... args) |
Response |
Connection.serviceRequest(Command cmd,
byte[]... args)
A blocking call to service the specified request.
|
Modifier and Type | Method and Description |
---|---|
Future<Response> |
FaultedConnection.queueRequest(Command cmd,
byte[]... args) |
Future<Response> |
Connection.queueRequest(Command cmd,
byte[]... args)
A non-blocking call to service the specified request at some point in the future.
|
Modifier and Type | Method and Description |
---|---|
void |
RequestListener.onResponse(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 |
---|---|
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. |
Modifier and Type | Field and Description |
---|---|
protected Future<Response> |
JRedisFutureSupport.FutureResultBase.pendingRequest |
Modifier and Type | Method and Description |
---|---|
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) |
protected Response |
JRedisPipelineService.serviceRequest(Command cmd,
byte[]... args) |
Modifier and Type | Method and Description |
---|---|
protected abstract 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 Future<Response> |
JRedisAsyncClient.queueRequest(Command cmd,
byte[]... args)
Requests to server are queued at this point.
|
protected Future<Response> |
JRedisPipeline.queueRequest(Command cmd,
byte[]... args)
Requests to server are queued at this point.
|
protected Future<Response> |
JRedisChunkedPipeline.queueRequest(Command cmd,
byte[]... args) |
Constructor and Description |
---|
FutureBit(Future<Response> pendingRequest) |
FutureBoolean(Future<Response> pendingRequest) |
FutureByteArray(Future<Response> pendingRequest) |
FutureByteArrayList(Future<Response> pendingRequest) |
FutureDataDictionary(Future<Response> pendingRequest) |
FutureDouble(Future<Response> pendingRequest) |
FutureInfo(Future<Response> pendingRequest) |
FutureKeyList(Future<Response> pendingRequest) |
FutureLong(Future<Response> pendingRequest) |
FutureObjectInfo(Future<Response> pendingRequest) |
FutureRedisType(Future<Response> pendingRequest) |
FutureResultBase(Future<Response> pendingRequest) |
FutureSortStoreResp(Future<Response> pendingRequest) |
FutureStatus(Future<Response> pendingRequest) |
FutureString(Future<Response> pendingRequest) |
FutureZSetList(Future<Response> pendingRequest) |
Modifier and Type | Method and Description |
---|---|
Response |
PendingRequest.get() |
Response |
PendingRequest.get(long timeout,
TimeUnit unit) |
Response |
SyncPipelineConnection.serviceRequest(Command cmd,
byte[]... args) |
Response |
SyncConnection.serviceRequest(Command cmd,
byte[]... args) |
Response |
ConnectionBase.serviceRequest(Command cmd,
byte[]... args) |
Modifier and Type | Method and Description |
---|---|
Future<Response> |
AsyncConnection.queueRequest(Command cmd,
byte[]... args) |
Future<Response> |
PipelineConnectionBase.queueRequest(Command cmd,
byte[]... args)
This is a pseudo asynchronous method.
|
Future<Response> |
ChunkedPipelineConnection.queueRequest(Command cmd,
byte[]... args)
This is a true asynchronous method.
|
Future<Response> |
ConnectionBase.queueRequest(Command cmd,
byte[]... args) |
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 Response |
SyncProtocol.createBooleanResponse(Command cmd) |
protected Response |
ConcurrentSyncProtocol.createBooleanResponse(Command cmd) |
protected abstract Response |
ProtocolBase.createBooleanResponse(Command cmd) |
protected Response |
SyncProtocol.createBulkResponse(Command cmd) |
protected Response |
ConcurrentSyncProtocol.createBulkResponse(Command cmd) |
protected abstract Response |
ProtocolBase.createBulkResponse(Command cmd) |
protected Response |
SyncProtocol.createMultiBulkResponse(Command cmd) |
protected Response |
ConcurrentSyncProtocol.createMultiBulkResponse(Command cmd) |
protected abstract Response |
ProtocolBase.createMultiBulkResponse(Command cmd) |
protected Response |
SyncProtocol.createNumberResponse(Command cmd) |
protected Response |
ConcurrentSyncProtocol.createNumberResponse(Command cmd) |
protected abstract Response |
ProtocolBase.createNumberResponse(Command cmd) |
Response |
ProtocolBase.createResponse(Command cmd) |
protected Response |
SyncProtocol.createStatusResponse(Command cmd) |
protected Response |
ConcurrentSyncProtocol.createStatusResponse(Command cmd) |
protected abstract Response |
ProtocolBase.createStatusResponse(Command cmd) |
protected Response |
SyncProtocol.createStringResponse(Command cmd) |
protected Response |
ConcurrentSyncProtocol.createStringResponse(Command cmd) |
protected abstract Response |
ProtocolBase.createStringResponse(Command cmd) |
Copyright © 2009–2015. All rights reserved.