| Package | Description |
|---|---|
| redis | |
| redis.client | |
| redis.reply |
| Modifier and Type | Method and Description |
|---|---|
static Reply |
RedisProtocol.receive(java.io.InputStream is)
Read a Reply from an input stream.
|
Reply |
RedisProtocol.receiveAsync()
Wait for a reply on the input stream.
|
| Modifier and Type | Field and Description |
|---|---|
private java.util.Queue<com.google.common.util.concurrent.SettableFuture<Reply>> |
RedisClientBase.txReplies |
| Modifier and Type | Method and Description |
|---|---|
Reply |
RedisClient.brpoplpush(java.lang.Object source0,
java.lang.Object destination1,
java.lang.Object timeout2)
Pop a value from a list, push it to another list and return it; or block until one is available
List
|
Reply |
RedisClient.client_getname()
Get the current connection name
Server
|
Reply |
RedisClient.client_kill(java.lang.Object ip_port0)
Kill the connection of a client
Server
|
Reply |
RedisClient.client_list()
Get the list of client connections
Server
|
Reply |
RedisClient.client_setname(java.lang.Object connection_name0)
Set the current connection name
Server
|
Reply |
RedisClient.config_get(java.lang.Object parameter0)
Get the value of a configuration parameter
Server
|
Reply |
RedisClient.config_resetstat()
Reset the stats returned by INFO
Server
|
Reply |
RedisClient.config_set(java.lang.Object parameter0,
java.lang.Object value1)
Set a configuration parameter to the given value
Server
|
Reply |
RedisClient.debug_object(java.lang.Object key0)
Get debugging information about a key
Server
|
Reply |
RedisClient.debug_segfault()
Make the server crash
Server
|
Reply |
RedisClient.eval_(java.lang.Object... arguments) |
Reply |
RedisClient.eval(java.lang.Object script0,
java.lang.Object numkeys1,
java.lang.Object... key2)
Execute a Lua script server side
Scripting
|
Reply |
RedisClient.evalsha_(java.lang.Object... arguments) |
Reply |
RedisClient.evalsha(java.lang.Object sha10,
java.lang.Object numkeys1,
java.lang.Object... key2)
Execute a Lua script server side
Scripting
|
Reply |
RedisClientBase.execute(java.lang.String name,
Command command) |
Reply |
RedisClient.monitor()
Listen for all requests received by the server in real time
Server
|
Reply |
RedisClient.object_(java.lang.Object... arguments) |
Reply |
RedisClient.object(java.lang.Object subcommand0,
java.lang.Object... arguments1)
Inspect the internals of Redis objects
Generic
|
Reply |
RedisClient.psetex(java.lang.Object key0,
java.lang.Object milliseconds1,
java.lang.Object value2)
Set the value and expiration in milliseconds of a key
String
|
Reply |
RedisClient.script_exists_(java.lang.Object... arguments) |
Reply |
RedisClient.script_exists(java.lang.Object... script0)
Check existence of scripts in the script cache.
|
Reply |
RedisClient.script_flush()
Remove all the scripts from the script cache.
|
Reply |
RedisClient.script_kill()
Kill the script currently in execution.
|
Reply |
RedisClient.script_load(java.lang.Object script0)
Load the specified Lua script into the script cache.
|
Reply |
RedisClient.slowlog_(java.lang.Object... arguments) |
Reply |
RedisClient.slowlog(java.lang.Object subcommand0,
java.lang.Object argument1)
Manages the Redis slow queries log
Server
|
Reply |
RedisClient.sort_(java.lang.Object... arguments) |
Reply |
RedisClient.sort(java.lang.Object key0,
java.lang.Object... pattern1)
Sort the elements in a list, set or sorted set
Generic
|
Reply |
RedisClient.srandmember_(java.lang.Object... arguments) |
Reply |
RedisClient.srandmember(java.lang.Object key0,
java.lang.Object count1)
Get one or multiple random members from a set
Set
|
Reply |
RedisClient.sync()
Internal command used for replication
Server
|
Reply |
RedisClient.zrank(java.lang.Object key0,
java.lang.Object member1)
Determine the index of a member in a sorted set
Sorted_set
|
Reply |
RedisClient.zrevrank(java.lang.Object key0,
java.lang.Object member1)
Determine the index of a member in a sorted set, with scores ordered from high to low
Sorted_set
|
| Modifier and Type | Method and Description |
|---|---|
com.google.common.util.concurrent.ListenableFuture<Reply> |
RedisClient.Pipeline.brpoplpush(java.lang.Object source0,
java.lang.Object destination1,
java.lang.Object timeout2)
Pop a value from a list, push it to another list and return it; or block until one is available
List
|
com.google.common.util.concurrent.ListenableFuture<Reply> |
RedisClient.Pipeline.client_getname()
Get the current connection name
Server
|
com.google.common.util.concurrent.ListenableFuture<Reply> |
RedisClient.Pipeline.client_kill(java.lang.Object ip_port0)
Kill the connection of a client
Server
|
com.google.common.util.concurrent.ListenableFuture<Reply> |
RedisClient.Pipeline.client_list()
Get the list of client connections
Server
|
com.google.common.util.concurrent.ListenableFuture<Reply> |
RedisClient.Pipeline.client_setname(java.lang.Object connection_name0)
Set the current connection name
Server
|
com.google.common.util.concurrent.ListenableFuture<Reply> |
RedisClient.Pipeline.config_get(java.lang.Object parameter0)
Get the value of a configuration parameter
Server
|
com.google.common.util.concurrent.ListenableFuture<Reply> |
RedisClient.Pipeline.config_resetstat()
Reset the stats returned by INFO
Server
|
com.google.common.util.concurrent.ListenableFuture<Reply> |
RedisClient.Pipeline.config_set(java.lang.Object parameter0,
java.lang.Object value1)
Set a configuration parameter to the given value
Server
|
com.google.common.util.concurrent.ListenableFuture<Reply> |
RedisClient.Pipeline.debug_object(java.lang.Object key0)
Get debugging information about a key
Server
|
com.google.common.util.concurrent.ListenableFuture<Reply> |
RedisClient.Pipeline.debug_segfault()
Make the server crash
Server
|
com.google.common.util.concurrent.ListenableFuture<Reply> |
RedisClient.Pipeline.eval_(java.lang.Object... arguments) |
com.google.common.util.concurrent.ListenableFuture<Reply> |
RedisClient.Pipeline.eval(java.lang.Object script0,
java.lang.Object numkeys1,
java.lang.Object... key2)
Execute a Lua script server side
Scripting
|
com.google.common.util.concurrent.ListenableFuture<Reply> |
RedisClient.Pipeline.evalsha_(java.lang.Object... arguments) |
com.google.common.util.concurrent.ListenableFuture<Reply> |
RedisClient.Pipeline.evalsha(java.lang.Object sha10,
java.lang.Object numkeys1,
java.lang.Object... key2)
Execute a Lua script server side
Scripting
|
com.google.common.util.concurrent.ListenableFuture<Reply> |
RedisClient.Pipeline.monitor()
Listen for all requests received by the server in real time
Server
|
com.google.common.util.concurrent.ListenableFuture<Reply> |
RedisClient.Pipeline.object_(java.lang.Object... arguments) |
com.google.common.util.concurrent.ListenableFuture<Reply> |
RedisClient.Pipeline.object(java.lang.Object subcommand0,
java.lang.Object... arguments1)
Inspect the internals of Redis objects
Generic
|
com.google.common.util.concurrent.ListenableFuture<? extends Reply> |
RedisClientBase.pipeline(java.lang.String name,
Command command) |
com.google.common.util.concurrent.ListenableFuture<Reply> |
RedisClient.Pipeline.psetex(java.lang.Object key0,
java.lang.Object milliseconds1,
java.lang.Object value2)
Set the value and expiration in milliseconds of a key
String
|
com.google.common.util.concurrent.ListenableFuture<Reply> |
RedisClient.Pipeline.script_exists_(java.lang.Object... arguments) |
com.google.common.util.concurrent.ListenableFuture<Reply> |
RedisClient.Pipeline.script_exists(java.lang.Object... script0)
Check existence of scripts in the script cache.
|
com.google.common.util.concurrent.ListenableFuture<Reply> |
RedisClient.Pipeline.script_flush()
Remove all the scripts from the script cache.
|
com.google.common.util.concurrent.ListenableFuture<Reply> |
RedisClient.Pipeline.script_kill()
Kill the script currently in execution.
|
com.google.common.util.concurrent.ListenableFuture<Reply> |
RedisClient.Pipeline.script_load(java.lang.Object script0)
Load the specified Lua script into the script cache.
|
com.google.common.util.concurrent.ListenableFuture<Reply> |
RedisClient.Pipeline.slowlog_(java.lang.Object... arguments) |
com.google.common.util.concurrent.ListenableFuture<Reply> |
RedisClient.Pipeline.slowlog(java.lang.Object subcommand0,
java.lang.Object argument1)
Manages the Redis slow queries log
Server
|
com.google.common.util.concurrent.ListenableFuture<Reply> |
RedisClient.Pipeline.sort_(java.lang.Object... arguments) |
com.google.common.util.concurrent.ListenableFuture<Reply> |
RedisClient.Pipeline.sort(java.lang.Object key0,
java.lang.Object... pattern1)
Sort the elements in a list, set or sorted set
Generic
|
com.google.common.util.concurrent.ListenableFuture<Reply> |
RedisClient.Pipeline.srandmember_(java.lang.Object... arguments) |
com.google.common.util.concurrent.ListenableFuture<Reply> |
RedisClient.Pipeline.srandmember(java.lang.Object key0,
java.lang.Object count1)
Get one or multiple random members from a set
Set
|
com.google.common.util.concurrent.ListenableFuture<Reply> |
RedisClient.Pipeline.sync()
Internal command used for replication
Server
|
com.google.common.util.concurrent.ListenableFuture<Reply> |
RedisClient.Pipeline.zrank(java.lang.Object key0,
java.lang.Object member1)
Determine the index of a member in a sorted set
Sorted_set
|
com.google.common.util.concurrent.ListenableFuture<Reply> |
RedisClient.Pipeline.zrevrank(java.lang.Object key0,
java.lang.Object member1)
Determine the index of a member in a sorted set, with scores ordered from high to low
Sorted_set
|
| Modifier and Type | Class and Description |
|---|---|
class |
BulkReply
Created by IntelliJ IDEA.
|
class |
ErrorReply
Created by IntelliJ IDEA.
|
class |
IntegerReply
Created by IntelliJ IDEA.
|
class |
MultiBulkReply
Nested replies.
|
class |
StatusReply
Created by IntelliJ IDEA.
|
| Modifier and Type | Field and Description |
|---|---|
private Reply[] |
MultiBulkReply.replies |
| Modifier and Type | Method and Description |
|---|---|
Reply[] |
MultiBulkReply.data() |
| Constructor and Description |
|---|
MultiBulkReply(Reply[] replies) |