public class RedisTransaction extends Object
Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<RedisTransaction> |
__TYPE_ARG |
Constructor and Description |
---|
RedisTransaction(Object delegate) |
RedisTransaction(RedisTransaction delegate) |
Modifier and Type | Method and Description |
---|---|
RedisTransaction |
append(String key,
String value,
Handler<AsyncResult<String>> handler)
Append a value to a key
|
RedisTransaction |
auth(String password,
Handler<AsyncResult<String>> handler)
Authenticate to the server
|
RedisTransaction |
bgrewriteaof(Handler<AsyncResult<String>> handler)
Asynchronously rewrite the append-only file
|
RedisTransaction |
bgsave(Handler<AsyncResult<String>> handler)
Asynchronously save the dataset to disk
|
RedisTransaction |
bitcount(String key,
Handler<AsyncResult<String>> handler)
Count set bits in a string
|
RedisTransaction |
bitcountRange(String key,
long start,
long end,
Handler<AsyncResult<String>> handler)
Count set bits in a string
|
RedisTransaction |
bitop(BitOperation operation,
String destkey,
List<String> keys,
Handler<AsyncResult<String>> handler)
Perform bitwise operations between strings
|
RedisTransaction |
bitpos(String key,
int bit,
Handler<AsyncResult<String>> handler)
Find first bit set or clear in a string
|
RedisTransaction |
bitposFrom(String key,
int bit,
int start,
Handler<AsyncResult<String>> handler)
Find first bit set or clear in a string
|
RedisTransaction |
bitposRange(String key,
int bit,
int start,
int stop,
Handler<AsyncResult<String>> handler)
Find first bit set or clear in a string
|
RedisTransaction |
blpop(String key,
int seconds,
Handler<AsyncResult<String>> handler)
Remove and get the first element in a list, or block until one is available
|
RedisTransaction |
blpopMany(List<String> keys,
int seconds,
Handler<AsyncResult<String>> handler)
Remove and get the first element in any of the lists, or block until one is available
|
RedisTransaction |
brpop(String key,
int seconds,
Handler<AsyncResult<String>> handler)
Remove and get the last element in a list, or block until one is available
|
RedisTransaction |
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
|
RedisTransaction |
brpopMany(List<String> keys,
int seconds,
Handler<AsyncResult<String>> handler)
Remove and get the last element in any of the lists, or block until one is available
|
RedisTransaction |
clientGetname(Handler<AsyncResult<String>> handler)
Get the current connection name
|
RedisTransaction |
clientKill(KillFilter filter,
Handler<AsyncResult<String>> handler)
Kill the connection of a client
|
RedisTransaction |
clientList(Handler<AsyncResult<String>> handler)
Get the list of client connections
|
RedisTransaction |
clientPause(long millis,
Handler<AsyncResult<String>> handler)
Stop processing commands from clients for some time
|
RedisTransaction |
clientSetname(String name,
Handler<AsyncResult<String>> handler)
Set the current connection name
|
void |
close(Handler<AsyncResult<Void>> handler)
Close the client - when it is fully closed the handler will be called.
|
RedisTransaction |
clusterAddslots(List<String> slots,
Handler<AsyncResult<String>> handler)
Assign new hash slots to receiving node.
|
RedisTransaction |
clusterCountFailureReports(String nodeId,
Handler<AsyncResult<String>> handler)
Return the number of failure reports active for a given node.
|
RedisTransaction |
clusterCountkeysinslot(long slot,
Handler<AsyncResult<String>> handler)
Return the number of local keys in the specified hash slot.
|
RedisTransaction |
clusterDelslots(long slot,
Handler<AsyncResult<String>> handler)
Set hash slots as unbound in receiving node.
|
RedisTransaction |
clusterDelslotsMany(List<String> slots,
Handler<AsyncResult<String>> handler)
Set hash slots as unbound in receiving node.
|
RedisTransaction |
clusterFailover(Handler<AsyncResult<String>> handler)
Forces a slave to perform a manual failover of its master.
|
RedisTransaction |
clusterFailOverWithOptions(FailoverOptions options,
Handler<AsyncResult<String>> handler)
Forces a slave to perform a manual failover of its master.
|
RedisTransaction |
clusterForget(String nodeId,
Handler<AsyncResult<String>> handler)
Remove a node from the nodes table.
|
RedisTransaction |
clusterGetkeysinslot(long slot,
long count,
Handler<AsyncResult<String>> handler)
Return local key names in the specified hash slot.
|
RedisTransaction |
clusterInfo(Handler<AsyncResult<String>> handler)
Provides info about Redis Cluster node state.
|
RedisTransaction |
clusterKeyslot(String key,
Handler<AsyncResult<String>> handler)
Returns the hash slot of the specified key.
|
RedisTransaction |
clusterMeet(String ip,
long port,
Handler<AsyncResult<String>> handler)
Force a node cluster to handshake with another node.
|
RedisTransaction |
clusterNodes(Handler<AsyncResult<String>> handler)
Get Cluster config for the node.
|
RedisTransaction |
clusterReplicate(String nodeId,
Handler<AsyncResult<String>> handler)
Reconfigure a node as a slave of the specified master node.
|
RedisTransaction |
clusterReset(Handler<AsyncResult<String>> handler)
Reset a Redis Cluster node.
|
RedisTransaction |
clusterResetWithOptions(ResetOptions options,
Handler<AsyncResult<String>> handler)
Reset a Redis Cluster node.
|
RedisTransaction |
clusterSaveconfig(Handler<AsyncResult<String>> handler)
Forces the node to save cluster state on disk.
|
RedisTransaction |
clusterSetConfigEpoch(long epoch,
Handler<AsyncResult<String>> handler)
Set the configuration epoch in a new node.
|
RedisTransaction |
clusterSetslot(long slot,
SlotCmd subcommand,
Handler<AsyncResult<String>> handler)
Bind an hash slot to a specific node.
|
RedisTransaction |
clusterSetslotWithNode(long slot,
SlotCmd subcommand,
String nodeId,
Handler<AsyncResult<String>> handler)
Bind an hash slot to a specific node.
|
RedisTransaction |
clusterSlaves(String nodeId,
Handler<AsyncResult<String>> handler)
List slave nodes of the specified master node.
|
RedisTransaction |
clusterSlots(Handler<AsyncResult<String>> handler)
Get array of Cluster slot to node mappings
|
RedisTransaction |
command(Handler<AsyncResult<String>> handler)
Get array of Redis command details
|
RedisTransaction |
commandCount(Handler<AsyncResult<String>> handler)
Get total number of Redis commands
|
RedisTransaction |
commandGetkeys(Handler<AsyncResult<String>> handler)
Extract keys given a full Redis command
|
RedisTransaction |
commandInfo(List<String> commands,
Handler<AsyncResult<String>> handler)
Get array of specific Redis command details
|
RedisTransaction |
configGet(String parameter,
Handler<AsyncResult<String>> handler)
Get the value of a configuration parameter
|
RedisTransaction |
configResetstat(Handler<AsyncResult<String>> handler)
Reset the stats returned by INFO
|
RedisTransaction |
configRewrite(Handler<AsyncResult<String>> handler)
Rewrite the configuration file with the in memory configuration
|
RedisTransaction |
configSet(String parameter,
String value,
Handler<AsyncResult<String>> handler)
Set a configuration parameter to the given value
|
RedisTransaction |
dbsize(Handler<AsyncResult<String>> handler)
Return the number of keys in the selected database
|
RedisTransaction |
debugObject(String key,
Handler<AsyncResult<String>> handler)
Get debugging information about a key
|
RedisTransaction |
debugSegfault(Handler<AsyncResult<String>> handler)
Make the server crash
|
RedisTransaction |
decr(String key,
Handler<AsyncResult<String>> handler)
Decrement the integer value of a key by one
|
RedisTransaction |
decrby(String key,
long decrement,
Handler<AsyncResult<String>> handler)
Decrement the integer value of a key by the given number
|
RedisTransaction |
del(String key,
Handler<AsyncResult<String>> handler)
Delete a key
|
RedisTransaction |
delMany(List<String> keys,
Handler<AsyncResult<String>> handler)
Delete many keys
|
RedisTransaction |
discard(Handler<AsyncResult<String>> handler)
Discard all commands issued after MULTI
|
RedisTransaction |
dump(String key,
Handler<AsyncResult<String>> handler)
Return a serialized version of the value stored at the specified key.
|
RedisTransaction |
echo(String message,
Handler<AsyncResult<String>> handler)
Echo the given string
|
boolean |
equals(Object o) |
RedisTransaction |
eval(String script,
List<String> keys,
List<String> args,
Handler<AsyncResult<String>> handler)
Execute a Lua script server side.
|
RedisTransaction |
evalsha(String sha1,
List<String> keys,
List<String> values,
Handler<AsyncResult<String>> handler)
Execute a Lua script server side.
|
RedisTransaction |
exec(Handler<AsyncResult<JsonArray>> handler)
Execute all commands issued after MULTI
|
RedisTransaction |
exists(String key,
Handler<AsyncResult<String>> handler)
Determine if a key exists
|
RedisTransaction |
existsMany(List<String> keys,
Handler<AsyncResult<String>> handler)
Determine if one or many keys exist
|
RedisTransaction |
expire(String key,
int seconds,
Handler<AsyncResult<String>> handler)
Set a key's time to live in seconds
|
RedisTransaction |
expireat(String key,
long seconds,
Handler<AsyncResult<String>> handler)
Set the expiration for a key as a UNIX timestamp
|
RedisTransaction |
flushall(Handler<AsyncResult<String>> handler)
Remove all keys from all databases
|
RedisTransaction |
flushdb(Handler<AsyncResult<String>> handler)
Remove all keys from the current database
|
RedisTransaction |
geoadd(String key,
double longitude,
double latitude,
String member,
Handler<AsyncResult<String>> handler)
Add one or more geospatial items in the geospatial index represented using a sorted set.
|
RedisTransaction |
geoaddMany(String key,
List<GeoMember> members,
Handler<AsyncResult<String>> handler)
Add one or more geospatial items in the geospatial index represented using a sorted set.
|
RedisTransaction |
geodist(String key,
String member1,
String member2,
Handler<AsyncResult<String>> handler)
Return the distance between two members in the geospatial index represented by the sorted set.
|
RedisTransaction |
geodistWithUnit(String key,
String member1,
String member2,
GeoUnit unit,
Handler<AsyncResult<String>> handler)
Return the distance between two members in the geospatial index represented by the sorted set.
|
RedisTransaction |
geohash(String key,
String member,
Handler<AsyncResult<String>> handler)
Return valid Geohash strings representing the position of one or more elements in a sorted set value representing
a geospatial index (where elements were added using GEOADD).
|
RedisTransaction |
geohashMany(String key,
List<String> members,
Handler<AsyncResult<String>> handler)
Return valid Geohash strings representing the position of one or more elements in a sorted set value representing
a geospatial index (where elements were added using GEOADD).
|
RedisTransaction |
geopos(String key,
String member,
Handler<AsyncResult<String>> handler)
Return the positions (longitude,latitude) of all the specified members of the geospatial index represented by the
sorted set at key.
|
RedisTransaction |
geoposMany(String key,
List<String> members,
Handler<AsyncResult<String>> handler)
Return the positions (longitude,latitude) of all the specified members of the geospatial index represented by the
sorted set at key.
|
RedisTransaction |
georadius(String key,
double longitude,
double latitude,
double radius,
GeoUnit unit,
Handler<AsyncResult<String>> handler)
Return the members of a sorted set populated with geospatial information using GEOADD, which are within the borders
of the area specified with the center location and the maximum distance from the center (the radius).
|
RedisTransaction |
georadiusbymember(String key,
String member,
double radius,
GeoUnit unit,
Handler<AsyncResult<String>> handler)
This command is exactly like GEORADIUS with the sole difference that instead of taking, as the center of the area
to query, a longitude and latitude value, it takes the name of a member already existing inside the geospatial
index represented by the sorted set.
|
RedisTransaction |
georadiusbymemberWithOptions(String key,
String member,
double radius,
GeoUnit unit,
GeoRadiusOptions options,
Handler<AsyncResult<String>> handler)
This command is exactly like GEORADIUS with the sole difference that instead of taking, as the center of the area
to query, a longitude and latitude value, it takes the name of a member already existing inside the geospatial
index represented by the sorted set.
|
RedisTransaction |
georadiusWithOptions(String key,
double longitude,
double latitude,
double radius,
GeoUnit unit,
GeoRadiusOptions options,
Handler<AsyncResult<String>> handler)
Return the members of a sorted set populated with geospatial information using GEOADD, which are within the borders
of the area specified with the center location and the maximum distance from the center (the radius).
|
RedisTransaction |
get(String key,
Handler<AsyncResult<String>> handler)
Get the value of a key
|
RedisTransaction |
getBinary(String key,
Handler<AsyncResult<Buffer>> handler)
Get the value of a key - without decoding as utf-8
|
RedisTransaction |
getbit(String key,
long offset,
Handler<AsyncResult<String>> handler)
Returns the bit value at offset in the string value stored at key
|
RedisTransaction |
getDelegate() |
RedisTransaction |
getrange(String key,
long start,
long end,
Handler<AsyncResult<String>> handler)
Get a substring of the string stored at a key
|
RedisTransaction |
getset(String key,
String value,
Handler<AsyncResult<String>> handler)
Set the string value of a key and return its old value
|
int |
hashCode() |
RedisTransaction |
hdel(String key,
String field,
Handler<AsyncResult<String>> handler)
Delete one or more hash fields
|
RedisTransaction |
hdelMany(String key,
List<String> fields,
Handler<AsyncResult<String>> handler)
Delete one or more hash fields
|
RedisTransaction |
hexists(String key,
String field,
Handler<AsyncResult<String>> handler)
Determine if a hash field exists
|
RedisTransaction |
hget(String key,
String field,
Handler<AsyncResult<String>> handler)
Get the value of a hash field
|
RedisTransaction |
hgetall(String key,
Handler<AsyncResult<String>> handler)
Get all the fields and values in a hash
|
RedisTransaction |
hincrby(String key,
String field,
long increment,
Handler<AsyncResult<String>> handler)
Increment the integer value of a hash field by the given number
|
RedisTransaction |
hincrbyfloat(String key,
String field,
double increment,
Handler<AsyncResult<String>> handler)
Increment the float value of a hash field by the given amount
|
RedisTransaction |
hkeys(String key,
Handler<AsyncResult<String>> handler)
Get all the fields in a hash
|
RedisTransaction |
hlen(String key,
Handler<AsyncResult<String>> handler)
Get the number of fields in a hash
|
RedisTransaction |
hmget(String key,
List<String> fields,
Handler<AsyncResult<String>> handler)
Get the values of all the given hash fields
|
RedisTransaction |
hmset(String key,
JsonObject values,
Handler<AsyncResult<String>> handler)
Set multiple hash fields to multiple values
|
RedisTransaction |
hscan(String key,
String cursor,
ScanOptions options,
Handler<AsyncResult<String>> handler)
Incrementally iterate hash fields and associated values
|
RedisTransaction |
hset(String key,
String field,
String value,
Handler<AsyncResult<String>> handler)
Set the string value of a hash field
|
RedisTransaction |
hsetnx(String key,
String field,
String value,
Handler<AsyncResult<String>> handler)
Set the value of a hash field, only if the field does not exist
|
RedisTransaction |
hvals(String key,
Handler<AsyncResult<String>> handler)
Get all the values in a hash
|
RedisTransaction |
incr(String key,
Handler<AsyncResult<String>> handler)
Increment the integer value of a key by one
|
RedisTransaction |
incrby(String key,
long increment,
Handler<AsyncResult<String>> handler)
Increment the integer value of a key by the given amount
|
RedisTransaction |
incrbyfloat(String key,
double increment,
Handler<AsyncResult<String>> handler)
Increment the float value of a key by the given amount
|
RedisTransaction |
info(Handler<AsyncResult<String>> handler)
Get information and statistics about the server
|
RedisTransaction |
infoSection(String section,
Handler<AsyncResult<String>> handler)
Get information and statistics about the server
|
RedisTransaction |
keys(String pattern,
Handler<AsyncResult<String>> handler)
Find all keys matching the given pattern
|
RedisTransaction |
lastsave(Handler<AsyncResult<String>> handler)
Get the UNIX time stamp of the last successful save to disk
|
RedisTransaction |
lindex(String key,
int index,
Handler<AsyncResult<String>> handler)
Get an element from a list by its index
|
RedisTransaction |
linsert(String key,
InsertOptions option,
String pivot,
String value,
Handler<AsyncResult<String>> handler)
Insert an element before or after another element in a list
|
RedisTransaction |
llen(String key,
Handler<AsyncResult<String>> handler)
Get the length of a list
|
RedisTransaction |
lpop(String key,
Handler<AsyncResult<String>> handler)
Remove and get the first element in a list
|
RedisTransaction |
lpush(String key,
String value,
Handler<AsyncResult<String>> handler)
Prepend one value to a list
|
RedisTransaction |
lpushMany(String key,
List<String> values,
Handler<AsyncResult<String>> handler)
Prepend one or multiple values to a list
|
RedisTransaction |
lpushx(String key,
String value,
Handler<AsyncResult<String>> handler)
Prepend a value to a list, only if the list exists
|
RedisTransaction |
lrange(String key,
long from,
long to,
Handler<AsyncResult<String>> handler)
Get a range of elements from a list
|
RedisTransaction |
lrem(String key,
long count,
String value,
Handler<AsyncResult<String>> handler)
Remove elements from a list
|
RedisTransaction |
lset(String key,
long index,
String value,
Handler<AsyncResult<String>> handler)
Set the value of an element in a list by its index
|
RedisTransaction |
ltrim(String key,
long from,
long to,
Handler<AsyncResult<String>> handler)
Trim a list to the specified range
|
RedisTransaction |
mget(String key,
Handler<AsyncResult<String>> handler)
Get the value of the given key
|
RedisTransaction |
mgetMany(List<String> keys,
Handler<AsyncResult<String>> handler)
Get the values of all the given keys
|
RedisTransaction |
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.
|
RedisTransaction |
monitor(Handler<AsyncResult<String>> handler)
Listen for all requests received by the server in real time
|
RedisTransaction |
move(String key,
int destdb,
Handler<AsyncResult<String>> handler)
Move a key to another database
|
RedisTransaction |
mset(JsonObject keyvals,
Handler<AsyncResult<String>> handler)
Set multiple keys to multiple values
|
RedisTransaction |
msetnx(JsonObject keyvals,
Handler<AsyncResult<String>> handler)
Set multiple keys to multiple values, only if none of the keys exist
|
RedisTransaction |
multi(Handler<AsyncResult<String>> handler)
Mark the start of a RedisTransaction block
|
static RedisTransaction |
newInstance(RedisTransaction arg) |
RedisTransaction |
object(String key,
ObjectCmd cmd,
Handler<AsyncResult<String>> handler)
Inspect the internals of Redis objects
|
RedisTransaction |
persist(String key,
Handler<AsyncResult<String>> handler)
Remove the expiration from a key
|
RedisTransaction |
pexpire(String key,
long millis,
Handler<AsyncResult<String>> handler)
Set a key's time to live in milliseconds
|
RedisTransaction |
pexpireat(String key,
long millis,
Handler<AsyncResult<String>> handler)
Set the expiration for a key as a UNIX timestamp specified in milliseconds
|
RedisTransaction |
pfadd(String key,
String element,
Handler<AsyncResult<String>> handler)
Adds the specified element to the specified HyperLogLog.
|
RedisTransaction |
pfaddMany(String key,
List<String> elements,
Handler<AsyncResult<String>> handler)
Adds the specified elements to the specified HyperLogLog.
|
RedisTransaction |
pfcount(String key,
Handler<AsyncResult<String>> handler)
Return the approximated cardinality of the set observed by the HyperLogLog at key.
|
RedisTransaction |
pfcountMany(List<String> keys,
Handler<AsyncResult<String>> handler)
Return the approximated cardinality of the set(s) observed by the HyperLogLog at key(s).
|
RedisTransaction |
pfmerge(String destkey,
List<String> keys,
Handler<AsyncResult<String>> handler)
Merge N different HyperLogLogs into a single one.
|
RedisTransaction |
ping(Handler<AsyncResult<String>> handler)
Ping the server
|
RedisTransaction |
psetex(String key,
long millis,
String value,
Handler<AsyncResult<String>> handler)
Set the value and expiration in milliseconds of a key
|
RedisTransaction |
psubscribe(String pattern,
Handler<AsyncResult<String>> handler)
Listen for messages published to channels matching the given pattern
|
RedisTransaction |
psubscribeMany(List<String> patterns,
Handler<AsyncResult<String>> handler)
Listen for messages published to channels matching the given patterns
|
RedisTransaction |
pttl(String key,
Handler<AsyncResult<String>> handler)
Get the time to live for a key in milliseconds
|
RedisTransaction |
publish(String channel,
String message,
Handler<AsyncResult<String>> handler)
Post a message to a channel
|
RedisTransaction |
pubsubChannels(String pattern,
Handler<AsyncResult<String>> handler)
Lists the currently active channels - only those matching the pattern
|
RedisTransaction |
pubsubNumpat(Handler<AsyncResult<String>> handler)
Returns the number of subscriptions to patterns (that are performed using the PSUBSCRIBE command)
|
RedisTransaction |
pubsubNumsub(List<String> channels,
Handler<AsyncResult<String>> handler)
Returns the number of subscribers (not counting clients subscribed to patterns) for the specified channels
|
RedisTransaction |
punsubscribe(List<String> patterns,
Handler<AsyncResult<String>> handler)
Stop listening for messages posted to channels matching the given patterns
|
RedisTransaction |
randomkey(Handler<AsyncResult<String>> handler)
Return a random key from the keyspace
|
RedisTransaction |
rename(String key,
String newkey,
Handler<AsyncResult<String>> handler)
Rename a key
|
RedisTransaction |
renamenx(String key,
String newkey,
Handler<AsyncResult<String>> handler)
Rename a key, only if the new key does not exist
|
RedisTransaction |
restore(String key,
long millis,
String serialized,
Handler<AsyncResult<String>> handler)
Create a key using the provided serialized value, previously obtained using DUMP.
|
RedisTransaction |
role(Handler<AsyncResult<String>> handler)
Return the role of the instance in the context of replication
|
RedisTransaction |
rpop(String key,
Handler<AsyncResult<String>> handler)
Remove and get the last element in a list
|
RedisTransaction |
rpoplpush(String key,
String destkey,
Handler<AsyncResult<String>> handler)
Remove the last element in a list, append it to another list and return it
|
RedisTransaction |
rpush(String key,
String value,
Handler<AsyncResult<String>> handler)
Append one or multiple values to a list
|
RedisTransaction |
rpushMany(String key,
List<String> values,
Handler<AsyncResult<String>> handler)
Append one or multiple values to a list
|
RedisTransaction |
rpushx(String key,
String value,
Handler<AsyncResult<String>> handler)
Append a value to a list, only if the list exists
|
Single<String> |
rxAppend(String key,
String value)
Append a value to a key
|
Single<String> |
rxAuth(String password)
Authenticate to the server
|
Single<String> |
rxBgrewriteaof()
Asynchronously rewrite the append-only file
|
Single<String> |
rxBgsave()
Asynchronously save the dataset to disk
|
Single<String> |
rxBitcount(String key)
Count set bits in a string
|
Single<String> |
rxBitcountRange(String key,
long start,
long end)
Count set bits in a string
|
Single<String> |
rxBitop(BitOperation operation,
String destkey,
List<String> keys)
Perform bitwise operations between strings
|
Single<String> |
rxBitpos(String key,
int bit)
Find first bit set or clear in a string
|
Single<String> |
rxBitposFrom(String key,
int bit,
int start)
Find first bit set or clear in a string
|
Single<String> |
rxBitposRange(String key,
int bit,
int start,
int stop)
Find first bit set or clear in a string
|
Single<String> |
rxBlpop(String key,
int seconds)
Remove and get the first element in a list, or block until one is available
|
Single<String> |
rxBlpopMany(List<String> keys,
int seconds)
Remove and get the first element in any of the lists, or block until one is available
|
Single<String> |
rxBrpop(String key,
int seconds)
Remove and get the last element in a list, or block until one is available
|
Single<String> |
rxBrpoplpush(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
|
Single<String> |
rxBrpopMany(List<String> keys,
int seconds)
Remove and get the last element in any of the lists, or block until one is available
|
Single<String> |
rxClientGetname()
Get the current connection name
|
Single<String> |
rxClientKill(KillFilter filter)
Kill the connection of a client
|
Single<String> |
rxClientList()
Get the list of client connections
|
Single<String> |
rxClientPause(long millis)
Stop processing commands from clients for some time
|
Single<String> |
rxClientSetname(String name)
Set the current connection name
|
Completable |
rxClose()
Close the client - when it is fully closed the handler will be called.
|
Single<String> |
rxClusterAddslots(List<String> slots)
Assign new hash slots to receiving node.
|
Single<String> |
rxClusterCountFailureReports(String nodeId)
Return the number of failure reports active for a given node.
|
Single<String> |
rxClusterCountkeysinslot(long slot)
Return the number of local keys in the specified hash slot.
|
Single<String> |
rxClusterDelslots(long slot)
Set hash slots as unbound in receiving node.
|
Single<String> |
rxClusterDelslotsMany(List<String> slots)
Set hash slots as unbound in receiving node.
|
Single<String> |
rxClusterFailover()
Forces a slave to perform a manual failover of its master.
|
Single<String> |
rxClusterFailOverWithOptions(FailoverOptions options)
Forces a slave to perform a manual failover of its master.
|
Single<String> |
rxClusterForget(String nodeId)
Remove a node from the nodes table.
|
Single<String> |
rxClusterGetkeysinslot(long slot,
long count)
Return local key names in the specified hash slot.
|
Single<String> |
rxClusterInfo()
Provides info about Redis Cluster node state.
|
Single<String> |
rxClusterKeyslot(String key)
Returns the hash slot of the specified key.
|
Single<String> |
rxClusterMeet(String ip,
long port)
Force a node cluster to handshake with another node.
|
Single<String> |
rxClusterNodes()
Get Cluster config for the node.
|
Single<String> |
rxClusterReplicate(String nodeId)
Reconfigure a node as a slave of the specified master node.
|
Single<String> |
rxClusterReset()
Reset a Redis Cluster node.
|
Single<String> |
rxClusterResetWithOptions(ResetOptions options)
Reset a Redis Cluster node.
|
Single<String> |
rxClusterSaveconfig()
Forces the node to save cluster state on disk.
|
Single<String> |
rxClusterSetConfigEpoch(long epoch)
Set the configuration epoch in a new node.
|
Single<String> |
rxClusterSetslot(long slot,
SlotCmd subcommand)
Bind an hash slot to a specific node.
|
Single<String> |
rxClusterSetslotWithNode(long slot,
SlotCmd subcommand,
String nodeId)
Bind an hash slot to a specific node.
|
Single<String> |
rxClusterSlaves(String nodeId)
List slave nodes of the specified master node.
|
Single<String> |
rxClusterSlots()
Get array of Cluster slot to node mappings
|
Single<String> |
rxCommand()
Get array of Redis command details
|
Single<String> |
rxCommandCount()
Get total number of Redis commands
|
Single<String> |
rxCommandGetkeys()
Extract keys given a full Redis command
|
Single<String> |
rxCommandInfo(List<String> commands)
Get array of specific Redis command details
|
Single<String> |
rxConfigGet(String parameter)
Get the value of a configuration parameter
|
Single<String> |
rxConfigResetstat()
Reset the stats returned by INFO
|
Single<String> |
rxConfigRewrite()
Rewrite the configuration file with the in memory configuration
|
Single<String> |
rxConfigSet(String parameter,
String value)
Set a configuration parameter to the given value
|
Single<String> |
rxDbsize()
Return the number of keys in the selected database
|
Single<String> |
rxDebugObject(String key)
Get debugging information about a key
|
Single<String> |
rxDebugSegfault()
Make the server crash
|
Single<String> |
rxDecr(String key)
Decrement the integer value of a key by one
|
Single<String> |
rxDecrby(String key,
long decrement)
Decrement the integer value of a key by the given number
|
Single<String> |
rxDel(String key)
Delete a key
|
Single<String> |
rxDelMany(List<String> keys)
Delete many keys
|
Single<String> |
rxDiscard()
Discard all commands issued after MULTI
|
Single<String> |
rxDump(String key)
Return a serialized version of the value stored at the specified key.
|
Single<String> |
rxEcho(String message)
Echo the given string
|
Single<String> |
rxEval(String script,
List<String> keys,
List<String> args)
Execute a Lua script server side.
|
Single<String> |
rxEvalsha(String sha1,
List<String> keys,
List<String> values)
Execute a Lua script server side.
|
Single<JsonArray> |
rxExec()
Execute all commands issued after MULTI
|
Single<String> |
rxExists(String key)
Determine if a key exists
|
Single<String> |
rxExistsMany(List<String> keys)
Determine if one or many keys exist
|
Single<String> |
rxExpire(String key,
int seconds)
Set a key's time to live in seconds
|
Single<String> |
rxExpireat(String key,
long seconds)
Set the expiration for a key as a UNIX timestamp
|
Single<String> |
rxFlushall()
Remove all keys from all databases
|
Single<String> |
rxFlushdb()
Remove all keys from the current database
|
Single<String> |
rxGeoadd(String key,
double longitude,
double latitude,
String member)
Add one or more geospatial items in the geospatial index represented using a sorted set.
|
Single<String> |
rxGeoaddMany(String key,
List<GeoMember> members)
Add one or more geospatial items in the geospatial index represented using a sorted set.
|
Single<String> |
rxGeodist(String key,
String member1,
String member2)
Return the distance between two members in the geospatial index represented by the sorted set.
|
Single<String> |
rxGeodistWithUnit(String key,
String member1,
String member2,
GeoUnit unit)
Return the distance between two members in the geospatial index represented by the sorted set.
|
Single<String> |
rxGeohash(String key,
String member)
Return valid Geohash strings representing the position of one or more elements in a sorted set value representing
a geospatial index (where elements were added using GEOADD).
|
Single<String> |
rxGeohashMany(String key,
List<String> members)
Return valid Geohash strings representing the position of one or more elements in a sorted set value representing
a geospatial index (where elements were added using GEOADD).
|
Single<String> |
rxGeopos(String key,
String member)
Return the positions (longitude,latitude) of all the specified members of the geospatial index represented by the
sorted set at key.
|
Single<String> |
rxGeoposMany(String key,
List<String> members)
Return the positions (longitude,latitude) of all the specified members of the geospatial index represented by the
sorted set at key.
|
Single<String> |
rxGeoradius(String key,
double longitude,
double latitude,
double radius,
GeoUnit unit)
Return the members of a sorted set populated with geospatial information using GEOADD, which are within the borders
of the area specified with the center location and the maximum distance from the center (the radius).
|
Single<String> |
rxGeoradiusbymember(String key,
String member,
double radius,
GeoUnit unit)
This command is exactly like GEORADIUS with the sole difference that instead of taking, as the center of the area
to query, a longitude and latitude value, it takes the name of a member already existing inside the geospatial
index represented by the sorted set.
|
Single<String> |
rxGeoradiusbymemberWithOptions(String key,
String member,
double radius,
GeoUnit unit,
GeoRadiusOptions options)
This command is exactly like GEORADIUS with the sole difference that instead of taking, as the center of the area
to query, a longitude and latitude value, it takes the name of a member already existing inside the geospatial
index represented by the sorted set.
|
Single<String> |
rxGeoradiusWithOptions(String key,
double longitude,
double latitude,
double radius,
GeoUnit unit,
GeoRadiusOptions options)
Return the members of a sorted set populated with geospatial information using GEOADD, which are within the borders
of the area specified with the center location and the maximum distance from the center (the radius).
|
Single<String> |
rxGet(String key)
Get the value of a key
|
Single<Buffer> |
rxGetBinary(String key)
Get the value of a key - without decoding as utf-8
|
Single<String> |
rxGetbit(String key,
long offset)
Returns the bit value at offset in the string value stored at key
|
Single<String> |
rxGetrange(String key,
long start,
long end)
Get a substring of the string stored at a key
|
Single<String> |
rxGetset(String key,
String value)
Set the string value of a key and return its old value
|
Single<String> |
rxHdel(String key,
String field)
Delete one or more hash fields
|
Single<String> |
rxHdelMany(String key,
List<String> fields)
Delete one or more hash fields
|
Single<String> |
rxHexists(String key,
String field)
Determine if a hash field exists
|
Single<String> |
rxHget(String key,
String field)
Get the value of a hash field
|
Single<String> |
rxHgetall(String key)
Get all the fields and values in a hash
|
Single<String> |
rxHincrby(String key,
String field,
long increment)
Increment the integer value of a hash field by the given number
|
Single<String> |
rxHincrbyfloat(String key,
String field,
double increment)
Increment the float value of a hash field by the given amount
|
Single<String> |
rxHkeys(String key)
Get all the fields in a hash
|
Single<String> |
rxHlen(String key)
Get the number of fields in a hash
|
Single<String> |
rxHmget(String key,
List<String> fields)
Get the values of all the given hash fields
|
Single<String> |
rxHmset(String key,
JsonObject values)
Set multiple hash fields to multiple values
|
Single<String> |
rxHscan(String key,
String cursor,
ScanOptions options)
Incrementally iterate hash fields and associated values
|
Single<String> |
rxHset(String key,
String field,
String value)
Set the string value of a hash field
|
Single<String> |
rxHsetnx(String key,
String field,
String value)
Set the value of a hash field, only if the field does not exist
|
Single<String> |
rxHvals(String key)
Get all the values in a hash
|
Single<String> |
rxIncr(String key)
Increment the integer value of a key by one
|
Single<String> |
rxIncrby(String key,
long increment)
Increment the integer value of a key by the given amount
|
Single<String> |
rxIncrbyfloat(String key,
double increment)
Increment the float value of a key by the given amount
|
Single<String> |
rxInfo()
Get information and statistics about the server
|
Single<String> |
rxInfoSection(String section)
Get information and statistics about the server
|
Single<String> |
rxKeys(String pattern)
Find all keys matching the given pattern
|
Single<String> |
rxLastsave()
Get the UNIX time stamp of the last successful save to disk
|
Single<String> |
rxLindex(String key,
int index)
Get an element from a list by its index
|
Single<String> |
rxLinsert(String key,
InsertOptions option,
String pivot,
String value)
Insert an element before or after another element in a list
|
Single<String> |
rxLlen(String key)
Get the length of a list
|
Single<String> |
rxLpop(String key)
Remove and get the first element in a list
|
Single<String> |
rxLpush(String key,
String value)
Prepend one value to a list
|
Single<String> |
rxLpushMany(String key,
List<String> values)
Prepend one or multiple values to a list
|
Single<String> |
rxLpushx(String key,
String value)
Prepend a value to a list, only if the list exists
|
Single<String> |
rxLrange(String key,
long from,
long to)
Get a range of elements from a list
|
Single<String> |
rxLrem(String key,
long count,
String value)
Remove elements from a list
|
Single<String> |
rxLset(String key,
long index,
String value)
Set the value of an element in a list by its index
|
Single<String> |
rxLtrim(String key,
long from,
long to)
Trim a list to the specified range
|
Single<String> |
rxMget(String key)
Get the value of the given key
|
Single<String> |
rxMgetMany(List<String> keys)
Get the values of all the given keys
|
Single<String> |
rxMigrate(String host,
int port,
String key,
int destdb,
long timeout,
MigrateOptions options)
Atomically transfer a key from a Redis instance to another one.
|
Single<String> |
rxMonitor()
Listen for all requests received by the server in real time
|
Single<String> |
rxMove(String key,
int destdb)
Move a key to another database
|
Single<String> |
rxMset(JsonObject keyvals)
Set multiple keys to multiple values
|
Single<String> |
rxMsetnx(JsonObject keyvals)
Set multiple keys to multiple values, only if none of the keys exist
|
Single<String> |
rxMulti()
Mark the start of a RedisTransaction block
|
Single<String> |
rxObject(String key,
ObjectCmd cmd)
Inspect the internals of Redis objects
|
Single<String> |
rxPersist(String key)
Remove the expiration from a key
|
Single<String> |
rxPexpire(String key,
long millis)
Set a key's time to live in milliseconds
|
Single<String> |
rxPexpireat(String key,
long millis)
Set the expiration for a key as a UNIX timestamp specified in milliseconds
|
Single<String> |
rxPfadd(String key,
String element)
Adds the specified element to the specified HyperLogLog.
|
Single<String> |
rxPfaddMany(String key,
List<String> elements)
Adds the specified elements to the specified HyperLogLog.
|
Single<String> |
rxPfcount(String key)
Return the approximated cardinality of the set observed by the HyperLogLog at key.
|
Single<String> |
rxPfcountMany(List<String> keys)
Return the approximated cardinality of the set(s) observed by the HyperLogLog at key(s).
|
Single<String> |
rxPfmerge(String destkey,
List<String> keys)
Merge N different HyperLogLogs into a single one.
|
Single<String> |
rxPing()
Ping the server
|
Single<String> |
rxPsetex(String key,
long millis,
String value)
Set the value and expiration in milliseconds of a key
|
Single<String> |
rxPsubscribe(String pattern)
Listen for messages published to channels matching the given pattern
|
Single<String> |
rxPsubscribeMany(List<String> patterns)
Listen for messages published to channels matching the given patterns
|
Single<String> |
rxPttl(String key)
Get the time to live for a key in milliseconds
|
Single<String> |
rxPublish(String channel,
String message)
Post a message to a channel
|
Single<String> |
rxPubsubChannels(String pattern)
Lists the currently active channels - only those matching the pattern
|
Single<String> |
rxPubsubNumpat()
Returns the number of subscriptions to patterns (that are performed using the PSUBSCRIBE command)
|
Single<String> |
rxPubsubNumsub(List<String> channels)
Returns the number of subscribers (not counting clients subscribed to patterns) for the specified channels
|
Single<String> |
rxPunsubscribe(List<String> patterns)
Stop listening for messages posted to channels matching the given patterns
|
Single<String> |
rxRandomkey()
Return a random key from the keyspace
|
Single<String> |
rxRename(String key,
String newkey)
Rename a key
|
Single<String> |
rxRenamenx(String key,
String newkey)
Rename a key, only if the new key does not exist
|
Single<String> |
rxRestore(String key,
long millis,
String serialized)
Create a key using the provided serialized value, previously obtained using DUMP.
|
Single<String> |
rxRole()
Return the role of the instance in the context of replication
|
Single<String> |
rxRpop(String key)
Remove and get the last element in a list
|
Single<String> |
rxRpoplpush(String key,
String destkey)
Remove the last element in a list, append it to another list and return it
|
Single<String> |
rxRpush(String key,
String value)
Append one or multiple values to a list
|
Single<String> |
rxRpushMany(String key,
List<String> values)
Append one or multiple values to a list
|
Single<String> |
rxRpushx(String key,
String value)
Append a value to a list, only if the list exists
|
Single<String> |
rxSadd(String key,
String member)
Add a member to a set
|
Single<String> |
rxSaddMany(String key,
List<String> members)
Add one or more members to a set
|
Single<String> |
rxSave()
Synchronously save the dataset to disk
|
Single<String> |
rxScan(String cursor,
ScanOptions options)
Incrementally iterate the keys space
|
Single<String> |
rxScard(String key)
Get the number of members in a set
|
Single<String> |
rxScriptExists(String script)
Check existence of script in the script cache.
|
Single<String> |
rxScriptExistsMany(List<String> scripts)
Check existence of scripts in the script cache.
|
Single<String> |
rxScriptFlush()
Remove all the scripts from the script cache.
|
Single<String> |
rxScriptKill()
Kill the script currently in execution.
|
Single<String> |
rxScriptLoad(String script)
Load the specified Lua script into the script cache.
|
Single<String> |
rxSdiff(String key,
List<String> cmpkeys)
Subtract multiple sets
|
Single<String> |
rxSdiffstore(String destkey,
String key,
List<String> cmpkeys)
Subtract multiple sets and store the resulting set in a key
|
Single<String> |
rxSelect(int dbindex)
Change the selected database for the current connection
|
Single<String> |
rxSet(String key,
String value)
Set the string value of a key
|
Single<String> |
rxSetBinary(String key,
Buffer value)
Set the binary string value of a key - without encoding as utf-8
|
Single<String> |
rxSetBinaryWithOptions(String key,
Buffer value,
SetOptions options)
Set the string value of a key
|
Single<String> |
rxSetbit(String key,
long offset,
int bit)
Sets or clears the bit at offset in the string value stored at key
|
Single<String> |
rxSetex(String key,
long seconds,
String value)
Set the value and expiration of a key
|
Single<String> |
rxSetnx(String key,
String value)
Set the value of a key, only if the key does not exist
|
Single<String> |
rxSetrange(String key,
int offset,
String value)
Overwrite part of a string at key starting at the specified offset
|
Single<String> |
rxSetWithOptions(String key,
String value,
SetOptions options)
Set the string value of a key
|
Single<String> |
rxSinter(List<String> keys)
Intersect multiple sets
|
Single<String> |
rxSinterstore(String destkey,
List<String> keys)
Intersect multiple sets and store the resulting set in a key
|
Single<String> |
rxSismember(String key,
String member)
Determine if a given value is a member of a set
|
Single<String> |
rxSlaveof(String host,
int port)
Make the server a slave of another instance
|
Single<String> |
rxSlaveofNoone()
Make this server a master
|
Single<String> |
rxSlowlogGet(int limit)
Read the Redis slow queries log
|
Single<String> |
rxSlowlogLen()
Get the length of the Redis slow queries log
|
Single<String> |
rxSlowlogReset()
Reset the Redis slow queries log
|
Single<JsonArray> |
rxSmembers(String key)
Get all the members in a set
|
Single<String> |
rxSmove(String key,
String destkey,
String member)
Move a member from one set to another
|
Single<String> |
rxSort(String key,
SortOptions options)
Sort the elements in a list, set or sorted set
|
Single<String> |
rxSpop(String key)
Remove and return a random member from a set
|
Single<String> |
rxSpopMany(String key,
int count)
Remove and return random members from a set
|
Single<String> |
rxSrandmember(String key)
Get one or multiple random members from a set
|
Single<String> |
rxSrandmemberCount(String key,
int count)
Get one or multiple random members from a set
|
Single<String> |
rxSrem(String key,
String member)
Remove one member from a set
|
Single<String> |
rxSremMany(String key,
List<String> members)
Remove one or more members from a set
|
Single<String> |
rxSscan(String key,
String cursor,
ScanOptions options)
Incrementally iterate Set elements
|
Single<String> |
rxStrlen(String key)
Get the length of the value stored in a key
|
Single<String> |
rxSubscribe(String channel)
Listen for messages published to the given channels
|
Single<String> |
rxSubscribeMany(List<String> channels)
Listen for messages published to the given channels
|
Single<String> |
rxSunion(List<String> keys)
Add multiple sets
|
Single<String> |
rxSunionstore(String destkey,
List<String> keys)
Add multiple sets and store the resulting set in a key
|
Single<String> |
rxSwapdb(int index1,
int index2)
Swaps two Redis databases
|
Single<String> |
rxSync()
Internal command used for replication
|
Single<String> |
rxTime()
Return the current server time
|
Single<String> |
rxTtl(String key)
Get the time to live for a key
|
Single<String> |
rxType(String key)
Determine the type stored at key
|
Single<String> |
rxUnlink(String key)
Delete a key asynchronously in another thread.
|
Single<String> |
rxUnlinkMany(List<String> keys)
Delete multiple keys asynchronously in another thread.
|
Single<String> |
rxUnsubscribe(List<String> channels)
Stop listening for messages posted to the given channels
|
Single<String> |
rxUnwatch()
Forget about all watched keys
|
Single<String> |
rxWait(long numSlaves,
long timeout)
Wait for the synchronous replication of all the write commands sent in the context of the current connection.
|
Single<String> |
rxWatch(String key)
Watch the given keys to determine execution of the MULTI/EXEC block
|
Single<String> |
rxWatchMany(List<String> keys)
Watch the given keys to determine execution of the MULTI/EXEC block
|
Single<String> |
rxZadd(String key,
double score,
String member)
Add one or more members to a sorted set, or update its score if it already exists
|
Single<String> |
rxZaddMany(String key,
Map<String,Double> members)
Add one or more members to a sorted set, or update its score if it already exists
|
Single<String> |
rxZcard(String key)
Get the number of members in a sorted set
|
Single<String> |
rxZcount(String key,
double min,
double max)
Count the members in a sorted set with scores within the given values
|
Single<String> |
rxZincrby(String key,
double increment,
String member)
Increment the score of a member in a sorted set
|
Single<String> |
rxZinterstore(String destkey,
List<String> sets,
AggregateOptions options)
Intersect multiple sorted sets and store the resulting sorted set in a new key
|
Single<String> |
rxZinterstoreWeighed(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
|
Single<String> |
rxZlexcount(String key,
String min,
String max)
Count the number of members in a sorted set between a given lexicographical range
|
Single<String> |
rxZrange(String key,
long start,
long stop)
Return a range of members in a sorted set, by index
|
Single<String> |
rxZrangebylex(String key,
String min,
String max,
LimitOptions options)
Return a range of members in a sorted set, by lexicographical range
|
Single<String> |
rxZrangebyscore(String key,
String min,
String max,
RangeLimitOptions options)
Return a range of members in a sorted set, by score
|
Single<String> |
rxZrangeWithOptions(String key,
long start,
long stop,
RangeOptions options)
Return a range of members in a sorted set, by index
|
Single<String> |
rxZrank(String key,
String member)
Determine the index of a member in a sorted set
|
Single<String> |
rxZrem(String key,
String member)
Remove one member from a sorted set
|
Single<String> |
rxZremMany(String key,
List<String> members)
Remove one or more members from a sorted set
|
Single<String> |
rxZremrangebylex(String key,
String min,
String max)
Remove all members in a sorted set between the given lexicographical range
|
Single<String> |
rxZremrangebyrank(String key,
long start,
long stop)
Remove all members in a sorted set within the given indexes
|
Single<String> |
rxZremrangebyscore(String key,
String min,
String max)
Remove all members in a sorted set within the given scores
|
Single<String> |
rxZrevrange(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
|
Single<String> |
rxZrevrangebylex(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
|
Single<String> |
rxZrevrangebyscore(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
|
Single<String> |
rxZrevrank(String key,
String member)
Determine the index of a member in a sorted set, with scores ordered from high to low
|
Single<String> |
rxZscan(String key,
String cursor,
ScanOptions options)
Incrementally iterate sorted sets elements and associated scores
|
Single<String> |
rxZscore(String key,
String member)
Get the score associated with the given member in a sorted set
|
Single<String> |
rxZunionstore(String destkey,
List<String> sets,
AggregateOptions options)
Add multiple sorted sets and store the resulting sorted set in a new key
|
Single<String> |
rxZunionstoreWeighed(String key,
Map<String,Double> sets,
AggregateOptions options)
Add multiple sorted sets using weights, and store the resulting sorted set in a new key
|
RedisTransaction |
sadd(String key,
String member,
Handler<AsyncResult<String>> handler)
Add a member to a set
|
RedisTransaction |
saddMany(String key,
List<String> members,
Handler<AsyncResult<String>> handler)
Add one or more members to a set
|
RedisTransaction |
save(Handler<AsyncResult<String>> handler)
Synchronously save the dataset to disk
|
RedisTransaction |
scan(String cursor,
ScanOptions options,
Handler<AsyncResult<String>> handler)
Incrementally iterate the keys space
|
RedisTransaction |
scard(String key,
Handler<AsyncResult<String>> handler)
Get the number of members in a set
|
RedisTransaction |
scriptExists(String script,
Handler<AsyncResult<String>> handler)
Check existence of script in the script cache.
|
RedisTransaction |
scriptExistsMany(List<String> scripts,
Handler<AsyncResult<String>> handler)
Check existence of scripts in the script cache.
|
RedisTransaction |
scriptFlush(Handler<AsyncResult<String>> handler)
Remove all the scripts from the script cache.
|
RedisTransaction |
scriptKill(Handler<AsyncResult<String>> handler)
Kill the script currently in execution.
|
RedisTransaction |
scriptLoad(String script,
Handler<AsyncResult<String>> handler)
Load the specified Lua script into the script cache.
|
RedisTransaction |
sdiff(String key,
List<String> cmpkeys,
Handler<AsyncResult<String>> handler)
Subtract multiple sets
|
RedisTransaction |
sdiffstore(String destkey,
String key,
List<String> cmpkeys,
Handler<AsyncResult<String>> handler)
Subtract multiple sets and store the resulting set in a key
|
RedisTransaction |
select(int dbindex,
Handler<AsyncResult<String>> handler)
Change the selected database for the current connection
|
RedisTransaction |
set(String key,
String value,
Handler<AsyncResult<String>> handler)
Set the string value of a key
|
RedisTransaction |
setBinary(String key,
Buffer value,
Handler<AsyncResult<String>> handler)
Set the binary string value of a key - without encoding as utf-8
|
RedisTransaction |
setBinaryWithOptions(String key,
Buffer value,
SetOptions options,
Handler<AsyncResult<String>> handler)
Set the string value of a key
|
RedisTransaction |
setbit(String key,
long offset,
int bit,
Handler<AsyncResult<String>> handler)
Sets or clears the bit at offset in the string value stored at key
|
RedisTransaction |
setex(String key,
long seconds,
String value,
Handler<AsyncResult<String>> handler)
Set the value and expiration of a key
|
RedisTransaction |
setnx(String key,
String value,
Handler<AsyncResult<String>> handler)
Set the value of a key, only if the key does not exist
|
RedisTransaction |
setrange(String key,
int offset,
String value,
Handler<AsyncResult<String>> handler)
Overwrite part of a string at key starting at the specified offset
|
RedisTransaction |
setWithOptions(String key,
String value,
SetOptions options,
Handler<AsyncResult<String>> handler)
Set the string value of a key
|
RedisTransaction |
sinter(List<String> keys,
Handler<AsyncResult<String>> handler)
Intersect multiple sets
|
RedisTransaction |
sinterstore(String destkey,
List<String> keys,
Handler<AsyncResult<String>> handler)
Intersect multiple sets and store the resulting set in a key
|
RedisTransaction |
sismember(String key,
String member,
Handler<AsyncResult<String>> handler)
Determine if a given value is a member of a set
|
RedisTransaction |
slaveof(String host,
int port,
Handler<AsyncResult<String>> handler)
Make the server a slave of another instance
|
RedisTransaction |
slaveofNoone(Handler<AsyncResult<String>> handler)
Make this server a master
|
RedisTransaction |
slowlogGet(int limit,
Handler<AsyncResult<String>> handler)
Read the Redis slow queries log
|
RedisTransaction |
slowlogLen(Handler<AsyncResult<String>> handler)
Get the length of the Redis slow queries log
|
RedisTransaction |
slowlogReset(Handler<AsyncResult<String>> handler)
Reset the Redis slow queries log
|
RedisTransaction |
smembers(String key,
Handler<AsyncResult<JsonArray>> handler)
Get all the members in a set
|
RedisTransaction |
smove(String key,
String destkey,
String member,
Handler<AsyncResult<String>> handler)
Move a member from one set to another
|
RedisTransaction |
sort(String key,
SortOptions options,
Handler<AsyncResult<String>> handler)
Sort the elements in a list, set or sorted set
|
RedisTransaction |
spop(String key,
Handler<AsyncResult<String>> handler)
Remove and return a random member from a set
|
RedisTransaction |
spopMany(String key,
int count,
Handler<AsyncResult<String>> handler)
Remove and return random members from a set
|
RedisTransaction |
srandmember(String key,
Handler<AsyncResult<String>> handler)
Get one or multiple random members from a set
|
RedisTransaction |
srandmemberCount(String key,
int count,
Handler<AsyncResult<String>> handler)
Get one or multiple random members from a set
|
RedisTransaction |
srem(String key,
String member,
Handler<AsyncResult<String>> handler)
Remove one member from a set
|
RedisTransaction |
sremMany(String key,
List<String> members,
Handler<AsyncResult<String>> handler)
Remove one or more members from a set
|
RedisTransaction |
sscan(String key,
String cursor,
ScanOptions options,
Handler<AsyncResult<String>> handler)
Incrementally iterate Set elements
|
RedisTransaction |
strlen(String key,
Handler<AsyncResult<String>> handler)
Get the length of the value stored in a key
|
RedisTransaction |
subscribe(String channel,
Handler<AsyncResult<String>> handler)
Listen for messages published to the given channels
|
RedisTransaction |
subscribeMany(List<String> channels,
Handler<AsyncResult<String>> handler)
Listen for messages published to the given channels
|
RedisTransaction |
sunion(List<String> keys,
Handler<AsyncResult<String>> handler)
Add multiple sets
|
RedisTransaction |
sunionstore(String destkey,
List<String> keys,
Handler<AsyncResult<String>> handler)
Add multiple sets and store the resulting set in a key
|
RedisTransaction |
swapdb(int index1,
int index2,
Handler<AsyncResult<String>> handler)
Swaps two Redis databases
|
RedisTransaction |
sync(Handler<AsyncResult<String>> handler)
Internal command used for replication
|
RedisTransaction |
time(Handler<AsyncResult<String>> handler)
Return the current server time
|
String |
toString() |
RedisTransaction |
ttl(String key,
Handler<AsyncResult<String>> handler)
Get the time to live for a key
|
RedisTransaction |
type(String key,
Handler<AsyncResult<String>> handler)
Determine the type stored at key
|
RedisTransaction |
unlink(String key,
Handler<AsyncResult<String>> handler)
Delete a key asynchronously in another thread.
|
RedisTransaction |
unlinkMany(List<String> keys,
Handler<AsyncResult<String>> handler)
Delete multiple keys asynchronously in another thread.
|
RedisTransaction |
unsubscribe(List<String> channels,
Handler<AsyncResult<String>> handler)
Stop listening for messages posted to the given channels
|
RedisTransaction |
unwatch(Handler<AsyncResult<String>> handler)
Forget about all watched keys
|
RedisTransaction |
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.
|
RedisTransaction |
watch(String key,
Handler<AsyncResult<String>> handler)
Watch the given keys to determine execution of the MULTI/EXEC block
|
RedisTransaction |
watchMany(List<String> keys,
Handler<AsyncResult<String>> handler)
Watch the given keys to determine execution of the MULTI/EXEC block
|
RedisTransaction |
zadd(String key,
double score,
String member,
Handler<AsyncResult<String>> handler)
Add one or more members to a sorted set, or update its score if it already exists
|
RedisTransaction |
zaddMany(String key,
Map<String,Double> members,
Handler<AsyncResult<String>> handler)
Add one or more members to a sorted set, or update its score if it already exists
|
RedisTransaction |
zcard(String key,
Handler<AsyncResult<String>> handler)
Get the number of members in a sorted set
|
RedisTransaction |
zcount(String key,
double min,
double max,
Handler<AsyncResult<String>> handler)
Count the members in a sorted set with scores within the given values
|
RedisTransaction |
zincrby(String key,
double increment,
String member,
Handler<AsyncResult<String>> handler)
Increment the score of a member in a sorted set
|
RedisTransaction |
zinterstore(String destkey,
List<String> sets,
AggregateOptions options,
Handler<AsyncResult<String>> handler)
Intersect multiple sorted sets and store the resulting sorted set in a new key
|
RedisTransaction |
zinterstoreWeighed(String destkey,
Map<String,Double> sets,
AggregateOptions options,
Handler<AsyncResult<String>> handler)
Intersect multiple sorted sets and store the resulting sorted set in a new key using weights for scoring
|
RedisTransaction |
zlexcount(String key,
String min,
String max,
Handler<AsyncResult<String>> handler)
Count the number of members in a sorted set between a given lexicographical range
|
RedisTransaction |
zrange(String key,
long start,
long stop,
Handler<AsyncResult<String>> handler)
Return a range of members in a sorted set, by index
|
RedisTransaction |
zrangebylex(String key,
String min,
String max,
LimitOptions options,
Handler<AsyncResult<String>> handler)
Return a range of members in a sorted set, by lexicographical range
|
RedisTransaction |
zrangebyscore(String key,
String min,
String max,
RangeLimitOptions options,
Handler<AsyncResult<String>> handler)
Return a range of members in a sorted set, by score
|
RedisTransaction |
zrangeWithOptions(String key,
long start,
long stop,
RangeOptions options,
Handler<AsyncResult<String>> handler)
Return a range of members in a sorted set, by index
|
RedisTransaction |
zrank(String key,
String member,
Handler<AsyncResult<String>> handler)
Determine the index of a member in a sorted set
|
RedisTransaction |
zrem(String key,
String member,
Handler<AsyncResult<String>> handler)
Remove one member from a sorted set
|
RedisTransaction |
zremMany(String key,
List<String> members,
Handler<AsyncResult<String>> handler)
Remove one or more members from a sorted set
|
RedisTransaction |
zremrangebylex(String key,
String min,
String max,
Handler<AsyncResult<String>> handler)
Remove all members in a sorted set between the given lexicographical range
|
RedisTransaction |
zremrangebyrank(String key,
long start,
long stop,
Handler<AsyncResult<String>> handler)
Remove all members in a sorted set within the given indexes
|
RedisTransaction |
zremrangebyscore(String key,
String min,
String max,
Handler<AsyncResult<String>> handler)
Remove all members in a sorted set within the given scores
|
RedisTransaction |
zrevrange(String key,
long start,
long stop,
RangeOptions options,
Handler<AsyncResult<String>> handler)
Return a range of members in a sorted set, by index, with scores ordered from high to low
|
RedisTransaction |
zrevrangebylex(String key,
String max,
String min,
LimitOptions options,
Handler<AsyncResult<String>> handler)
Return a range of members in a sorted set, by score, between the given lexicographical range with scores ordered from high to low
|
RedisTransaction |
zrevrangebyscore(String key,
String max,
String min,
RangeLimitOptions options,
Handler<AsyncResult<String>> handler)
Return a range of members in a sorted set, by score, with scores ordered from high to low
|
RedisTransaction |
zrevrank(String key,
String member,
Handler<AsyncResult<String>> handler)
Determine the index of a member in a sorted set, with scores ordered from high to low
|
RedisTransaction |
zscan(String key,
String cursor,
ScanOptions options,
Handler<AsyncResult<String>> handler)
Incrementally iterate sorted sets elements and associated scores
|
RedisTransaction |
zscore(String key,
String member,
Handler<AsyncResult<String>> handler)
Get the score associated with the given member in a sorted set
|
RedisTransaction |
zunionstore(String destkey,
List<String> sets,
AggregateOptions options,
Handler<AsyncResult<String>> handler)
Add multiple sorted sets and store the resulting sorted set in a new key
|
RedisTransaction |
zunionstoreWeighed(String key,
Map<String,Double> sets,
AggregateOptions options,
Handler<AsyncResult<String>> handler)
Add multiple sorted sets using weights, and store the resulting sorted set in a new key
|
public static final io.vertx.lang.rx.TypeArg<RedisTransaction> __TYPE_ARG
public RedisTransaction(RedisTransaction delegate)
public RedisTransaction(Object delegate)
public RedisTransaction getDelegate()
public void close(Handler<AsyncResult<Void>> handler)
handler
- public Completable rxClose()
public RedisTransaction append(String key, String value, Handler<AsyncResult<String>> handler)
key
- Key stringvalue
- Value to appendhandler
- Handler for the result of this call.public Single<String> rxAppend(String key, String value)
key
- Key stringvalue
- Value to appendpublic RedisTransaction auth(String password, Handler<AsyncResult<String>> handler)
password
- Password for authenticationhandler
- Handler for the result of this call.public Single<String> rxAuth(String password)
password
- Password for authenticationpublic RedisTransaction bgrewriteaof(Handler<AsyncResult<String>> handler)
handler
- public Single<String> rxBgrewriteaof()
public RedisTransaction bgsave(Handler<AsyncResult<String>> handler)
handler
- public RedisTransaction bitcount(String key, Handler<AsyncResult<String>> handler)
key
- Key stringhandler
- Handler for the result of this call.public Single<String> rxBitcount(String key)
key
- Key stringpublic RedisTransaction bitcountRange(String key, long start, long end, Handler<AsyncResult<String>> handler)
key
- Key stringstart
- Start indexend
- End indexhandler
- Handler for the result of this call.public Single<String> rxBitcountRange(String key, long start, long end)
key
- Key stringstart
- Start indexend
- End indexpublic RedisTransaction bitop(BitOperation operation, String destkey, List<String> keys, Handler<AsyncResult<String>> 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 Single<String> rxBitop(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 RedisTransaction bitpos(String key, int bit, Handler<AsyncResult<String>> handler)
key
- Key stringbit
- What bit value to look for - must be 1, or 0handler
- Handler for the result of this call.public Single<String> rxBitpos(String key, int bit)
key
- Key stringbit
- What bit value to look for - must be 1, or 0public RedisTransaction bitposFrom(String key, int bit, int start, Handler<AsyncResult<String>> handler)
See also bitposRange() method, which takes start, and stop offset.
key
- Key stringbit
- What bit value to look for - must be 1, or 0start
- Start offsethandler
- Handler for the result of this call.public Single<String> rxBitposFrom(String key, int bit, int start)
See also bitposRange() method, which takes start, and stop offset.
key
- Key stringbit
- What bit value to look for - must be 1, or 0start
- Start offsetpublic RedisTransaction bitposRange(String key, int bit, int start, int stop, Handler<AsyncResult<String>> handler)
Note: when both start, and stop offsets are specified, behaviour is slightly different than if only start is specified
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 Single<String> rxBitposRange(String key, int bit, int start, int stop)
Note: when both start, and stop offsets are specified, behaviour is slightly different than if only start is specified
key
- Key stringbit
- What bit value to look for - must be 1, or 0start
- Start offsetstop
- End offset - inclusivepublic RedisTransaction blpop(String key, int seconds, Handler<AsyncResult<String>> handler)
key
- Key string identifying a list to watchseconds
- Timeout in secondshandler
- Handler for the result of this call.public Single<String> rxBlpop(String key, int seconds)
key
- Key string identifying a list to watchseconds
- Timeout in secondspublic RedisTransaction blpopMany(List<String> keys, int seconds, Handler<AsyncResult<String>> handler)
keys
- List of key strings identifying lists to watchseconds
- Timeout in secondshandler
- Handler for the result of this call.public Single<String> rxBlpopMany(List<String> keys, int seconds)
keys
- List of key strings identifying lists to watchseconds
- Timeout in secondspublic RedisTransaction brpop(String key, int seconds, Handler<AsyncResult<String>> handler)
key
- Key string identifying a list to watchseconds
- Timeout in secondshandler
- Handler for the result of this call.public Single<String> rxBrpop(String key, int seconds)
key
- Key string identifying a list to watchseconds
- Timeout in secondspublic RedisTransaction brpopMany(List<String> keys, int seconds, Handler<AsyncResult<String>> handler)
keys
- List of key strings identifying lists to watchseconds
- Timeout in secondshandler
- Handler for the result of this call.public Single<String> rxBrpopMany(List<String> keys, int seconds)
keys
- List of key strings identifying lists to watchseconds
- Timeout in secondspublic RedisTransaction 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 Single<String> rxBrpoplpush(String key, String destkey, int seconds)
key
- Key string identifying the source listdestkey
- Key string identifying the destination listseconds
- Timeout in secondspublic RedisTransaction clientKill(KillFilter filter, Handler<AsyncResult<String>> handler)
filter
- Filter optionshandler
- Handler for the result of this call.public Single<String> rxClientKill(KillFilter filter)
filter
- Filter optionspublic RedisTransaction clientList(Handler<AsyncResult<String>> handler)
handler
- public RedisTransaction clientGetname(Handler<AsyncResult<String>> handler)
handler
- public RedisTransaction clientPause(long millis, Handler<AsyncResult<String>> handler)
millis
- Pause time in millisecondshandler
- Handler for the result of this call.public Single<String> rxClientPause(long millis)
millis
- Pause time in millisecondspublic RedisTransaction clientSetname(String name, Handler<AsyncResult<String>> handler)
name
- New name for current connectionhandler
- Handler for the result of this call.public Single<String> rxClientSetname(String name)
name
- New name for current connectionpublic RedisTransaction clusterAddslots(List<String> slots, Handler<AsyncResult<String>> handler)
slots
- handler
- Handler for the result of this call.public Single<String> rxClusterAddslots(List<String> slots)
slots
- public RedisTransaction clusterCountFailureReports(String nodeId, Handler<AsyncResult<String>> handler)
nodeId
- handler
- Handler for the result of this call.public Single<String> rxClusterCountFailureReports(String nodeId)
nodeId
- public RedisTransaction clusterCountkeysinslot(long slot, Handler<AsyncResult<String>> handler)
slot
- handler
- Handler for the result of this call.public Single<String> rxClusterCountkeysinslot(long slot)
slot
- public RedisTransaction clusterDelslots(long slot, Handler<AsyncResult<String>> handler)
slot
- handler
- Handler for the result of this call.public Single<String> rxClusterDelslots(long slot)
slot
- public RedisTransaction clusterDelslotsMany(List<String> slots, Handler<AsyncResult<String>> handler)
slots
- handler
- Handler for the result of this call.public Single<String> rxClusterDelslotsMany(List<String> slots)
slots
- public RedisTransaction clusterFailover(Handler<AsyncResult<String>> handler)
handler
- Handler for the result of this call.public Single<String> rxClusterFailover()
public RedisTransaction clusterFailOverWithOptions(FailoverOptions options, Handler<AsyncResult<String>> handler)
options
- handler
- Handler for the result of this call.public Single<String> rxClusterFailOverWithOptions(FailoverOptions options)
options
- public RedisTransaction clusterForget(String nodeId, Handler<AsyncResult<String>> handler)
nodeId
- handler
- Handler for the result of this call.public Single<String> rxClusterForget(String nodeId)
nodeId
- public RedisTransaction clusterGetkeysinslot(long slot, long count, Handler<AsyncResult<String>> handler)
slot
- count
- handler
- Handler for the result of this call.public Single<String> rxClusterGetkeysinslot(long slot, long count)
slot
- count
- public RedisTransaction clusterInfo(Handler<AsyncResult<String>> handler)
handler
- Handler for the result of this call.public Single<String> rxClusterInfo()
public RedisTransaction clusterKeyslot(String key, Handler<AsyncResult<String>> handler)
key
- handler
- Handler for the result of this call.public Single<String> rxClusterKeyslot(String key)
key
- public RedisTransaction clusterMeet(String ip, long port, Handler<AsyncResult<String>> handler)
ip
- port
- handler
- Handler for the result of this call.public Single<String> rxClusterMeet(String ip, long port)
ip
- port
- public RedisTransaction clusterNodes(Handler<AsyncResult<String>> handler)
handler
- Handler for the result of this call.public RedisTransaction clusterReplicate(String nodeId, Handler<AsyncResult<String>> handler)
nodeId
- handler
- Handler for the result of this call.public Single<String> rxClusterReplicate(String nodeId)
nodeId
- public RedisTransaction clusterReset(Handler<AsyncResult<String>> handler)
handler
- Handler for the result of this call.public RedisTransaction clusterResetWithOptions(ResetOptions options, Handler<AsyncResult<String>> handler)
options
- handler
- Handler for the result of this call.public Single<String> rxClusterResetWithOptions(ResetOptions options)
options
- public RedisTransaction clusterSaveconfig(Handler<AsyncResult<String>> handler)
handler
- Handler for the result of this call.public Single<String> rxClusterSaveconfig()
public RedisTransaction clusterSetConfigEpoch(long epoch, Handler<AsyncResult<String>> handler)
epoch
- handler
- Handler for the result of this call.public Single<String> rxClusterSetConfigEpoch(long epoch)
epoch
- public RedisTransaction clusterSetslot(long slot, SlotCmd subcommand, Handler<AsyncResult<String>> handler)
slot
- subcommand
- handler
- Handler for the result of this call.public Single<String> rxClusterSetslot(long slot, SlotCmd subcommand)
slot
- subcommand
- public RedisTransaction clusterSetslotWithNode(long slot, SlotCmd subcommand, String nodeId, Handler<AsyncResult<String>> handler)
slot
- subcommand
- nodeId
- handler
- Handler for the result of this call.public Single<String> rxClusterSetslotWithNode(long slot, SlotCmd subcommand, String nodeId)
slot
- subcommand
- nodeId
- public RedisTransaction clusterSlaves(String nodeId, Handler<AsyncResult<String>> handler)
nodeId
- handler
- Handler for the result of this call.public Single<String> rxClusterSlaves(String nodeId)
nodeId
- public RedisTransaction clusterSlots(Handler<AsyncResult<String>> handler)
handler
- public Single<String> rxClusterSlots()
public RedisTransaction command(Handler<AsyncResult<String>> handler)
handler
- public RedisTransaction commandCount(Handler<AsyncResult<String>> handler)
handler
- public RedisTransaction commandGetkeys(Handler<AsyncResult<String>> handler)
handler
- public Single<String> rxCommandGetkeys()
public RedisTransaction commandInfo(List<String> commands, Handler<AsyncResult<String>> handler)
commands
- List of commands to get info forhandler
- Handler for the result of this call.public Single<String> rxCommandInfo(List<String> commands)
commands
- List of commands to get info forpublic RedisTransaction configGet(String parameter, Handler<AsyncResult<String>> handler)
parameter
- Configuration parameterhandler
- Handler for the result of this call.public Single<String> rxConfigGet(String parameter)
parameter
- Configuration parameterpublic RedisTransaction configRewrite(Handler<AsyncResult<String>> handler)
handler
- public Single<String> rxConfigRewrite()
public RedisTransaction configSet(String parameter, String value, Handler<AsyncResult<String>> handler)
parameter
- Configuration parametervalue
- New valuehandler
- Handler for the result of this call.public Single<String> rxConfigSet(String parameter, String value)
parameter
- Configuration parametervalue
- New valuepublic RedisTransaction configResetstat(Handler<AsyncResult<String>> handler)
handler
- public Single<String> rxConfigResetstat()
public RedisTransaction dbsize(Handler<AsyncResult<String>> handler)
handler
- public Single<String> rxDbsize()
public RedisTransaction debugObject(String key, Handler<AsyncResult<String>> handler)
key
- Key stringhandler
- Handler for the result of this call.public Single<String> rxDebugObject(String key)
key
- Key stringpublic RedisTransaction debugSegfault(Handler<AsyncResult<String>> handler)
handler
- public RedisTransaction decr(String key, Handler<AsyncResult<String>> handler)
key
- Key stringhandler
- Handler for the result of this call.public Single<String> rxDecr(String key)
key
- Key stringpublic RedisTransaction decrby(String key, long decrement, Handler<AsyncResult<String>> handler)
key
- Key stringdecrement
- Value by which to decrementhandler
- Handler for the result of this call.public Single<String> rxDecrby(String key, long decrement)
key
- Key stringdecrement
- Value by which to decrementpublic RedisTransaction del(String key, Handler<AsyncResult<String>> handler)
key
- Keys to deletehandler
- Handler for the result of this call.public Single<String> rxDel(String key)
key
- Keys to deletepublic RedisTransaction delMany(List<String> keys, Handler<AsyncResult<String>> handler)
keys
- List of keys to deletehandler
- Handler for the result of this call.public Single<String> rxDelMany(List<String> keys)
keys
- List of keys to deletepublic RedisTransaction discard(Handler<AsyncResult<String>> handler)
handler
- public RedisTransaction dump(String key, Handler<AsyncResult<String>> handler)
key
- Key stringhandler
- Handler for the result of this call.public Single<String> rxDump(String key)
key
- Key stringpublic RedisTransaction echo(String message, Handler<AsyncResult<String>> handler)
message
- String to echohandler
- Handler for the result of this call.public Single<String> rxEcho(String message)
message
- String to echopublic RedisTransaction eval(String script, List<String> keys, List<String> args, Handler<AsyncResult<String>> handler)
When a reply if for example a String the handler will be called with a JsonArray with a single element containing the String.
script
- Lua script to evaluatekeys
- List of keysargs
- List of argument valueshandler
- Handler for the result of this call.public Single<String> rxEval(String script, List<String> keys, List<String> args)
When a reply if for example a String the handler will be called with a JsonArray with a single element containing the String.
script
- Lua script to evaluatekeys
- List of keysargs
- List of argument valuespublic RedisTransaction evalsha(String sha1, List<String> keys, List<String> values, Handler<AsyncResult<String>> handler)
When a reply if for example a String the handler will be called with a JsonArray with a single element containing the String.
sha1
- SHA1 digest of the script cached on the serverkeys
- List of keysvalues
- List of valueshandler
- Handler for the result of this call.public Single<String> rxEvalsha(String sha1, List<String> keys, List<String> values)
When a reply if for example a String the handler will be called with a JsonArray with a single element containing the String.
sha1
- SHA1 digest of the script cached on the serverkeys
- List of keysvalues
- List of valuespublic RedisTransaction exec(Handler<AsyncResult<JsonArray>> handler)
handler
- public RedisTransaction exists(String key, Handler<AsyncResult<String>> handler)
key
- Key stringhandler
- Handler for the result of this call.public Single<String> rxExists(String key)
key
- Key stringpublic RedisTransaction existsMany(List<String> keys, Handler<AsyncResult<String>> handler)
keys
- List of key stringshandler
- Handler for the result of this call.public Single<String> rxExistsMany(List<String> keys)
keys
- List of key stringspublic RedisTransaction expire(String key, int seconds, Handler<AsyncResult<String>> handler)
key
- Key stringseconds
- Time to live in secondshandler
- Handler for the result of this call.public Single<String> rxExpire(String key, int seconds)
key
- Key stringseconds
- Time to live in secondspublic RedisTransaction expireat(String key, long seconds, Handler<AsyncResult<String>> handler)
key
- Key stringseconds
- Expiry time as Unix timestamp in secondshandler
- Handler for the result of this call.public Single<String> rxExpireat(String key, long seconds)
key
- Key stringseconds
- Expiry time as Unix timestamp in secondspublic RedisTransaction flushall(Handler<AsyncResult<String>> handler)
handler
- public RedisTransaction flushdb(Handler<AsyncResult<String>> handler)
handler
- public RedisTransaction get(String key, Handler<AsyncResult<String>> handler)
key
- Key stringhandler
- Handler for the result of this call.public Single<String> rxGet(String key)
key
- Key stringpublic RedisTransaction getBinary(String key, Handler<AsyncResult<Buffer>> handler)
key
- Key stringhandler
- Handler for the result of this call.public Single<Buffer> rxGetBinary(String key)
key
- Key stringpublic RedisTransaction getbit(String key, long offset, Handler<AsyncResult<String>> handler)
key
- Key stringoffset
- Offset in bitshandler
- Handler for the result of this call.public Single<String> rxGetbit(String key, long offset)
key
- Key stringoffset
- Offset in bitspublic RedisTransaction 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 Single<String> rxGetrange(String key, long start, long end)
key
- Key stringstart
- Start offsetend
- End offset - inclusivepublic RedisTransaction 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 Single<String> rxGetset(String key, String value)
key
- Key of which value to setvalue
- New value for the keypublic RedisTransaction hdel(String key, String field, Handler<AsyncResult<String>> handler)
key
- Key stringfield
- Field namehandler
- Handler for the result of this call.public Single<String> rxHdel(String key, String field)
key
- Key stringfield
- Field namepublic RedisTransaction hdelMany(String key, List<String> fields, Handler<AsyncResult<String>> handler)
key
- Key stringfields
- Field nameshandler
- Handler for the result of this call.public Single<String> rxHdelMany(String key, List<String> fields)
key
- Key stringfields
- Field namespublic RedisTransaction hexists(String key, String field, Handler<AsyncResult<String>> handler)
key
- Key stringfield
- Field namehandler
- Handler for the result of this call.public Single<String> rxHexists(String key, String field)
key
- Key stringfield
- Field namepublic RedisTransaction hget(String key, String field, Handler<AsyncResult<String>> handler)
key
- Key stringfield
- Field namehandler
- Handler for the result of this call.public Single<String> rxHget(String key, String field)
key
- Key stringfield
- Field namepublic RedisTransaction hgetall(String key, Handler<AsyncResult<String>> handler)
key
- Key stringhandler
- Handler for the result of this call.public Single<String> rxHgetall(String key)
key
- Key stringpublic RedisTransaction hincrby(String key, String field, long increment, Handler<AsyncResult<String>> handler)
key
- Key stringfield
- Field nameincrement
- Value by which to incrementhandler
- Handler for the result of this call.public Single<String> rxHincrby(String key, String field, long increment)
key
- Key stringfield
- Field nameincrement
- Value by which to incrementpublic RedisTransaction 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 Single<String> rxHincrbyfloat(String key, String field, double increment)
key
- Key stringfield
- Field nameincrement
- Value by which to incrementpublic RedisTransaction hkeys(String key, Handler<AsyncResult<String>> handler)
key
- Key stringhandler
- Handler for the result of this call.public Single<String> rxHkeys(String key)
key
- Key stringpublic RedisTransaction hlen(String key, Handler<AsyncResult<String>> handler)
key
- Key stringhandler
- Handler for the result of this call.public Single<String> rxHlen(String key)
key
- Key stringpublic RedisTransaction hmget(String key, List<String> fields, Handler<AsyncResult<String>> handler)
key
- Key stringfields
- Field nameshandler
- Handler for the result of this call.public Single<String> rxHmget(String key, List<String> fields)
key
- Key stringfields
- Field namespublic RedisTransaction 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 Single<String> rxHmset(String key, JsonObject values)
key
- Key stringvalues
- Map of field:value pairspublic RedisTransaction hset(String key, String field, String value, Handler<AsyncResult<String>> handler)
key
- Key stringfield
- Field namevalue
- New valuehandler
- Handler for the result of this call.public Single<String> rxHset(String key, String field, String value)
key
- Key stringfield
- Field namevalue
- New valuepublic RedisTransaction hsetnx(String key, String field, String value, Handler<AsyncResult<String>> handler)
key
- Key stringfield
- Field namevalue
- New valuehandler
- Handler for the result of this call.public Single<String> rxHsetnx(String key, String field, String value)
key
- Key stringfield
- Field namevalue
- New valuepublic RedisTransaction hvals(String key, Handler<AsyncResult<String>> handler)
key
- Key stringhandler
- Handler for the result of this call.public Single<String> rxHvals(String key)
key
- Key stringpublic RedisTransaction incr(String key, Handler<AsyncResult<String>> handler)
key
- Key stringhandler
- Handler for the result of this call.public Single<String> rxIncr(String key)
key
- Key stringpublic RedisTransaction incrby(String key, long increment, Handler<AsyncResult<String>> handler)
key
- Key stringincrement
- Value by which to incrementhandler
- Handler for the result of this call.public Single<String> rxIncrby(String key, long increment)
key
- Key stringincrement
- Value by which to incrementpublic RedisTransaction 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 Single<String> rxIncrbyfloat(String key, double increment)
key
- Key stringincrement
- Value by which to incrementpublic RedisTransaction info(Handler<AsyncResult<String>> handler)
handler
- Handler for the result of this call.public RedisTransaction infoSection(String section, Handler<AsyncResult<String>> handler)
section
- Specific section of information to returnhandler
- Handler for the result of this call.public Single<String> rxInfoSection(String section)
section
- Specific section of information to returnpublic RedisTransaction keys(String pattern, Handler<AsyncResult<String>> handler)
pattern
- Pattern to limit the keys returnedhandler
- Handler for the result of this call.public Single<String> rxKeys(String pattern)
pattern
- Pattern to limit the keys returnedpublic RedisTransaction lastsave(Handler<AsyncResult<String>> handler)
handler
- public Single<String> rxLastsave()
public RedisTransaction 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 Single<String> rxLindex(String key, int index)
key
- Key stringindex
- Index of list element to getpublic RedisTransaction linsert(String key, InsertOptions option, String pivot, String value, Handler<AsyncResult<String>> 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 Single<String> rxLinsert(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 RedisTransaction llen(String key, Handler<AsyncResult<String>> handler)
key
- String keyhandler
- Handler for the result of this call.public Single<String> rxLlen(String key)
key
- String keypublic RedisTransaction lpop(String key, Handler<AsyncResult<String>> handler)
key
- String keyhandler
- Handler for the result of this call.public Single<String> rxLpop(String key)
key
- String keypublic RedisTransaction lpushMany(String key, List<String> values, Handler<AsyncResult<String>> 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 Single<String> rxLpushMany(String key, List<String> values)
key
- Key stringvalues
- Values to be added at the beginning of the list, one by onepublic RedisTransaction lpush(String key, String value, Handler<AsyncResult<String>> handler)
key
- Key stringvalue
- Value to be added at the beginning of the listhandler
- Handler for the result of this call.public Single<String> rxLpush(String key, String value)
key
- Key stringvalue
- Value to be added at the beginning of the listpublic RedisTransaction lpushx(String key, String value, Handler<AsyncResult<String>> handler)
key
- Key stringvalue
- Value to add at the beginning of the listhandler
- Handler for the result of this call.public Single<String> rxLpushx(String key, String value)
key
- Key stringvalue
- Value to add at the beginning of the listpublic RedisTransaction lrange(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 Single<String> rxLrange(String key, long from, long to)
key
- Key stringfrom
- Start indexto
- Stop indexpublic RedisTransaction lrem(String key, long count, String value, Handler<AsyncResult<String>> 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 Single<String> rxLrem(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 RedisTransaction 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 Single<String> rxLset(String key, long index, String value)
key
- Key stringindex
- Position within listvalue
- New valuepublic RedisTransaction 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 Single<String> rxLtrim(String key, long from, long to)
key
- Key stringfrom
- Start indexto
- Stop indexpublic RedisTransaction mget(String key, Handler<AsyncResult<String>> handler)
key
- Key stringhandler
- Handler for the result of this call.public Single<String> rxMget(String key)
key
- Key stringpublic RedisTransaction mgetMany(List<String> keys, Handler<AsyncResult<String>> handler)
keys
- List of keys to gethandler
- Handler for the result of this call.public Single<String> rxMgetMany(List<String> keys)
keys
- List of keys to getpublic RedisTransaction 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 Single<String> rxMigrate(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 RedisTransaction monitor(Handler<AsyncResult<String>> handler)
handler
- public Single<String> rxMonitor()
public RedisTransaction move(String key, int destdb, Handler<AsyncResult<String>> handler)
key
- Key to migratedestdb
- Destination database indexhandler
- Handler for the result of this call.public Single<String> rxMove(String key, int destdb)
key
- Key to migratedestdb
- Destination database indexpublic RedisTransaction mset(JsonObject keyvals, Handler<AsyncResult<String>> handler)
keyvals
- Key value pairs to sethandler
- Handler for the result of this call.public Single<String> rxMset(JsonObject keyvals)
keyvals
- Key value pairs to setpublic RedisTransaction msetnx(JsonObject keyvals, Handler<AsyncResult<String>> handler)
keyvals
- Key value pairs to sethandler
- Handler for the result of this call.public Single<String> rxMsetnx(JsonObject keyvals)
keyvals
- Key value pairs to setpublic RedisTransaction multi(Handler<AsyncResult<String>> handler)
handler
- public RedisTransaction object(String key, ObjectCmd cmd, Handler<AsyncResult<String>> handler)
key
- Key stringcmd
- Object sub commandhandler
- Handler for the result of this call.public Single<String> rxObject(String key, ObjectCmd cmd)
key
- Key stringcmd
- Object sub commandpublic RedisTransaction persist(String key, Handler<AsyncResult<String>> handler)
key
- Key stringhandler
- Handler for the result of this call.public Single<String> rxPersist(String key)
key
- Key stringpublic RedisTransaction pexpire(String key, long millis, Handler<AsyncResult<String>> handler)
key
- String keymillis
- Time to live in millisecondshandler
- Handler for the result of this call.public Single<String> rxPexpire(String key, long millis)
key
- String keymillis
- Time to live in millisecondspublic RedisTransaction pexpireat(String key, long millis, Handler<AsyncResult<String>> handler)
key
- Key stringmillis
- Expiry time as Unix timestamp in millisecondshandler
- Handler for the result of this call.public Single<String> rxPexpireat(String key, long millis)
key
- Key stringmillis
- Expiry time as Unix timestamp in millisecondspublic RedisTransaction pfadd(String key, String element, Handler<AsyncResult<String>> handler)
key
- Key stringelement
- Element to addhandler
- Handler for the result of this call.public Single<String> rxPfadd(String key, String element)
key
- Key stringelement
- Element to addpublic RedisTransaction pfaddMany(String key, List<String> elements, Handler<AsyncResult<String>> handler)
key
- Key stringelements
- Elementa to addhandler
- Handler for the result of this call.public Single<String> rxPfaddMany(String key, List<String> elements)
key
- Key stringelements
- Elementa to addpublic RedisTransaction pfcount(String key, Handler<AsyncResult<String>> handler)
key
- Key stringhandler
- Handler for the result of this call.public Single<String> rxPfcount(String key)
key
- Key stringpublic RedisTransaction pfcountMany(List<String> keys, Handler<AsyncResult<String>> handler)
keys
- List of keyshandler
- Handler for the result of this call.public Single<String> rxPfcountMany(List<String> keys)
keys
- List of keyspublic RedisTransaction 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 Single<String> rxPfmerge(String destkey, List<String> keys)
destkey
- Destination keykeys
- List of source keyspublic RedisTransaction ping(Handler<AsyncResult<String>> handler)
handler
- public RedisTransaction psetex(String key, long millis, String value, Handler<AsyncResult<String>> handler)
key
- Key stringmillis
- Number of milliseconds until the key expiresvalue
- New value for keyhandler
- Handler for the result of this call.public Single<String> rxPsetex(String key, long millis, String value)
key
- Key stringmillis
- Number of milliseconds until the key expiresvalue
- New value for keypublic RedisTransaction psubscribe(String pattern, Handler<AsyncResult<String>> handler)
pattern
- Pattern stringhandler
- Handler for the result of this call.public Single<String> rxPsubscribe(String pattern)
pattern
- Pattern stringpublic RedisTransaction psubscribeMany(List<String> patterns, Handler<AsyncResult<String>> handler)
patterns
- List of patternshandler
- Handler for the result of this call.public Single<String> rxPsubscribeMany(List<String> patterns)
patterns
- List of patternspublic RedisTransaction pubsubChannels(String pattern, Handler<AsyncResult<String>> handler)
pattern
- A glob-style pattern - an empty string means no patternhandler
- Handler for the result of this call.public Single<String> rxPubsubChannels(String pattern)
pattern
- A glob-style pattern - an empty string means no patternpublic RedisTransaction pubsubNumsub(List<String> channels, Handler<AsyncResult<String>> handler)
channels
- List of channelshandler
- Handler for the result of this call.public Single<String> rxPubsubNumsub(List<String> channels)
channels
- List of channelspublic RedisTransaction pubsubNumpat(Handler<AsyncResult<String>> handler)
handler
- Handler for the result of this call.public Single<String> rxPubsubNumpat()
public RedisTransaction pttl(String key, Handler<AsyncResult<String>> handler)
key
- Key stringhandler
- Handler for the result of this call.public Single<String> rxPttl(String key)
key
- Key stringpublic RedisTransaction publish(String channel, String message, Handler<AsyncResult<String>> handler)
channel
- Channel keymessage
- Message to send to channelhandler
- Handler for the result of this call.public Single<String> rxPublish(String channel, String message)
channel
- Channel keymessage
- Message to send to channelpublic RedisTransaction punsubscribe(List<String> patterns, Handler<AsyncResult<String>> handler)
patterns
- List of patterns to match againsthandler
- Handler for the result of this call.public Single<String> rxPunsubscribe(List<String> patterns)
patterns
- List of patterns to match againstpublic RedisTransaction randomkey(Handler<AsyncResult<String>> handler)
handler
- public RedisTransaction 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 Single<String> rxRename(String key, String newkey)
key
- Key string to be renamednewkey
- New key stringpublic RedisTransaction renamenx(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 Single<String> rxRenamenx(String key, String newkey)
key
- Key string to be renamednewkey
- New key stringpublic RedisTransaction 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 Single<String> rxRestore(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 RedisTransaction role(Handler<AsyncResult<String>> handler)
handler
- public Single<String> rxRole()
public RedisTransaction rpop(String key, Handler<AsyncResult<String>> handler)
key
- Key stringhandler
- Handler for the result of this call.public Single<String> rxRpop(String key)
key
- Key stringpublic RedisTransaction 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 Single<String> rxRpoplpush(String key, String destkey)
key
- Key string identifying source listdestkey
- Key string identifying destination listpublic RedisTransaction rpushMany(String key, List<String> values, Handler<AsyncResult<String>> handler)
key
- Key stringvalues
- List of values to add to the end of the listhandler
- Handler for the result of this call.public Single<String> rxRpushMany(String key, List<String> values)
key
- Key stringvalues
- List of values to add to the end of the listpublic RedisTransaction rpush(String key, String value, Handler<AsyncResult<String>> handler)
key
- Key stringvalue
- Value to be added to the end of the listhandler
- Handler for the result of this call.public Single<String> rxRpush(String key, String value)
key
- Key stringvalue
- Value to be added to the end of the listpublic RedisTransaction rpushx(String key, String value, Handler<AsyncResult<String>> handler)
key
- Key stringvalue
- Value to be added to the end of the listhandler
- Handler for the result of this call.public Single<String> rxRpushx(String key, String value)
key
- Key stringvalue
- Value to be added to the end of the listpublic RedisTransaction sadd(String key, String member, Handler<AsyncResult<String>> handler)
key
- Key stringmember
- Value to be added to the sethandler
- Handler for the result of this call.public Single<String> rxSadd(String key, String member)
key
- Key stringmember
- Value to be added to the setpublic RedisTransaction saddMany(String key, List<String> members, Handler<AsyncResult<String>> handler)
key
- Key stringmembers
- Values to be added to the sethandler
- Handler for the result of this call.public Single<String> rxSaddMany(String key, List<String> members)
key
- Key stringmembers
- Values to be added to the setpublic RedisTransaction save(Handler<AsyncResult<String>> handler)
handler
- public RedisTransaction scard(String key, Handler<AsyncResult<String>> handler)
key
- Key stringhandler
- Handler for the result of this call.public Single<String> rxScard(String key)
key
- Key stringpublic RedisTransaction scriptExists(String script, Handler<AsyncResult<String>> handler)
script
- SHA1 digest identifying a script in the script cachehandler
- Handler for the result of this call.public Single<String> rxScriptExists(String script)
script
- SHA1 digest identifying a script in the script cachepublic RedisTransaction scriptExistsMany(List<String> scripts, Handler<AsyncResult<String>> handler)
scripts
- List of SHA1 digests identifying scripts in the script cachehandler
- Handler for the result of this call.public Single<String> rxScriptExistsMany(List<String> scripts)
scripts
- List of SHA1 digests identifying scripts in the script cachepublic RedisTransaction scriptFlush(Handler<AsyncResult<String>> handler)
handler
- public Single<String> rxScriptFlush()
public RedisTransaction scriptKill(Handler<AsyncResult<String>> handler)
handler
- public RedisTransaction scriptLoad(String script, Handler<AsyncResult<String>> handler)
script
- Lua scripthandler
- Handler for the result of this call.public Single<String> rxScriptLoad(String script)
script
- Lua scriptpublic RedisTransaction sdiff(String key, List<String> cmpkeys, Handler<AsyncResult<String>> 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 Single<String> rxSdiff(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 RedisTransaction sdiffstore(String destkey, String key, List<String> cmpkeys, Handler<AsyncResult<String>> 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 Single<String> rxSdiffstore(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 RedisTransaction select(int dbindex, Handler<AsyncResult<String>> handler)
dbindex
- Index identifying the new active databasehandler
- Handler for the result of this call.public Single<String> rxSelect(int dbindex)
dbindex
- Index identifying the new active databasepublic RedisTransaction set(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 Single<String> rxSet(String key, String value)
key
- Key of which value to setvalue
- New value for the keypublic RedisTransaction setWithOptions(String key, String value, SetOptions options, Handler<AsyncResult<String>> handler)
key
- Key of which value to setvalue
- New value for the keyoptions
- Set optionshandler
- Handler for the result of this call.public Single<String> rxSetWithOptions(String key, String value, SetOptions options)
key
- Key of which value to setvalue
- New value for the keyoptions
- Set optionspublic RedisTransaction setBinary(String key, Buffer 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 Single<String> rxSetBinary(String key, Buffer value)
key
- Key of which value to setvalue
- New value for the keypublic RedisTransaction setBinaryWithOptions(String key, Buffer value, SetOptions options, Handler<AsyncResult<String>> handler)
key
- Key of which value to setvalue
- New value for the keyoptions
- Set optionshandler
- Handler for the result of this call.public Single<String> rxSetBinaryWithOptions(String key, Buffer value, SetOptions options)
key
- Key of which value to setvalue
- New value for the keyoptions
- Set optionspublic RedisTransaction setbit(String key, long offset, int bit, Handler<AsyncResult<String>> handler)
key
- Key stringoffset
- Bit offsetbit
- New value - must be 1 or 0handler
- Handler for the result of this call.public Single<String> rxSetbit(String key, long offset, int bit)
key
- Key stringoffset
- Bit offsetbit
- New value - must be 1 or 0public RedisTransaction 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 Single<String> rxSetex(String key, long seconds, String value)
key
- Key stringseconds
- Number of seconds until the key expiresvalue
- New value for keypublic RedisTransaction setnx(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 Single<String> rxSetnx(String key, String value)
key
- Key of which value to setvalue
- New value for the keypublic RedisTransaction setrange(String key, int offset, String value, Handler<AsyncResult<String>> 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 Single<String> rxSetrange(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 RedisTransaction sinter(List<String> keys, Handler<AsyncResult<String>> handler)
keys
- List of keys to perform intersection onhandler
- Handler for the result of this call.public Single<String> rxSinter(List<String> keys)
keys
- List of keys to perform intersection onpublic RedisTransaction sinterstore(String destkey, List<String> keys, Handler<AsyncResult<String>> handler)
destkey
- Key where to store the resultskeys
- List of keys to perform intersection onhandler
- Handler for the result of this call.public Single<String> rxSinterstore(String destkey, List<String> keys)
destkey
- Key where to store the resultskeys
- List of keys to perform intersection onpublic RedisTransaction sismember(String key, String member, Handler<AsyncResult<String>> handler)
key
- Key stringmember
- Member to look forhandler
- Handler for the result of this call.public Single<String> rxSismember(String key, String member)
key
- Key stringmember
- Member to look forpublic RedisTransaction 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 Single<String> rxSlaveof(String host, int port)
host
- Host to become this server's masterport
- Port of our new masterpublic RedisTransaction slaveofNoone(Handler<AsyncResult<String>> handler)
handler
- Handler for the result of this call.public RedisTransaction slowlogGet(int limit, Handler<AsyncResult<String>> 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 Single<String> rxSlowlogGet(int limit)
limit
- Number of log entries to return. If value is less than zero all entries are returnedpublic RedisTransaction slowlogLen(Handler<AsyncResult<String>> handler)
handler
- Handler for the result of this call.public Single<String> rxSlowlogLen()
public RedisTransaction slowlogReset(Handler<AsyncResult<String>> handler)
handler
- Handler for the result of this call.public RedisTransaction smembers(String key, Handler<AsyncResult<JsonArray>> handler)
key
- Key stringhandler
- Handler for the result of this call.public Single<JsonArray> rxSmembers(String key)
key
- Key stringpublic RedisTransaction smove(String key, String destkey, String member, Handler<AsyncResult<String>> 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 Single<String> rxSmove(String key, String destkey, String member)
key
- Key of source set currently containing the memberdestkey
- Key identifying the destination setmember
- Member to movepublic RedisTransaction sort(String key, SortOptions options, Handler<AsyncResult<String>> handler)
key
- Key stringoptions
- Sort optionshandler
- Handler for the result of this call.public Single<String> rxSort(String key, SortOptions options)
key
- Key stringoptions
- Sort optionspublic RedisTransaction spop(String key, Handler<AsyncResult<String>> handler)
key
- Key stringhandler
- Handler for the result of this call.public Single<String> rxSpop(String key)
key
- Key stringpublic RedisTransaction 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 Single<String> rxSpopMany(String key, int count)
key
- Key stringcount
- Number of members to removepublic RedisTransaction srandmember(String key, Handler<AsyncResult<String>> handler)
key
- Key stringhandler
- Handler for the result of this call.public Single<String> rxSrandmember(String key)
key
- Key stringpublic RedisTransaction srandmemberCount(String key, int count, Handler<AsyncResult<String>> handler)
key
- Key stringcount
- Number of members to gethandler
- Handler for the result of this call.public Single<String> rxSrandmemberCount(String key, int count)
key
- Key stringcount
- Number of members to getpublic RedisTransaction srem(String key, String member, Handler<AsyncResult<String>> handler)
key
- Key stringmember
- Member to removehandler
- Handler for the result of this call.public Single<String> rxSrem(String key, String member)
key
- Key stringmember
- Member to removepublic RedisTransaction sremMany(String key, List<String> members, Handler<AsyncResult<String>> handler)
key
- Key stringmembers
- Members to removehandler
- Handler for the result of this call.public Single<String> rxSremMany(String key, List<String> members)
key
- Key stringmembers
- Members to removepublic RedisTransaction strlen(String key, Handler<AsyncResult<String>> handler)
key
- Key stringhandler
- Handler for the result of this call.public Single<String> rxStrlen(String key)
key
- Key stringpublic RedisTransaction subscribe(String channel, Handler<AsyncResult<String>> handler)
channel
- Channel to subscribe tohandler
- Handler for the result of this call.public Single<String> rxSubscribe(String channel)
channel
- Channel to subscribe topublic RedisTransaction subscribeMany(List<String> channels, Handler<AsyncResult<String>> handler)
channels
- List of channels to subscribe tohandler
- Handler for the result of this call.public Single<String> rxSubscribeMany(List<String> channels)
channels
- List of channels to subscribe topublic RedisTransaction sunion(List<String> keys, Handler<AsyncResult<String>> handler)
keys
- List of keys identifying sets to add uphandler
- Handler for the result of this call.public Single<String> rxSunion(List<String> keys)
keys
- List of keys identifying sets to add uppublic RedisTransaction sunionstore(String destkey, List<String> keys, Handler<AsyncResult<String>> handler)
destkey
- Destination keykeys
- List of keys identifying sets to add uphandler
- Handler for the result of this call.public Single<String> rxSunionstore(String destkey, List<String> keys)
destkey
- Destination keykeys
- List of keys identifying sets to add uppublic RedisTransaction sync(Handler<AsyncResult<String>> handler)
handler
- public RedisTransaction time(Handler<AsyncResult<String>> handler)
handler
- public RedisTransaction ttl(String key, Handler<AsyncResult<String>> handler)
key
- Key stringhandler
- Handler for the result of this call.public Single<String> rxTtl(String key)
key
- Key stringpublic RedisTransaction type(String key, Handler<AsyncResult<String>> handler)
key
- Key stringhandler
- Handler for the result of this call.public Single<String> rxType(String key)
key
- Key stringpublic RedisTransaction unsubscribe(List<String> channels, Handler<AsyncResult<String>> handler)
channels
- List of channels to subscribe tohandler
- Handler for the result of this call.public Single<String> rxUnsubscribe(List<String> channels)
channels
- List of channels to subscribe topublic RedisTransaction unwatch(Handler<AsyncResult<String>> handler)
handler
- public RedisTransaction wait(long numSlaves, long timeout, Handler<AsyncResult<String>> handler)
numSlaves
- timeout
- handler
- Handler for the result of this call.public Single<String> rxWait(long numSlaves, long timeout)
numSlaves
- timeout
- public RedisTransaction watch(String key, Handler<AsyncResult<String>> handler)
key
- Key to watchhandler
- Handler for the result of this call.public Single<String> rxWatch(String key)
key
- Key to watchpublic RedisTransaction watchMany(List<String> keys, Handler<AsyncResult<String>> handler)
keys
- List of keys to watchhandler
- Handler for the result of this call.public Single<String> rxWatchMany(List<String> keys)
keys
- List of keys to watchpublic RedisTransaction zadd(String key, double score, String member, Handler<AsyncResult<String>> handler)
key
- Key stringscore
- Score used for sortingmember
- New member keyhandler
- Handler for the result of this call.public Single<String> rxZadd(String key, double score, String member)
key
- Key stringscore
- Score used for sortingmember
- New member keypublic RedisTransaction zaddMany(String key, Map<String,Double> members, Handler<AsyncResult<String>> handler)
key
- Key stringmembers
- New member keys and their scoreshandler
- Handler for the result of this call.public Single<String> rxZaddMany(String key, Map<String,Double> members)
key
- Key stringmembers
- New member keys and their scorespublic RedisTransaction zcard(String key, Handler<AsyncResult<String>> handler)
key
- Key stringhandler
- Handler for the result of this call.public Single<String> rxZcard(String key)
key
- Key stringpublic RedisTransaction zcount(String key, double min, double max, Handler<AsyncResult<String>> handler)
key
- Key stringmin
- Minimum scoremax
- Maximum scorehandler
- Handler for the result of this call.public Single<String> rxZcount(String key, double min, double max)
key
- Key stringmin
- Minimum scoremax
- Maximum scorepublic RedisTransaction 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 Single<String> rxZincrby(String key, double increment, String member)
key
- Key stringincrement
- Increment amountmember
- Member keypublic RedisTransaction zinterstore(String destkey, List<String> sets, AggregateOptions options, Handler<AsyncResult<String>> handler)
destkey
- Destination keysets
- List of keys identifying sorted sets to intersectoptions
- Aggregation optionshandler
- Handler for the result of this call.public Single<String> rxZinterstore(String destkey, List<String> sets, AggregateOptions options)
destkey
- Destination keysets
- List of keys identifying sorted sets to intersectoptions
- Aggregation optionspublic RedisTransaction zinterstoreWeighed(String destkey, Map<String,Double> sets, AggregateOptions options, Handler<AsyncResult<String>> handler)
destkey
- Destination keysets
- List of keys identifying sorted sets to intersectoptions
- Aggregation optionshandler
- Handler for the result of this call.public Single<String> rxZinterstoreWeighed(String destkey, Map<String,Double> sets, AggregateOptions options)
destkey
- Destination keysets
- List of keys identifying sorted sets to intersectoptions
- Aggregation optionspublic RedisTransaction zlexcount(String key, String min, String max, Handler<AsyncResult<String>> 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 Single<String> rxZlexcount(String key, String min, String max)
key
- Key stringmin
- Pattern to compare against for minimum valuemax
- Pattern to compare against for maximum valuepublic RedisTransaction zrange(String key, long start, long stop, Handler<AsyncResult<String>> handler)
key
- Key stringstart
- Start index for the rangestop
- Stop index for the range - inclusivehandler
- Handler for the result of this call.public Single<String> rxZrange(String key, long start, long stop)
key
- Key stringstart
- Start index for the rangestop
- Stop index for the range - inclusivepublic RedisTransaction zrangeWithOptions(String key, long start, long stop, RangeOptions options, Handler<AsyncResult<String>> 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 Single<String> rxZrangeWithOptions(String key, long start, long stop, RangeOptions options)
key
- Key stringstart
- Start index for the rangestop
- Stop index for the range - inclusiveoptions
- Range optionspublic RedisTransaction zrangebylex(String key, String min, String max, LimitOptions options, Handler<AsyncResult<String>> 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 Single<String> rxZrangebylex(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 RedisTransaction zrangebyscore(String key, String min, String max, RangeLimitOptions options, Handler<AsyncResult<String>> 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 Single<String> rxZrangebyscore(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 RedisTransaction zrank(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 Single<String> rxZrank(String key, String member)
key
- Key stringmember
- Member in the sorted set identified by keypublic RedisTransaction zrem(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 Single<String> rxZrem(String key, String member)
key
- Key stringmember
- Member in the sorted set identified by keypublic RedisTransaction zremMany(String key, List<String> members, Handler<AsyncResult<String>> handler)
key
- Key stringmembers
- Members in the sorted set identified by keyhandler
- Handler for the result of this call.public Single<String> rxZremMany(String key, List<String> members)
key
- Key stringmembers
- Members in the sorted set identified by keypublic RedisTransaction zremrangebylex(String key, String min, String max, Handler<AsyncResult<String>> handler)
key
- Key stringmin
- Pattern defining a minimum valuemax
- Pattern defining a maximum valuehandler
- Handler for the result of this call.public Single<String> rxZremrangebylex(String key, String min, String max)
key
- Key stringmin
- Pattern defining a minimum valuemax
- Pattern defining a maximum valuepublic RedisTransaction zremrangebyrank(String key, long start, long stop, Handler<AsyncResult<String>> handler)
key
- Key stringstart
- Start indexstop
- Stop indexhandler
- Handler for the result of this call.public Single<String> rxZremrangebyrank(String key, long start, long stop)
key
- Key stringstart
- Start indexstop
- Stop indexpublic RedisTransaction zremrangebyscore(String key, String min, String max, Handler<AsyncResult<String>> handler)
key
- Key stringmin
- Pattern defining a minimum valuemax
- Pattern defining a maximum valuehandler
- public Single<String> rxZremrangebyscore(String key, String min, String max)
key
- Key stringmin
- Pattern defining a minimum valuemax
- Pattern defining a maximum valuepublic RedisTransaction zrevrange(String key, long start, long stop, RangeOptions options, Handler<AsyncResult<String>> 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 Single<String> rxZrevrange(String key, long start, long stop, RangeOptions options)
key
- Key stringstart
- Start index for the rangestop
- Stop index for the range - inclusiveoptions
- Range optionspublic RedisTransaction zrevrangebylex(String key, String max, String min, LimitOptions options, Handler<AsyncResult<String>> handler)
key
- Key stringmax
- Pattern defining a maximum valuemin
- Pattern defining a minimum valueoptions
- Limit optionshandler
- Handler for the result of this call.public Single<String> rxZrevrangebylex(String key, String max, String min, LimitOptions options)
key
- Key stringmax
- Pattern defining a maximum valuemin
- Pattern defining a minimum valueoptions
- Limit optionspublic RedisTransaction zrevrangebyscore(String key, String max, String min, RangeLimitOptions options, Handler<AsyncResult<String>> 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 Single<String> rxZrevrangebyscore(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 RedisTransaction zrevrank(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 Single<String> rxZrevrank(String key, String member)
key
- Key stringmember
- Member in the sorted set identified by keypublic RedisTransaction 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 Single<String> rxZscore(String key, String member)
key
- Key stringmember
- Member in the sorted set identified by keypublic RedisTransaction zunionstore(String destkey, List<String> sets, AggregateOptions options, Handler<AsyncResult<String>> handler)
destkey
- Destination keysets
- List of keys identifying sorted setsoptions
- Aggregation optionshandler
- Handler for the result of this call.public Single<String> rxZunionstore(String destkey, List<String> sets, AggregateOptions options)
destkey
- Destination keysets
- List of keys identifying sorted setsoptions
- Aggregation optionspublic RedisTransaction zunionstoreWeighed(String key, Map<String,Double> sets, AggregateOptions options, Handler<AsyncResult<String>> handler)
key
- Destination keysets
- Map containing set-key:weight pairsoptions
- Aggregation optionshandler
- Handler for the result of this call.public Single<String> rxZunionstoreWeighed(String key, Map<String,Double> sets, AggregateOptions options)
key
- Destination keysets
- Map containing set-key:weight pairsoptions
- Aggregation optionspublic RedisTransaction scan(String cursor, ScanOptions options, Handler<AsyncResult<String>> handler)
cursor
- Cursor idoptions
- Scan optionshandler
- Handler for the result of this call.public Single<String> rxScan(String cursor, ScanOptions options)
cursor
- Cursor idoptions
- Scan optionspublic RedisTransaction sscan(String key, String cursor, ScanOptions options, Handler<AsyncResult<String>> handler)
key
- Key stringcursor
- Cursor idoptions
- Scan optionshandler
- Handler for the result of this call.public Single<String> rxSscan(String key, String cursor, ScanOptions options)
key
- Key stringcursor
- Cursor idoptions
- Scan optionspublic RedisTransaction hscan(String key, String cursor, ScanOptions options, Handler<AsyncResult<String>> handler)
key
- Key stringcursor
- Cursor idoptions
- Scan optionshandler
- Handler for the result of this call.public Single<String> rxHscan(String key, String cursor, ScanOptions options)
key
- Key stringcursor
- Cursor idoptions
- Scan optionspublic RedisTransaction zscan(String key, String cursor, ScanOptions options, Handler<AsyncResult<String>> handler)
key
- Key stringcursor
- Cursor idoptions
- Scan optionshandler
- Handler for the result of this call.public Single<String> rxZscan(String key, String cursor, ScanOptions options)
key
- Key stringcursor
- Cursor idoptions
- Scan optionspublic RedisTransaction geoadd(String key, double longitude, double latitude, String member, Handler<AsyncResult<String>> handler)
key
- Key stringlongitude
- longitudelatitude
- latitudemember
- memberhandler
- Handler for the result of this call.public Single<String> rxGeoadd(String key, double longitude, double latitude, String member)
key
- Key stringlongitude
- longitudelatitude
- latitudemember
- memberpublic RedisTransaction geoaddMany(String key, List<GeoMember> members, Handler<AsyncResult<String>> handler)
key
- Key stringmembers
- list of <lon, lat, member>handler
- Handler for the result of this call.public Single<String> rxGeoaddMany(String key, List<GeoMember> members)
key
- Key stringmembers
- list of <lon, lat, member>public RedisTransaction geohash(String key, String member, Handler<AsyncResult<String>> handler)
key
- Key stringmember
- memberhandler
- Handler for the result of this call.public Single<String> rxGeohash(String key, String member)
key
- Key stringmember
- memberpublic RedisTransaction geohashMany(String key, List<String> members, Handler<AsyncResult<String>> handler)
key
- Key stringmembers
- list of membershandler
- Handler for the result of this call.public Single<String> rxGeohashMany(String key, List<String> members)
key
- Key stringmembers
- list of memberspublic RedisTransaction geopos(String key, String member, Handler<AsyncResult<String>> handler)
key
- Key stringmember
- memberhandler
- Handler for the result of this call.public Single<String> rxGeopos(String key, String member)
key
- Key stringmember
- memberpublic RedisTransaction geoposMany(String key, List<String> members, Handler<AsyncResult<String>> handler)
key
- Key stringmembers
- list of membershandler
- Handler for the result of this call.public Single<String> rxGeoposMany(String key, List<String> members)
key
- Key stringmembers
- list of memberspublic RedisTransaction geodist(String key, String member1, String member2, Handler<AsyncResult<String>> handler)
key
- Key stringmember1
- member 1member2
- member 2handler
- Handler for the result of this call.public Single<String> rxGeodist(String key, String member1, String member2)
key
- Key stringmember1
- member 1member2
- member 2public RedisTransaction geodistWithUnit(String key, String member1, String member2, GeoUnit unit, Handler<AsyncResult<String>> handler)
key
- Key stringmember1
- member 1member2
- member 2unit
- geo unithandler
- Handler for the result of this call.public Single<String> rxGeodistWithUnit(String key, String member1, String member2, GeoUnit unit)
key
- Key stringmember1
- member 1member2
- member 2unit
- geo unitpublic RedisTransaction georadius(String key, double longitude, double latitude, double radius, GeoUnit unit, Handler<AsyncResult<String>> handler)
key
- Key stringlongitude
- longitudelatitude
- latituderadius
- radiusunit
- geo unithandler
- Handler for the result of this call.public Single<String> rxGeoradius(String key, double longitude, double latitude, double radius, GeoUnit unit)
key
- Key stringlongitude
- longitudelatitude
- latituderadius
- radiusunit
- geo unitpublic RedisTransaction georadiusWithOptions(String key, double longitude, double latitude, double radius, GeoUnit unit, GeoRadiusOptions options, Handler<AsyncResult<String>> handler)
key
- Key stringlongitude
- longitudelatitude
- latituderadius
- radiusunit
- geo unitoptions
- geo radius optionshandler
- Handler for the result of this call.public Single<String> rxGeoradiusWithOptions(String key, double longitude, double latitude, double radius, GeoUnit unit, GeoRadiusOptions options)
key
- Key stringlongitude
- longitudelatitude
- latituderadius
- radiusunit
- geo unitoptions
- geo radius optionspublic RedisTransaction georadiusbymember(String key, String member, double radius, GeoUnit unit, Handler<AsyncResult<String>> handler)
key
- Key stringmember
- memberradius
- radiusunit
- geo unithandler
- Handler for the result of this call.public Single<String> rxGeoradiusbymember(String key, String member, double radius, GeoUnit unit)
key
- Key stringmember
- memberradius
- radiusunit
- geo unitpublic RedisTransaction georadiusbymemberWithOptions(String key, String member, double radius, GeoUnit unit, GeoRadiusOptions options, Handler<AsyncResult<String>> handler)
key
- Key stringmember
- memberradius
- radiusunit
- geo unitoptions
- geo radius optionshandler
- Handler for the result of this call.public Single<String> rxGeoradiusbymemberWithOptions(String key, String member, double radius, GeoUnit unit, GeoRadiusOptions options)
key
- Key stringmember
- memberradius
- radiusunit
- geo unitoptions
- geo radius optionspublic RedisTransaction unlink(String key, Handler<AsyncResult<String>> handler)
key
- Key stringhandler
- public Single<String> rxUnlink(String key)
key
- Key stringpublic RedisTransaction unlinkMany(List<String> keys, Handler<AsyncResult<String>> handler)
keys
- List of keys to deletehandler
- Handler for the result of this call.public Single<String> rxUnlinkMany(List<String> keys)
keys
- List of keys to deletepublic RedisTransaction swapdb(int index1, int index2, Handler<AsyncResult<String>> handler)
index1
- index of first database to swapindex2
- index of second database to swaphandler
- Handler for the result of this call.public Single<String> rxSwapdb(int index1, int index2)
index1
- index of first database to swapindex2
- index of second database to swappublic static RedisTransaction newInstance(RedisTransaction arg)
Copyright © 2023 Eclipse. All rights reserved.