- c - Variable in class com.lambdaworks.redis.RedisConnection
-
- cancel(boolean) - Method in class com.lambdaworks.redis.protocol.Command
-
Cancel the command and notify any waiting consumers.
- channel() - Method in class com.lambdaworks.redis.pubsub.PubSubOutput
-
- channel - Variable in class com.lambdaworks.redis.RedisAsyncConnection
-
- channelClosed(ChannelHandlerContext, ChannelStateEvent) - Method in class com.lambdaworks.redis.protocol.ConnectionWatchdog
-
- channelClosed(ChannelHandlerContext, ChannelStateEvent) - Method in class com.lambdaworks.redis.RedisAsyncConnection
-
- channelConnected(ChannelHandlerContext, ChannelStateEvent) - Method in class com.lambdaworks.redis.protocol.ConnectionWatchdog
-
- channelConnected(ChannelHandlerContext, ChannelStateEvent) - Method in class com.lambdaworks.redis.pubsub.RedisPubSubConnection
-
- channelConnected(ChannelHandlerContext, ChannelStateEvent) - Method in class com.lambdaworks.redis.RedisAsyncConnection
-
- channelOpen(ChannelHandlerContext, ChannelStateEvent) - Method in class com.lambdaworks.redis.protocol.CommandHandler
-
- Charsets - Class in com.lambdaworks.redis.protocol
-
- Charsets() - Constructor for class com.lambdaworks.redis.protocol.Charsets
-
- clientGetname() - Method in class com.lambdaworks.redis.RedisAsyncConnection
-
- clientGetname() - Method in class com.lambdaworks.redis.RedisConnection
-
- clientKill(String) - Method in class com.lambdaworks.redis.RedisAsyncConnection
-
- clientKill(String) - Method in class com.lambdaworks.redis.RedisConnection
-
- clientList() - Method in class com.lambdaworks.redis.RedisAsyncConnection
-
- clientList() - Method in class com.lambdaworks.redis.RedisConnection
-
- clientSetname(K) - Method in class com.lambdaworks.redis.RedisAsyncConnection
-
- clientSetname(K) - Method in class com.lambdaworks.redis.RedisConnection
-
- close() - Method in class com.lambdaworks.redis.RedisAsyncConnection
-
Close the connection.
- close() - Method in class com.lambdaworks.redis.RedisConnection
-
Close the connection.
- codec - Variable in class com.lambdaworks.redis.protocol.CommandOutput
-
- codec - Variable in class com.lambdaworks.redis.RedisAsyncConnection
-
- com.lambdaworks.codec - package com.lambdaworks.codec
-
- com.lambdaworks.redis - package com.lambdaworks.redis
-
- com.lambdaworks.redis.codec - package com.lambdaworks.redis.codec
-
- com.lambdaworks.redis.output - package com.lambdaworks.redis.output
-
- com.lambdaworks.redis.protocol - package com.lambdaworks.redis.protocol
-
- com.lambdaworks.redis.pubsub - package com.lambdaworks.redis.pubsub
-
- Command<K,V,T> - Class in com.lambdaworks.redis.protocol
-
A redis command and its result.
- Command(CommandType, CommandOutput<K, V, T>, CommandArgs<K, V>, boolean) - Constructor for class com.lambdaworks.redis.protocol.Command
-
Create a new command with the supplied type and args.
- CommandArgs<K,V> - Class in com.lambdaworks.redis.protocol
-
Redis command argument encoder.
- CommandArgs(RedisCodec<K, V>) - Constructor for class com.lambdaworks.redis.protocol.CommandArgs
-
- CommandHandler<K,V> - Class in com.lambdaworks.redis.protocol
-
A netty ChannelHandler
responsible for writing redis commands and
reading responses from the server.
- CommandHandler(BlockingQueue<Command<K, V, ?>>) - Constructor for class com.lambdaworks.redis.protocol.CommandHandler
-
Initialize a new instance that handles commands from the supplied queue.
- CommandKeyword - Enum in com.lambdaworks.redis.protocol
-
Keyword modifiers for redis commands.
- CommandOutput<K,V,T> - Class in com.lambdaworks.redis.protocol
-
Abstract representation of the output of a redis command.
- CommandOutput(RedisCodec<K, V>, T) - Constructor for class com.lambdaworks.redis.protocol.CommandOutput
-
Initialize a new instance that encodes and decodes keys and
values using the supplied codec.
- CommandType - Enum in com.lambdaworks.redis.protocol
-
Redis commands.
- complete(int) - Method in class com.lambdaworks.redis.output.MultiOutput
-
- complete(int) - Method in class com.lambdaworks.redis.output.NestedMultiOutput
-
- complete() - Method in class com.lambdaworks.redis.protocol.Command
-
Mark this command complete and notify all waiting threads.
- complete(int) - Method in class com.lambdaworks.redis.protocol.CommandOutput
-
Mark the command output complete.
- configGet(String) - Method in class com.lambdaworks.redis.RedisAsyncConnection
-
- configGet(String) - Method in class com.lambdaworks.redis.RedisConnection
-
- configResetstat() - Method in class com.lambdaworks.redis.RedisAsyncConnection
-
- configResetstat() - Method in class com.lambdaworks.redis.RedisConnection
-
- configSet(String, String) - Method in class com.lambdaworks.redis.RedisAsyncConnection
-
- configSet(String, String) - Method in class com.lambdaworks.redis.RedisConnection
-
- connect() - Method in class com.lambdaworks.redis.RedisClient
-
Open a new synchronous connection to the redis server that treats
keys and values as UTF-8 strings.
- connect(RedisCodec<K, V>) - Method in class com.lambdaworks.redis.RedisClient
-
Open a new synchronous connection to the redis server.
- connectAsync() - Method in class com.lambdaworks.redis.RedisClient
-
Open a new asynchronous connection to the redis server that treats
keys and values as UTF-8 strings.
- connectAsync(RedisCodec<K, V>) - Method in class com.lambdaworks.redis.RedisClient
-
Open a new asynchronous connection to the redis server.
- ConnectionWatchdog - Class in com.lambdaworks.redis.protocol
-
A netty ChannelHandler
responsible for monitoring the channel and
reconnecting when the connection is lost.
- ConnectionWatchdog(ClientBootstrap, ChannelGroup, Timer) - Constructor for class com.lambdaworks.redis.protocol.ConnectionWatchdog
-
Create a new watchdog that adds to new connections to the supplied ChannelGroup
and establishes a new Channel
when disconnected, while reconnect is true.
- connectPubSub() - Method in class com.lambdaworks.redis.RedisClient
-
Open a new pub/sub connection to the redis server that treats
keys and values as UTF-8 strings.
- connectPubSub(RedisCodec<K, V>) - Method in class com.lambdaworks.redis.RedisClient
-
Open a new pub/sub connection to the redis server.
- count() - Method in class com.lambdaworks.redis.protocol.CommandArgs
-
- count() - Method in class com.lambdaworks.redis.pubsub.PubSubOutput
-
- randomkey() - Method in class com.lambdaworks.redis.RedisAsyncConnection
-
- randomkey() - Method in class com.lambdaworks.redis.RedisConnection
-
- RedisAsyncConnection<K,V> - Class in com.lambdaworks.redis
-
An asynchronous thread-safe connection to a redis server.
- RedisAsyncConnection(BlockingQueue<Command<K, V, ?>>, RedisCodec<K, V>, long, TimeUnit) - Constructor for class com.lambdaworks.redis.RedisAsyncConnection
-
Initialize a new connection.
- RedisClient - Class in com.lambdaworks.redis
-
A scalable thread-safe
Redis client.
- RedisClient(String) - Constructor for class com.lambdaworks.redis.RedisClient
-
Create a new client that connects to the supplied host on the default port.
- RedisClient(String, int) - Constructor for class com.lambdaworks.redis.RedisClient
-
Create a new client that connects to the supplied host and port.
- RedisCodec<K,V> - Class in com.lambdaworks.redis.codec
-
A RedisCodec encodes keys and values sent to redis, and decodes keys
and values in the command output.
- RedisCodec() - Constructor for class com.lambdaworks.redis.codec.RedisCodec
-
- RedisCommandInterruptedException - Exception in com.lambdaworks.redis
-
Exception thrown when the thread executing a redis command is
interrupted.
- RedisCommandInterruptedException(Throwable) - Constructor for exception com.lambdaworks.redis.RedisCommandInterruptedException
-
- RedisConnection<K,V> - Class in com.lambdaworks.redis
-
A synchronous thread-safe connection to a redis server.
- RedisConnection(RedisAsyncConnection<K, V>) - Constructor for class com.lambdaworks.redis.RedisConnection
-
Initialize a new connection.
- RedisException - Exception in com.lambdaworks.redis
-
Exception thrown when redis returns an error message, or when the client
fails for any reason.
- RedisException(String) - Constructor for exception com.lambdaworks.redis.RedisException
-
- RedisException(String, Throwable) - Constructor for exception com.lambdaworks.redis.RedisException
-
- RedisPubSubAdapter<K,V> - Class in com.lambdaworks.redis.pubsub
-
- RedisPubSubAdapter() - Constructor for class com.lambdaworks.redis.pubsub.RedisPubSubAdapter
-
- RedisPubSubConnection<K,V> - Class in com.lambdaworks.redis.pubsub
-
An asynchronous thread-safe pub/sub connection to a redis server.
- RedisPubSubConnection(BlockingQueue<Command<K, V, ?>>, RedisCodec<K, V>, long, TimeUnit) - Constructor for class com.lambdaworks.redis.pubsub.RedisPubSubConnection
-
Initialize a new connection.
- RedisPubSubListener<K,V> - Interface in com.lambdaworks.redis.pubsub
-
Interface for redis pub/sub listeners.
- RedisStateMachine<K,V> - Class in com.lambdaworks.redis.protocol
-
- RedisStateMachine() - Constructor for class com.lambdaworks.redis.protocol.RedisStateMachine
-
Initialize a new instance.
- removeListener(RedisPubSubListener<K, V>) - Method in class com.lambdaworks.redis.pubsub.RedisPubSubConnection
-
Remove an existing listener.
- rename(K, K) - Method in class com.lambdaworks.redis.RedisAsyncConnection
-
- rename(K, K) - Method in class com.lambdaworks.redis.RedisConnection
-
- renamenx(K, K) - Method in class com.lambdaworks.redis.RedisAsyncConnection
-
- renamenx(K, K) - Method in class com.lambdaworks.redis.RedisConnection
-
- restore(K, long, byte[]) - Method in class com.lambdaworks.redis.RedisAsyncConnection
-
- restore(K, long, byte[]) - Method in class com.lambdaworks.redis.RedisConnection
-
- rpop(K) - Method in class com.lambdaworks.redis.RedisAsyncConnection
-
- rpop(K) - Method in class com.lambdaworks.redis.RedisConnection
-
- rpoplpush(K, K) - Method in class com.lambdaworks.redis.RedisAsyncConnection
-
- rpoplpush(K, K) - Method in class com.lambdaworks.redis.RedisConnection
-
- rpush(K, V...) - Method in class com.lambdaworks.redis.RedisAsyncConnection
-
- rpush(K, V...) - Method in class com.lambdaworks.redis.RedisConnection
-
- rpushx(K, V) - Method in class com.lambdaworks.redis.RedisAsyncConnection
-
- rpushx(K, V) - Method in class com.lambdaworks.redis.RedisConnection
-
- rsm - Variable in class com.lambdaworks.redis.protocol.CommandHandler
-
- run(Timeout) - Method in class com.lambdaworks.redis.protocol.ConnectionWatchdog
-
Reconnect to the remote address that the closed channel was connected to.