| Package | Description |
|---|---|
| io.lettuce.core.cluster.api.sync |
Redis Cluster API for synchronous executed commands.
|
| io.lettuce.core.cluster.pubsub.api.sync |
Redis Cluster Pub/Sub API for synchronous executed commands.
|
| Modifier and Type | Method and Description |
|---|---|
Executions<Long> |
NodeSelectionStringCommands.append(K key,
V value)
Append a value to a key.
|
Executions<String> |
NodeSelectionServerCommands.bgrewriteaof()
Asynchronously rewrite the append-only file.
|
Executions<String> |
NodeSelectionServerCommands.bgsave()
Asynchronously save the dataset to disk.
|
Executions<Long> |
NodeSelectionStringCommands.bitcount(K key)
Count set bits in a string.
|
Executions<Long> |
NodeSelectionStringCommands.bitcount(K key,
long start,
long end)
Count set bits in a string.
|
Executions<List<Long>> |
NodeSelectionStringCommands.bitfield(K key,
BitFieldArgs bitFieldArgs)
Execute
BITFIELD with its subcommands. |
Executions<Long> |
NodeSelectionStringCommands.bitopAnd(K destination,
K... keys)
Perform bitwise AND between strings.
|
Executions<Long> |
NodeSelectionStringCommands.bitopNot(K destination,
K source)
Perform bitwise NOT between strings.
|
Executions<Long> |
NodeSelectionStringCommands.bitopOr(K destination,
K... keys)
Perform bitwise OR between strings.
|
Executions<Long> |
NodeSelectionStringCommands.bitopXor(K destination,
K... keys)
Perform bitwise XOR between strings.
|
Executions<Long> |
NodeSelectionStringCommands.bitpos(K key,
boolean state)
Find first bit set or clear in a string.
|
Executions<Long> |
NodeSelectionStringCommands.bitpos(K key,
boolean state,
long start)
Find first bit set or clear in a string.
|
Executions<Long> |
NodeSelectionStringCommands.bitpos(K key,
boolean state,
long start,
long end)
Find first bit set or clear in a string.
|
Executions<KeyValue<K,V>> |
NodeSelectionListCommands.blpop(long timeout,
K... keys)
Remove and get the first element in a list, or block until one is available.
|
Executions<KeyValue<K,V>> |
NodeSelectionListCommands.brpop(long timeout,
K... keys)
Remove and get the last element in a list, or block until one is available.
|
Executions<V> |
NodeSelectionListCommands.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.
|
Executions<KeyValue<K,ScoredValue<V>>> |
NodeSelectionSortedSetCommands.bzpopmax(long timeout,
K... keys)
Removes and returns a member with the highest scores in the sorted set stored at one of the keys.
|
Executions<KeyValue<K,ScoredValue<V>>> |
NodeSelectionSortedSetCommands.bzpopmin(long timeout,
K... keys)
Removes and returns a member with the lowest scores in the sorted set stored at one of the keys.
|
Executions<K> |
NodeSelectionServerCommands.clientGetname()
Get the current connection name.
|
Executions<Long> |
NodeSelectionServerCommands.clientKill(KillArgs killArgs)
Kill connections of clients which are filtered by
killArgs |
Executions<String> |
NodeSelectionServerCommands.clientKill(String addr)
Kill the connection of a client identified by ip:port.
|
Executions<String> |
NodeSelectionServerCommands.clientList()
Get the list of client connections.
|
Executions<String> |
NodeSelectionServerCommands.clientPause(long timeout)
Stop processing commands from clients for some time.
|
Executions<String> |
NodeSelectionServerCommands.clientSetname(K name)
Set the current connection name.
|
Executions<Long> |
NodeSelectionServerCommands.clientUnblock(long id,
UnblockType type)
Unblock the specified blocked client.
|
Executions<List<Object>> |
NodeSelectionServerCommands.command()
Returns an array reply of details about all Redis commands.
|
Executions<Long> |
NodeSelectionServerCommands.commandCount()
Get total number of Redis commands.
|
Executions<List<Object>> |
NodeSelectionServerCommands.commandInfo(CommandType... commands)
Returns an array reply of details about the requested commands.
|
Executions<List<Object>> |
NodeSelectionServerCommands.commandInfo(String... commands)
Returns an array reply of details about the requested commands.
|
Executions<Map<String,String>> |
NodeSelectionServerCommands.configGet(String parameter)
Get the value of a configuration parameter.
|
Executions<String> |
NodeSelectionServerCommands.configResetstat()
Reset the stats returned by INFO.
|
Executions<String> |
NodeSelectionServerCommands.configRewrite()
Rewrite the configuration file with the in memory configuration.
|
Executions<String> |
NodeSelectionServerCommands.configSet(String parameter,
String value)
Set a configuration parameter to the given value.
|
Executions<Long> |
NodeSelectionServerCommands.dbsize()
Return the number of keys in the selected database.
|
Executions<String> |
NodeSelectionServerCommands.debugCrashAndRecover(Long delay)
Crash and recover
|
Executions<String> |
NodeSelectionServerCommands.debugHtstats(int db)
Get debugging information about the internal hash-table state.
|
Executions<String> |
NodeSelectionServerCommands.debugObject(K key)
Get debugging information about a key.
|
Executions<String> |
NodeSelectionServerCommands.debugReload()
Save RDB, clear the database and reload RDB.
|
Executions<String> |
NodeSelectionServerCommands.debugRestart(Long delay)
Restart the server gracefully.
|
Executions<String> |
NodeSelectionServerCommands.debugSdslen(K key)
Get debugging information about the internal SDS length.
|
Executions<Long> |
NodeSelectionStringCommands.decr(K key)
Decrement the integer value of a key by one.
|
Executions<Long> |
NodeSelectionStringCommands.decrby(K key,
long amount)
Decrement the integer value of a key by the given number.
|
Executions<Long> |
NodeSelectionKeyCommands.del(K... keys)
Delete one or more keys.
|
Executions<byte[]> |
NodeSelectionKeyCommands.dump(K key)
Return a serialized version of the value stored at the specified key.
|
Executions<V> |
BaseNodeSelectionCommands.echo(V msg)
Echo the given string.
|
<T> Executions<T> |
NodeSelectionScriptingCommands.eval(String script,
ScriptOutputType type,
K... keys)
Execute a Lua script server side.
|
<T> Executions<T> |
NodeSelectionScriptingCommands.eval(String script,
ScriptOutputType type,
K[] keys,
V... values)
Execute a Lua script server side.
|
<T> Executions<T> |
NodeSelectionScriptingCommands.evalsha(String digest,
ScriptOutputType type,
K... keys)
Evaluates a script cached on the server side by its SHA1 digest
|
<T> Executions<T> |
NodeSelectionScriptingCommands.evalsha(String digest,
ScriptOutputType type,
K[] keys,
V... values)
Execute a Lua script server side.
|
Executions<Long> |
NodeSelectionKeyCommands.exists(K... keys)
Determine how many keys exist.
|
Executions<Boolean> |
NodeSelectionKeyCommands.expire(K key,
long seconds)
Set a key's time to live in seconds.
|
Executions<Boolean> |
NodeSelectionKeyCommands.expireat(K key,
Date timestamp)
Set the expiration for a key as a UNIX timestamp.
|
Executions<Boolean> |
NodeSelectionKeyCommands.expireat(K key,
long timestamp)
Set the expiration for a key as a UNIX timestamp.
|
Executions<String> |
NodeSelectionServerCommands.flushall()
Remove all keys from all databases.
|
Executions<String> |
NodeSelectionServerCommands.flushallAsync()
Remove all keys asynchronously from all databases.
|
Executions<String> |
NodeSelectionServerCommands.flushdb()
Remove all keys from the current database.
|
Executions<String> |
NodeSelectionServerCommands.flushdbAsync()
Remove all keys asynchronously from the current database.
|
Executions<Long> |
NodeSelectionGeoCommands.geoadd(K key,
double longitude,
double latitude,
V member)
Single geo add.
|
Executions<Long> |
NodeSelectionGeoCommands.geoadd(K key,
Object... lngLatMember)
Multi geo add.
|
Executions<Double> |
NodeSelectionGeoCommands.geodist(K key,
V from,
V to,
GeoArgs.Unit unit)
Retrieve distance between points
from and to. |
Executions<List<Value<String>>> |
NodeSelectionGeoCommands.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.
|
Executions<List<GeoCoordinates>> |
NodeSelectionGeoCommands.geopos(K key,
V... members)
Get geo coordinates for the
members. |
Executions<Set<V>> |
NodeSelectionGeoCommands.georadius(K key,
double longitude,
double latitude,
double distance,
GeoArgs.Unit unit)
Retrieve members selected by distance with the center of
longitude and latitude. |
Executions<List<GeoWithin<V>>> |
NodeSelectionGeoCommands.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. |
Executions<Long> |
NodeSelectionGeoCommands.georadius(K key,
double longitude,
double latitude,
double distance,
GeoArgs.Unit unit,
GeoRadiusStoreArgs<K> geoRadiusStoreArgs)
Perform a
NodeSelectionGeoCommands.georadius(Object, double, double, double, GeoArgs.Unit, GeoArgs) query and store the results in a sorted set. |
Executions<Set<V>> |
NodeSelectionGeoCommands.georadiusbymember(K key,
V member,
double distance,
GeoArgs.Unit unit)
Retrieve members selected by distance with the center of
member. |
Executions<List<GeoWithin<V>>> |
NodeSelectionGeoCommands.georadiusbymember(K key,
V member,
double distance,
GeoArgs.Unit unit,
GeoArgs geoArgs)
Retrieve members selected by distance with the center of
member. |
Executions<Long> |
NodeSelectionGeoCommands.georadiusbymember(K key,
V member,
double distance,
GeoArgs.Unit unit,
GeoRadiusStoreArgs<K> geoRadiusStoreArgs)
Perform a
NodeSelectionGeoCommands.georadiusbymember(Object, Object, double, GeoArgs.Unit, GeoArgs) query and store the results in a sorted set. |
Executions<V> |
NodeSelectionStringCommands.get(K key)
Get the value of a key.
|
Executions<Long> |
NodeSelectionStringCommands.getbit(K key,
long offset)
Returns the bit value at offset in the string value stored at key.
|
Executions<V> |
NodeSelectionStringCommands.getrange(K key,
long start,
long end)
Get a substring of the string stored at a key.
|
Executions<V> |
NodeSelectionStringCommands.getset(K key,
V value)
Set the string value of a key and return its old value.
|
Executions<Long> |
NodeSelectionHashCommands.hdel(K key,
K... fields)
Delete one or more hash fields.
|
Executions<Boolean> |
NodeSelectionHashCommands.hexists(K key,
K field)
Determine if a hash field exists.
|
Executions<V> |
NodeSelectionHashCommands.hget(K key,
K field)
Get the value of a hash field.
|
Executions<Map<K,V>> |
NodeSelectionHashCommands.hgetall(K key)
Get all the fields and values in a hash.
|
Executions<Long> |
NodeSelectionHashCommands.hgetall(KeyValueStreamingChannel<K,V> channel,
K key)
Stream over all the fields and values in a hash.
|
Executions<Long> |
NodeSelectionHashCommands.hincrby(K key,
K field,
long amount)
Increment the integer value of a hash field by the given number.
|
Executions<Double> |
NodeSelectionHashCommands.hincrbyfloat(K key,
K field,
double amount)
Increment the float value of a hash field by the given amount.
|
Executions<List<K>> |
NodeSelectionHashCommands.hkeys(K key)
Get all the fields in a hash.
|
Executions<Long> |
NodeSelectionHashCommands.hkeys(KeyStreamingChannel<K> channel,
K key)
Stream over all the fields in a hash.
|
Executions<Long> |
NodeSelectionHashCommands.hlen(K key)
Get the number of fields in a hash.
|
Executions<Long> |
NodeSelectionHashCommands.hmget(KeyValueStreamingChannel<K,V> channel,
K key,
K... fields)
Stream over the values of all the given hash fields.
|
Executions<List<KeyValue<K,V>>> |
NodeSelectionHashCommands.hmget(K key,
K... fields)
Get the values of all the given hash fields.
|
Executions<String> |
NodeSelectionHashCommands.hmset(K key,
Map<K,V> map)
Set multiple hash fields to multiple values.
|
Executions<MapScanCursor<K,V>> |
NodeSelectionHashCommands.hscan(K key)
Incrementally iterate hash fields and associated values.
|
Executions<StreamScanCursor> |
NodeSelectionHashCommands.hscan(KeyValueStreamingChannel<K,V> channel,
K key)
Incrementally iterate hash fields and associated values.
|
Executions<StreamScanCursor> |
NodeSelectionHashCommands.hscan(KeyValueStreamingChannel<K,V> channel,
K key,
ScanArgs scanArgs)
Incrementally iterate hash fields and associated values.
|
Executions<StreamScanCursor> |
NodeSelectionHashCommands.hscan(KeyValueStreamingChannel<K,V> channel,
K key,
ScanCursor scanCursor)
Incrementally iterate hash fields and associated values.
|
Executions<StreamScanCursor> |
NodeSelectionHashCommands.hscan(KeyValueStreamingChannel<K,V> channel,
K key,
ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate hash fields and associated values.
|
Executions<MapScanCursor<K,V>> |
NodeSelectionHashCommands.hscan(K key,
ScanArgs scanArgs)
Incrementally iterate hash fields and associated values.
|
Executions<MapScanCursor<K,V>> |
NodeSelectionHashCommands.hscan(K key,
ScanCursor scanCursor)
Incrementally iterate hash fields and associated values.
|
Executions<MapScanCursor<K,V>> |
NodeSelectionHashCommands.hscan(K key,
ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate hash fields and associated values.
|
Executions<Boolean> |
NodeSelectionHashCommands.hset(K key,
K field,
V value)
Set the string value of a hash field.
|
Executions<Boolean> |
NodeSelectionHashCommands.hsetnx(K key,
K field,
V value)
Set the value of a hash field, only if the field does not exist.
|
Executions<Long> |
NodeSelectionHashCommands.hstrlen(K key,
K field)
Get the string length of the field value in a hash.
|
Executions<List<V>> |
NodeSelectionHashCommands.hvals(K key)
Get all the values in a hash.
|
Executions<Long> |
NodeSelectionHashCommands.hvals(ValueStreamingChannel<V> channel,
K key)
Stream over all the values in a hash.
|
Executions<Long> |
NodeSelectionStringCommands.incr(K key)
Increment the integer value of a key by one.
|
Executions<Long> |
NodeSelectionStringCommands.incrby(K key,
long amount)
Increment the integer value of a key by the given amount.
|
Executions<Double> |
NodeSelectionStringCommands.incrbyfloat(K key,
double amount)
Increment the float value of a key by the given amount.
|
Executions<String> |
NodeSelectionServerCommands.info()
Get information and statistics about the server.
|
Executions<String> |
NodeSelectionServerCommands.info(String section)
Get information and statistics about the server.
|
Executions<List<K>> |
NodeSelectionKeyCommands.keys(K pattern)
Find all keys matching the given pattern.
|
Executions<Long> |
NodeSelectionKeyCommands.keys(KeyStreamingChannel<K> channel,
K pattern)
Find all keys matching the given pattern.
|
Executions<Date> |
NodeSelectionServerCommands.lastsave()
Get the UNIX time stamp of the last successful save to disk.
|
Executions<V> |
NodeSelectionListCommands.lindex(K key,
long index)
Get an element from a list by its index.
|
Executions<Long> |
NodeSelectionListCommands.linsert(K key,
boolean before,
V pivot,
V value)
Insert an element before or after another element in a list.
|
Executions<Long> |
NodeSelectionListCommands.llen(K key)
Get the length of a list.
|
Executions<V> |
NodeSelectionListCommands.lpop(K key)
Remove and get the first element in a list.
|
Executions<Long> |
NodeSelectionListCommands.lpush(K key,
V... values)
Prepend one or multiple values to a list.
|
Executions<Long> |
NodeSelectionListCommands.lpushx(K key,
V... values)
Prepend values to a list, only if the list exists.
|
Executions<List<V>> |
NodeSelectionListCommands.lrange(K key,
long start,
long stop)
Get a range of elements from a list.
|
Executions<Long> |
NodeSelectionListCommands.lrange(ValueStreamingChannel<V> channel,
K key,
long start,
long stop)
Get a range of elements from a list.
|
Executions<Long> |
NodeSelectionListCommands.lrem(K key,
long count,
V value)
Remove elements from a list.
|
Executions<String> |
NodeSelectionListCommands.lset(K key,
long index,
V value)
Set the value of an element in a list by its index.
|
Executions<String> |
NodeSelectionListCommands.ltrim(K key,
long start,
long stop)
Trim a list to the specified range.
|
Executions<Long> |
NodeSelectionServerCommands.memoryUsage(K key)
Reports the number of bytes that a key and its value require to be stored in RAM.
|
Executions<List<KeyValue<K,V>>> |
NodeSelectionStringCommands.mget(K... keys)
Get the values of all the given keys.
|
Executions<Long> |
NodeSelectionStringCommands.mget(KeyValueStreamingChannel<K,V> channel,
K... keys)
Stream over the values of all the given keys.
|
Executions<String> |
NodeSelectionKeyCommands.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.
|
Executions<String> |
NodeSelectionKeyCommands.migrate(String host,
int port,
K key,
int db,
long timeout)
Atomically transfer a key from a Redis instance to another one.
|
Executions<Boolean> |
NodeSelectionKeyCommands.move(K key,
int db)
Move a key to another database.
|
Executions<String> |
NodeSelectionStringCommands.mset(Map<K,V> map)
Set multiple keys to multiple values.
|
Executions<Boolean> |
NodeSelectionStringCommands.msetnx(Map<K,V> map)
Set multiple keys to multiple values, only if none of the keys exist.
|
Executions<String> |
NodeSelectionKeyCommands.objectEncoding(K key)
returns the kind of internal representation used in order to store the value associated with a key.
|
Executions<Long> |
NodeSelectionKeyCommands.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).
|
Executions<Long> |
NodeSelectionKeyCommands.objectRefcount(K key)
returns the number of references of the value associated with the specified key.
|
Executions<Boolean> |
NodeSelectionKeyCommands.persist(K key)
Remove the expiration from a key.
|
Executions<Boolean> |
NodeSelectionKeyCommands.pexpire(K key,
long milliseconds)
Set a key's time to live in milliseconds.
|
Executions<Boolean> |
NodeSelectionKeyCommands.pexpireat(K key,
Date timestamp)
Set the expiration for a key as a UNIX timestamp specified in milliseconds.
|
Executions<Boolean> |
NodeSelectionKeyCommands.pexpireat(K key,
long timestamp)
Set the expiration for a key as a UNIX timestamp specified in milliseconds.
|
Executions<Long> |
NodeSelectionHLLCommands.pfadd(K key,
V... values)
Adds the specified elements to the specified HyperLogLog.
|
Executions<Long> |
NodeSelectionHLLCommands.pfcount(K... keys)
Return the approximated cardinality of the set(s) observed by the HyperLogLog at key(s).
|
Executions<String> |
NodeSelectionHLLCommands.pfmerge(K destkey,
K... sourcekeys)
Merge N different HyperLogLogs into a single one.
|
Executions<String> |
BaseNodeSelectionCommands.ping()
Ping the server.
|
Executions<String> |
NodeSelectionStringCommands.psetex(K key,
long milliseconds,
V value)
Set the value and expiration in milliseconds of a key.
|
Executions<Long> |
NodeSelectionKeyCommands.pttl(K key)
Get the time to live for a key in milliseconds.
|
Executions<Long> |
BaseNodeSelectionCommands.publish(K channel,
V message)
Post a message to a channel.
|
Executions<List<K>> |
BaseNodeSelectionCommands.pubsubChannels()
Lists the currently *active channels*.
|
Executions<List<K>> |
BaseNodeSelectionCommands.pubsubChannels(K channel)
Lists the currently *active channels*.
|
Executions<Long> |
BaseNodeSelectionCommands.pubsubNumpat()
Returns the number of subscriptions to patterns.
|
Executions<Map<K,Long>> |
BaseNodeSelectionCommands.pubsubNumsub(K... channels)
Returns the number of subscribers (not counting clients subscribed to patterns) for the specified channels.
|
Executions<String> |
BaseNodeSelectionCommands.quit()
Instructs Redis to disconnect the connection.
|
Executions<V> |
NodeSelectionKeyCommands.randomkey()
Return a random key from the keyspace.
|
Executions<String> |
NodeSelectionKeyCommands.rename(K key,
K newKey)
Rename a key.
|
Executions<Boolean> |
NodeSelectionKeyCommands.renamenx(K key,
K newKey)
Rename a key, only if the new key does not exist.
|
Executions<String> |
NodeSelectionKeyCommands.restore(K key,
byte[] value,
RestoreArgs args)
Create a key using the provided serialized value, previously obtained using DUMP.
|
Executions<String> |
NodeSelectionKeyCommands.restore(K key,
long ttl,
byte[] value)
Create a key using the provided serialized value, previously obtained using DUMP.
|
Executions<List<Object>> |
BaseNodeSelectionCommands.role()
Return the role of the instance in the context of replication.
|
Executions<V> |
NodeSelectionListCommands.rpop(K key)
Remove and get the last element in a list.
|
Executions<V> |
NodeSelectionListCommands.rpoplpush(K source,
K destination)
Remove the last element in a list, append it to another list and return it.
|
Executions<Long> |
NodeSelectionListCommands.rpush(K key,
V... values)
Append one or multiple values to a list.
|
Executions<Long> |
NodeSelectionListCommands.rpushx(K key,
V... values)
Append values to a list, only if the list exists.
|
Executions<Long> |
NodeSelectionSetCommands.sadd(K key,
V... members)
Add one or more members to a set.
|
Executions<String> |
NodeSelectionServerCommands.save()
Synchronously save the dataset to disk.
|
Executions<KeyScanCursor<K>> |
NodeSelectionKeyCommands.scan()
Incrementally iterate the keys space.
|
Executions<StreamScanCursor> |
NodeSelectionKeyCommands.scan(KeyStreamingChannel<K> channel)
Incrementally iterate the keys space.
|
Executions<StreamScanCursor> |
NodeSelectionKeyCommands.scan(KeyStreamingChannel<K> channel,
ScanArgs scanArgs)
Incrementally iterate the keys space.
|
Executions<StreamScanCursor> |
NodeSelectionKeyCommands.scan(KeyStreamingChannel<K> channel,
ScanCursor scanCursor)
Incrementally iterate the keys space.
|
Executions<StreamScanCursor> |
NodeSelectionKeyCommands.scan(KeyStreamingChannel<K> channel,
ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate the keys space.
|
Executions<KeyScanCursor<K>> |
NodeSelectionKeyCommands.scan(ScanArgs scanArgs)
Incrementally iterate the keys space.
|
Executions<KeyScanCursor<K>> |
NodeSelectionKeyCommands.scan(ScanCursor scanCursor)
Incrementally iterate the keys space.
|
Executions<KeyScanCursor<K>> |
NodeSelectionKeyCommands.scan(ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate the keys space.
|
Executions<Long> |
NodeSelectionSetCommands.scard(K key)
Get the number of members in a set.
|
Executions<List<Boolean>> |
NodeSelectionScriptingCommands.scriptExists(String... digests)
Check existence of scripts in the script cache.
|
Executions<String> |
NodeSelectionScriptingCommands.scriptFlush()
Remove all the scripts from the script cache.
|
Executions<String> |
NodeSelectionScriptingCommands.scriptKill()
Kill the script currently in execution.
|
Executions<String> |
NodeSelectionScriptingCommands.scriptLoad(V script)
Load the specified Lua script into the script cache.
|
Executions<Set<V>> |
NodeSelectionSetCommands.sdiff(K... keys)
Subtract multiple sets.
|
Executions<Long> |
NodeSelectionSetCommands.sdiff(ValueStreamingChannel<V> channel,
K... keys)
Subtract multiple sets.
|
Executions<Long> |
NodeSelectionSetCommands.sdiffstore(K destination,
K... keys)
Subtract multiple sets and store the resulting set in a key.
|
Executions<String> |
NodeSelectionStringCommands.set(K key,
V value)
Set the string value of a key.
|
Executions<String> |
NodeSelectionStringCommands.set(K key,
V value,
SetArgs setArgs)
Set the string value of a key.
|
Executions<Long> |
NodeSelectionStringCommands.setbit(K key,
long offset,
int value)
Sets or clears the bit at offset in the string value stored at key.
|
Executions<String> |
NodeSelectionStringCommands.setex(K key,
long seconds,
V value)
Set the value and expiration of a key.
|
Executions<Boolean> |
NodeSelectionStringCommands.setnx(K key,
V value)
Set the value of a key, only if the key does not exist.
|
Executions<Long> |
NodeSelectionStringCommands.setrange(K key,
long offset,
V value)
Overwrite part of a string at key starting at the specified offset.
|
Executions<Set<V>> |
NodeSelectionSetCommands.sinter(K... keys)
Intersect multiple sets.
|
Executions<Long> |
NodeSelectionSetCommands.sinter(ValueStreamingChannel<V> channel,
K... keys)
Intersect multiple sets.
|
Executions<Long> |
NodeSelectionSetCommands.sinterstore(K destination,
K... keys)
Intersect multiple sets and store the resulting set in a key.
|
Executions<Boolean> |
NodeSelectionSetCommands.sismember(K key,
V member)
Determine if a given value is a member of a set.
|
Executions<String> |
NodeSelectionServerCommands.slaveof(String host,
int port)
Make the server a replica of another instance, or promote it as master.
|
Executions<String> |
NodeSelectionServerCommands.slaveofNoOne()
Promote server as master.
|
Executions<List<Object>> |
NodeSelectionServerCommands.slowlogGet()
Read the slow log.
|
Executions<List<Object>> |
NodeSelectionServerCommands.slowlogGet(int count)
Read the slow log.
|
Executions<Long> |
NodeSelectionServerCommands.slowlogLen()
Obtaining the current length of the slow log.
|
Executions<String> |
NodeSelectionServerCommands.slowlogReset()
Resetting the slow log.
|
Executions<Set<V>> |
NodeSelectionSetCommands.smembers(K key)
Get all the members in a set.
|
Executions<Long> |
NodeSelectionSetCommands.smembers(ValueStreamingChannel<V> channel,
K key)
Get all the members in a set.
|
Executions<Boolean> |
NodeSelectionSetCommands.smove(K source,
K destination,
V member)
Move a member from one set to another.
|
Executions<List<V>> |
NodeSelectionKeyCommands.sort(K key)
Sort the elements in a list, set or sorted set.
|
Executions<List<V>> |
NodeSelectionKeyCommands.sort(K key,
SortArgs sortArgs)
Sort the elements in a list, set or sorted set.
|
Executions<Long> |
NodeSelectionKeyCommands.sort(ValueStreamingChannel<V> channel,
K key)
Sort the elements in a list, set or sorted set.
|
Executions<Long> |
NodeSelectionKeyCommands.sort(ValueStreamingChannel<V> channel,
K key,
SortArgs sortArgs)
Sort the elements in a list, set or sorted set.
|
Executions<Long> |
NodeSelectionKeyCommands.sortStore(K key,
SortArgs sortArgs,
K destination)
Sort the elements in a list, set or sorted set.
|
Executions<V> |
NodeSelectionSetCommands.spop(K key)
Remove and return a random member from a set.
|
Executions<Set<V>> |
NodeSelectionSetCommands.spop(K key,
long count)
Remove and return one or multiple random members from a set.
|
Executions<V> |
NodeSelectionSetCommands.srandmember(K key)
Get one random member from a set.
|
Executions<List<V>> |
NodeSelectionSetCommands.srandmember(K key,
long count)
Get one or multiple random members from a set.
|
Executions<Long> |
NodeSelectionSetCommands.srandmember(ValueStreamingChannel<V> channel,
K key,
long count)
Get one or multiple random members from a set.
|
Executions<Long> |
NodeSelectionSetCommands.srem(K key,
V... members)
Remove one or more members from a set.
|
Executions<ValueScanCursor<V>> |
NodeSelectionSetCommands.sscan(K key)
Incrementally iterate Set elements.
|
Executions<ValueScanCursor<V>> |
NodeSelectionSetCommands.sscan(K key,
ScanArgs scanArgs)
Incrementally iterate Set elements.
|
Executions<ValueScanCursor<V>> |
NodeSelectionSetCommands.sscan(K key,
ScanCursor scanCursor)
Incrementally iterate Set elements.
|
Executions<ValueScanCursor<V>> |
NodeSelectionSetCommands.sscan(K key,
ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate Set elements.
|
Executions<StreamScanCursor> |
NodeSelectionSetCommands.sscan(ValueStreamingChannel<V> channel,
K key)
Incrementally iterate Set elements.
|
Executions<StreamScanCursor> |
NodeSelectionSetCommands.sscan(ValueStreamingChannel<V> channel,
K key,
ScanArgs scanArgs)
Incrementally iterate Set elements.
|
Executions<StreamScanCursor> |
NodeSelectionSetCommands.sscan(ValueStreamingChannel<V> channel,
K key,
ScanCursor scanCursor)
Incrementally iterate Set elements.
|
Executions<StreamScanCursor> |
NodeSelectionSetCommands.sscan(ValueStreamingChannel<V> channel,
K key,
ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate Set elements.
|
Executions<Long> |
NodeSelectionStringCommands.strlen(K key)
Get the length of the value stored in a key.
|
Executions<Set<V>> |
NodeSelectionSetCommands.sunion(K... keys)
Add multiple sets.
|
Executions<Long> |
NodeSelectionSetCommands.sunion(ValueStreamingChannel<V> channel,
K... keys)
Add multiple sets.
|
Executions<Long> |
NodeSelectionSetCommands.sunionstore(K destination,
K... keys)
Add multiple sets and store the resulting set in a key.
|
Executions<List<V>> |
NodeSelectionServerCommands.time()
Return the current server time.
|
Executions<Long> |
NodeSelectionKeyCommands.touch(K... keys)
Touch one or more keys.
|
Executions<Long> |
NodeSelectionKeyCommands.ttl(K key)
Get the time to live for a key.
|
Executions<String> |
NodeSelectionKeyCommands.type(K key)
Determine the type stored at key.
|
Executions<Long> |
NodeSelectionKeyCommands.unlink(K... keys)
Unlink one or more keys (non blocking DEL).
|
Executions<Long> |
BaseNodeSelectionCommands.waitForReplication(int replicas,
long timeout)
Wait for replication.
|
Executions<Long> |
NodeSelectionStreamCommands.xack(K key,
K group,
String... messageIds)
Acknowledge one or more messages as processed.
|
Executions<String> |
NodeSelectionStreamCommands.xadd(K key,
Map<K,V> body)
Append a message to the stream
key. |
Executions<String> |
NodeSelectionStreamCommands.xadd(K key,
Object... keysAndValues)
Append a message to the stream
key. |
Executions<String> |
NodeSelectionStreamCommands.xadd(K key,
XAddArgs args,
Map<K,V> body)
Append a message to the stream
key. |
Executions<String> |
NodeSelectionStreamCommands.xadd(K key,
XAddArgs args,
Object... keysAndValues)
Append a message to the stream
key. |
Executions<List<StreamMessage<K,V>>> |
NodeSelectionStreamCommands.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.
|
Executions<List<StreamMessage<K,V>>> |
NodeSelectionStreamCommands.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.
|
Executions<Long> |
NodeSelectionStreamCommands.xdel(K key,
String... messageIds)
Removes the specified entries from the stream.
|
Executions<String> |
NodeSelectionStreamCommands.xgroupCreate(XReadArgs.StreamOffset<K> streamOffset,
K group)
Create a consumer group.
|
Executions<String> |
NodeSelectionStreamCommands.xgroupCreate(XReadArgs.StreamOffset<K> streamOffset,
K group,
XGroupCreateArgs args)
Create a consumer group.
|
Executions<Boolean> |
NodeSelectionStreamCommands.xgroupDelconsumer(K key,
Consumer<K> consumer)
Delete a consumer from a consumer group.
|
Executions<Boolean> |
NodeSelectionStreamCommands.xgroupDestroy(K key,
K group)
Destroy a consumer group.
|
Executions<String> |
NodeSelectionStreamCommands.xgroupSetid(XReadArgs.StreamOffset<K> streamOffset,
K group)
Set the current
group id. |
Executions<List<Object>> |
NodeSelectionStreamCommands.xinfoConsumers(K key,
K group)
Retrieve information about consumer groups of group
group and stream at key. |
Executions<List<Object>> |
NodeSelectionStreamCommands.xinfoGroups(K key)
Retrieve information about the stream consumer groups at
key. |
Executions<List<Object>> |
NodeSelectionStreamCommands.xinfoStream(K key)
Retrieve information about the stream at
key. |
Executions<Long> |
NodeSelectionStreamCommands.xlen(K key)
Get the length of a steam.
|
Executions<List<Object>> |
NodeSelectionStreamCommands.xpending(K key,
Consumer<K> consumer,
Range<String> range,
Limit limit)
Read pending messages from a stream within a specific
Range. |
Executions<List<Object>> |
NodeSelectionStreamCommands.xpending(K key,
K group)
Read pending messages from a stream for a
group. |
Executions<List<Object>> |
NodeSelectionStreamCommands.xpending(K key,
K group,
Range<String> range,
Limit limit)
Read pending messages from a stream within a specific
Range. |
Executions<List<StreamMessage<K,V>>> |
NodeSelectionStreamCommands.xrange(K key,
Range<String> range)
Read messages from a stream within a specific
Range. |
Executions<List<StreamMessage<K,V>>> |
NodeSelectionStreamCommands.xrange(K key,
Range<String> range,
Limit limit)
|
Executions<List<StreamMessage<K,V>>> |
NodeSelectionStreamCommands.xread(XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffsets. |
Executions<List<StreamMessage<K,V>>> |
NodeSelectionStreamCommands.xread(XReadArgs args,
XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffsets. |
Executions<List<StreamMessage<K,V>>> |
NodeSelectionStreamCommands.xreadgroup(Consumer<K> consumer,
XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffsets using a consumer group. |
Executions<List<StreamMessage<K,V>>> |
NodeSelectionStreamCommands.xreadgroup(Consumer<K> consumer,
XReadArgs args,
XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffsets using a consumer group. |
Executions<List<StreamMessage<K,V>>> |
NodeSelectionStreamCommands.xrevrange(K key,
Range<String> range)
Read messages from a stream within a specific
Range in reverse order. |
Executions<List<StreamMessage<K,V>>> |
NodeSelectionStreamCommands.xrevrange(K key,
Range<String> range,
Limit limit)
|
Executions<Long> |
NodeSelectionStreamCommands.xtrim(K key,
boolean approximateTrimming,
long count)
Trims the stream to
count elements. |
Executions<Long> |
NodeSelectionStreamCommands.xtrim(K key,
long count)
Trims the stream to
count elements. |
Executions<Long> |
NodeSelectionSortedSetCommands.zadd(K key,
double score,
V member)
Add one or more members to a sorted set, or update its score if it already exists.
|
Executions<Long> |
NodeSelectionSortedSetCommands.zadd(K key,
Object... scoresAndValues)
Add one or more members to a sorted set, or update its score if it already exists.
|
Executions<Long> |
NodeSelectionSortedSetCommands.zadd(K key,
ScoredValue<V>... scoredValues)
Add one or more members to a sorted set, or update its score if it already exists.
|
Executions<Long> |
NodeSelectionSortedSetCommands.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.
|
Executions<Long> |
NodeSelectionSortedSetCommands.zadd(K key,
ZAddArgs zAddArgs,
Object... scoresAndValues)
Add one or more members to a sorted set, or update its score if it already exists.
|
Executions<Long> |
NodeSelectionSortedSetCommands.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.
|
Executions<Double> |
NodeSelectionSortedSetCommands.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. |
Executions<Double> |
NodeSelectionSortedSetCommands.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. |
Executions<Long> |
NodeSelectionSortedSetCommands.zcard(K key)
Get the number of members in a sorted set.
|
Executions<Long> |
NodeSelectionSortedSetCommands.zcount(K key,
double min,
double max)
Deprecated.
|
Executions<Long> |
NodeSelectionSortedSetCommands.zcount(K key,
Range<? extends Number> range)
Count the members in a sorted set with scores within the given
Range. |
Executions<Long> |
NodeSelectionSortedSetCommands.zcount(K key,
String min,
String max)
Deprecated.
|
Executions<Double> |
NodeSelectionSortedSetCommands.zincrby(K key,
double amount,
V member)
Increment the score of a member in a sorted set.
|
Executions<Long> |
NodeSelectionSortedSetCommands.zinterstore(K destination,
K... keys)
Intersect multiple sorted sets and store the resulting sorted set in a new key.
|
Executions<Long> |
NodeSelectionSortedSetCommands.zinterstore(K destination,
ZStoreArgs storeArgs,
K... keys)
Intersect multiple sorted sets and store the resulting sorted set in a new key.
|
Executions<Long> |
NodeSelectionSortedSetCommands.zlexcount(K key,
Range<? extends V> range)
Count the number of members in a sorted set between a given lexicographical range.
|
Executions<Long> |
NodeSelectionSortedSetCommands.zlexcount(K key,
String min,
String max)
|
Executions<ScoredValue<V>> |
NodeSelectionSortedSetCommands.zpopmax(K key)
Removes and returns up to count members with the highest scores in the sorted set stored at key.
|
Executions<List<ScoredValue<V>>> |
NodeSelectionSortedSetCommands.zpopmax(K key,
long count)
Removes and returns up to count members with the highest scores in the sorted set stored at key.
|
Executions<ScoredValue<V>> |
NodeSelectionSortedSetCommands.zpopmin(K key)
Removes and returns up to count members with the lowest scores in the sorted set stored at key.
|
Executions<List<ScoredValue<V>>> |
NodeSelectionSortedSetCommands.zpopmin(K key,
long count)
Removes and returns up to count members with the lowest scores in the sorted set stored at key.
|
Executions<List<V>> |
NodeSelectionSortedSetCommands.zrange(K key,
long start,
long stop)
Return a range of members in a sorted set, by index.
|
Executions<Long> |
NodeSelectionSortedSetCommands.zrange(ValueStreamingChannel<V> channel,
K key,
long start,
long stop)
Return a range of members in a sorted set, by index.
|
Executions<List<V>> |
NodeSelectionSortedSetCommands.zrangebylex(K key,
Range<? extends V> range)
Return a range of members in a sorted set, by lexicographical range.
|
Executions<List<V>> |
NodeSelectionSortedSetCommands.zrangebylex(K key,
Range<? extends V> range,
Limit limit)
Return a range of members in a sorted set, by lexicographical range.
|
Executions<List<V>> |
NodeSelectionSortedSetCommands.zrangebylex(K key,
String min,
String max)
|
Executions<List<V>> |
NodeSelectionSortedSetCommands.zrangebylex(K key,
String min,
String max,
long offset,
long count)
|
Executions<List<V>> |
NodeSelectionSortedSetCommands.zrangebyscore(K key,
double min,
double max)
|
Executions<List<V>> |
NodeSelectionSortedSetCommands.zrangebyscore(K key,
double min,
double max,
long offset,
long count)
|
Executions<List<V>> |
NodeSelectionSortedSetCommands.zrangebyscore(K key,
Range<? extends Number> range)
Return a range of members in a sorted set, by score.
|
Executions<List<V>> |
NodeSelectionSortedSetCommands.zrangebyscore(K key,
Range<? extends Number> range,
Limit limit)
Return a range of members in a sorted set, by score.
|
Executions<List<V>> |
NodeSelectionSortedSetCommands.zrangebyscore(K key,
String min,
String max)
|
Executions<List<V>> |
NodeSelectionSortedSetCommands.zrangebyscore(K key,
String min,
String max,
long offset,
long count)
|
Executions<Long> |
NodeSelectionSortedSetCommands.zrangebyscore(ValueStreamingChannel<V> channel,
K key,
double min,
double max)
|
Executions<Long> |
NodeSelectionSortedSetCommands.zrangebyscore(ValueStreamingChannel<V> channel,
K key,
double min,
double max,
long offset,
long count)
|
Executions<Long> |
NodeSelectionSortedSetCommands.zrangebyscore(ValueStreamingChannel<V> channel,
K key,
Range<? extends Number> range)
Stream over a range of members in a sorted set, by score.
|
Executions<Long> |
NodeSelectionSortedSetCommands.zrangebyscore(ValueStreamingChannel<V> channel,
K key,
Range<? extends Number> range,
Limit limit)
Stream over a range of members in a sorted set, by score.
|
Executions<Long> |
NodeSelectionSortedSetCommands.zrangebyscore(ValueStreamingChannel<V> channel,
K key,
String min,
String max)
|
Executions<Long> |
NodeSelectionSortedSetCommands.zrangebyscore(ValueStreamingChannel<V> channel,
K key,
String min,
String max,
long offset,
long count)
|
Executions<List<ScoredValue<V>>> |
NodeSelectionSortedSetCommands.zrangebyscoreWithScores(K key,
double min,
double max)
|
Executions<List<ScoredValue<V>>> |
NodeSelectionSortedSetCommands.zrangebyscoreWithScores(K key,
double min,
double max,
long offset,
long count)
|
Executions<List<ScoredValue<V>>> |
NodeSelectionSortedSetCommands.zrangebyscoreWithScores(K key,
Range<? extends Number> range)
Return a range of members with score in a sorted set, by score.
|
Executions<List<ScoredValue<V>>> |
NodeSelectionSortedSetCommands.zrangebyscoreWithScores(K key,
Range<? extends Number> range,
Limit limit)
Return a range of members with score in a sorted set, by score.
|
Executions<List<ScoredValue<V>>> |
NodeSelectionSortedSetCommands.zrangebyscoreWithScores(K key,
String min,
String max)
|
Executions<List<ScoredValue<V>>> |
NodeSelectionSortedSetCommands.zrangebyscoreWithScores(K key,
String min,
String max,
long offset,
long count)
|
Executions<Long> |
NodeSelectionSortedSetCommands.zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
double min,
double max)
|
Executions<Long> |
NodeSelectionSortedSetCommands.zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
double min,
double max,
long offset,
long count)
|
Executions<Long> |
NodeSelectionSortedSetCommands.zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
Range<? extends Number> range)
Stream over a range of members with scores in a sorted set, by score.
|
Executions<Long> |
NodeSelectionSortedSetCommands.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.
|
Executions<Long> |
NodeSelectionSortedSetCommands.zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
String min,
String max)
|
Executions<Long> |
NodeSelectionSortedSetCommands.zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
String min,
String max,
long offset,
long count)
|
Executions<List<ScoredValue<V>>> |
NodeSelectionSortedSetCommands.zrangeWithScores(K key,
long start,
long stop)
Return a range of members with scores in a sorted set, by index.
|
Executions<Long> |
NodeSelectionSortedSetCommands.zrangeWithScores(ScoredValueStreamingChannel<V> channel,
K key,
long start,
long stop)
Stream over a range of members with scores in a sorted set, by index.
|
Executions<Long> |
NodeSelectionSortedSetCommands.zrank(K key,
V member)
Determine the index of a member in a sorted set.
|
Executions<Long> |
NodeSelectionSortedSetCommands.zrem(K key,
V... members)
Remove one or more members from a sorted set.
|
Executions<Long> |
NodeSelectionSortedSetCommands.zremrangebylex(K key,
Range<? extends V> range)
Remove all members in a sorted set between the given lexicographical range.
|
Executions<Long> |
NodeSelectionSortedSetCommands.zremrangebylex(K key,
String min,
String max)
|
Executions<Long> |
NodeSelectionSortedSetCommands.zremrangebyrank(K key,
long start,
long stop)
Remove all members in a sorted set within the given indexes.
|
Executions<Long> |
NodeSelectionSortedSetCommands.zremrangebyscore(K key,
double min,
double max)
|
Executions<Long> |
NodeSelectionSortedSetCommands.zremrangebyscore(K key,
Range<? extends Number> range)
Remove all members in a sorted set within the given scores.
|
Executions<Long> |
NodeSelectionSortedSetCommands.zremrangebyscore(K key,
String min,
String max)
|
Executions<List<V>> |
NodeSelectionSortedSetCommands.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.
|
Executions<Long> |
NodeSelectionSortedSetCommands.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.
|
Executions<List<V>> |
NodeSelectionSortedSetCommands.zrevrangebylex(K key,
Range<? extends V> range)
Return a range of members in a sorted set, by lexicographical range ordered from high to low.
|
Executions<List<V>> |
NodeSelectionSortedSetCommands.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.
|
Executions<List<V>> |
NodeSelectionSortedSetCommands.zrevrangebyscore(K key,
double max,
double min)
|
Executions<List<V>> |
NodeSelectionSortedSetCommands.zrevrangebyscore(K key,
double max,
double min,
long offset,
long count)
|
Executions<List<V>> |
NodeSelectionSortedSetCommands.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.
|
Executions<List<V>> |
NodeSelectionSortedSetCommands.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.
|
Executions<List<V>> |
NodeSelectionSortedSetCommands.zrevrangebyscore(K key,
String max,
String min)
|
Executions<List<V>> |
NodeSelectionSortedSetCommands.zrevrangebyscore(K key,
String max,
String min,
long offset,
long count)
|
Executions<Long> |
NodeSelectionSortedSetCommands.zrevrangebyscore(ValueStreamingChannel<V> channel,
K key,
double max,
double min)
|
Executions<Long> |
NodeSelectionSortedSetCommands.zrevrangebyscore(ValueStreamingChannel<V> channel,
K key,
double max,
double min,
long offset,
long count)
|
Executions<Long> |
NodeSelectionSortedSetCommands.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.
|
Executions<Long> |
NodeSelectionSortedSetCommands.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.
|
Executions<Long> |
NodeSelectionSortedSetCommands.zrevrangebyscore(ValueStreamingChannel<V> channel,
K key,
String max,
String min)
|
Executions<Long> |
NodeSelectionSortedSetCommands.zrevrangebyscore(ValueStreamingChannel<V> channel,
K key,
String max,
String min,
long offset,
long count)
|
Executions<List<ScoredValue<V>>> |
NodeSelectionSortedSetCommands.zrevrangebyscoreWithScores(K key,
double max,
double min)
|
Executions<List<ScoredValue<V>>> |
NodeSelectionSortedSetCommands.zrevrangebyscoreWithScores(K key,
double max,
double min,
long offset,
long count)
|
Executions<List<ScoredValue<V>>> |
NodeSelectionSortedSetCommands.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.
|
Executions<List<ScoredValue<V>>> |
NodeSelectionSortedSetCommands.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.
|
Executions<List<ScoredValue<V>>> |
NodeSelectionSortedSetCommands.zrevrangebyscoreWithScores(K key,
String max,
String min)
|
Executions<List<ScoredValue<V>>> |
NodeSelectionSortedSetCommands.zrevrangebyscoreWithScores(K key,
String max,
String min,
long offset,
long count)
|
Executions<Long> |
NodeSelectionSortedSetCommands.zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
double max,
double min)
|
Executions<Long> |
NodeSelectionSortedSetCommands.zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
double max,
double min,
long offset,
long count)
|
Executions<Long> |
NodeSelectionSortedSetCommands.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.
|
Executions<Long> |
NodeSelectionSortedSetCommands.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.
|
Executions<Long> |
NodeSelectionSortedSetCommands.zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
String max,
String min)
|
Executions<Long> |
NodeSelectionSortedSetCommands.zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
String max,
String min,
long offset,
long count)
|
Executions<List<ScoredValue<V>>> |
NodeSelectionSortedSetCommands.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.
|
Executions<Long> |
NodeSelectionSortedSetCommands.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.
|
Executions<Long> |
NodeSelectionSortedSetCommands.zrevrank(K key,
V member)
Determine the index of a member in a sorted set, with scores ordered from high to low.
|
Executions<ScoredValueScanCursor<V>> |
NodeSelectionSortedSetCommands.zscan(K key)
Incrementally iterate sorted sets elements and associated scores.
|
Executions<ScoredValueScanCursor<V>> |
NodeSelectionSortedSetCommands.zscan(K key,
ScanArgs scanArgs)
Incrementally iterate sorted sets elements and associated scores.
|
Executions<ScoredValueScanCursor<V>> |
NodeSelectionSortedSetCommands.zscan(K key,
ScanCursor scanCursor)
Incrementally iterate sorted sets elements and associated scores.
|
Executions<ScoredValueScanCursor<V>> |
NodeSelectionSortedSetCommands.zscan(K key,
ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate sorted sets elements and associated scores.
|
Executions<StreamScanCursor> |
NodeSelectionSortedSetCommands.zscan(ScoredValueStreamingChannel<V> channel,
K key)
Incrementally iterate sorted sets elements and associated scores.
|
Executions<StreamScanCursor> |
NodeSelectionSortedSetCommands.zscan(ScoredValueStreamingChannel<V> channel,
K key,
ScanArgs scanArgs)
Incrementally iterate sorted sets elements and associated scores.
|
Executions<StreamScanCursor> |
NodeSelectionSortedSetCommands.zscan(ScoredValueStreamingChannel<V> channel,
K key,
ScanCursor scanCursor)
Incrementally iterate sorted sets elements and associated scores.
|
Executions<StreamScanCursor> |
NodeSelectionSortedSetCommands.zscan(ScoredValueStreamingChannel<V> channel,
K key,
ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate sorted sets elements and associated scores.
|
Executions<Double> |
NodeSelectionSortedSetCommands.zscore(K key,
V member)
Get the score associated with the given member in a sorted set.
|
Executions<Long> |
NodeSelectionSortedSetCommands.zunionstore(K destination,
K... keys)
Add multiple sorted sets and store the resulting sorted set in a new key.
|
Executions<Long> |
NodeSelectionSortedSetCommands.zunionstore(K destination,
ZStoreArgs storeArgs,
K... keys)
Add multiple sorted sets and store the resulting sorted set in a new key.
|
| Modifier and Type | Method and Description |
|---|---|
Executions<Void> |
NodeSelectionPubSubCommands.psubscribe(K... patterns)
Listen for messages published to channels matching the given patterns.
|
Executions<Void> |
NodeSelectionPubSubCommands.punsubscribe(K... patterns)
Stop listening for messages posted to channels matching the given patterns.
|
Executions<Void> |
NodeSelectionPubSubCommands.subscribe(K... channels)
Listen for messages published to the given channels.
|
Executions<Void> |
NodeSelectionPubSubCommands.unsubscribe(K... channels)
Stop listening for messages posted to the given channels.
|
Copyright © 2019 lettuce.io. All rights reserved.