public class RedisClient extends Object
Constructor and Description |
---|
RedisClient(RedisClient delegate) |
Modifier and Type | Method and Description |
---|---|
RedisClient |
append(String key,
String value,
Handler<AsyncResult<Long>> handler)
Append a value to a key
|
rx.Observable<Long> |
appendObservable(String key,
String value)
Append a value to a key
|
RedisClient |
auth(String password,
Handler<AsyncResult<String>> handler)
Authenticate to the server
|
rx.Observable<String> |
authObservable(String password)
Authenticate to the server
|
RedisClient |
bgrewriteaof(Handler<AsyncResult<String>> handler)
Asynchronously rewrite the append-only file
|
rx.Observable<String> |
bgrewriteaofObservable()
Asynchronously rewrite the append-only file
|
RedisClient |
bgsave(Handler<AsyncResult<String>> handler)
Asynchronously save the dataset to disk
|
rx.Observable<String> |
bgsaveObservable()
Asynchronously save the dataset to disk
|
RedisClient |
bitcount(String key,
Handler<AsyncResult<Long>> handler)
Count set bits in a string
|
rx.Observable<Long> |
bitcountObservable(String key)
Count set bits in a string
|
RedisClient |
bitcountRange(String key,
long start,
long end,
Handler<AsyncResult<Long>> handler)
Count set bits in a string
|
rx.Observable<Long> |
bitcountRangeObservable(String key,
long start,
long end)
Count set bits in a string
|
RedisClient |
bitop(BitOperation operation,
String destkey,
List<String> keys,
Handler<AsyncResult<Long>> handler)
Perform bitwise operations between strings
|
rx.Observable<Long> |
bitopObservable(BitOperation operation,
String destkey,
List<String> keys)
Perform bitwise operations between strings
|
RedisClient |
bitpos(String key,
int bit,
Handler<AsyncResult<Long>> handler)
Find first bit set or clear in a string
|
RedisClient |
bitposFrom(String key,
int bit,
int start,
Handler<AsyncResult<Long>> handler)
Find first bit set or clear in a string
See also bitposRange() method, which takes start, and stop offset.
|
rx.Observable<Long> |
bitposFromObservable(String key,
int bit,
int start)
Find first bit set or clear in a string
See also bitposRange() method, which takes start, and stop offset.
|
rx.Observable<Long> |
bitposObservable(String key,
int bit)
Find first bit set or clear in a string
|
RedisClient |
bitposRange(String key,
int bit,
int start,
int stop,
Handler<AsyncResult<Long>> handler)
Find first bit set or clear in a string
Note: when both start, and stop offsets are specified,
behaviour is slightly different than if only start is specified
|
rx.Observable<Long> |
bitposRangeObservable(String key,
int bit,
int start,
int stop)
Find first bit set or clear in a string
Note: when both start, and stop offsets are specified,
behaviour is slightly different than if only start is specified
|
RedisClient |
blpop(String key,
int seconds,
Handler<AsyncResult<JsonArray>> handler)
Remove and get the first element in a list, or block until one is available
|
RedisClient |
blpopMany(List<String> keys,
int seconds,
Handler<AsyncResult<JsonArray>> handler)
Remove and get the first element in any of the lists, or block until one is available
|
rx.Observable<JsonArray> |
blpopManyObservable(List<String> keys,
int seconds)
Remove and get the first element in any of the lists, or block until one is available
|
rx.Observable<JsonArray> |
blpopObservable(String key,
int seconds)
Remove and get the first element in a list, or block until one is available
|
RedisClient |
brpop(String key,
int seconds,
Handler<AsyncResult<JsonArray>> handler)
Remove and get the last element in a list, or block until one is available
|
RedisClient |
brpoplpush(String key,
String destkey,
int seconds,
Handler<AsyncResult<String>> handler)
Pop a value from a list, push it to another list and return it; or block until one is available
|
rx.Observable<String> |
brpoplpushObservable(String key,
String destkey,
int seconds)
Pop a value from a list, push it to another list and return it; or block until one is available
|
RedisClient |
brpopMany(List<String> keys,
int seconds,
Handler<AsyncResult<JsonArray>> handler)
Remove and get the last element in any of the lists, or block until one is available
|
rx.Observable<JsonArray> |
brpopManyObservable(List<String> keys,
int seconds)
Remove and get the last element in any of the lists, or block until one is available
|
rx.Observable<JsonArray> |
brpopObservable(String key,
int seconds)
Remove and get the last element in a list, or block until one is available
|
RedisClient |
clientGetname(Handler<AsyncResult<String>> handler)
Get the current connection name
|
rx.Observable<String> |
clientGetnameObservable()
Get the current connection name
|
RedisClient |
clientKill(KillFilter filter,
Handler<AsyncResult<Long>> handler)
Kill the connection of a client
|
rx.Observable<Long> |
clientKillObservable(KillFilter filter)
Kill the connection of a client
|
RedisClient |
clientList(Handler<AsyncResult<String>> handler)
Get the list of client connections
|
rx.Observable<String> |
clientListObservable()
Get the list of client connections
|
RedisClient |
clientPause(long millis,
Handler<AsyncResult<String>> handler)
Stop processing commands from clients for some time
|
rx.Observable<String> |
clientPauseObservable(long millis)
Stop processing commands from clients for some time
|
RedisClient |
clientSetname(String name,
Handler<AsyncResult<String>> handler)
Set the current connection name
|
rx.Observable<String> |
clientSetnameObservable(String name)
Set the current connection name
|
void |
close(Handler<AsyncResult<Void>> handler)
Close the client - when it is fully closed the handler will be called.
|
rx.Observable<Void> |
closeObservable()
Close the client - when it is fully closed the handler will be called.
|
RedisClient |
clusterAddslots(List<Long> slots,
Handler<AsyncResult<Void>> handler)
Assign new hash slots to receiving node.
|
rx.Observable<Void> |
clusterAddslotsObservable(List<Long> slots)
Assign new hash slots to receiving node.
|
RedisClient |
clusterCountFailureReports(String nodeId,
Handler<AsyncResult<Long>> handler)
Return the number of failure reports active for a given node.
|
rx.Observable<Long> |
clusterCountFailureReportsObservable(String nodeId)
Return the number of failure reports active for a given node.
|
RedisClient |
clusterCountkeysinslot(long slot,
Handler<AsyncResult<Long>> handler)
Return the number of local keys in the specified hash slot.
|
rx.Observable<Long> |
clusterCountkeysinslotObservable(long slot)
Return the number of local keys in the specified hash slot.
|
RedisClient |
clusterDelslots(long slot,
Handler<AsyncResult<Void>> handler)
Set hash slots as unbound in receiving node.
|
RedisClient |
clusterDelslotsMany(List<Long> slots,
Handler<AsyncResult<Void>> handler)
Set hash slots as unbound in receiving node.
|
rx.Observable<Void> |
clusterDelslotsManyObservable(List<Long> slots)
Set hash slots as unbound in receiving node.
|
rx.Observable<Void> |
clusterDelslotsObservable(long slot)
Set hash slots as unbound in receiving node.
|
RedisClient |
clusterFailover(Handler<AsyncResult<Void>> handler)
Forces a slave to perform a manual failover of its master.
|
rx.Observable<Void> |
clusterFailoverObservable()
Forces a slave to perform a manual failover of its master.
|
RedisClient |
clusterFailOverWithOptions(FailoverOptions options,
Handler<AsyncResult<Void>> handler)
Forces a slave to perform a manual failover of its master.
|
rx.Observable<Void> |
clusterFailOverWithOptionsObservable(FailoverOptions options)
Forces a slave to perform a manual failover of its master.
|
RedisClient |
clusterForget(String nodeId,
Handler<AsyncResult<Void>> handler)
Remove a node from the nodes table.
|
rx.Observable<Void> |
clusterForgetObservable(String nodeId)
Remove a node from the nodes table.
|
RedisClient |
clusterGetkeysinslot(long slot,
long count,
Handler<AsyncResult<JsonArray>> handler)
Return local key names in the specified hash slot.
|
rx.Observable<JsonArray> |
clusterGetkeysinslotObservable(long slot,
long count)
Return local key names in the specified hash slot.
|
RedisClient |
clusterInfo(Handler<AsyncResult<JsonArray>> handler)
Provides info about Redis Cluster node state.
|
rx.Observable<JsonArray> |
clusterInfoObservable()
Provides info about Redis Cluster node state.
|
RedisClient |
clusterKeyslot(String key,
Handler<AsyncResult<Long>> handler)
Returns the hash slot of the specified key.
|
rx.Observable<Long> |
clusterKeyslotObservable(String key)
Returns the hash slot of the specified key.
|
RedisClient |
clusterMeet(String ip,
long port,
Handler<AsyncResult<Void>> handler)
Force a node cluster to handshake with another node.
|
rx.Observable<Void> |
clusterMeetObservable(String ip,
long port)
Force a node cluster to handshake with another node.
|
RedisClient |
clusterNodes(Handler<AsyncResult<JsonArray>> handler)
Get Cluster config for the node.
|
rx.Observable<JsonArray> |
clusterNodesObservable()
Get Cluster config for the node.
|
RedisClient |
clusterReplicate(String nodeId,
Handler<AsyncResult<Void>> handler)
Reconfigure a node as a slave of the specified master node.
|
rx.Observable<Void> |
clusterReplicateObservable(String nodeId)
Reconfigure a node as a slave of the specified master node.
|
RedisClient |
clusterReset(Handler<AsyncResult<Void>> handler)
Reset a Redis Cluster node.
|
rx.Observable<Void> |
clusterResetObservable()
Reset a Redis Cluster node.
|
RedisClient |
clusterResetWithOptions(ResetOptions options,
Handler<AsyncResult<Void>> handler)
Reset a Redis Cluster node.
|
rx.Observable<Void> |
clusterResetWithOptionsObservable(ResetOptions options)
Reset a Redis Cluster node.
|
RedisClient |
clusterSaveconfig(Handler<AsyncResult<Void>> handler)
Forces the node to save cluster state on disk.
|
rx.Observable<Void> |
clusterSaveconfigObservable()
Forces the node to save cluster state on disk.
|
RedisClient |
clusterSetConfigEpoch(long epoch,
Handler<AsyncResult<Void>> handler)
Set the configuration epoch in a new node.
|
rx.Observable<Void> |
clusterSetConfigEpochObservable(long epoch)
Set the configuration epoch in a new node.
|
RedisClient |
clusterSetslot(long slot,
SlotCmd subcommand,
Handler<AsyncResult<Void>> handler)
Bind an hash slot to a specific node.
|
rx.Observable<Void> |
clusterSetslotObservable(long slot,
SlotCmd subcommand)
Bind an hash slot to a specific node.
|
RedisClient |
clusterSetslotWithNode(long slot,
SlotCmd subcommand,
String nodeId,
Handler<AsyncResult<Void>> handler)
Bind an hash slot to a specific node.
|
rx.Observable<Void> |
clusterSetslotWithNodeObservable(long slot,
SlotCmd subcommand,
String nodeId)
Bind an hash slot to a specific node.
|
RedisClient |
clusterSlaves(String nodeId,
Handler<AsyncResult<JsonArray>> handler)
List slave nodes of the specified master node.
|
rx.Observable<JsonArray> |
clusterSlavesObservable(String nodeId)
List slave nodes of the specified master node.
|
RedisClient |
clusterSlots(Handler<AsyncResult<JsonArray>> handler)
Get array of Cluster slot to node mappings
|
rx.Observable<JsonArray> |
clusterSlotsObservable()
Get array of Cluster slot to node mappings
|
RedisClient |
command(Handler<AsyncResult<JsonArray>> handler)
Get array of Redis command details
|
RedisClient |
commandCount(Handler<AsyncResult<Long>> handler)
Get total number of Redis commands
|
rx.Observable<Long> |
commandCountObservable()
Get total number of Redis commands
|
RedisClient |
commandGetkeys(Handler<AsyncResult<JsonArray>> handler)
Extract keys given a full Redis command
|
rx.Observable<JsonArray> |
commandGetkeysObservable()
Extract keys given a full Redis command
|
RedisClient |
commandInfo(List<String> commands,
Handler<AsyncResult<JsonArray>> handler)
Get array of specific Redis command details
|
rx.Observable<JsonArray> |
commandInfoObservable(List<String> commands)
Get array of specific Redis command details
|
rx.Observable<JsonArray> |
commandObservable()
Get array of Redis command details
|
RedisClient |
configGet(String parameter,
Handler<AsyncResult<JsonArray>> handler)
Get the value of a configuration parameter
|
rx.Observable<JsonArray> |
configGetObservable(String parameter)
Get the value of a configuration parameter
|
RedisClient |
configResetstat(Handler<AsyncResult<String>> handler)
Reset the stats returned by INFO
|
rx.Observable<String> |
configResetstatObservable()
Reset the stats returned by INFO
|
RedisClient |
configRewrite(Handler<AsyncResult<String>> handler)
Rewrite the configuration file with the in memory configuration
|
rx.Observable<String> |
configRewriteObservable()
Rewrite the configuration file with the in memory configuration
|
RedisClient |
configSet(String parameter,
String value,
Handler<AsyncResult<String>> handler)
Set a configuration parameter to the given value
|
rx.Observable<String> |
configSetObservable(String parameter,
String value)
Set a configuration parameter to the given value
|
static RedisClient |
create(Vertx vertx) |
static RedisClient |
create(Vertx vertx,
RedisOptions config) |
RedisClient |
dbsize(Handler<AsyncResult<Long>> handler)
Return the number of keys in the selected database
|
rx.Observable<Long> |
dbsizeObservable()
Return the number of keys in the selected database
|
RedisClient |
debugObject(String key,
Handler<AsyncResult<String>> handler)
Get debugging information about a key
|
rx.Observable<String> |
debugObjectObservable(String key)
Get debugging information about a key
|
RedisClient |
debugSegfault(Handler<AsyncResult<String>> handler)
Make the server crash
|
rx.Observable<String> |
debugSegfaultObservable()
Make the server crash
|
RedisClient |
decr(String key,
Handler<AsyncResult<Long>> handler)
Decrement the integer value of a key by one
|
RedisClient |
decrby(String key,
long decrement,
Handler<AsyncResult<Long>> handler)
Decrement the integer value of a key by the given number
|
rx.Observable<Long> |
decrbyObservable(String key,
long decrement)
Decrement the integer value of a key by the given number
|
rx.Observable<Long> |
decrObservable(String key)
Decrement the integer value of a key by one
|
RedisClient |
del(String key,
Handler<AsyncResult<Long>> handler)
Delete a key
|
RedisClient |
delMany(List<String> keys,
Handler<AsyncResult<Long>> handler)
Delete many keys
|
rx.Observable<Long> |
delManyObservable(List<String> keys)
Delete many keys
|
rx.Observable<Long> |
delObservable(String key)
Delete a key
|
RedisClient |
discard(Handler<AsyncResult<String>> handler)
Discard all commands issued after MULTI
|
rx.Observable<String> |
discardObservable()
Discard all commands issued after MULTI
|
RedisClient |
dump(String key,
Handler<AsyncResult<String>> handler)
Return a serialized version of the value stored at the specified key.
|
rx.Observable<String> |
dumpObservable(String key)
Return a serialized version of the value stored at the specified key.
|
RedisClient |
echo(String message,
Handler<AsyncResult<String>> handler)
Echo the given string
|
rx.Observable<String> |
echoObservable(String message)
Echo the given string
|
RedisClient |
eval(String script,
List<String> keys,
List<String> args,
Handler<AsyncResult<JsonArray>> handler)
Execute a Lua script server side.
|
rx.Observable<JsonArray> |
evalObservable(String script,
List<String> keys,
List<String> args)
Execute a Lua script server side.
|
RedisClient |
evalsha(String sha1,
List<String> keys,
List<String> values,
Handler<AsyncResult<JsonArray>> handler)
Execute a Lua script server side.
|
rx.Observable<JsonArray> |
evalshaObservable(String sha1,
List<String> keys,
List<String> values)
Execute a Lua script server side.
|
RedisClient |
exec(Handler<AsyncResult<JsonArray>> handler)
Execute all commands issued after MULTI
|
rx.Observable<JsonArray> |
execObservable()
Execute all commands issued after MULTI
|
RedisClient |
exists(String key,
Handler<AsyncResult<Long>> handler)
Determine if a key exists
|
rx.Observable<Long> |
existsObservable(String key)
Determine if a key exists
|
RedisClient |
expire(String key,
int seconds,
Handler<AsyncResult<Long>> handler)
Set a key's time to live in seconds
|
RedisClient |
expireat(String key,
long seconds,
Handler<AsyncResult<Long>> handler)
Set the expiration for a key as a UNIX timestamp
|
rx.Observable<Long> |
expireatObservable(String key,
long seconds)
Set the expiration for a key as a UNIX timestamp
|
rx.Observable<Long> |
expireObservable(String key,
int seconds)
Set a key's time to live in seconds
|
RedisClient |
flushall(Handler<AsyncResult<String>> handler)
Remove all keys from all databases
|
rx.Observable<String> |
flushallObservable()
Remove all keys from all databases
|
RedisClient |
flushdb(Handler<AsyncResult<String>> handler)
Remove all keys from the current database
|
rx.Observable<String> |
flushdbObservable()
Remove all keys from the current database
|
RedisClient |
get(String key,
Handler<AsyncResult<String>> handler)
Get the value of a key
|
RedisClient |
getBinary(String key,
Handler<AsyncResult<Buffer>> handler)
Get the value of a key - without decoding as utf-8
|
rx.Observable<Buffer> |
getBinaryObservable(String key)
Get the value of a key - without decoding as utf-8
|
RedisClient |
getbit(String key,
long offset,
Handler<AsyncResult<Long>> handler)
Returns the bit value at offset in the string value stored at key
|
rx.Observable<Long> |
getbitObservable(String key,
long offset)
Returns the bit value at offset in the string value stored at key
|
Object |
getDelegate() |
rx.Observable<String> |
getObservable(String key)
Get the value of a key
|
RedisClient |
getrange(String key,
long start,
long end,
Handler<AsyncResult<String>> handler)
Get a substring of the string stored at a key
|
rx.Observable<String> |
getrangeObservable(String key,
long start,
long end)
Get a substring of the string stored at a key
|
RedisClient |
getset(String key,
String value,
Handler<AsyncResult<String>> handler)
Set the string value of a key and return its old value
|
rx.Observable<String> |
getsetObservable(String key,
String value)
Set the string value of a key and return its old value
|
RedisClient |
hdel(String key,
String field,
Handler<AsyncResult<Long>> handler)
Delete one or more hash fields
|
RedisClient |
hdelMany(String key,
List<String> fields,
Handler<AsyncResult<Long>> handler)
Delete one or more hash fields
|
rx.Observable<Long> |
hdelManyObservable(String key,
List<String> fields)
Delete one or more hash fields
|
rx.Observable<Long> |
hdelObservable(String key,
String field)
Delete one or more hash fields
|
RedisClient |
hexists(String key,
String field,
Handler<AsyncResult<Long>> handler)
Determine if a hash field exists
|
rx.Observable<Long> |
hexistsObservable(String key,
String field)
Determine if a hash field exists
|
RedisClient |
hget(String key,
String field,
Handler<AsyncResult<String>> handler)
Get the value of a hash field
|
RedisClient |
hgetall(String key,
Handler<AsyncResult<JsonObject>> handler)
Get all the fields and values in a hash
|
rx.Observable<JsonObject> |
hgetallObservable(String key)
Get all the fields and values in a hash
|
rx.Observable<String> |
hgetObservable(String key,
String field)
Get the value of a hash field
|
RedisClient |
hincrby(String key,
String field,
long increment,
Handler<AsyncResult<Long>> handler)
Increment the integer value of a hash field by the given number
|
RedisClient |
hincrbyfloat(String key,
String field,
double increment,
Handler<AsyncResult<String>> handler)
Increment the float value of a hash field by the given amount
|
rx.Observable<String> |
hincrbyfloatObservable(String key,
String field,
double increment)
Increment the float value of a hash field by the given amount
|
rx.Observable<Long> |
hincrbyObservable(String key,
String field,
long increment)
Increment the integer value of a hash field by the given number
|
RedisClient |
hkeys(String key,
Handler<AsyncResult<JsonArray>> handler)
Get all the fields in a hash
|
rx.Observable<JsonArray> |
hkeysObservable(String key)
Get all the fields in a hash
|
RedisClient |
hlen(String key,
Handler<AsyncResult<Long>> handler)
Get the number of fields in a hash
|
rx.Observable<Long> |
hlenObservable(String key)
Get the number of fields in a hash
|
RedisClient |
hmget(String key,
List<String> fields,
Handler<AsyncResult<JsonArray>> handler)
Get the values of all the given hash fields
|
rx.Observable<JsonArray> |
hmgetObservable(String key,
List<String> fields)
Get the values of all the given hash fields
|
RedisClient |
hmset(String key,
JsonObject values,
Handler<AsyncResult<String>> handler)
Set multiple hash fields to multiple values
|
rx.Observable<String> |
hmsetObservable(String key,
JsonObject values)
Set multiple hash fields to multiple values
|
RedisClient |
hscan(String key,
String cursor,
ScanOptions options,
Handler<AsyncResult<JsonArray>> handler)
Incrementally iterate hash fields and associated values
|
rx.Observable<JsonArray> |
hscanObservable(String key,
String cursor,
ScanOptions options)
Incrementally iterate hash fields and associated values
|
RedisClient |
hset(String key,
String field,
String value,
Handler<AsyncResult<Long>> handler)
Set the string value of a hash field
|
RedisClient |
hsetnx(String key,
String field,
String value,
Handler<AsyncResult<Long>> handler)
Set the value of a hash field, only if the field does not exist
|
rx.Observable<Long> |
hsetnxObservable(String key,
String field,
String value)
Set the value of a hash field, only if the field does not exist
|
rx.Observable<Long> |
hsetObservable(String key,
String field,
String value)
Set the string value of a hash field
|
RedisClient |
hvals(String key,
Handler<AsyncResult<JsonArray>> handler)
Get all the values in a hash
|
rx.Observable<JsonArray> |
hvalsObservable(String key)
Get all the values in a hash
|
RedisClient |
incr(String key,
Handler<AsyncResult<Long>> handler)
Increment the integer value of a key by one
|
RedisClient |
incrby(String key,
long increment,
Handler<AsyncResult<Long>> handler)
Increment the integer value of a key by the given amount
|
RedisClient |
incrbyfloat(String key,
double increment,
Handler<AsyncResult<String>> handler)
Increment the float value of a key by the given amount
|
rx.Observable<String> |
incrbyfloatObservable(String key,
double increment)
Increment the float value of a key by the given amount
|
rx.Observable<Long> |
incrbyObservable(String key,
long increment)
Increment the integer value of a key by the given amount
|
rx.Observable<Long> |
incrObservable(String key)
Increment the integer value of a key by one
|
RedisClient |
info(Handler<AsyncResult<JsonObject>> handler)
Get information and statistics about the server
|
rx.Observable<JsonObject> |
infoObservable()
Get information and statistics about the server
|
RedisClient |
infoSection(String section,
Handler<AsyncResult<JsonObject>> handler)
Get information and statistics about the server
|
rx.Observable<JsonObject> |
infoSectionObservable(String section)
Get information and statistics about the server
|
RedisClient |
keys(String pattern,
Handler<AsyncResult<JsonArray>> handler)
Find all keys matching the given pattern
|
rx.Observable<JsonArray> |
keysObservable(String pattern)
Find all keys matching the given pattern
|
RedisClient |
lastsave(Handler<AsyncResult<Long>> handler)
Get the UNIX time stamp of the last successful save to disk
|
rx.Observable<Long> |
lastsaveObservable()
Get the UNIX time stamp of the last successful save to disk
|
RedisClient |
lindex(String key,
int index,
Handler<AsyncResult<String>> handler)
Get an element from a list by its index
|
rx.Observable<String> |
lindexObservable(String key,
int index)
Get an element from a list by its index
|
RedisClient |
linsert(String key,
InsertOptions option,
String pivot,
String value,
Handler<AsyncResult<Long>> handler)
Insert an element before or after another element in a list
|
rx.Observable<Long> |
linsertObservable(String key,
InsertOptions option,
String pivot,
String value)
Insert an element before or after another element in a list
|
RedisClient |
llen(String key,
Handler<AsyncResult<Long>> handler)
Get the length of a list
|
rx.Observable<Long> |
llenObservable(String key)
Get the length of a list
|
RedisClient |
lpop(String key,
Handler<AsyncResult<String>> handler)
Remove and get the first element in a list
|
rx.Observable<String> |
lpopObservable(String key)
Remove and get the first element in a list
|
RedisClient |
lpush(String key,
String value,
Handler<AsyncResult<Long>> handler)
Prepend one value to a list
|
RedisClient |
lpushMany(String key,
List<String> values,
Handler<AsyncResult<Long>> handler)
Prepend one or multiple values to a list
|
rx.Observable<Long> |
lpushManyObservable(String key,
List<String> values)
Prepend one or multiple values to a list
|
rx.Observable<Long> |
lpushObservable(String key,
String value)
Prepend one value to a list
|
RedisClient |
lpushx(String key,
String value,
Handler<AsyncResult<Long>> handler)
Prepend a value to a list, only if the list exists
|
rx.Observable<Long> |
lpushxObservable(String key,
String value)
Prepend a value to a list, only if the list exists
|
RedisClient |
lrange(String key,
long from,
long to,
Handler<AsyncResult<JsonArray>> handler)
Get a range of elements from a list
|
rx.Observable<JsonArray> |
lrangeObservable(String key,
long from,
long to)
Get a range of elements from a list
|
RedisClient |
lrem(String key,
long count,
String value,
Handler<AsyncResult<Long>> handler)
Remove elements from a list
|
rx.Observable<Long> |
lremObservable(String key,
long count,
String value)
Remove elements from a list
|
RedisClient |
lset(String key,
long index,
String value,
Handler<AsyncResult<String>> handler)
Set the value of an element in a list by its index
|
rx.Observable<String> |
lsetObservable(String key,
long index,
String value)
Set the value of an element in a list by its index
|
RedisClient |
ltrim(String key,
long from,
long to,
Handler<AsyncResult<String>> handler)
Trim a list to the specified range
|
rx.Observable<String> |
ltrimObservable(String key,
long from,
long to)
Trim a list to the specified range
|
RedisClient |
mget(String key,
Handler<AsyncResult<JsonArray>> handler)
Get the value of the given key
|
RedisClient |
mgetMany(List<String> keys,
Handler<AsyncResult<JsonArray>> handler)
Get the values of all the given keys
|
rx.Observable<JsonArray> |
mgetManyObservable(List<String> keys)
Get the values of all the given keys
|
rx.Observable<JsonArray> |
mgetObservable(String key)
Get the value of the given key
|
RedisClient |
migrate(String host,
int port,
String key,
int destdb,
long timeout,
MigrateOptions options,
Handler<AsyncResult<String>> handler)
Atomically transfer a key from a Redis instance to another one.
|
rx.Observable<String> |
migrateObservable(String host,
int port,
String key,
int destdb,
long timeout,
MigrateOptions options)
Atomically transfer a key from a Redis instance to another one.
|
RedisClient |
monitor(Handler<AsyncResult<Void>> handler)
Listen for all requests received by the server in real time
|
rx.Observable<Void> |
monitorObservable()
Listen for all requests received by the server in real time
|
RedisClient |
move(String key,
int destdb,
Handler<AsyncResult<Long>> handler)
Move a key to another database
|
rx.Observable<Long> |
moveObservable(String key,
int destdb)
Move a key to another database
|
RedisClient |
mset(JsonObject keyvals,
Handler<AsyncResult<String>> handler)
Set multiple keys to multiple values
|
RedisClient |
msetnx(JsonObject keyvals,
Handler<AsyncResult<Long>> handler)
Set multiple keys to multiple values, only if none of the keys exist
|
rx.Observable<Long> |
msetnxObservable(JsonObject keyvals)
Set multiple keys to multiple values, only if none of the keys exist
|
rx.Observable<String> |
msetObservable(JsonObject keyvals)
Set multiple keys to multiple values
|
RedisClient |
multi(Handler<AsyncResult<String>> handler)
Mark the start of a transaction block
|
rx.Observable<String> |
multiObservable()
Mark the start of a transaction block
|
static RedisClient |
newInstance(RedisClient arg) |
RedisClient |
object(String key,
ObjectCmd cmd,
Handler<AsyncResult<Void>> handler)
Inspect the internals of Redis objects
|
rx.Observable<Void> |
objectObservable(String key,
ObjectCmd cmd)
Inspect the internals of Redis objects
|
RedisClient |
persist(String key,
Handler<AsyncResult<Long>> handler)
Remove the expiration from a key
|
rx.Observable<Long> |
persistObservable(String key)
Remove the expiration from a key
|
RedisClient |
pexpire(String key,
long millis,
Handler<AsyncResult<Long>> handler)
Set a key's time to live in milliseconds
|
RedisClient |
pexpireat(String key,
long millis,
Handler<AsyncResult<Long>> handler)
Set the expiration for a key as a UNIX timestamp specified in milliseconds
|
rx.Observable<Long> |
pexpireatObservable(String key,
long millis)
Set the expiration for a key as a UNIX timestamp specified in milliseconds
|
rx.Observable<Long> |
pexpireObservable(String key,
long millis)
Set a key's time to live in milliseconds
|
RedisClient |
pfadd(String key,
String element,
Handler<AsyncResult<Long>> handler)
Adds the specified element to the specified HyperLogLog.
|
RedisClient |
pfaddMany(String key,
List<String> elements,
Handler<AsyncResult<Long>> handler)
Adds the specified elements to the specified HyperLogLog.
|
rx.Observable<Long> |
pfaddManyObservable(String key,
List<String> elements)
Adds the specified elements to the specified HyperLogLog.
|
rx.Observable<Long> |
pfaddObservable(String key,
String element)
Adds the specified element to the specified HyperLogLog.
|
RedisClient |
pfcount(String key,
Handler<AsyncResult<Long>> handler)
Return the approximated cardinality of the set observed by the HyperLogLog at key.
|
RedisClient |
pfcountMany(List<String> keys,
Handler<AsyncResult<Long>> handler)
Return the approximated cardinality of the set(s) observed by the HyperLogLog at key(s).
|
rx.Observable<Long> |
pfcountManyObservable(List<String> keys)
Return the approximated cardinality of the set(s) observed by the HyperLogLog at key(s).
|
rx.Observable<Long> |
pfcountObservable(String key)
Return the approximated cardinality of the set observed by the HyperLogLog at key.
|
RedisClient |
pfmerge(String destkey,
List<String> keys,
Handler<AsyncResult<String>> handler)
Merge N different HyperLogLogs into a single one.
|
rx.Observable<String> |
pfmergeObservable(String destkey,
List<String> keys)
Merge N different HyperLogLogs into a single one.
|
RedisClient |
ping(Handler<AsyncResult<String>> handler)
Ping the server
|
rx.Observable<String> |
pingObservable()
Ping the server
|
RedisClient |
psetex(String key,
long millis,
String value,
Handler<AsyncResult<Void>> handler)
Set the value and expiration in milliseconds of a key
|
rx.Observable<Void> |
psetexObservable(String key,
long millis,
String value)
Set the value and expiration in milliseconds of a key
|
RedisClient |
psubscribe(String pattern,
Handler<AsyncResult<JsonArray>> handler)
Listen for messages published to channels matching the given pattern
|
RedisClient |
psubscribeMany(List<String> patterns,
Handler<AsyncResult<JsonArray>> handler)
Listen for messages published to channels matching the given patterns
|
rx.Observable<JsonArray> |
psubscribeManyObservable(List<String> patterns)
Listen for messages published to channels matching the given patterns
|
rx.Observable<JsonArray> |
psubscribeObservable(String pattern)
Listen for messages published to channels matching the given pattern
|
RedisClient |
pttl(String key,
Handler<AsyncResult<Long>> handler)
Get the time to live for a key in milliseconds
|
rx.Observable<Long> |
pttlObservable(String key)
Get the time to live for a key in milliseconds
|
RedisClient |
publish(String channel,
String message,
Handler<AsyncResult<Long>> handler)
Post a message to a channel
|
rx.Observable<Long> |
publishObservable(String channel,
String message)
Post a message to a channel
|
RedisClient |
pubsubChannels(String pattern,
Handler<AsyncResult<JsonArray>> handler)
Lists the currently active channels - only those matching the pattern
|
rx.Observable<JsonArray> |
pubsubChannelsObservable(String pattern)
Lists the currently active channels - only those matching the pattern
|
RedisClient |
pubsubNumpat(Handler<AsyncResult<Long>> handler)
Returns the number of subscriptions to patterns (that are performed using the PSUBSCRIBE command)
|
rx.Observable<Long> |
pubsubNumpatObservable()
Returns the number of subscriptions to patterns (that are performed using the PSUBSCRIBE command)
|
RedisClient |
pubsubNumsub(List<String> channels,
Handler<AsyncResult<JsonArray>> handler)
Returns the number of subscribers (not counting clients subscribed to patterns) for the specified channels
|
rx.Observable<JsonArray> |
pubsubNumsubObservable(List<String> channels)
Returns the number of subscribers (not counting clients subscribed to patterns) for the specified channels
|
RedisClient |
punsubscribe(List<String> patterns,
Handler<AsyncResult<Void>> handler)
Stop listening for messages posted to channels matching the given patterns
|
rx.Observable<Void> |
punsubscribeObservable(List<String> patterns)
Stop listening for messages posted to channels matching the given patterns
|
RedisClient |
randomkey(Handler<AsyncResult<String>> handler)
Return a random key from the keyspace
|
rx.Observable<String> |
randomkeyObservable()
Return a random key from the keyspace
|
RedisClient |
rename(String key,
String newkey,
Handler<AsyncResult<String>> handler)
Rename a key
|
RedisClient |
renamenx(String key,
String newkey,
Handler<AsyncResult<Long>> handler)
Rename a key, only if the new key does not exist
|
rx.Observable<Long> |
renamenxObservable(String key,
String newkey)
Rename a key, only if the new key does not exist
|
rx.Observable<String> |
renameObservable(String key,
String newkey)
Rename a key
|
RedisClient |
restore(String key,
long millis,
String serialized,
Handler<AsyncResult<String>> handler)
Create a key using the provided serialized value, previously obtained using DUMP.
|
rx.Observable<String> |
restoreObservable(String key,
long millis,
String serialized)
Create a key using the provided serialized value, previously obtained using DUMP.
|
RedisClient |
role(Handler<AsyncResult<JsonArray>> handler)
Return the role of the instance in the context of replication
|
rx.Observable<JsonArray> |
roleObservable()
Return the role of the instance in the context of replication
|
RedisClient |
rpop(String key,
Handler<AsyncResult<String>> handler)
Remove and get the last element in a list
|
RedisClient |
rpoplpush(String key,
String destkey,
Handler<AsyncResult<String>> handler)
Remove the last element in a list, append it to another list and return it
|
rx.Observable<String> |
rpoplpushObservable(String key,
String destkey)
Remove the last element in a list, append it to another list and return it
|
rx.Observable<String> |
rpopObservable(String key)
Remove and get the last element in a list
|
RedisClient |
rpush(String key,
String value,
Handler<AsyncResult<Long>> handler)
Append one or multiple values to a list
|
RedisClient |
rpushMany(String key,
List<String> values,
Handler<AsyncResult<Long>> handler)
Append one or multiple values to a list
|
rx.Observable<Long> |
rpushManyObservable(String key,
List<String> values)
Append one or multiple values to a list
|
rx.Observable<Long> |
rpushObservable(String key,
String value)
Append one or multiple values to a list
|
RedisClient |
rpushx(String key,
String value,
Handler<AsyncResult<Long>> handler)
Append a value to a list, only if the list exists
|
rx.Observable<Long> |
rpushxObservable(String key,
String value)
Append a value to a list, only if the list exists
|
RedisClient |
sadd(String key,
String member,
Handler<AsyncResult<Long>> handler)
Add a member to a set
|
RedisClient |
saddMany(String key,
List<String> members,
Handler<AsyncResult<Long>> handler)
Add one or more members to a set
|
rx.Observable<Long> |
saddManyObservable(String key,
List<String> members)
Add one or more members to a set
|
rx.Observable<Long> |
saddObservable(String key,
String member)
Add a member to a set
|
RedisClient |
save(Handler<AsyncResult<String>> handler)
Synchronously save the dataset to disk
|
rx.Observable<String> |
saveObservable()
Synchronously save the dataset to disk
|
RedisClient |
scan(String cursor,
ScanOptions options,
Handler<AsyncResult<JsonArray>> handler)
Incrementally iterate the keys space
|
rx.Observable<JsonArray> |
scanObservable(String cursor,
ScanOptions options)
Incrementally iterate the keys space
|
RedisClient |
scard(String key,
Handler<AsyncResult<Long>> handler)
Get the number of members in a set
|
rx.Observable<Long> |
scardObservable(String key)
Get the number of members in a set
|
RedisClient |
scriptExists(String script,
Handler<AsyncResult<JsonArray>> handler)
Check existence of script in the script cache.
|
RedisClient |
scriptExistsMany(List<String> scripts,
Handler<AsyncResult<JsonArray>> handler)
Check existence of scripts in the script cache.
|
rx.Observable<JsonArray> |
scriptExistsManyObservable(List<String> scripts)
Check existence of scripts in the script cache.
|
rx.Observable<JsonArray> |
scriptExistsObservable(String script)
Check existence of script in the script cache.
|
RedisClient |
scriptFlush(Handler<AsyncResult<String>> handler)
Remove all the scripts from the script cache.
|
rx.Observable<String> |
scriptFlushObservable()
Remove all the scripts from the script cache.
|
RedisClient |
scriptKill(Handler<AsyncResult<String>> handler)
Kill the script currently in execution.
|
rx.Observable<String> |
scriptKillObservable()
Kill the script currently in execution.
|
RedisClient |
scriptLoad(String script,
Handler<AsyncResult<String>> handler)
Load the specified Lua script into the script cache.
|
rx.Observable<String> |
scriptLoadObservable(String script)
Load the specified Lua script into the script cache.
|
RedisClient |
sdiff(String key,
List<String> cmpkeys,
Handler<AsyncResult<JsonArray>> handler)
Subtract multiple sets
|
rx.Observable<JsonArray> |
sdiffObservable(String key,
List<String> cmpkeys)
Subtract multiple sets
|
RedisClient |
sdiffstore(String destkey,
String key,
List<String> cmpkeys,
Handler<AsyncResult<Long>> handler)
Subtract multiple sets and store the resulting set in a key
|
rx.Observable<Long> |
sdiffstoreObservable(String destkey,
String key,
List<String> cmpkeys)
Subtract multiple sets and store the resulting set in a key
|
RedisClient |
select(int dbindex,
Handler<AsyncResult<String>> handler)
Change the selected database for the current connection
|
rx.Observable<String> |
selectObservable(int dbindex)
Change the selected database for the current connection
|
RedisClient |
set(String key,
String value,
Handler<AsyncResult<Void>> handler)
Set the string value of a key
|
RedisClient |
setBinary(String key,
Buffer value,
Handler<AsyncResult<Void>> handler)
Set the binary string value of a key - without encoding as utf-8
|
rx.Observable<Void> |
setBinaryObservable(String key,
Buffer value)
Set the binary string value of a key - without encoding as utf-8
|
RedisClient |
setBinaryWithOptions(String key,
Buffer value,
SetOptions options,
Handler<AsyncResult<Void>> handler)
Set the string value of a key
|
rx.Observable<Void> |
setBinaryWithOptionsObservable(String key,
Buffer value,
SetOptions options)
Set the string value of a key
|
RedisClient |
setbit(String key,
long offset,
int bit,
Handler<AsyncResult<Long>> handler)
Sets or clears the bit at offset in the string value stored at key
|
rx.Observable<Long> |
setbitObservable(String key,
long offset,
int bit)
Sets or clears the bit at offset in the string value stored at key
|
RedisClient |
setex(String key,
long seconds,
String value,
Handler<AsyncResult<String>> handler)
Set the value and expiration of a key
|
rx.Observable<String> |
setexObservable(String key,
long seconds,
String value)
Set the value and expiration of a key
|
RedisClient |
setnx(String key,
String value,
Handler<AsyncResult<Long>> handler)
Set the value of a key, only if the key does not exist
|
rx.Observable<Long> |
setnxObservable(String key,
String value)
Set the value of a key, only if the key does not exist
|
rx.Observable<Void> |
setObservable(String key,
String value)
Set the string value of a key
|
RedisClient |
setrange(String key,
int offset,
String value,
Handler<AsyncResult<Long>> handler)
Overwrite part of a string at key starting at the specified offset
|
rx.Observable<Long> |
setrangeObservable(String key,
int offset,
String value)
Overwrite part of a string at key starting at the specified offset
|
RedisClient |
setWithOptions(String key,
String value,
SetOptions options,
Handler<AsyncResult<Void>> handler)
Set the string value of a key
|
rx.Observable<Void> |
setWithOptionsObservable(String key,
String value,
SetOptions options)
Set the string value of a key
|
RedisClient |
sinter(List<String> keys,
Handler<AsyncResult<JsonArray>> handler)
Intersect multiple sets
|
rx.Observable<JsonArray> |
sinterObservable(List<String> keys)
Intersect multiple sets
|
RedisClient |
sinterstore(String destkey,
List<String> keys,
Handler<AsyncResult<Long>> handler)
Intersect multiple sets and store the resulting set in a key
|
rx.Observable<Long> |
sinterstoreObservable(String destkey,
List<String> keys)
Intersect multiple sets and store the resulting set in a key
|
RedisClient |
sismember(String key,
String member,
Handler<AsyncResult<Long>> handler)
Determine if a given value is a member of a set
|
rx.Observable<Long> |
sismemberObservable(String key,
String member)
Determine if a given value is a member of a set
|
RedisClient |
slaveof(String host,
int port,
Handler<AsyncResult<String>> handler)
Make the server a slave of another instance
|
RedisClient |
slaveofNoone(Handler<AsyncResult<String>> handler)
Make this server a master
|
rx.Observable<String> |
slaveofNooneObservable()
Make this server a master
|
rx.Observable<String> |
slaveofObservable(String host,
int port)
Make the server a slave of another instance
|
RedisClient |
slowlogGet(int limit,
Handler<AsyncResult<JsonArray>> handler)
Read the Redis slow queries log
|
rx.Observable<JsonArray> |
slowlogGetObservable(int limit)
Read the Redis slow queries log
|
RedisClient |
slowlogLen(Handler<AsyncResult<Long>> handler)
Get the length of the Redis slow queries log
|
rx.Observable<Long> |
slowlogLenObservable()
Get the length of the Redis slow queries log
|
RedisClient |
slowlogReset(Handler<AsyncResult<Void>> handler)
Reset the Redis slow queries log
|
rx.Observable<Void> |
slowlogResetObservable()
Reset the Redis slow queries log
|
RedisClient |
smembers(String key,
Handler<AsyncResult<JsonArray>> handler)
Get all the members in a set
|
rx.Observable<JsonArray> |
smembersObservable(String key)
Get all the members in a set
|
RedisClient |
smove(String key,
String destkey,
String member,
Handler<AsyncResult<Long>> handler)
Move a member from one set to another
|
rx.Observable<Long> |
smoveObservable(String key,
String destkey,
String member)
Move a member from one set to another
|
RedisClient |
sort(String key,
SortOptions options,
Handler<AsyncResult<JsonArray>> handler)
Sort the elements in a list, set or sorted set
|
rx.Observable<JsonArray> |
sortObservable(String key,
SortOptions options)
Sort the elements in a list, set or sorted set
|
RedisClient |
spop(String key,
Handler<AsyncResult<String>> handler)
Remove and return a random member from a set
|
RedisClient |
spopMany(String key,
int count,
Handler<AsyncResult<String>> handler)
Remove and return random members from a set
|
rx.Observable<String> |
spopManyObservable(String key,
int count)
Remove and return random members from a set
|
rx.Observable<String> |
spopObservable(String key)
Remove and return a random member from a set
|
RedisClient |
srandmember(String key,
Handler<AsyncResult<String>> handler)
Get one or multiple random members from a set
|
RedisClient |
srandmemberCount(String key,
int count,
Handler<AsyncResult<JsonArray>> handler)
Get one or multiple random members from a set
|
rx.Observable<JsonArray> |
srandmemberCountObservable(String key,
int count)
Get one or multiple random members from a set
|
rx.Observable<String> |
srandmemberObservable(String key)
Get one or multiple random members from a set
|
RedisClient |
srem(String key,
String member,
Handler<AsyncResult<Long>> handler)
Remove one member from a set
|
RedisClient |
sremMany(String key,
List<String> members,
Handler<AsyncResult<Long>> handler)
Remove one or more members from a set
|
rx.Observable<Long> |
sremManyObservable(String key,
List<String> members)
Remove one or more members from a set
|
rx.Observable<Long> |
sremObservable(String key,
String member)
Remove one member from a set
|
RedisClient |
sscan(String key,
String cursor,
ScanOptions options,
Handler<AsyncResult<JsonArray>> handler)
Incrementally iterate Set elements
|
rx.Observable<JsonArray> |
sscanObservable(String key,
String cursor,
ScanOptions options)
Incrementally iterate Set elements
|
RedisClient |
strlen(String key,
Handler<AsyncResult<Long>> handler)
Get the length of the value stored in a key
|
rx.Observable<Long> |
strlenObservable(String key)
Get the length of the value stored in a key
|
RedisClient |
subscribe(String channel,
Handler<AsyncResult<JsonArray>> handler)
Listen for messages published to the given channels
|
RedisClient |
subscribeMany(List<String> channels,
Handler<AsyncResult<JsonArray>> handler)
Listen for messages published to the given channels
|
rx.Observable<JsonArray> |
subscribeManyObservable(List<String> channels)
Listen for messages published to the given channels
|
rx.Observable<JsonArray> |
subscribeObservable(String channel)
Listen for messages published to the given channels
|
RedisClient |
sunion(List<String> keys,
Handler<AsyncResult<JsonArray>> handler)
Add multiple sets
|
rx.Observable<JsonArray> |
sunionObservable(List<String> keys)
Add multiple sets
|
RedisClient |
sunionstore(String destkey,
List<String> keys,
Handler<AsyncResult<Long>> handler)
Add multiple sets and store the resulting set in a key
|
rx.Observable<Long> |
sunionstoreObservable(String destkey,
List<String> keys)
Add multiple sets and store the resulting set in a key
|
RedisClient |
sync(Handler<AsyncResult<Void>> handler)
Internal command used for replication
|
rx.Observable<Void> |
syncObservable()
Internal command used for replication
|
RedisClient |
time(Handler<AsyncResult<JsonArray>> handler)
Return the current server time
|
rx.Observable<JsonArray> |
timeObservable()
Return the current server time
|
RedisClient |
ttl(String key,
Handler<AsyncResult<Long>> handler)
Get the time to live for a key
|
rx.Observable<Long> |
ttlObservable(String key)
Get the time to live for a key
|
RedisClient |
type(String key,
Handler<AsyncResult<String>> handler)
Determine the type stored at key
|
rx.Observable<String> |
typeObservable(String key)
Determine the type stored at key
|
RedisClient |
unsubscribe(List<String> channels,
Handler<AsyncResult<Void>> handler)
Stop listening for messages posted to the given channels
|
rx.Observable<Void> |
unsubscribeObservable(List<String> channels)
Stop listening for messages posted to the given channels
|
RedisClient |
unwatch(Handler<AsyncResult<String>> handler)
Forget about all watched keys
|
rx.Observable<String> |
unwatchObservable()
Forget about all watched keys
|
RedisClient |
wait(long numSlaves,
long timeout,
Handler<AsyncResult<String>> handler)
Wait for the synchronous replication of all the write commands sent in the context of the current connection.
|
rx.Observable<String> |
waitObservable(long numSlaves,
long timeout)
Wait for the synchronous replication of all the write commands sent in the context of the current connection.
|
RedisClient |
watch(String key,
Handler<AsyncResult<String>> handler)
Watch the given keys to determine execution of the MULTI/EXEC block
|
RedisClient |
watchMany(List<String> keys,
Handler<AsyncResult<String>> handler)
Watch the given keys to determine execution of the MULTI/EXEC block
|
rx.Observable<String> |
watchManyObservable(List<String> keys)
Watch the given keys to determine execution of the MULTI/EXEC block
|
rx.Observable<String> |
watchObservable(String key)
Watch the given keys to determine execution of the MULTI/EXEC block
|
RedisClient |
zadd(String key,
double score,
String member,
Handler<AsyncResult<Long>> handler)
Add one or more members to a sorted set, or update its score if it already exists
|
RedisClient |
zaddMany(String key,
Map<String,Double> members,
Handler<AsyncResult<Long>> handler)
Add one or more members to a sorted set, or update its score if it already exists
|
rx.Observable<Long> |
zaddManyObservable(String key,
Map<String,Double> members)
Add one or more members to a sorted set, or update its score if it already exists
|
rx.Observable<Long> |
zaddObservable(String key,
double score,
String member)
Add one or more members to a sorted set, or update its score if it already exists
|
RedisClient |
zcard(String key,
Handler<AsyncResult<Long>> handler)
Get the number of members in a sorted set
|
rx.Observable<Long> |
zcardObservable(String key)
Get the number of members in a sorted set
|
RedisClient |
zcount(String key,
double min,
double max,
Handler<AsyncResult<Long>> handler)
Count the members in a sorted set with scores within the given values
|
rx.Observable<Long> |
zcountObservable(String key,
double min,
double max)
Count the members in a sorted set with scores within the given values
|
RedisClient |
zincrby(String key,
double increment,
String member,
Handler<AsyncResult<String>> handler)
Increment the score of a member in a sorted set
|
rx.Observable<String> |
zincrbyObservable(String key,
double increment,
String member)
Increment the score of a member in a sorted set
|
RedisClient |
zinterstore(String destkey,
List<String> sets,
AggregateOptions options,
Handler<AsyncResult<Long>> handler)
Intersect multiple sorted sets and store the resulting sorted set in a new key
|
rx.Observable<Long> |
zinterstoreObservable(String destkey,
List<String> sets,
AggregateOptions options)
Intersect multiple sorted sets and store the resulting sorted set in a new key
|
RedisClient |
zinterstoreWeighed(String destkey,
Map<String,Double> sets,
AggregateOptions options,
Handler<AsyncResult<Long>> handler)
Intersect multiple sorted sets and store the resulting sorted set in a new key using weights for scoring
|
rx.Observable<Long> |
zinterstoreWeighedObservable(String destkey,
Map<String,Double> sets,
AggregateOptions options)
Intersect multiple sorted sets and store the resulting sorted set in a new key using weights for scoring
|
RedisClient |
zlexcount(String key,
String min,
String max,
Handler<AsyncResult<Long>> handler)
Count the number of members in a sorted set between a given lexicographical range
|
rx.Observable<Long> |
zlexcountObservable(String key,
String min,
String max)
Count the number of members in a sorted set between a given lexicographical range
|
RedisClient |
zrange(String key,
long start,
long stop,
Handler<AsyncResult<JsonArray>> handler)
Return a range of members in a sorted set, by index
|
RedisClient |
zrangebylex(String key,
String min,
String max,
LimitOptions options,
Handler<AsyncResult<JsonArray>> handler)
Return a range of members in a sorted set, by lexicographical range
|
rx.Observable<JsonArray> |
zrangebylexObservable(String key,
String min,
String max,
LimitOptions options)
Return a range of members in a sorted set, by lexicographical range
|
RedisClient |
zrangebyscore(String key,
String min,
String max,
RangeLimitOptions options,
Handler<AsyncResult<JsonArray>> handler)
Return a range of members in a sorted set, by score
|
rx.Observable<JsonArray> |
zrangebyscoreObservable(String key,
String min,
String max,
RangeLimitOptions options)
Return a range of members in a sorted set, by score
|
rx.Observable<JsonArray> |
zrangeObservable(String key,
long start,
long stop)
Return a range of members in a sorted set, by index
|
RedisClient |
zrangeWithOptions(String key,
long start,
long stop,
RangeOptions options,
Handler<AsyncResult<JsonArray>> handler)
Return a range of members in a sorted set, by index
|
rx.Observable<JsonArray> |
zrangeWithOptionsObservable(String key,
long start,
long stop,
RangeOptions options)
Return a range of members in a sorted set, by index
|
RedisClient |
zrank(String key,
String member,
Handler<AsyncResult<Long>> handler)
Determine the index of a member in a sorted set
|
rx.Observable<Long> |
zrankObservable(String key,
String member)
Determine the index of a member in a sorted set
|
RedisClient |
zrem(String key,
String member,
Handler<AsyncResult<Long>> handler)
Remove one member from a sorted set
|
RedisClient |
zremMany(String key,
List<String> members,
Handler<AsyncResult<Long>> handler)
Remove one or more members from a sorted set
|
rx.Observable<Long> |
zremManyObservable(String key,
List<String> members)
Remove one or more members from a sorted set
|
rx.Observable<Long> |
zremObservable(String key,
String member)
Remove one member from a sorted set
|
RedisClient |
zremrangebylex(String key,
String min,
String max,
Handler<AsyncResult<Long>> handler)
Remove all members in a sorted set between the given lexicographical range
|
rx.Observable<Long> |
zremrangebylexObservable(String key,
String min,
String max)
Remove all members in a sorted set between the given lexicographical range
|
RedisClient |
zremrangebyrank(String key,
long start,
long stop,
Handler<AsyncResult<Long>> handler)
Remove all members in a sorted set within the given indexes
|
rx.Observable<Long> |
zremrangebyrankObservable(String key,
long start,
long stop)
Remove all members in a sorted set within the given indexes
|
RedisClient |
zremrangebyscore(String key,
String min,
String max,
Handler<AsyncResult<Long>> handler)
Remove all members in a sorted set within the given scores
|
rx.Observable<Long> |
zremrangebyscoreObservable(String key,
String min,
String max)
Remove all members in a sorted set within the given scores
|
RedisClient |
zrevrange(String key,
long start,
long stop,
RangeOptions options,
Handler<AsyncResult<JsonArray>> handler)
Return a range of members in a sorted set, by index, with scores ordered from high to low
|
RedisClient |
zrevrangebylex(String key,
String max,
String min,
LimitOptions options,
Handler<AsyncResult<JsonArray>> handler)
Return a range of members in a sorted set, by score, between the given lexicographical range with scores ordered from high to low
|
rx.Observable<JsonArray> |
zrevrangebylexObservable(String key,
String max,
String min,
LimitOptions options)
Return a range of members in a sorted set, by score, between the given lexicographical range with scores ordered from high to low
|
RedisClient |
zrevrangebyscore(String key,
String max,
String min,
RangeLimitOptions options,
Handler<AsyncResult<JsonArray>> handler)
Return a range of members in a sorted set, by score, with scores ordered from high to low
|
rx.Observable<JsonArray> |
zrevrangebyscoreObservable(String key,
String max,
String min,
RangeLimitOptions options)
Return a range of members in a sorted set, by score, with scores ordered from high to low
|
rx.Observable<JsonArray> |
zrevrangeObservable(String key,
long start,
long stop,
RangeOptions options)
Return a range of members in a sorted set, by index, with scores ordered from high to low
|
RedisClient |
zrevrank(String key,
String member,
Handler<AsyncResult<Long>> handler)
Determine the index of a member in a sorted set, with scores ordered from high to low
|
rx.Observable<Long> |
zrevrankObservable(String key,
String member)
Determine the index of a member in a sorted set, with scores ordered from high to low
|
RedisClient |
zscan(String key,
String cursor,
ScanOptions options,
Handler<AsyncResult<JsonArray>> handler)
Incrementally iterate sorted sets elements and associated scores
|
rx.Observable<JsonArray> |
zscanObservable(String key,
String cursor,
ScanOptions options)
Incrementally iterate sorted sets elements and associated scores
|
RedisClient |
zscore(String key,
String member,
Handler<AsyncResult<String>> handler)
Get the score associated with the given member in a sorted set
|
rx.Observable<String> |
zscoreObservable(String key,
String member)
Get the score associated with the given member in a sorted set
|
RedisClient |
zunionstore(String destkey,
List<String> sets,
AggregateOptions options,
Handler<AsyncResult<Long>> handler)
Add multiple sorted sets and store the resulting sorted set in a new key
|
rx.Observable<Long> |
zunionstoreObservable(String destkey,
List<String> sets,
AggregateOptions options)
Add multiple sorted sets and store the resulting sorted set in a new key
|
RedisClient |
zunionstoreWeighed(String key,
Map<String,Double> sets,
AggregateOptions options,
Handler<AsyncResult<Long>> handler)
Add multiple sorted sets using weights, and store the resulting sorted set in a new key
|
rx.Observable<Long> |
zunionstoreWeighedObservable(String key,
Map<String,Double> sets,
AggregateOptions options)
Add multiple sorted sets using weights, and store the resulting sorted set in a new key
|
public RedisClient(RedisClient delegate)
public Object getDelegate()
public static RedisClient create(Vertx vertx)
public static RedisClient create(Vertx vertx, RedisOptions config)
public void close(Handler<AsyncResult<Void>> handler)
handler
- public rx.Observable<Void> closeObservable()
public RedisClient append(String key, String value, Handler<AsyncResult<Long>> handler)
key
- Key stringvalue
- Value to appendhandler
- Handler for the result of this call.public rx.Observable<Long> appendObservable(String key, String value)
key
- Key stringvalue
- Value to appendpublic RedisClient auth(String password, Handler<AsyncResult<String>> handler)
password
- Password for authenticationhandler
- Handler for the result of this call.public rx.Observable<String> authObservable(String password)
password
- Password for authenticationpublic RedisClient bgrewriteaof(Handler<AsyncResult<String>> handler)
handler
- public rx.Observable<String> bgrewriteaofObservable()
public RedisClient bgsave(Handler<AsyncResult<String>> handler)
handler
- public rx.Observable<String> bgsaveObservable()
public RedisClient bitcount(String key, Handler<AsyncResult<Long>> handler)
key
- Key stringhandler
- Handler for the result of this call.public rx.Observable<Long> bitcountObservable(String key)
key
- Key stringpublic RedisClient bitcountRange(String key, long start, long end, Handler<AsyncResult<Long>> handler)
key
- Key stringstart
- Start indexend
- End indexhandler
- Handler for the result of this call.public rx.Observable<Long> bitcountRangeObservable(String key, long start, long end)
key
- Key stringstart
- Start indexend
- End indexpublic RedisClient bitop(BitOperation operation, String destkey, List<String> keys, Handler<AsyncResult<Long>> handler)
operation
- Bitwise operation to performdestkey
- Destination key where result is storedkeys
- List of keys on which to perform the operationhandler
- Handler for the result of this call.public rx.Observable<Long> bitopObservable(BitOperation operation, String destkey, List<String> keys)
operation
- Bitwise operation to performdestkey
- Destination key where result is storedkeys
- List of keys on which to perform the operationpublic RedisClient bitpos(String key, int bit, Handler<AsyncResult<Long>> handler)
key
- Key stringbit
- What bit value to look for - must be 1, or 0handler
- Handler for the result of this call.public rx.Observable<Long> bitposObservable(String key, int bit)
key
- Key stringbit
- What bit value to look for - must be 1, or 0public RedisClient bitposFrom(String key, int bit, int start, Handler<AsyncResult<Long>> handler)
key
- Key stringbit
- What bit value to look for - must be 1, or 0start
- Start offsethandler
- Handler for the result of this call.public rx.Observable<Long> bitposFromObservable(String key, int bit, int start)
key
- Key stringbit
- What bit value to look for - must be 1, or 0start
- Start offsetpublic RedisClient bitposRange(String key, int bit, int start, int stop, Handler<AsyncResult<Long>> handler)
key
- Key stringbit
- What bit value to look for - must be 1, or 0start
- Start offsetstop
- End offset - inclusivehandler
- Handler for the result of this call.public rx.Observable<Long> bitposRangeObservable(String key, int bit, int start, int stop)
key
- Key stringbit
- What bit value to look for - must be 1, or 0start
- Start offsetstop
- End offset - inclusivepublic RedisClient blpop(String key, int seconds, Handler<AsyncResult<JsonArray>> handler)
key
- Key string identifying a list to watchseconds
- Timeout in secondshandler
- Handler for the result of this call.public rx.Observable<JsonArray> blpopObservable(String key, int seconds)
key
- Key string identifying a list to watchseconds
- Timeout in secondspublic RedisClient blpopMany(List<String> keys, int seconds, Handler<AsyncResult<JsonArray>> handler)
keys
- List of key strings identifying lists to watchseconds
- Timeout in secondshandler
- Handler for the result of this call.public rx.Observable<JsonArray> blpopManyObservable(List<String> keys, int seconds)
keys
- List of key strings identifying lists to watchseconds
- Timeout in secondspublic RedisClient brpop(String key, int seconds, Handler<AsyncResult<JsonArray>> handler)
key
- Key string identifying a list to watchseconds
- Timeout in secondshandler
- Handler for the result of this call.public rx.Observable<JsonArray> brpopObservable(String key, int seconds)
key
- Key string identifying a list to watchseconds
- Timeout in secondspublic RedisClient brpopMany(List<String> keys, int seconds, Handler<AsyncResult<JsonArray>> handler)
keys
- List of key strings identifying lists to watchseconds
- Timeout in secondshandler
- Handler for the result of this call.public rx.Observable<JsonArray> brpopManyObservable(List<String> keys, int seconds)
keys
- List of key strings identifying lists to watchseconds
- Timeout in secondspublic RedisClient brpoplpush(String key, String destkey, int seconds, Handler<AsyncResult<String>> handler)
key
- Key string identifying the source listdestkey
- Key string identifying the destination listseconds
- Timeout in secondshandler
- Handler for the result of this call.public rx.Observable<String> brpoplpushObservable(String key, String destkey, int seconds)
key
- Key string identifying the source listdestkey
- Key string identifying the destination listseconds
- Timeout in secondspublic RedisClient clientKill(KillFilter filter, Handler<AsyncResult<Long>> handler)
filter
- Filter optionshandler
- Handler for the result of this call.public rx.Observable<Long> clientKillObservable(KillFilter filter)
filter
- Filter optionspublic RedisClient clientList(Handler<AsyncResult<String>> handler)
handler
- public rx.Observable<String> clientListObservable()
public RedisClient clientGetname(Handler<AsyncResult<String>> handler)
handler
- public rx.Observable<String> clientGetnameObservable()
public RedisClient clientPause(long millis, Handler<AsyncResult<String>> handler)
millis
- Pause time in millisecondshandler
- Handler for the result of this call.public rx.Observable<String> clientPauseObservable(long millis)
millis
- Pause time in millisecondspublic RedisClient clientSetname(String name, Handler<AsyncResult<String>> handler)
name
- New name for current connectionhandler
- Handler for the result of this call.public rx.Observable<String> clientSetnameObservable(String name)
name
- New name for current connectionpublic RedisClient clusterAddslots(List<Long> slots, Handler<AsyncResult<Void>> handler)
slots
- handler
- Handler for the result of this call.public rx.Observable<Void> clusterAddslotsObservable(List<Long> slots)
slots
- public RedisClient clusterCountFailureReports(String nodeId, Handler<AsyncResult<Long>> handler)
nodeId
- handler
- Handler for the result of this call.public rx.Observable<Long> clusterCountFailureReportsObservable(String nodeId)
nodeId
- public RedisClient clusterCountkeysinslot(long slot, Handler<AsyncResult<Long>> handler)
slot
- handler
- Handler for the result of this call.public rx.Observable<Long> clusterCountkeysinslotObservable(long slot)
slot
- public RedisClient clusterDelslots(long slot, Handler<AsyncResult<Void>> handler)
slot
- handler
- Handler for the result of this call.public rx.Observable<Void> clusterDelslotsObservable(long slot)
slot
- public RedisClient clusterDelslotsMany(List<Long> slots, Handler<AsyncResult<Void>> handler)
slots
- handler
- Handler for the result of this call.public rx.Observable<Void> clusterDelslotsManyObservable(List<Long> slots)
slots
- public RedisClient clusterFailover(Handler<AsyncResult<Void>> handler)
handler
- Handler for the result of this call.public rx.Observable<Void> clusterFailoverObservable()
public RedisClient clusterFailOverWithOptions(FailoverOptions options, Handler<AsyncResult<Void>> handler)
options
- handler
- Handler for the result of this call.public rx.Observable<Void> clusterFailOverWithOptionsObservable(FailoverOptions options)
options
- public RedisClient clusterForget(String nodeId, Handler<AsyncResult<Void>> handler)
nodeId
- handler
- Handler for the result of this call.public rx.Observable<Void> clusterForgetObservable(String nodeId)
nodeId
- public RedisClient clusterGetkeysinslot(long slot, long count, Handler<AsyncResult<JsonArray>> handler)
slot
- count
- handler
- Handler for the result of this call.public rx.Observable<JsonArray> clusterGetkeysinslotObservable(long slot, long count)
slot
- count
- public RedisClient clusterInfo(Handler<AsyncResult<JsonArray>> handler)
handler
- Handler for the result of this call.public rx.Observable<JsonArray> clusterInfoObservable()
public RedisClient clusterKeyslot(String key, Handler<AsyncResult<Long>> handler)
key
- handler
- Handler for the result of this call.public rx.Observable<Long> clusterKeyslotObservable(String key)
key
- public RedisClient clusterMeet(String ip, long port, Handler<AsyncResult<Void>> handler)
ip
- port
- handler
- Handler for the result of this call.public rx.Observable<Void> clusterMeetObservable(String ip, long port)
ip
- port
- public RedisClient clusterNodes(Handler<AsyncResult<JsonArray>> handler)
handler
- Handler for the result of this call.public rx.Observable<JsonArray> clusterNodesObservable()
public RedisClient clusterReplicate(String nodeId, Handler<AsyncResult<Void>> handler)
nodeId
- handler
- Handler for the result of this call.public rx.Observable<Void> clusterReplicateObservable(String nodeId)
nodeId
- public RedisClient clusterReset(Handler<AsyncResult<Void>> handler)
handler
- Handler for the result of this call.public rx.Observable<Void> clusterResetObservable()
public RedisClient clusterResetWithOptions(ResetOptions options, Handler<AsyncResult<Void>> handler)
options
- handler
- Handler for the result of this call.public rx.Observable<Void> clusterResetWithOptionsObservable(ResetOptions options)
options
- public RedisClient clusterSaveconfig(Handler<AsyncResult<Void>> handler)
handler
- Handler for the result of this call.public rx.Observable<Void> clusterSaveconfigObservable()
public RedisClient clusterSetConfigEpoch(long epoch, Handler<AsyncResult<Void>> handler)
epoch
- handler
- Handler for the result of this call.public rx.Observable<Void> clusterSetConfigEpochObservable(long epoch)
epoch
- public RedisClient clusterSetslot(long slot, SlotCmd subcommand, Handler<AsyncResult<Void>> handler)
slot
- subcommand
- handler
- Handler for the result of this call.public rx.Observable<Void> clusterSetslotObservable(long slot, SlotCmd subcommand)
slot
- subcommand
- public RedisClient clusterSetslotWithNode(long slot, SlotCmd subcommand, String nodeId, Handler<AsyncResult<Void>> handler)
slot
- subcommand
- nodeId
- handler
- Handler for the result of this call.public rx.Observable<Void> clusterSetslotWithNodeObservable(long slot, SlotCmd subcommand, String nodeId)
slot
- subcommand
- nodeId
- public RedisClient clusterSlaves(String nodeId, Handler<AsyncResult<JsonArray>> handler)
nodeId
- handler
- Handler for the result of this call.public rx.Observable<JsonArray> clusterSlavesObservable(String nodeId)
nodeId
- public RedisClient clusterSlots(Handler<AsyncResult<JsonArray>> handler)
handler
- public rx.Observable<JsonArray> clusterSlotsObservable()
public RedisClient command(Handler<AsyncResult<JsonArray>> handler)
handler
- public rx.Observable<JsonArray> commandObservable()
public RedisClient commandCount(Handler<AsyncResult<Long>> handler)
handler
- public rx.Observable<Long> commandCountObservable()
public RedisClient commandGetkeys(Handler<AsyncResult<JsonArray>> handler)
handler
- public rx.Observable<JsonArray> commandGetkeysObservable()
public RedisClient commandInfo(List<String> commands, Handler<AsyncResult<JsonArray>> handler)
commands
- List of commands to get info forhandler
- Handler for the result of this call.public rx.Observable<JsonArray> commandInfoObservable(List<String> commands)
commands
- List of commands to get info forpublic RedisClient configGet(String parameter, Handler<AsyncResult<JsonArray>> handler)
parameter
- Configuration parameterhandler
- Handler for the result of this call.public rx.Observable<JsonArray> configGetObservable(String parameter)
parameter
- Configuration parameterpublic RedisClient configRewrite(Handler<AsyncResult<String>> handler)
handler
- public rx.Observable<String> configRewriteObservable()
public RedisClient configSet(String parameter, String value, Handler<AsyncResult<String>> handler)
parameter
- Configuration parametervalue
- New valuehandler
- Handler for the result of this call.public rx.Observable<String> configSetObservable(String parameter, String value)
parameter
- Configuration parametervalue
- New valuepublic RedisClient configResetstat(Handler<AsyncResult<String>> handler)
handler
- public rx.Observable<String> configResetstatObservable()
public RedisClient dbsize(Handler<AsyncResult<Long>> handler)
handler
- public rx.Observable<Long> dbsizeObservable()
public RedisClient debugObject(String key, Handler<AsyncResult<String>> handler)
key
- Key stringhandler
- Handler for the result of this call.public rx.Observable<String> debugObjectObservable(String key)
key
- Key stringpublic RedisClient debugSegfault(Handler<AsyncResult<String>> handler)
handler
- public rx.Observable<String> debugSegfaultObservable()
public RedisClient decr(String key, Handler<AsyncResult<Long>> handler)
key
- Key stringhandler
- Handler for the result of this call.public rx.Observable<Long> decrObservable(String key)
key
- Key stringpublic RedisClient decrby(String key, long decrement, Handler<AsyncResult<Long>> handler)
key
- Key stringdecrement
- Value by which to decrementhandler
- Handler for the result of this call.public rx.Observable<Long> decrbyObservable(String key, long decrement)
key
- Key stringdecrement
- Value by which to decrementpublic RedisClient del(String key, Handler<AsyncResult<Long>> handler)
key
- Keys to deletehandler
- Handler for the result of this call.public rx.Observable<Long> delObservable(String key)
key
- Keys to deletepublic RedisClient delMany(List<String> keys, Handler<AsyncResult<Long>> handler)
keys
- List of keys to deletehandler
- Handler for the result of this call.public rx.Observable<Long> delManyObservable(List<String> keys)
keys
- List of keys to deletepublic RedisClient discard(Handler<AsyncResult<String>> handler)
handler
- public rx.Observable<String> discardObservable()
public RedisClient dump(String key, Handler<AsyncResult<String>> handler)
key
- Key stringhandler
- Handler for the result of this call.public rx.Observable<String> dumpObservable(String key)
key
- Key stringpublic RedisClient echo(String message, Handler<AsyncResult<String>> handler)
message
- String to echohandler
- Handler for the result of this call.public rx.Observable<String> echoObservable(String message)
message
- String to echopublic RedisClient eval(String script, List<String> keys, List<String> args, Handler<AsyncResult<JsonArray>> handler)
script
- Lua script to evaluatekeys
- List of keysargs
- List of argument valueshandler
- Handler for the result of this call.public rx.Observable<JsonArray> evalObservable(String script, List<String> keys, List<String> args)
script
- Lua script to evaluatekeys
- List of keysargs
- List of argument valuespublic RedisClient evalsha(String sha1, List<String> keys, List<String> values, Handler<AsyncResult<JsonArray>> handler)
sha1
- SHA1 digest of the script cached on the serverkeys
- List of keysvalues
- List of valueshandler
- Handler for the result of this call.public rx.Observable<JsonArray> evalshaObservable(String sha1, List<String> keys, List<String> values)
sha1
- SHA1 digest of the script cached on the serverkeys
- List of keysvalues
- List of valuespublic RedisClient exec(Handler<AsyncResult<JsonArray>> handler)
handler
- public rx.Observable<JsonArray> execObservable()
public RedisClient exists(String key, Handler<AsyncResult<Long>> handler)
key
- Key stringhandler
- Handler for the result of this call.public rx.Observable<Long> existsObservable(String key)
key
- Key stringpublic RedisClient expire(String key, int seconds, Handler<AsyncResult<Long>> handler)
key
- Key stringseconds
- Time to live in secondshandler
- Handler for the result of this call.public rx.Observable<Long> expireObservable(String key, int seconds)
key
- Key stringseconds
- Time to live in secondspublic RedisClient expireat(String key, long seconds, Handler<AsyncResult<Long>> handler)
key
- Key stringseconds
- Expiry time as Unix timestamp in secondshandler
- Handler for the result of this call.public rx.Observable<Long> expireatObservable(String key, long seconds)
key
- Key stringseconds
- Expiry time as Unix timestamp in secondspublic RedisClient flushall(Handler<AsyncResult<String>> handler)
handler
- public rx.Observable<String> flushallObservable()
public RedisClient flushdb(Handler<AsyncResult<String>> handler)
handler
- public rx.Observable<String> flushdbObservable()
public RedisClient get(String key, Handler<AsyncResult<String>> handler)
key
- Key stringhandler
- Handler for the result of this call.public rx.Observable<String> getObservable(String key)
key
- Key stringpublic RedisClient getBinary(String key, Handler<AsyncResult<Buffer>> handler)
key
- Key stringhandler
- Handler for the result of this call.public rx.Observable<Buffer> getBinaryObservable(String key)
key
- Key stringpublic RedisClient getbit(String key, long offset, Handler<AsyncResult<Long>> handler)
key
- Key stringoffset
- Offset in bitshandler
- Handler for the result of this call.public rx.Observable<Long> getbitObservable(String key, long offset)
key
- Key stringoffset
- Offset in bitspublic RedisClient getrange(String key, long start, long end, Handler<AsyncResult<String>> handler)
key
- Key stringstart
- Start offsetend
- End offset - inclusivehandler
- Handler for the result of this call.public rx.Observable<String> getrangeObservable(String key, long start, long end)
key
- Key stringstart
- Start offsetend
- End offset - inclusivepublic RedisClient getset(String key, String value, Handler<AsyncResult<String>> handler)
key
- Key of which value to setvalue
- New value for the keyhandler
- Handler for the result of this call.public rx.Observable<String> getsetObservable(String key, String value)
key
- Key of which value to setvalue
- New value for the keypublic RedisClient hdel(String key, String field, Handler<AsyncResult<Long>> handler)
key
- Key stringfield
- Field namehandler
- Handler for the result of this call.public rx.Observable<Long> hdelObservable(String key, String field)
key
- Key stringfield
- Field namepublic RedisClient hdelMany(String key, List<String> fields, Handler<AsyncResult<Long>> handler)
key
- Key stringfields
- Field nameshandler
- Handler for the result of this call.public rx.Observable<Long> hdelManyObservable(String key, List<String> fields)
key
- Key stringfields
- Field namespublic RedisClient hexists(String key, String field, Handler<AsyncResult<Long>> handler)
key
- Key stringfield
- Field namehandler
- Handler for the result of this call.public rx.Observable<Long> hexistsObservable(String key, String field)
key
- Key stringfield
- Field namepublic RedisClient hget(String key, String field, Handler<AsyncResult<String>> handler)
key
- Key stringfield
- Field namehandler
- Handler for the result of this call.public rx.Observable<String> hgetObservable(String key, String field)
key
- Key stringfield
- Field namepublic RedisClient hgetall(String key, Handler<AsyncResult<JsonObject>> handler)
key
- Key stringhandler
- Handler for the result of this call.public rx.Observable<JsonObject> hgetallObservable(String key)
key
- Key stringpublic RedisClient hincrby(String key, String field, long increment, Handler<AsyncResult<Long>> handler)
key
- Key stringfield
- Field nameincrement
- Value by which to incrementhandler
- Handler for the result of this call.public rx.Observable<Long> hincrbyObservable(String key, String field, long increment)
key
- Key stringfield
- Field nameincrement
- Value by which to incrementpublic RedisClient hincrbyfloat(String key, String field, double increment, Handler<AsyncResult<String>> handler)
key
- Key stringfield
- Field nameincrement
- Value by which to incrementhandler
- Handler for the result of this call.public rx.Observable<String> hincrbyfloatObservable(String key, String field, double increment)
key
- Key stringfield
- Field nameincrement
- Value by which to incrementpublic RedisClient hkeys(String key, Handler<AsyncResult<JsonArray>> handler)
key
- Key stringhandler
- Handler for the result of this call.public rx.Observable<JsonArray> hkeysObservable(String key)
key
- Key stringpublic RedisClient hlen(String key, Handler<AsyncResult<Long>> handler)
key
- Key stringhandler
- Handler for the result of this call.public rx.Observable<Long> hlenObservable(String key)
key
- Key stringpublic RedisClient hmget(String key, List<String> fields, Handler<AsyncResult<JsonArray>> handler)
key
- Key stringfields
- Field nameshandler
- Handler for the result of this call.public rx.Observable<JsonArray> hmgetObservable(String key, List<String> fields)
key
- Key stringfields
- Field namespublic RedisClient hmset(String key, JsonObject values, Handler<AsyncResult<String>> handler)
key
- Key stringvalues
- Map of field:value pairshandler
- Handler for the result of this call.public rx.Observable<String> hmsetObservable(String key, JsonObject values)
key
- Key stringvalues
- Map of field:value pairspublic RedisClient hset(String key, String field, String value, Handler<AsyncResult<Long>> handler)
key
- Key stringfield
- Field namevalue
- New valuehandler
- Handler for the result of this call.public rx.Observable<Long> hsetObservable(String key, String field, String value)
key
- Key stringfield
- Field namevalue
- New valuepublic RedisClient hsetnx(String key, String field, String value, Handler<AsyncResult<Long>> handler)
key
- Key stringfield
- Field namevalue
- New valuehandler
- Handler for the result of this call.public rx.Observable<Long> hsetnxObservable(String key, String field, String value)
key
- Key stringfield
- Field namevalue
- New valuepublic RedisClient hvals(String key, Handler<AsyncResult<JsonArray>> handler)
key
- Key stringhandler
- Handler for the result of this call.public rx.Observable<JsonArray> hvalsObservable(String key)
key
- Key stringpublic RedisClient incr(String key, Handler<AsyncResult<Long>> handler)
key
- Key stringhandler
- Handler for the result of this call.public rx.Observable<Long> incrObservable(String key)
key
- Key stringpublic RedisClient incrby(String key, long increment, Handler<AsyncResult<Long>> handler)
key
- Key stringincrement
- Value by which to incrementhandler
- Handler for the result of this call.public rx.Observable<Long> incrbyObservable(String key, long increment)
key
- Key stringincrement
- Value by which to incrementpublic RedisClient incrbyfloat(String key, double increment, Handler<AsyncResult<String>> handler)
key
- Key stringincrement
- Value by which to incrementhandler
- Handler for the result of this call.public rx.Observable<String> incrbyfloatObservable(String key, double increment)
key
- Key stringincrement
- Value by which to incrementpublic RedisClient info(Handler<AsyncResult<JsonObject>> handler)
handler
- Handler for the result of this call.public rx.Observable<JsonObject> infoObservable()
public RedisClient infoSection(String section, Handler<AsyncResult<JsonObject>> handler)
section
- Specific section of information to returnhandler
- Handler for the result of this call.public rx.Observable<JsonObject> infoSectionObservable(String section)
section
- Specific section of information to returnpublic RedisClient keys(String pattern, Handler<AsyncResult<JsonArray>> handler)
pattern
- Pattern to limit the keys returnedhandler
- Handler for the result of this call.public rx.Observable<JsonArray> keysObservable(String pattern)
pattern
- Pattern to limit the keys returnedpublic RedisClient lastsave(Handler<AsyncResult<Long>> handler)
handler
- public rx.Observable<Long> lastsaveObservable()
public RedisClient lindex(String key, int index, Handler<AsyncResult<String>> handler)
key
- Key stringindex
- Index of list element to gethandler
- Handler for the result of this call.public rx.Observable<String> lindexObservable(String key, int index)
key
- Key stringindex
- Index of list element to getpublic RedisClient linsert(String key, InsertOptions option, String pivot, String value, Handler<AsyncResult<Long>> handler)
key
- Key stringoption
- BEFORE or AFTERpivot
- Key to use as a pivotvalue
- Value to be inserted before or after the pivothandler
- Handler for the result of this call.public rx.Observable<Long> linsertObservable(String key, InsertOptions option, String pivot, String value)
key
- Key stringoption
- BEFORE or AFTERpivot
- Key to use as a pivotvalue
- Value to be inserted before or after the pivotpublic RedisClient llen(String key, Handler<AsyncResult<Long>> handler)
key
- String keyhandler
- Handler for the result of this call.public rx.Observable<Long> llenObservable(String key)
key
- String keypublic RedisClient lpop(String key, Handler<AsyncResult<String>> handler)
key
- String keyhandler
- Handler for the result of this call.public rx.Observable<String> lpopObservable(String key)
key
- String keypublic RedisClient lpushMany(String key, List<String> values, Handler<AsyncResult<Long>> handler)
key
- Key stringvalues
- Values to be added at the beginning of the list, one by onehandler
- Handler for the result of this call.public rx.Observable<Long> lpushManyObservable(String key, List<String> values)
key
- Key stringvalues
- Values to be added at the beginning of the list, one by onepublic RedisClient lpush(String key, String value, Handler<AsyncResult<Long>> handler)
key
- Key stringvalue
- Value to be added at the beginning of the listhandler
- Handler for the result of this call.public rx.Observable<Long> lpushObservable(String key, String value)
key
- Key stringvalue
- Value to be added at the beginning of the listpublic RedisClient lpushx(String key, String value, Handler<AsyncResult<Long>> handler)
key
- Key stringvalue
- Value to add at the beginning of the listhandler
- Handler for the result of this call.public rx.Observable<Long> lpushxObservable(String key, String value)
key
- Key stringvalue
- Value to add at the beginning of the listpublic RedisClient lrange(String key, long from, long to, Handler<AsyncResult<JsonArray>> handler)
key
- Key stringfrom
- Start indexto
- Stop indexhandler
- Handler for the result of this call.public rx.Observable<JsonArray> lrangeObservable(String key, long from, long to)
key
- Key stringfrom
- Start indexto
- Stop indexpublic RedisClient lrem(String key, long count, String value, Handler<AsyncResult<Long>> handler)
key
- Key stringcount
- Number of first found occurrences equal to $value to remove from the listvalue
- Value to be removedhandler
- Handler for the result of this call.public rx.Observable<Long> lremObservable(String key, long count, String value)
key
- Key stringcount
- Number of first found occurrences equal to $value to remove from the listvalue
- Value to be removedpublic RedisClient lset(String key, long index, String value, Handler<AsyncResult<String>> handler)
key
- Key stringindex
- Position within listvalue
- New valuehandler
- Handler for the result of this call.public rx.Observable<String> lsetObservable(String key, long index, String value)
key
- Key stringindex
- Position within listvalue
- New valuepublic RedisClient ltrim(String key, long from, long to, Handler<AsyncResult<String>> handler)
key
- Key stringfrom
- Start indexto
- Stop indexhandler
- Handler for the result of this call.public rx.Observable<String> ltrimObservable(String key, long from, long to)
key
- Key stringfrom
- Start indexto
- Stop indexpublic RedisClient mget(String key, Handler<AsyncResult<JsonArray>> handler)
key
- Key stringhandler
- Handler for the result of this call.public rx.Observable<JsonArray> mgetObservable(String key)
key
- Key stringpublic RedisClient mgetMany(List<String> keys, Handler<AsyncResult<JsonArray>> handler)
keys
- List of keys to gethandler
- Handler for the result of this call.public rx.Observable<JsonArray> mgetManyObservable(List<String> keys)
keys
- List of keys to getpublic RedisClient migrate(String host, int port, String key, int destdb, long timeout, MigrateOptions options, Handler<AsyncResult<String>> handler)
host
- Destination hostport
- Destination portkey
- Key to migratedestdb
- Destination database indextimeout
- options
- Migrate optionshandler
- Handler for the result of this call.public rx.Observable<String> migrateObservable(String host, int port, String key, int destdb, long timeout, MigrateOptions options)
host
- Destination hostport
- Destination portkey
- Key to migratedestdb
- Destination database indextimeout
- options
- Migrate optionspublic RedisClient monitor(Handler<AsyncResult<Void>> handler)
handler
- public rx.Observable<Void> monitorObservable()
public RedisClient move(String key, int destdb, Handler<AsyncResult<Long>> handler)
key
- Key to migratedestdb
- Destination database indexhandler
- Handler for the result of this call.public rx.Observable<Long> moveObservable(String key, int destdb)
key
- Key to migratedestdb
- Destination database indexpublic RedisClient mset(JsonObject keyvals, Handler<AsyncResult<String>> handler)
keyvals
- Key value pairs to sethandler
- Handler for the result of this call.public rx.Observable<String> msetObservable(JsonObject keyvals)
keyvals
- Key value pairs to setpublic RedisClient msetnx(JsonObject keyvals, Handler<AsyncResult<Long>> handler)
keyvals
- Key value pairs to sethandler
- Handler for the result of this call.public rx.Observable<Long> msetnxObservable(JsonObject keyvals)
keyvals
- Key value pairs to setpublic RedisClient multi(Handler<AsyncResult<String>> handler)
handler
- public rx.Observable<String> multiObservable()
public RedisClient object(String key, ObjectCmd cmd, Handler<AsyncResult<Void>> handler)
key
- Key stringcmd
- Object sub commandhandler
- Handler for the result of this call.public rx.Observable<Void> objectObservable(String key, ObjectCmd cmd)
key
- Key stringcmd
- Object sub commandpublic RedisClient persist(String key, Handler<AsyncResult<Long>> handler)
key
- Key stringhandler
- Handler for the result of this call.public rx.Observable<Long> persistObservable(String key)
key
- Key stringpublic RedisClient pexpire(String key, long millis, Handler<AsyncResult<Long>> handler)
key
- String keymillis
- Time to live in millisecondshandler
- Handler for the result of this call.public rx.Observable<Long> pexpireObservable(String key, long millis)
key
- String keymillis
- Time to live in millisecondspublic RedisClient pexpireat(String key, long millis, Handler<AsyncResult<Long>> handler)
key
- Key stringmillis
- Expiry time as Unix timestamp in millisecondshandler
- Handler for the result of this call.public rx.Observable<Long> pexpireatObservable(String key, long millis)
key
- Key stringmillis
- Expiry time as Unix timestamp in millisecondspublic RedisClient pfadd(String key, String element, Handler<AsyncResult<Long>> handler)
key
- Key stringelement
- Element to addhandler
- Handler for the result of this call.public rx.Observable<Long> pfaddObservable(String key, String element)
key
- Key stringelement
- Element to addpublic RedisClient pfaddMany(String key, List<String> elements, Handler<AsyncResult<Long>> handler)
key
- Key stringelements
- Elementa to addhandler
- Handler for the result of this call.public rx.Observable<Long> pfaddManyObservable(String key, List<String> elements)
key
- Key stringelements
- Elementa to addpublic RedisClient pfcount(String key, Handler<AsyncResult<Long>> handler)
key
- Key stringhandler
- Handler for the result of this call.public rx.Observable<Long> pfcountObservable(String key)
key
- Key stringpublic RedisClient pfcountMany(List<String> keys, Handler<AsyncResult<Long>> handler)
keys
- List of keyshandler
- Handler for the result of this call.public rx.Observable<Long> pfcountManyObservable(List<String> keys)
keys
- List of keyspublic RedisClient pfmerge(String destkey, List<String> keys, Handler<AsyncResult<String>> handler)
destkey
- Destination keykeys
- List of source keyshandler
- Handler for the result of this call.public rx.Observable<String> pfmergeObservable(String destkey, List<String> keys)
destkey
- Destination keykeys
- List of source keyspublic RedisClient ping(Handler<AsyncResult<String>> handler)
handler
- public rx.Observable<String> pingObservable()
public RedisClient psetex(String key, long millis, String value, Handler<AsyncResult<Void>> handler)
key
- Key stringmillis
- Number of milliseconds until the key expiresvalue
- New value for keyhandler
- Handler for the result of this call.public rx.Observable<Void> psetexObservable(String key, long millis, String value)
key
- Key stringmillis
- Number of milliseconds until the key expiresvalue
- New value for keypublic RedisClient psubscribe(String pattern, Handler<AsyncResult<JsonArray>> handler)
pattern
- Pattern stringhandler
- Handler for the result of this call.public rx.Observable<JsonArray> psubscribeObservable(String pattern)
pattern
- Pattern stringpublic RedisClient psubscribeMany(List<String> patterns, Handler<AsyncResult<JsonArray>> handler)
patterns
- List of patternshandler
- Handler for the result of this call.public rx.Observable<JsonArray> psubscribeManyObservable(List<String> patterns)
patterns
- List of patternspublic RedisClient pubsubChannels(String pattern, Handler<AsyncResult<JsonArray>> handler)
pattern
- A glob-style pattern - an empty string means no patternhandler
- Handler for the result of this call.public rx.Observable<JsonArray> pubsubChannelsObservable(String pattern)
pattern
- A glob-style pattern - an empty string means no patternpublic RedisClient pubsubNumsub(List<String> channels, Handler<AsyncResult<JsonArray>> handler)
channels
- List of channelshandler
- Handler for the result of this call.public rx.Observable<JsonArray> pubsubNumsubObservable(List<String> channels)
channels
- List of channelspublic RedisClient pubsubNumpat(Handler<AsyncResult<Long>> handler)
handler
- Handler for the result of this call.public rx.Observable<Long> pubsubNumpatObservable()
public RedisClient pttl(String key, Handler<AsyncResult<Long>> handler)
key
- Key stringhandler
- Handler for the result of this call.public rx.Observable<Long> pttlObservable(String key)
key
- Key stringpublic RedisClient publish(String channel, String message, Handler<AsyncResult<Long>> handler)
channel
- Channel keymessage
- Message to send to channelhandler
- Handler for the result of this call.public rx.Observable<Long> publishObservable(String channel, String message)
channel
- Channel keymessage
- Message to send to channelpublic RedisClient punsubscribe(List<String> patterns, Handler<AsyncResult<Void>> handler)
patterns
- List of patterns to match againsthandler
- Handler for the result of this call.public rx.Observable<Void> punsubscribeObservable(List<String> patterns)
patterns
- List of patterns to match againstpublic RedisClient randomkey(Handler<AsyncResult<String>> handler)
handler
- public rx.Observable<String> randomkeyObservable()
public RedisClient rename(String key, String newkey, Handler<AsyncResult<String>> handler)
key
- Key string to be renamednewkey
- New key stringhandler
- Handler for the result of this call.public rx.Observable<String> renameObservable(String key, String newkey)
key
- Key string to be renamednewkey
- New key stringpublic RedisClient renamenx(String key, String newkey, Handler<AsyncResult<Long>> handler)
key
- Key string to be renamednewkey
- New key stringhandler
- Handler for the result of this call.public rx.Observable<Long> renamenxObservable(String key, String newkey)
key
- Key string to be renamednewkey
- New key stringpublic RedisClient restore(String key, long millis, String serialized, Handler<AsyncResult<String>> handler)
key
- Key stringmillis
- Expiry time in milliseconds to set on the keyserialized
- Serialized form of the key value as obtained using DUMPhandler
- Handler for the result of this call.public rx.Observable<String> restoreObservable(String key, long millis, String serialized)
key
- Key stringmillis
- Expiry time in milliseconds to set on the keyserialized
- Serialized form of the key value as obtained using DUMPpublic RedisClient role(Handler<AsyncResult<JsonArray>> handler)
handler
- public rx.Observable<JsonArray> roleObservable()
public RedisClient rpop(String key, Handler<AsyncResult<String>> handler)
key
- Key stringhandler
- Handler for the result of this call.public rx.Observable<String> rpopObservable(String key)
key
- Key stringpublic RedisClient rpoplpush(String key, String destkey, Handler<AsyncResult<String>> handler)
key
- Key string identifying source listdestkey
- Key string identifying destination listhandler
- Handler for the result of this call.public rx.Observable<String> rpoplpushObservable(String key, String destkey)
key
- Key string identifying source listdestkey
- Key string identifying destination listpublic RedisClient rpushMany(String key, List<String> values, Handler<AsyncResult<Long>> handler)
key
- Key stringvalues
- List of values to add to the end of the listhandler
- Handler for the result of this call.public rx.Observable<Long> rpushManyObservable(String key, List<String> values)
key
- Key stringvalues
- List of values to add to the end of the listpublic RedisClient rpush(String key, String value, Handler<AsyncResult<Long>> handler)
key
- Key stringvalue
- Value to be added to the end of the listhandler
- Handler for the result of this call.public rx.Observable<Long> rpushObservable(String key, String value)
key
- Key stringvalue
- Value to be added to the end of the listpublic RedisClient rpushx(String key, String value, Handler<AsyncResult<Long>> handler)
key
- Key stringvalue
- Value to be added to the end of the listhandler
- Handler for the result of this call.public rx.Observable<Long> rpushxObservable(String key, String value)
key
- Key stringvalue
- Value to be added to the end of the listpublic RedisClient sadd(String key, String member, Handler<AsyncResult<Long>> handler)
key
- Key stringmember
- Value to be added to the sethandler
- Handler for the result of this call.public rx.Observable<Long> saddObservable(String key, String member)
key
- Key stringmember
- Value to be added to the setpublic RedisClient saddMany(String key, List<String> members, Handler<AsyncResult<Long>> handler)
key
- Key stringmembers
- Values to be added to the sethandler
- Handler for the result of this call.public rx.Observable<Long> saddManyObservable(String key, List<String> members)
key
- Key stringmembers
- Values to be added to the setpublic RedisClient save(Handler<AsyncResult<String>> handler)
handler
- public rx.Observable<String> saveObservable()
public RedisClient scard(String key, Handler<AsyncResult<Long>> handler)
key
- Key stringhandler
- Handler for the result of this call.public rx.Observable<Long> scardObservable(String key)
key
- Key stringpublic RedisClient scriptExists(String script, Handler<AsyncResult<JsonArray>> handler)
script
- SHA1 digest identifying a script in the script cachehandler
- Handler for the result of this call.public rx.Observable<JsonArray> scriptExistsObservable(String script)
script
- SHA1 digest identifying a script in the script cachepublic RedisClient scriptExistsMany(List<String> scripts, Handler<AsyncResult<JsonArray>> handler)
scripts
- List of SHA1 digests identifying scripts in the script cachehandler
- Handler for the result of this call.public rx.Observable<JsonArray> scriptExistsManyObservable(List<String> scripts)
scripts
- List of SHA1 digests identifying scripts in the script cachepublic RedisClient scriptFlush(Handler<AsyncResult<String>> handler)
handler
- public rx.Observable<String> scriptFlushObservable()
public RedisClient scriptKill(Handler<AsyncResult<String>> handler)
handler
- public rx.Observable<String> scriptKillObservable()
public RedisClient scriptLoad(String script, Handler<AsyncResult<String>> handler)
script
- Lua scripthandler
- Handler for the result of this call.public rx.Observable<String> scriptLoadObservable(String script)
script
- Lua scriptpublic RedisClient sdiff(String key, List<String> cmpkeys, Handler<AsyncResult<JsonArray>> handler)
key
- Key identifying the set to compare with all other sets combinedcmpkeys
- List of keys identifying sets to subtract from the key sethandler
- Handler for the result of this call.public rx.Observable<JsonArray> sdiffObservable(String key, List<String> cmpkeys)
key
- Key identifying the set to compare with all other sets combinedcmpkeys
- List of keys identifying sets to subtract from the key setpublic RedisClient sdiffstore(String destkey, String key, List<String> cmpkeys, Handler<AsyncResult<Long>> handler)
destkey
- Destination key where the result should be storedkey
- Key identifying the set to compare with all other sets combinedcmpkeys
- List of keys identifying sets to subtract from the key sethandler
- Handler for the result of this call.public rx.Observable<Long> sdiffstoreObservable(String destkey, String key, List<String> cmpkeys)
destkey
- Destination key where the result should be storedkey
- Key identifying the set to compare with all other sets combinedcmpkeys
- List of keys identifying sets to subtract from the key setpublic RedisClient select(int dbindex, Handler<AsyncResult<String>> handler)
dbindex
- Index identifying the new active databasehandler
- Handler for the result of this call.public rx.Observable<String> selectObservable(int dbindex)
dbindex
- Index identifying the new active databasepublic RedisClient set(String key, String value, Handler<AsyncResult<Void>> handler)
key
- Key of which value to setvalue
- New value for the keyhandler
- Handler for the result of this call.public rx.Observable<Void> setObservable(String key, String value)
key
- Key of which value to setvalue
- New value for the keypublic RedisClient setWithOptions(String key, String value, SetOptions options, Handler<AsyncResult<Void>> handler)
key
- Key of which value to setvalue
- New value for the keyoptions
- Set optionshandler
- Handler for the result of this call.public rx.Observable<Void> setWithOptionsObservable(String key, String value, SetOptions options)
key
- Key of which value to setvalue
- New value for the keyoptions
- Set optionspublic RedisClient setBinary(String key, Buffer value, Handler<AsyncResult<Void>> handler)
key
- Key of which value to setvalue
- New value for the keyhandler
- Handler for the result of this call.public rx.Observable<Void> setBinaryObservable(String key, Buffer value)
key
- Key of which value to setvalue
- New value for the keypublic RedisClient setBinaryWithOptions(String key, Buffer value, SetOptions options, Handler<AsyncResult<Void>> handler)
key
- Key of which value to setvalue
- New value for the keyoptions
- Set optionshandler
- Handler for the result of this call.public rx.Observable<Void> setBinaryWithOptionsObservable(String key, Buffer value, SetOptions options)
key
- Key of which value to setvalue
- New value for the keyoptions
- Set optionspublic RedisClient setbit(String key, long offset, int bit, Handler<AsyncResult<Long>> handler)
key
- Key stringoffset
- Bit offsetbit
- New value - must be 1 or 0handler
- Handler for the result of this call.public rx.Observable<Long> setbitObservable(String key, long offset, int bit)
key
- Key stringoffset
- Bit offsetbit
- New value - must be 1 or 0public RedisClient setex(String key, long seconds, String value, Handler<AsyncResult<String>> handler)
key
- Key stringseconds
- Number of seconds until the key expiresvalue
- New value for keyhandler
- Handler for the result of this call.public rx.Observable<String> setexObservable(String key, long seconds, String value)
key
- Key stringseconds
- Number of seconds until the key expiresvalue
- New value for keypublic RedisClient setnx(String key, String value, Handler<AsyncResult<Long>> handler)
key
- Key of which value to setvalue
- New value for the keyhandler
- Handler for the result of this call.public rx.Observable<Long> setnxObservable(String key, String value)
key
- Key of which value to setvalue
- New value for the keypublic RedisClient setrange(String key, int offset, String value, Handler<AsyncResult<Long>> handler)
key
- Key stringoffset
- Offset - the maximum offset that you can set is 2^29 -1 (536870911), as Redis Strings are limited to 512 megabytesvalue
- Value to overwrite withhandler
- Handler for the result of this call.public rx.Observable<Long> setrangeObservable(String key, int offset, String value)
key
- Key stringoffset
- Offset - the maximum offset that you can set is 2^29 -1 (536870911), as Redis Strings are limited to 512 megabytesvalue
- Value to overwrite withpublic RedisClient sinter(List<String> keys, Handler<AsyncResult<JsonArray>> handler)
keys
- List of keys to perform intersection onhandler
- Handler for the result of this call.public rx.Observable<JsonArray> sinterObservable(List<String> keys)
keys
- List of keys to perform intersection onpublic RedisClient sinterstore(String destkey, List<String> keys, Handler<AsyncResult<Long>> handler)
destkey
- Key where to store the resultskeys
- List of keys to perform intersection onhandler
- Handler for the result of this call.public rx.Observable<Long> sinterstoreObservable(String destkey, List<String> keys)
destkey
- Key where to store the resultskeys
- List of keys to perform intersection onpublic RedisClient sismember(String key, String member, Handler<AsyncResult<Long>> handler)
key
- Key stringmember
- Member to look forhandler
- Handler for the result of this call.public rx.Observable<Long> sismemberObservable(String key, String member)
key
- Key stringmember
- Member to look forpublic RedisClient slaveof(String host, int port, Handler<AsyncResult<String>> handler)
host
- Host to become this server's masterport
- Port of our new masterhandler
- Handler for the result of this call.public rx.Observable<String> slaveofObservable(String host, int port)
host
- Host to become this server's masterport
- Port of our new masterpublic RedisClient slaveofNoone(Handler<AsyncResult<String>> handler)
handler
- Handler for the result of this call.public rx.Observable<String> slaveofNooneObservable()
public RedisClient slowlogGet(int limit, Handler<AsyncResult<JsonArray>> handler)
limit
- Number of log entries to return. If value is less than zero all entries are returnedhandler
- Handler for the result of this call.public rx.Observable<JsonArray> slowlogGetObservable(int limit)
limit
- Number of log entries to return. If value is less than zero all entries are returnedpublic RedisClient slowlogLen(Handler<AsyncResult<Long>> handler)
handler
- Handler for the result of this call.public rx.Observable<Long> slowlogLenObservable()
public RedisClient slowlogReset(Handler<AsyncResult<Void>> handler)
handler
- Handler for the result of this call.public rx.Observable<Void> slowlogResetObservable()
public RedisClient smembers(String key, Handler<AsyncResult<JsonArray>> handler)
key
- Key stringhandler
- Handler for the result of this call.public rx.Observable<JsonArray> smembersObservable(String key)
key
- Key stringpublic RedisClient smove(String key, String destkey, String member, Handler<AsyncResult<Long>> handler)
key
- Key of source set currently containing the memberdestkey
- Key identifying the destination setmember
- Member to movehandler
- Handler for the result of this call.public rx.Observable<Long> smoveObservable(String key, String destkey, String member)
key
- Key of source set currently containing the memberdestkey
- Key identifying the destination setmember
- Member to movepublic RedisClient sort(String key, SortOptions options, Handler<AsyncResult<JsonArray>> handler)
key
- Key stringoptions
- Sort optionshandler
- Handler for the result of this call.public rx.Observable<JsonArray> sortObservable(String key, SortOptions options)
key
- Key stringoptions
- Sort optionspublic RedisClient spop(String key, Handler<AsyncResult<String>> handler)
key
- Key stringhandler
- Handler for the result of this call.public rx.Observable<String> spopObservable(String key)
key
- Key stringpublic RedisClient spopMany(String key, int count, Handler<AsyncResult<String>> handler)
key
- Key stringcount
- Number of members to removehandler
- Handler for the result of this call.public rx.Observable<String> spopManyObservable(String key, int count)
key
- Key stringcount
- Number of members to removepublic RedisClient srandmember(String key, Handler<AsyncResult<String>> handler)
key
- Key stringhandler
- Handler for the result of this call.public rx.Observable<String> srandmemberObservable(String key)
key
- Key stringpublic RedisClient srandmemberCount(String key, int count, Handler<AsyncResult<JsonArray>> handler)
key
- Key stringcount
- Number of members to gethandler
- Handler for the result of this call.public rx.Observable<JsonArray> srandmemberCountObservable(String key, int count)
key
- Key stringcount
- Number of members to getpublic RedisClient srem(String key, String member, Handler<AsyncResult<Long>> handler)
key
- Key stringmember
- Member to removehandler
- Handler for the result of this call.public rx.Observable<Long> sremObservable(String key, String member)
key
- Key stringmember
- Member to removepublic RedisClient sremMany(String key, List<String> members, Handler<AsyncResult<Long>> handler)
key
- Key stringmembers
- Members to removehandler
- Handler for the result of this call.public rx.Observable<Long> sremManyObservable(String key, List<String> members)
key
- Key stringmembers
- Members to removepublic RedisClient strlen(String key, Handler<AsyncResult<Long>> handler)
key
- Key stringhandler
- Handler for the result of this call.public rx.Observable<Long> strlenObservable(String key)
key
- Key stringpublic RedisClient subscribe(String channel, Handler<AsyncResult<JsonArray>> handler)
channel
- Channel to subscribe tohandler
- Handler for the result of this call.public rx.Observable<JsonArray> subscribeObservable(String channel)
channel
- Channel to subscribe topublic RedisClient subscribeMany(List<String> channels, Handler<AsyncResult<JsonArray>> handler)
channels
- List of channels to subscribe tohandler
- Handler for the result of this call.public rx.Observable<JsonArray> subscribeManyObservable(List<String> channels)
channels
- List of channels to subscribe topublic RedisClient sunion(List<String> keys, Handler<AsyncResult<JsonArray>> handler)
keys
- List of keys identifying sets to add uphandler
- Handler for the result of this call.public rx.Observable<JsonArray> sunionObservable(List<String> keys)
keys
- List of keys identifying sets to add uppublic RedisClient sunionstore(String destkey, List<String> keys, Handler<AsyncResult<Long>> handler)
destkey
- Destination keykeys
- List of keys identifying sets to add uphandler
- Handler for the result of this call.public rx.Observable<Long> sunionstoreObservable(String destkey, List<String> keys)
destkey
- Destination keykeys
- List of keys identifying sets to add uppublic RedisClient sync(Handler<AsyncResult<Void>> handler)
handler
- public rx.Observable<Void> syncObservable()
public RedisClient time(Handler<AsyncResult<JsonArray>> handler)
handler
- public rx.Observable<JsonArray> timeObservable()
public RedisClient ttl(String key, Handler<AsyncResult<Long>> handler)
key
- Key stringhandler
- Handler for the result of this call.public rx.Observable<Long> ttlObservable(String key)
key
- Key stringpublic RedisClient type(String key, Handler<AsyncResult<String>> handler)
key
- Key stringhandler
- Handler for the result of this call.public rx.Observable<String> typeObservable(String key)
key
- Key stringpublic RedisClient unsubscribe(List<String> channels, Handler<AsyncResult<Void>> handler)
channels
- List of channels to subscribe tohandler
- Handler for the result of this call.public rx.Observable<Void> unsubscribeObservable(List<String> channels)
channels
- List of channels to subscribe topublic RedisClient unwatch(Handler<AsyncResult<String>> handler)
handler
- public rx.Observable<String> unwatchObservable()
public RedisClient wait(long numSlaves, long timeout, Handler<AsyncResult<String>> handler)
numSlaves
- timeout
- handler
- Handler for the result of this call.public rx.Observable<String> waitObservable(long numSlaves, long timeout)
numSlaves
- timeout
- public RedisClient watch(String key, Handler<AsyncResult<String>> handler)
key
- Key to watchhandler
- Handler for the result of this call.public rx.Observable<String> watchObservable(String key)
key
- Key to watchpublic RedisClient watchMany(List<String> keys, Handler<AsyncResult<String>> handler)
keys
- List of keys to watchhandler
- Handler for the result of this call.public rx.Observable<String> watchManyObservable(List<String> keys)
keys
- List of keys to watchpublic RedisClient zadd(String key, double score, String member, Handler<AsyncResult<Long>> handler)
key
- Key stringscore
- Score used for sortingmember
- New member keyhandler
- Handler for the result of this call.public rx.Observable<Long> zaddObservable(String key, double score, String member)
key
- Key stringscore
- Score used for sortingmember
- New member keypublic RedisClient zaddMany(String key, Map<String,Double> members, Handler<AsyncResult<Long>> handler)
key
- Key stringmembers
- New member keys and their scoreshandler
- Handler for the result of this call.public rx.Observable<Long> zaddManyObservable(String key, Map<String,Double> members)
key
- Key stringmembers
- New member keys and their scorespublic RedisClient zcard(String key, Handler<AsyncResult<Long>> handler)
key
- Key stringhandler
- Handler for the result of this call.public rx.Observable<Long> zcardObservable(String key)
key
- Key stringpublic RedisClient zcount(String key, double min, double max, Handler<AsyncResult<Long>> handler)
key
- Key stringmin
- Minimum scoremax
- Maximum scorehandler
- Handler for the result of this call.public rx.Observable<Long> zcountObservable(String key, double min, double max)
key
- Key stringmin
- Minimum scoremax
- Maximum scorepublic RedisClient zincrby(String key, double increment, String member, Handler<AsyncResult<String>> handler)
key
- Key stringincrement
- Increment amountmember
- Member keyhandler
- Handler for the result of this call.public rx.Observable<String> zincrbyObservable(String key, double increment, String member)
key
- Key stringincrement
- Increment amountmember
- Member keypublic RedisClient zinterstore(String destkey, List<String> sets, AggregateOptions options, Handler<AsyncResult<Long>> handler)
destkey
- Destination keysets
- List of keys identifying sorted sets to intersectoptions
- Aggregation optionshandler
- Handler for the result of this call.public rx.Observable<Long> zinterstoreObservable(String destkey, List<String> sets, AggregateOptions options)
destkey
- Destination keysets
- List of keys identifying sorted sets to intersectoptions
- Aggregation optionspublic RedisClient zinterstoreWeighed(String destkey, Map<String,Double> sets, AggregateOptions options, Handler<AsyncResult<Long>> handler)
destkey
- Destination keysets
- List of keys identifying sorted sets to intersectoptions
- Aggregation optionshandler
- Handler for the result of this call.public rx.Observable<Long> zinterstoreWeighedObservable(String destkey, Map<String,Double> sets, AggregateOptions options)
destkey
- Destination keysets
- List of keys identifying sorted sets to intersectoptions
- Aggregation optionspublic RedisClient zlexcount(String key, String min, String max, Handler<AsyncResult<Long>> handler)
key
- Key stringmin
- Pattern to compare against for minimum valuemax
- Pattern to compare against for maximum valuehandler
- Handler for the result of this call.public rx.Observable<Long> zlexcountObservable(String key, String min, String max)
key
- Key stringmin
- Pattern to compare against for minimum valuemax
- Pattern to compare against for maximum valuepublic RedisClient zrange(String key, long start, long stop, Handler<AsyncResult<JsonArray>> handler)
key
- Key stringstart
- Start index for the rangestop
- Stop index for the range - inclusivehandler
- Handler for the result of this call.public rx.Observable<JsonArray> zrangeObservable(String key, long start, long stop)
key
- Key stringstart
- Start index for the rangestop
- Stop index for the range - inclusivepublic RedisClient zrangeWithOptions(String key, long start, long stop, RangeOptions options, Handler<AsyncResult<JsonArray>> handler)
key
- Key stringstart
- Start index for the rangestop
- Stop index for the range - inclusiveoptions
- Range optionshandler
- Handler for the result of this call.public rx.Observable<JsonArray> zrangeWithOptionsObservable(String key, long start, long stop, RangeOptions options)
key
- Key stringstart
- Start index for the rangestop
- Stop index for the range - inclusiveoptions
- Range optionspublic RedisClient zrangebylex(String key, String min, String max, LimitOptions options, Handler<AsyncResult<JsonArray>> handler)
key
- Key stringmin
- Pattern representing a minimum allowed valuemax
- Pattern representing a maximum allowed valueoptions
- Limit options where limit can be specifiedhandler
- Handler for the result of this call.public rx.Observable<JsonArray> zrangebylexObservable(String key, String min, String max, LimitOptions options)
key
- Key stringmin
- Pattern representing a minimum allowed valuemax
- Pattern representing a maximum allowed valueoptions
- Limit options where limit can be specifiedpublic RedisClient zrangebyscore(String key, String min, String max, RangeLimitOptions options, Handler<AsyncResult<JsonArray>> handler)
key
- Key stringmin
- Pattern defining a minimum valuemax
- Pattern defining a maximum valueoptions
- Range and limit optionshandler
- Handler for the result of this call.public rx.Observable<JsonArray> zrangebyscoreObservable(String key, String min, String max, RangeLimitOptions options)
key
- Key stringmin
- Pattern defining a minimum valuemax
- Pattern defining a maximum valueoptions
- Range and limit optionspublic RedisClient zrank(String key, String member, Handler<AsyncResult<Long>> handler)
key
- Key stringmember
- Member in the sorted set identified by keyhandler
- Handler for the result of this call.public rx.Observable<Long> zrankObservable(String key, String member)
key
- Key stringmember
- Member in the sorted set identified by keypublic RedisClient zrem(String key, String member, Handler<AsyncResult<Long>> handler)
key
- Key stringmember
- Member in the sorted set identified by keyhandler
- Handler for the result of this call.public rx.Observable<Long> zremObservable(String key, String member)
key
- Key stringmember
- Member in the sorted set identified by keypublic RedisClient zremMany(String key, List<String> members, Handler<AsyncResult<Long>> handler)
key
- Key stringmembers
- Members in the sorted set identified by keyhandler
- Handler for the result of this call.public rx.Observable<Long> zremManyObservable(String key, List<String> members)
key
- Key stringmembers
- Members in the sorted set identified by keypublic RedisClient zremrangebylex(String key, String min, String max, Handler<AsyncResult<Long>> handler)
key
- Key stringmin
- Pattern defining a minimum valuemax
- Pattern defining a maximum valuehandler
- Handler for the result of this call.public rx.Observable<Long> zremrangebylexObservable(String key, String min, String max)
key
- Key stringmin
- Pattern defining a minimum valuemax
- Pattern defining a maximum valuepublic RedisClient zremrangebyrank(String key, long start, long stop, Handler<AsyncResult<Long>> handler)
key
- Key stringstart
- Start indexstop
- Stop indexhandler
- Handler for the result of this call.public rx.Observable<Long> zremrangebyrankObservable(String key, long start, long stop)
key
- Key stringstart
- Start indexstop
- Stop indexpublic RedisClient zremrangebyscore(String key, String min, String max, Handler<AsyncResult<Long>> handler)
key
- Key stringmin
- Pattern defining a minimum valuemax
- Pattern defining a maximum valuehandler
- public rx.Observable<Long> zremrangebyscoreObservable(String key, String min, String max)
key
- Key stringmin
- Pattern defining a minimum valuemax
- Pattern defining a maximum valuepublic RedisClient zrevrange(String key, long start, long stop, RangeOptions options, Handler<AsyncResult<JsonArray>> handler)
key
- Key stringstart
- Start index for the rangestop
- Stop index for the range - inclusiveoptions
- Range optionshandler
- Handler for the result of this call.public rx.Observable<JsonArray> zrevrangeObservable(String key, long start, long stop, RangeOptions options)
key
- Key stringstart
- Start index for the rangestop
- Stop index for the range - inclusiveoptions
- Range optionspublic RedisClient zrevrangebylex(String key, String max, String min, LimitOptions options, Handler<AsyncResult<JsonArray>> handler)
key
- Key stringmax
- Pattern defining a maximum valuemin
- Pattern defining a minimum valueoptions
- Limit optionshandler
- Handler for the result of this call.public rx.Observable<JsonArray> zrevrangebylexObservable(String key, String max, String min, LimitOptions options)
key
- Key stringmax
- Pattern defining a maximum valuemin
- Pattern defining a minimum valueoptions
- Limit optionspublic RedisClient zrevrangebyscore(String key, String max, String min, RangeLimitOptions options, Handler<AsyncResult<JsonArray>> handler)
key
- Key stringmax
- Pattern defining a maximum valuemin
- Pattern defining a minimum valueoptions
- Range and limit optionshandler
- Handler for the result of this call.public rx.Observable<JsonArray> zrevrangebyscoreObservable(String key, String max, String min, RangeLimitOptions options)
key
- Key stringmax
- Pattern defining a maximum valuemin
- Pattern defining a minimum valueoptions
- Range and limit optionspublic RedisClient zrevrank(String key, String member, Handler<AsyncResult<Long>> handler)
key
- Key stringmember
- Member in the sorted set identified by keyhandler
- Handler for the result of this call.public rx.Observable<Long> zrevrankObservable(String key, String member)
key
- Key stringmember
- Member in the sorted set identified by keypublic RedisClient zscore(String key, String member, Handler<AsyncResult<String>> handler)
key
- Key stringmember
- Member in the sorted set identified by keyhandler
- Handler for the result of this call.public rx.Observable<String> zscoreObservable(String key, String member)
key
- Key stringmember
- Member in the sorted set identified by keypublic RedisClient zunionstore(String destkey, List<String> sets, AggregateOptions options, Handler<AsyncResult<Long>> handler)
destkey
- Destination keysets
- List of keys identifying sorted setsoptions
- Aggregation optionshandler
- Handler for the result of this call.public rx.Observable<Long> zunionstoreObservable(String destkey, List<String> sets, AggregateOptions options)
destkey
- Destination keysets
- List of keys identifying sorted setsoptions
- Aggregation optionspublic RedisClient zunionstoreWeighed(String key, Map<String,Double> sets, AggregateOptions options, Handler<AsyncResult<Long>> handler)
key
- Destination keysets
- Map containing set-key:weight pairsoptions
- Aggregation optionshandler
- Handler for the result of this call.public rx.Observable<Long> zunionstoreWeighedObservable(String key, Map<String,Double> sets, AggregateOptions options)
key
- Destination keysets
- Map containing set-key:weight pairsoptions
- Aggregation optionspublic RedisClient scan(String cursor, ScanOptions options, Handler<AsyncResult<JsonArray>> handler)
cursor
- Cursor idoptions
- Scan optionshandler
- Handler for the result of this call.public rx.Observable<JsonArray> scanObservable(String cursor, ScanOptions options)
cursor
- Cursor idoptions
- Scan optionspublic RedisClient sscan(String key, String cursor, ScanOptions options, Handler<AsyncResult<JsonArray>> handler)
key
- Key stringcursor
- Cursor idoptions
- Scan optionshandler
- Handler for the result of this call.public rx.Observable<JsonArray> sscanObservable(String key, String cursor, ScanOptions options)
key
- Key stringcursor
- Cursor idoptions
- Scan optionspublic RedisClient hscan(String key, String cursor, ScanOptions options, Handler<AsyncResult<JsonArray>> handler)
key
- Key stringcursor
- Cursor idoptions
- Scan optionshandler
- Handler for the result of this call.public rx.Observable<JsonArray> hscanObservable(String key, String cursor, ScanOptions options)
key
- Key stringcursor
- Cursor idoptions
- Scan optionspublic RedisClient zscan(String key, String cursor, ScanOptions options, Handler<AsyncResult<JsonArray>> handler)
key
- Key stringcursor
- Cursor idoptions
- Scan optionshandler
- Handler for the result of this call.public rx.Observable<JsonArray> zscanObservable(String key, String cursor, ScanOptions options)
key
- Key stringcursor
- Cursor idoptions
- Scan optionspublic static RedisClient newInstance(RedisClient arg)
Copyright © 2015. All rights reserved.