K
- Key type.V
- Value type.public abstract class AbstractRedisReactiveCommands<K,V> extends Object implements RedisHashReactiveCommands<K,V>, RedisKeyReactiveCommands<K,V>, RedisStringReactiveCommands<K,V>, RedisListReactiveCommands<K,V>, RedisSetReactiveCommands<K,V>, RedisSortedSetReactiveCommands<K,V>, RedisScriptingReactiveCommands<K,V>, RedisServerReactiveCommands<K,V>, RedisHLLReactiveCommands<K,V>, BaseRedisReactiveCommands<K,V>, RedisTransactionalReactiveCommands<K,V>, RedisGeoReactiveCommands<K,V>, RedisClusterReactiveCommands<K,V>
Modifier and Type | Field and Description |
---|---|
protected RedisCodec<K,V> |
codec |
protected com.lambdaworks.redis.RedisCommandBuilder<K,V> |
commandBuilder |
protected StatefulConnection<K,V> |
connection |
protected MultiOutput<K,V> |
multi |
Constructor and Description |
---|
AbstractRedisReactiveCommands(StatefulConnection<K,V> connection,
RedisCodec<K,V> codec)
Initialize a new instance.
|
Modifier and Type | Method and Description |
---|---|
Observable<Long> |
append(K key,
V value)
Append a value to a key.
|
Observable<String> |
asking()
The asking command is required after a
-ASK redirection. |
Observable<String> |
auth(String password)
Authenticate to the server.
|
Observable<String> |
bgrewriteaof()
Asynchronously rewrite the append-only file.
|
Observable<String> |
bgsave()
Asynchronously save the dataset to disk.
|
Observable<Long> |
bitcount(K key)
Count set bits in a string.
|
Observable<Long> |
bitcount(K key,
long start,
long end)
Count set bits in a string.
|
Observable<Long> |
bitfield(K key,
BitFieldArgs args)
Execute
BITFIELD with its subcommands. |
Observable<Long> |
bitopAnd(K destination,
K... keys)
Perform bitwise AND between strings.
|
Observable<Long> |
bitopNot(K destination,
K source)
Perform bitwise NOT between strings.
|
Observable<Long> |
bitopOr(K destination,
K... keys)
Perform bitwise OR between strings.
|
Observable<Long> |
bitopXor(K destination,
K... keys)
Perform bitwise XOR between strings.
|
Observable<Long> |
bitpos(K key,
boolean state)
Find first bit set or clear in a string.
|
Observable<Long> |
bitpos(K key,
boolean state,
long start)
Find first bit set or clear in a string.
|
Observable<Long> |
bitpos(K key,
boolean state,
long start,
long end)
Find first bit set or clear in a string.
|
Observable<KeyValue<K,V>> |
blpop(long timeout,
K... keys)
Remove and get the first element in a list, or block until one is available.
|
Observable<KeyValue<K,V>> |
brpop(long timeout,
K... keys)
Remove and get the last element in a list, or block until one is available.
|
Observable<V> |
brpoplpush(long timeout,
K source,
K destination)
Pop a value from a list, push it to another list and return it; or block until one is available.
|
Observable<KeyValue<K,ScoredValue<V>>> |
bzpopmax(long timeout,
K... keys)
Removes and returns a member with the highest scores in the sorted set stored at one of the keys.
|
Observable<KeyValue<K,ScoredValue<V>>> |
bzpopmin(long timeout,
K... keys)
Removes and returns a member with the lowest scores in the sorted set stored at one of the keys.
|
Observable<K> |
clientGetname()
Get the current connection name.
|
Observable<Long> |
clientKill(KillArgs killArgs)
Kill connections of clients which are filtered by
killArgs |
Observable<String> |
clientKill(String addr)
Kill the connection of a client identified by ip:port.
|
Observable<String> |
clientList()
Get the list of client connections.
|
Observable<String> |
clientPause(long timeout)
Stop processing commands from clients for some time.
|
Observable<String> |
clientSetname(K name)
Set the current connection name.
|
Observable<Long> |
clientUnblock(long id,
UnblockType type)
Unblock the specified blocked client.
|
void |
close()
Close the connection.
|
Observable<String> |
clusterAddSlots(int... slots)
Adds slots to the cluster node.
|
Observable<String> |
clusterBumpepoch()
Generate a new config epoch, incrementing the current epoch, assign the new epoch to this node, WITHOUT any consensus and
persist the configuration on disk before sending packets with the new configuration.
|
Observable<Long> |
clusterCountFailureReports(String nodeId)
Returns the number of failure reports for the specified node.
|
Observable<Long> |
clusterCountKeysInSlot(int slot)
Returns the number of keys in the specified Redis Cluster hash
slot . |
Observable<String> |
clusterDelSlots(int... slots)
Removes slots from the cluster node.
|
Observable<String> |
clusterFailover(boolean force)
Failover a cluster node.
|
Observable<String> |
clusterFlushslots()
Delete all the slots associated with the specified node.
|
Observable<String> |
clusterForget(String nodeId)
Blacklist and remove the cluster node from the cluster.
|
Observable<K> |
clusterGetKeysInSlot(int slot,
int count)
Retrieve the list of keys within the
slot . |
Observable<String> |
clusterInfo()
Get information and statistics about the cluster viewed by the current node.
|
Observable<Long> |
clusterKeyslot(K key)
Returns an integer identifying the hash slot the specified key hashes to.
|
Observable<String> |
clusterMeet(String ip,
int port)
Meet another cluster node to include the node into the cluster.
|
Observable<String> |
clusterMyId()
Obtain the nodeId for the currently connected node.
|
Observable<String> |
clusterNodes()
Obtain details about all cluster nodes.
|
Observable<String> |
clusterReplicate(String nodeId)
Turn this node into a slave of the node with the id
nodeId . |
Observable<String> |
clusterReset(boolean hard)
Reset a node performing a soft or hard reset:
All other nodes are forgotten
All the assigned / open slots are released
If the node is a slave, it turns into a master
Only for hard reset: a new Node ID is generated
Only for hard reset: currentEpoch and configEpoch are set to 0
The new configuration is saved and the cluster state updated
If the node was a slave, the whole data set is flushed away
|
Observable<String> |
clusterSaveconfig()
Forces a node to save the nodes.conf configuration on disk.
|
Observable<String> |
clusterSetConfigEpoch(long configEpoch)
This command sets a specific config epoch in a fresh node.
|
Observable<String> |
clusterSetSlotImporting(int slot,
String nodeId)
Flag a slot as IMPORTING (incoming) from the node specified in
nodeId . |
Observable<String> |
clusterSetSlotMigrating(int slot,
String nodeId)
Flag a slot as MIGRATING (outgoing) towards the node specified in
nodeId . |
Observable<String> |
clusterSetSlotNode(int slot,
String nodeId)
Assign a slot to a node.
|
Observable<String> |
clusterSetSlotStable(int slot)
Clears migrating / importing state from the slot.
|
Observable<String> |
clusterSlaves(String nodeId)
List slaves for a certain node identified by its
nodeId . |
Observable<Object> |
clusterSlots()
Get array of cluster slots to node mappings.
|
Observable<Object> |
command()
Returns an array reply of details about all Redis commands.
|
Observable<Long> |
commandCount()
Get total number of Redis commands.
|
Observable<Object> |
commandInfo(CommandType... commands)
Returns an array reply of details about the requested commands.
|
Observable<Object> |
commandInfo(String... commands)
Returns an array reply of details about the requested commands.
|
Observable<String> |
configGet(String parameter)
Get the value of a configuration parameter.
|
Observable<String> |
configResetstat()
Reset the stats returned by INFO.
|
Observable<String> |
configRewrite()
Rewrite the configuration file with the in memory configuration.
|
Observable<String> |
configSet(String parameter,
String value)
Set a configuration parameter to the given value.
|
<T,R> R |
createDissolvingObservable(CommandType type,
CommandOutput<K,V,T> output,
CommandArgs<K,V> args) |
<T,R> R |
createDissolvingObservable(Supplier<RedisCommand<K,V,T>> commandSupplier) |
protected <T> Observable<T> |
createObservable(CommandType type,
CommandOutput<K,V,T> output,
CommandArgs<K,V> args) |
<T> Observable<T> |
createObservable(Supplier<RedisCommand<K,V,T>> commandSupplier) |
Observable<Long> |
dbsize()
Return the number of keys in the selected database.
|
Observable<String> |
debugCrashAndRecover(Long delay)
Crash and recover
|
Observable<String> |
debugHtstats(int db)
Get debugging information about the internal hash-table state.
|
Observable<String> |
debugObject(K key)
Get debugging information about a key.
|
Observable<Success> |
debugOom()
Make the server crash: Out of memory.
|
Observable<String> |
debugReload()
Save RDB, clear the database and reload RDB.
|
Observable<String> |
debugRestart(Long delay)
Restart the server gracefully.
|
Observable<String> |
debugSdslen(K key)
Get debugging information about the internal SDS length.
|
Observable<Success> |
debugSegfault()
Make the server crash: Invalid pointer access.
|
Observable<Long> |
decr(K key)
Decrement the integer value of a key by one.
|
Observable<Long> |
decrby(K key,
long amount)
Decrement the integer value of a key by the given number.
|
Observable<Long> |
del(Iterable<K> keys) |
Observable<Long> |
del(K... keys)
Delete one or more keys.
|
String |
digest(V script)
Create a SHA1 digest from a Lua script.
|
Observable<String> |
discard()
Discard all commands issued after MULTI.
|
<T> Observable<T> |
dispatch(ProtocolKeyword type,
CommandOutput<K,V,?> output)
Dispatch a command to the Redis Server.
|
<T> Observable<T> |
dispatch(ProtocolKeyword type,
CommandOutput<K,V,?> output,
CommandArgs<K,V> args)
Dispatch a command to the Redis Server.
|
Observable<byte[]> |
dump(K key)
Return a serialized version of the value stored at the specified key.
|
Observable<V> |
echo(V msg)
Echo the given string.
|
<T> Observable<T> |
eval(String script,
ScriptOutputType type,
K... keys)
Execute a Lua script server side.
|
<T> Observable<T> |
eval(String script,
ScriptOutputType type,
K[] keys,
V... values)
Execute a Lua script server side.
|
<T> Observable<T> |
evalsha(String digest,
ScriptOutputType type,
K... keys)
Evaluates a script cached on the server side by its SHA1 digest
|
<T> Observable<T> |
evalsha(String digest,
ScriptOutputType type,
K[] keys,
V... values)
Execute a Lua script server side.
|
Observable<Object> |
exec()
Execute all commands issued after MULTI.
|
Observable<Long> |
exists(Iterable<K> keys) |
Observable<Long> |
exists(K... keys)
Determine how many keys exist.
|
Observable<Boolean> |
exists(K key) |
Observable<Boolean> |
expire(K key,
long seconds)
Set a key's time to live in seconds.
|
Observable<Boolean> |
expireat(K key,
Date timestamp)
Set the expiration for a key as a UNIX timestamp.
|
Observable<Boolean> |
expireat(K key,
long timestamp)
Set the expiration for a key as a UNIX timestamp.
|
Observable<String> |
flushall()
Remove all keys from all databases.
|
Observable<String> |
flushallAsync()
Remove all keys asynchronously from all databases.
|
Observable<String> |
flushdb()
Remove all keys from the current database.
|
Observable<String> |
flushdbAsync()
Remove all keys asynchronously from the current database.
|
Observable<Long> |
geoadd(K key,
double longitude,
double latitude,
V member)
Single geo add.
|
Observable<Long> |
geoadd(K key,
Object... lngLatMember)
Multi geo add.
|
Observable<Double> |
geodist(K key,
V from,
V to,
GeoArgs.Unit unit)
Retrieve distance between points
from and to . |
Observable<String> |
geohash(K key,
V... members)
Retrieve Geohash strings representing the position of one or more elements in a sorted set value representing a geospatial index.
|
Observable<GeoCoordinates> |
geopos(K key,
V... members)
Get geo coordinates for the
members . |
protected Observable<V> |
georadius_ro(K key,
double longitude,
double latitude,
double distance,
GeoArgs.Unit unit) |
protected Observable<GeoWithin<V>> |
georadius_ro(K key,
double longitude,
double latitude,
double distance,
GeoArgs.Unit unit,
GeoArgs geoArgs) |
Observable<V> |
georadius(K key,
double longitude,
double latitude,
double distance,
GeoArgs.Unit unit)
Retrieve members selected by distance with the center of
longitude and latitude . |
Observable<GeoWithin<V>> |
georadius(K key,
double longitude,
double latitude,
double distance,
GeoArgs.Unit unit,
GeoArgs geoArgs)
Retrieve members selected by distance with the center of
longitude and latitude . |
Observable<Long> |
georadius(K key,
double longitude,
double latitude,
double distance,
GeoArgs.Unit unit,
GeoRadiusStoreArgs<K> geoRadiusStoreArgs)
Perform a
RedisGeoReactiveCommands.georadius(Object, double, double, double, GeoArgs.Unit, GeoArgs) query and store the results in a sorted set. |
protected Observable<V> |
georadiusbymember_ro(K key,
V member,
double distance,
GeoArgs.Unit unit) |
protected Observable<GeoWithin<V>> |
georadiusbymember_ro(K key,
V member,
double distance,
GeoArgs.Unit unit,
GeoArgs geoArgs) |
Observable<V> |
georadiusbymember(K key,
V member,
double distance,
GeoArgs.Unit unit)
Retrieve members selected by distance with the center of
member . |
Observable<GeoWithin<V>> |
georadiusbymember(K key,
V member,
double distance,
GeoArgs.Unit unit,
GeoArgs geoArgs)
Retrieve members selected by distance with the center of
member . |
Observable<Long> |
georadiusbymember(K key,
V member,
double distance,
GeoArgs.Unit unit,
GeoRadiusStoreArgs<K> geoRadiusStoreArgs)
Perform a
RedisGeoReactiveCommands.georadiusbymember(Object, Object, double, GeoArgs.Unit, GeoArgs) query and store the results in a sorted set. |
Observable<V> |
get(K key)
Get the value of a key.
|
Observable<Long> |
getbit(K key,
long offset)
Returns the bit value at offset in the string value stored at key.
|
StatefulConnection<K,V> |
getConnection() |
Observable<V> |
getrange(K key,
long start,
long end)
Get a substring of the string stored at a key.
|
Observable<V> |
getset(K key,
V value)
Set the string value of a key and return its old value.
|
protected <T> Observable<Success> |
getSuccessObservable(Observable<T> observable)
Emits just
Success.Success or the Throwable after the inner observable is completed. |
Observable<Long> |
hdel(K key,
K... fields)
Delete one or more hash fields.
|
Observable<Boolean> |
hexists(K key,
K field)
Determine if a hash field exists.
|
Observable<V> |
hget(K key,
K field)
Get the value of a hash field.
|
Observable<Map<K,V>> |
hgetall(K key)
Get all the fields and values in a hash.
|
Observable<Long> |
hgetall(KeyValueStreamingChannel<K,V> channel,
K key)
Stream over all the fields and values in a hash.
|
Observable<Long> |
hincrby(K key,
K field,
long amount)
Increment the integer value of a hash field by the given number.
|
Observable<Double> |
hincrbyfloat(K key,
K field,
double amount)
Increment the float value of a hash field by the given amount.
|
Observable<K> |
hkeys(K key)
Get all the fields in a hash.
|
Observable<Long> |
hkeys(KeyStreamingChannel<K> channel,
K key)
Stream over all the fields in a hash.
|
Observable<Long> |
hlen(K key)
Get the number of fields in a hash.
|
Observable<V> |
hmget(K key,
K... fields)
Get the values of all the given hash fields.
|
Observable<Long> |
hmget(ValueStreamingChannel<V> channel,
K key,
K... fields)
Stream over the values of all the given hash fields.
|
Observable<String> |
hmset(K key,
Map<K,V> map)
Set multiple hash fields to multiple values.
|
Observable<MapScanCursor<K,V>> |
hscan(K key)
Incrementally iterate hash fields and associated values.
|
Observable<StreamScanCursor> |
hscan(KeyValueStreamingChannel<K,V> channel,
K key)
Incrementally iterate hash fields and associated values.
|
Observable<StreamScanCursor> |
hscan(KeyValueStreamingChannel<K,V> channel,
K key,
ScanArgs scanArgs)
Incrementally iterate hash fields and associated values.
|
Observable<StreamScanCursor> |
hscan(KeyValueStreamingChannel<K,V> channel,
K key,
ScanCursor scanCursor)
Incrementally iterate hash fields and associated values.
|
Observable<StreamScanCursor> |
hscan(KeyValueStreamingChannel<K,V> channel,
K key,
ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate hash fields and associated values.
|
Observable<MapScanCursor<K,V>> |
hscan(K key,
ScanArgs scanArgs)
Incrementally iterate hash fields and associated values.
|
Observable<MapScanCursor<K,V>> |
hscan(K key,
ScanCursor scanCursor)
Incrementally iterate hash fields and associated values.
|
Observable<MapScanCursor<K,V>> |
hscan(K key,
ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate hash fields and associated values.
|
Observable<Boolean> |
hset(K key,
K field,
V value)
Set the string value of a hash field.
|
Observable<Boolean> |
hsetnx(K key,
K field,
V value)
Set the value of a hash field, only if the field does not exist.
|
Observable<Long> |
hstrlen(K key,
K field)
Get the string length of the field value in a hash.
|
Observable<V> |
hvals(K key)
Get all the values in a hash.
|
Observable<Long> |
hvals(ValueStreamingChannel<V> channel,
K key)
Stream over all the values in a hash.
|
Observable<Long> |
incr(K key)
Increment the integer value of a key by one.
|
Observable<Long> |
incrby(K key,
long amount)
Increment the integer value of a key by the given amount.
|
Observable<Double> |
incrbyfloat(K key,
double amount)
Increment the float value of a key by the given amount.
|
Observable<String> |
info()
Get information and statistics about the server.
|
Observable<String> |
info(String section)
Get information and statistics about the server.
|
boolean |
isOpen() |
Observable<K> |
keys(K pattern)
Find all keys matching the given pattern.
|
Observable<Long> |
keys(KeyStreamingChannel<K> channel,
K pattern)
Find all keys matching the given pattern.
|
Observable<Date> |
lastsave()
Get the UNIX time stamp of the last successful save to disk.
|
Observable<V> |
lindex(K key,
long index)
Get an element from a list by its index.
|
Observable<Long> |
linsert(K key,
boolean before,
V pivot,
V value)
Insert an element before or after another element in a list.
|
Observable<Long> |
llen(K key)
Get the length of a list.
|
Observable<V> |
lpop(K key)
Remove and get the first element in a list.
|
Observable<Long> |
lpush(K key,
V... values)
Prepend one or multiple values to a list.
|
Observable<Long> |
lpushx(K key,
V... values)
Prepend values to a list, only if the list exists.
|
Observable<Long> |
lpushx(K key,
V value)
Prepend a value to a list, only if the list exists.
|
Observable<V> |
lrange(K key,
long start,
long stop)
Get a range of elements from a list.
|
Observable<Long> |
lrange(ValueStreamingChannel<V> channel,
K key,
long start,
long stop)
Get a range of elements from a list.
|
Observable<Long> |
lrem(K key,
long count,
V value)
Remove elements from a list.
|
Observable<String> |
lset(K key,
long index,
V value)
Set the value of an element in a list by its index.
|
Observable<String> |
ltrim(K key,
long start,
long stop)
Trim a list to the specified range.
|
Observable<V> |
mget(Iterable<K> keys) |
Observable<V> |
mget(K... keys)
Get the values of all the given keys.
|
Observable<Long> |
mget(ValueStreamingChannel<V> channel,
Iterable<K> keys) |
Observable<Long> |
mget(ValueStreamingChannel<V> channel,
K... keys)
Stream over the values of all the given keys.
|
Observable<String> |
migrate(String host,
int port,
int db,
long timeout,
MigrateArgs<K> migrateArgs)
Atomically transfer one or more keys from a Redis instance to another one.
|
Observable<String> |
migrate(String host,
int port,
K key,
int db,
long timeout)
Atomically transfer a key from a Redis instance to another one.
|
Observable<Boolean> |
move(K key,
int db)
Move a key to another database.
|
Observable<String> |
mset(Map<K,V> map)
Set multiple keys to multiple values.
|
Observable<Boolean> |
msetnx(Map<K,V> map)
Set multiple keys to multiple values, only if none of the keys exist.
|
Observable<String> |
multi()
Mark the start of a transaction block.
|
Observable<String> |
objectEncoding(K key)
returns the kind of internal representation used in order to store the value associated with a key.
|
Observable<Long> |
objectIdletime(K key)
returns the number of seconds since the object stored at the specified key is idle (not requested by read or write
operations).
|
Observable<Long> |
objectRefcount(K key)
returns the number of references of the value associated with the specified key.
|
Observable<Boolean> |
persist(K key)
Remove the expiration from a key.
|
Observable<Boolean> |
pexpire(K key,
long milliseconds)
Set a key's time to live in milliseconds.
|
Observable<Boolean> |
pexpireat(K key,
Date timestamp)
Set the expiration for a key as a UNIX timestamp specified in milliseconds.
|
Observable<Boolean> |
pexpireat(K key,
long timestamp)
Set the expiration for a key as a UNIX timestamp specified in milliseconds.
|
Observable<Long> |
pfadd(K key,
V... values)
Adds the specified elements to the specified HyperLogLog.
|
Observable<Long> |
pfadd(K key,
V value,
V... values) |
Observable<Long> |
pfcount(K... keys)
Return the approximated cardinality of the set(s) observed by the HyperLogLog at key(s).
|
Observable<Long> |
pfcount(K key,
K... keys) |
Observable<String> |
pfmerge(K destkey,
K... sourcekeys)
Merge N different HyperLogLogs into a single one.
|
Observable<String> |
pfmerge(K destkey,
K sourceKey,
K... sourcekeys) |
Observable<String> |
ping()
Ping the server.
|
Observable<String> |
psetex(K key,
long milliseconds,
V value)
Set the value and expiration in milliseconds of a key.
|
Observable<Long> |
pttl(K key)
Get the time to live for a key in milliseconds.
|
Observable<Long> |
publish(K channel,
V message)
Post a message to a channel.
|
Observable<K> |
pubsubChannels()
Lists the currently *active channels*.
|
Observable<K> |
pubsubChannels(K channel)
Lists the currently *active channels*.
|
Observable<Long> |
pubsubNumpat()
Returns the number of subscriptions to patterns.
|
Observable<Map<K,Long>> |
pubsubNumsub(K... channels)
Returns the number of subscribers (not counting clients subscribed to patterns) for the specified channels.
|
Observable<String> |
quit()
Instructs Redis to disconnect the connection.
|
Observable<V> |
randomkey()
Return a random key from the keyspace.
|
Observable<String> |
readOnly()
Switch connection to Read-Only mode when connecting to a cluster.
|
Observable<String> |
readWrite()
Switch connection to Read-Write mode (default) when connecting to a cluster.
|
Observable<String> |
rename(K key,
K newKey)
Rename a key.
|
Observable<Boolean> |
renamenx(K key,
K newKey)
Rename a key, only if the new key does not exist.
|
void |
reset()
Reset the command state.
|
Observable<String> |
restore(K key,
byte[] value,
RestoreArgs args)
Create a key using the provided serialized value, previously obtained using DUMP.
|
Observable<String> |
restore(K key,
long ttl,
byte[] value)
Create a key using the provided serialized value, previously obtained using DUMP.
|
Observable<Object> |
role()
Return the role of the instance in the context of replication.
|
Observable<V> |
rpop(K key)
Remove and get the last element in a list.
|
Observable<V> |
rpoplpush(K source,
K destination)
Remove the last element in a list, append it to another list and return it.
|
Observable<Long> |
rpush(K key,
V... values)
Append one or multiple values to a list.
|
Observable<Long> |
rpushx(K key,
V... values)
Append values to a list, only if the list exists.
|
Observable<Long> |
rpushx(K key,
V value)
Append a value to a list, only if the list exists.
|
Observable<Long> |
sadd(K key,
V... members)
Add one or more members to a set.
|
Observable<String> |
save()
Synchronously save the dataset to disk.
|
Observable<KeyScanCursor<K>> |
scan()
Incrementally iterate the keys space.
|
Observable<StreamScanCursor> |
scan(KeyStreamingChannel<K> channel)
Incrementally iterate the keys space.
|
Observable<StreamScanCursor> |
scan(KeyStreamingChannel<K> channel,
ScanArgs scanArgs)
Incrementally iterate the keys space.
|
Observable<StreamScanCursor> |
scan(KeyStreamingChannel<K> channel,
ScanCursor scanCursor)
Incrementally iterate the keys space.
|
Observable<StreamScanCursor> |
scan(KeyStreamingChannel<K> channel,
ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate the keys space.
|
Observable<KeyScanCursor<K>> |
scan(ScanArgs scanArgs)
Incrementally iterate the keys space.
|
Observable<KeyScanCursor<K>> |
scan(ScanCursor scanCursor)
Incrementally iterate the keys space.
|
Observable<KeyScanCursor<K>> |
scan(ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate the keys space.
|
Observable<Long> |
scard(K key)
Get the number of members in a set.
|
Observable<Boolean> |
scriptExists(String... digests)
Check existence of scripts in the script cache.
|
Observable<String> |
scriptFlush()
Remove all the scripts from the script cache.
|
Observable<String> |
scriptKill()
Kill the script currently in execution.
|
Observable<String> |
scriptLoad(V script)
Load the specified Lua script into the script cache.
|
Observable<V> |
sdiff(K... keys)
Subtract multiple sets.
|
Observable<Long> |
sdiff(ValueStreamingChannel<V> channel,
K... keys)
Subtract multiple sets.
|
Observable<Long> |
sdiffstore(K destination,
K... keys)
Subtract multiple sets and store the resulting set in a key.
|
Observable<String> |
select(int db) |
Observable<String> |
set(K key,
V value)
Set the string value of a key.
|
Observable<String> |
set(K key,
V value,
SetArgs setArgs)
Set the string value of a key.
|
Observable<Long> |
setbit(K key,
long offset,
int value)
Sets or clears the bit at offset in the string value stored at key.
|
Observable<String> |
setex(K key,
long seconds,
V value)
Set the value and expiration of a key.
|
Observable<Boolean> |
setnx(K key,
V value)
Set the value of a key, only if the key does not exist.
|
Observable<Long> |
setrange(K key,
long offset,
V value)
Overwrite part of a string at key starting at the specified offset.
|
void |
setTimeout(long timeout,
TimeUnit unit)
Set the default timeout for operations.
|
Observable<Success> |
shutdown(boolean save)
Synchronously save the dataset to disk and then shut down the server.
|
Observable<V> |
sinter(K... keys)
Intersect multiple sets.
|
Observable<Long> |
sinter(ValueStreamingChannel<V> channel,
K... keys)
Intersect multiple sets.
|
Observable<Long> |
sinterstore(K destination,
K... keys)
Intersect multiple sets and store the resulting set in a key.
|
Observable<Boolean> |
sismember(K key,
V member)
Determine if a given value is a member of a set.
|
Observable<String> |
slaveof(String host,
int port)
Make the server a slave of another instance, or promote it as master.
|
Observable<String> |
slaveofNoOne()
Promote server as master.
|
Observable<Object> |
slowlogGet()
Read the slow log.
|
Observable<Object> |
slowlogGet(int count)
Read the slow log.
|
Observable<Long> |
slowlogLen()
Obtaining the current length of the slow log.
|
Observable<String> |
slowlogReset()
Resetting the slow log.
|
Observable<V> |
smembers(K key)
Get all the members in a set.
|
Observable<Long> |
smembers(ValueStreamingChannel<V> channel,
K key)
Get all the members in a set.
|
Observable<Boolean> |
smove(K source,
K destination,
V member)
Move a member from one set to another.
|
Observable<V> |
sort(K key)
Sort the elements in a list, set or sorted set.
|
Observable<V> |
sort(K key,
SortArgs sortArgs)
Sort the elements in a list, set or sorted set.
|
Observable<Long> |
sort(ValueStreamingChannel<V> channel,
K key)
Sort the elements in a list, set or sorted set.
|
Observable<Long> |
sort(ValueStreamingChannel<V> channel,
K key,
SortArgs sortArgs)
Sort the elements in a list, set or sorted set.
|
Observable<Long> |
sortStore(K key,
SortArgs sortArgs,
K destination)
Sort the elements in a list, set or sorted set.
|
Observable<V> |
spop(K key)
Remove and return a random member from a set.
|
Observable<V> |
spop(K key,
long count)
Remove and return one or multiple random members from a set.
|
Observable<V> |
srandmember(K key)
Get one random member from a set.
|
Observable<V> |
srandmember(K key,
long count)
Get one or multiple random members from a set.
|
Observable<Long> |
srandmember(ValueStreamingChannel<V> channel,
K key,
long count)
Get one or multiple random members from a set.
|
Observable<Long> |
srem(K key,
V... members)
Remove one or more members from a set.
|
Observable<ValueScanCursor<V>> |
sscan(K key)
Incrementally iterate Set elements.
|
Observable<ValueScanCursor<V>> |
sscan(K key,
ScanArgs scanArgs)
Incrementally iterate Set elements.
|
Observable<ValueScanCursor<V>> |
sscan(K key,
ScanCursor scanCursor)
Incrementally iterate Set elements.
|
Observable<ValueScanCursor<V>> |
sscan(K key,
ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate Set elements.
|
Observable<StreamScanCursor> |
sscan(ValueStreamingChannel<V> channel,
K key)
Incrementally iterate Set elements.
|
Observable<StreamScanCursor> |
sscan(ValueStreamingChannel<V> channel,
K key,
ScanArgs scanArgs)
Incrementally iterate Set elements.
|
Observable<StreamScanCursor> |
sscan(ValueStreamingChannel<V> channel,
K key,
ScanCursor scanCursor)
Incrementally iterate Set elements.
|
Observable<StreamScanCursor> |
sscan(ValueStreamingChannel<V> channel,
K key,
ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate Set elements.
|
Observable<Long> |
strlen(K key)
Get the length of the value stored in a key.
|
Observable<V> |
sunion(K... keys)
Add multiple sets.
|
Observable<Long> |
sunion(ValueStreamingChannel<V> channel,
K... keys)
Add multiple sets.
|
Observable<Long> |
sunionstore(K destination,
K... keys)
Add multiple sets and store the resulting set in a key.
|
Observable<String> |
swapdb(int db1,
int db2) |
Observable<String> |
sync()
Internal command used for replication.
|
Observable<V> |
time()
Return the current server time.
|
Observable<Long> |
touch(Iterable<K> keys) |
Observable<Long> |
touch(K... keys)
Touch one or more keys.
|
Observable<Long> |
ttl(K key)
Get the time to live for a key.
|
Observable<String> |
type(K key)
Determine the type stored at key.
|
Observable<Long> |
unlink(Iterable<K> keys) |
Observable<Long> |
unlink(K... keys)
Unlink one or more keys (non blocking DEL).
|
Observable<String> |
unwatch()
Forget about all watched keys.
|
Observable<Long> |
waitForReplication(int replicas,
long timeout)
Wait for replication.
|
Observable<String> |
watch(K... keys)
Watch the given keys to determine execution of the MULTI/EXEC block.
|
Observable<Long> |
xack(K key,
K group,
String... messageIds)
Acknowledge one or more messages as processed.
|
Observable<String> |
xadd(K key,
Map<K,V> body)
Append a message to the stream
key . |
Observable<String> |
xadd(K key,
Object... keysAndValues)
Append a message to the stream
key . |
Observable<String> |
xadd(K key,
XAddArgs args,
Map<K,V> body)
Append a message to the stream
key . |
Observable<String> |
xadd(K key,
XAddArgs args,
Object... keysAndValues)
Append a message to the stream
key . |
Observable<StreamMessage<K,V>> |
xclaim(K key,
Consumer<K> consumer,
long minIdleTime,
String... messageIds)
Gets ownership of one or multiple messages in the Pending Entries List of a given stream consumer group.
|
Observable<StreamMessage<K,V>> |
xclaim(K key,
Consumer<K> consumer,
XClaimArgs args,
String... messageIds)
Gets ownership of one or multiple messages in the Pending Entries List of a given stream consumer group.
|
Observable<Long> |
xdel(K key,
String... messageIds)
Removes the specified entries from the stream.
|
Observable<String> |
xgroupCreate(XReadArgs.StreamOffset<K> streamOffset,
K group)
Create a consumer group.
|
Observable<Boolean> |
xgroupDelconsumer(K key,
Consumer<K> consumer)
Delete a consumer from a consumer group.
|
Observable<Boolean> |
xgroupDestroy(K key,
K group)
Destroy a consumer group.
|
Observable<String> |
xgroupSetid(XReadArgs.StreamOffset<K> streamOffset,
K group)
Set the current
group id. |
Observable<Long> |
xlen(K key)
Get the length of a steam.
|
Observable<Object> |
xpending(K key,
Consumer<K> consumer,
Range<String> range,
Limit limit)
Read pending messages from a stream within a specific
Range . |
Observable<Object> |
xpending(K key,
K group)
Read pending messages from a stream for a
group . |
Observable<Object> |
xpending(K key,
K group,
Range<String> range,
Limit limit)
Read pending messages from a stream within a specific
Range . |
Observable<StreamMessage<K,V>> |
xrange(K key,
Range<String> range)
Read messages from a stream within a specific
Range . |
Observable<StreamMessage<K,V>> |
xrange(K key,
Range<String> range,
Limit limit)
|
Observable<StreamMessage<K,V>> |
xread(XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffset s. |
Observable<StreamMessage<K,V>> |
xread(XReadArgs args,
XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffset s. |
Observable<StreamMessage<K,V>> |
xreadgroup(Consumer<K> consumer,
XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffset s using a consumer group. |
Observable<StreamMessage<K,V>> |
xreadgroup(Consumer<K> consumer,
XReadArgs args,
XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffset s using a consumer group. |
Observable<StreamMessage<K,V>> |
xrevrange(K key,
Range<String> range)
Read messages from a stream within a specific
Range in reverse order. |
Observable<StreamMessage<K,V>> |
xrevrange(K key,
Range<String> range,
Limit limit)
|
Observable<Long> |
xtrim(K key,
boolean approximateTrimming,
long count)
Trims the stream to
count elements. |
Observable<Long> |
xtrim(K key,
long count)
Trims the stream to
count elements. |
Observable<Long> |
zadd(K key,
double score,
V member)
Add one or more members to a sorted set, or update its score if it already exists.
|
Observable<Long> |
zadd(K key,
Object... scoresAndValues)
Add one or more members to a sorted set, or update its score if it already exists.
|
Observable<Long> |
zadd(K key,
ScoredValue<V>... scoredValues)
Add one or more members to a sorted set, or update its score if it already exists.
|
Observable<Long> |
zadd(K key,
ZAddArgs zAddArgs,
double score,
V member)
Add one or more members to a sorted set, or update its score if it already exists.
|
Observable<Long> |
zadd(K key,
ZAddArgs zAddArgs,
Object... scoresAndValues)
Add one or more members to a sorted set, or update its score if it already exists.
|
Observable<Long> |
zadd(K key,
ZAddArgs zAddArgs,
ScoredValue<V>... scoredValues)
Add one or more members to a sorted set, or update its score if it already exists.
|
Observable<Double> |
zaddincr(K key,
double score,
V member)
Add one or more members to a sorted set, or update its score if it already exists applying the
INCR option. |
Observable<Double> |
zaddincr(K key,
ZAddArgs zAddArgs,
double score,
V member)
Add one or more members to a sorted set, or update its score if it already exists applying the
INCR option. |
Observable<Long> |
zcard(K key)
Get the number of members in a sorted set.
|
Observable<Long> |
zcount(K key,
double min,
double max)
Count the members in a sorted set with scores within the given values.
|
Observable<Long> |
zcount(K key,
Range<? extends Number> range)
Count the members in a sorted set with scores within the given
Range . |
Observable<Long> |
zcount(K key,
String min,
String max)
Count the members in a sorted set with scores within the given values.
|
Observable<Double> |
zincrby(K key,
double amount,
V member)
Increment the score of a member in a sorted set.
|
Observable<Long> |
zinterstore(K destination,
K... keys)
Intersect multiple sorted sets and store the resulting sorted set in a new key.
|
Observable<Long> |
zinterstore(K destination,
ZStoreArgs storeArgs,
K... keys)
Intersect multiple sorted sets and store the resulting sorted set in a new key.
|
Observable<Long> |
zlexcount(K key,
Range<? extends V> range)
Count the number of members in a sorted set between a given lexicographical range.
|
Observable<Long> |
zlexcount(K key,
String min,
String max)
Count the number of members in a sorted set between a given lexicographical range.
|
Observable<ScoredValue<V>> |
zpopmax(K key)
Removes and returns up to count members with the highest scores in the sorted set stored at key.
|
Observable<ScoredValue<V>> |
zpopmax(K key,
long count)
Removes and returns up to count members with the highest scores in the sorted set stored at key.
|
Observable<ScoredValue<V>> |
zpopmin(K key)
Removes and returns up to count members with the lowest scores in the sorted set stored at key.
|
Observable<ScoredValue<V>> |
zpopmin(K key,
long count)
Removes and returns up to count members with the lowest scores in the sorted set stored at key.
|
Observable<V> |
zrange(K key,
long start,
long stop)
Return a range of members in a sorted set, by index.
|
Observable<Long> |
zrange(ValueStreamingChannel<V> channel,
K key,
long start,
long stop)
Return a range of members in a sorted set, by index.
|
Observable<V> |
zrangebylex(K key,
Range<? extends V> range)
Return a range of members in a sorted set, by lexicographical range.
|
Observable<V> |
zrangebylex(K key,
Range<? extends V> range,
Limit limit)
Return a range of members in a sorted set, by lexicographical range.
|
Observable<V> |
zrangebylex(K key,
String min,
String max)
Return a range of members in a sorted set, by lexicographical range.
|
Observable<V> |
zrangebylex(K key,
String min,
String max,
long offset,
long count)
Return a range of members in a sorted set, by lexicographical range.
|
Observable<V> |
zrangebyscore(K key,
double min,
double max)
Return a range of members in a sorted set, by score.
|
Observable<V> |
zrangebyscore(K key,
double min,
double max,
long offset,
long count)
Return a range of members in a sorted set, by score.
|
Observable<V> |
zrangebyscore(K key,
Range<? extends Number> range)
Return a range of members in a sorted set, by score.
|
Observable<V> |
zrangebyscore(K key,
Range<? extends Number> range,
Limit limit)
Return a range of members in a sorted set, by score.
|
Observable<V> |
zrangebyscore(K key,
String min,
String max)
Return a range of members in a sorted set, by score.
|
Observable<V> |
zrangebyscore(K key,
String min,
String max,
long offset,
long count)
Return a range of members in a sorted set, by score.
|
Observable<Long> |
zrangebyscore(ValueStreamingChannel<V> channel,
K key,
double min,
double max)
Stream over a range of members in a sorted set, by score.
|
Observable<Long> |
zrangebyscore(ValueStreamingChannel<V> channel,
K key,
double min,
double max,
long offset,
long count)
Stream over range of members in a sorted set, by score.
|
Observable<Long> |
zrangebyscore(ValueStreamingChannel<V> channel,
K key,
Range<? extends Number> range)
Stream over a range of members in a sorted set, by score.
|
Observable<Long> |
zrangebyscore(ValueStreamingChannel<V> channel,
K key,
Range<? extends Number> range,
Limit limit)
Stream over a range of members in a sorted set, by score.
|
Observable<Long> |
zrangebyscore(ValueStreamingChannel<V> channel,
K key,
String min,
String max)
Stream over a range of members in a sorted set, by score.
|
Observable<Long> |
zrangebyscore(ValueStreamingChannel<V> channel,
K key,
String min,
String max,
long offset,
long count)
Stream over a range of members in a sorted set, by score.
|
Observable<ScoredValue<V>> |
zrangebyscoreWithScores(K key,
double min,
double max)
Return a range of members with score in a sorted set, by score.
|
Observable<ScoredValue<V>> |
zrangebyscoreWithScores(K key,
double min,
double max,
long offset,
long count)
Return a range of members with score in a sorted set, by score.
|
Observable<ScoredValue<V>> |
zrangebyscoreWithScores(K key,
Range<? extends Number> range)
Return a range of members with score in a sorted set, by score.
|
Observable<ScoredValue<V>> |
zrangebyscoreWithScores(K key,
Range<? extends Number> range,
Limit limit)
Return a range of members with score in a sorted set, by score.
|
Observable<ScoredValue<V>> |
zrangebyscoreWithScores(K key,
String min,
String max)
Return a range of members with score in a sorted set, by score.
|
Observable<ScoredValue<V>> |
zrangebyscoreWithScores(K key,
String min,
String max,
long offset,
long count)
Return a range of members with score in a sorted set, by score.
|
Observable<Long> |
zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
double min,
double max)
Stream over a range of members with scores in a sorted set, by score.
|
Observable<Long> |
zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
double min,
double max,
long offset,
long count)
Stream over a range of members with scores in a sorted set, by score.
|
Observable<Long> |
zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
Range<? extends Number> range)
Stream over a range of members with scores in a sorted set, by score.
|
Observable<Long> |
zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
Range<? extends Number> range,
Limit limit)
Stream over a range of members with scores in a sorted set, by score.
|
Observable<Long> |
zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
String min,
String max)
Stream over a range of members with scores in a sorted set, by score.
|
Observable<Long> |
zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
String min,
String max,
long offset,
long count)
Stream over a range of members with scores in a sorted set, by score.
|
Observable<ScoredValue<V>> |
zrangeWithScores(K key,
long start,
long stop)
Return a range of members with scores in a sorted set, by index.
|
Observable<Long> |
zrangeWithScores(ScoredValueStreamingChannel<V> channel,
K key,
long start,
long stop)
Stream over a range of members with scores in a sorted set, by index.
|
Observable<Long> |
zrank(K key,
V member)
Determine the index of a member in a sorted set.
|
Observable<Long> |
zrem(K key,
V... members)
Remove one or more members from a sorted set.
|
Observable<Long> |
zremrangebylex(K key,
Range<? extends V> range)
Remove all members in a sorted set between the given lexicographical range.
|
Observable<Long> |
zremrangebylex(K key,
String min,
String max)
Remove all members in a sorted set between the given lexicographical range.
|
Observable<Long> |
zremrangebyrank(K key,
long start,
long stop)
Remove all members in a sorted set within the given indexes.
|
Observable<Long> |
zremrangebyscore(K key,
double min,
double max)
Remove all members in a sorted set within the given scores.
|
Observable<Long> |
zremrangebyscore(K key,
Range<? extends Number> range)
Remove all members in a sorted set within the given scores.
|
Observable<Long> |
zremrangebyscore(K key,
String min,
String max)
Remove all members in a sorted set within the given scores.
|
Observable<V> |
zrevrange(K key,
long start,
long stop)
Return a range of members in a sorted set, by index, with scores ordered from high to low.
|
Observable<Long> |
zrevrange(ValueStreamingChannel<V> channel,
K key,
long start,
long stop)
Stream over a range of members in a sorted set, by index, with scores ordered from high to low.
|
Observable<V> |
zrevrangebylex(K key,
Range<? extends V> range)
Return a range of members in a sorted set, by lexicographical range ordered from high to low.
|
Observable<V> |
zrevrangebylex(K key,
Range<? extends V> range,
Limit limit)
Return a range of members in a sorted set, by lexicographical range ordered from high to low.
|
Observable<V> |
zrevrangebyscore(K key,
double max,
double min)
Return a range of members in a sorted set, by score, with scores ordered from high to low.
|
Observable<V> |
zrevrangebyscore(K key,
double max,
double min,
long offset,
long count)
Return a range of members in a sorted set, by score, with scores ordered from high to low.
|
Observable<V> |
zrevrangebyscore(K key,
Range<? extends Number> range)
Return a range of members in a sorted set, by score, with scores ordered from high to low.
|
Observable<V> |
zrevrangebyscore(K key,
Range<? extends Number> range,
Limit limit)
Return a range of members in a sorted set, by score, with scores ordered from high to low.
|
Observable<V> |
zrevrangebyscore(K key,
String max,
String min)
Return a range of members in a sorted set, by score, with scores ordered from high to low.
|
Observable<V> |
zrevrangebyscore(K key,
String max,
String min,
long offset,
long count)
Return a range of members in a sorted set, by score, with scores ordered from high to low.
|
Observable<Long> |
zrevrangebyscore(ValueStreamingChannel<V> channel,
K key,
double max,
double min)
Stream over a range of members in a sorted set, by score, with scores ordered from high to low.
|
Observable<Long> |
zrevrangebyscore(ValueStreamingChannel<V> channel,
K key,
double max,
double min,
long offset,
long count)
Stream over a range of members in a sorted set, by score, with scores ordered from high to low.
|
Observable<Long> |
zrevrangebyscore(ValueStreamingChannel<V> channel,
K key,
Range<? extends Number> range)
Stream over a range of members in a sorted set, by score, with scores ordered from high to low.
|
Observable<Long> |
zrevrangebyscore(ValueStreamingChannel<V> channel,
K key,
Range<? extends Number> range,
Limit limit)
Stream over a range of members in a sorted set, by score, with scores ordered from high to low.
|
Observable<Long> |
zrevrangebyscore(ValueStreamingChannel<V> channel,
K key,
String max,
String min)
Stream over a range of members in a sorted set, by score, with scores ordered from high to low.
|
Observable<Long> |
zrevrangebyscore(ValueStreamingChannel<V> channel,
K key,
String max,
String min,
long offset,
long count)
Stream over a range of members in a sorted set, by score, with scores ordered from high to low.
|
Observable<ScoredValue<V>> |
zrevrangebyscoreWithScores(K key,
double max,
double min)
Return a range of members with scores in a sorted set, by score, with scores ordered from high to low.
|
Observable<ScoredValue<V>> |
zrevrangebyscoreWithScores(K key,
double max,
double min,
long offset,
long count)
Return a range of members with scores in a sorted set, by score, with scores ordered from high to low.
|
Observable<ScoredValue<V>> |
zrevrangebyscoreWithScores(K key,
Range<? extends Number> range)
Return a range of members with scores in a sorted set, by score, with scores ordered from high to low.
|
Observable<ScoredValue<V>> |
zrevrangebyscoreWithScores(K key,
Range<? extends Number> range,
Limit limit)
Return a range of members with scores in a sorted set, by score, with scores ordered from high to low.
|
Observable<ScoredValue<V>> |
zrevrangebyscoreWithScores(K key,
String max,
String min)
Return a range of members with scores in a sorted set, by score, with scores ordered from high to low.
|
Observable<ScoredValue<V>> |
zrevrangebyscoreWithScores(K key,
String max,
String min,
long offset,
long count)
Return a range of members with scores in a sorted set, by score, with scores ordered from high to low.
|
Observable<Long> |
zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
double max,
double min)
Stream over a range of members with scores in a sorted set, by score, with scores ordered from high to low.
|
Observable<Long> |
zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
double max,
double min,
long offset,
long count)
Stream over a range of members with scores in a sorted set, by score, with scores ordered from high to low.
|
Observable<Long> |
zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
Range<? extends Number> range)
Stream over a range of members with scores in a sorted set, by score, with scores ordered from high to low.
|
Observable<Long> |
zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
Range<? extends Number> range,
Limit limit)
Stream over a range of members with scores in a sorted set, by score, with scores ordered from high to low.
|
Observable<Long> |
zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
String max,
String min)
Stream over a range of members with scores in a sorted set, by score, with scores ordered from high to low.
|
Observable<Long> |
zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
String max,
String min,
long offset,
long count)
Stream over a range of members with scores in a sorted set, by score, with scores ordered from high to low.
|
Observable<ScoredValue<V>> |
zrevrangeWithScores(K key,
long start,
long stop)
Return a range of members with scores in a sorted set, by index, with scores ordered from high to low.
|
Observable<Long> |
zrevrangeWithScores(ScoredValueStreamingChannel<V> channel,
K key,
long start,
long stop)
Stream over a range of members with scores in a sorted set, by index, with scores ordered from high to low.
|
Observable<Long> |
zrevrank(K key,
V member)
Determine the index of a member in a sorted set, with scores ordered from high to low.
|
Observable<ScoredValueScanCursor<V>> |
zscan(K key)
Incrementally iterate sorted sets elements and associated scores.
|
Observable<ScoredValueScanCursor<V>> |
zscan(K key,
ScanArgs scanArgs)
Incrementally iterate sorted sets elements and associated scores.
|
Observable<ScoredValueScanCursor<V>> |
zscan(K key,
ScanCursor scanCursor)
Incrementally iterate sorted sets elements and associated scores.
|
Observable<ScoredValueScanCursor<V>> |
zscan(K key,
ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate sorted sets elements and associated scores.
|
Observable<StreamScanCursor> |
zscan(ScoredValueStreamingChannel<V> channel,
K key)
Incrementally iterate sorted sets elements and associated scores.
|
Observable<StreamScanCursor> |
zscan(ScoredValueStreamingChannel<V> channel,
K key,
ScanArgs scanArgs)
Incrementally iterate sorted sets elements and associated scores.
|
Observable<StreamScanCursor> |
zscan(ScoredValueStreamingChannel<V> channel,
K key,
ScanCursor scanCursor)
Incrementally iterate sorted sets elements and associated scores.
|
Observable<StreamScanCursor> |
zscan(ScoredValueStreamingChannel<V> channel,
K key,
ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate sorted sets elements and associated scores.
|
Observable<Double> |
zscore(K key,
V member)
Get the score associated with the given member in a sorted set.
|
Observable<Long> |
zunionstore(K destination,
K... keys)
Add multiple sorted sets and store the resulting sorted set in a new key.
|
Observable<Long> |
zunionstore(K destination,
ZStoreArgs storeArgs,
K... keys)
Add multiple sorted sets and store the resulting sorted set in a new key.
|
protected StatefulConnection<K,V> connection
protected RedisCodec<K,V> codec
protected MultiOutput<K,V> multi
public AbstractRedisReactiveCommands(StatefulConnection<K,V> connection, RedisCodec<K,V> codec)
connection
- the connection to operate oncodec
- the codec for command encodingpublic Observable<Long> append(K key, V value)
RedisStringReactiveCommands
append
in interface RedisStringReactiveCommands<K,V>
key
- the keyvalue
- the valuepublic Observable<String> asking()
RedisClusterReactiveCommands
-ASK
redirection. The client should issue ASKING
before to
actually send the command to the target instance. See the Redis Cluster specification for more information.asking
in interface RedisClusterReactiveCommands<K,V>
public Observable<String> auth(String password)
RedisClusterReactiveCommands
auth
in interface RedisClusterReactiveCommands<K,V>
password
- the passwordpublic Observable<String> bgrewriteaof()
RedisServerReactiveCommands
bgrewriteaof
in interface RedisServerReactiveCommands<K,V>
OK
.public Observable<String> bgsave()
RedisServerReactiveCommands
bgsave
in interface RedisServerReactiveCommands<K,V>
public Observable<Long> bitcount(K key)
RedisStringReactiveCommands
bitcount
in interface RedisStringReactiveCommands<K,V>
key
- the keypublic Observable<Long> bitcount(K key, long start, long end)
RedisStringReactiveCommands
bitcount
in interface RedisStringReactiveCommands<K,V>
key
- the keystart
- the startend
- the endpublic Observable<Long> bitfield(K key, BitFieldArgs args)
RedisStringReactiveCommands
BITFIELD
with its subcommands.bitfield
in interface RedisStringReactiveCommands<K,V>
key
- the keyargs
- the args containing subcommands, must not be null.public Observable<Long> bitopAnd(K destination, K... keys)
RedisStringReactiveCommands
bitopAnd
in interface RedisStringReactiveCommands<K,V>
destination
- result key of the operationkeys
- operation input key namespublic Observable<Long> bitopNot(K destination, K source)
RedisStringReactiveCommands
bitopNot
in interface RedisStringReactiveCommands<K,V>
destination
- result key of the operationsource
- operation input key namespublic Observable<Long> bitopOr(K destination, K... keys)
RedisStringReactiveCommands
bitopOr
in interface RedisStringReactiveCommands<K,V>
destination
- result key of the operationkeys
- operation input key namespublic Observable<Long> bitopXor(K destination, K... keys)
RedisStringReactiveCommands
bitopXor
in interface RedisStringReactiveCommands<K,V>
destination
- result key of the operationkeys
- operation input key namespublic Observable<Long> bitpos(K key, boolean state)
RedisStringReactiveCommands
bitpos
in interface RedisStringReactiveCommands<K,V>
key
- the keystate
- the stateBITPOS key 0
will return 24, since up to bit 23 all the bits are 1.
Basically the function consider the right of the string as padded with zeros if you look for clear bits and
specify no range.public Observable<Long> bitpos(K key, boolean state, long start)
RedisStringReactiveCommands
bitpos
in interface RedisStringReactiveCommands<K,V>
key
- the keystate
- the bit type: longstart
- the start type: longBITPOS key 0
will return 24, since up to bit 23 all the bits are 1.
Basically the function consider the right of the string as padded with zeros if you look for clear bits and
specify no range or the start argument only.public Observable<Long> bitpos(K key, boolean state, long start, long end)
RedisStringReactiveCommands
bitpos
in interface RedisStringReactiveCommands<K,V>
key
- the keystate
- the bit type: longstart
- the start type: longend
- the end type: longBITPOS key 0
will return 24, since up to bit 23 all the bits are 1.
Basically the function consider the right of the string as padded with zeros if you look for clear bits and
specify no range or the start argument only.
However this behavior changes if you are looking for clear bits and specify a range with both
start and end. If no clear bit is found in the specified range, the function
returns -1 as the user specified a clear range and there are no 0 bits in that range.public Observable<KeyValue<K,V>> blpop(long timeout, K... keys)
RedisListReactiveCommands
blpop
in interface RedisListReactiveCommands<K,V>
timeout
- the timeout in secondskeys
- the keyspublic Observable<KeyValue<K,V>> brpop(long timeout, K... keys)
RedisListReactiveCommands
brpop
in interface RedisListReactiveCommands<K,V>
timeout
- the timeout in secondskeys
- the keyspublic Observable<V> brpoplpush(long timeout, K source, K destination)
RedisListReactiveCommands
brpoplpush
in interface RedisListReactiveCommands<K,V>
timeout
- the timeout in secondssource
- the source keydestination
- the destination type: keysource
and pushed to destination
. If
timeout
is reached, apublic Observable<K> clientGetname()
RedisServerReactiveCommands
clientGetname
in interface RedisServerReactiveCommands<K,V>
public Observable<String> clientKill(String addr)
RedisServerReactiveCommands
clientKill
in interface RedisServerReactiveCommands<K,V>
addr
- ip:portOK
if the connection exists and has been closedpublic Observable<Long> clientKill(KillArgs killArgs)
RedisServerReactiveCommands
killArgs
clientKill
in interface RedisServerReactiveCommands<K,V>
killArgs
- args for the kill operationpublic Observable<String> clientList()
RedisServerReactiveCommands
clientList
in interface RedisServerReactiveCommands<K,V>
public Observable<String> clientPause(long timeout)
RedisServerReactiveCommands
clientPause
in interface RedisServerReactiveCommands<K,V>
timeout
- the timeout value in millisecondspublic Observable<String> clientSetname(K name)
RedisServerReactiveCommands
clientSetname
in interface RedisServerReactiveCommands<K,V>
name
- the client nameOK
if the connection name was successfully set.public Observable<Long> clientUnblock(long id, UnblockType type)
RedisServerReactiveCommands
clientUnblock
in interface RedisServerReactiveCommands<K,V>
id
- the client id.type
- unblock type.public void close()
BaseRedisReactiveCommands
close
in interface BaseRedisReactiveCommands<K,V>
close
in interface AutoCloseable
public Observable<String> clusterAddSlots(int... slots)
RedisClusterReactiveCommands
clusterAddSlots
in interface RedisClusterReactiveCommands<K,V>
slots
- one or more slots from 0 to 16384public Observable<String> clusterBumpepoch()
RedisClusterReactiveCommands
clusterBumpepoch
in interface RedisClusterReactiveCommands<K,V>
public Observable<Long> clusterCountFailureReports(String nodeId)
RedisClusterReactiveCommands
clusterCountFailureReports
in interface RedisClusterReactiveCommands<K,V>
nodeId
- the node idpublic Observable<Long> clusterCountKeysInSlot(int slot)
RedisClusterReactiveCommands
slot
.clusterCountKeysInSlot
in interface RedisClusterReactiveCommands<K,V>
slot
- the slotpublic Observable<String> clusterDelSlots(int... slots)
RedisClusterReactiveCommands
clusterDelSlots
in interface RedisClusterReactiveCommands<K,V>
slots
- one or more slots from 0 to 16384public Observable<String> clusterFailover(boolean force)
RedisClusterReactiveCommands
clusterFailover
in interface RedisClusterReactiveCommands<K,V>
force
- do not coordinate with master if truepublic Observable<String> clusterFlushslots()
RedisClusterReactiveCommands
clusterFlushslots
in interface RedisClusterReactiveCommands<K,V>
public Observable<String> clusterForget(String nodeId)
RedisClusterReactiveCommands
clusterForget
in interface RedisClusterReactiveCommands<K,V>
nodeId
- the node Idpublic Observable<K> clusterGetKeysInSlot(int slot, int count)
RedisClusterReactiveCommands
slot
.clusterGetKeysInSlot
in interface RedisClusterReactiveCommands<K,V>
slot
- the slotcount
- maximal number of keyspublic Observable<String> clusterInfo()
RedisClusterReactiveCommands
clusterInfo
in interface RedisClusterReactiveCommands<K,V>
public Observable<Long> clusterKeyslot(K key)
RedisClusterReactiveCommands
SlotHash.getSlot(byte[])
. If not, call Houston and report that we've got a problem.clusterKeyslot
in interface RedisClusterReactiveCommands<K,V>
key
- the key.public Observable<String> clusterMeet(String ip, int port)
RedisClusterReactiveCommands
clusterMeet
in interface RedisClusterReactiveCommands<K,V>
ip
- IP address of the hostport
- port number.public Observable<String> clusterMyId()
RedisClusterReactiveCommands
clusterMyId
in interface RedisClusterReactiveCommands<K,V>
public Observable<String> clusterNodes()
RedisClusterReactiveCommands
ClusterPartitionParser.parse(java.lang.String)
clusterNodes
in interface RedisClusterReactiveCommands<K,V>
public Observable<String> clusterReplicate(String nodeId)
RedisClusterReactiveCommands
nodeId
.clusterReplicate
in interface RedisClusterReactiveCommands<K,V>
nodeId
- master node idpublic Observable<String> clusterReset(boolean hard)
RedisClusterReactiveCommands
clusterReset
in interface RedisClusterReactiveCommands<K,V>
hard
- true for hard reset. Generates a new nodeId and currentEpoch/configEpoch are set to 0public Observable<String> clusterSaveconfig()
RedisClusterReactiveCommands
clusterSaveconfig
in interface RedisClusterReactiveCommands<K,V>
OK
or an error if the operation fails.public Observable<String> clusterSetConfigEpoch(long configEpoch)
RedisClusterReactiveCommands
clusterSetConfigEpoch
in interface RedisClusterReactiveCommands<K,V>
configEpoch
- the config epochOK
or an error if the operation fails.public Observable<String> clusterSetSlotImporting(int slot, String nodeId)
RedisClusterReactiveCommands
nodeId
.clusterSetSlotImporting
in interface RedisClusterReactiveCommands<K,V>
slot
- the slotnodeId
- the id of the node is the master of the slotpublic Observable<String> clusterSetSlotMigrating(int slot, String nodeId)
RedisClusterReactiveCommands
nodeId
. The slot must be handled by
the current node in order to be migrated.clusterSetSlotMigrating
in interface RedisClusterReactiveCommands<K,V>
slot
- the slotnodeId
- the id of the node is targeted to become the master for the slotpublic Observable<String> clusterSetSlotNode(int slot, String nodeId)
RedisClusterReactiveCommands
nodeId
clusterSetSlotNode
in interface RedisClusterReactiveCommands<K,V>
slot
- the slotnodeId
- the id of the node that will become the master for the slotpublic Observable<String> clusterSetSlotStable(int slot)
RedisClusterReactiveCommands
clusterSetSlotStable
in interface RedisClusterReactiveCommands<K,V>
slot
- the slotpublic Observable<String> clusterSlaves(String nodeId)
RedisClusterReactiveCommands
nodeId
. Can be parsed using
ClusterPartitionParser.parse(java.lang.String)
clusterSlaves
in interface RedisClusterReactiveCommands<K,V>
nodeId
- node id of the master nodeRedisClusterReactiveCommands.clusterNodes()
but one line per slave.public Observable<Object> clusterSlots()
RedisClusterReactiveCommands
clusterSlots
in interface RedisClusterReactiveCommands<K,V>
public Observable<Object> command()
RedisServerReactiveCommands
command
in interface RedisServerReactiveCommands<K,V>
public Observable<Long> commandCount()
RedisServerReactiveCommands
commandCount
in interface RedisServerReactiveCommands<K,V>
public Observable<Object> commandInfo(String... commands)
RedisServerReactiveCommands
commandInfo
in interface RedisServerReactiveCommands<K,V>
commands
- the commands to query forpublic Observable<Object> commandInfo(CommandType... commands)
RedisServerReactiveCommands
commandInfo
in interface RedisServerReactiveCommands<K,V>
commands
- the commands to query forpublic Observable<String> configGet(String parameter)
RedisServerReactiveCommands
configGet
in interface RedisServerReactiveCommands<K,V>
parameter
- name of the parameterpublic Observable<String> configResetstat()
RedisServerReactiveCommands
configResetstat
in interface RedisServerReactiveCommands<K,V>
OK
.public Observable<String> configRewrite()
RedisServerReactiveCommands
configRewrite
in interface RedisServerReactiveCommands<K,V>
OK
when the configuration was rewritten properly. Otherwise an error is
returned.public Observable<String> configSet(String parameter, String value)
RedisServerReactiveCommands
configSet
in interface RedisServerReactiveCommands<K,V>
parameter
- the parameter namevalue
- the parameter valueOK
when the configuration was set properly. Otherwise an error is returned.public <T,R> R createDissolvingObservable(Supplier<RedisCommand<K,V,T>> commandSupplier)
public <T,R> R createDissolvingObservable(CommandType type, CommandOutput<K,V,T> output, CommandArgs<K,V> args)
protected <T> Observable<T> createObservable(CommandType type, CommandOutput<K,V,T> output, CommandArgs<K,V> args)
public <T> Observable<T> createObservable(Supplier<RedisCommand<K,V,T>> commandSupplier)
public Observable<Long> dbsize()
RedisServerReactiveCommands
dbsize
in interface RedisServerReactiveCommands<K,V>
public Observable<String> debugCrashAndRecover(Long delay)
RedisServerReactiveCommands
debugCrashAndRecover
in interface RedisServerReactiveCommands<K,V>
delay
- optional delay in millisecondspublic Observable<String> debugHtstats(int db)
RedisServerReactiveCommands
debugHtstats
in interface RedisServerReactiveCommands<K,V>
db
- the database numberpublic Observable<String> debugObject(K key)
RedisServerReactiveCommands
debugObject
in interface RedisServerReactiveCommands<K,V>
key
- the keypublic Observable<Success> debugOom()
RedisServerReactiveCommands
debugOom
in interface RedisServerReactiveCommands<K,V>
public Observable<String> debugReload()
RedisServerReactiveCommands
debugReload
in interface RedisServerReactiveCommands<K,V>
public Observable<String> debugRestart(Long delay)
RedisServerReactiveCommands
debugRestart
in interface RedisServerReactiveCommands<K,V>
delay
- optional delay in millisecondspublic Observable<String> debugSdslen(K key)
RedisServerReactiveCommands
debugSdslen
in interface RedisServerReactiveCommands<K,V>
key
- the keypublic Observable<Success> debugSegfault()
RedisServerReactiveCommands
debugSegfault
in interface RedisServerReactiveCommands<K,V>
public Observable<Long> decr(K key)
RedisStringReactiveCommands
decr
in interface RedisStringReactiveCommands<K,V>
key
- the keykey
after the decrementpublic Observable<Long> decrby(K key, long amount)
RedisStringReactiveCommands
decrby
in interface RedisStringReactiveCommands<K,V>
key
- the keyamount
- the decrement type: longkey
after the decrementpublic Observable<Long> del(K... keys)
RedisKeyReactiveCommands
del
in interface RedisKeyReactiveCommands<K,V>
del
in interface RedisClusterReactiveCommands<K,V>
keys
- the keyspublic Observable<Long> del(Iterable<K> keys)
public String digest(V script)
RedisScriptingReactiveCommands
digest
in interface RedisScriptingReactiveCommands<K,V>
script
- script contentpublic Observable<String> discard()
RedisTransactionalReactiveCommands
discard
in interface RedisTransactionalReactiveCommands<K,V>
OK
.public <T> Observable<T> dispatch(ProtocolKeyword type, CommandOutput<K,V,?> output)
BaseRedisReactiveCommands
dispatch
in interface BaseRedisReactiveCommands<K,V>
T
- response typetype
- the command, must not be null.output
- the command output, must not be null.public <T> Observable<T> dispatch(ProtocolKeyword type, CommandOutput<K,V,?> output, CommandArgs<K,V> args)
BaseRedisReactiveCommands
dispatch
in interface BaseRedisReactiveCommands<K,V>
T
- response typetype
- the command, must not be null.output
- the command output, must not be null.args
- the command arguments, must not be null.public Observable<byte[]> dump(K key)
RedisKeyReactiveCommands
dump
in interface RedisKeyReactiveCommands<K,V>
key
- the keypublic Observable<V> echo(V msg)
BaseRedisReactiveCommands
echo
in interface BaseRedisReactiveCommands<K,V>
msg
- the message type: valuepublic <T> Observable<T> eval(String script, ScriptOutputType type, K... keys)
RedisScriptingReactiveCommands
eval
in interface RedisScriptingReactiveCommands<K,V>
T
- expected return typescript
- Lua 5.1 script.type
- output typekeys
- key namespublic <T> Observable<T> eval(String script, ScriptOutputType type, K[] keys, V... values)
RedisScriptingReactiveCommands
eval
in interface RedisScriptingReactiveCommands<K,V>
T
- expected return typescript
- Lua 5.1 script.type
- the typekeys
- the keysvalues
- the valuespublic <T> Observable<T> evalsha(String digest, ScriptOutputType type, K... keys)
RedisScriptingReactiveCommands
evalsha
in interface RedisScriptingReactiveCommands<K,V>
T
- expected return typedigest
- SHA1 of the scripttype
- the typekeys
- the keyspublic <T> Observable<T> evalsha(String digest, ScriptOutputType type, K[] keys, V... values)
RedisScriptingReactiveCommands
evalsha
in interface RedisScriptingReactiveCommands<K,V>
T
- expected return typedigest
- SHA1 of the scripttype
- the typekeys
- the keysvalues
- the valuespublic Observable<Object> exec()
RedisTransactionalReactiveCommands
exec
in interface RedisTransactionalReactiveCommands<K,V>
WATCH
, EXEC
can return apublic Observable<Boolean> exists(K key)
public Observable<Long> exists(K... keys)
RedisKeyReactiveCommands
exists
in interface RedisKeyReactiveCommands<K,V>
keys
- the keyspublic Observable<Long> exists(Iterable<K> keys)
public Observable<Boolean> expire(K key, long seconds)
RedisKeyReactiveCommands
expire
in interface RedisKeyReactiveCommands<K,V>
key
- the keyseconds
- the seconds type: longkey
does not exist or the timeout could not
be set.public Observable<Boolean> expireat(K key, long timestamp)
RedisKeyReactiveCommands
expireat
in interface RedisKeyReactiveCommands<K,V>
key
- the keytimestamp
- the timestamp type: posix timekey
does not exist or the timeout could not
be set (see: EXPIRE
).public Observable<Boolean> expireat(K key, Date timestamp)
RedisKeyReactiveCommands
expireat
in interface RedisKeyReactiveCommands<K,V>
key
- the keytimestamp
- the timestamp type: posix timekey
does not exist or the timeout could not
be set (see: EXPIRE
).public Observable<String> flushall()
RedisServerReactiveCommands
flushall
in interface RedisServerReactiveCommands<K,V>
public Observable<String> flushallAsync()
RedisServerReactiveCommands
flushallAsync
in interface RedisServerReactiveCommands<K,V>
public Observable<String> flushdb()
RedisServerReactiveCommands
flushdb
in interface RedisServerReactiveCommands<K,V>
public Observable<String> flushdbAsync()
RedisServerReactiveCommands
flushdbAsync
in interface RedisServerReactiveCommands<K,V>
public Observable<Long> geoadd(K key, double longitude, double latitude, V member)
RedisGeoReactiveCommands
geoadd
in interface RedisGeoReactiveCommands<K,V>
key
- the key of the geo setlongitude
- the longitude coordinate according to WGS84latitude
- the latitude coordinate according to WGS84member
- the member to addpublic Observable<Long> geoadd(K key, Object... lngLatMember)
RedisGeoReactiveCommands
geoadd
in interface RedisGeoReactiveCommands<K,V>
key
- the key of the geo setlngLatMember
- triplets of double longitude, double latitude and V memberpublic Observable<Double> geodist(K key, V from, V to, GeoArgs.Unit unit)
RedisGeoReactiveCommands
from
and to
. If one or more elements are missing null is
returned. Default in meters by, otherwise according to unit
geodist
in interface RedisGeoReactiveCommands<K,V>
key
- the key of the geo setfrom
- from memberto
- to memberunit
- distance unitfrom
and to
. If one or more elements are missing null is
returned.public Observable<String> geohash(K key, V... members)
RedisGeoReactiveCommands
geohash
in interface RedisGeoReactiveCommands<K,V>
key
- the key of the geo setmembers
- the membersmembers
. Returns null if a member is not found.public Observable<GeoCoordinates> geopos(K key, V... members)
RedisGeoReactiveCommands
members
.geopos
in interface RedisGeoReactiveCommands<K,V>
key
- the key of the geo setmembers
- the membersGeoCoordinates
s representing the x,y position of each element specified in the arguments. For
missing elements null is returned.public Observable<V> georadius(K key, double longitude, double latitude, double distance, GeoArgs.Unit unit)
RedisGeoReactiveCommands
longitude
and latitude
.georadius
in interface RedisGeoReactiveCommands<K,V>
key
- the key of the geo setlongitude
- the longitude coordinate according to WGS84latitude
- the latitude coordinate according to WGS84distance
- radius distanceunit
- distance unitpublic Observable<GeoWithin<V>> georadius(K key, double longitude, double latitude, double distance, GeoArgs.Unit unit, GeoArgs geoArgs)
RedisGeoReactiveCommands
longitude
and latitude
.georadius
in interface RedisGeoReactiveCommands<K,V>
key
- the key of the geo setlongitude
- the longitude coordinate according to WGS84latitude
- the latitude coordinate according to WGS84distance
- radius distanceunit
- distance unitgeoArgs
- args to control the resultGeoWithin
contains only fields which were requested by GeoArgs
public Observable<Long> georadius(K key, double longitude, double latitude, double distance, GeoArgs.Unit unit, GeoRadiusStoreArgs<K> geoRadiusStoreArgs)
RedisGeoReactiveCommands
RedisGeoReactiveCommands.georadius(Object, double, double, double, GeoArgs.Unit, GeoArgs)
query and store the results in a sorted set.georadius
in interface RedisGeoReactiveCommands<K,V>
key
- the key of the geo setlongitude
- the longitude coordinate according to WGS84latitude
- the latitude coordinate according to WGS84distance
- radius distanceunit
- distance unitgeoRadiusStoreArgs
- args to store either the resulting elements with their distance or the resulting elements with
their locations a sorted set.protected Observable<V> georadius_ro(K key, double longitude, double latitude, double distance, GeoArgs.Unit unit)
protected Observable<GeoWithin<V>> georadius_ro(K key, double longitude, double latitude, double distance, GeoArgs.Unit unit, GeoArgs geoArgs)
public Observable<V> georadiusbymember(K key, V member, double distance, GeoArgs.Unit unit)
RedisGeoReactiveCommands
member
. The member itself is always contained in the
results.georadiusbymember
in interface RedisGeoReactiveCommands<K,V>
key
- the key of the geo setmember
- reference memberdistance
- radius distanceunit
- distance unitpublic Observable<GeoWithin<V>> georadiusbymember(K key, V member, double distance, GeoArgs.Unit unit, GeoArgs geoArgs)
RedisGeoReactiveCommands
member
. The member itself is always contained in the
results.georadiusbymember
in interface RedisGeoReactiveCommands<K,V>
key
- the key of the geo setmember
- reference memberdistance
- radius distanceunit
- distance unitgeoArgs
- args to control the resultGeoWithin
contains only fields which were requested by GeoArgs
public Observable<Long> georadiusbymember(K key, V member, double distance, GeoArgs.Unit unit, GeoRadiusStoreArgs<K> geoRadiusStoreArgs)
RedisGeoReactiveCommands
RedisGeoReactiveCommands.georadiusbymember(Object, Object, double, GeoArgs.Unit, GeoArgs)
query and store the results in a sorted set.georadiusbymember
in interface RedisGeoReactiveCommands<K,V>
key
- the key of the geo setmember
- reference memberdistance
- radius distanceunit
- distance unitgeoRadiusStoreArgs
- args to store either the resulting elements with their distance or the resulting elements with
their locations a sorted set.protected Observable<V> georadiusbymember_ro(K key, V member, double distance, GeoArgs.Unit unit)
protected Observable<GeoWithin<V>> georadiusbymember_ro(K key, V member, double distance, GeoArgs.Unit unit, GeoArgs geoArgs)
public Observable<V> get(K key)
RedisStringReactiveCommands
get
in interface RedisStringReactiveCommands<K,V>
key
- the keykey
, or null when key
does not exist.public StatefulConnection<K,V> getConnection()
protected <T> Observable<Success> getSuccessObservable(Observable<T> observable)
Success.Success
or the Throwable
after the inner observable is completed.T
- used for type inferenceobservable
- inner observablepublic Observable<Long> getbit(K key, long offset)
RedisStringReactiveCommands
getbit
in interface RedisStringReactiveCommands<K,V>
key
- the keyoffset
- the offset type: longpublic Observable<V> getrange(K key, long start, long end)
RedisStringReactiveCommands
getrange
in interface RedisStringReactiveCommands<K,V>
key
- the keystart
- the start type: longend
- the end type: longpublic Observable<V> getset(K key, V value)
RedisStringReactiveCommands
getset
in interface RedisStringReactiveCommands<K,V>
key
- the keyvalue
- the valuekey
, or null when key
did not exist.public Observable<Long> hdel(K key, K... fields)
RedisHashReactiveCommands
hdel
in interface RedisHashReactiveCommands<K,V>
key
- the keyfields
- the field type: keypublic Observable<Boolean> hexists(K key, K field)
RedisHashReactiveCommands
hexists
in interface RedisHashReactiveCommands<K,V>
key
- the keyfield
- the field type: keyfield
. false if the hash does not contain field
,
or key
does not exist.public Observable<V> hget(K key, K field)
RedisHashReactiveCommands
hget
in interface RedisHashReactiveCommands<K,V>
key
- the keyfield
- the field type: keyfield
, or null when field
is not present
in the hash or key
does not exist.public Observable<Map<K,V>> hgetall(K key)
RedisHashReactiveCommands
hgetall
in interface RedisHashReactiveCommands<K,V>
key
- the keykey
does not exist.public Observable<Long> hgetall(KeyValueStreamingChannel<K,V> channel, K key)
RedisHashReactiveCommands
hgetall
in interface RedisHashReactiveCommands<K,V>
channel
- the channelkey
- the keypublic Observable<Long> hincrby(K key, K field, long amount)
RedisHashReactiveCommands
hincrby
in interface RedisHashReactiveCommands<K,V>
key
- the keyfield
- the field type: keyamount
- the increment type: longfield
after the increment operation.public Observable<Double> hincrbyfloat(K key, K field, double amount)
RedisHashReactiveCommands
hincrbyfloat
in interface RedisHashReactiveCommands<K,V>
key
- the keyfield
- the field type: keyamount
- the increment type: doublefield
after the increment.public Observable<K> hkeys(K key)
RedisHashReactiveCommands
hkeys
in interface RedisHashReactiveCommands<K,V>
key
- the keykey
does not exist.public Observable<Long> hkeys(KeyStreamingChannel<K> channel, K key)
RedisHashReactiveCommands
hkeys
in interface RedisHashReactiveCommands<K,V>
channel
- the channelkey
- the keypublic Observable<Long> hlen(K key)
RedisHashReactiveCommands
hlen
in interface RedisHashReactiveCommands<K,V>
key
- the key0
when key
does not exist.public Observable<V> hmget(K key, K... fields)
RedisHashReactiveCommands
hmget
in interface RedisHashReactiveCommands<K,V>
key
- the keyfields
- the field type: keypublic Observable<Long> hmget(ValueStreamingChannel<V> channel, K key, K... fields)
RedisHashReactiveCommands
hmget
in interface RedisHashReactiveCommands<K,V>
channel
- the channelkey
- the keyfields
- the fieldspublic Observable<String> hmset(K key, Map<K,V> map)
RedisHashReactiveCommands
hmset
in interface RedisHashReactiveCommands<K,V>
key
- the keymap
- the nullpublic Observable<MapScanCursor<K,V>> hscan(K key)
RedisHashReactiveCommands
hscan
in interface RedisHashReactiveCommands<K,V>
key
- the keypublic Observable<MapScanCursor<K,V>> hscan(K key, ScanArgs scanArgs)
RedisHashReactiveCommands
hscan
in interface RedisHashReactiveCommands<K,V>
key
- the keyscanArgs
- scan argumentspublic Observable<MapScanCursor<K,V>> hscan(K key, ScanCursor scanCursor, ScanArgs scanArgs)
RedisHashReactiveCommands
hscan
in interface RedisHashReactiveCommands<K,V>
key
- the keyscanCursor
- cursor to resume from a previous scan, must not be nullscanArgs
- scan argumentspublic Observable<MapScanCursor<K,V>> hscan(K key, ScanCursor scanCursor)
RedisHashReactiveCommands
hscan
in interface RedisHashReactiveCommands<K,V>
key
- the keyscanCursor
- cursor to resume from a previous scan, must not be nullpublic Observable<StreamScanCursor> hscan(KeyValueStreamingChannel<K,V> channel, K key)
RedisHashReactiveCommands
hscan
in interface RedisHashReactiveCommands<K,V>
channel
- streaming channel that receives a call for every key-value pairkey
- the keypublic Observable<StreamScanCursor> hscan(KeyValueStreamingChannel<K,V> channel, K key, ScanArgs scanArgs)
RedisHashReactiveCommands
hscan
in interface RedisHashReactiveCommands<K,V>
channel
- streaming channel that receives a call for every key-value pairkey
- the keyscanArgs
- scan argumentspublic Observable<StreamScanCursor> hscan(KeyValueStreamingChannel<K,V> channel, K key, ScanCursor scanCursor, ScanArgs scanArgs)
RedisHashReactiveCommands
hscan
in interface RedisHashReactiveCommands<K,V>
channel
- streaming channel that receives a call for every key-value pairkey
- the keyscanCursor
- cursor to resume from a previous scan, must not be nullscanArgs
- scan argumentspublic Observable<StreamScanCursor> hscan(KeyValueStreamingChannel<K,V> channel, K key, ScanCursor scanCursor)
RedisHashReactiveCommands
hscan
in interface RedisHashReactiveCommands<K,V>
channel
- streaming channel that receives a call for every key-value pairkey
- the keyscanCursor
- cursor to resume from a previous scan, must not be nullpublic Observable<Boolean> hset(K key, K field, V value)
RedisHashReactiveCommands
hset
in interface RedisHashReactiveCommands<K,V>
key
- the keyfield
- the field type: keyvalue
- the valuefield
is a new field in the hash and value
was set. false if
field
already exists in the hash and the value was updated.public Observable<Boolean> hsetnx(K key, K field, V value)
RedisHashReactiveCommands
hsetnx
in interface RedisHashReactiveCommands<K,V>
key
- the keyfield
- the field type: keyvalue
- the value1
if field
is a new field in the hash and value
was set. 0
if field
already exists in the hash and no operation was performed.public Observable<Long> hstrlen(K key, K field)
RedisHashReactiveCommands
hstrlen
in interface RedisHashReactiveCommands<K,V>
key
- the keyfield
- the field type: keyfield
value, or 0
when field
is not present
in the hash or key
does not exist at all.public Observable<V> hvals(K key)
RedisHashReactiveCommands
hvals
in interface RedisHashReactiveCommands<K,V>
key
- the keykey
does not exist.public Observable<Long> hvals(ValueStreamingChannel<V> channel, K key)
RedisHashReactiveCommands
hvals
in interface RedisHashReactiveCommands<K,V>
channel
- streaming channel that receives a call for every valuekey
- the keypublic Observable<Long> incr(K key)
RedisStringReactiveCommands
incr
in interface RedisStringReactiveCommands<K,V>
key
- the keykey
after the incrementpublic Observable<Long> incrby(K key, long amount)
RedisStringReactiveCommands
incrby
in interface RedisStringReactiveCommands<K,V>
key
- the keyamount
- the increment type: longkey
after the incrementpublic Observable<Double> incrbyfloat(K key, double amount)
RedisStringReactiveCommands
incrbyfloat
in interface RedisStringReactiveCommands<K,V>
key
- the keyamount
- the increment type: doublekey
after the increment.public Observable<String> info()
RedisServerReactiveCommands
info
in interface RedisServerReactiveCommands<K,V>
public Observable<String> info(String section)
RedisServerReactiveCommands
info
in interface RedisServerReactiveCommands<K,V>
section
- the section type: stringpublic boolean isOpen()
isOpen
in interface BaseRedisReactiveCommands<K,V>
public Observable<K> keys(K pattern)
RedisKeyReactiveCommands
keys
in interface RedisKeyReactiveCommands<K,V>
pattern
- the pattern type: patternkey (pattern)pattern
.public Observable<Long> keys(KeyStreamingChannel<K> channel, K pattern)
RedisKeyReactiveCommands
keys
in interface RedisKeyReactiveCommands<K,V>
channel
- the channelpattern
- the patternpattern
.public Observable<Date> lastsave()
RedisServerReactiveCommands
lastsave
in interface RedisServerReactiveCommands<K,V>
public Observable<V> lindex(K key, long index)
RedisListReactiveCommands
lindex
in interface RedisListReactiveCommands<K,V>
key
- the keyindex
- the index type: longindex
is out of range.public Observable<Long> linsert(K key, boolean before, V pivot, V value)
RedisListReactiveCommands
linsert
in interface RedisListReactiveCommands<K,V>
key
- the keybefore
- the beforepivot
- the pivotvalue
- the value-1
when the value pivot
was not found.public Observable<Long> llen(K key)
RedisListReactiveCommands
llen
in interface RedisListReactiveCommands<K,V>
key
- the keykey
.public Observable<V> lpop(K key)
RedisListReactiveCommands
lpop
in interface RedisListReactiveCommands<K,V>
key
- the keykey
does not exist.public Observable<Long> lpush(K key, V... values)
RedisListReactiveCommands
lpush
in interface RedisListReactiveCommands<K,V>
key
- the keyvalues
- the valuepublic Observable<Long> lpushx(K key, V value)
RedisListReactiveCommands
lpushx
in interface RedisListReactiveCommands<K,V>
key
- the keyvalue
- the valuepublic Observable<Long> lpushx(K key, V... values)
RedisListReactiveCommands
lpushx
in interface RedisListReactiveCommands<K,V>
key
- the keyvalues
- the valuespublic Observable<V> lrange(K key, long start, long stop)
RedisListReactiveCommands
lrange
in interface RedisListReactiveCommands<K,V>
key
- the keystart
- the start type: longstop
- the stop type: longpublic Observable<Long> lrange(ValueStreamingChannel<V> channel, K key, long start, long stop)
RedisListReactiveCommands
lrange
in interface RedisListReactiveCommands<K,V>
channel
- the channelkey
- the keystart
- the start type: longstop
- the stop type: longpublic Observable<Long> lrem(K key, long count, V value)
RedisListReactiveCommands
lrem
in interface RedisListReactiveCommands<K,V>
key
- the keycount
- the count type: longvalue
- the valuepublic Observable<String> lset(K key, long index, V value)
RedisListReactiveCommands
lset
in interface RedisListReactiveCommands<K,V>
key
- the keyindex
- the index type: longvalue
- the valuepublic Observable<String> ltrim(K key, long start, long stop)
RedisListReactiveCommands
ltrim
in interface RedisListReactiveCommands<K,V>
key
- the keystart
- the start type: longstop
- the stop type: longpublic Observable<V> mget(K... keys)
RedisStringReactiveCommands
mget
in interface RedisStringReactiveCommands<K,V>
mget
in interface RedisClusterReactiveCommands<K,V>
keys
- the keypublic Observable<V> mget(Iterable<K> keys)
public Observable<Long> mget(ValueStreamingChannel<V> channel, K... keys)
RedisStringReactiveCommands
mget
in interface RedisStringReactiveCommands<K,V>
channel
- the channelkeys
- the keyspublic Observable<Long> mget(ValueStreamingChannel<V> channel, Iterable<K> keys)
public Observable<String> migrate(String host, int port, K key, int db, long timeout)
RedisKeyReactiveCommands
migrate
in interface RedisKeyReactiveCommands<K,V>
host
- the hostport
- the portkey
- the keydb
- the databasetimeout
- the timeout in millisecondspublic Observable<String> migrate(String host, int port, int db, long timeout, MigrateArgs<K> migrateArgs)
RedisKeyReactiveCommands
migrate
in interface RedisKeyReactiveCommands<K,V>
host
- the hostport
- the portdb
- the databasetimeout
- the timeout in millisecondsmigrateArgs
- migrate args that allow to configure further optionspublic Observable<Boolean> move(K key, int db)
RedisKeyReactiveCommands
move
in interface RedisKeyReactiveCommands<K,V>
key
- the keydb
- the db type: longpublic Observable<String> mset(Map<K,V> map)
RedisStringReactiveCommands
mset
in interface RedisStringReactiveCommands<K,V>
mset
in interface RedisClusterReactiveCommands<K,V>
map
- the nullOK
since MSET
can't fail.public Observable<Boolean> msetnx(Map<K,V> map)
RedisStringReactiveCommands
msetnx
in interface RedisStringReactiveCommands<K,V>
msetnx
in interface RedisClusterReactiveCommands<K,V>
map
- the null1
if the all the keys were set. 0
if no key was set (at least one key already existed).public Observable<String> multi()
RedisTransactionalReactiveCommands
multi
in interface RedisTransactionalReactiveCommands<K,V>
OK
.public Observable<String> objectEncoding(K key)
RedisKeyReactiveCommands
objectEncoding
in interface RedisKeyReactiveCommands<K,V>
key
- the keypublic Observable<Long> objectIdletime(K key)
RedisKeyReactiveCommands
objectIdletime
in interface RedisKeyReactiveCommands<K,V>
key
- the keypublic Observable<Long> objectRefcount(K key)
RedisKeyReactiveCommands
objectRefcount
in interface RedisKeyReactiveCommands<K,V>
key
- the keypublic Observable<Boolean> persist(K key)
RedisKeyReactiveCommands
persist
in interface RedisKeyReactiveCommands<K,V>
key
- the keykey
does not exist or does not have an
associated timeout.public Observable<Boolean> pexpire(K key, long milliseconds)
RedisKeyReactiveCommands
pexpire
in interface RedisKeyReactiveCommands<K,V>
key
- the keymilliseconds
- the milliseconds type: longkey
does not exist or the timeout could not
be set.public Observable<Boolean> pexpireat(K key, Date timestamp)
RedisKeyReactiveCommands
pexpireat
in interface RedisKeyReactiveCommands<K,V>
key
- the keytimestamp
- the milliseconds-timestamp type: posix timekey
does not exist or the timeout could not
be set (see: EXPIRE
).public Observable<Boolean> pexpireat(K key, long timestamp)
RedisKeyReactiveCommands
pexpireat
in interface RedisKeyReactiveCommands<K,V>
key
- the keytimestamp
- the milliseconds-timestamp type: posix timekey
does not exist or the timeout could not
be set (see: EXPIRE
).public Observable<Long> pfadd(K key, V... values)
RedisHLLReactiveCommands
pfadd
in interface RedisHLLReactiveCommands<K,V>
key
- the keyvalues
- the valuespublic Observable<Long> pfadd(K key, V value, V... values)
public Observable<Long> pfcount(K... keys)
RedisHLLReactiveCommands
pfcount
in interface RedisHLLReactiveCommands<K,V>
keys
- the keysPFADD
.public Observable<Long> pfcount(K key, K... keys)
public Observable<String> pfmerge(K destkey, K... sourcekeys)
RedisHLLReactiveCommands
pfmerge
in interface RedisHLLReactiveCommands<K,V>
destkey
- the destination keysourcekeys
- the source keyOK
.public Observable<String> pfmerge(K destkey, K sourceKey, K... sourcekeys)
public Observable<String> ping()
BaseRedisReactiveCommands
ping
in interface BaseRedisReactiveCommands<K,V>
public Observable<String> psetex(K key, long milliseconds, V value)
RedisStringReactiveCommands
psetex
in interface RedisStringReactiveCommands<K,V>
key
- the keymilliseconds
- the milliseconds type: longvalue
- the valuepublic Observable<Long> pttl(K key)
RedisKeyReactiveCommands
pttl
in interface RedisKeyReactiveCommands<K,V>
key
- the keypublic Observable<Long> publish(K channel, V message)
BaseRedisReactiveCommands
publish
in interface BaseRedisReactiveCommands<K,V>
channel
- the channel type: keymessage
- the message type: valuepublic Observable<K> pubsubChannels()
BaseRedisReactiveCommands
pubsubChannels
in interface BaseRedisReactiveCommands<K,V>
public Observable<K> pubsubChannels(K channel)
BaseRedisReactiveCommands
pubsubChannels
in interface BaseRedisReactiveCommands<K,V>
channel
- the keypublic Observable<Long> pubsubNumpat()
BaseRedisReactiveCommands
pubsubNumpat
in interface BaseRedisReactiveCommands<K,V>
public Observable<Map<K,Long>> pubsubNumsub(K... channels)
BaseRedisReactiveCommands
pubsubNumsub
in interface BaseRedisReactiveCommands<K,V>
channels
- channel keyspublic Observable<String> quit()
BaseRedisReactiveCommands
StatefulConnection.close()
to close connections and
release resources.quit
in interface BaseRedisReactiveCommands<K,V>
public Observable<V> randomkey()
RedisKeyReactiveCommands
randomkey
in interface RedisKeyReactiveCommands<K,V>
public Observable<String> readOnly()
BaseRedisReactiveCommands
readOnly
in interface BaseRedisReactiveCommands<K,V>
readOnly
in interface RedisClusterReactiveCommands<K,V>
public Observable<String> readWrite()
BaseRedisReactiveCommands
readWrite
in interface BaseRedisReactiveCommands<K,V>
readWrite
in interface RedisClusterReactiveCommands<K,V>
public Observable<String> rename(K key, K newKey)
RedisKeyReactiveCommands
rename
in interface RedisKeyReactiveCommands<K,V>
key
- the keynewKey
- the newkey type: keypublic Observable<Boolean> renamenx(K key, K newKey)
RedisKeyReactiveCommands
renamenx
in interface RedisKeyReactiveCommands<K,V>
key
- the keynewKey
- the newkey type: keykey
was renamed to newkey
. false if newkey
already exists.public void reset()
BaseRedisReactiveCommands
reset
in interface BaseRedisReactiveCommands<K,V>
public Observable<String> restore(K key, long ttl, byte[] value)
RedisKeyReactiveCommands
restore
in interface RedisKeyReactiveCommands<K,V>
key
- the keyttl
- the ttl type: longvalue
- the serialized-value type: stringpublic Observable<String> restore(K key, byte[] value, RestoreArgs args)
RedisKeyReactiveCommands
restore
in interface RedisKeyReactiveCommands<K,V>
key
- the keyvalue
- the serialized-value type: stringargs
- the RestoreArgs
, must not be null.public Observable<Object> role()
BaseRedisReactiveCommands
role
in interface BaseRedisReactiveCommands<K,V>
public Observable<V> rpop(K key)
RedisListReactiveCommands
rpop
in interface RedisListReactiveCommands<K,V>
key
- the keykey
does not exist.public Observable<V> rpoplpush(K source, K destination)
RedisListReactiveCommands
rpoplpush
in interface RedisListReactiveCommands<K,V>
source
- the source keydestination
- the destination type: keypublic Observable<Long> rpush(K key, V... values)
RedisListReactiveCommands
rpush
in interface RedisListReactiveCommands<K,V>
key
- the keyvalues
- the valuepublic Observable<Long> rpushx(K key, V value)
RedisListReactiveCommands
rpushx
in interface RedisListReactiveCommands<K,V>
key
- the keyvalue
- the valuepublic Observable<Long> rpushx(K key, V... values)
RedisListReactiveCommands
rpushx
in interface RedisListReactiveCommands<K,V>
key
- the keyvalues
- the valuespublic Observable<Long> sadd(K key, V... members)
RedisSetReactiveCommands
sadd
in interface RedisSetReactiveCommands<K,V>
key
- the keymembers
- the member type: valuepublic Observable<String> save()
RedisServerReactiveCommands
save
in interface RedisServerReactiveCommands<K,V>
public Observable<KeyScanCursor<K>> scan()
RedisKeyReactiveCommands
scan
in interface RedisKeyReactiveCommands<K,V>
public Observable<KeyScanCursor<K>> scan(ScanArgs scanArgs)
RedisKeyReactiveCommands
scan
in interface RedisKeyReactiveCommands<K,V>
scanArgs
- scan argumentspublic Observable<KeyScanCursor<K>> scan(ScanCursor scanCursor, ScanArgs scanArgs)
RedisKeyReactiveCommands
scan
in interface RedisKeyReactiveCommands<K,V>
scanCursor
- cursor to resume from a previous scan, must not be nullscanArgs
- scan argumentspublic Observable<KeyScanCursor<K>> scan(ScanCursor scanCursor)
RedisKeyReactiveCommands
scan
in interface RedisKeyReactiveCommands<K,V>
scanCursor
- cursor to resume from a previous scan, must not be nullpublic Observable<StreamScanCursor> scan(KeyStreamingChannel<K> channel)
RedisKeyReactiveCommands
scan
in interface RedisKeyReactiveCommands<K,V>
channel
- streaming channel that receives a call for every keypublic Observable<StreamScanCursor> scan(KeyStreamingChannel<K> channel, ScanArgs scanArgs)
RedisKeyReactiveCommands
scan
in interface RedisKeyReactiveCommands<K,V>
channel
- streaming channel that receives a call for every keyscanArgs
- scan argumentspublic Observable<StreamScanCursor> scan(KeyStreamingChannel<K> channel, ScanCursor scanCursor, ScanArgs scanArgs)
RedisKeyReactiveCommands
scan
in interface RedisKeyReactiveCommands<K,V>
channel
- streaming channel that receives a call for every keyscanCursor
- cursor to resume from a previous scan, must not be nullscanArgs
- scan argumentspublic Observable<StreamScanCursor> scan(KeyStreamingChannel<K> channel, ScanCursor scanCursor)
RedisKeyReactiveCommands
scan
in interface RedisKeyReactiveCommands<K,V>
channel
- streaming channel that receives a call for every keyscanCursor
- cursor to resume from a previous scan, must not be nullpublic Observable<Long> scard(K key)
RedisSetReactiveCommands
scard
in interface RedisSetReactiveCommands<K,V>
key
- the keykey
does not
exist.public Observable<Boolean> scriptExists(String... digests)
RedisScriptingReactiveCommands
scriptExists
in interface RedisScriptingReactiveCommands<K,V>
digests
- script digestspublic Observable<String> scriptFlush()
RedisScriptingReactiveCommands
scriptFlush
in interface RedisScriptingReactiveCommands<K,V>
public Observable<String> scriptKill()
RedisScriptingReactiveCommands
scriptKill
in interface RedisScriptingReactiveCommands<K,V>
public Observable<String> scriptLoad(V script)
RedisScriptingReactiveCommands
scriptLoad
in interface RedisScriptingReactiveCommands<K,V>
script
- script contentpublic Observable<V> sdiff(K... keys)
RedisSetReactiveCommands
sdiff
in interface RedisSetReactiveCommands<K,V>
keys
- the keypublic Observable<Long> sdiff(ValueStreamingChannel<V> channel, K... keys)
RedisSetReactiveCommands
sdiff
in interface RedisSetReactiveCommands<K,V>
channel
- the channelkeys
- the keyspublic Observable<Long> sdiffstore(K destination, K... keys)
RedisSetReactiveCommands
sdiffstore
in interface RedisSetReactiveCommands<K,V>
destination
- the destination type: keykeys
- the keypublic Observable<String> select(int db)
public Observable<String> set(K key, V value)
RedisStringReactiveCommands
set
in interface RedisStringReactiveCommands<K,V>
key
- the keyvalue
- the valueOK
if SET
was executed correctly.public Observable<String> set(K key, V value, SetArgs setArgs)
RedisStringReactiveCommands
set
in interface RedisStringReactiveCommands<K,V>
key
- the keyvalue
- the valuesetArgs
- the setArgsOK
if SET
was executed correctly.public void setTimeout(long timeout, TimeUnit unit)
RedisClusterReactiveCommands
setTimeout
in interface RedisClusterReactiveCommands<K,V>
timeout
- the timeout valueunit
- the unit of the timeout valuepublic Observable<Long> setbit(K key, long offset, int value)
RedisStringReactiveCommands
setbit
in interface RedisStringReactiveCommands<K,V>
key
- the keyoffset
- the offset type: longvalue
- the value type: stringpublic Observable<String> setex(K key, long seconds, V value)
RedisStringReactiveCommands
setex
in interface RedisStringReactiveCommands<K,V>
key
- the keyseconds
- the seconds type: longvalue
- the valuepublic Observable<Boolean> setnx(K key, V value)
RedisStringReactiveCommands
setnx
in interface RedisStringReactiveCommands<K,V>
key
- the keyvalue
- the value1
if the key was set 0
if the key was not setpublic Observable<Long> setrange(K key, long offset, V value)
RedisStringReactiveCommands
setrange
in interface RedisStringReactiveCommands<K,V>
key
- the keyoffset
- the offset type: longvalue
- the valuepublic Observable<Success> shutdown(boolean save)
RedisServerReactiveCommands
shutdown
in interface RedisServerReactiveCommands<K,V>
save
- true force save operationpublic Observable<V> sinter(K... keys)
RedisSetReactiveCommands
sinter
in interface RedisSetReactiveCommands<K,V>
keys
- the keypublic Observable<Long> sinter(ValueStreamingChannel<V> channel, K... keys)
RedisSetReactiveCommands
sinter
in interface RedisSetReactiveCommands<K,V>
channel
- the channelkeys
- the keyspublic Observable<Long> sinterstore(K destination, K... keys)
RedisSetReactiveCommands
sinterstore
in interface RedisSetReactiveCommands<K,V>
destination
- the destination type: keykeys
- the keypublic Observable<Boolean> sismember(K key, V member)
RedisSetReactiveCommands
sismember
in interface RedisSetReactiveCommands<K,V>
key
- the keymember
- the member type: valuekey
does not exist.public Observable<String> slaveof(String host, int port)
RedisServerReactiveCommands
slaveof
in interface RedisServerReactiveCommands<K,V>
host
- the host type: stringport
- the port type: stringpublic Observable<String> slaveofNoOne()
RedisServerReactiveCommands
slaveofNoOne
in interface RedisServerReactiveCommands<K,V>
public Observable<Object> slowlogGet()
RedisServerReactiveCommands
slowlogGet
in interface RedisServerReactiveCommands<K,V>
public Observable<Object> slowlogGet(int count)
RedisServerReactiveCommands
slowlogGet
in interface RedisServerReactiveCommands<K,V>
count
- the countpublic Observable<Long> slowlogLen()
RedisServerReactiveCommands
slowlogLen
in interface RedisServerReactiveCommands<K,V>
public Observable<String> slowlogReset()
RedisServerReactiveCommands
slowlogReset
in interface RedisServerReactiveCommands<K,V>
public Observable<V> smembers(K key)
RedisSetReactiveCommands
smembers
in interface RedisSetReactiveCommands<K,V>
key
- the keypublic Observable<Long> smembers(ValueStreamingChannel<V> channel, K key)
RedisSetReactiveCommands
smembers
in interface RedisSetReactiveCommands<K,V>
channel
- the channelkey
- the keyspublic Observable<Boolean> smove(K source, K destination, V member)
RedisSetReactiveCommands
smove
in interface RedisSetReactiveCommands<K,V>
source
- the source keydestination
- the destination type: keymember
- the member type: valuesource
and no
operation was performed.public Observable<V> sort(K key)
RedisKeyReactiveCommands
sort
in interface RedisKeyReactiveCommands<K,V>
key
- the keypublic Observable<Long> sort(ValueStreamingChannel<V> channel, K key)
RedisKeyReactiveCommands
sort
in interface RedisKeyReactiveCommands<K,V>
channel
- streaming channel that receives a call for every valuekey
- the keypublic Observable<V> sort(K key, SortArgs sortArgs)
RedisKeyReactiveCommands
sort
in interface RedisKeyReactiveCommands<K,V>
key
- the keysortArgs
- sort argumentspublic Observable<Long> sort(ValueStreamingChannel<V> channel, K key, SortArgs sortArgs)
RedisKeyReactiveCommands
sort
in interface RedisKeyReactiveCommands<K,V>
channel
- streaming channel that receives a call for every valuekey
- the keysortArgs
- sort argumentspublic Observable<Long> sortStore(K key, SortArgs sortArgs, K destination)
RedisKeyReactiveCommands
sortStore
in interface RedisKeyReactiveCommands<K,V>
key
- the keysortArgs
- sort argumentsdestination
- the destination key to store sort resultspublic Observable<V> spop(K key)
RedisSetReactiveCommands
spop
in interface RedisSetReactiveCommands<K,V>
key
- the keykey
does not exist.public Observable<V> spop(K key, long count)
RedisSetReactiveCommands
spop
in interface RedisSetReactiveCommands<K,V>
key
- the keycount
- number of members to popkey
does not exist.public Observable<V> srandmember(K key)
RedisSetReactiveCommands
srandmember
in interface RedisSetReactiveCommands<K,V>
key
- the keycount
argument the command returns a Bulk Reply with the
randomly selected element, or null when key
does not exist.public Observable<V> srandmember(K key, long count)
RedisSetReactiveCommands
srandmember
in interface RedisSetReactiveCommands<K,V>
key
- the keycount
- the count type: longcount
argument the command returns a Bulk Reply with the
randomly selected element, or null when key
does not exist.public Observable<Long> srandmember(ValueStreamingChannel<V> channel, K key, long count)
RedisSetReactiveCommands
srandmember
in interface RedisSetReactiveCommands<K,V>
channel
- streaming channel that receives a call for every valuekey
- the keycount
- the countpublic Observable<Long> srem(K key, V... members)
RedisSetReactiveCommands
srem
in interface RedisSetReactiveCommands<K,V>
key
- the keymembers
- the member type: valuepublic Observable<ValueScanCursor<V>> sscan(K key)
RedisSetReactiveCommands
sscan
in interface RedisSetReactiveCommands<K,V>
key
- the keypublic Observable<ValueScanCursor<V>> sscan(K key, ScanArgs scanArgs)
RedisSetReactiveCommands
sscan
in interface RedisSetReactiveCommands<K,V>
key
- the keyscanArgs
- scan argumentspublic Observable<ValueScanCursor<V>> sscan(K key, ScanCursor scanCursor, ScanArgs scanArgs)
RedisSetReactiveCommands
sscan
in interface RedisSetReactiveCommands<K,V>
key
- the keyscanCursor
- cursor to resume from a previous scan, must not be nullscanArgs
- scan argumentspublic Observable<ValueScanCursor<V>> sscan(K key, ScanCursor scanCursor)
RedisSetReactiveCommands
sscan
in interface RedisSetReactiveCommands<K,V>
key
- the keyscanCursor
- cursor to resume from a previous scan, must not be nullpublic Observable<StreamScanCursor> sscan(ValueStreamingChannel<V> channel, K key)
RedisSetReactiveCommands
sscan
in interface RedisSetReactiveCommands<K,V>
channel
- streaming channel that receives a call for every valuekey
- the keypublic Observable<StreamScanCursor> sscan(ValueStreamingChannel<V> channel, K key, ScanArgs scanArgs)
RedisSetReactiveCommands
sscan
in interface RedisSetReactiveCommands<K,V>
channel
- streaming channel that receives a call for every valuekey
- the keyscanArgs
- scan argumentspublic Observable<StreamScanCursor> sscan(ValueStreamingChannel<V> channel, K key, ScanCursor scanCursor, ScanArgs scanArgs)
RedisSetReactiveCommands
sscan
in interface RedisSetReactiveCommands<K,V>
channel
- streaming channel that receives a call for every valuekey
- the keyscanCursor
- cursor to resume from a previous scan, must not be nullscanArgs
- scan argumentspublic Observable<StreamScanCursor> sscan(ValueStreamingChannel<V> channel, K key, ScanCursor scanCursor)
RedisSetReactiveCommands
sscan
in interface RedisSetReactiveCommands<K,V>
channel
- streaming channel that receives a call for every valuekey
- the keyscanCursor
- cursor to resume from a previous scan, must not be nullpublic Observable<Long> strlen(K key)
RedisStringReactiveCommands
strlen
in interface RedisStringReactiveCommands<K,V>
key
- the keykey
, or 0
when key
does not exist.public Observable<V> sunion(K... keys)
RedisSetReactiveCommands
sunion
in interface RedisSetReactiveCommands<K,V>
keys
- the keypublic Observable<Long> sunion(ValueStreamingChannel<V> channel, K... keys)
RedisSetReactiveCommands
sunion
in interface RedisSetReactiveCommands<K,V>
channel
- streaming channel that receives a call for every valuekeys
- the keyspublic Observable<Long> sunionstore(K destination, K... keys)
RedisSetReactiveCommands
sunionstore
in interface RedisSetReactiveCommands<K,V>
destination
- the destination type: keykeys
- the keypublic Observable<String> swapdb(int db1, int db2)
public Observable<String> sync()
RedisServerReactiveCommands
sync
in interface RedisServerReactiveCommands<K,V>
public Observable<V> time()
RedisServerReactiveCommands
time
in interface RedisServerReactiveCommands<K,V>
public Observable<Long> touch(K... keys)
RedisKeyReactiveCommands
touch
in interface RedisKeyReactiveCommands<K,V>
keys
- the keyspublic Observable<Long> touch(Iterable<K> keys)
public Observable<Long> ttl(K key)
RedisKeyReactiveCommands
ttl
in interface RedisKeyReactiveCommands<K,V>
key
- the keypublic Observable<String> type(K key)
RedisKeyReactiveCommands
type
in interface RedisKeyReactiveCommands<K,V>
key
- the keykey
, or none
when key
does not exist.public Observable<Long> unlink(K... keys)
RedisKeyReactiveCommands
unlink
in interface RedisKeyReactiveCommands<K,V>
keys
- the keyspublic Observable<Long> unlink(Iterable<K> keys)
public Observable<String> unwatch()
RedisTransactionalReactiveCommands
unwatch
in interface RedisTransactionalReactiveCommands<K,V>
OK
.public Observable<Long> waitForReplication(int replicas, long timeout)
BaseRedisReactiveCommands
waitForReplication
in interface BaseRedisReactiveCommands<K,V>
replicas
- minimum number of replicastimeout
- timeout in millisecondspublic Observable<String> watch(K... keys)
RedisTransactionalReactiveCommands
watch
in interface RedisTransactionalReactiveCommands<K,V>
keys
- the keyOK
.public Observable<Long> xack(K key, K group, String... messageIds)
RedisStreamReactiveCommands
xack
in interface RedisStreamReactiveCommands<K,V>
key
- the stream key.group
- name of the consumer group.messageIds
- message Id's to acknowledge.public Observable<String> xadd(K key, Map<K,V> body)
RedisStreamReactiveCommands
key
.xadd
in interface RedisStreamReactiveCommands<K,V>
key
- the stream key.body
- message body.public Observable<String> xadd(K key, XAddArgs args, Map<K,V> body)
RedisStreamReactiveCommands
key
.xadd
in interface RedisStreamReactiveCommands<K,V>
key
- the stream key.body
- message body.public Observable<String> xadd(K key, Object... keysAndValues)
RedisStreamReactiveCommands
key
.xadd
in interface RedisStreamReactiveCommands<K,V>
key
- the stream key.keysAndValues
- message body.public Observable<String> xadd(K key, XAddArgs args, Object... keysAndValues)
RedisStreamReactiveCommands
key
.xadd
in interface RedisStreamReactiveCommands<K,V>
key
- the stream key.keysAndValues
- message body.public Observable<StreamMessage<K,V>> xclaim(K key, Consumer<K> consumer, long minIdleTime, String... messageIds)
RedisStreamReactiveCommands
xclaim
in interface RedisStreamReactiveCommands<K,V>
key
- the stream key.consumer
- consumer identified by group name and consumer key.messageIds
- message Id's to claim.StreamMessage
public Observable<StreamMessage<K,V>> xclaim(K key, Consumer<K> consumer, XClaimArgs args, String... messageIds)
RedisStreamReactiveCommands
xclaim
in interface RedisStreamReactiveCommands<K,V>
key
- the stream key.consumer
- consumer identified by group name and consumer key.messageIds
- message Id's to claim.StreamMessage
public Observable<Long> xdel(K key, String... messageIds)
RedisStreamReactiveCommands
xdel
in interface RedisStreamReactiveCommands<K,V>
key
- the stream key.messageIds
- stream message Id's.public Observable<String> xgroupCreate(XReadArgs.StreamOffset<K> streamOffset, K group)
RedisStreamReactiveCommands
xgroupCreate
in interface RedisStreamReactiveCommands<K,V>
streamOffset
- name of the stream containing the offset to set.group
- name of the consumer group.public Observable<Boolean> xgroupDelconsumer(K key, Consumer<K> consumer)
RedisStreamReactiveCommands
xgroupDelconsumer
in interface RedisStreamReactiveCommands<K,V>
key
- the stream key.consumer
- consumer identified by group name and consumer key.public Observable<Boolean> xgroupDestroy(K key, K group)
RedisStreamReactiveCommands
xgroupDestroy
in interface RedisStreamReactiveCommands<K,V>
key
- the stream key.group
- name of the consumer group.public Observable<String> xgroupSetid(XReadArgs.StreamOffset<K> streamOffset, K group)
RedisStreamReactiveCommands
group
id.xgroupSetid
in interface RedisStreamReactiveCommands<K,V>
streamOffset
- name of the stream containing the offset to set.group
- name of the consumer group.public Observable<Long> xlen(K key)
RedisStreamReactiveCommands
xlen
in interface RedisStreamReactiveCommands<K,V>
key
- the stream key.public Observable<Object> xpending(K key, K group)
RedisStreamReactiveCommands
group
.xpending
in interface RedisStreamReactiveCommands<K,V>
key
- the stream key.group
- name of the consumer group.public Observable<Object> xpending(K key, K group, Range<String> range, Limit limit)
RedisStreamReactiveCommands
Range
.xpending
in interface RedisStreamReactiveCommands<K,V>
key
- the stream key.group
- name of the consumer group.range
- must not be null.limit
- must not be null.public Observable<Object> xpending(K key, Consumer<K> consumer, Range<String> range, Limit limit)
RedisStreamReactiveCommands
Range
.xpending
in interface RedisStreamReactiveCommands<K,V>
key
- the stream key.consumer
- consumer identified by group name and consumer key.range
- must not be null.limit
- must not be null.public Observable<StreamMessage<K,V>> xrange(K key, Range<String> range)
RedisStreamReactiveCommands
Range
.xrange
in interface RedisStreamReactiveCommands<K,V>
key
- the stream key.range
- must not be null.public Observable<StreamMessage<K,V>> xrange(K key, Range<String> range, Limit limit)
RedisStreamReactiveCommands
xrange
in interface RedisStreamReactiveCommands<K,V>
key
- the stream key.range
- must not be null.limit
- must not be null.public Observable<StreamMessage<K,V>> xread(XReadArgs.StreamOffset<K>... streams)
RedisStreamReactiveCommands
XReadArgs.StreamOffset
s.xread
in interface RedisStreamReactiveCommands<K,V>
streams
- the streams to read from.public Observable<StreamMessage<