Package | Description |
---|---|
com.lambdaworks.redis |
The redis client package containing
RedisClient for regular and sentinel operations. |
com.lambdaworks.redis.api |
Standalone Redis connection API.
|
com.lambdaworks.redis.cluster |
Client for Redis Cluster, see
RedisClusterClient . |
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.
|
com.lambdaworks.redis.sentinel |
Redis Sentinel connection classes.
|
Modifier and Type | Method and Description |
---|---|
<T,C extends RedisCommand<K,V,T>> |
StatefulRedisConnectionImpl.dispatch(C command) |
protected <T,C extends RedisCommand<K,V,T>> |
RedisChannelHandler.dispatch(C cmd) |
<T,C extends RedisCommand<K,V,T>> |
RedisChannelWriter.write(C command)
Write a command on the channel.
|
Modifier and Type | Method and Description |
---|---|
RedisCommand<?,?,?> |
ConnectionEvents.PingBeforeActivate.getCommand() |
Modifier and Type | Method and Description |
---|---|
<T> AsyncCommand<K,V,T> |
AbstractRedisAsyncCommands.dispatch(RedisCommand<K,V,T> cmd) |
Modifier and Type | Method and Description |
---|---|
<T,R> R |
AbstractRedisReactiveCommands.createDissolvingObservable(Supplier<RedisCommand<K,V,T>> commandSupplier) |
<T> Observable<T> |
AbstractRedisReactiveCommands.createObservable(Supplier<RedisCommand<K,V,T>> commandSupplier) |
Constructor and Description |
---|
PingBeforeActivate(RedisCommand<?,?,?> command) |
ReactiveCommandDispatcher(RedisCommand<K,V,T> staticCommand,
StatefulConnection<K,V> connection,
boolean dissolve) |
Constructor and Description |
---|
ReactiveCommandDispatcher(Supplier<RedisCommand<K,V,T>> commandSupplier,
StatefulConnection<K,V> connection,
boolean dissolve) |
Modifier and Type | Method and Description |
---|---|
<T,C extends RedisCommand<K,V,T>> |
StatefulConnection.dispatch(C command)
Dispatch a command.
|
Modifier and Type | Method and Description |
---|---|
<T,C extends RedisCommand<K,V,T>> |
StatefulRedisClusterConnectionImpl.dispatch(C command) |
Modifier and Type | Method and Description |
---|---|
void |
MultiOutput.add(RedisCommand<K,V,?> cmd) |
Modifier and Type | Class and Description |
---|---|
class |
AsyncCommand<K,V,T>
An asynchronous redis command and its result.
|
class |
Command<K,V,T>
|
class |
CommandWrapper<K,V,T>
Wrapper for a command.
|
class |
TransactionalCommand<K,V,T>
A wrapper for commands within a MULTI transaction.
|
Modifier and Type | Field and Description |
---|---|
protected RedisCommand<K,V,T> |
CommandWrapper.command |
Modifier and Type | Field and Description |
---|---|
protected Queue<RedisCommand<K,V,?>> |
CommandHandler.commandBuffer |
protected Queue<RedisCommand<K,V,?>> |
CommandHandler.disconnectedBuffer |
protected Deque<RedisCommand<K,V,?>> |
CommandHandler.stack |
Modifier and Type | Method and Description |
---|---|
<T,C extends RedisCommand<K,V,T>> |
CommandHandler.write(C command) |
protected <C extends RedisCommand<K,V,T>,T> |
CommandHandler.writeToDisconnectedBuffer(C command) |
Modifier and Type | Method and Description |
---|---|
RedisCommand<K,V,T> |
DecoratedCommand.getDelegate()
The underlying command.
|
RedisCommand<K,V,T> |
CommandWrapper.getDelegate() |
RedisCommand<K,V,T> |
AsyncCommand.getDelegate() |
static <K,V,T> RedisCommand<K,V,T> |
CommandWrapper.unwrap(RedisCommand<K,V,T> wrapped)
Unwrap a wrapped command.
|
Modifier and Type | Method and Description |
---|---|
protected List<RedisCommand<K,V,?>> |
CommandHandler.prepareReset() |
Modifier and Type | Method and Description |
---|---|
protected void |
CommandHandler.afterComplete(ChannelHandlerContext ctx,
RedisCommand<K,V,?> command)
Hook method called after command completion.
|
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)
Safely sets
CommandOutput.multi(int) . |
protected void |
RedisStateMachine.safeSet(CommandOutput<K,V,?> output,
ByteBuffer bytes,
RedisCommand<K,V,?> command)
Safely sets
CommandOutput.set(ByteBuffer) . |
protected void |
RedisStateMachine.safeSet(CommandOutput<K,V,?> output,
long integer,
RedisCommand<K,V,?> command)
Safely sets
CommandOutput.set(long) . |
protected void |
RedisStateMachine.safeSetError(CommandOutput<K,V,?> output,
ByteBuffer bytes,
RedisCommand<K,V,?> command)
Safely sets
CommandOutput.setError(ByteBuffer) . |
static <K,V,T> RedisCommand<K,V,T> |
CommandWrapper.unwrap(RedisCommand<K,V,T> wrapped)
Unwrap a wrapped command.
|
Constructor and Description |
---|
AsyncCommand(RedisCommand<K,V,T> command) |
AsyncCommand(RedisCommand<K,V,T> command,
int count) |
CommandWrapper(RedisCommand<K,V,T> command) |
TransactionalCommand(RedisCommand<K,V,T> command) |
Modifier and Type | Method and Description |
---|---|
protected void |
PubSubCommandHandler.afterComplete(ChannelHandlerContext ctx,
RedisCommand<K,V,?> command) |
Modifier and Type | Method and Description |
---|---|
<T,C extends RedisCommand<K,V,T>> |
StatefulRedisSentinelConnectionImpl.dispatch(C cmd) |
Modifier and Type | Method and Description |
---|---|
<T> AsyncCommand<K,V,T> |
RedisSentinelAsyncCommandsImpl.dispatch(RedisCommand<K,V,T> cmd) |
Modifier and Type | Method and Description |
---|---|
<T,R> R |
RedisSentinelReactiveCommandsImpl.createDissolvingObservable(Supplier<RedisCommand<K,V,T>> commandSupplier) |
<T> Observable<T> |
RedisSentinelReactiveCommandsImpl.createObservable(Supplier<RedisCommand<K,V,T>> commandSupplier) |
Copyright © 2017 lettuce.io. All rights reserved.