Package | Description |
---|---|
org.jredis |
This package contains the constructs that define the Java API semantics of the
JRedis clients.
|
org.jredis.bench | |
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 |
---|---|
Command |
RedisException.getCommand() |
Constructor and Description |
---|
RedisException(Command command,
String message) |
Modifier and Type | Method and Description |
---|---|
static void |
JRedisBenchmark.Benchmarker.runBenchmark(Command cmd,
int reqCnt,
int threadCnt,
JRedisBenchmark.BenchmarkWorker[] workers) |
Modifier and Type | Method and Description |
---|---|
Future<Response> |
Connection.queueRequest(Command cmd,
byte[]... args)
A non-blocking call to service the specified request at some point in the future.
|
Future<Response> |
FaultedConnection.queueRequest(Command cmd,
byte[]... args) |
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 |
---|---|
static Command |
Command.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static Command[] |
Command.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
Request |
Protocol.createRequest(Command cmd,
byte[]... args) |
byte[] |
Protocol.createRequestBuffer(Command cmd,
byte[]... args)
EXPERIMENTAL
|
Response |
Protocol.createResponse(Command cmd)
Creates a response object for the
Command specified. |
Constructor and Description |
---|
CommandNotImplemented(Command command) |
Modifier and Type | Method and Description |
---|---|
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) |
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 Response |
JRedisClient.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 |
JRedisPipelineService.serviceRequest(Command cmd,
byte[]... args) |
Modifier and Type | Method and Description |
---|---|
Future<Response> |
AsyncConnection.queueRequest(Command cmd,
byte[]... args) |
Future<Response> |
ConnectionBase.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.
|
Response |
ConnectionBase.serviceRequest(Command cmd,
byte[]... args) |
Response |
SyncConnection.serviceRequest(Command cmd,
byte[]... args) |
Response |
SyncPipelineConnection.serviceRequest(Command cmd,
byte[]... args) |
Constructor and Description |
---|
PendingRequest(Command cmd) |
PendingRequest(Command cmd,
byte[]... args) |
Modifier and Type | Field and Description |
---|---|
protected Command |
ResponseSupport.cmd |
Modifier and Type | Method and Description |
---|---|
protected abstract Response |
ProtocolBase.createBooleanResponse(Command cmd) |
protected Response |
ConcurrentSyncProtocol.createBooleanResponse(Command cmd) |
protected Response |
SyncProtocol.createBooleanResponse(Command cmd) |
protected abstract Response |
ProtocolBase.createBulkResponse(Command cmd) |
protected Response |
ConcurrentSyncProtocol.createBulkResponse(Command cmd) |
protected Response |
SyncProtocol.createBulkResponse(Command cmd) |
protected abstract Response |
ProtocolBase.createMultiBulkResponse(Command cmd) |
protected Response |
ConcurrentSyncProtocol.createMultiBulkResponse(Command cmd) |
protected Response |
SyncProtocol.createMultiBulkResponse(Command cmd) |
protected abstract Response |
ProtocolBase.createNumberResponse(Command cmd) |
protected Response |
ConcurrentSyncProtocol.createNumberResponse(Command cmd) |
protected Response |
SyncProtocol.createNumberResponse(Command cmd) |
Request |
ProtocolBase.createRequest(Command cmd,
byte[]... args) |
byte[] |
ProtocolBase.createRequestBuffer(Command cmd,
byte[]... args) |
protected abstract ByteArrayOutputStream |
ProtocolBase.createRequestBufffer(Command cmd) |
protected ByteArrayOutputStream |
SyncProtocol.createRequestBufffer(Command cmd) |
Response |
ProtocolBase.createResponse(Command cmd) |
protected abstract Response |
ProtocolBase.createStatusResponse(Command cmd) |
protected Response |
ConcurrentSyncProtocol.createStatusResponse(Command cmd) |
protected Response |
SyncProtocol.createStatusResponse(Command cmd) |
protected abstract Response |
ProtocolBase.createStringResponse(Command cmd) |
protected Response |
ConcurrentSyncProtocol.createStringResponse(Command cmd) |
protected Response |
SyncProtocol.createStringResponse(Command cmd) |
protected void |
SyncProtocol.SyncLineResponse.reset(Command cmd) |
protected void |
SyncProtocol.SyncBulkResponse.reset(Command cmd) |
protected void |
SyncProtocol.SyncMultiBulkResponse.reset(Command cmd) |
protected void |
SyncProtocol.SyncResponseBase.reset(Command cmd,
Response.Type type) |
protected void |
SyncProtocol.SyncLineResponse.reset(Command cmd,
SyncProtocol.ValueType flavor) |
Constructor and Description |
---|
ResponseSupport(Command cmd,
Response.Type type) |
SyncBulkResponse(byte[] buff,
Command cmd) |
SyncLineResponse(byte[] buff,
Command cmd,
SyncProtocol.ValueType flavor) |
SyncMultiBulkResponse(byte[] buff,
Command cmd) |
SyncMultiLineResponseBase(byte[] buffer,
Command cmd,
Response.Type type) |
SyncResponseBase(byte[] buffer,
Command cmd,
Response.Type type) |
Copyright © 2009–2016. All rights reserved.