Package | Description |
---|---|
com.lambdaworks.redis |
The redis client package containing
RedisClient for regular and sentinel operations. |
com.lambdaworks.redis.cluster |
Client for redis clusters
RedisClusterClient |
com.lambdaworks.redis.protocol |
Redis protocol layer abstraction.
|
com.lambdaworks.redis.pubsub |
Pub/Sub connection classes.
|
Modifier and Type | Method and Description |
---|---|
RedisFuture<Long> |
RedisStringsAsyncConnection.append(K key,
V value)
Append a value to a key.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.append(K key,
V value) |
RedisFuture<String> |
RedisClusterAsyncConnection.asking()
The asking command is required after a
-ASK redirection. |
RedisFuture<String> |
RedisAsyncConnectionImpl.asking() |
RedisFuture<String> |
RedisServerAsyncConnection.bgrewriteaof()
Asynchronously rewrite the append-only file.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.bgrewriteaof() |
RedisFuture<String> |
RedisServerAsyncConnection.bgsave()
Asynchronously save the dataset to disk.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.bgsave() |
RedisFuture<Long> |
RedisStringsAsyncConnection.bitcount(K key)
Count set bits in a string.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.bitcount(K key) |
RedisFuture<Long> |
RedisStringsAsyncConnection.bitcount(K key,
long start,
long end)
Count set bits in a string.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.bitcount(K key,
long start,
long end) |
RedisFuture<List<Long>> |
RedisStringsAsyncConnection.bitfield(K key,
BitFieldArgs bitFieldArgs)
Execute
BITFIELD with its subcommands. |
RedisFuture<List<Long>> |
RedisAsyncConnectionImpl.bitfield(K key,
BitFieldArgs bitFieldArgs) |
RedisFuture<Long> |
RedisStringsAsyncConnection.bitopAnd(K destination,
K... keys)
Perform bitwise AND between strings.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.bitopAnd(K destination,
K... keys) |
RedisFuture<Long> |
RedisStringsAsyncConnection.bitopNot(K destination,
K source)
Perform bitwise NOT between strings.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.bitopNot(K destination,
K source) |
RedisFuture<Long> |
RedisStringsAsyncConnection.bitopOr(K destination,
K... keys)
Perform bitwise OR between strings.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.bitopOr(K destination,
K... keys) |
RedisFuture<Long> |
RedisStringsAsyncConnection.bitopXor(K destination,
K... keys)
Perform bitwise XOR between strings.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.bitopXor(K destination,
K... keys) |
RedisFuture<Long> |
RedisStringsAsyncConnection.bitpos(K key,
boolean state)
Find first bit set or clear in a string.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.bitpos(K key,
boolean state) |
RedisFuture<Long> |
RedisStringsAsyncConnection.bitpos(K key,
boolean state,
long start,
long end)
Find first bit set or clear in a string.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.bitpos(K key,
boolean state,
long start,
long end) |
RedisFuture<KeyValue<K,V>> |
RedisListsAsyncConnection.blpop(long timeout,
K... keys)
Remove and get the first element in a list, or block until one is available.
|
RedisFuture<KeyValue<K,V>> |
RedisAsyncConnectionImpl.blpop(long timeout,
K... keys) |
RedisFuture<KeyValue<K,V>> |
RedisListsAsyncConnection.brpop(long timeout,
K... keys)
Remove and get the last element in a list, or block until one is available.
|
RedisFuture<KeyValue<K,V>> |
RedisAsyncConnectionImpl.brpop(long timeout,
K... keys) |
RedisFuture<V> |
RedisListsAsyncConnection.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.
|
RedisFuture<V> |
RedisAsyncConnectionImpl.brpoplpush(long timeout,
K source,
K destination) |
RedisFuture<K> |
RedisServerAsyncConnection.clientGetname()
Get the current connection name.
|
RedisFuture<K> |
RedisAsyncConnectionImpl.clientGetname() |
RedisFuture<Long> |
RedisServerAsyncConnection.clientKill(KillArgs killArgs)
Kill connections of clients which are filtered by
killArgs |
RedisFuture<Long> |
RedisAsyncConnectionImpl.clientKill(KillArgs killArgs) |
RedisFuture<String> |
RedisServerAsyncConnection.clientKill(String addr)
Kill the connection of a client identified by ip:port.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.clientKill(String addr) |
RedisFuture<String> |
RedisServerAsyncConnection.clientList()
Get the list of client connections.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.clientList() |
RedisFuture<String> |
RedisServerAsyncConnection.clientPause(long timeout)
Stop processing commands from clients for some time.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.clientPause(long timeout) |
RedisFuture<String> |
RedisServerAsyncConnection.clientSetname(K name)
Set the current connection name.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.clientSetname(K name) |
RedisFuture<String> |
RedisClusterAsyncConnection.clusterAddSlots(int... slots)
Adds slots to the cluster node.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.clusterAddSlots(int... slots) |
RedisFuture<String> |
RedisClusterAsyncConnection.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.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.clusterBumpepoch() |
RedisFuture<Long> |
RedisClusterAsyncConnection.clusterCountFailureReports(String nodeId)
Returns the number of failure reports for the specified node.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.clusterCountFailureReports(String nodeId) |
RedisFuture<Long> |
RedisClusterAsyncConnection.clusterCountKeysInSlot(int slot)
Returns the number of keys in the specified Redis Cluster hash
slot . |
RedisFuture<Long> |
RedisAsyncConnectionImpl.clusterCountKeysInSlot(int slot) |
RedisFuture<String> |
RedisClusterAsyncConnection.clusterDelSlots(int... slots)
Removes slots from the cluster node.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.clusterDelSlots(int... slots) |
RedisFuture<String> |
RedisClusterAsyncConnection.clusterFailover(boolean force)
Failover a cluster node.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.clusterFailover(boolean force) |
RedisFuture<String> |
RedisClusterAsyncConnection.clusterFlushslots()
Delete all the slots associated with the specified node.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.clusterFlushslots() |
RedisFuture<String> |
RedisClusterAsyncConnection.clusterForget(String nodeId)
Blacklist and remove the cluster node from the cluster.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.clusterForget(String nodeId) |
RedisFuture<List<K>> |
RedisClusterAsyncConnection.clusterGetKeysInSlot(int slot,
int count)
Retrieve the list of keys within the
slot . |
RedisFuture<List<K>> |
RedisAsyncConnectionImpl.clusterGetKeysInSlot(int slot,
int count) |
RedisFuture<String> |
RedisClusterAsyncConnection.clusterInfo()
Get information and statistics about the cluster viewed by the current node.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.clusterInfo() |
RedisFuture<Long> |
RedisClusterAsyncConnection.clusterKeyslot(K key)
Returns an integer identifying the hash slot the specified key hashes to.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.clusterKeyslot(K key) |
RedisFuture<String> |
RedisClusterAsyncConnection.clusterMeet(String ip,
int port)
Meet another cluster node to include the node into the cluster.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.clusterMeet(String ip,
int port) |
RedisFuture<String> |
RedisClusterAsyncConnection.clusterMyId()
Obtain the nodeId for the currently connected node.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.clusterMyId() |
RedisFuture<String> |
RedisClusterAsyncConnection.clusterNodes()
Obtain details about all cluster nodes.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.clusterNodes() |
RedisFuture<String> |
RedisClusterAsyncConnection.clusterReplicate(String nodeId)
Turn this node into a slave of the node with the id
nodeId . |
RedisFuture<String> |
RedisAsyncConnectionImpl.clusterReplicate(String nodeId) |
RedisFuture<String> |
RedisClusterAsyncConnection.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
|
RedisFuture<String> |
RedisAsyncConnectionImpl.clusterReset(boolean hard) |
RedisFuture<String> |
RedisClusterAsyncConnection.clusterSaveconfig()
Forces a node to save the nodes.conf configuration on disk.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.clusterSaveconfig() |
RedisFuture<String> |
RedisClusterAsyncConnection.clusterSetConfigEpoch(long configEpoch)
This command sets a specific config epoch in a fresh node.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.clusterSetConfigEpoch(long configEpoch) |
RedisFuture<String> |
RedisClusterAsyncConnection.clusterSetSlotImporting(int slot,
String nodeId)
Flag a slot as IMPORTING (incoming) from the node specified in
nodeId . |
RedisFuture<String> |
RedisAsyncConnectionImpl.clusterSetSlotImporting(int slot,
String nodeId) |
RedisFuture<String> |
RedisClusterAsyncConnection.clusterSetSlotMigrating(int slot,
String nodeId)
Flag a slot as MIGRATING (outgoing) towards the node specified in
nodeId . |
RedisFuture<String> |
RedisAsyncConnectionImpl.clusterSetSlotMigrating(int slot,
String nodeId) |
RedisFuture<String> |
RedisClusterAsyncConnection.clusterSetSlotNode(int slot,
String nodeId)
Assign a slot to a node.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.clusterSetSlotNode(int slot,
String nodeId) |
RedisFuture<String> |
RedisClusterAsyncConnection.clusterSetSlotStable(int slot)
Clears migrating / importing state from the slot.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.clusterSetSlotStable(int slot) |
RedisFuture<List<String>> |
RedisClusterAsyncConnection.clusterSlaves(String nodeId)
List slaves for a certain node identified by its
nodeId . |
RedisFuture<List<String>> |
RedisAsyncConnectionImpl.clusterSlaves(String nodeId) |
RedisFuture<List<Object>> |
RedisClusterAsyncConnection.clusterSlots()
Get array of cluster slots to node mappings.
|
RedisFuture<List<Object>> |
RedisAsyncConnectionImpl.clusterSlots() |
RedisFuture<List<Object>> |
RedisServerAsyncConnection.command()
Returns an array reply of details about all Redis commands.
|
RedisFuture<List<Object>> |
RedisAsyncConnectionImpl.command() |
RedisFuture<Long> |
RedisServerAsyncConnection.commandCount()
Get total number of Redis commands.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.commandCount() |
RedisFuture<List<Object>> |
RedisServerAsyncConnection.commandInfo(CommandType... commands)
Returns an array reply of details about the requested commands.
|
RedisFuture<List<Object>> |
RedisAsyncConnectionImpl.commandInfo(CommandType... commands) |
RedisFuture<List<Object>> |
RedisServerAsyncConnection.commandInfo(String... commands)
Returns an array reply of details about the requested commands.
|
RedisFuture<List<Object>> |
RedisAsyncConnectionImpl.commandInfo(String... commands) |
RedisFuture<List<String>> |
RedisServerAsyncConnection.configGet(String parameter)
Get the value of a configuration parameter.
|
RedisFuture<List<String>> |
RedisAsyncConnectionImpl.configGet(String parameter) |
RedisFuture<String> |
RedisServerAsyncConnection.configResetstat()
Reset the stats returned by INFO.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.configResetstat() |
RedisFuture<String> |
RedisServerAsyncConnection.configRewrite()
Rewrite the configuration file with the in memory configuration.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.configRewrite() |
RedisFuture<String> |
RedisServerAsyncConnection.configSet(String parameter,
String value)
Set a configuration parameter to the given value.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.configSet(String parameter,
String value) |
RedisFuture<Long> |
RedisServerAsyncConnection.dbsize()
Return the number of keys in the selected database.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.dbsize() |
RedisFuture<String> |
RedisServerAsyncConnection.debugHtstats(int db)
Get debugging information about the internal hash-table state.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.debugHtstats(int db) |
RedisFuture<String> |
RedisServerAsyncConnection.debugObject(K key)
Get debugging information about a key.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.debugObject(K key) |
RedisFuture<Long> |
RedisStringsAsyncConnection.decr(K key)
Decrement the integer value of a key by one.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.decr(K key) |
RedisFuture<Long> |
RedisStringsAsyncConnection.decrby(K key,
long amount)
Decrement the integer value of a key by the given number.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.decrby(K key,
long amount) |
RedisFuture<Long> |
RedisKeysAsyncConnection.del(K... keys)
Delete one or more keys.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.del(K... keys) |
RedisFuture<String> |
RedisAsyncConnectionImpl.discard() |
RedisFuture<String> |
BaseRedisAsyncConnection.discard()
Discard all commands issued after MULTI.
|
protected <T> RedisFuture<T> |
RedisAsyncConnectionImpl.dispatch(CommandType type,
CommandOutput<K,V,T> output) |
<T> RedisFuture<T> |
RedisAsyncConnectionImpl.dispatch(ProtocolKeyword type,
CommandOutput<K,V,T> output) |
<T> RedisFuture<T> |
BaseRedisAsyncConnection.dispatch(ProtocolKeyword type,
CommandOutput<K,V,T> output)
Dispatch a command to the Redis Server.
|
<T> RedisFuture<T> |
RedisAsyncConnectionImpl.dispatch(ProtocolKeyword type,
CommandOutput<K,V,T> output,
CommandArgs<K,V> args) |
<T> RedisFuture<T> |
BaseRedisAsyncConnection.dispatch(ProtocolKeyword type,
CommandOutput<K,V,T> output,
CommandArgs<K,V> args)
Dispatch a command to the Redis Server.
|
RedisFuture<byte[]> |
RedisKeysAsyncConnection.dump(K key)
Return a serialized version of the value stored at the specified key.
|
RedisFuture<byte[]> |
RedisAsyncConnectionImpl.dump(K key) |
RedisFuture<V> |
RedisAsyncConnectionImpl.echo(V msg) |
RedisFuture<V> |
BaseRedisAsyncConnection.echo(V msg)
Echo the given string.
|
<T> RedisFuture<T> |
RedisScriptingAsyncConnection.eval(String script,
ScriptOutputType type,
K... keys)
Execute a Lua script server side.
|
<T> RedisFuture<T> |
RedisAsyncConnectionImpl.eval(String script,
ScriptOutputType type,
K... keys) |
<T> RedisFuture<T> |
RedisScriptingAsyncConnection.eval(String script,
ScriptOutputType type,
K[] keys,
V... values)
Execute a Lua script server side.
|
<T> RedisFuture<T> |
RedisAsyncConnectionImpl.eval(String script,
ScriptOutputType type,
K[] keys,
V... values) |
<T> RedisFuture<T> |
RedisScriptingAsyncConnection.evalsha(String digest,
ScriptOutputType type,
K... keys)
Evaluates a script cached on the server side by its SHA1 digest
|
<T> RedisFuture<T> |
RedisAsyncConnectionImpl.evalsha(String digest,
ScriptOutputType type,
K... keys) |
<T> RedisFuture<T> |
RedisScriptingAsyncConnection.evalsha(String digest,
ScriptOutputType type,
K[] keys,
V... values)
Execute a Lua script server side.
|
<T> RedisFuture<T> |
RedisAsyncConnectionImpl.evalsha(String digest,
ScriptOutputType type,
K[] keys,
V... values) |
RedisFuture<List<Object>> |
RedisAsyncConnectionImpl.exec() |
RedisFuture<List<Object>> |
BaseRedisAsyncConnection.exec()
Execute all commands issued after MULTI.
|
RedisFuture<Long> |
RedisKeysAsyncConnection.exists(K... keys)
Determine how many keys exist.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.exists(K... keys) |
RedisFuture<Boolean> |
RedisKeysAsyncConnection.exists(K key)
Deprecated.
Use
RedisKeysAsyncConnection.exists(Object[]) instead |
RedisFuture<Boolean> |
RedisAsyncConnectionImpl.exists(K key) |
RedisFuture<Boolean> |
RedisKeysAsyncConnection.expire(K key,
long seconds)
Set a key's time to live in seconds.
|
RedisFuture<Boolean> |
RedisAsyncConnectionImpl.expire(K key,
long seconds) |
RedisFuture<Boolean> |
RedisKeysAsyncConnection.expireat(K key,
Date timestamp)
Set the expiration for a key as a UNIX timestamp.
|
RedisFuture<Boolean> |
RedisAsyncConnectionImpl.expireat(K key,
Date timestamp) |
RedisFuture<Boolean> |
RedisKeysAsyncConnection.expireat(K key,
long timestamp)
Set the expiration for a key as a UNIX timestamp.
|
RedisFuture<Boolean> |
RedisAsyncConnectionImpl.expireat(K key,
long timestamp) |
RedisFuture<String> |
RedisSentinelAsyncConnection.failover(K key)
Perform a failover.
|
RedisFuture<String> |
RedisServerAsyncConnection.flushall()
Remove all keys from all databases.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.flushall() |
RedisFuture<String> |
RedisServerAsyncConnection.flushallAsync()
Remove all keys asynchronously from all databases.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.flushallAsync() |
RedisFuture<String> |
RedisServerAsyncConnection.flushdb()
Remove all keys from the current database.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.flushdb() |
RedisFuture<String> |
RedisServerAsyncConnection.flushdbAsync()
Remove all keys asynchronously from the current database.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.flushdbAsync() |
RedisFuture<Long> |
RedisGeoAsyncConnection.geoadd(K key,
double longitude,
double latitude,
V member)
Single geo add.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.geoadd(K key,
double longitude,
double latitude,
V member) |
RedisFuture<Long> |
RedisGeoAsyncConnection.geoadd(K key,
Object... lngLatMember)
Multi geo add.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.geoadd(K key,
Object... lngLatMember) |
RedisFuture<Double> |
RedisGeoAsyncConnection.geodist(K key,
V from,
V to,
GeoArgs.Unit unit)
Retrieve distance between points
from and to . |
RedisFuture<Double> |
RedisAsyncConnectionImpl.geodist(K key,
V from,
V to,
GeoArgs.Unit unit) |
RedisFuture<List<String>> |
RedisGeoAsyncConnection.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.
|
RedisFuture<List<String>> |
RedisAsyncConnectionImpl.geohash(K key,
V... members) |
RedisFuture<List<GeoCoordinates>> |
RedisGeoAsyncConnection.geopos(K key,
V... members)
Get geo coordinates for the
members . |
RedisFuture<List<GeoCoordinates>> |
RedisAsyncConnectionImpl.geopos(K key,
V... members) |
RedisFuture<Set<V>> |
RedisGeoAsyncConnection.georadius(K key,
double longitude,
double latitude,
double distance,
GeoArgs.Unit unit)
Retrieve members selected by distance with the center of
longitude and latitude . |
RedisFuture<Set<V>> |
RedisAsyncConnectionImpl.georadius(K key,
double longitude,
double latitude,
double distance,
GeoArgs.Unit unit) |
RedisFuture<List<GeoWithin<V>>> |
RedisGeoAsyncConnection.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 . |
RedisFuture<List<GeoWithin<V>>> |
RedisAsyncConnectionImpl.georadius(K key,
double longitude,
double latitude,
double distance,
GeoArgs.Unit unit,
GeoArgs geoArgs) |
RedisFuture<Long> |
RedisGeoAsyncConnection.georadius(K key,
double longitude,
double latitude,
double distance,
GeoArgs.Unit unit,
GeoRadiusStoreArgs<K> geoRadiusStoreArgs)
Perform a
RedisGeoAsyncConnection.georadius(Object, double, double, double, GeoArgs.Unit, GeoArgs) query and store the results in a
sorted set. |
RedisFuture<Long> |
RedisAsyncConnectionImpl.georadius(K key,
double longitude,
double latitude,
double distance,
GeoArgs.Unit unit,
GeoRadiusStoreArgs<K> geoRadiusStoreArgs) |
RedisFuture<Set<V>> |
RedisGeoAsyncConnection.georadiusbymember(K key,
V member,
double distance,
GeoArgs.Unit unit)
Retrieve members selected by distance with the center of
member . |
RedisFuture<Set<V>> |
RedisAsyncConnectionImpl.georadiusbymember(K key,
V member,
double distance,
GeoArgs.Unit unit) |
RedisFuture<List<GeoWithin<V>>> |
RedisGeoAsyncConnection.georadiusbymember(K key,
V member,
double distance,
GeoArgs.Unit unit,
GeoArgs geoArgs)
Retrieve members selected by distance with the center of
member . |
RedisFuture<List<GeoWithin<V>>> |
RedisAsyncConnectionImpl.georadiusbymember(K key,
V member,
double distance,
GeoArgs.Unit unit,
GeoArgs geoArgs) |
RedisFuture<Long> |
RedisGeoAsyncConnection.georadiusbymember(K key,
V member,
double distance,
GeoArgs.Unit unit,
GeoRadiusStoreArgs<K> geoRadiusStoreArgs)
Perform a
RedisGeoAsyncConnection.georadiusbymember(Object, Object, double, GeoArgs.Unit, GeoArgs) query and store the results in a
sorted set. |
RedisFuture<Long> |
RedisAsyncConnectionImpl.georadiusbymember(K key,
V member,
double distance,
GeoArgs.Unit unit,
GeoRadiusStoreArgs<K> geoRadiusStoreArgs) |
RedisFuture<V> |
RedisStringsAsyncConnection.get(K key)
Get the value of a key.
|
RedisFuture<V> |
RedisAsyncConnectionImpl.get(K key) |
RedisFuture<Long> |
RedisStringsAsyncConnection.getbit(K key,
long offset)
Returns the bit value at offset in the string value stored at key.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.getbit(K key,
long offset) |
RedisFuture<V> |
RedisStringsAsyncConnection.getrange(K key,
long start,
long end)
Get a substring of the string stored at a key.
|
RedisFuture<V> |
RedisAsyncConnectionImpl.getrange(K key,
long start,
long end) |
RedisFuture<V> |
RedisStringsAsyncConnection.getset(K key,
V value)
Set the string value of a key and return its old value.
|
RedisFuture<V> |
RedisAsyncConnectionImpl.getset(K key,
V value) |
RedisFuture<Long> |
RedisHashesAsyncConnection.hdel(K key,
K... fields)
Delete one or more hash fields.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.hdel(K key,
K... fields) |
RedisFuture<Boolean> |
RedisHashesAsyncConnection.hexists(K key,
K field)
Determine if a hash field exists.
|
RedisFuture<Boolean> |
RedisAsyncConnectionImpl.hexists(K key,
K field) |
RedisFuture<V> |
RedisHashesAsyncConnection.hget(K key,
K field)
Get the value of a hash field.
|
RedisFuture<V> |
RedisAsyncConnectionImpl.hget(K key,
K field) |
RedisFuture<Map<K,V>> |
RedisHashesAsyncConnection.hgetall(K key)
Get all the fields and values in a hash.
|
RedisFuture<Map<K,V>> |
RedisAsyncConnectionImpl.hgetall(K key) |
RedisFuture<Long> |
RedisHashesAsyncConnection.hgetall(KeyValueStreamingChannel<K,V> channel,
K key)
Stream over all the fields and values in a hash.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.hgetall(KeyValueStreamingChannel<K,V> channel,
K key) |
RedisFuture<Long> |
RedisHashesAsyncConnection.hincrby(K key,
K field,
long amount)
Increment the integer value of a hash field by the given number.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.hincrby(K key,
K field,
long amount) |
RedisFuture<Double> |
RedisHashesAsyncConnection.hincrbyfloat(K key,
K field,
double amount)
Increment the float value of a hash field by the given amount.
|
RedisFuture<Double> |
RedisAsyncConnectionImpl.hincrbyfloat(K key,
K field,
double amount) |
RedisFuture<List<K>> |
RedisHashesAsyncConnection.hkeys(K key)
Get all the fields in a hash.
|
RedisFuture<List<K>> |
RedisAsyncConnectionImpl.hkeys(K key) |
RedisFuture<Long> |
RedisHashesAsyncConnection.hkeys(KeyStreamingChannel<K> channel,
K key)
Get all the fields in a hash.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.hkeys(KeyStreamingChannel<K> channel,
K key) |
RedisFuture<Long> |
RedisHashesAsyncConnection.hlen(K key)
Get the number of fields in a hash.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.hlen(K key) |
RedisFuture<List<V>> |
RedisHashesAsyncConnection.hmget(K key,
K... fields)
Get the values of all the given hash fields.
|
RedisFuture<List<V>> |
RedisAsyncConnectionImpl.hmget(K key,
K... fields) |
RedisFuture<Long> |
RedisHashesAsyncConnection.hmget(ValueStreamingChannel<V> channel,
K key,
K... fields)
Stream over the values of all the given hash fields.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.hmget(ValueStreamingChannel<V> channel,
K key,
K... fields) |
RedisFuture<String> |
RedisHashesAsyncConnection.hmset(K key,
Map<K,V> map)
Set multiple hash fields to multiple values.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.hmset(K key,
Map<K,V> map) |
RedisFuture<MapScanCursor<K,V>> |
RedisHashesAsyncConnection.hscan(K key)
Incrementally iterate hash fields and associated values.
|
RedisFuture<MapScanCursor<K,V>> |
RedisAsyncConnectionImpl.hscan(K key) |
RedisFuture<StreamScanCursor> |
RedisHashesAsyncConnection.hscan(KeyValueStreamingChannel<K,V> channel,
K key)
Incrementally iterate hash fields and associated values.
|
RedisFuture<StreamScanCursor> |
RedisAsyncConnectionImpl.hscan(KeyValueStreamingChannel<K,V> channel,
K key) |
RedisFuture<StreamScanCursor> |
RedisHashesAsyncConnection.hscan(KeyValueStreamingChannel<K,V> channel,
K key,
ScanArgs scanArgs)
Incrementally iterate hash fields and associated values.
|
RedisFuture<StreamScanCursor> |
RedisAsyncConnectionImpl.hscan(KeyValueStreamingChannel<K,V> channel,
K key,
ScanArgs scanArgs) |
RedisFuture<StreamScanCursor> |
RedisHashesAsyncConnection.hscan(KeyValueStreamingChannel<K,V> channel,
K key,
ScanCursor scanCursor)
Incrementally iterate hash fields and associated values.
|
RedisFuture<StreamScanCursor> |
RedisAsyncConnectionImpl.hscan(KeyValueStreamingChannel<K,V> channel,
K key,
ScanCursor scanCursor) |
RedisFuture<StreamScanCursor> |
RedisHashesAsyncConnection.hscan(KeyValueStreamingChannel<K,V> channel,
K key,
ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate hash fields and associated values.
|
RedisFuture<StreamScanCursor> |
RedisAsyncConnectionImpl.hscan(KeyValueStreamingChannel<K,V> channel,
K key,
ScanCursor scanCursor,
ScanArgs scanArgs) |
RedisFuture<MapScanCursor<K,V>> |
RedisHashesAsyncConnection.hscan(K key,
ScanArgs scanArgs)
Incrementally iterate hash fields and associated values.
|
RedisFuture<MapScanCursor<K,V>> |
RedisAsyncConnectionImpl.hscan(K key,
ScanArgs scanArgs) |
RedisFuture<MapScanCursor<K,V>> |
RedisHashesAsyncConnection.hscan(K key,
ScanCursor scanCursor)
Incrementally iterate hash fields and associated values.
|
RedisFuture<MapScanCursor<K,V>> |
RedisAsyncConnectionImpl.hscan(K key,
ScanCursor scanCursor) |
RedisFuture<MapScanCursor<K,V>> |
RedisHashesAsyncConnection.hscan(K key,
ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate hash fields and associated values.
|
RedisFuture<MapScanCursor<K,V>> |
RedisAsyncConnectionImpl.hscan(K key,
ScanCursor scanCursor,
ScanArgs scanArgs) |
RedisFuture<Boolean> |
RedisHashesAsyncConnection.hset(K key,
K field,
V value)
Set the string value of a hash field.
|
RedisFuture<Boolean> |
RedisAsyncConnectionImpl.hset(K key,
K field,
V value) |
RedisFuture<Boolean> |
RedisHashesAsyncConnection.hsetnx(K key,
K field,
V value)
Set the value of a hash field, only if the field does not exist.
|
RedisFuture<Boolean> |
RedisAsyncConnectionImpl.hsetnx(K key,
K field,
V value) |
RedisFuture<Long> |
RedisHashesAsyncConnection.hstrlen(K key,
K field)
Get the string length of the field value in a hash.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.hstrlen(K key,
K field) |
RedisFuture<List<V>> |
RedisHashesAsyncConnection.hvals(K key)
Get all the values in a hash.
|
RedisFuture<List<V>> |
RedisAsyncConnectionImpl.hvals(K key) |
RedisFuture<Long> |
RedisHashesAsyncConnection.hvals(ValueStreamingChannel<V> channel,
K key)
Stream over all the values in a hash.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.hvals(ValueStreamingChannel<V> channel,
K key) |
RedisFuture<Long> |
RedisStringsAsyncConnection.incr(K key)
Increment the integer value of a key by one.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.incr(K key) |
RedisFuture<Long> |
RedisStringsAsyncConnection.incrby(K key,
long amount)
Increment the integer value of a key by the given amount.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.incrby(K key,
long amount) |
RedisFuture<Double> |
RedisStringsAsyncConnection.incrbyfloat(K key,
double amount)
Increment the float value of a key by the given amount.
|
RedisFuture<Double> |
RedisAsyncConnectionImpl.incrbyfloat(K key,
double amount) |
RedisFuture<String> |
RedisServerAsyncConnection.info()
Get information and statistics about the server.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.info() |
RedisFuture<String> |
RedisServerAsyncConnection.info(String section)
Get information and statistics about the server.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.info(String section) |
RedisFuture<List<K>> |
RedisKeysAsyncConnection.keys(K pattern)
Find all keys matching the given pattern.
|
RedisFuture<List<K>> |
RedisAsyncConnectionImpl.keys(K pattern) |
RedisFuture<Long> |
RedisKeysAsyncConnection.keys(KeyStreamingChannel<K> channel,
K pattern)
Find all keys matching the given pattern.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.keys(KeyStreamingChannel<K> channel,
K pattern) |
RedisFuture<Date> |
RedisServerAsyncConnection.lastsave()
Get the UNIX time stamp of the last successful save to disk.
|
RedisFuture<Date> |
RedisAsyncConnectionImpl.lastsave() |
RedisFuture<V> |
RedisListsAsyncConnection.lindex(K key,
long index)
Get an element from a list by its index.
|
RedisFuture<V> |
RedisAsyncConnectionImpl.lindex(K key,
long index) |
RedisFuture<Long> |
RedisListsAsyncConnection.linsert(K key,
boolean before,
V pivot,
V value)
Insert an element before or after another element in a list.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.linsert(K key,
boolean before,
V pivot,
V value) |
RedisFuture<Long> |
RedisListsAsyncConnection.llen(K key)
Get the length of a list.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.llen(K key) |
RedisFuture<V> |
RedisListsAsyncConnection.lpop(K key)
Remove and get the first element in a list.
|
RedisFuture<V> |
RedisAsyncConnectionImpl.lpop(K key) |
RedisFuture<Long> |
RedisListsAsyncConnection.lpush(K key,
V... values)
Prepend one or multiple values to a list.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.lpush(K key,
V... values) |
RedisFuture<Long> |
RedisListsAsyncConnection.lpushx(K key,
V... values)
Prepend values to a list, only if the list exists.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.lpushx(K key,
V... values) |
RedisFuture<Long> |
RedisListsAsyncConnection.lpushx(K key,
V value)
Deprecated.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.lpushx(K key,
V value) |
RedisFuture<List<V>> |
RedisListsAsyncConnection.lrange(K key,
long start,
long stop)
Get a range of elements from a list.
|
RedisFuture<List<V>> |
RedisAsyncConnectionImpl.lrange(K key,
long start,
long stop) |
RedisFuture<Long> |
RedisListsAsyncConnection.lrange(ValueStreamingChannel<V> channel,
K key,
long start,
long stop)
Get a range of elements from a list.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.lrange(ValueStreamingChannel<V> channel,
K key,
long start,
long stop) |
RedisFuture<Long> |
RedisListsAsyncConnection.lrem(K key,
long count,
V value)
Remove elements from a list.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.lrem(K key,
long count,
V value) |
RedisFuture<String> |
RedisListsAsyncConnection.lset(K key,
long index,
V value)
Set the value of an element in a list by its index.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.lset(K key,
long index,
V value) |
RedisFuture<String> |
RedisListsAsyncConnection.ltrim(K key,
long start,
long stop)
Trim a list to the specified range.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.ltrim(K key,
long start,
long stop) |
RedisFuture<Map<K,V>> |
RedisSentinelAsyncConnection.master(K key)
Show the state and info of the specified master.
|
RedisFuture<List<Map<K,V>>> |
RedisSentinelAsyncConnection.masters()
Enumerates all the monitored masters and their states.
|
RedisFuture<List<V>> |
RedisStringsAsyncConnection.mget(K... keys)
Get the values of all the given keys.
|
RedisFuture<List<V>> |
RedisAsyncConnectionImpl.mget(K... keys) |
RedisFuture<Long> |
RedisStringsAsyncConnection.mget(ValueStreamingChannel<V> channel,
K... keys)
Stream the values of all the given keys.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.mget(ValueStreamingChannel<V> channel,
K... keys) |
RedisFuture<String> |
RedisKeysAsyncConnection.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.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.migrate(String host,
int port,
int db,
long timeout,
MigrateArgs<K> migrateArgs) |
RedisFuture<String> |
RedisKeysAsyncConnection.migrate(String host,
int port,
K key,
int db,
long timeout)
Atomically transfer a key from a Redis instance to another one.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.migrate(String host,
int port,
K key,
int db,
long timeout) |
RedisFuture<String> |
RedisSentinelAsyncConnection.monitor(K key,
String ip,
int port,
int quorum)
This command tells the Sentinel to start monitoring a new master with the specified name, ip, port, and quorum.
|
RedisFuture<Boolean> |
RedisKeysAsyncConnection.move(K key,
int db)
Move a key to another database.
|
RedisFuture<Boolean> |
RedisAsyncConnectionImpl.move(K key,
int db) |
RedisFuture<String> |
RedisStringsAsyncConnection.mset(Map<K,V> map)
Set multiple keys to multiple values.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.mset(Map<K,V> map) |
RedisFuture<Boolean> |
RedisStringsAsyncConnection.msetnx(Map<K,V> map)
Set multiple keys to multiple values, only if none of the keys exist.
|
RedisFuture<Boolean> |
RedisAsyncConnectionImpl.msetnx(Map<K,V> map) |
RedisFuture<String> |
RedisAsyncConnectionImpl.multi() |
RedisFuture<String> |
BaseRedisAsyncConnection.multi()
Mark the start of a transaction block.
|
RedisFuture<String> |
RedisKeysAsyncConnection.objectEncoding(K key)
returns the kind of internal representation used in order to store the value associated with a key.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.objectEncoding(K key) |
RedisFuture<Long> |
RedisKeysAsyncConnection.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).
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.objectIdletime(K key) |
RedisFuture<Long> |
RedisKeysAsyncConnection.objectRefcount(K key)
returns the number of references of the value associated with the specified key.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.objectRefcount(K key) |
RedisFuture<Boolean> |
RedisKeysAsyncConnection.persist(K key)
Remove the expiration from a key.
|
RedisFuture<Boolean> |
RedisAsyncConnectionImpl.persist(K key) |
RedisFuture<Boolean> |
RedisKeysAsyncConnection.pexpire(K key,
long milliseconds)
Set a key's time to live in milliseconds.
|
RedisFuture<Boolean> |
RedisAsyncConnectionImpl.pexpire(K key,
long milliseconds) |
RedisFuture<Boolean> |
RedisKeysAsyncConnection.pexpireat(K key,
Date timestamp)
Set the expiration for a key as a UNIX timestamp specified in milliseconds.
|
RedisFuture<Boolean> |
RedisAsyncConnectionImpl.pexpireat(K key,
Date timestamp) |
RedisFuture<Boolean> |
RedisKeysAsyncConnection.pexpireat(K key,
long timestamp)
Set the expiration for a key as a UNIX timestamp specified in milliseconds.
|
RedisFuture<Boolean> |
RedisAsyncConnectionImpl.pexpireat(K key,
long timestamp) |
RedisFuture<Long> |
RedisHLLAsyncConnection.pfadd(K key,
V value,
V... moreValues)
Adds the specified elements to the specified HyperLogLog.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.pfadd(K key,
V value,
V... moreValues) |
RedisFuture<Long> |
RedisHLLAsyncConnection.pfcount(K key,
K... moreKeys)
Return the approximated cardinality of the set(s) observed by the HyperLogLog at key(s).
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.pfcount(K key,
K... moreKeys) |
RedisFuture<String> |
RedisHLLAsyncConnection.pfmerge(K destkey,
K sourcekey,
K... moreSourceKeys)
Merge N different HyperLogLogs into a single one.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.pfmerge(K destkey,
K sourcekey,
K... moreSourceKeys) |
RedisFuture<String> |
RedisSentinelAsyncConnection.ping()
Ping the server.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.ping() |
RedisFuture<String> |
BaseRedisAsyncConnection.ping()
Ping the server.
|
RedisFuture<String> |
RedisStringsAsyncConnection.psetex(K key,
long milliseconds,
V value)
Set the value and expiration in milliseconds of a key.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.psetex(K key,
long milliseconds,
V value) |
RedisFuture<Long> |
RedisKeysAsyncConnection.pttl(K key)
Get the time to live for a key in milliseconds.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.pttl(K key) |
RedisFuture<Long> |
RedisAsyncConnectionImpl.publish(K channel,
V message) |
RedisFuture<Long> |
BaseRedisAsyncConnection.publish(K channel,
V message)
Post a message to a channel.
|
RedisFuture<List<K>> |
RedisAsyncConnectionImpl.pubsubChannels() |
RedisFuture<List<K>> |
BaseRedisAsyncConnection.pubsubChannels()
Lists the currently *active channels*.
|
RedisFuture<List<K>> |
RedisAsyncConnectionImpl.pubsubChannels(K channel) |
RedisFuture<List<K>> |
BaseRedisAsyncConnection.pubsubChannels(K channel)
Lists the currently *active channels*.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.pubsubNumpat() |
RedisFuture<Long> |
BaseRedisAsyncConnection.pubsubNumpat()
Returns the number of subscriptions to patterns.
|
RedisFuture<Map<K,Long>> |
RedisAsyncConnectionImpl.pubsubNumsub(K... channels) |
RedisFuture<Map<K,Long>> |
BaseRedisAsyncConnection.pubsubNumsub(K... channels)
Returns the number of subscribers (not counting clients subscribed to patterns) for the specified channels.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.quit() |
RedisFuture<String> |
BaseRedisAsyncConnection.quit()
Close the connection.
|
RedisFuture<V> |
RedisKeysAsyncConnection.randomkey()
Return a random key from the keyspace.
|
RedisFuture<V> |
RedisAsyncConnectionImpl.randomkey() |
RedisFuture<String> |
RedisSentinelAsyncConnection.remove(K key)
remove the specified master.
|
RedisFuture<String> |
RedisKeysAsyncConnection.rename(K key,
K newKey)
Rename a key.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.rename(K key,
K newKey) |
RedisFuture<Boolean> |
RedisKeysAsyncConnection.renamenx(K key,
K newKey)
Rename a key, only if the new key does not exist.
|
RedisFuture<Boolean> |
RedisAsyncConnectionImpl.renamenx(K key,
K newKey) |
RedisFuture<Long> |
RedisSentinelAsyncConnection.reset(K key)
This command will reset all the masters with matching name.
|
RedisFuture<String> |
RedisKeysAsyncConnection.restore(K key,
long ttl,
byte[] value)
Create a key using the provided serialized value, previously obtained using DUMP.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.restore(K key,
long ttl,
byte[] value) |
RedisFuture<List<Object>> |
RedisAsyncConnectionImpl.role() |
RedisFuture<List<Object>> |
BaseRedisAsyncConnection.role()
Return the role of the instance in the context of replication.
|
RedisFuture<V> |
RedisListsAsyncConnection.rpop(K key)
Remove and get the last element in a list.
|
RedisFuture<V> |
RedisAsyncConnectionImpl.rpop(K key) |
RedisFuture<V> |
RedisListsAsyncConnection.rpoplpush(K source,
K destination)
Remove the last element in a list, append it to another list and return it.
|
RedisFuture<V> |
RedisAsyncConnectionImpl.rpoplpush(K source,
K destination) |
RedisFuture<Long> |
RedisListsAsyncConnection.rpush(K key,
V... values)
Append one or multiple values to a list.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.rpush(K key,
V... values) |
RedisFuture<Long> |
RedisListsAsyncConnection.rpushx(K key,
V... values)
Append values to a list, only if the list exists.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.rpushx(K key,
V... values) |
RedisFuture<Long> |
RedisListsAsyncConnection.rpushx(K key,
V value)
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.rpushx(K key,
V value) |
RedisFuture<Long> |
RedisSetsAsyncConnection.sadd(K key,
V... members)
Add one or more members to a set.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.sadd(K key,
V... members) |
RedisFuture<String> |
RedisServerAsyncConnection.save()
Synchronously save the dataset to disk.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.save() |
RedisFuture<KeyScanCursor<K>> |
RedisKeysAsyncConnection.scan()
Incrementally iterate the keys space.
|
RedisFuture<KeyScanCursor<K>> |
RedisAsyncConnectionImpl.scan() |
RedisFuture<StreamScanCursor> |
RedisKeysAsyncConnection.scan(KeyStreamingChannel<K> channel)
Incrementally iterate the keys space.
|
RedisFuture<StreamScanCursor> |
RedisAsyncConnectionImpl.scan(KeyStreamingChannel<K> channel) |
RedisFuture<StreamScanCursor> |
RedisKeysAsyncConnection.scan(KeyStreamingChannel<K> channel,
ScanArgs scanArgs)
Incrementally iterate the keys space.
|
RedisFuture<StreamScanCursor> |
RedisAsyncConnectionImpl.scan(KeyStreamingChannel<K> channel,
ScanArgs scanArgs) |
RedisFuture<StreamScanCursor> |
RedisKeysAsyncConnection.scan(KeyStreamingChannel<K> channel,
ScanCursor scanCursor)
Incrementally iterate the keys space.
|
RedisFuture<StreamScanCursor> |
RedisAsyncConnectionImpl.scan(KeyStreamingChannel<K> channel,
ScanCursor scanCursor) |
RedisFuture<StreamScanCursor> |
RedisKeysAsyncConnection.scan(KeyStreamingChannel<K> channel,
ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate the keys space.
|
RedisFuture<StreamScanCursor> |
RedisAsyncConnectionImpl.scan(KeyStreamingChannel<K> channel,
ScanCursor scanCursor,
ScanArgs scanArgs) |
RedisFuture<KeyScanCursor<K>> |
RedisKeysAsyncConnection.scan(ScanArgs scanArgs)
Incrementally iterate the keys space.
|
RedisFuture<KeyScanCursor<K>> |
RedisAsyncConnectionImpl.scan(ScanArgs scanArgs) |
RedisFuture<KeyScanCursor<K>> |
RedisKeysAsyncConnection.scan(ScanCursor scanCursor)
Incrementally iterate the keys space.
|
RedisFuture<KeyScanCursor<K>> |
RedisAsyncConnectionImpl.scan(ScanCursor scanCursor) |
RedisFuture<KeyScanCursor<K>> |
RedisKeysAsyncConnection.scan(ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate the keys space.
|
RedisFuture<KeyScanCursor<K>> |
RedisAsyncConnectionImpl.scan(ScanCursor scanCursor,
ScanArgs scanArgs) |
RedisFuture<Long> |
RedisSetsAsyncConnection.scard(K key)
Get the number of members in a set.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.scard(K key) |
RedisFuture<List<Boolean>> |
RedisScriptingAsyncConnection.scriptExists(String... digests)
Check existence of scripts in the script cache.
|
RedisFuture<List<Boolean>> |
RedisAsyncConnectionImpl.scriptExists(String... digests) |
RedisFuture<String> |
RedisScriptingAsyncConnection.scriptFlush()
Remove all the scripts from the script cache.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.scriptFlush() |
RedisFuture<String> |
RedisScriptingAsyncConnection.scriptKill()
Kill the script currently in execution.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.scriptKill() |
RedisFuture<String> |
RedisScriptingAsyncConnection.scriptLoad(V script)
Load the specified Lua script into the script cache.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.scriptLoad(V script) |
RedisFuture<Set<V>> |
RedisSetsAsyncConnection.sdiff(K... keys)
Subtract multiple sets.
|
RedisFuture<Set<V>> |
RedisAsyncConnectionImpl.sdiff(K... keys) |
RedisFuture<Long> |
RedisSetsAsyncConnection.sdiff(ValueStreamingChannel<V> channel,
K... keys)
Subtract multiple sets.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.sdiff(ValueStreamingChannel<V> channel,
K... keys) |
RedisFuture<Long> |
RedisSetsAsyncConnection.sdiffstore(K destination,
K... keys)
Subtract multiple sets and store the resulting set in a key.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.sdiffstore(K destination,
K... keys) |
RedisFuture<String> |
RedisSentinelAsyncConnection.set(K key,
String option,
V value)
Multiple option / value pairs can be specified (or none at all).
|
RedisFuture<String> |
RedisStringsAsyncConnection.set(K key,
V value)
Set the string value of a key.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.set(K key,
V value) |
RedisFuture<String> |
RedisStringsAsyncConnection.set(K key,
V value,
SetArgs setArgs)
Set the string value of a key.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.set(K key,
V value,
SetArgs setArgs) |
RedisFuture<Long> |
RedisStringsAsyncConnection.setbit(K key,
long offset,
int value)
Sets or clears the bit at offset in the string value stored at key.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.setbit(K key,
long offset,
int value) |
RedisFuture<String> |
RedisStringsAsyncConnection.setex(K key,
long seconds,
V value)
Set the value and expiration of a key.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.setex(K key,
long seconds,
V value) |
RedisFuture<Boolean> |
RedisStringsAsyncConnection.setnx(K key,
V value)
Set the value of a key, only if the key does not exist.
|
RedisFuture<Boolean> |
RedisAsyncConnectionImpl.setnx(K key,
V value) |
RedisFuture<Long> |
RedisStringsAsyncConnection.setrange(K key,
long offset,
V value)
Overwrite part of a string at key starting at the specified offset.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.setrange(K key,
long offset,
V value) |
RedisFuture<Set<V>> |
RedisSetsAsyncConnection.sinter(K... keys)
Intersect multiple sets.
|
RedisFuture<Set<V>> |
RedisAsyncConnectionImpl.sinter(K... keys) |
RedisFuture<Long> |
RedisSetsAsyncConnection.sinter(ValueStreamingChannel<V> channel,
K... keys)
Intersect multiple sets.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.sinter(ValueStreamingChannel<V> channel,
K... keys) |
RedisFuture<Long> |
RedisSetsAsyncConnection.sinterstore(K destination,
K... keys)
Intersect multiple sets and store the resulting set in a key.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.sinterstore(K destination,
K... keys) |
RedisFuture<Boolean> |
RedisSetsAsyncConnection.sismember(K key,
V member)
Determine if a given value is a member of a set.
|
RedisFuture<Boolean> |
RedisAsyncConnectionImpl.sismember(K key,
V member) |
RedisFuture<String> |
RedisServerAsyncConnection.slaveof(String host,
int port)
Make the server a slave of another instance.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.slaveof(String host,
int port) |
RedisFuture<String> |
RedisServerAsyncConnection.slaveofNoOne()
Promote server as master.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.slaveofNoOne() |
RedisFuture<List<Map<K,V>>> |
RedisSentinelAsyncConnection.slaves(K key)
Provides a list of slaves for the master with the specified name.
|
RedisFuture<List<Object>> |
RedisServerAsyncConnection.slowlogGet()
Read the slow log.
|
RedisFuture<List<Object>> |
RedisAsyncConnectionImpl.slowlogGet() |
RedisFuture<List<Object>> |
RedisServerAsyncConnection.slowlogGet(int count)
Read the slow log.
|
RedisFuture<List<Object>> |
RedisAsyncConnectionImpl.slowlogGet(int count) |
RedisFuture<Long> |
RedisServerAsyncConnection.slowlogLen()
Obtaining the current length of the slow log.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.slowlogLen() |
RedisFuture<String> |
RedisServerAsyncConnection.slowlogReset()
Resetting the slow log.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.slowlogReset() |
RedisFuture<Set<V>> |
RedisSetsAsyncConnection.smembers(K key)
Get all the members in a set.
|
RedisFuture<Set<V>> |
RedisAsyncConnectionImpl.smembers(K key) |
RedisFuture<Long> |
RedisSetsAsyncConnection.smembers(ValueStreamingChannel<V> channel,
K key)
Get all the members in a set.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.smembers(ValueStreamingChannel<V> channel,
K key) |
RedisFuture<Boolean> |
RedisSetsAsyncConnection.smove(K source,
K destination,
V member)
Move a member from one set to another.
|
RedisFuture<Boolean> |
RedisAsyncConnectionImpl.smove(K source,
K destination,
V member) |
RedisFuture<List<V>> |
RedisKeysAsyncConnection.sort(K key)
Sort the elements in a list, set or sorted set.
|
RedisFuture<List<V>> |
RedisAsyncConnectionImpl.sort(K key) |
RedisFuture<List<V>> |
RedisKeysAsyncConnection.sort(K key,
SortArgs sortArgs)
Sort the elements in a list, set or sorted set.
|
RedisFuture<List<V>> |
RedisAsyncConnectionImpl.sort(K key,
SortArgs sortArgs) |
RedisFuture<Long> |
RedisKeysAsyncConnection.sort(ValueStreamingChannel<V> channel,
K key)
Sort the elements in a list, set or sorted set.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.sort(ValueStreamingChannel<V> channel,
K key) |
RedisFuture<Long> |
RedisKeysAsyncConnection.sort(ValueStreamingChannel<V> channel,
K key,
SortArgs sortArgs)
Sort the elements in a list, set or sorted set.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.sort(ValueStreamingChannel<V> channel,
K key,
SortArgs sortArgs) |
RedisFuture<Long> |
RedisKeysAsyncConnection.sortStore(K key,
SortArgs sortArgs,
K destination)
Sort the elements in a list, set or sorted set.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.sortStore(K key,
SortArgs sortArgs,
K destination) |
RedisFuture<V> |
RedisSetsAsyncConnection.spop(K key)
Remove and return a random member from a set.
|
RedisFuture<V> |
RedisAsyncConnectionImpl.spop(K key) |
RedisFuture<Set<V>> |
RedisSetsAsyncConnection.spop(K key,
long count)
Remove and return one or multiple random members from a set.
|
RedisFuture<Set<V>> |
RedisAsyncConnectionImpl.spop(K key,
long count) |
RedisFuture<V> |
RedisSetsAsyncConnection.srandmember(K key)
Get one or multiple random members from a set.
|
RedisFuture<V> |
RedisAsyncConnectionImpl.srandmember(K key) |
RedisFuture<Set<V>> |
RedisSetsAsyncConnection.srandmember(K key,
long count)
Get one or multiple random members from a set.
|
RedisFuture<Set<V>> |
RedisAsyncConnectionImpl.srandmember(K key,
long count) |
RedisFuture<Long> |
RedisSetsAsyncConnection.srandmember(ValueStreamingChannel<V> channel,
K key,
long count)
Get one or multiple random members from a set.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.srandmember(ValueStreamingChannel<V> channel,
K key,
long count) |
RedisFuture<Long> |
RedisSetsAsyncConnection.srem(K key,
V... members)
Remove one or more members from a set.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.srem(K key,
V... members) |
RedisFuture<ValueScanCursor<V>> |
RedisSetsAsyncConnection.sscan(K key)
Incrementally iterate Set elements.
|
RedisFuture<ValueScanCursor<V>> |
RedisAsyncConnectionImpl.sscan(K key) |
RedisFuture<ValueScanCursor<V>> |
RedisSetsAsyncConnection.sscan(K key,
ScanArgs scanArgs)
Incrementally iterate Set elements.
|
RedisFuture<ValueScanCursor<V>> |
RedisAsyncConnectionImpl.sscan(K key,
ScanArgs scanArgs) |
RedisFuture<ValueScanCursor<V>> |
RedisSetsAsyncConnection.sscan(K key,
ScanCursor scanCursor)
Incrementally iterate Set elements.
|
RedisFuture<ValueScanCursor<V>> |
RedisAsyncConnectionImpl.sscan(K key,
ScanCursor scanCursor) |
RedisFuture<ValueScanCursor<V>> |
RedisSetsAsyncConnection.sscan(K key,
ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate Set elements.
|
RedisFuture<ValueScanCursor<V>> |
RedisAsyncConnectionImpl.sscan(K key,
ScanCursor scanCursor,
ScanArgs scanArgs) |
RedisFuture<StreamScanCursor> |
RedisSetsAsyncConnection.sscan(ValueStreamingChannel<V> channel,
K key)
Incrementally iterate Set elements.
|
RedisFuture<StreamScanCursor> |
RedisAsyncConnectionImpl.sscan(ValueStreamingChannel<V> channel,
K key) |
RedisFuture<StreamScanCursor> |
RedisSetsAsyncConnection.sscan(ValueStreamingChannel<V> channel,
K key,
ScanArgs scanArgs)
Incrementally iterate Set elements.
|
RedisFuture<StreamScanCursor> |
RedisAsyncConnectionImpl.sscan(ValueStreamingChannel<V> channel,
K key,
ScanArgs scanArgs) |
RedisFuture<StreamScanCursor> |
RedisSetsAsyncConnection.sscan(ValueStreamingChannel<V> channel,
K key,
ScanCursor scanCursor)
Incrementally iterate Set elements.
|
RedisFuture<StreamScanCursor> |
RedisAsyncConnectionImpl.sscan(ValueStreamingChannel<V> channel,
K key,
ScanCursor scanCursor) |
RedisFuture<StreamScanCursor> |
RedisSetsAsyncConnection.sscan(ValueStreamingChannel<V> channel,
K key,
ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate Set elements.
|
RedisFuture<StreamScanCursor> |
RedisAsyncConnectionImpl.sscan(ValueStreamingChannel<V> channel,
K key,
ScanCursor scanCursor,
ScanArgs scanArgs) |
RedisFuture<Long> |
RedisStringsAsyncConnection.strlen(K key)
Get the length of the value stored in a key.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.strlen(K key) |
RedisFuture<Set<V>> |
RedisSetsAsyncConnection.sunion(K... keys)
Add multiple sets.
|
RedisFuture<Set<V>> |
RedisAsyncConnectionImpl.sunion(K... keys) |
RedisFuture<Long> |
RedisSetsAsyncConnection.sunion(ValueStreamingChannel<V> channel,
K... keys)
Add multiple sets.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.sunion(ValueStreamingChannel<V> channel,
K... keys) |
RedisFuture<Long> |
RedisSetsAsyncConnection.sunionstore(K destination,
K... keys)
Add multiple sets and store the resulting set in a key.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.sunionstore(K destination,
K... keys) |
RedisFuture<String> |
RedisServerAsyncConnection.sync()
Internal command used for replication.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.sync() |
RedisFuture<List<V>> |
RedisServerAsyncConnection.time()
Return the current server time.
|
RedisFuture<List<V>> |
RedisAsyncConnectionImpl.time() |
RedisFuture<Long> |
RedisKeysAsyncConnection.touch(K... keys)
Touch one or more keys.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.touch(K... keys) |
RedisFuture<Long> |
RedisKeysAsyncConnection.ttl(K key)
Get the time to live for a key.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.ttl(K key) |
RedisFuture<String> |
RedisKeysAsyncConnection.type(K key)
Determine the type stored at key.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.type(K key) |
RedisFuture<Long> |
RedisKeysAsyncConnection.unlink(K... keys)
Unlink one or more keys (non blocking DEL).
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.unlink(K... keys) |
RedisFuture<String> |
RedisAsyncConnectionImpl.unwatch() |
RedisFuture<String> |
BaseRedisAsyncConnection.unwatch()
Forget about all watched keys.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.waitForReplication(int replicas,
long timeout) |
RedisFuture<Long> |
BaseRedisAsyncConnection.waitForReplication(int replicas,
long timeout)
Wait for replication.
|
RedisFuture<String> |
RedisAsyncConnectionImpl.watch(K... keys) |
RedisFuture<String> |
BaseRedisAsyncConnection.watch(K... keys)
Watch the given keys to determine execution of the MULTI/EXEC block.
|
RedisFuture<Long> |
RedisSortedSetsAsyncConnection.zadd(K key,
double score,
V member)
Add one or more members to a sorted set, or update its score if it already exists.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.zadd(K key,
double score,
V member) |
RedisFuture<Long> |
RedisSortedSetsAsyncConnection.zadd(K key,
Object... scoresAndValues)
Add one or more members to a sorted set, or update its score if it already exists.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.zadd(K key,
Object... scoresAndValues) |
RedisFuture<Long> |
RedisSortedSetsAsyncConnection.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.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.zadd(K key,
ZAddArgs zAddArgs,
double score,
V member) |
RedisFuture<Long> |
RedisSortedSetsAsyncConnection.zadd(K key,
ZAddArgs zAddArgs,
Object... scoresAndValues)
Add one or more members to a sorted set, or update its score if it already exists.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.zadd(K key,
ZAddArgs zAddArgs,
Object... scoresAndValues) |
RedisFuture<Double> |
RedisSortedSetsAsyncConnection.zaddincr(K key,
double score,
V member)
ZADD acts like ZINCRBY
|
RedisFuture<Double> |
RedisAsyncConnectionImpl.zaddincr(K key,
double score,
V member) |
RedisFuture<Long> |
RedisSortedSetsAsyncConnection.zcard(K key)
Get the number of members in a sorted set.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.zcard(K key) |
RedisFuture<Long> |
RedisSortedSetsAsyncConnection.zcount(K key,
double min,
double max)
Count the members in a sorted set with scores within the given values.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.zcount(K key,
double min,
double max) |
RedisFuture<Long> |
RedisSortedSetsAsyncConnection.zcount(K key,
String min,
String max)
Count the members in a sorted set with scores within the given values.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.zcount(K key,
String min,
String max) |
RedisFuture<Double> |
RedisSortedSetsAsyncConnection.zincrby(K key,
double amount,
K member)
Increment the score of a member in a sorted set.
|
RedisFuture<Double> |
RedisAsyncConnectionImpl.zincrby(K key,
double amount,
K member) |
RedisFuture<Long> |
RedisSortedSetsAsyncConnection.zinterstore(K destination,
K... keys)
Intersect multiple sorted sets and store the resulting sorted set in a new key.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.zinterstore(K destination,
K... keys) |
RedisFuture<Long> |
RedisSortedSetsAsyncConnection.zinterstore(K destination,
ZStoreArgs storeArgs,
K... keys)
Intersect multiple sorted sets and store the resulting sorted set in a new key.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.zinterstore(K destination,
ZStoreArgs storeArgs,
K... keys) |
RedisFuture<Long> |
RedisSortedSetsAsyncConnection.zlexcount(K key,
String min,
String max)
Count the number of members in a sorted set between a given lexicographical range.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.zlexcount(K key,
String min,
String max) |
RedisFuture<List<V>> |
RedisSortedSetsAsyncConnection.zrange(K key,
long start,
long stop)
Return a range of members in a sorted set, by index.
|
RedisFuture<List<V>> |
RedisAsyncConnectionImpl.zrange(K key,
long start,
long stop) |
RedisFuture<Long> |
RedisSortedSetsAsyncConnection.zrange(ValueStreamingChannel<V> channel,
K key,
long start,
long stop)
Stream over a range of members in a sorted set, by index.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.zrange(ValueStreamingChannel<V> channel,
K key,
long start,
long stop) |
RedisFuture<List<V>> |
RedisSortedSetsAsyncConnection.zrangebylex(K key,
String min,
String max)
Return a range of members in a sorted set, by lexicographical range.
|
RedisFuture<List<V>> |
RedisAsyncConnectionImpl.zrangebylex(K key,
String min,
String max) |
RedisFuture<List<V>> |
RedisSortedSetsAsyncConnection.zrangebylex(K key,
String min,
String max,
long offset,
long count)
Return a range of members in a sorted set, by lexicographical range.
|
RedisFuture<List<V>> |
RedisAsyncConnectionImpl.zrangebylex(K key,
String min,
String max,
long offset,
long count) |
RedisFuture<List<V>> |
RedisSortedSetsAsyncConnection.zrangebyscore(K key,
double min,
double max)
Return a range of members in a sorted set, by score.
|
RedisFuture<List<V>> |
RedisAsyncConnectionImpl.zrangebyscore(K key,
double min,
double max) |
RedisFuture<List<V>> |
RedisSortedSetsAsyncConnection.zrangebyscore(K key,
double min,
double max,
long offset,
long count)
Return a range of members in a sorted set, by score.
|
RedisFuture<List<V>> |
RedisAsyncConnectionImpl.zrangebyscore(K key,
double min,
double max,
long offset,
long count) |
RedisFuture<List<V>> |
RedisSortedSetsAsyncConnection.zrangebyscore(K key,
String min,
String max)
Return a range of members in a sorted set, by score.
|
RedisFuture<List<V>> |
RedisAsyncConnectionImpl.zrangebyscore(K key,
String min,
String max) |
RedisFuture<List<V>> |
RedisSortedSetsAsyncConnection.zrangebyscore(K key,
String min,
String max,
long offset,
long count)
Return a range of members in a sorted set, by score.
|
RedisFuture<List<V>> |
RedisAsyncConnectionImpl.zrangebyscore(K key,
String min,
String max,
long offset,
long count) |
RedisFuture<Long> |
RedisSortedSetsAsyncConnection.zrangebyscore(ValueStreamingChannel<V> channel,
K key,
double min,
double max)
Stream over a range of members in a sorted set, by score.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.zrangebyscore(ValueStreamingChannel<V> channel,
K key,
double min,
double max) |
RedisFuture<Long> |
RedisSortedSetsAsyncConnection.zrangebyscore(ValueStreamingChannel<V> channel,
K key,
double min,
double max,
long offset,
long count)
Stream over a range of members in a sorted set, by score.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.zrangebyscore(ValueStreamingChannel<V> channel,
K key,
double min,
double max,
long offset,
long count) |
RedisFuture<Long> |
RedisSortedSetsAsyncConnection.zrangebyscore(ValueStreamingChannel<V> channel,
K key,
String min,
String max)
Stream over a range of members in a sorted set, by score.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.zrangebyscore(ValueStreamingChannel<V> channel,
K key,
String min,
String max) |
RedisFuture<Long> |
RedisSortedSetsAsyncConnection.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.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.zrangebyscore(ValueStreamingChannel<V> channel,
K key,
String min,
String max,
long offset,
long count) |
RedisFuture<List<ScoredValue<V>>> |
RedisSortedSetsAsyncConnection.zrangebyscoreWithScores(K key,
double min,
double max)
Return a range of members with score in a sorted set, by score.
|
RedisFuture<List<ScoredValue<V>>> |
RedisAsyncConnectionImpl.zrangebyscoreWithScores(K key,
double min,
double max) |
RedisFuture<List<ScoredValue<V>>> |
RedisSortedSetsAsyncConnection.zrangebyscoreWithScores(K key,
double min,
double max,
long offset,
long count)
Return a range of members with score in a sorted set, by score.
|
RedisFuture<List<ScoredValue<V>>> |
RedisAsyncConnectionImpl.zrangebyscoreWithScores(K key,
double min,
double max,
long offset,
long count) |
RedisFuture<List<ScoredValue<V>>> |
RedisSortedSetsAsyncConnection.zrangebyscoreWithScores(K key,
String min,
String max)
Return a range of members with score in a sorted set, by score.
|
RedisFuture<List<ScoredValue<V>>> |
RedisAsyncConnectionImpl.zrangebyscoreWithScores(K key,
String min,
String max) |
RedisFuture<List<ScoredValue<V>>> |
RedisSortedSetsAsyncConnection.zrangebyscoreWithScores(K key,
String min,
String max,
long offset,
long count)
Return a range of members with score in a sorted set, by score.
|
RedisFuture<List<ScoredValue<V>>> |
RedisAsyncConnectionImpl.zrangebyscoreWithScores(K key,
String min,
String max,
long offset,
long count) |
RedisFuture<Long> |
RedisSortedSetsAsyncConnection.zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
double min,
double max)
Stream over a range of members with scores in a sorted set, by score.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
double min,
double max) |
RedisFuture<Long> |
RedisSortedSetsAsyncConnection.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.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
double min,
double max,
long offset,
long count) |
RedisFuture<Long> |
RedisSortedSetsAsyncConnection.zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
String min,
String max)
Stream over a range of members with scores in a sorted set, by score.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
String min,
String max) |
RedisFuture<Long> |
RedisSortedSetsAsyncConnection.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.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
String min,
String max,
long offset,
long count) |
RedisFuture<List<ScoredValue<V>>> |
RedisSortedSetsAsyncConnection.zrangeWithScores(K key,
long start,
long stop)
Return a range of members in a sorted set, by index.
|
RedisFuture<List<ScoredValue<V>>> |
RedisAsyncConnectionImpl.zrangeWithScores(K key,
long start,
long stop) |
RedisFuture<Long> |
RedisSortedSetsAsyncConnection.zrangeWithScores(ScoredValueStreamingChannel<V> channel,
K key,
long start,
long stop)
Stream over a range of members with scores in a sorted set, by index.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.zrangeWithScores(ScoredValueStreamingChannel<V> channel,
K key,
long start,
long stop) |
RedisFuture<Long> |
RedisSortedSetsAsyncConnection.zrank(K key,
V member)
Determine the index of a member in a sorted set.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.zrank(K key,
V member) |
RedisFuture<Long> |
RedisSortedSetsAsyncConnection.zrem(K key,
V... members)
Remove one or more members from a sorted set.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.zrem(K key,
V... members) |
RedisFuture<Long> |
RedisSortedSetsAsyncConnection.zremrangebylex(K key,
String min,
String max)
Remove all members in a sorted set between the given lexicographical range.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.zremrangebylex(K key,
String min,
String max) |
RedisFuture<Long> |
RedisSortedSetsAsyncConnection.zremrangebyrank(K key,
long start,
long stop)
Remove all members in a sorted set within the given indexes.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.zremrangebyrank(K key,
long start,
long stop) |
RedisFuture<Long> |
RedisSortedSetsAsyncConnection.zremrangebyscore(K key,
double min,
double max)
Remove all members in a sorted set within the given scores.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.zremrangebyscore(K key,
double min,
double max) |
RedisFuture<Long> |
RedisSortedSetsAsyncConnection.zremrangebyscore(K key,
String min,
String max)
Remove all members in a sorted set within the given scores.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.zremrangebyscore(K key,
String min,
String max) |
RedisFuture<List<V>> |
RedisSortedSetsAsyncConnection.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.
|
RedisFuture<List<V>> |
RedisAsyncConnectionImpl.zrevrange(K key,
long start,
long stop) |
RedisFuture<Long> |
RedisSortedSetsAsyncConnection.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.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.zrevrange(ValueStreamingChannel<V> channel,
K key,
long start,
long stop) |
RedisFuture<List<V>> |
RedisSortedSetsAsyncConnection.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.
|
RedisFuture<List<V>> |
RedisAsyncConnectionImpl.zrevrangebyscore(K key,
double max,
double min) |
RedisFuture<List<V>> |
RedisSortedSetsAsyncConnection.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.
|
RedisFuture<List<V>> |
RedisAsyncConnectionImpl.zrevrangebyscore(K key,
double max,
double min,
long offset,
long count) |
RedisFuture<List<V>> |
RedisSortedSetsAsyncConnection.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.
|
RedisFuture<List<V>> |
RedisAsyncConnectionImpl.zrevrangebyscore(K key,
String max,
String min) |
RedisFuture<List<V>> |
RedisSortedSetsAsyncConnection.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.
|
RedisFuture<List<V>> |
RedisAsyncConnectionImpl.zrevrangebyscore(K key,
String max,
String min,
long offset,
long count) |
RedisFuture<Long> |
RedisSortedSetsAsyncConnection.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.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.zrevrangebyscore(ValueStreamingChannel<V> channel,
K key,
double max,
double min) |
RedisFuture<Long> |
RedisSortedSetsAsyncConnection.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.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.zrevrangebyscore(ValueStreamingChannel<V> channel,
K key,
double max,
double min,
long offset,
long count) |
RedisFuture<Long> |
RedisSortedSetsAsyncConnection.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.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.zrevrangebyscore(ValueStreamingChannel<V> channel,
K key,
String max,
String min) |
RedisFuture<Long> |
RedisSortedSetsAsyncConnection.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.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.zrevrangebyscore(ValueStreamingChannel<V> channel,
K key,
String max,
String min,
long offset,
long count) |
RedisFuture<List<ScoredValue<V>>> |
RedisSortedSetsAsyncConnection.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.
|
RedisFuture<List<ScoredValue<V>>> |
RedisAsyncConnectionImpl.zrevrangebyscoreWithScores(K key,
double max,
double min) |
RedisFuture<List<ScoredValue<V>>> |
RedisSortedSetsAsyncConnection.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.
|
RedisFuture<List<ScoredValue<V>>> |
RedisAsyncConnectionImpl.zrevrangebyscoreWithScores(K key,
double max,
double min,
long offset,
long count) |
RedisFuture<List<ScoredValue<V>>> |
RedisSortedSetsAsyncConnection.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.
|
RedisFuture<List<ScoredValue<V>>> |
RedisAsyncConnectionImpl.zrevrangebyscoreWithScores(K key,
String max,
String min) |
RedisFuture<List<ScoredValue<V>>> |
RedisSortedSetsAsyncConnection.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.
|
RedisFuture<List<ScoredValue<V>>> |
RedisAsyncConnectionImpl.zrevrangebyscoreWithScores(K key,
String max,
String min,
long offset,
long count) |
RedisFuture<Long> |
RedisSortedSetsAsyncConnection.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.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
double max,
double min) |
RedisFuture<Long> |
RedisSortedSetsAsyncConnection.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.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
double max,
double min,
long offset,
long count) |
RedisFuture<Long> |
RedisSortedSetsAsyncConnection.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.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
String max,
String min) |
RedisFuture<Long> |
RedisSortedSetsAsyncConnection.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.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
String max,
String min,
long offset,
long count) |
RedisFuture<List<ScoredValue<V>>> |
RedisSortedSetsAsyncConnection.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.
|
RedisFuture<List<ScoredValue<V>>> |
RedisAsyncConnectionImpl.zrevrangeWithScores(K key,
long start,
long stop) |
RedisFuture<Long> |
RedisSortedSetsAsyncConnection.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.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.zrevrangeWithScores(ScoredValueStreamingChannel<V> channel,
K key,
long start,
long stop) |
RedisFuture<Long> |
RedisSortedSetsAsyncConnection.zrevrank(K key,
V member)
Determine the index of a member in a sorted set, with scores ordered from high to low.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.zrevrank(K key,
V member) |
RedisFuture<ScoredValueScanCursor<V>> |
RedisSortedSetsAsyncConnection.zscan(K key)
Incrementally iterate sorted sets elements and associated scores.
|
RedisFuture<ScoredValueScanCursor<V>> |
RedisAsyncConnectionImpl.zscan(K key) |
RedisFuture<ScoredValueScanCursor<V>> |
RedisSortedSetsAsyncConnection.zscan(K key,
ScanArgs scanArgs)
Incrementally iterate sorted sets elements and associated scores.
|
RedisFuture<ScoredValueScanCursor<V>> |
RedisAsyncConnectionImpl.zscan(K key,
ScanArgs scanArgs) |
RedisFuture<ScoredValueScanCursor<V>> |
RedisSortedSetsAsyncConnection.zscan(K key,
ScanCursor scanCursor)
Incrementally iterate sorted sets elements and associated scores.
|
RedisFuture<ScoredValueScanCursor<V>> |
RedisAsyncConnectionImpl.zscan(K key,
ScanCursor scanCursor) |
RedisFuture<ScoredValueScanCursor<V>> |
RedisSortedSetsAsyncConnection.zscan(K key,
ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate sorted sets elements and associated scores.
|
RedisFuture<ScoredValueScanCursor<V>> |
RedisAsyncConnectionImpl.zscan(K key,
ScanCursor scanCursor,
ScanArgs scanArgs) |
RedisFuture<StreamScanCursor> |
RedisSortedSetsAsyncConnection.zscan(ScoredValueStreamingChannel<V> channel,
K key)
Incrementally iterate sorted sets elements and associated scores.
|
RedisFuture<StreamScanCursor> |
RedisAsyncConnectionImpl.zscan(ScoredValueStreamingChannel<V> channel,
K key) |
RedisFuture<StreamScanCursor> |
RedisSortedSetsAsyncConnection.zscan(ScoredValueStreamingChannel<V> channel,
K key,
ScanArgs scanArgs)
Incrementally iterate sorted sets elements and associated scores.
|
RedisFuture<StreamScanCursor> |
RedisAsyncConnectionImpl.zscan(ScoredValueStreamingChannel<V> channel,
K key,
ScanArgs scanArgs) |
RedisFuture<StreamScanCursor> |
RedisSortedSetsAsyncConnection.zscan(ScoredValueStreamingChannel<V> channel,
K key,
ScanCursor scanCursor)
Incrementally iterate sorted sets elements and associated scores.
|
RedisFuture<StreamScanCursor> |
RedisAsyncConnectionImpl.zscan(ScoredValueStreamingChannel<V> channel,
K key,
ScanCursor scanCursor) |
RedisFuture<StreamScanCursor> |
RedisSortedSetsAsyncConnection.zscan(ScoredValueStreamingChannel<V> channel,
K key,
ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate sorted sets elements and associated scores.
|
RedisFuture<StreamScanCursor> |
RedisAsyncConnectionImpl.zscan(ScoredValueStreamingChannel<V> channel,
K key,
ScanCursor scanCursor,
ScanArgs scanArgs) |
RedisFuture<Double> |
RedisSortedSetsAsyncConnection.zscore(K key,
V member)
Get the score associated with the given member in a sorted set.
|
RedisFuture<Double> |
RedisAsyncConnectionImpl.zscore(K key,
V member) |
RedisFuture<Long> |
RedisSortedSetsAsyncConnection.zunionstore(K destination,
K... keys)
Add multiple sorted sets and store the resulting sorted set in a new key.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.zunionstore(K destination,
K... keys) |
RedisFuture<Long> |
RedisSortedSetsAsyncConnection.zunionstore(K destination,
ZStoreArgs storeArgs,
K... keys)
Add multiple sorted sets and store the resulting sorted set in a new key.
|
RedisFuture<Long> |
RedisAsyncConnectionImpl.zunionstore(K destination,
ZStoreArgs storeArgs,
K... keys) |
Modifier and Type | Method and Description |
---|---|
RedisFuture<Long> |
RedisAdvancedClusterAsyncConnectionImpl.clusterCountKeysInSlot(int slot) |
RedisFuture<List<K>> |
RedisAdvancedClusterAsyncConnectionImpl.clusterGetKeysInSlot(int slot,
int count) |
Modifier and Type | Interface and Description |
---|---|
interface |
RedisCommand<K,V,T> |
Modifier and Type | Class and Description |
---|---|
class |
Command<K,V,T>
A redis command and its result.
|
Modifier and Type | Method and Description |
---|---|
RedisFuture<Void> |
RedisPubSubConnectionImpl.psubscribe(K... patterns) |
RedisFuture<Void> |
RedisPubSubConnection.psubscribe(K... patterns)
Listen for messages published to channels matching the given patterns.
|
RedisFuture<Void> |
RedisPubSubConnectionImpl.punsubscribe(K... patterns) |
RedisFuture<Void> |
RedisPubSubConnection.punsubscribe(K... patterns)
Stop listening for messages posted to channels matching the given patterns.
|
RedisFuture<Void> |
RedisPubSubConnectionImpl.subscribe(K... channels) |
RedisFuture<Void> |
RedisPubSubConnection.subscribe(K... channels)
Listen for messages published to the given channels.
|
RedisFuture<Void> |
RedisPubSubConnectionImpl.unsubscribe(K... channels) |
RedisFuture<Void> |
RedisPubSubConnection.unsubscribe(K... channels)
Stop listening for messages posted to the given channels.
|
Modifier and Type | Method and Description |
---|---|
protected List<RedisFuture<Void>> |
RedisPubSubConnectionImpl.resubscribe()
Re-subscribe to all previously subscribed channels and patterns.
|
Copyright © 2016. All rights reserved.