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,
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)
Deprecated.
The method name does not reflect what the method is doing, therefore it is deprecated. Use
LettuceFutures.awaitOrCancel(RedisCommand, long, TimeUnit) instead. The semantics did not change and
LettuceFutures.awaitOrCancel(RedisCommand, long, TimeUnit) simply calls this method. |
static <K,V,T> T |
LettuceFutures.awaitOrCancel(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 Deque<RedisCommand<K,V,?>> |
CommandHandler.commandBuffer |
protected Queue<RedisCommand<K,V,?>> |
CommandHandler.queue |
protected Deque<RedisCommand<K,V,?>> |
CommandHandler.transportBuffer |
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.
|
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) |
<T> RedisCommand<K,V,T> |
CommandHandler.write(RedisCommand<K,V,T> command) |
Constructor and Description |
---|
CommandHandler(ClientOptions clientOptions,
ClientResources clientResources,
Queue<RedisCommand<K,V,?>> queue)
Initialize a new instance that handles commands from the supplied queue.
|
Constructor and Description |
---|
PubSubCommandHandler(ClientOptions clientOptions,
ClientResources clientResources,
Queue<RedisCommand<K,V,?>> queue,
RedisCodec<K,V> codec)
Initialize a new instance.
|
Copyright © 2016. All rights reserved.