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> RedisCommand<K,V,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) |
protected <T> RedisCommand<K,V,T> |
RedisChannelHandler.dispatch(RedisCommand<K,V,T> cmd) |
<T> RedisCommand<K,V,T> |
RedisAsyncConnectionImpl.dispatch(RedisCommand<K,V,T> cmd) |
<T> RedisCommand<K,V,T> |
RedisChannelWriter.write(RedisCommand<K,V,T> command)
Write a command on the channel.
|
Modifier and Type | Method and Description |
---|---|
static <K,V,T> T |
LettuceFutures.await(RedisCommand<K,V,T> cmd,
long timeout,
TimeUnit unit)
Wait until futures are complete or the supplied timeout is reached.
|
protected <T> RedisCommand<K,V,T> |
RedisChannelHandler.dispatch(RedisCommand<K,V,T> cmd) |
<T> RedisCommand<K,V,T> |
RedisAsyncConnectionImpl.dispatch(RedisCommand<K,V,T> cmd) |
<T> RedisCommand<K,V,T> |
RedisChannelWriter.write(RedisCommand<K,V,T> command)
Write a command on the channel.
|
Modifier and Type | Method and Description |
---|---|
void |
MultiOutput.add(RedisCommand<K,V,?> cmd) |
Modifier and Type | Class and Description |
---|---|
class |
Command<K,V,T>
A redis command and its result.
|
Modifier and Type | Field and Description |
---|---|
protected BlockingQueue<RedisCommand<K,V,?>> |
CommandHandler.commandBuffer |
protected BlockingQueue<RedisCommand<K,V,?>> |
CommandHandler.queue |
Modifier and Type | Method and Description |
---|---|
<T> RedisCommand<K,V,T> |
CommandHandler.write(RedisCommand<K,V,T> command) |
Modifier and Type | Method and Description |
---|---|
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.
|
<T> RedisCommand<K,V,T> |
CommandHandler.write(RedisCommand<K,V,T> command) |
Constructor and Description |
---|
CommandHandler(BlockingQueue<RedisCommand<K,V,?>> queue)
Initialize a new instance that handles commands from the supplied queue.
|
Constructor and Description |
---|
PubSubCommandHandler(BlockingQueue<RedisCommand<K,V,?>> queue,
RedisCodec<K,V> codec)
Initialize a new instance.
|
Copyright © 2015. All rights reserved.