K
- Key type.V
- Value type.public abstract class AbstractRedisAsyncCommands<K,V> extends Object implements RedisAclAsyncCommands<K,V>, RedisHashAsyncCommands<K,V>, RedisKeyAsyncCommands<K,V>, RedisStringAsyncCommands<K,V>, RedisListAsyncCommands<K,V>, RedisSetAsyncCommands<K,V>, RedisSortedSetAsyncCommands<K,V>, RedisScriptingAsyncCommands<K,V>, RedisServerAsyncCommands<K,V>, RedisHLLAsyncCommands<K,V>, BaseRedisAsyncCommands<K,V>, RedisTransactionalAsyncCommands<K,V>, RedisGeoAsyncCommands<K,V>, RedisClusterAsyncCommands<K,V>
Constructor and Description |
---|
AbstractRedisAsyncCommands(StatefulConnection<K,V> connection,
RedisCodec<K,V> codec)
Initialize a new instance.
|
Modifier and Type | Method and Description |
---|---|
RedisFuture<Set<AclCategory>> |
aclCat()
The command shows the available ACL categories if called without arguments.
|
RedisFuture<Set<CommandType>> |
aclCat(AclCategory category)
The command shows all the Redis commands in the specified category.
|
RedisFuture<Long> |
aclDeluser(String... usernames)
Delete all the specified ACL users and terminate all the connections that are authenticated with such users.
|
RedisFuture<String> |
aclDryRun(String username,
RedisCommand<K,V,?> command)
Simulate the execution of a given command by a given user.
|
RedisFuture<String> |
aclDryRun(String username,
String command,
String... args)
Simulate the execution of a given command by a given user.
|
RedisFuture<String> |
aclGenpass()
The command generates a password.
|
RedisFuture<String> |
aclGenpass(int bits)
The command generates a password.
|
RedisFuture<List<Object>> |
aclGetuser(String username)
The command returns all the rules defined for an existing ACL user.
|
RedisFuture<List<String>> |
aclList()
The command shows the currently active ACL rules in the Redis server.
|
RedisFuture<String> |
aclLoad()
When Redis is configured to use an ACL file (with the aclfile configuration option), this command
will reload the ACLs from the file, replacing all the current ACL rules with the ones defined in the file.
|
RedisFuture<List<Map<String,Object>>> |
aclLog()
The command shows a list of recent ACL security events.
|
RedisFuture<List<Map<String,Object>>> |
aclLog(int count)
The command shows a list of recent ACL security events.
|
RedisFuture<String> |
aclLogReset()
The command clears ACL security events.
|
RedisFuture<String> |
aclSave()
When Redis is configured to use an ACL file (with the aclfile configuration option),
this command will save the currently defined ACLs from the server memory to the ACL file.
|
RedisFuture<String> |
aclSetuser(String username,
AclSetuserArgs args)
Create an ACL user with the specified rules or modify the rules of an existing user.
|
RedisFuture<List<String>> |
aclUsers()
The command shows a list of all the usernames of the currently configured users in the Redis ACL system.
|
RedisFuture<String> |
aclWhoami()
The command shows a list of all the usernames of the currently configured users in the Redis ACL system.
|
RedisFuture<Long> |
append(K key,
V value)
Append a value to a key.
|
RedisFuture<String> |
asking()
The asking command is required after a
-ASK redirection. |
RedisFuture<String> |
auth(char[] password) |
RedisFuture<String> |
auth(CharSequence password)
Authenticate to the server.
|
RedisFuture<String> |
auth(String username,
char[] password) |
RedisFuture<String> |
auth(String username,
CharSequence password)
Authenticate to the server with username and password.
|
RedisFuture<String> |
bgrewriteaof()
Asynchronously rewrite the append-only file.
|
RedisFuture<String> |
bgsave()
Asynchronously save the dataset to disk.
|
RedisFuture<Long> |
bitcount(K key)
Count set bits in a string.
|
RedisFuture<Long> |
bitcount(K key,
long start,
long end)
Count set bits in a string.
|
RedisFuture<List<Long>> |
bitfield(K key,
BitFieldArgs bitFieldArgs)
Execute
BITFIELD with its subcommands. |
RedisFuture<Long> |
bitopAnd(K destination,
K... keys)
Perform bitwise AND between strings.
|
RedisFuture<Long> |
bitopNot(K destination,
K source)
Perform bitwise NOT between strings.
|
RedisFuture<Long> |
bitopOr(K destination,
K... keys)
Perform bitwise OR between strings.
|
RedisFuture<Long> |
bitopXor(K destination,
K... keys)
Perform bitwise XOR between strings.
|
RedisFuture<Long> |
bitpos(K key,
boolean state)
Find first bit set or clear in a string.
|
RedisFuture<Long> |
bitpos(K key,
boolean state,
long start)
Find first bit set or clear in a string.
|
RedisFuture<Long> |
bitpos(K key,
boolean state,
long start,
long end)
Find first bit set or clear in a string.
|
RedisFuture<V> |
blmove(K source,
K destination,
LMoveArgs args,
double timeout)
Atomically returns and removes the first/last element (head/tail depending on the where from argument) of the list stored
at source, and pushes the element at the first/last element (head/tail depending on the whereto argument) of the list
stored at destination.
|
RedisFuture<V> |
blmove(K source,
K destination,
LMoveArgs args,
long timeout)
Atomically returns and removes the first/last element (head/tail depending on the where from argument) of the list stored
at source, and pushes the element at the first/last element (head/tail depending on the whereto argument) of the list
stored at destination.
|
RedisFuture<KeyValue<K,List<V>>> |
blmpop(double timeout,
LMPopArgs args,
K... keys)
Remove and get the first/last elements in a list, or block until one is available.
|
RedisFuture<KeyValue<K,List<V>>> |
blmpop(long timeout,
LMPopArgs args,
K... keys)
Remove and get the first/last elements in a list, or block until one is available.
|
RedisFuture<KeyValue<K,V>> |
blpop(double timeout,
K... keys)
Remove and get the first element in a list, or block until one is available.
|
RedisFuture<KeyValue<K,V>> |
blpop(long timeout,
K... keys)
Remove and get the first element in a list, or block until one is available.
|
RedisFuture<KeyValue<K,V>> |
brpop(double timeout,
K... keys)
Remove and get the last element in a list, or block until one is available.
|
RedisFuture<KeyValue<K,V>> |
brpop(long timeout,
K... keys)
Remove and get the last element in a list, or block until one is available.
|
RedisFuture<V> |
brpoplpush(double 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> |
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<KeyValue<K,ScoredValue<V>>> |
bzpopmax(double timeout,
K... keys)
Removes and returns a member with the highest scores in the sorted set stored at one of the keys.
|
RedisFuture<KeyValue<K,ScoredValue<V>>> |
bzpopmax(long timeout,
K... keys)
Removes and returns a member with the highest scores in the sorted set stored at one of the keys.
|
RedisFuture<KeyValue<K,ScoredValue<V>>> |
bzpopmin(double timeout,
K... keys)
Removes and returns a member with the lowest scores in the sorted set stored at one of the keys.
|
RedisFuture<KeyValue<K,ScoredValue<V>>> |
bzpopmin(long timeout,
K... keys)
Removes and returns a member with the lowest scores in the sorted set stored at one of the keys.
|
RedisFuture<String> |
clientCaching(boolean enabled)
Control tracking of keys in the context of server-assisted client cache invalidation.
|
RedisFuture<K> |
clientGetname()
Get the current connection name.
|
RedisFuture<Long> |
clientGetredir()
Returns the client ID we are redirecting our tracking notifications to.
|
RedisFuture<Long> |
clientId()
Get the id of the current connection.
|
RedisFuture<Long> |
clientKill(KillArgs killArgs)
Kill connections of clients which are filtered by
killArgs . |
RedisFuture<String> |
clientKill(String addr)
Kill the connection of a client identified by ip:port.
|
RedisFuture<String> |
clientList()
Get the list of client connections.
|
RedisFuture<String> |
clientNoEvict(boolean on)
Sets the client eviction mode for the current connection.
|
RedisFuture<String> |
clientPause(long timeout)
Stop processing commands from clients for some time.
|
RedisFuture<String> |
clientSetname(K name)
Set the current connection name.
|
RedisFuture<String> |
clientTracking(TrackingArgs args)
Enables the tracking feature of the Redis server, that is used for server assisted client side caching.
|
RedisFuture<Long> |
clientUnblock(long id,
UnblockType type)
Unblock the specified blocked client.
|
RedisFuture<String> |
clusterAddSlots(int... slots)
Adds slots to the cluster node.
|
RedisFuture<String> |
clusterAddSlotsRange(Range<Integer>... ranges)
Takes a list of slot ranges (specified by start and end slots) to assign to the node.
|
RedisFuture<String> |
clusterBumpepoch()
Generate a new config epoch, incrementing the current epoch, assign the new epoch to this node, WITHOUT any consensus and
persist the configuration on disk before sending packets with the new configuration.
|
RedisFuture<Long> |
clusterCountFailureReports(String nodeId)
Returns the number of failure reports for the specified node.
|
RedisFuture<Long> |
clusterCountKeysInSlot(int slot)
Returns the number of keys in the specified Redis Cluster hash
slot . |
RedisFuture<String> |
clusterDelSlots(int... slots)
Removes slots from the cluster node.
|
RedisFuture<String> |
clusterDelSlotsRange(Range<Integer>... ranges)
Takes a list of slot ranges (specified by start and end slots) to remove to the node.
|
RedisFuture<String> |
clusterFailover(boolean force)
Failover a cluster node.
|
RedisFuture<String> |
clusterFailover(boolean force,
boolean takeOver)
Failover a cluster node.
|
RedisFuture<String> |
clusterFlushslots()
Delete all the slots associated with the specified node.
|
RedisFuture<String> |
clusterForget(String nodeId)
Disallow connections and remove the cluster node from the cluster.
|
RedisFuture<List<K>> |
clusterGetKeysInSlot(int slot,
int count)
Retrieve the list of keys within the
slot . |
RedisFuture<String> |
clusterInfo()
Get information and statistics about the cluster viewed by the current node.
|
RedisFuture<Long> |
clusterKeyslot(K key)
Returns an integer identifying the hash slot the specified key hashes to.
|
RedisFuture<String> |
clusterMeet(String ip,
int port)
Meet another cluster node to include the node into the cluster.
|
RedisFuture<String> |
clusterMyId()
Obtain the nodeId for the currently connected node.
|
RedisFuture<String> |
clusterNodes()
Obtain details about all cluster nodes.
|
RedisFuture<List<String>> |
clusterReplicas(String nodeId)
List replicas for a certain node identified by its
nodeId . |
RedisFuture<String> |
clusterReplicate(String nodeId)
Turn this node into a replica of the node with the id
nodeId . |
RedisFuture<String> |
clusterReset(boolean hard)
Reset a node performing a soft or hard reset:
All other nodes are forgotten
All the assigned / open slots are released
If the node is a replica, 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 replica, the whole data set is flushed away
|
RedisFuture<String> |
clusterSaveconfig()
Forces a node to save the nodes.conf configuration on disk.
|
RedisFuture<String> |
clusterSetConfigEpoch(long configEpoch)
This command sets a specific config epoch in a fresh node.
|
RedisFuture<String> |
clusterSetSlotImporting(int slot,
String nodeId)
Flag a slot as IMPORTING (incoming) from the node specified in
nodeId . |
RedisFuture<String> |
clusterSetSlotMigrating(int slot,
String nodeId)
Flag a slot as MIGRATING (outgoing) towards the node specified in
nodeId . |
RedisFuture<String> |
clusterSetSlotNode(int slot,
String nodeId)
Assign a slot to a node.
|
RedisFuture<String> |
clusterSetSlotStable(int slot)
Clears migrating / importing state from the slot.
|
RedisFuture<List<Object>> |
clusterShards()
Get array of cluster shards
|
RedisFuture<List<String>> |
clusterSlaves(String nodeId)
List replicas for a certain node identified by its
nodeId . |
RedisFuture<List<Object>> |
clusterSlots()
Get array of cluster slots to node mappings.
|
RedisFuture<List<Object>> |
command()
Returns an array reply of details about all Redis commands.
|
RedisFuture<Long> |
commandCount()
Get total number of Redis commands.
|
RedisFuture<List<Object>> |
commandInfo(CommandType... commands)
Returns an array reply of details about the requested commands.
|
RedisFuture<List<Object>> |
commandInfo(String... commands)
Returns an array reply of details about the requested commands.
|
RedisFuture<Map<String,String>> |
configGet(String... parameters)
Get the value of multiple pattern parameters.
|
RedisFuture<Map<String,String>> |
configGet(String parameter)
Get the value of a configuration parameter.
|
RedisFuture<String> |
configResetstat()
Reset the stats returned by INFO.
|
RedisFuture<String> |
configRewrite()
Rewrite the configuration file with the in memory configuration.
|
RedisFuture<String> |
configSet(Map<String,String> kvs)
Set multiple parameters to the given value.
|
RedisFuture<String> |
configSet(String parameter,
String value)
Set a configuration parameter to the given value.
|
RedisFuture<Boolean> |
copy(K source,
K destination)
Copy the value stored at the source key to the destination key.
|
RedisFuture<Boolean> |
copy(K source,
K destination,
CopyArgs copyArgs)
Copy the value stored at the source key to the destination key.
|
RedisFuture<Long> |
dbsize()
Return the number of keys in the selected database.
|
RedisFuture<String> |
debugCrashAndRecover(Long delay)
Crash and recover.
|
RedisFuture<String> |
debugHtstats(int db)
Get debugging information about the internal hash-table state.
|
RedisFuture<String> |
debugObject(K key)
Get debugging information about a key.
|
void |
debugOom()
Make the server crash: Out of memory.
|
RedisFuture<String> |
debugReload()
Save RDB, clear the database and reload RDB.
|
RedisFuture<String> |
debugRestart(Long delay)
Restart the server gracefully.
|
RedisFuture<String> |
debugSdslen(K key)
Get debugging information about the internal SDS length.
|
void |
debugSegfault()
Make the server crash: Invalid pointer access.
|
RedisFuture<Long> |
decr(K key)
Decrement the integer value of a key by one.
|
RedisFuture<Long> |
decrby(K key,
long amount)
Decrement the integer value of a key by the given number.
|
RedisFuture<Long> |
del(Iterable<K> keys) |
RedisFuture<Long> |
del(K... keys)
Delete one or more keys.
|
String |
digest(byte[] script)
Create a SHA1 digest from a Lua script.
|
String |
digest(String script)
Create a SHA1 digest from a Lua script.
|
RedisFuture<String> |
discard()
Discard all commands issued after MULTI.
|
protected <T> RedisFuture<T> |
dispatch(CommandType type,
CommandOutput<K,V,T> output) |
protected <T> RedisFuture<T> |
dispatch(CommandType type,
CommandOutput<K,V,T> output,
CommandArgs<K,V> args) |
<T> RedisFuture<T> |
dispatch(ProtocolKeyword type,
CommandOutput<K,V,T> output)
Dispatch a command to the Redis Server.
|
<T> RedisFuture<T> |
dispatch(ProtocolKeyword type,
CommandOutput<K,V,T> output,
CommandArgs<K,V> args)
Dispatch a command to the Redis Server.
|
<T> AsyncCommand<K,V,T> |
dispatch(RedisCommand<K,V,T> cmd) |
RedisFuture<byte[]> |
dump(K key)
Return a serialized version of the value stored at the specified key.
|
RedisFuture<V> |
echo(V msg)
Echo the given string.
|
<T> RedisFuture<T> |
eval(byte[] script,
ScriptOutputType type,
K... keys)
Execute a Lua script server side.
|
<T> RedisFuture<T> |
eval(byte[] script,
ScriptOutputType type,
K[] keys,
V... values)
Execute a Lua script server side.
|
<T> RedisFuture<T> |
eval(String script,
ScriptOutputType type,
K... keys)
Execute a Lua script server side.
|
<T> RedisFuture<T> |
eval(String script,
ScriptOutputType type,
K[] keys,
V... values)
Execute a Lua script server side.
|
<T> RedisFuture<T> |
evalReadOnly(byte[] script,
ScriptOutputType type,
K[] keys,
V... values)
This is a read-only variant of the EVAL command that cannot execute commands that modify data.
|
<T> RedisFuture<T> |
evalsha(String digest,
ScriptOutputType type,
K... keys)
Evaluates a script cached on the server side by its SHA1 digest.
|
<T> RedisFuture<T> |
evalsha(String digest,
ScriptOutputType type,
K[] keys,
V... values)
Execute a Lua script server side.
|
<T> RedisFuture<T> |
evalshaReadOnly(String digest,
ScriptOutputType type,
K[] keys,
V... values)
This is a read-only variant of the EVALSHA command that cannot execute commands that modify data.
|
RedisFuture<TransactionResult> |
exec()
Execute all commands issued after MULTI.
|
RedisFuture<Long> |
exists(Iterable<K> keys) |
RedisFuture<Long> |
exists(K... keys)
Determine how many keys exist.
|
RedisFuture<Boolean> |
expire(K key,
Duration seconds)
Set a key's time to live in seconds.
|
RedisFuture<Boolean> |
expire(K key,
Duration seconds,
ExpireArgs expireArgs)
Set a key's time to live in seconds.
|
RedisFuture<Boolean> |
expire(K key,
long seconds)
Set a key's time to live in seconds.
|
RedisFuture<Boolean> |
expire(K key,
long seconds,
ExpireArgs expireArgs)
Set a key's time to live in seconds.
|
RedisFuture<Boolean> |
expireat(K key,
Date timestamp)
Set the expiration for a key as a UNIX timestamp.
|
RedisFuture<Boolean> |
expireat(K key,
Date timestamp,
ExpireArgs expireArgs)
Set the expiration for a key as a UNIX timestamp.
|
RedisFuture<Boolean> |
expireat(K key,
Instant timestamp)
Set the expiration for a key as a UNIX timestamp.
|
RedisFuture<Boolean> |
expireat(K key,
Instant timestamp,
ExpireArgs expireArgs)
Set the expiration for a key as a UNIX timestamp.
|
RedisFuture<Boolean> |
expireat(K key,
long timestamp)
Set the expiration for a key as a UNIX timestamp.
|
RedisFuture<Boolean> |
expireat(K key,
long timestamp,
ExpireArgs expireArgs)
Set the expiration for a key as a UNIX timestamp.
|
RedisFuture<Long> |
expiretime(K key)
Get the time to live for a key in as unix timestamp in seconds.
|
RedisFuture<String> |
flushall()
Remove all keys from all databases.
|
RedisFuture<String> |
flushall(FlushMode flushMode)
Remove all keys from all databases using the specified
FlushMode . |
RedisFuture<String> |
flushallAsync()
Remove all keys asynchronously from all databases.
|
void |
flushCommands()
Flush pending commands.
|
RedisFuture<String> |
flushdb()
Remove all keys from the current database.
|
RedisFuture<String> |
flushdb(FlushMode flushMode)
Remove all keys from the current database using the specified
FlushMode . |
RedisFuture<String> |
flushdbAsync()
Remove all keys asynchronously from the current database.
|
RedisFuture<Long> |
geoadd(K key,
double longitude,
double latitude,
V member)
Single geo add.
|
RedisFuture<Long> |
geoadd(K key,
double longitude,
double latitude,
V member,
GeoAddArgs args)
Single geo add.
|
RedisFuture<Long> |
geoadd(K key,
GeoAddArgs args,
GeoValue<V>... values)
Multi geo add.
|
RedisFuture<Long> |
geoadd(K key,
GeoAddArgs args,
Object... lngLatMember)
Multi geo add.
|
RedisFuture<Long> |
geoadd(K key,
GeoValue<V>... values)
Multi geo add.
|
RedisFuture<Long> |
geoadd(K key,
Object... lngLatMember)
Multi geo add.
|
RedisFuture<Double> |
geodist(K key,
V from,
V to,
GeoArgs.Unit unit)
Retrieve distance between points
from and to . |
RedisFuture<List<Value<String>>> |
geohash(K key,
V... members)
Retrieve Geohash strings representing the position of one or more elements in a sorted set value representing a
geospatial index.
|
RedisFuture<List<GeoCoordinates>> |
geopos(K key,
V... members)
Get geo coordinates for the
members . |
protected RedisFuture<Set<V>> |
georadius_ro(K key,
double longitude,
double latitude,
double distance,
GeoArgs.Unit unit) |
protected RedisFuture<List<GeoWithin<V>>> |
georadius_ro(K key,
double longitude,
double latitude,
double distance,
GeoArgs.Unit unit,
GeoArgs geoArgs) |
RedisFuture<Set<V>> |
georadius(K key,
double longitude,
double latitude,
double distance,
GeoArgs.Unit unit)
Retrieve members selected by distance with the center of
longitude and latitude . |
RedisFuture<List<GeoWithin<V>>> |
georadius(K key,
double longitude,
double latitude,
double distance,
GeoArgs.Unit unit,
GeoArgs geoArgs)
Retrieve members selected by distance with the center of
longitude and latitude . |
RedisFuture<Long> |
georadius(K key,
double longitude,
double latitude,
double distance,
GeoArgs.Unit unit,
GeoRadiusStoreArgs<K> geoRadiusStoreArgs)
Perform a
RedisGeoAsyncCommands.georadius(Object, double, double, double, GeoArgs.Unit, GeoArgs) query and store the results in a
sorted set. |
protected RedisFuture<Set<V>> |
georadiusbymember_ro(K key,
V member,
double distance,
GeoArgs.Unit unit) |
protected RedisFuture<List<GeoWithin<V>>> |
georadiusbymember_ro(K key,
V member,
double distance,
GeoArgs.Unit unit,
GeoArgs geoArgs) |
RedisFuture<Set<V>> |
georadiusbymember(K key,
V member,
double distance,
GeoArgs.Unit unit)
Retrieve members selected by distance with the center of
member . |
RedisFuture<List<GeoWithin<V>>> |
georadiusbymember(K key,
V member,
double distance,
GeoArgs.Unit unit,
GeoArgs geoArgs)
Retrieve members selected by distance with the center of
member . |
RedisFuture<Long> |
georadiusbymember(K key,
V member,
double distance,
GeoArgs.Unit unit,
GeoRadiusStoreArgs<K> geoRadiusStoreArgs)
Perform a
RedisGeoAsyncCommands.georadiusbymember(Object, Object, double, GeoArgs.Unit, GeoArgs) query and store the results in a
sorted set. |
RedisFuture<Set<V>> |
geosearch(K key,
GeoSearch.GeoRef<K> reference,
GeoSearch.GeoPredicate predicate)
Retrieve members selected by distance with the center of
reference the search predicate . |
RedisFuture<List<GeoWithin<V>>> |
geosearch(K key,
GeoSearch.GeoRef<K> reference,
GeoSearch.GeoPredicate predicate,
GeoArgs geoArgs)
Retrieve members selected by distance with the center of
reference the search predicate . |
RedisFuture<Long> |
geosearchstore(K destination,
K key,
GeoSearch.GeoRef<K> reference,
GeoSearch.GeoPredicate predicate,
GeoArgs geoArgs,
boolean storeDist)
Perform a
RedisGeoAsyncCommands.geosearch(Object, GeoSearch.GeoRef, GeoSearch.GeoPredicate, GeoArgs) query and store the results in a
sorted set. |
RedisFuture<V> |
get(K key)
Get the value of a key.
|
RedisFuture<Long> |
getbit(K key,
long offset)
Returns the bit value at offset in the string value stored at key.
|
StatefulConnection<K,V> |
getConnection() |
RedisFuture<V> |
getdel(K key)
Get the value of key and delete the key.
|
RedisFuture<V> |
getex(K key,
GetExArgs args)
Get the value of key and optionally set its expiration.
|
RedisFuture<V> |
getrange(K key,
long start,
long end)
Get a substring of the string stored at a key.
|
RedisFuture<V> |
getset(K key,
V value)
Set the string value of a key and return its old value.
|
RedisFuture<Long> |
hdel(K key,
K... fields)
Delete one or more hash fields.
|
RedisFuture<Boolean> |
hexists(K key,
K field)
Determine if a hash field exists.
|
RedisFuture<V> |
hget(K key,
K field)
Get the value of a hash field.
|
RedisFuture<Map<K,V>> |
hgetall(K key)
Get all the fields and values in a hash.
|
RedisFuture<Long> |
hgetall(KeyValueStreamingChannel<K,V> channel,
K key)
Stream over all the fields and values in a hash.
|
RedisFuture<Long> |
hincrby(K key,
K field,
long amount)
Increment the integer value of a hash field by the given number.
|
RedisFuture<Double> |
hincrbyfloat(K key,
K field,
double amount)
Increment the float value of a hash field by the given amount.
|
RedisFuture<List<K>> |
hkeys(K key)
Get all the fields in a hash.
|
RedisFuture<Long> |
hkeys(KeyStreamingChannel<K> channel,
K key)
Stream over all the fields in a hash.
|
RedisFuture<Long> |
hlen(K key)
Get the number of fields in a hash.
|
RedisFuture<Long> |
hmget(KeyValueStreamingChannel<K,V> channel,
K key,
K... fields)
Stream over the values of all the given hash fields.
|
RedisFuture<List<KeyValue<K,V>>> |
hmget(K key,
K... fields)
Get the values of all the given hash fields.
|
RedisFuture<String> |
hmset(K key,
Map<K,V> map)
Set multiple hash fields to multiple values.
|
RedisFuture<K> |
hrandfield(K key)
Return a random field from the hash stored at
key . |
RedisFuture<List<K>> |
hrandfield(K key,
long count)
Return
count random fields from the hash stored at key . |
RedisFuture<KeyValue<K,V>> |
hrandfieldWithvalues(K key)
Return a random field along its value from the hash stored at
key . |
RedisFuture<List<KeyValue<K,V>>> |
hrandfieldWithvalues(K key,
long count)
Return
count random fields along their value from the hash stored at key . |
RedisFuture<MapScanCursor<K,V>> |
hscan(K key)
Incrementally iterate hash fields and associated values.
|
RedisFuture<StreamScanCursor> |
hscan(KeyValueStreamingChannel<K,V> channel,
K key)
Incrementally iterate hash fields and associated values.
|
RedisFuture<StreamScanCursor> |
hscan(KeyValueStreamingChannel<K,V> channel,
K key,
ScanArgs scanArgs)
Incrementally iterate hash fields and associated values.
|
RedisFuture<StreamScanCursor> |
hscan(KeyValueStreamingChannel<K,V> channel,
K key,
ScanCursor scanCursor)
Incrementally iterate hash fields and associated values.
|
RedisFuture<StreamScanCursor> |
hscan(KeyValueStreamingChannel<K,V> channel,
K key,
ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate hash fields and associated values.
|
RedisFuture<MapScanCursor<K,V>> |
hscan(K key,
ScanArgs scanArgs)
Incrementally iterate hash fields and associated values.
|
RedisFuture<MapScanCursor<K,V>> |
hscan(K key,
ScanCursor scanCursor)
Incrementally iterate hash fields and associated values.
|
RedisFuture<MapScanCursor<K,V>> |
hscan(K key,
ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate hash fields and associated values.
|
RedisFuture<Boolean> |
hset(K key,
K field,
V value)
Set the string value of a hash field.
|
RedisFuture<Long> |
hset(K key,
Map<K,V> map)
Set multiple hash fields to multiple values.
|
RedisFuture<Boolean> |
hsetnx(K key,
K field,
V value)
Set the value of a hash field, only if the field does not exist.
|
RedisFuture<Long> |
hstrlen(K key,
K field)
Get the string length of the field value in a hash.
|
RedisFuture<List<V>> |
hvals(K key)
Get all the values in a hash.
|
RedisFuture<Long> |
hvals(ValueStreamingChannel<V> channel,
K key)
Stream over all the values in a hash.
|
RedisFuture<Long> |
incr(K key)
Increment the integer value of a key by one.
|
RedisFuture<Long> |
incrby(K key,
long amount)
Increment the integer value of a key by the given amount.
|
RedisFuture<Double> |
incrbyfloat(K key,
double amount)
Increment the float value of a key by the given amount.
|
RedisFuture<String> |
info()
Get information and statistics about the server.
|
RedisFuture<String> |
info(String section)
Get information and statistics about the server.
|
boolean |
isOpen() |
RedisFuture<List<K>> |
keys(K pattern)
Find all keys matching the given pattern.
|
RedisFuture<Long> |
keys(KeyStreamingChannel<K> channel,
K pattern)
Find all keys matching the given pattern.
|
RedisFuture<Date> |
lastsave()
Get the UNIX time stamp of the last successful save to disk.
|
RedisFuture<V> |
lindex(K key,
long index)
Get an element from a list by its index.
|
RedisFuture<Long> |
linsert(K key,
boolean before,
V pivot,
V value)
Insert an element before or after another element in a list.
|
RedisFuture<Long> |
llen(K key)
Get the length of a list.
|
RedisFuture<V> |
lmove(K source,
K destination,
LMoveArgs args)
Atomically returns and removes the first/last element (head/tail depending on the where from argument) of the list stored
at source, and pushes the element at the first/last element (head/tail depending on the whereto argument) of the list
stored at destination.
|
RedisFuture<KeyValue<K,List<V>>> |
lmpop(LMPopArgs args,
K... keys)
Remove and get the first/last elements in a list.
|
RedisFuture<V> |
lpop(K key)
Remove and get the first element in a list.
|
RedisFuture<List<V>> |
lpop(K key,
long count)
Remove and get the first
count elements in a list. |
RedisFuture<Long> |
lpos(K key,
V value)
Return the index of matching elements inside a Redis list.
|
RedisFuture<List<Long>> |
lpos(K key,
V value,
int count)
Return the index of matching elements inside a Redis list using the
COUNT option. |
RedisFuture<List<Long>> |
lpos(K key,
V value,
int count,
LPosArgs args)
Return the index of matching elements inside a Redis list using the
COUNT option. |
RedisFuture<Long> |
lpos(K key,
V value,
LPosArgs args)
Return the index of matching elements inside a Redis list.
|
RedisFuture<Long> |
lpush(K key,
V... values)
Prepend one or multiple values to a list.
|
RedisFuture<Long> |
lpushx(K key,
V... values)
Prepend values to a list, only if the list exists.
|
RedisFuture<List<V>> |
lrange(K key,
long start,
long stop)
Get a range of elements from a list.
|
RedisFuture<Long> |
lrange(ValueStreamingChannel<V> channel,
K key,
long start,
long stop)
Get a range of elements from a list.
|
RedisFuture<Long> |
lrem(K key,
long count,
V value)
Remove elements from a list.
|
RedisFuture<String> |
lset(K key,
long index,
V value)
Set the value of an element in a list by its index.
|
RedisFuture<String> |
ltrim(K key,
long start,
long stop)
Trim a list to the specified range.
|
RedisFuture<Long> |
memoryUsage(K key)
Reports the number of bytes that a key and its value require to be stored in RAM.
|
RedisFuture<List<KeyValue<K,V>>> |
mget(Iterable<K> keys) |
RedisFuture<List<KeyValue<K,V>>> |
mget(K... keys)
Get the values of all the given keys.
|
RedisFuture<Long> |
mget(KeyValueStreamingChannel<K,V> channel,
Iterable<K> keys) |
RedisFuture<Long> |
mget(KeyValueStreamingChannel<K,V> channel,
K... keys)
Stream over the values of all the given keys.
|
RedisFuture<String> |
migrate(String host,
int port,
int db,
long timeout,
MigrateArgs<K> migrateArgs)
Atomically transfer one or more keys from a Redis instance to another one.
|
RedisFuture<String> |
migrate(String host,
int port,
K key,
int db,
long timeout)
Atomically transfer a key from a Redis instance to another one.
|
RedisFuture<Boolean> |
move(K key,
int db)
Move a key to another database.
|
RedisFuture<String> |
mset(Map<K,V> map)
Set multiple keys to multiple values.
|
RedisFuture<Boolean> |
msetnx(Map<K,V> map)
Set multiple keys to multiple values, only if none of the keys exist.
|
RedisFuture<String> |
multi()
Mark the start of a transaction block.
|
RedisFuture<String> |
objectEncoding(K key)
Returns the kind of internal representation used in order to store the value associated with the
key . |
RedisFuture<Long> |
objectFreq(K key)
Returns the logarithmic access frequency counter of the object stored at the specified
key . |
RedisFuture<Long> |
objectIdletime(K key)
Returns the number of seconds since the object stored at the specified key is idle (not requested by read or write
operations).
|
RedisFuture<Long> |
objectRefcount(K key)
Returns the number of references of the value associated with the specified key.
|
RedisFuture<Boolean> |
persist(K key)
Remove the expiration from a key.
|
RedisFuture<Boolean> |
pexpire(K key,
Duration milliseconds)
Set a key's time to live in milliseconds.
|
RedisFuture<Boolean> |
pexpire(K key,
Duration milliseconds,
ExpireArgs expireArgs)
Set a key's time to live in milliseconds.
|
RedisFuture<Boolean> |
pexpire(K key,
long milliseconds)
Set a key's time to live in milliseconds.
|
RedisFuture<Boolean> |
pexpire(K key,
long milliseconds,
ExpireArgs expireArgs)
Set a key's time to live in milliseconds.
|
RedisFuture<Boolean> |
pexpireat(K key,
Date timestamp)
Set the expiration for a key as a UNIX timestamp specified in milliseconds.
|
RedisFuture<Boolean> |
pexpireat(K key,
Date timestamp,
ExpireArgs expireArgs)
Set the expiration for a key as a UNIX timestamp specified in milliseconds.
|
RedisFuture<Boolean> |
pexpireat(K key,
Instant timestamp)
Set the expiration for a key as a UNIX timestamp specified in milliseconds.
|
RedisFuture<Boolean> |
pexpireat(K key,
Instant timestamp,
ExpireArgs expireArgs)
Set the expiration for a key as a UNIX timestamp specified in milliseconds.
|
RedisFuture<Boolean> |
pexpireat(K key,
long timestamp)
Set the expiration for a key as a UNIX timestamp specified in milliseconds.
|
RedisFuture<Boolean> |
pexpireat(K key,
long timestamp,
ExpireArgs expireArgs)
Set the expiration for a key as a UNIX timestamp specified in milliseconds.
|
RedisFuture<Long> |
pexpiretime(K key)
Get the time to live for a key in as unix timestamp in milliseconds.
|
RedisFuture<Long> |
pfadd(K key,
V... values)
Adds the specified elements to the specified HyperLogLog.
|
RedisFuture<Long> |
pfcount(K... keys)
Return the approximated cardinality of the set(s) observed by the HyperLogLog at key(s).
|
RedisFuture<String> |
pfmerge(K destkey,
K... sourcekeys)
Merge N different HyperLogLogs into a single one.
|
RedisFuture<String> |
ping()
Ping the server.
|
RedisFuture<String> |
psetex(K key,
long milliseconds,
V value)
Set the value and expiration in milliseconds of a key.
|
RedisFuture<Long> |
pttl(K key)
Get the time to live for a key in milliseconds.
|
RedisFuture<Long> |
publish(K channel,
V message)
Post a message to a channel.
|
RedisFuture<List<K>> |
pubsubChannels()
Lists the currently *active channels*.
|
RedisFuture<List<K>> |
pubsubChannels(K channel)
Lists the currently *active channels*.
|
RedisFuture<Long> |
pubsubNumpat()
Returns the number of subscriptions to patterns.
|
RedisFuture<Map<K,Long>> |
pubsubNumsub(K... channels)
Returns the number of subscribers (not counting clients subscribed to patterns) for the specified channels.
|
RedisFuture<String> |
quit()
Instructs Redis to disconnect the connection.
|
RedisFuture<K> |
randomkey()
Return a random key from the keyspace.
|
RedisFuture<String> |
readOnly()
Switch connection to Read-Only mode when connecting to a cluster.
|
RedisFuture<String> |
readWrite()
Switch connection to Read-Write mode (default) when connecting to a cluster.
|
RedisFuture<String> |
rename(K key,
K newKey)
Rename a key.
|
RedisFuture<Boolean> |
renamenx(K key,
K newKey)
Rename a key, only if the new key does not exist.
|
RedisFuture<String> |
replicaof(String host,
int port)
Make the server a replica of another instance.
|
RedisFuture<String> |
replicaofNoOne()
Promote server as master.
|
void |
reset()
Reset the command state.
|
RedisFuture<String> |
restore(K key,
byte[] value,
RestoreArgs args)
Create a key using the provided serialized value, previously obtained using DUMP.
|
RedisFuture<String> |
restore(K key,
long ttl,
byte[] value)
Create a key using the provided serialized value, previously obtained using DUMP.
|
RedisFuture<List<Object>> |
role()
Return the role of the instance in the context of replication.
|
RedisFuture<V> |
rpop(K key)
Remove and get the last element in a list.
|
RedisFuture<List<V>> |
rpop(K key,
long count)
Remove and get the last
count elements in a list. |
RedisFuture<V> |
rpoplpush(K source,
K destination)
Remove the last element in a list, append it to another list and return it.
|
RedisFuture<Long> |
rpush(K key,
V... values)
Append one or multiple values to a list.
|
RedisFuture<Long> |
rpushx(K key,
V... values)
Append values to a list, only if the list exists.
|
RedisFuture<Long> |
sadd(K key,
V... members)
Add one or more members to a set.
|
RedisFuture<String> |
save()
Synchronously save the dataset to disk.
|
RedisFuture<KeyScanCursor<K>> |
scan()
Incrementally iterate the keys space.
|
RedisFuture<StreamScanCursor> |
scan(KeyStreamingChannel<K> channel)
Incrementally iterate the keys space.
|
RedisFuture<StreamScanCursor> |
scan(KeyStreamingChannel<K> channel,
ScanArgs scanArgs)
Incrementally iterate the keys space.
|
RedisFuture<StreamScanCursor> |
scan(KeyStreamingChannel<K> channel,
ScanCursor scanCursor)
Incrementally iterate the keys space.
|
RedisFuture<StreamScanCursor> |
scan(KeyStreamingChannel<K> channel,
ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate the keys space.
|
RedisFuture<KeyScanCursor<K>> |
scan(ScanArgs scanArgs)
Incrementally iterate the keys space.
|
RedisFuture<KeyScanCursor<K>> |
scan(ScanCursor scanCursor)
Incrementally iterate the keys space.
|
RedisFuture<KeyScanCursor<K>> |
scan(ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate the keys space.
|
RedisFuture<Long> |
scard(K key)
Get the number of members in a set.
|
RedisFuture<List<Boolean>> |
scriptExists(String... digests)
Check existence of scripts in the script cache.
|
RedisFuture<String> |
scriptFlush()
Remove all the scripts from the script cache.
|
RedisFuture<String> |
scriptFlush(FlushMode flushMode)
Remove all the scripts from the script cache using the specified
FlushMode . |
RedisFuture<String> |
scriptKill()
Kill the script currently in execution.
|
RedisFuture<String> |
scriptLoad(byte[] script)
Load the specified Lua script into the script cache.
|
RedisFuture<String> |
scriptLoad(String script)
Load the specified Lua script into the script cache.
|
RedisFuture<Set<V>> |
sdiff(K... keys)
Subtract multiple sets.
|
RedisFuture<Long> |
sdiff(ValueStreamingChannel<V> channel,
K... keys)
Subtract multiple sets.
|
RedisFuture<Long> |
sdiffstore(K destination,
K... keys)
Subtract multiple sets and store the resulting set in a key.
|
RedisFuture<String> |
select(int db) |
RedisFuture<String> |
set(K key,
V value)
Set the string value of a key.
|
RedisFuture<String> |
set(K key,
V value,
SetArgs setArgs)
Set the string value of a key.
|
void |
setAutoFlushCommands(boolean autoFlush)
Disable or enable auto-flush behavior.
|
RedisFuture<Long> |
setbit(K key,
long offset,
int value)
Sets or clears the bit at offset in the string value stored at key.
|
RedisFuture<String> |
setex(K key,
long seconds,
V value)
Set the value and expiration of a key.
|
RedisFuture<V> |
setGet(K key,
V value)
Set the string value of a key and return its old value.
|
RedisFuture<V> |
setGet(K key,
V value,
SetArgs setArgs)
Set the string value of a key and return its old value.
|
RedisFuture<Boolean> |
setnx(K key,
V value)
Set the value of a key, only if the key does not exist.
|
RedisFuture<Long> |
setrange(K key,
long offset,
V value)
Overwrite part of a string at key starting at the specified offset.
|
void |
setTimeout(Duration timeout)
Set the default timeout for operations.
|
void |
shutdown(boolean save)
Synchronously save the dataset to disk and then shut down the server.
|
void |
shutdown(ShutdownArgs args)
Synchronously save the dataset to disk and then shutdown the server.
|
RedisFuture<Set<V>> |
sinter(K... keys)
Intersect multiple sets.
|
RedisFuture<Long> |
sinter(ValueStreamingChannel<V> channel,
K... keys)
Intersect multiple sets.
|
RedisFuture<Long> |
sintercard(K... keys)
This command works exactly like
RedisSetAsyncCommands.sinter(java.lang.Object[]) but instead of returning the result set, it returns
just the cardinality of the result. |
RedisFuture<Long> |
sintercard(long limit,
K... keys)
This command works exactly like
RedisSetAsyncCommands.sinter(java.lang.Object[]) but instead of returning the result set, it returns
just the cardinality of the result. |
RedisFuture<Long> |
sinterstore(K destination,
K... keys)
Intersect multiple sets and store the resulting set in a key.
|
RedisFuture<Boolean> |
sismember(K key,
V member)
Determine if a given value is a member of a set.
|
RedisFuture<String> |
slaveof(String host,
int port)
Make the server a replica of another instance.
|
RedisFuture<String> |
slaveofNoOne()
Promote server as master.
|
RedisFuture<List<Object>> |
slowlogGet()
Read the slow log.
|
RedisFuture<List<Object>> |
slowlogGet(int count)
Read the slow log.
|
RedisFuture<Long> |
slowlogLen()
Obtaining the current length of the slow log.
|
RedisFuture<String> |
slowlogReset()
Resetting the slow log.
|
RedisFuture<Set<V>> |
smembers(K key)
Get all the members in a set.
|
RedisFuture<Long> |
smembers(ValueStreamingChannel<V> channel,
K key)
Get all the members in a set.
|
RedisFuture<List<Boolean>> |
smismember(K key,
V... members)
Returns whether each member is a member of the set stored at key.
|
RedisFuture<Boolean> |
smove(K source,
K destination,
V member)
Move a member from one set to another.
|
RedisFuture<List<V>> |
sort(K key)
Sort the elements in a list, set or sorted set.
|
RedisFuture<List<V>> |
sort(K key,
SortArgs sortArgs)
Sort the elements in a list, set or sorted set.
|
RedisFuture<Long> |
sort(ValueStreamingChannel<V> channel,
K key)
Sort the elements in a list, set or sorted set.
|
RedisFuture<Long> |
sort(ValueStreamingChannel<V> channel,
K key,
SortArgs sortArgs)
Sort the elements in a list, set or sorted set.
|
RedisFuture<List<V>> |
sortReadOnly(K key)
Sort the elements in a list, set or sorted set.
|
RedisFuture<List<V>> |
sortReadOnly(K key,
SortArgs sortArgs)
Sort the elements in a list, set or sorted set.
|
RedisFuture<Long> |
sortReadOnly(ValueStreamingChannel<V> channel,
K key)
Sort the elements in a list, set or sorted set.
|
RedisFuture<Long> |
sortReadOnly(ValueStreamingChannel<V> channel,
K key,
SortArgs sortArgs)
Sort the elements in a list, set or sorted set.
|
RedisFuture<Long> |
sortStore(K key,
SortArgs sortArgs,
K destination)
Sort the elements in a list, set or sorted set.
|
RedisFuture<V> |
spop(K key)
Remove and return a random member from a set.
|
RedisFuture<Set<V>> |
spop(K key,
long count)
Remove and return one or multiple random members from a set.
|
RedisFuture<V> |
srandmember(K key)
Get one random member from a set.
|
RedisFuture<List<V>> |
srandmember(K key,
long count)
Get one or multiple random members from a set.
|
RedisFuture<Long> |
srandmember(ValueStreamingChannel<V> channel,
K key,
long count)
Get one or multiple random members from a set.
|
RedisFuture<Long> |
srem(K key,
V... members)
Remove one or more members from a set.
|
RedisFuture<ValueScanCursor<V>> |
sscan(K key)
Incrementally iterate Set elements.
|
RedisFuture<ValueScanCursor<V>> |
sscan(K key,
ScanArgs scanArgs)
Incrementally iterate Set elements.
|
RedisFuture<ValueScanCursor<V>> |
sscan(K key,
ScanCursor scanCursor)
Incrementally iterate Set elements.
|
RedisFuture<ValueScanCursor<V>> |
sscan(K key,
ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate Set elements.
|
RedisFuture<StreamScanCursor> |
sscan(ValueStreamingChannel<V> channel,
K key)
Incrementally iterate Set elements.
|
RedisFuture<StreamScanCursor> |
sscan(ValueStreamingChannel<V> channel,
K key,
ScanArgs scanArgs)
Incrementally iterate Set elements.
|
RedisFuture<StreamScanCursor> |
sscan(ValueStreamingChannel<V> channel,
K key,
ScanCursor scanCursor)
Incrementally iterate Set elements.
|
RedisFuture<StreamScanCursor> |
sscan(ValueStreamingChannel<V> channel,
K key,
ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate Set elements.
|
RedisFuture<StringMatchResult> |
stralgoLcs(StrAlgoArgs args)
The STRALGO command implements complex algorithms that operate on strings.
|
RedisFuture<Long> |
strlen(K key)
Get the length of the value stored in a key.
|
RedisFuture<Set<V>> |
sunion(K... keys)
Add multiple sets.
|
RedisFuture<Long> |
sunion(ValueStreamingChannel<V> channel,
K... keys)
Add multiple sets.
|
RedisFuture<Long> |
sunionstore(K destination,
K... keys)
Add multiple sets and store the resulting set in a key.
|
RedisFuture<String> |
swapdb(int db1,
int db2) |
RedisFuture<List<V>> |
time()
Return the current server time.
|
RedisFuture<Long> |
touch(Iterable<K> keys) |
RedisFuture<Long> |
touch(K... keys)
Touch one or more keys.
|
RedisFuture<Long> |
ttl(K key)
Get the time to live for a key.
|
RedisFuture<String> |
type(K key)
Determine the type stored at key.
|
RedisFuture<Long> |
unlink(Iterable<K> keys) |
RedisFuture<Long> |
unlink(K... keys)
Unlink one or more keys (non blocking DEL).
|
RedisFuture<String> |
unwatch()
Forget about all watched keys.
|
RedisFuture<Long> |
waitForReplication(int replicas,
long timeout)
Wait for replication.
|
RedisFuture<String> |
watch(K... keys)
Watch the given keys to determine execution of the MULTI/EXEC block.
|
RedisFuture<Long> |
xack(K key,
K group,
String... messageIds)
Acknowledge one or more messages as processed.
|
RedisFuture<String> |
xadd(K key,
Map<K,V> body)
Append a message to the stream
key . |
RedisFuture<String> |
xadd(K key,
Object... keysAndValues)
Append a message to the stream
key . |
RedisFuture<String> |
xadd(K key,
XAddArgs args,
Map<K,V> body)
Append a message to the stream
key . |
RedisFuture<String> |
xadd(K key,
XAddArgs args,
Object... keysAndValues)
Append a message to the stream
key . |
RedisFuture<ClaimedMessages<K,V>> |
xautoclaim(K key,
XAutoClaimArgs<K> args)
Gets ownership of one or multiple messages in the Pending Entries List of a given stream consumer group.
|
RedisFuture<List<StreamMessage<K,V>>> |
xclaim(K key,
Consumer<K> consumer,
long minIdleTime,
String... messageIds)
Gets ownership of one or multiple messages in the Pending Entries List of a given stream consumer group.
|
RedisFuture<List<StreamMessage<K,V>>> |
xclaim(K key,
Consumer<K> consumer,
XClaimArgs args,
String... messageIds)
Gets ownership of one or multiple messages in the Pending Entries List of a given stream consumer group.
|
RedisFuture<Long> |
xdel(K key,
String... messageIds)
Removes the specified entries from the stream.
|
RedisFuture<String> |
xgroupCreate(XReadArgs.StreamOffset<K> offset,
K group)
Create a consumer group.
|
RedisFuture<String> |
xgroupCreate(XReadArgs.StreamOffset<K> offset,
K group,
XGroupCreateArgs args)
Create a consumer group.
|
RedisFuture<Boolean> |
xgroupCreateconsumer(K key,
Consumer<K> consumer)
Create a consumer from a consumer group.
|
RedisFuture<Long> |
xgroupDelconsumer(K key,
Consumer<K> consumer)
Delete a consumer from a consumer group.
|
RedisFuture<Boolean> |
xgroupDestroy(K key,
K group)
Destroy a consumer group.
|
RedisFuture<String> |
xgroupSetid(XReadArgs.StreamOffset<K> offset,
K group)
Set the current
group id. |
RedisFuture<List<Object>> |
xinfoConsumers(K key,
K group)
Retrieve information about consumer groups of group
group and stream at key . |
RedisFuture<List<Object>> |
xinfoGroups(K key)
Retrieve information about the stream consumer groups at
key . |
RedisFuture<List<Object>> |
xinfoStream(K key)
Retrieve information about the stream at
key . |
RedisFuture<Long> |
xlen(K key)
Get the length of a steam.
|
RedisFuture<List<PendingMessage>> |
xpending(K key,
Consumer<K> consumer,
Range<String> range,
Limit limit)
Read pending messages from a stream within a specific
Range . |
RedisFuture<PendingMessages> |
xpending(K key,
K group)
Read pending messages from a stream for a
group . |
RedisFuture<List<PendingMessage>> |
xpending(K key,
K group,
Range<String> range,
Limit limit)
Read pending messages from a stream within a specific
Range . |
RedisFuture<List<PendingMessage>> |
xpending(K key,
XPendingArgs<K> args)
Read pending messages from a stream within a specific
XPendingArgs . |
RedisFuture<List<StreamMessage<K,V>>> |
xrange(K key,
Range<String> range)
Read messages from a stream within a specific
Range . |
RedisFuture<List<StreamMessage<K,V>>> |
xrange(K key,
Range<String> range,
Limit limit)
|
RedisFuture<List<StreamMessage<K,V>>> |
xread(XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffset s. |
RedisFuture<List<StreamMessage<K,V>>> |
xread(XReadArgs args,
XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffset s. |
RedisFuture<List<StreamMessage<K,V>>> |
xreadgroup(Consumer<K> consumer,
XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffset s using a consumer group. |
RedisFuture<List<StreamMessage<K,V>>> |
xreadgroup(Consumer<K> consumer,
XReadArgs args,
XReadArgs.StreamOffset<K>... streams)
Read messages from one or more
XReadArgs.StreamOffset s using a consumer group. |
RedisFuture<List<StreamMessage<K,V>>> |
xrevrange(K key,
Range<String> range)
Read messages from a stream within a specific
Range in reverse order. |
RedisFuture<List<StreamMessage<K,V>>> |
xrevrange(K key,
Range<String> range,
Limit limit)
|
RedisFuture<Long> |
xtrim(K key,
boolean approximateTrimming,
long count)
Trims the stream to
count elements. |
RedisFuture<Long> |
xtrim(K key,
long count)
Trims the stream to
count elements. |
RedisFuture<Long> |
xtrim(K key,
XTrimArgs args)
Trims the stream within a specific
XTrimArgs . |
RedisFuture<Long> |
zadd(K key,
double score,
V member)
Add one or more members to a sorted set, or update its score if it already exists.
|
RedisFuture<Long> |
zadd(K key,
Object... scoresAndValues)
Add one or more members to a sorted set, or update its score if it already exists.
|
RedisFuture<Long> |
zadd(K key,
ScoredValue<V>... scoredValues)
Add one or more members to a sorted set, or update its score if it already exists.
|
RedisFuture<Long> |
zadd(K key,
ZAddArgs zAddArgs,
double score,
V member)
Add one or more members to a sorted set, or update its score if it already exists.
|
RedisFuture<Long> |
zadd(K key,
ZAddArgs zAddArgs,
Object... scoresAndValues)
Add one or more members to a sorted set, or update its score if it already exists.
|
RedisFuture<Long> |
zadd(K key,
ZAddArgs zAddArgs,
ScoredValue<V>... scoredValues)
Add one or more members to a sorted set, or update its score if it already exists.
|
RedisFuture<Double> |
zaddincr(K key,
double score,
V member)
Add one or more members to a sorted set, or update its score if it already exists applying the
INCR option. |
RedisFuture<Double> |
zaddincr(K key,
ZAddArgs zAddArgs,
double score,
V member)
Add one or more members to a sorted set, or update its score if it already exists applying the
INCR option. |
RedisFuture<Long> |
zcard(K key)
Get the number of members in a sorted set.
|
RedisFuture<Long> |
zcount(K key,
double min,
double max)
Count the members in a sorted set with scores within the given values.
|
RedisFuture<Long> |
zcount(K key,
Range<? extends Number> range)
Count the members in a sorted set with scores within the given
Range . |
RedisFuture<Long> |
zcount(K key,
String min,
String max)
Count the members in a sorted set with scores within the given values.
|
RedisFuture<List<V>> |
zdiff(K... keys)
Computes the difference between the first and all successive input sorted sets.
|
RedisFuture<Long> |
zdiffstore(K destKey,
K... srcKeys)
Computes the difference between the first and all successive input sorted sets and stores the result in destination.
|
RedisFuture<List<ScoredValue<V>>> |
zdiffWithScores(K... keys)
Computes the difference between the first and all successive input sorted sets.
|
RedisFuture<Double> |
zincrby(K key,
double amount,
V member)
Increment the score of a member in a sorted set.
|
RedisFuture<List<V>> |
zinter(K... keys)
Intersect multiple sorted sets and returns the resulting sorted.
|
RedisFuture<List<V>> |
zinter(ZAggregateArgs aggregateArgs,
K... keys)
Intersect multiple sorted sets and returns the resulting sorted.
|
RedisFuture<Long> |
zintercard(K... keys)
This command is similar to
RedisSortedSetAsyncCommands.zinter(java.lang.Object[]) , but instead of returning the result set, it returns just
the cardinality of the result. |
RedisFuture<Long> |
zintercard(long limit,
K... keys)
This command is similar to
RedisSortedSetAsyncCommands.zinter(java.lang.Object[]) , but instead of returning the result set, it returns just
the cardinality of the result. |
RedisFuture<Long> |
zinterstore(K destination,
K... keys)
Intersect multiple sorted sets and store the resulting sorted set in a new key.
|
RedisFuture<Long> |
zinterstore(K destination,
ZStoreArgs zStoreArgs,
K... keys)
Intersect multiple sorted sets and store the resulting sorted set in a new key.
|
RedisFuture<List<ScoredValue<V>>> |
zinterWithScores(K... keys)
Intersect multiple sorted sets and returns the resulting sorted.
|
RedisFuture<List<ScoredValue<V>>> |
zinterWithScores(ZAggregateArgs aggregateArgs,
K... keys)
Intersect multiple sorted sets and returns the resulting sorted.
|
RedisFuture<Long> |
zlexcount(K key,
Range<? extends V> range)
Count the number of members in a sorted set between a given lexicographical range.
|
RedisFuture<Long> |
zlexcount(K key,
String min,
String max)
Count the number of members in a sorted set between a given lexicographical range.
|
RedisFuture<List<Double>> |
zmscore(K key,
V... members)
Returns the scores associated with the specified members in the sorted set stored at key.
|
RedisFuture<ScoredValue<V>> |
zpopmax(K key)
Removes and returns up to count members with the highest scores in the sorted set stored at key.
|
RedisFuture<List<ScoredValue<V>>> |
zpopmax(K key,
long count)
Removes and returns up to count members with the highest scores in the sorted set stored at key.
|
RedisFuture<ScoredValue<V>> |
zpopmin(K key)
Removes and returns up to count members with the lowest scores in the sorted set stored at key.
|
RedisFuture<List<ScoredValue<V>>> |
zpopmin(K key,
long count)
Removes and returns up to count members with the lowest scores in the sorted set stored at key.
|
RedisFuture<V> |
zrandmember(K key)
Return a random member from the sorted set stored at
key . |
RedisFuture<List<V>> |
zrandmember(K key,
long count)
Return
count random members from the sorted set stored at key . |
RedisFuture<ScoredValue<V>> |
zrandmemberWithScores(K key)
Return a random member along its value from the sorted set stored at
key . |
RedisFuture<List<ScoredValue<V>>> |
zrandmemberWithScores(K key,
long count)
Return
count random members along their value from the sorted set stored at key . |
RedisFuture<List<V>> |
zrange(K key,
long start,
long stop)
Return a range of members in a sorted set, by index.
|
RedisFuture<Long> |
zrange(ValueStreamingChannel<V> channel,
K key,
long start,
long stop)
Return a range of members in a sorted set, by index.
|
RedisFuture<List<V>> |
zrangebylex(K key,
Range<? extends V> range)
Return a range of members in a sorted set, by lexicographical range.
|
RedisFuture<List<V>> |
zrangebylex(K key,
Range<? extends V> range,
Limit limit)
Return a range of members in a sorted set, by lexicographical range.
|
RedisFuture<List<V>> |
zrangebylex(K key,
String min,
String max)
Return a range of members in a sorted set, by lexicographical range.
|
RedisFuture<List<V>> |
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>> |
zrangebyscore(K key,
double min,
double max)
Return a range of members in a sorted set, by score.
|
RedisFuture<List<V>> |
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>> |
zrangebyscore(K key,
Range<? extends Number> range)
Return a range of members in a sorted set, by score.
|
RedisFuture<List<V>> |
zrangebyscore(K key,
Range<? extends Number> range,
Limit limit)
Return a range of members in a sorted set, by score.
|
RedisFuture<List<V>> |
zrangebyscore(K key,
String min,
String max)
Return a range of members in a sorted set, by score.
|
RedisFuture<List<V>> |
zrangebyscore(K key,
String min,
String max,
long offset,
long count)
Return a range of members in a sorted set, by score.
|
RedisFuture<Long> |
zrangebyscore(ValueStreamingChannel<V> channel,
K key,
double min,
double max)
Stream over a range of members in a sorted set, by score.
|
RedisFuture<Long> |
zrangebyscore(ValueStreamingChannel<V> channel,
K key,
double min,
double max,
long offset,
long count)
Stream over range of members in a sorted set, by score.
|
RedisFuture<Long> |
zrangebyscore(ValueStreamingChannel<V> channel,
K key,
Range<? extends Number> range)
Stream over a range of members in a sorted set, by score.
|
RedisFuture<Long> |
zrangebyscore(ValueStreamingChannel<V> channel,
K key,
Range<? extends Number> range,
Limit limit)
Stream over a range of members in a sorted set, by score.
|
RedisFuture<Long> |
zrangebyscore(ValueStreamingChannel<V> channel,
K key,
String min,
String max)
Stream over a range of members in a sorted set, by score.
|
RedisFuture<Long> |
zrangebyscore(ValueStreamingChannel<V> channel,
K key,
String min,
String max,
long offset,
long count)
Stream over a range of members in a sorted set, by score.
|
RedisFuture<List<ScoredValue<V>>> |
zrangebyscoreWithScores(K key,
double min,
double max)
Return a range of members with score in a sorted set, by score.
|
RedisFuture<List<ScoredValue<V>>> |
zrangebyscoreWithScores(K key,
double min,
double max,
long offset,
long count)
Return a range of members with score in a sorted set, by score.
|
RedisFuture<List<ScoredValue<V>>> |
zrangebyscoreWithScores(K key,
Range<? extends Number> range)
Return a range of members with score in a sorted set, by score.
|
RedisFuture<List<ScoredValue<V>>> |
zrangebyscoreWithScores(K key,
Range<? extends Number> range,
Limit limit)
Return a range of members with score in a sorted set, by score.
|
RedisFuture<List<ScoredValue<V>>> |
zrangebyscoreWithScores(K key,
String min,
String max)
Return a range of members with score in a sorted set, by score.
|
RedisFuture<List<ScoredValue<V>>> |
zrangebyscoreWithScores(K key,
String min,
String max,
long offset,
long count)
Return a range of members with score in a sorted set, by score.
|
RedisFuture<Long> |
zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
double min,
double max)
Stream over a range of members with scores in a sorted set, by score.
|
RedisFuture<Long> |
zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
double min,
double max,
long offset,
long count)
Stream over a range of members with scores in a sorted set, by score.
|
RedisFuture<Long> |
zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
Range<? extends Number> range)
Stream over a range of members with scores in a sorted set, by score.
|
RedisFuture<Long> |
zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
Range<? extends Number> range,
Limit limit)
Stream over a range of members with scores in a sorted set, by score.
|
RedisFuture<Long> |
zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
String min,
String max)
Stream over a range of members with scores in a sorted set, by score.
|
RedisFuture<Long> |
zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
String min,
String max,
long offset,
long count)
Stream over a range of members with scores in a sorted set, by score.
|
RedisFuture<Long> |
zrangestore(K dstKey,
K srcKey,
Range<Long> range)
Get the specified range of elements in the sorted set stored at
srcKey and stores the result in the
dstKey destination key. |
RedisFuture<Long> |
zrangestorebylex(K dstKey,
K srcKey,
Range<? extends V> range,
Limit limit)
Get the specified range of elements in the sorted set stored at
srcKey and stores the result in the
dstKey destination key. |
RedisFuture<Long> |
zrangestorebyscore(K dstKey,
K srcKey,
Range<? extends Number> range,
Limit limit)
Get the specified range of elements in the sorted set stored at
srcKey and stores the result in the
dstKey destination key. |
RedisFuture<List<ScoredValue<V>>> |
zrangeWithScores(K key,
long start,
long stop)
Return a range of members with scores in a sorted set, by index.
|
RedisFuture<Long> |
zrangeWithScores(ScoredValueStreamingChannel<V> channel,
K key,
long start,
long stop)
Stream over a range of members with scores in a sorted set, by index.
|
RedisFuture<Long> |
zrank(K key,
V member)
Determine the index of a member in a sorted set.
|
RedisFuture<Long> |
zrem(K key,
V... members)
Remove one or more members from a sorted set.
|
RedisFuture<Long> |
zremrangebylex(K key,
Range<? extends V> range)
Remove all members in a sorted set between the given lexicographical range.
|
RedisFuture<Long> |
zremrangebylex(K key,
String min,
String max)
Remove all members in a sorted set between the given lexicographical range.
|
RedisFuture<Long> |
zremrangebyrank(K key,
long start,
long stop)
Remove all members in a sorted set within the given indexes.
|
RedisFuture<Long> |
zremrangebyscore(K key,
double min,
double max)
Remove all members in a sorted set within the given scores.
|
RedisFuture<Long> |
zremrangebyscore(K key,
Range<? extends Number> range)
Remove all members in a sorted set within the given scores.
|
RedisFuture<Long> |
zremrangebyscore(K key,
String min,
String max)
Remove all members in a sorted set within the given scores.
|
RedisFuture<List<V>> |
zrevrange(K key,
long start,
long stop)
Return a range of members in a sorted set, by index, with scores ordered from high to low.
|
RedisFuture<Long> |
zrevrange(ValueStreamingChannel<V> channel,
K key,
long start,
long stop)
Stream over a range of members in a sorted set, by index, with scores ordered from high to low.
|
RedisFuture<List<V>> |
zrevrangebylex(K key,
Range<? extends V> range)
Return a range of members in a sorted set, by lexicographical range ordered from high to low.
|
RedisFuture<List<V>> |
zrevrangebylex(K key,
Range<? extends V> range,
Limit limit)
Return a range of members in a sorted set, by lexicographical range ordered from high to low.
|
RedisFuture<List<V>> |
zrevrangebyscore(K key,
double max,
double min)
Return a range of members in a sorted set, by score, with scores ordered from high to low.
|
RedisFuture<List<V>> |
zrevrangebyscore(K key,
double max,
double min,
long offset,
long count)
Return a range of members in a sorted set, by score, with scores ordered from high to low.
|
RedisFuture<List<V>> |
zrevrangebyscore(K key,
Range<? extends Number> range)
Return a range of members in a sorted set, by score, with scores ordered from high to low.
|
RedisFuture<List<V>> |
zrevrangebyscore(K key,
Range<? extends Number> range,
Limit limit)
Return a range of members in a sorted set, by score, with scores ordered from high to low.
|
RedisFuture<List<V>> |
zrevrangebyscore(K key,
String max,
String min)
Return a range of members in a sorted set, by score, with scores ordered from high to low.
|
RedisFuture<List<V>> |
zrevrangebyscore(K key,
String max,
String min,
long offset,
long count)
Return a range of members in a sorted set, by score, with scores ordered from high to low.
|
RedisFuture<Long> |
zrevrangebyscore(ValueStreamingChannel<V> channel,
K key,
double max,
double min)
Stream over a range of members in a sorted set, by score, with scores ordered from high to low.
|
RedisFuture<Long> |
zrevrangebyscore(ValueStreamingChannel<V> channel,
K key,
double max,
double min,
long offset,
long count)
Stream over a range of members in a sorted set, by score, with scores ordered from high to low.
|
RedisFuture<Long> |
zrevrangebyscore(ValueStreamingChannel<V> channel,
K key,
Range<? extends Number> range)
Stream over a range of members in a sorted set, by score, with scores ordered from high to low.
|
RedisFuture<Long> |
zrevrangebyscore(ValueStreamingChannel<V> channel,
K key,
Range<? extends Number> range,
Limit limit)
Stream over a range of members in a sorted set, by score, with scores ordered from high to low.
|
RedisFuture<Long> |
zrevrangebyscore(ValueStreamingChannel<V> channel,
K key,
String max,
String min)
Stream over a range of members in a sorted set, by score, with scores ordered from high to low.
|
RedisFuture<Long> |
zrevrangebyscore(ValueStreamingChannel<V> channel,
K key,
String max,
String min,
long offset,
long count)
Stream over a range of members in a sorted set, by score, with scores ordered from high to low.
|
RedisFuture<List<ScoredValue<V>>> |
zrevrangebyscoreWithScores(K key,
double max,
double min)
Return a range of members with scores in a sorted set, by score, with scores ordered from high to low.
|
RedisFuture<List<ScoredValue<V>>> |
zrevrangebyscoreWithScores(K key,
double max,
double min,
long offset,
long count)
Return a range of members with scores in a sorted set, by score, with scores ordered from high to low.
|
RedisFuture<List<ScoredValue<V>>> |
zrevrangebyscoreWithScores(K key,
Range<? extends Number> range)
Return a range of members with scores in a sorted set, by score, with scores ordered from high to low.
|
RedisFuture<List<ScoredValue<V>>> |
zrevrangebyscoreWithScores(K key,
Range<? extends Number> range,
Limit limit)
Return a range of members with scores in a sorted set, by score, with scores ordered from high to low.
|
RedisFuture<List<ScoredValue<V>>> |
zrevrangebyscoreWithScores(K key,
String max,
String min)
Return a range of members with scores in a sorted set, by score, with scores ordered from high to low.
|
RedisFuture<List<ScoredValue<V>>> |
zrevrangebyscoreWithScores(K key,
String max,
String min,
long offset,
long count)
Return a range of members with scores in a sorted set, by score, with scores ordered from high to low.
|
RedisFuture<Long> |
zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
double max,
double min)
Stream over a range of members with scores in a sorted set, by score, with scores ordered from high to low.
|
RedisFuture<Long> |
zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
double max,
double min,
long offset,
long count)
Stream over a range of members with scores in a sorted set, by score, with scores ordered from high to low.
|
RedisFuture<Long> |
zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
Range<? extends Number> range)
Stream over a range of members with scores in a sorted set, by score, with scores ordered from high to low.
|
RedisFuture<Long> |
zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
Range<? extends Number> range,
Limit limit)
Stream over a range of members with scores in a sorted set, by score, with scores ordered from high to low.
|
RedisFuture<Long> |
zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
String max,
String min)
Stream over a range of members with scores in a sorted set, by score, with scores ordered from high to low.
|
RedisFuture<Long> |
zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
String max,
String min,
long offset,
long count)
Stream over a range of members with scores in a sorted set, by score, with scores ordered from high to low.
|
RedisFuture<Long> |
zrevrangestore(K dstKey,
K srcKey,
Range<Long> range)
Get the specified range of elements ordered from high to low in the sorted set stored at
srcKey and stores the
result in the dstKey destination key. |
RedisFuture<Long> |
zrevrangestorebylex(K dstKey,
K srcKey,
Range<? extends V> range,
Limit limit)
Get the lexicographical range ordered from high to low of elements in the sorted set stored at
srcKey and stores
the result in the dstKey destination key. |
RedisFuture<Long> |
zrevrangestorebyscore(K dstKey,
K srcKey,
Range<? extends Number> range,
Limit limit)
Get the specified range of elements in the sorted set stored at srcKey with scores ordered from high to low and
stores the result in the {@code dstKey} destination key.
|
RedisFuture<List<ScoredValue<V>>> |
zrevrangeWithScores(K key,
long start,
long stop)
Return a range of members with scores in a sorted set, by index, with scores ordered from high to low.
|
RedisFuture<Long> |
zrevrangeWithScores(ScoredValueStreamingChannel<V> channel,
K key,
long start,
long stop)
Stream over a range of members with scores in a sorted set, by index, with scores ordered from high to low.
|
RedisFuture<Long> |
zrevrank(K key,
V member)
Determine the index of a member in a sorted set, with scores ordered from high to low.
|
RedisFuture<ScoredValueScanCursor<V>> |
zscan(K key)
Incrementally iterate sorted sets elements and associated scores.
|
RedisFuture<ScoredValueScanCursor<V>> |
zscan(K key,
ScanArgs scanArgs)
Incrementally iterate sorted sets elements and associated scores.
|
RedisFuture<ScoredValueScanCursor<V>> |
zscan(K key,
ScanCursor scanCursor)
Incrementally iterate sorted sets elements and associated scores.
|
RedisFuture<ScoredValueScanCursor<V>> |
zscan(K key,
ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate sorted sets elements and associated scores.
|
RedisFuture<StreamScanCursor> |
zscan(ScoredValueStreamingChannel<V> channel,
K key)
Incrementally iterate sorted sets elements and associated scores.
|
RedisFuture<StreamScanCursor> |
zscan(ScoredValueStreamingChannel<V> channel,
K key,
ScanArgs scanArgs)
Incrementally iterate sorted sets elements and associated scores.
|
RedisFuture<StreamScanCursor> |
zscan(ScoredValueStreamingChannel<V> channel,
K key,
ScanCursor scanCursor)
Incrementally iterate sorted sets elements and associated scores.
|
RedisFuture<StreamScanCursor> |
zscan(ScoredValueStreamingChannel<V> channel,
K key,
ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate sorted sets elements and associated scores.
|
RedisFuture<Double> |
zscore(K key,
V member)
Get the score associated with the given member in a sorted set.
|
RedisFuture<List<V>> |
zunion(K... keys)
Add multiple sorted sets and returns the resulting sorted set.
|
RedisFuture<List<V>> |
zunion(ZAggregateArgs aggregateArgs,
K... keys)
Add multiple sorted sets and returns the resulting sorted set.
|
RedisFuture<Long> |
zunionstore(K destination,
K... keys)
Add multiple sorted sets and store the resulting sorted set in a new key.
|
RedisFuture<Long> |
zunionstore(K destination,
ZStoreArgs zStoreArgs,
K... keys)
Add multiple sorted sets and store the resulting sorted set in a new key.
|
RedisFuture<List<ScoredValue<V>>> |
zunionWithScores(K... keys)
Add multiple sorted sets and returns the resulting sorted set.
|
RedisFuture<List<ScoredValue<V>>> |
zunionWithScores(ZAggregateArgs aggregateArgs,
K... keys)
Add multiple sorted sets and returns the resulting sorted set.
|
public AbstractRedisAsyncCommands(StatefulConnection<K,V> connection, RedisCodec<K,V> codec)
connection
- the connection to operate oncodec
- the codec for command encodingpublic RedisFuture<Set<AclCategory>> aclCat()
RedisAclAsyncCommands
aclCat
in interface RedisAclAsyncCommands<K,V>
public RedisFuture<Set<CommandType>> aclCat(AclCategory category)
RedisAclAsyncCommands
aclCat
in interface RedisAclAsyncCommands<K,V>
category
- the specified categorypublic RedisFuture<Long> aclDeluser(String... usernames)
RedisAclAsyncCommands
aclDeluser
in interface RedisAclAsyncCommands<K,V>
usernames
- the specified usernamespublic RedisFuture<String> aclDryRun(String username, String command, String... args)
RedisAclAsyncCommands
aclDryRun
in interface RedisAclAsyncCommands<K,V>
username
- the specified usernamecommand
- the specified commandargs
- the specified args of commandpublic RedisFuture<String> aclDryRun(String username, RedisCommand<K,V,?> command)
RedisAclAsyncCommands
aclDryRun
in interface RedisAclAsyncCommands<K,V>
username
- the specified usernamecommand
- the specified command to inspectpublic RedisFuture<String> aclGenpass()
RedisAclAsyncCommands
aclGenpass
in interface RedisAclAsyncCommands<K,V>
public RedisFuture<String> aclGenpass(int bits)
RedisAclAsyncCommands
aclGenpass
in interface RedisAclAsyncCommands<K,V>
bits
- amount of bitspublic RedisFuture<List<Object>> aclGetuser(String username)
RedisAclAsyncCommands
aclGetuser
in interface RedisAclAsyncCommands<K,V>
username
- the specified usernamepublic RedisFuture<List<String>> aclList()
RedisAclAsyncCommands
aclList
in interface RedisAclAsyncCommands<K,V>
public RedisFuture<String> aclLoad()
RedisAclAsyncCommands
aclLoad
in interface RedisAclAsyncCommands<K,V>
public RedisFuture<List<Map<String,Object>>> aclLog()
RedisAclAsyncCommands
aclLog
in interface RedisAclAsyncCommands<K,V>
public RedisFuture<List<Map<String,Object>>> aclLog(int count)
RedisAclAsyncCommands
aclLog
in interface RedisAclAsyncCommands<K,V>
count
- max count of eventspublic RedisFuture<String> aclLogReset()
RedisAclAsyncCommands
aclLogReset
in interface RedisAclAsyncCommands<K,V>
public RedisFuture<String> aclSave()
RedisAclAsyncCommands
aclSave
in interface RedisAclAsyncCommands<K,V>
public RedisFuture<String> aclSetuser(String username, AclSetuserArgs args)
RedisAclAsyncCommands
aclSetuser
in interface RedisAclAsyncCommands<K,V>
username
- the specified usernameargs
- rulespublic RedisFuture<List<String>> aclUsers()
RedisAclAsyncCommands
aclUsers
in interface RedisAclAsyncCommands<K,V>
public RedisFuture<String> aclWhoami()
RedisAclAsyncCommands
aclWhoami
in interface RedisAclAsyncCommands<K,V>
public RedisFuture<Long> append(K key, V value)
RedisStringAsyncCommands
append
in interface RedisStringAsyncCommands<K,V>
key
- the key.value
- the value.public RedisFuture<String> asking()
RedisClusterAsyncCommands
-ASK
redirection. The client should issue ASKING
before to
actually send the command to the target instance. See the Redis Cluster specification for more information.asking
in interface RedisClusterAsyncCommands<K,V>
public RedisFuture<String> auth(CharSequence password)
RedisClusterAsyncCommands
auth
in interface RedisClusterAsyncCommands<K,V>
password
- the passwordpublic RedisFuture<String> auth(char[] password)
public RedisFuture<String> auth(String username, CharSequence password)
RedisClusterAsyncCommands
auth
in interface RedisClusterAsyncCommands<K,V>
username
- the usernamepassword
- the passwordpublic RedisFuture<String> auth(String username, char[] password)
public RedisFuture<String> bgrewriteaof()
RedisServerAsyncCommands
bgrewriteaof
in interface RedisServerAsyncCommands<K,V>
OK
.public RedisFuture<String> bgsave()
RedisServerAsyncCommands
bgsave
in interface RedisServerAsyncCommands<K,V>
public RedisFuture<Long> bitcount(K key)
RedisStringAsyncCommands
bitcount
in interface RedisStringAsyncCommands<K,V>
key
- the key.public RedisFuture<Long> bitcount(K key, long start, long end)
RedisStringAsyncCommands
bitcount
in interface RedisStringAsyncCommands<K,V>
key
- the key.start
- the start.end
- the end.public RedisFuture<List<Long>> bitfield(K key, BitFieldArgs bitFieldArgs)
RedisStringAsyncCommands
BITFIELD
with its subcommands.bitfield
in interface RedisStringAsyncCommands<K,V>
key
- the key.bitFieldArgs
- the args containing subcommands, must not be null
.public RedisFuture<Long> bitopAnd(K destination, K... keys)
RedisStringAsyncCommands
bitopAnd
in interface RedisStringAsyncCommands<K,V>
destination
- result key of the operation.keys
- operation input key names.public RedisFuture<Long> bitopNot(K destination, K source)
RedisStringAsyncCommands
bitopNot
in interface RedisStringAsyncCommands<K,V>
destination
- result key of the operation.source
- operation input key names.public RedisFuture<Long> bitopOr(K destination, K... keys)
RedisStringAsyncCommands
bitopOr
in interface RedisStringAsyncCommands<K,V>
destination
- result key of the operation.keys
- operation input key names.public RedisFuture<Long> bitopXor(K destination, K... keys)
RedisStringAsyncCommands
bitopXor
in interface RedisStringAsyncCommands<K,V>
destination
- result key of the operation.keys
- operation input key names.public RedisFuture<Long> bitpos(K key, boolean state)
RedisStringAsyncCommands
bitpos
in interface RedisStringAsyncCommands<K,V>
key
- the key.state
- the state.BITPOS key 0
will return 24, since up to bit 23 all the bits are 1.
Basically the function consider the right of the string as padded with zeros if you look for clear bits and
specify no range or the start argument only.public RedisFuture<Long> bitpos(K key, boolean state, long start)
RedisStringAsyncCommands
bitpos
in interface RedisStringAsyncCommands<K,V>
key
- the key.state
- the bit type: long.start
- the start type: long.BITPOS key 0
will return 24, since up to bit 23 all the bits are 1.
Basically the function consider the right of the string as padded with zeros if you look for clear bits and
specify no range or the start argument only.public RedisFuture<Long> bitpos(K key, boolean state, long start, long end)
RedisStringAsyncCommands
bitpos
in interface RedisStringAsyncCommands<K,V>
key
- the key.state
- the bit type: long.start
- the start type: long.end
- the end type: long.BITPOS key 0
will return 24, since up to bit 23 all the bits are 1.
Basically the function consider the right of the string as padded with zeros if you look for clear bits and
specify no range or the start argument only.
However this behavior changes if you are looking for clear bits and specify a range with both
start and end. If no clear bit is found in the specified range, the function
returns -1 as the user specified a clear range and there are no 0 bits in that range.public RedisFuture<V> blmove(K source, K destination, LMoveArgs args, long timeout)
RedisListAsyncCommands
blmove
in interface RedisListAsyncCommands<K,V>
source
- the source key.destination
- the destination type: key.args
- command arguments to configure source and destination directions.timeout
- the timeout in seconds.public RedisFuture<V> blmove(K source, K destination, LMoveArgs args, double timeout)
RedisListAsyncCommands
blmove
in interface RedisListAsyncCommands<K,V>
source
- the source key.destination
- the destination type: key.args
- command arguments to configure source and destination directions.timeout
- the timeout in seconds.public RedisFuture<KeyValue<K,List<V>>> blmpop(long timeout, LMPopArgs args, K... keys)
RedisListAsyncCommands
blmpop
in interface RedisListAsyncCommands<K,V>
timeout
- the timeout in seconds.args
- the additional command arguments.keys
- the keys.null
when key
does not exist or the timeout was
exceeded.public RedisFuture<KeyValue<K,List<V>>> blmpop(double timeout, LMPopArgs args, K... keys)
RedisListAsyncCommands
blmpop
in interface RedisListAsyncCommands<K,V>
timeout
- the timeout in seconds.args
- the additional command arguments.keys
- the keys.null
when key
does not exist or the timeout was
exceeded.public RedisFuture<KeyValue<K,V>> blpop(long timeout, K... keys)
RedisListAsyncCommands
blpop
in interface RedisListAsyncCommands<K,V>
timeout
- the timeout in seconds.keys
- the keys.null
multi-bulk when no element could be popped and the timeout expired. A two-element multi-bulk with
the first element being the name of the key where an element was popped and the second element being the value of
the popped element.public RedisFuture<KeyValue<K,V>> blpop(double timeout, K... keys)
RedisListAsyncCommands
blpop
in interface RedisListAsyncCommands<K,V>
timeout
- the timeout in seconds.keys
- the keys.null
multi-bulk when no element could be popped and the timeout expired. A two-element multi-bulk with
the first element being the name of the key where an element was popped and the second element being the value of
the popped element.public RedisFuture<KeyValue<K,V>> brpop(long timeout, K... keys)
RedisListAsyncCommands
brpop
in interface RedisListAsyncCommands<K,V>
timeout
- the timeout in seconds.keys
- the keys.null
multi-bulk when no element could be popped and the timeout expired. A two-element multi-bulk with
the first element being the name of the key where an element was popped and the second element being the value of
the popped element.public RedisFuture<KeyValue<K,V>> brpop(double timeout, K... keys)
RedisListAsyncCommands
brpop
in interface RedisListAsyncCommands<K,V>
timeout
- the timeout in seconds.keys
- the keys.null
multi-bulk when no element could be popped and the timeout expired. A two-element multi-bulk with
the first element being the name of the key where an element was popped and the second element being the value of
the popped element.public RedisFuture<V> brpoplpush(long timeout, K source, K destination)
RedisListAsyncCommands
brpoplpush
in interface RedisListAsyncCommands<K,V>
timeout
- the timeout in seconds.source
- the source key.destination
- the destination type: key.source
and pushed to destination
. If
timeout
is reached, a.public RedisFuture<V> brpoplpush(double timeout, K source, K destination)
RedisListAsyncCommands
brpoplpush
in interface RedisListAsyncCommands<K,V>
timeout
- the timeout in seconds.source
- the source key.destination
- the destination type: key.source
and pushed to destination
. If
timeout
is reached, a.public RedisFuture<String> clientCaching(boolean enabled)
RedisServerAsyncCommands
clientCaching
in interface RedisServerAsyncCommands<K,V>
enabled
- true
to enable key tracking.OK
.public RedisFuture<K> clientGetname()
RedisServerAsyncCommands
clientGetname
in interface RedisServerAsyncCommands<K,V>
public RedisFuture<Long> clientGetredir()
RedisServerAsyncCommands
clientGetredir
in interface RedisServerAsyncCommands<K,V>
public RedisFuture<String> clientKill(String addr)
RedisServerAsyncCommands
clientKill
in interface RedisServerAsyncCommands<K,V>
addr
- ip:port.OK
if the connection exists and has been closed.public RedisFuture<Long> clientKill(KillArgs killArgs)
RedisServerAsyncCommands
killArgs
.clientKill
in interface RedisServerAsyncCommands<K,V>
killArgs
- args for the kill operation.public RedisFuture<String> clientList()
RedisServerAsyncCommands
clientList
in interface RedisServerAsyncCommands<K,V>
public RedisFuture<String> clientNoEvict(boolean on)
RedisServerAsyncCommands
clientNoEvict
in interface RedisServerAsyncCommands<K,V>
on
- true
will turn eviction mode on, and false
will turn it off.OK
.public RedisFuture<Long> clientId()
RedisServerAsyncCommands
clientId
in interface RedisServerAsyncCommands<K,V>
public RedisFuture<String> clientPause(long timeout)
RedisServerAsyncCommands
clientPause
in interface RedisServerAsyncCommands<K,V>
timeout
- the timeout value in milliseconds.public RedisFuture<String> clientSetname(K name)
RedisServerAsyncCommands
clientSetname
in interface RedisServerAsyncCommands<K,V>
name
- the client name.OK
if the connection name was successfully set.public RedisFuture<String> clientTracking(TrackingArgs args)
RedisServerAsyncCommands
clientTracking
in interface RedisServerAsyncCommands<K,V>
args
- for the CLIENT TRACKING operation.OK
.public RedisFuture<Long> clientUnblock(long id, UnblockType type)
RedisServerAsyncCommands
clientUnblock
in interface RedisServerAsyncCommands<K,V>
id
- the client id.type
- unblock type.public RedisFuture<String> clusterAddSlots(int... slots)
RedisClusterAsyncCommands
clusterAddSlots
in interface RedisClusterAsyncCommands<K,V>
slots
- one or more slots from 0 to 16384public RedisFuture<String> clusterAddSlotsRange(Range<Integer>... ranges)
RedisClusterAsyncCommands
clusterAddSlotsRange
in interface RedisClusterAsyncCommands<K,V>
ranges
- a list of slot ranges (specified by start and end slots)public RedisFuture<String> clusterBumpepoch()
RedisClusterAsyncCommands
clusterBumpepoch
in interface RedisClusterAsyncCommands<K,V>
public RedisFuture<Long> clusterCountFailureReports(String nodeId)
RedisClusterAsyncCommands
clusterCountFailureReports
in interface RedisClusterAsyncCommands<K,V>
nodeId
- the node idpublic RedisFuture<Long> clusterCountKeysInSlot(int slot)
RedisClusterAsyncCommands
slot
.clusterCountKeysInSlot
in interface RedisClusterAsyncCommands<K,V>
slot
- the slotpublic RedisFuture<String> clusterDelSlots(int... slots)
RedisClusterAsyncCommands
clusterDelSlots
in interface RedisClusterAsyncCommands<K,V>
slots
- one or more slots from 0 to 16384public RedisFuture<String> clusterDelSlotsRange(Range<Integer>... ranges)
RedisClusterAsyncCommands
clusterDelSlotsRange
in interface RedisClusterAsyncCommands<K,V>
ranges
- a list of slot ranges (specified by start and end slots)public RedisFuture<String> clusterFailover(boolean force)
RedisClusterAsyncCommands
clusterFailover
in interface RedisClusterAsyncCommands<K,V>
force
- do not coordinate with master if true
public RedisFuture<String> clusterFailover(boolean force, boolean takeOver)
RedisClusterAsyncCommands
clusterFailover
in interface RedisClusterAsyncCommands<K,V>
force
- do not coordinate with master if true
takeOver
- do not coordinate with the rest of the cluster if true
force will take precedence over takeOver
if both are set.public RedisFuture<String> clusterFlushslots()
RedisClusterAsyncCommands
clusterFlushslots
in interface RedisClusterAsyncCommands<K,V>
public RedisFuture<String> clusterForget(String nodeId)
RedisClusterAsyncCommands
clusterForget
in interface RedisClusterAsyncCommands<K,V>
nodeId
- the node Idpublic RedisFuture<List<K>> clusterGetKeysInSlot(int slot, int count)
RedisClusterAsyncCommands
slot
.clusterGetKeysInSlot
in interface RedisClusterAsyncCommands<K,V>
slot
- the slotcount
- maximal number of keyspublic RedisFuture<String> clusterInfo()
RedisClusterAsyncCommands
clusterInfo
in interface RedisClusterAsyncCommands<K,V>
public RedisFuture<Long> clusterKeyslot(K key)
RedisClusterAsyncCommands
SlotHash.getSlot(byte[])
. If not, call Houston and report that we've got a problem.clusterKeyslot
in interface RedisClusterAsyncCommands<K,V>
key
- the key.public RedisFuture<String> clusterMeet(String ip, int port)
RedisClusterAsyncCommands
clusterMeet
in interface RedisClusterAsyncCommands<K,V>
ip
- IP address of the hostport
- port number.public RedisFuture<String> clusterMyId()
RedisClusterAsyncCommands
clusterMyId
in interface RedisClusterAsyncCommands<K,V>
public RedisFuture<String> clusterNodes()
RedisClusterAsyncCommands
ClusterPartitionParser.parse(java.util.List<java.lang.Object>)
clusterNodes
in interface RedisClusterAsyncCommands<K,V>
public RedisFuture<String> clusterReplicate(String nodeId)
RedisClusterAsyncCommands
nodeId
.clusterReplicate
in interface RedisClusterAsyncCommands<K,V>
nodeId
- master node idpublic RedisFuture<List<String>> clusterReplicas(String nodeId)
RedisClusterAsyncCommands
nodeId
. Can be parsed using
ClusterPartitionParser.parse(java.util.List<java.lang.Object>)
clusterReplicas
in interface RedisClusterAsyncCommands<K,V>
nodeId
- node id of the master nodeRedisClusterAsyncCommands.clusterNodes()
but one line per replica.public RedisFuture<String> clusterReset(boolean hard)
RedisClusterAsyncCommands
clusterReset
in interface RedisClusterAsyncCommands<K,V>
hard
- true
for hard reset. Generates a new nodeId and currentEpoch/configEpoch are set to 0public RedisFuture<String> clusterSaveconfig()
RedisClusterAsyncCommands
clusterSaveconfig
in interface RedisClusterAsyncCommands<K,V>
OK
or an error if the operation fails.public RedisFuture<String> clusterSetConfigEpoch(long configEpoch)
RedisClusterAsyncCommands
clusterSetConfigEpoch
in interface RedisClusterAsyncCommands<K,V>
configEpoch
- the config epochOK
or an error if the operation fails.public RedisFuture<String> clusterSetSlotImporting(int slot, String nodeId)
RedisClusterAsyncCommands
nodeId
.clusterSetSlotImporting
in interface RedisClusterAsyncCommands<K,V>
slot
- the slotnodeId
- the id of the node is the master of the slotpublic RedisFuture<String> clusterSetSlotMigrating(int slot, String nodeId)
RedisClusterAsyncCommands
nodeId
. The slot must be handled by
the current node in order to be migrated.clusterSetSlotMigrating
in interface RedisClusterAsyncCommands<K,V>
slot
- the slotnodeId
- the id of the node is targeted to become the master for the slotpublic RedisFuture<String> clusterSetSlotNode(int slot, String nodeId)
RedisClusterAsyncCommands
nodeId
clusterSetSlotNode
in interface RedisClusterAsyncCommands<K,V>
slot
- the slotnodeId
- the id of the node that will become the master for the slotpublic RedisFuture<String> clusterSetSlotStable(int slot)
RedisClusterAsyncCommands
clusterSetSlotStable
in interface RedisClusterAsyncCommands<K,V>
slot
- the slotpublic RedisFuture<List<Object>> clusterShards()
RedisClusterAsyncCommands
clusterShards
in interface RedisClusterAsyncCommands<K,V>
public RedisFuture<List<String>> clusterSlaves(String nodeId)
RedisClusterAsyncCommands
nodeId
. Can be parsed using
ClusterPartitionParser.parse(java.util.List<java.lang.Object>)
clusterSlaves
in interface RedisClusterAsyncCommands<K,V>
nodeId
- node id of the master nodeRedisClusterAsyncCommands.clusterNodes()
but one line per replica.public RedisFuture<List<Object>> clusterSlots()
RedisClusterAsyncCommands
clusterSlots
in interface RedisClusterAsyncCommands<K,V>
public RedisFuture<List<Object>> command()
RedisServerAsyncCommands
command
in interface RedisServerAsyncCommands<K,V>
public RedisFuture<Long> commandCount()
RedisServerAsyncCommands
commandCount
in interface RedisServerAsyncCommands<K,V>
public RedisFuture<List<Object>> commandInfo(String... commands)
RedisServerAsyncCommands
commandInfo
in interface RedisServerAsyncCommands<K,V>
commands
- the commands to query for.public RedisFuture<List<Object>> commandInfo(CommandType... commands)
RedisServerAsyncCommands
commandInfo
in interface RedisServerAsyncCommands<K,V>
commands
- the commands to query for.public RedisFuture<Map<String,String>> configGet(String parameter)
RedisServerAsyncCommands
configGet
in interface RedisServerAsyncCommands<K,V>
parameter
- name of the parameter.public RedisFuture<Map<String,String>> configGet(String... parameters)
RedisServerAsyncCommands
configGet
in interface RedisServerAsyncCommands<K,V>
parameters
- patterns names of Redis server's configuration.public RedisFuture<String> configResetstat()
RedisServerAsyncCommands
configResetstat
in interface RedisServerAsyncCommands<K,V>
OK
.public RedisFuture<String> configRewrite()
RedisServerAsyncCommands
configRewrite
in interface RedisServerAsyncCommands<K,V>
OK
when the configuration was rewritten properly. Otherwise an error is
returned.public RedisFuture<String> configSet(String parameter, String value)
RedisServerAsyncCommands
configSet
in interface RedisServerAsyncCommands<K,V>
parameter
- the parameter name.value
- the parameter value.OK
when the configuration was set properly. Otherwise an error is returned.public RedisFuture<String> configSet(Map<String,String> kvs)
RedisServerAsyncCommands
configSet
in interface RedisServerAsyncCommands<K,V>
kvs
- the parameter name and value.OK
when the configuration was set properly. Otherwise an error is returned.public RedisFuture<Long> dbsize()
RedisServerAsyncCommands
dbsize
in interface RedisServerAsyncCommands<K,V>
public RedisFuture<String> debugCrashAndRecover(Long delay)
RedisServerAsyncCommands
debugCrashAndRecover
in interface RedisServerAsyncCommands<K,V>
delay
- optional delay in milliseconds.public RedisFuture<String> debugHtstats(int db)
RedisServerAsyncCommands
debugHtstats
in interface RedisServerAsyncCommands<K,V>
db
- the database number.public RedisFuture<String> debugObject(K key)
RedisServerAsyncCommands
debugObject
in interface RedisServerAsyncCommands<K,V>
key
- the key.public void debugOom()
RedisServerAsyncCommands
debugOom
in interface RedisServerAsyncCommands<K,V>
public RedisFuture<String> debugReload()
RedisServerAsyncCommands
debugReload
in interface RedisServerAsyncCommands<K,V>
public RedisFuture<String> debugRestart(Long delay)
RedisServerAsyncCommands
debugRestart
in interface RedisServerAsyncCommands<K,V>
delay
- optional delay in milliseconds.public RedisFuture<String> debugSdslen(K key)
RedisServerAsyncCommands
debugSdslen
in interface RedisServerAsyncCommands<K,V>
key
- the key.public void debugSegfault()
RedisServerAsyncCommands
debugSegfault
in interface RedisServerAsyncCommands<K,V>
public RedisFuture<Long> decr(K key)
RedisStringAsyncCommands
decr
in interface RedisStringAsyncCommands<K,V>
key
- the key.key
after the decrement.public RedisFuture<Long> decrby(K key, long amount)
RedisStringAsyncCommands
decrby
in interface RedisStringAsyncCommands<K,V>
key
- the key.amount
- the decrement type: long.key
after the decrement.public RedisFuture<Long> del(K... keys)
RedisKeyAsyncCommands
del
in interface RedisKeyAsyncCommands<K,V>
keys
- the keys.public RedisFuture<Long> del(Iterable<K> keys)
public String digest(String script)
RedisScriptingAsyncCommands
digest
in interface RedisScriptingAsyncCommands<K,V>
script
- script content.public String digest(byte[] script)
RedisScriptingAsyncCommands
digest
in interface RedisScriptingAsyncCommands<K,V>
script
- script content.public RedisFuture<String> discard()
RedisTransactionalAsyncCommands
discard
in interface RedisTransactionalAsyncCommands<K,V>
OK
.public <T> RedisFuture<T> dispatch(ProtocolKeyword type, CommandOutput<K,V,T> output)
BaseRedisAsyncCommands
dispatch
in interface BaseRedisAsyncCommands<K,V>
T
- response type.type
- the command, must not be null
.output
- the command output, must not be null
.public <T> RedisFuture<T> dispatch(ProtocolKeyword type, CommandOutput<K,V,T> output, CommandArgs<K,V> args)
BaseRedisAsyncCommands
dispatch
in interface BaseRedisAsyncCommands<K,V>
T
- response type.type
- the command, must not be null
.output
- the command output, must not be null
.args
- the command arguments, must not be null
.protected <T> RedisFuture<T> dispatch(CommandType type, CommandOutput<K,V,T> output)
protected <T> RedisFuture<T> dispatch(CommandType type, CommandOutput<K,V,T> output, CommandArgs<K,V> args)
public <T> AsyncCommand<K,V,T> dispatch(RedisCommand<K,V,T> cmd)
public RedisFuture<byte[]> dump(K key)
RedisKeyAsyncCommands
dump
in interface RedisKeyAsyncCommands<K,V>
key
- the key.public RedisFuture<V> echo(V msg)
BaseRedisAsyncCommands
echo
in interface BaseRedisAsyncCommands<K,V>
msg
- the message type: value.public <T> RedisFuture<T> eval(String script, ScriptOutputType type, K... keys)
RedisScriptingAsyncCommands
eval
in interface RedisScriptingAsyncCommands<K,V>
T
- expected return type.script
- Lua 5.1 script.type
- output type.keys
- key names.public <T> RedisFuture<T> eval(byte[] script, ScriptOutputType type, K... keys)
RedisScriptingAsyncCommands
eval
in interface RedisScriptingAsyncCommands<K,V>
T
- expected return type.script
- Lua 5.1 script.type
- output type.keys
- key names.public <T> RedisFuture<T> eval(String script, ScriptOutputType type, K[] keys, V... values)
RedisScriptingAsyncCommands
eval
in interface RedisScriptingAsyncCommands<K,V>
T
- expected return type.script
- Lua 5.1 script.type
- the type.keys
- the keys.values
- the values.public <T> RedisFuture<T> eval(byte[] script, ScriptOutputType type, K[] keys, V... values)
RedisScriptingAsyncCommands
eval
in interface RedisScriptingAsyncCommands<K,V>
T
- expected return type.script
- Lua 5.1 script.type
- the type.keys
- the keys.values
- the values.public <T> RedisFuture<T> evalReadOnly(byte[] script, ScriptOutputType type, K[] keys, V... values)
RedisScriptingAsyncCommands
evalReadOnly
in interface RedisScriptingAsyncCommands<K,V>
T
- expected return type.script
- Lua 5.1 script.type
- the type.keys
- the keys.values
- the values.public <T> RedisFuture<T> evalsha(String digest, ScriptOutputType type, K... keys)
RedisScriptingAsyncCommands
evalsha
in interface RedisScriptingAsyncCommands<K,V>
T
- expected return type.digest
- SHA1 of the script.type
- the type.keys
- the keys.public <T> RedisFuture<T> evalsha(String digest, ScriptOutputType type, K[] keys, V... values)
RedisScriptingAsyncCommands
evalsha
in interface RedisScriptingAsyncCommands<K,V>
T
- expected return type.digest
- SHA1 of the script.type
- the type.keys
- the keys.values
- the values.public <T> RedisFuture<T> evalshaReadOnly(String digest, ScriptOutputType type, K[] keys, V... values)
RedisScriptingAsyncCommands
evalshaReadOnly
in interface RedisScriptingAsyncCommands<K,V>
T
- expected return type.digest
- SHA1 of the script.type
- the type.keys
- the keys.values
- the values.public RedisFuture<TransactionResult> exec()
RedisTransactionalAsyncCommands
exec
in interface RedisTransactionalAsyncCommands<K,V>
WATCH
, EXEC
can return a discarded
TransactionResult
.TransactionResult.wasDiscarded()
public RedisFuture<Long> exists(K... keys)
RedisKeyAsyncCommands
exists
in interface RedisKeyAsyncCommands<K,V>
keys
- the keys.public RedisFuture<Long> exists(Iterable<K> keys)
public RedisFuture<Boolean> expire(K key, long seconds)
RedisKeyAsyncCommands
expire
in interface RedisKeyAsyncCommands<K,V>
key
- the key.seconds
- the seconds type: long.true
if the timeout was set. false
if key
does not
exist or the timeout could not be set.public RedisFuture<Boolean> expire(K key, long seconds, ExpireArgs expireArgs)
RedisKeyAsyncCommands
expire
in interface RedisKeyAsyncCommands<K,V>
key
- the key.seconds
- the seconds type: long.expireArgs
- the expire arguments.true
if the timeout was set. false
if key
does not
exist or the timeout could not be set.public RedisFuture<Boolean> expire(K key, Duration seconds)
RedisKeyAsyncCommands
expire
in interface RedisKeyAsyncCommands<K,V>
key
- the key.seconds
- the seconds.true
if the timeout was set. false
if key
does not
exist or the timeout could not be set.public RedisFuture<Boolean> expire(K key, Duration seconds, ExpireArgs expireArgs)
RedisKeyAsyncCommands
expire
in interface RedisKeyAsyncCommands<K,V>
key
- the key.seconds
- the seconds.expireArgs
- the expire arguments.true
if the timeout was set. false
if key
does not
exist or the timeout could not be set.public RedisFuture<Boolean> expireat(K key, long timestamp)
RedisKeyAsyncCommands
expireat
in interface RedisKeyAsyncCommands<K,V>
key
- the key.timestamp
- the timestamp type: posix time.true
if the timeout was set. false
if key
does not
exist or the timeout could not be set (see: EXPIRE
).public RedisFuture<Boolean> expireat(K key, long timestamp, ExpireArgs expireArgs)
RedisKeyAsyncCommands
expireat
in interface RedisKeyAsyncCommands<K,V>
key
- the key.timestamp
- the timestamp type: posix time.expireArgs
- the expire arguments.true
if the timeout was set. false
if key
does not
exist or the timeout could not be set (see: EXPIRE
).public RedisFuture<Boolean> expireat(K key, Date timestamp)
RedisKeyAsyncCommands
expireat
in interface RedisKeyAsyncCommands<K,V>
key
- the key.timestamp
- the timestamp type: posix time.true
if the timeout was set. false
if key
does not
exist or the timeout could not be set (see: EXPIRE
).public RedisFuture<Boolean> expireat(K key, Date timestamp, ExpireArgs expireArgs)
RedisKeyAsyncCommands
expireat
in interface RedisKeyAsyncCommands<K,V>
key
- the key.timestamp
- the timestamp type: posix time.expireArgs
- the expire arguments.true
if the timeout was set. false
if key
does not
exist or the timeout could not be set (see: EXPIRE
).public RedisFuture<Boolean> expireat(K key, Instant timestamp)
RedisKeyAsyncCommands
expireat
in interface RedisKeyAsyncCommands<K,V>
key
- the key.timestamp
- the timestamp type: posix time.true
if the timeout was set. false
if key
does not
exist or the timeout could not be set (see: EXPIRE
).public RedisFuture<Boolean> expireat(K key, Instant timestamp, ExpireArgs expireArgs)
RedisKeyAsyncCommands
expireat
in interface RedisKeyAsyncCommands<K,V>
key
- the key.timestamp
- the timestamp type: posix time.expireArgs
- the expire arguments.true
if the timeout was set. false
if key
does not
exist or the timeout could not be set (see: EXPIRE
).public RedisFuture<Long> expiretime(K key)
RedisKeyAsyncCommands
expiretime
in interface RedisKeyAsyncCommands<K,V>
key
- the key.-1
if
the key exists but has no associated expiration time. The command returns -2
if the key does not exist.public void flushCommands()
BaseRedisAsyncCommands
flushCommands
in interface BaseRedisAsyncCommands<K,V>
public RedisFuture<String> flushall()
RedisServerAsyncCommands
flushall
in interface RedisServerAsyncCommands<K,V>
public RedisFuture<String> flushall(FlushMode flushMode)
RedisServerAsyncCommands
FlushMode
.flushall
in interface RedisServerAsyncCommands<K,V>
flushMode
- the flush mode (sync/async).public RedisFuture<String> flushallAsync()
RedisServerAsyncCommands
flushallAsync
in interface RedisServerAsyncCommands<K,V>
public RedisFuture<String> flushdb()
RedisServerAsyncCommands
flushdb
in interface RedisServerAsyncCommands<K,V>
public RedisFuture<String> flushdb(FlushMode flushMode)
RedisServerAsyncCommands
FlushMode
.flushdb
in interface RedisServerAsyncCommands<K,V>
flushMode
- the flush mode (sync/async).public RedisFuture<String> flushdbAsync()
RedisServerAsyncCommands
flushdbAsync
in interface RedisServerAsyncCommands<K,V>
public RedisFuture<Long> geoadd(K key, double longitude, double latitude, V member)
RedisGeoAsyncCommands
geoadd
in interface RedisGeoAsyncCommands<K,V>
key
- the key of the geo set.longitude
- the longitude coordinate according to WGS84.latitude
- the latitude coordinate according to WGS84.member
- the member to add.public RedisFuture<Long> geoadd(K key, double longitude, double latitude, V member, GeoAddArgs args)
RedisGeoAsyncCommands
geoadd
in interface RedisGeoAsyncCommands<K,V>
key
- the key of the geo set.longitude
- the longitude coordinate according to WGS84.latitude
- the latitude coordinate according to WGS84.member
- the member to add.args
- additional arguments.public RedisFuture<Long> geoadd(K key, Object... lngLatMember)
RedisGeoAsyncCommands
geoadd
in interface RedisGeoAsyncCommands<K,V>
key
- the key of the geo set.lngLatMember
- triplets of double longitude, double latitude and V member.public RedisFuture<Long> geoadd(K key, GeoValue<V>... values)
RedisGeoAsyncCommands
geoadd
in interface RedisGeoAsyncCommands<K,V>
key
- the key of the geo set.values
- GeoValue
values to add.public RedisFuture<Long> geoadd(K key, GeoAddArgs args, Object... lngLatMember)
RedisGeoAsyncCommands
geoadd
in interface RedisGeoAsyncCommands<K,V>
key
- the key of the geo set.args
- additional arguments.lngLatMember
- triplets of double longitude, double latitude and V member.public RedisFuture<Long> geoadd(K key, GeoAddArgs args, GeoValue<V>... values)
RedisGeoAsyncCommands
geoadd
in interface RedisGeoAsyncCommands<K,V>
key
- the key of the geo set.args
- additional arguments.values
- GeoValue
values to add.public RedisFuture<Double> geodist(K key, V from, V to, GeoArgs.Unit unit)
RedisGeoAsyncCommands
from
and to
. If one or more elements are missing null
is
returned. Default in meters by, otherwise according to unit
geodist
in interface RedisGeoAsyncCommands<K,V>
key
- the key of the geo set.from
- from member.to
- to member.unit
- distance unit.from
and to
. If one or more elements are missing null
is
returned.public RedisFuture<List<Value<String>>> geohash(K key, V... members)
RedisGeoAsyncCommands
geohash
in interface RedisGeoAsyncCommands<K,V>
key
- the key of the geo set.members
- the members.members
. Returns null
if a member is not found.public RedisFuture<List<GeoCoordinates>> geopos(K key, V... members)
RedisGeoAsyncCommands
members
.geopos
in interface RedisGeoAsyncCommands<K,V>
key
- the key of the geo set.members
- the members.GeoCoordinates
s representing the x,y position of each element specified in the arguments. For
missing elements null
is returned.public RedisFuture<Set<V>> georadius(K key, double longitude, double latitude, double distance, GeoArgs.Unit unit)
RedisGeoAsyncCommands
longitude
and latitude
.georadius
in interface RedisGeoAsyncCommands<K,V>
key
- the key of the geo set.longitude
- the longitude coordinate according to WGS84.latitude
- the latitude coordinate according to WGS84.distance
- radius distance.unit
- distance unit.public RedisFuture<List<GeoWithin<V>>> georadius(K key, double longitude, double latitude, double distance, GeoArgs.Unit unit, GeoArgs geoArgs)
RedisGeoAsyncCommands
longitude
and latitude
.georadius
in interface RedisGeoAsyncCommands<K,V>
key
- the key of the geo set.longitude
- the longitude coordinate according to WGS84.latitude
- the latitude coordinate according to WGS84.distance
- radius distance.unit
- distance unit.geoArgs
- args to control the result.GeoWithin
contains only fields which were requested by GeoArgs
.public RedisFuture<Long> georadius(K key, double longitude, double latitude, double distance, GeoArgs.Unit unit, GeoRadiusStoreArgs<K> geoRadiusStoreArgs)
RedisGeoAsyncCommands
RedisGeoAsyncCommands.georadius(Object, double, double, double, GeoArgs.Unit, GeoArgs)
query and store the results in a
sorted set.georadius
in interface RedisGeoAsyncCommands<K,V>
key
- the key of the geo set.longitude
- the longitude coordinate according to WGS84.latitude
- the latitude coordinate according to WGS84.distance
- radius distance.unit
- distance unit.geoRadiusStoreArgs
- args to store either the resulting elements with their distance or the resulting elements with
their locations a sorted set.protected RedisFuture<Set<V>> georadius_ro(K key, double longitude, double latitude, double distance, GeoArgs.Unit unit)
protected RedisFuture<List<GeoWithin<V>>> georadius_ro(K key, double longitude, double latitude, double distance, GeoArgs.Unit unit, GeoArgs geoArgs)
public RedisFuture<Set<V>> georadiusbymember(K key, V member, double distance, GeoArgs.Unit unit)
RedisGeoAsyncCommands
member
. The member itself is always contained in the
results.georadiusbymember
in interface RedisGeoAsyncCommands<K,V>
key
- the key of the geo set.member
- reference member.distance
- radius distance.unit
- distance unit.public RedisFuture<List<GeoWithin<V>>> georadiusbymember(K key, V member, double distance, GeoArgs.Unit unit, GeoArgs geoArgs)
RedisGeoAsyncCommands
member
. The member itself is always contained in the
results.georadiusbymember
in interface RedisGeoAsyncCommands<K,V>
key
- the key of the geo set.member
- reference member.distance
- radius distance.unit
- distance unit.geoArgs
- args to control the result.GeoWithin
contains only fields which were requested by GeoArgs
.public RedisFuture<Long> georadiusbymember(K key, V member, double distance, GeoArgs.Unit unit, GeoRadiusStoreArgs<K> geoRadiusStoreArgs)
RedisGeoAsyncCommands
RedisGeoAsyncCommands.georadiusbymember(Object, Object, double, GeoArgs.Unit, GeoArgs)
query and store the results in a
sorted set.georadiusbymember
in interface RedisGeoAsyncCommands<K,V>
key
- the key of the geo set.member
- reference member.distance
- radius distance.unit
- distance unit.geoRadiusStoreArgs
- args to store either the resulting elements with their distance or the resulting elements with
their locations a sorted set.protected RedisFuture<Set<V>> georadiusbymember_ro(K key, V member, double distance, GeoArgs.Unit unit)
protected RedisFuture<List<GeoWithin<V>>> georadiusbymember_ro(K key, V member, double distance, GeoArgs.Unit unit, GeoArgs geoArgs)
public RedisFuture<Set<V>> geosearch(K key, GeoSearch.GeoRef<K> reference, GeoSearch.GeoPredicate predicate)
RedisGeoAsyncCommands
reference
the search predicate
.
Use GeoSearch
to create reference and predicate objects.geosearch
in interface RedisGeoAsyncCommands<K,V>
key
- the key of the geo set.reference
- the reference member or longitude/latitude coordinates.predicate
- the bounding box or radius to search in.public RedisFuture<List<GeoWithin<V>>> geosearch(K key, GeoSearch.GeoRef<K> reference, GeoSearch.GeoPredicate predicate, GeoArgs geoArgs)
RedisGeoAsyncCommands
reference
the search predicate
.
Use GeoSearch
to create reference and predicate objects.geosearch
in interface RedisGeoAsyncCommands<K,V>
key
- the key of the geo set.reference
- the reference member or longitude/latitude coordinates.predicate
- the bounding box or radius to search in.geoArgs
- args to control the result.GeoWithin
contains only fields which were requested by GeoArgs
.public RedisFuture<Long> geosearchstore(K destination, K key, GeoSearch.GeoRef<K> reference, GeoSearch.GeoPredicate predicate, GeoArgs geoArgs, boolean storeDist)
RedisGeoAsyncCommands
RedisGeoAsyncCommands.geosearch(Object, GeoSearch.GeoRef, GeoSearch.GeoPredicate, GeoArgs)
query and store the results in a
sorted set.geosearchstore
in interface RedisGeoAsyncCommands<K,V>
destination
- the destination where to store results.key
- the key of the geo set.reference
- the reference member or longitude/latitude coordinates.predicate
- the bounding box or radius to search in.geoArgs
- args to control the result.storeDist
- stores the items in a sorted set populated with their distance from the center of the circle or box, as a floating-point number, in the same unit specified for that shape.public RedisFuture<V> get(K key)
RedisStringAsyncCommands
get
in interface RedisStringAsyncCommands<K,V>
key
- the key.key
, or null
when key
does not exist.public StatefulConnection<K,V> getConnection()
public RedisFuture<Long> getbit(K key, long offset)
RedisStringAsyncCommands
getbit
in interface RedisStringAsyncCommands<K,V>
key
- the key.offset
- the offset type: long.public RedisFuture<V> getdel(K key)
RedisStringAsyncCommands
getdel
in interface RedisStringAsyncCommands<K,V>
key
- the key.key
, or null
when key
does not exist.public RedisFuture<V> getex(K key, GetExArgs args)
RedisStringAsyncCommands
getex
in interface RedisStringAsyncCommands<K,V>
key
- the key.args
- the arguments for GETEX
.key
, or null
when key
does not exist.public RedisFuture<V> getrange(K key, long start, long end)
RedisStringAsyncCommands
getrange
in interface RedisStringAsyncCommands<K,V>
key
- the key.start
- the start type: long.end
- the end type: long.public RedisFuture<V> getset(K key, V value)
RedisStringAsyncCommands
getset
in interface RedisStringAsyncCommands<K,V>
key
- the key.value
- the value.key
, or null
when key
did not exist.public RedisFuture<Long> hdel(K key, K... fields)
RedisHashAsyncCommands
hdel
in interface RedisHashAsyncCommands<K,V>
key
- the key.fields
- the field type: key.public RedisFuture<Boolean> hexists(K key, K field)
RedisHashAsyncCommands
hexists
in interface RedisHashAsyncCommands<K,V>
key
- the key.field
- the field type: key.true
if the hash contains field
. false
if the hash does not contain field
, or
key
does not exist.public RedisFuture<V> hget(K key, K field)
RedisHashAsyncCommands
hget
in interface RedisHashAsyncCommands<K,V>
key
- the key.field
- the field type: key.field
, or null
when field
is not present in
the hash or key
does not exist.public RedisFuture<Map<K,V>> hgetall(K key)
RedisHashAsyncCommands
hgetall
in interface RedisHashAsyncCommands<K,V>
key
- the key.key
does not exist.public RedisFuture<Long> hgetall(KeyValueStreamingChannel<K,V> channel, K key)
RedisHashAsyncCommands
hgetall
in interface RedisHashAsyncCommands<K,V>
channel
- the channel.key
- the key.public RedisFuture<Long> hincrby(K key, K field, long amount)
RedisHashAsyncCommands
hincrby
in interface RedisHashAsyncCommands<K,V>
key
- the key.field
- the field type: key.amount
- the increment type: long.field
after the increment operation.public RedisFuture<Double> hincrbyfloat(K key, K field, double amount)
RedisHashAsyncCommands
hincrbyfloat
in interface RedisHashAsyncCommands<K,V>
key
- the key.field
- the field type: key.amount
- the increment type: double.field
after the increment.public RedisFuture<List<K>> hkeys(K key)
RedisHashAsyncCommands
hkeys
in interface RedisHashAsyncCommands<K,V>
key
- the key.key
does not exist.public RedisFuture<Long> hkeys(KeyStreamingChannel<K> channel, K key)
RedisHashAsyncCommands
hkeys
in interface RedisHashAsyncCommands<K,V>
channel
- the channel.key
- the key.public RedisFuture<Long> hlen(K key)
RedisHashAsyncCommands
hlen
in interface RedisHashAsyncCommands<K,V>
key
- the key.0
when key
does not exist.public RedisFuture<List<KeyValue<K,V>>> hmget(K key, K... fields)
RedisHashAsyncCommands
hmget
in interface RedisHashAsyncCommands<K,V>
key
- the key.fields
- the field type: key.public RedisFuture<Long> hmget(KeyValueStreamingChannel<K,V> channel, K key, K... fields)
RedisHashAsyncCommands
hmget
in interface RedisHashAsyncCommands<K,V>
channel
- the channel.key
- the key.fields
- the fields.public RedisFuture<String> hmset(K key, Map<K,V> map)
RedisHashAsyncCommands
hmset
in interface RedisHashAsyncCommands<K,V>
key
- the key.map
- the hash to apply.public RedisFuture<K> hrandfield(K key)
RedisHashAsyncCommands
key
.hrandfield
in interface RedisHashAsyncCommands<K,V>
key
- the key.public RedisFuture<List<K>> hrandfield(K key, long count)
RedisHashAsyncCommands
count
random fields from the hash stored at key
.hrandfield
in interface RedisHashAsyncCommands<K,V>
key
- the key.count
- the number of fields to return. If the provided count argument is positive, return an array of distinct
fields.public RedisFuture<KeyValue<K,V>> hrandfieldWithvalues(K key)
RedisHashAsyncCommands
key
.hrandfieldWithvalues
in interface RedisHashAsyncCommands<K,V>
key
- the key.public RedisFuture<List<KeyValue<K,V>>> hrandfieldWithvalues(K key, long count)
RedisHashAsyncCommands
count
random fields along their value from the hash stored at key
.hrandfieldWithvalues
in interface RedisHashAsyncCommands<K,V>
key
- the key.count
- the number of fields to return. If the provided count argument is positive, return an array of distinct
fields.public RedisFuture<MapScanCursor<K,V>> hscan(K key)
RedisHashAsyncCommands
hscan
in interface RedisHashAsyncCommands<K,V>
key
- the key.public RedisFuture<MapScanCursor<K,V>> hscan(K key, ScanArgs scanArgs)
RedisHashAsyncCommands
hscan
in interface RedisHashAsyncCommands<K,V>
key
- the key.scanArgs
- scan arguments.public RedisFuture<MapScanCursor<K,V>> hscan(K key, ScanCursor scanCursor, ScanArgs scanArgs)
RedisHashAsyncCommands
hscan
in interface RedisHashAsyncCommands<K,V>
key
- the key.scanCursor
- cursor to resume from a previous scan, must not be null
.scanArgs
- scan arguments.public RedisFuture<MapScanCursor<K,V>> hscan(K key, ScanCursor scanCursor)
RedisHashAsyncCommands
hscan
in interface RedisHashAsyncCommands<K,V>
key
- the key.scanCursor
- cursor to resume from a previous scan, must not be null
.public RedisFuture<StreamScanCursor> hscan(KeyValueStreamingChannel<K,V> channel, K key)
RedisHashAsyncCommands
hscan
in interface RedisHashAsyncCommands<K,V>
channel
- streaming channel that receives a call for every key-value pair.key
- the key.public RedisFuture<StreamScanCursor> hscan(KeyValueStreamingChannel<K,V> channel, K key, ScanArgs scanArgs)
RedisHashAsyncCommands
hscan
in interface RedisHashAsyncCommands<K,V>
channel
- streaming channel that receives a call for every key-value pair.key
- the key.scanArgs
- scan arguments.public RedisFuture<StreamScanCursor> hscan(KeyValueStreamingChannel<K,V> channel, K key, ScanCursor scanCursor, ScanArgs scanArgs)
RedisHashAsyncCommands
hscan
in interface RedisHashAsyncCommands<K,V>
channel
- streaming channel that receives a call for every key-value pair.key
- the key.scanCursor
- cursor to resume from a previous scan, must not be null
.scanArgs
- scan arguments.public RedisFuture<StreamScanCursor> hscan(KeyValueStreamingChannel<K,V> channel, K key, ScanCursor scanCursor)
RedisHashAsyncCommands
hscan
in interface RedisHashAsyncCommands<K,V>
channel
- streaming channel that receives a call for every key-value pair.key
- the key.scanCursor
- cursor to resume from a previous scan, must not be null
.public RedisFuture<Boolean> hset(K key, K field, V value)
RedisHashAsyncCommands
hset
in interface RedisHashAsyncCommands<K,V>
key
- the key.field
- the field type: key.value
- the value.true
if field
is a new field in the hash and value
was set. false
if
field
already exists in the hash and the value was updated.public RedisFuture<Long> hset(K key, Map<K,V> map)
RedisHashAsyncCommands
hset
in interface RedisHashAsyncCommands<K,V>
key
- the key of the hash.map
- the field/value pairs to update.public RedisFuture<Boolean> hsetnx(K key, K field, V value)
RedisHashAsyncCommands
hsetnx
in interface RedisHashAsyncCommands<K,V>
key
- the key.field
- the field type: key.value
- the value.1
if field
is a new field in the hash and value
was set. 0
if field
already exists in the hash and no operation was performed.public RedisFuture<Long> hstrlen(K key, K field)
RedisHashAsyncCommands
hstrlen
in interface RedisHashAsyncCommands<K,V>
key
- the key.field
- the field type: key.field
value, or 0
when field
is not present
in the hash or key
does not exist at all.public RedisFuture<List<V>> hvals(K key)
RedisHashAsyncCommands
hvals
in interface RedisHashAsyncCommands<K,V>
key
- the key.key
does not exist.public RedisFuture<Long> hvals(ValueStreamingChannel<V> channel, K key)
RedisHashAsyncCommands
hvals
in interface RedisHashAsyncCommands<K,V>
channel
- streaming channel that receives a call for every value.key
- the key.public RedisFuture<Long> incr(K key)
RedisStringAsyncCommands
incr
in interface RedisStringAsyncCommands<K,V>
key
- the key.key
after the increment.public RedisFuture<Long> incrby(K key, long amount)
RedisStringAsyncCommands
incrby
in interface RedisStringAsyncCommands<K,V>
key
- the key.amount
- the increment type: long.key
after the increment.public RedisFuture<Double> incrbyfloat(K key, double amount)
RedisStringAsyncCommands
incrbyfloat
in interface RedisStringAsyncCommands<K,V>
key
- the key.amount
- the increment type: double.key
after the increment.public RedisFuture<String> info()
RedisServerAsyncCommands
info
in interface RedisServerAsyncCommands<K,V>
public RedisFuture<String> info(String section)
RedisServerAsyncCommands
info
in interface RedisServerAsyncCommands<K,V>
section
- the section type: string.public boolean isOpen()
isOpen
in interface BaseRedisAsyncCommands<K,V>
true
if the connection is open (connected and not closed).public RedisFuture<List<K>> keys(K pattern)
RedisKeyAsyncCommands
keys
in interface RedisKeyAsyncCommands<K,V>
pattern
- the pattern type: patternkey (pattern).pattern
.public RedisFuture<Long> keys(KeyStreamingChannel<K> channel, K pattern)
RedisKeyAsyncCommands
keys
in interface RedisKeyAsyncCommands<K,V>
channel
- the channel.pattern
- the pattern.pattern
.public RedisFuture<Date> lastsave()
RedisServerAsyncCommands
lastsave
in interface RedisServerAsyncCommands<K,V>
public RedisFuture<V> lindex(K key, long index)
RedisListAsyncCommands
lindex
in interface RedisListAsyncCommands<K,V>
key
- the key.index
- the index type: long.null
when index
is out of range.public RedisFuture<Long> linsert(K key, boolean before, V pivot, V value)
RedisListAsyncCommands
linsert
in interface RedisListAsyncCommands<K,V>
key
- the key.before
- the before.pivot
- the pivot.value
- the value.-1
when the value pivot
was not found.public RedisFuture<Long> llen(K key)
RedisListAsyncCommands
llen
in interface RedisListAsyncCommands<K,V>
key
- the key.key
.public RedisFuture<V> lmove(K source, K destination, LMoveArgs args)
RedisListAsyncCommands
lmove
in interface RedisListAsyncCommands<K,V>
source
- the source key.destination
- the destination type: key.args
- command arguments to configure source and destination directions.public RedisFuture<V> lpop(K key)
RedisListAsyncCommands
lpop
in interface RedisListAsyncCommands<K,V>
key
- the key.null
when key
does not exist.public RedisFuture<List<V>> lpop(K key, long count)
RedisListAsyncCommands
count
elements in a list.lpop
in interface RedisListAsyncCommands<K,V>
key
- the key.count
- the number of elements to return.count
elements, or null
when key
does
not exist.public RedisFuture<KeyValue<K,List<V>>> lmpop(LMPopArgs args, K... keys)
RedisListAsyncCommands
lmpop
in interface RedisListAsyncCommands<K,V>
args
- the additional command arguments.keys
- the keys.null
when key
does not exist.public RedisFuture<Long> lpos(K key, V value)
RedisListAsyncCommands
null
is returned. The returned elements indexes are
always referring to what RedisListAsyncCommands.lindex(java.lang.Object, long)
would return. So first element from head is 0
,
and so forth.lpos
in interface RedisListAsyncCommands<K,V>
key
- the key.value
- the element to search for.public RedisFuture<Long> lpos(K key, V value, LPosArgs args)
RedisListAsyncCommands
null
is returned. The returned elements indexes are
always referring to what RedisListAsyncCommands.lindex(java.lang.Object, long)
would return. So first element from head is 0
,
and so forth.lpos
in interface RedisListAsyncCommands<K,V>
key
- the key.value
- the element to search for.args
- command arguments to configureFIRST
and MAXLEN
options.public RedisFuture<List<Long>> lpos(K key, V value, int count)
RedisListAsyncCommands
COUNT
option. By default, when no options are
given, it will scan the list from head to tail, looking for the first match of "element". The returned elements indexes
are always referring to what RedisListAsyncCommands.lindex(java.lang.Object, long)
would return. So first element from head is
0
, and so forth.lpos
in interface RedisListAsyncCommands<K,V>
key
- the key.value
- the element to search for.count
- limit the number of matches.public RedisFuture<List<Long>> lpos(K key, V value, int count, LPosArgs args)
RedisListAsyncCommands
COUNT
option. By default, when no options are
given, it will scan the list from head to tail, looking for the first match of "element". The returned elements indexes
are always referring to what RedisListAsyncCommands.lindex(java.lang.Object, long)
would return. So first element from head is
0
, and so forth.lpos
in interface RedisListAsyncCommands<K,V>
key
- the key.value
- the element to search for.count
- limit the number of matches.args
- command arguments to configureFIRST
and MAXLEN
options.public RedisFuture<Long> lpush(K key, V... values)
RedisListAsyncCommands
lpush
in interface RedisListAsyncCommands<K,V>
key
- the key.values
- the value.public RedisFuture<Long> lpushx(K key, V... values)
RedisListAsyncCommands
lpushx
in interface RedisListAsyncCommands<K,V>
key
- the key.values
- the values.public RedisFuture<List<V>> lrange(K key, long start, long stop)
RedisListAsyncCommands
lrange
in interface RedisListAsyncCommands<K,V>
key
- the key.start
- the start type: long.stop
- the stop type: long.public RedisFuture<Long> lrange(ValueStreamingChannel<V> channel, K key, long start, long stop)
RedisListAsyncCommands
lrange
in interface RedisListAsyncCommands<K,V>
channel
- the channel.key
- the key.start
- the start type: long.stop
- the stop type: long.public RedisFuture<Long> lrem(K key, long count, V value)
RedisListAsyncCommands
lrem
in interface RedisListAsyncCommands<K,V>
key
- the key.count
- the count type: long.value
- the value.public RedisFuture<String> lset(K key, long index, V value)
RedisListAsyncCommands
lset
in interface RedisListAsyncCommands<K,V>
key
- the key.index
- the index type: long.value
- the value.public RedisFuture<String> ltrim(K key, long start, long stop)
RedisListAsyncCommands
ltrim
in interface RedisListAsyncCommands<K,V>
key
- the key.start
- the start type: long.stop
- the stop type: long.public RedisFuture<Long> memoryUsage(K key)
RedisServerAsyncCommands
memoryUsage
in interface RedisServerAsyncCommands<K,V>
public RedisFuture<List<KeyValue<K,V>>> mget(K... keys)
RedisStringAsyncCommands
mget
in interface RedisStringAsyncCommands<K,V>
keys
- the key.public RedisFuture<Long> mget(KeyValueStreamingChannel<K,V> channel, K... keys)
RedisStringAsyncCommands
mget
in interface RedisStringAsyncCommands<K,V>
channel
- the channel.keys
- the keys.public RedisFuture<Long> mget(KeyValueStreamingChannel<K,V> channel, Iterable<K> keys)
public RedisFuture<String> migrate(String host, int port, K key, int db, long timeout)
RedisKeyAsyncCommands
migrate
in interface RedisKeyAsyncCommands<K,V>
host
- the host.port
- the port.key
- the key.db
- the database.timeout
- the timeout in milliseconds.public RedisFuture<String> migrate(String host, int port, int db, long timeout, MigrateArgs<K> migrateArgs)
RedisKeyAsyncCommands
migrate
in interface RedisKeyAsyncCommands<K,V>
host
- the host.port
- the port.db
- the database.timeout
- the timeout in milliseconds.migrateArgs
- migrate args that allow to configure further options.public RedisFuture<Boolean> move(K key, int db)
RedisKeyAsyncCommands
move
in interface RedisKeyAsyncCommands<K,V>
key
- the key.db
- the db type: long.public RedisFuture<String> mset(Map<K,V> map)
RedisStringAsyncCommands
mset
in interface RedisStringAsyncCommands<K,V>
map
- the map.OK
since MSET
can't fail.public RedisFuture<Boolean> msetnx(Map<K,V> map)
RedisStringAsyncCommands
msetnx
in interface RedisStringAsyncCommands<K,V>
msetnx
in interface RedisClusterAsyncCommands<K,V>
map
- the map.1
if the all the keys were set. 0
if no key was set (at least one key already existed).public RedisFuture<String> multi()
RedisTransactionalAsyncCommands
multi
in interface RedisTransactionalAsyncCommands<K,V>
OK
.public RedisFuture<String> objectEncoding(K key)
RedisKeyAsyncCommands
key
.objectEncoding
in interface RedisKeyAsyncCommands<K,V>
key
- the key.public RedisFuture<Long> objectFreq(K key)
RedisKeyAsyncCommands
key
.objectFreq
in interface RedisKeyAsyncCommands<K,V>
key
- the key.public RedisFuture<Long> objectIdletime(K key)
RedisKeyAsyncCommands
objectIdletime
in interface RedisKeyAsyncCommands<K,V>
key
- the key.public RedisFuture<Long> objectRefcount(K key)
RedisKeyAsyncCommands
objectRefcount
in interface RedisKeyAsyncCommands<K,V>
key
- the key.public RedisFuture<Boolean> persist(K key)
RedisKeyAsyncCommands
persist
in interface RedisKeyAsyncCommands<K,V>
key
- the key.true
if the timeout was removed. false
if key
does not exist or does not have an
associated timeout.public RedisFuture<Boolean> pexpire(K key, long milliseconds)
RedisKeyAsyncCommands
pexpire
in interface RedisKeyAsyncCommands<K,V>
key
- the key.milliseconds
- the milliseconds type: long.true
if the timeout was set. false
if key
does not exist or
the timeout could not be set.public RedisFuture<Boolean> pexpire(K key, long milliseconds, ExpireArgs expireArgs)
RedisKeyAsyncCommands
pexpire
in interface RedisKeyAsyncCommands<K,V>
key
- the key.milliseconds
- the milliseconds type: long.expireArgs
- the expire arguments.true
if the timeout was set. false
if key
does not exist or
the timeout could not be set.public RedisFuture<Boolean> pexpire(K key, Duration milliseconds)
RedisKeyAsyncCommands
pexpire
in interface RedisKeyAsyncCommands<K,V>
key
- the key.milliseconds
- the milliseconds.true
if the timeout was set. false
if key
does not exist or
the timeout could not be set.public RedisFuture<Boolean> pexpire(K key,