Package | Description |
---|---|
com.lambdaworks.redis |
The redis client package containing
RedisClient for regular and sentinel operations. |
com.lambdaworks.redis.output |
Implementation of different output protocols including the Streaming API.
|
com.lambdaworks.redis.protocol |
Redis protocol layer abstraction.
|
com.lambdaworks.redis.pubsub |
Pub/Sub connection classes.
|
Modifier and Type | Method and Description |
---|---|
protected <T> RedisFuture<T> |
RedisAsyncConnectionImpl.dispatch(CommandType type,
CommandOutput<K,V,T> output) |
protected <T> RedisCommand<K,V,T> |
RedisAsyncConnectionImpl.dispatch(CommandType type,
CommandOutput<K,V,T> output,
CommandArgs<K,V> args) |
<T> RedisFuture<T> |
RedisAsyncConnectionImpl.dispatch(ProtocolKeyword type,
CommandOutput<K,V,T> output) |
<T> T |
BaseRedisConnection.dispatch(ProtocolKeyword type,
CommandOutput<K,V,T> output)
Dispatch a command to the Redis Server.
|
<T> RedisFuture<T> |
BaseRedisAsyncConnection.dispatch(ProtocolKeyword type,
CommandOutput<K,V,T> output)
Dispatch a command to the Redis Server.
|
<T> RedisFuture<T> |
RedisAsyncConnectionImpl.dispatch(ProtocolKeyword type,
CommandOutput<K,V,T> output,
CommandArgs<K,V> args) |
<T> T |
BaseRedisConnection.dispatch(ProtocolKeyword type,
CommandOutput<K,V,T> output,
CommandArgs<K,V> args)
Dispatch a command to the Redis Server.
|
<T> RedisFuture<T> |
BaseRedisAsyncConnection.dispatch(ProtocolKeyword type,
CommandOutput<K,V,T> output,
CommandArgs<K,V> args)
Dispatch a command to the Redis Server.
|
Modifier and Type | Class and Description |
---|---|
class |
ArrayOutput<K,V>
List of objects and lists to support dynamic nested structures (List with mixed content of values and
sublists). |
class |
BooleanListOutput<K,V>
List of boolean output. |
class |
BooleanOutput<K,V>
Boolean output.
|
class |
ByteArrayOutput<K,V>
Byte array output.
|
class |
DateOutput<K,V>
Date output with no milliseconds.
|
class |
DoubleOutput<K,V>
Double output, may be null.
|
class |
GeoCoordinatesListOutput<K,V>
A list output that creates a list with
GeoCoordinates 's. |
class |
GeoWithinListOutput<K,V>
A list output that creates a list with either double/long or
GeoCoordinates 's. |
class |
IntegerOutput<K,V>
64-bit integer output, may be null.
|
class |
KeyListOutput<K,V>
List of keys output. |
class |
KeyOutput<K,V>
Key output.
|
class |
KeyScanOutput<K,V>
KeyScanCursor for scan cursor output. |
class |
KeyScanStreamingOutput<K,V>
Streaming API for multiple Keys.
|
class |
KeyStreamingOutput<K,V>
Streaming-Output of Keys.
|
class |
KeyValueOutput<K,V>
Key-value pair output.
|
class |
KeyValueScanStreamingOutput<K,V>
Streaming-Output of Key Value Pairs.
|
class |
KeyValueStreamingOutput<K,V>
Streaming-Output of Key Value Pairs.
|
class |
ListOfMapsOutput<K,V>
List of maps output. |
class |
MapOutput<K,V>
Map of keys and values output. |
class |
MapScanOutput<K,V>
MapScanCursor for scan cursor output. |
class |
MultiOutput<K,V>
Output of all commands within a MULTI block.
|
class |
NestedMultiOutput<K,V>
List of command outputs, possibly deeply nested. |
class |
ScanOutput<K,V,T extends ScanCursor>
Cursor handling output.
|
class |
ScoredValueListOutput<K,V>
List of values and their associated scores. |
class |
ScoredValueScanOutput<K,V>
ScoredValueScanCursor for scan cursor output. |
class |
ScoredValueScanStreamingOutput<K,V>
Streaming-Output of of values and their associated scores.
|
class |
ScoredValueStreamingOutput<K,V>
Streaming-Output of of values and their associated scores.
|
class |
StatusOutput<K,V>
Status message output.
|
class |
StringListOutput<K,V>
List of string output. |
class |
ValueListOutput<K,V>
List of values output. |
class |
ValueOutput<K,V>
Value output.
|
class |
ValueScanOutput<K,V>
ValueScanCursor for scan cursor output. |
class |
ValueScanStreamingOutput<K,V>
Streaming API for multiple Values.
|
class |
ValueSetOutput<K,V>
Set of value output. |
class |
ValueStreamingOutput<K,V>
Streaming-Output of Values.
|
Modifier and Type | Field and Description |
---|---|
protected CommandOutput<K,V,T> |
Command.output |
Modifier and Type | Method and Description |
---|---|
CommandOutput<K,V,T> |
RedisCommand.getOutput()
The command output.
|
CommandOutput<K,V,T> |
Command.getOutput()
Get the object that holds this command's output.
|
Modifier and Type | Method and Description |
---|---|
boolean |
RedisStateMachine.decode(ByteBuf buffer,
CommandOutput<K,V,?> output)
Decode a command using the input buffer.
|
boolean |
RedisStateMachine.decode(ByteBuf buffer,
RedisCommand<K,V,?> command,
CommandOutput<K,V,?> output)
Attempt to decode a redis response and return a flag indicating whether a complete response was read.
|
protected void |
RedisStateMachine.safeMulti(CommandOutput<K,V,?> output,
int count,
RedisCommand<K,V,?> command) |
protected void |
RedisStateMachine.safeSet(CommandOutput<K,V,?> output,
ByteBuffer bytes,
RedisCommand<K,V,?> command) |
protected void |
RedisStateMachine.safeSet(CommandOutput<K,V,?> output,
long integer,
RedisCommand<K,V,?> command) |
protected void |
RedisStateMachine.safeSetError(CommandOutput<K,V,?> output,
ByteBuffer bytes,
RedisCommand<K,V,?> command) |
void |
Command.setOutput(CommandOutput<K,V,T> output) |
Constructor and Description |
---|
Command(ProtocolKeyword type,
CommandOutput<K,V,T> output,
CommandArgs<K,V> args)
Create a new command with the supplied type and args.
|
Command(ProtocolKeyword type,
CommandOutput<K,V,T> output,
CommandArgs<K,V> args,
boolean multi)
Create a new command with the supplied type and args.
|
Modifier and Type | Class and Description |
---|---|
class |
PubSubOutput<K,V,T>
One element of the redis pub/sub stream.
|
Copyright © 2016. All rights reserved.