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.resource |
Optional package.
|
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.bench | |
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.
|
class |
ProviderException
Used by JRedis implementation providers to indicate an exception related to the
implementation of the specification.
|
Modifier and Type | Method and Description |
---|---|
protected abstract JRedis |
JRedisBenchmark.newConnection(String host,
int port,
int db,
String password)
Define this method to test a specific JRedis implementation.
|
Modifier and Type | Class and Description |
---|---|
class |
ConnectionException
[TODO: document me!]
|
class |
ConnectionFault
[TODO: document me!]
|
class |
ConnectionReset
This exception is thrown by a
Connection to indicate that the connection to redis was
reset (typically due to timeout on Redis side). |
class |
NotConnectedException
This connection will should be thrown if users issue any calls on
the
JRedis interface after a call to either JRedis.quit()
or JRedis#shutdown()
[TODO: document me!] |
Modifier and Type | Method and Description |
---|---|
Connection |
Connection.Factory.newConnection(ConnectionSpec spec)
Creates a connection to a redis server using the specified connection attributes.
|
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 |
---|---|
Response |
Protocol.createResponse(Command cmd)
Creates a response object for the
Command specified. |
List<byte[]> |
MultiBulkResponse.getMultiBulkData() |
Modifier and Type | Class and Description |
---|---|
class |
ResourceException
The overall superclass for resource related exceptions, itself an
extension of ClientRuntimeException.
|
Modifier and Type | Method and Description |
---|---|
<K> boolean |
JRedisSupport.getbit(K key,
int offset) |
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) |
<K> boolean |
JRedisSupport.setbit(K key,
int offset,
boolean value) |
Constructor and Description |
---|
JRedisClient()
and using localhost:6379 as its network addressing parameters.
|
JRedisClient(String password)
Connects to the localhost:6379 redis server using the password.
|
JRedisClient(String host,
int port) |
JRedisClient(String host,
int port,
String password,
int database)
New JRedisClient for the default protocol version
RedisVersion |
Modifier and Type | Method and Description |
---|---|
protected JRedis |
JRedisClientBenchmark.newConnection(String host,
int port,
int db,
String password) |
Modifier and Type | Class and Description |
---|---|
class |
UnexpectedEOFException
[TODO: document me!]
|
Modifier and Type | Method and Description |
---|---|
protected void |
ConnectionBase.connect() |
protected void |
ConnectionBase.initializeAsyncConnection() |
protected void |
ConnectionBase.initializeOnConnect() |
protected void |
ConnectionBase.initializeSyncConnection() |
Connection |
DefaultConnectionFactory.newConnection(ConnectionSpec spec) |
static ConnectionSpec |
DefaultConnectionSpec.newSpec() |
static ConnectionSpec |
DefaultConnectionSpec.newSpec(InetAddress address,
int port,
int database,
byte[] credentials)
Returns an instance of the
ConnectionSpec used by this Connection
as default spec, for the provided params. |
static ConnectionSpec |
DefaultConnectionSpec.newSpec(String host,
int port,
int database,
byte[] credentials)
Returns an instance of the
ConnectionSpec used by this Connection
as default spec, for the provided params. |
protected void |
ConnectionBase.onConnectionFault(String fault,
boolean raiseEx)
Will throw a
ClientRuntimeException if raiseEx is true |
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.
|
Future<Response> |
ConnectionBase.queueRequest(Command cmd,
byte[]... args) |
Response |
SyncPipelineConnection.serviceRequest(Command cmd,
byte[]... args) |
Response |
ConnectionBase.serviceRequest(Command cmd,
byte[]... args) |
Constructor and Description |
---|
AsyncConnection(ConnectionSpec connectionSpec) |
AsyncPipelineConnection(ConnectionSpec spec) |
ChunkedPipelineConnection(ConnectionSpec spec) |
ConnectionBase(ConnectionSpec spec)
Will create and initialize a socket per the connection spec.
|
DefaultConnectionSpec()
Instantiates a default connection spec for the given host and port.
|
DefaultConnectionSpec(InetAddress address,
int port)
Deprecated.
|
DefaultConnectionSpec(InetAddress address,
int port,
int database,
byte[] credentials)
Deprecated.
|
PipelineConnectionBase(ConnectionSpec spec) |
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 . |
SyncPipelineConnection(ConnectionSpec spec) |
Modifier and Type | Method and Description |
---|---|
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 |
ResponseSupport.write(OutputStream out) |
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.
|
Copyright © 2009–2019. All rights reserved.