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 clusters
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 cmd) |
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 |
---|---|
<T> AsyncCommand<K,V,T> |
AbstractRedisAsyncCommands.dispatch(RedisCommand<K,V,T> cmd) |
Modifier and Type | Method and Description |
---|---|
<T,R> R |
AbstractRedisReactiveCommands.createDissolvingObservable(java.util.function.Supplier<RedisCommand<K,V,T>> commandSupplier) |
<T> Observable<T> |
AbstractRedisReactiveCommands.createObservable(java.util.function.Supplier<RedisCommand<K,V,T>> commandSupplier) |
Constructor and Description |
---|
ReactiveCommandDispatcher(RedisCommand<K,V,T> staticCommand,
StatefulConnection<K,V> connection,
boolean dissolve) |
Constructor and Description |
---|
ReactiveCommandDispatcher(java.util.function.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 cmd) |
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>
A redis command and its result.
|
class |
CommandWrapper<K,V,T> |
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 |
protected RedisCommand<K,V,T> |
AsyncCommand.command |
Modifier and Type | Field and Description |
---|---|
protected Queue<RedisCommand<K,V,?>> |
CommandHandler.commandBuffer |
protected Queue<RedisCommand<K,V,?>> |
CommandHandler.queue |
Modifier and Type | Method and Description |
---|---|
<T,C extends RedisCommand<K,V,T>> |
CommandHandler.write(C 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.safeSet(Runnable runnable,
RedisCommand<K,V,?> command) |
protected void |
RedisStateMachine.safeSetError(CommandOutput<K,V,?> output,
ByteBuffer bytes,
RedisCommand<K,V,?> command) |
Constructor and Description |
---|
AsyncCommand(RedisCommand<K,V,T> command) |
CommandWrapper(RedisCommand<K,V,T> command) |
TransactionalCommand(RedisCommand<K,V,T> command) |
Constructor and Description |
---|
CommandHandler(ClientOptions clientOptions,
Queue<RedisCommand<K,V,?>> queue)
Initialize a new instance that handles commands from the supplied queue.
|
Constructor and Description |
---|
PubSubCommandHandler(ClientOptions clientOptions,
Queue<RedisCommand<K,V,?>> queue,
RedisCodec<K,V> codec)
Initialize a new instance.
|
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(java.util.function.Supplier<RedisCommand<K,V,T>> commandSupplier) |
<T> Observable<T> |
RedisSentinelReactiveCommandsImpl.createObservable(java.util.function.Supplier<RedisCommand<K,V,T>> commandSupplier) |
Copyright © 2015. All rights reserved.