Package | Description |
---|---|
org.aredis.cache |
Contains the core aredis related classes.
|
org.aredis.net |
Contains classes used by aredis for NIO based asynchronous socket communication.
|
Modifier and Type | Class and Description |
---|---|
class |
RedisResponseReader
This is a low level redis response parser that is used by aredis.
|
Modifier and Type | Method and Description |
---|---|
RedisRawResponse |
RedisResponseReader.readResponse(AsyncHandler<RedisRawResponse> presponseHandler)
Reads the response from the Redis Server.
|
void |
AbstractAsyncRedisClient.submitCommand(AsyncHandler<RedisCommandInfo> completionHandler,
DataHandler dataHandler,
Object metaData,
RedisCommand command,
Object... params) |
void |
AsyncRedisClient.submitCommand(AsyncHandler<RedisCommandInfo> completionHandler,
DataHandler dataHandler,
Object metaData,
RedisCommand command,
Object... params)
Submit a Redis Command.
|
void |
AbstractAsyncRedisClient.submitCommand(AsyncHandler<RedisCommandInfo> completionHandler,
DataHandler dataHandler,
RedisCommand command,
Object... params) |
void |
AsyncRedisClient.submitCommand(AsyncHandler<RedisCommandInfo> completionHandler,
DataHandler dataHandler,
RedisCommand command,
Object... params)
Submit a Redis Command.
|
void |
AbstractAsyncRedisClient.submitCommand(AsyncHandler<RedisCommandInfo> completionHandler,
Object metaData,
RedisCommand command,
Object... params) |
void |
AsyncRedisClient.submitCommand(AsyncHandler<RedisCommandInfo> completionHandler,
Object metaData,
RedisCommand command,
Object... params)
Submit a Redis Command.
|
void |
AbstractAsyncRedisClient.submitCommand(AsyncHandler<RedisCommandInfo> completionHandler,
RedisCommand command,
Object... params) |
void |
AsyncRedisClient.submitCommand(AsyncHandler<RedisCommandInfo> completionHandler,
RedisCommand command,
Object... params)
Submit a Redis Command.
|
void |
AbstractAsyncRedisClient.submitCommand(RedisCommandInfo command,
AsyncHandler<RedisCommandInfo> completionHandler) |
void |
AsyncRedisClient.submitCommand(RedisCommandInfo command,
AsyncHandler<RedisCommandInfo> completionHandler)
Submit a Redis Command.
|
abstract Future<RedisCommandInfo> |
AbstractAsyncRedisClient.submitCommand(RedisCommandInfo command,
AsyncHandler<RedisCommandInfo> completionHandler,
boolean requireFutureResult,
boolean isSyncCallback) |
Future<RedisCommandInfo> |
AsyncRedisClient.submitCommand(RedisCommandInfo command,
AsyncHandler<RedisCommandInfo> completionHandler,
boolean requireFutureResult,
boolean isSyncCallback)
Submit a Redis Command.
|
Future<RedisCommandInfo> |
AsyncRedisConnection.submitCommand(RedisCommandInfo command,
AsyncHandler<RedisCommandInfo> completionHandler,
boolean requireFutureResult,
boolean isSyncCallback) |
Future<RedisCommandInfo> |
ShardedAsyncRedisClient.submitCommand(RedisCommandInfo commandInfo,
AsyncHandler<RedisCommandInfo> completionHandler,
boolean requireFutureResult,
boolean isSyncCallback) |
void |
AbstractAsyncRedisClient.submitCommands(RedisCommandInfo[] commands,
AsyncHandler<RedisCommandInfo[]> completionHandler) |
void |
AsyncRedisClient.submitCommands(RedisCommandInfo[] commands,
AsyncHandler<RedisCommandInfo[]> completionHandler)
Submit multiple Redis Commands.
|
abstract Future<RedisCommandInfo[]> |
AbstractAsyncRedisClient.submitCommands(RedisCommandInfo[] commands,
AsyncHandler<RedisCommandInfo[]> completionHandler,
boolean requireFutureResult,
boolean isSyncCallback) |
Future<RedisCommandInfo[]> |
AsyncRedisClient.submitCommands(RedisCommandInfo[] commands,
AsyncHandler<RedisCommandInfo[]> completionHandler,
boolean requireFutureResult,
boolean isSyncCallback)
Submit multiple Redis Commands.
|
Future<RedisCommandInfo[]> |
AsyncRedisConnection.submitCommands(RedisCommandInfo[] commands,
AsyncHandler<RedisCommandInfo[]> completionHandler,
boolean requireFutureResult,
boolean isSyncCallback) |
Future<RedisCommandInfo[]> |
ShardedAsyncRedisClient.submitCommands(RedisCommandInfo[] commandInfos,
AsyncHandler<RedisCommandInfo[]> completionHandler,
boolean requireFutureResult,
boolean isSyncCallback) |
Modifier and Type | Method and Description |
---|---|
ConnectionStatus |
ConnectionState.checkRetry(AsyncHandler<ConnectionStatus> callBack)
This method is to be called when the getStatus method returns RETRY.
|
void |
AbstractAsyncSocketTransport.connect(AsyncHandler<Boolean> handler) |
void |
AsyncSocketTransport.connect(AsyncHandler<Boolean> handler)
Connects to Socket and calls handler with true on success and false with
Exception on failure.
|
protected abstract void |
AbstractAsyncSocketTransport.connectInternal(AsyncHandler<Boolean> handler)
Connect Method to be implemented by sub-class.
|
void |
AsyncJavaSocketTransport.connectInternal(AsyncHandler<Boolean> handler) |
boolean |
AsyncJavaSocketTransport.flush(AsyncHandler<Integer> handler) |
boolean |
AsyncSocketTransport.flush(AsyncHandler<Integer> handler)
Flushes bytes in buffer to Socket Output.
|
int |
AsyncJavaSocketTransport.read(OutputStream dest,
int maxBytes,
AsyncHandler<Integer> handler) |
int |
AsyncSocketTransport.read(OutputStream dest,
int maxBytes,
AsyncHandler<Integer> handler)
Reads atleast 1 byte and a max of upto maxBytes writing bytes read to specified
Stream.
|
int |
AsyncJavaSocketTransport.write(byte[] b,
int ofs,
int len,
AsyncHandler<Integer> handler) |
int |
AsyncSocketTransport.write(byte[] b,
int ofs,
int len,
AsyncHandler<Integer> handler)
Writes specified bytes to Output Stream.
|
Copyright © 2013- Suresh Mahalingam. All Rights Reserved.