Package | Description |
---|---|
org.jredis |
This package contains the constructs that define the Java API semantics of the
JRedis clients.
|
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 | Class and Description |
---|---|
class |
NotSupportedException
Providers can throw this exception in response for requests for optional
aspects of Redis Specification.
|
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.
|
void |
Message.read(InputStream in)
Reads itself from the provided
InputStream |
Response |
FaultedConnection.serviceRequest(Command cmd,
byte[]... args) |
Response |
Connection.serviceRequest(Command cmd,
byte[]... args)
A blocking call to service the specified request.
|
void |
Message.write(OutputStream out)
Writes itself to the provided
OutputStream . |
Modifier and Type | Class and Description |
---|---|
class |
CommandNotImplemented
[TODO: document me!]
|
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. |
List<byte[]> |
MultiBulkResponse.getMultiBulkData() |
Modifier and Type | Method and Description |
---|---|
<K> boolean |
JRedisSupport.getbit(K key,
int offset) |
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> |
JRedisChunkedPipeline.queueRequest(Command cmd,
byte[]... args) |
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 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) |
<K> boolean |
JRedisSupport.setbit(K key,
int offset,
boolean value) |
Modifier and Type | Method and Description |
---|---|
protected void |
ConnectionBase.initializeAsyncConnection() |
protected void |
ConnectionBase.initializeOnConnect() |
protected void |
ConnectionBase.initializeSyncConnection() |
Future<Response> |
ConnectionBase.queueRequest(Command cmd,
byte[]... args) |
Future<Response> |
AsyncConnection.queueRequest(Command cmd,
byte[]... args) |
Future<Response> |
ChunkedPipelineConnection.queueRequest(Command cmd,
byte[]... args)
This is a true asynchronous method.
|
Future<Response> |
PipelineConnectionBase.queueRequest(Command cmd,
byte[]... args)
This is a pseudo asynchronous method.
|
Response |
ConnectionBase.serviceRequest(Command cmd,
byte[]... args) |
Response |
SyncPipelineConnection.serviceRequest(Command cmd,
byte[]... args) |
Constructor and Description |
---|
AsyncConnection(ConnectionSpec connectionSpec) |
SyncConnection(ConnectionSpec connectionSpec)
This constructor will pass the connection spec to the super class constructor and
create and install the
Protocol handler delegate instance for this SyncConnection . |
Modifier and Type | Method and Description |
---|---|
Request |
ProtocolBase.createRequest(Command cmd,
byte[]... args) |
byte[] |
ProtocolBase.createRequestBuffer(Command cmd,
byte[]... args) |
Response |
ProtocolBase.createResponse(Command cmd) |
List<byte[]> |
SyncProtocol.SyncMultiBulkResponse.getMultiBulkData() |
void |
VirtualResponse.read(InputStream in) |
void |
ProtocolBase.StreamBufferRequest.read(InputStream in) |
void |
SyncProtocol.SyncLineResponse.read(InputStream in)
Delegates the io handling to the base class and parses the value reponse
based on the data flavor.
|
void |
SyncProtocol.SyncBulkResponse.read(InputStream in) |
void |
SyncProtocol.SyncMultiBulkResponse.read(InputStream in) |
void |
VirtualResponse.write(OutputStream out) |
void |
ProtocolBase.StreamBufferRequest.write(OutputStream out)
Writes the entire content of the message to the output stream and flushes it.
|
void |
ResponseSupport.write(OutputStream out) |
Copyright © 2009–2016. All rights reserved.