com.lambdaworks.redis.cluster.api.async

Interface RedisClusterAsyncCommands<K,V>

Type Parameters:

K - Key type.

V - Value type.

All Superinterfaces:

AutoCloseable, BaseRedisAsyncCommands<K,V>, BaseRedisAsyncConnection<K,V>, Closeable, RedisClusterAsyncConnection<K,V>, RedisGeoAsyncCommands<K,V>, RedisGeoAsyncConnection<K,V>, RedisHashAsyncCommands<K,V>, RedisHashesAsyncConnection<K,V>, RedisHLLAsyncCommands<K,V>, RedisHLLAsyncConnection<K,V>, RedisKeyAsyncCommands<K,V>, RedisKeysAsyncConnection<K,V>, RedisListAsyncCommands<K,V>, RedisListsAsyncConnection<K,V>, RedisScriptingAsyncCommands<K,V>, RedisScriptingAsyncConnection<K,V>, RedisServerAsyncCommands<K,V>, RedisServerAsyncConnection<K,V>, RedisSetAsyncCommands<K,V>, RedisSetsAsyncConnection<K,V>, RedisSortedSetAsyncCommands<K,V>, RedisSortedSetsAsyncConnection<K,V>, RedisStringAsyncCommands<K,V>, RedisStringsAsyncConnection<K,V>

All Known Subinterfaces:

RedisAdvancedClusterAsyncCommands<K,V>, RedisAsyncCommands<K,V>, RedisPubSubAsyncCommands<K,V>

All Known Implementing Classes:

AbstractRedisAsyncCommands, RedisAdvancedClusterAsyncCommandsImpl, RedisAsyncCommandsImpl, RedisPubSubAsyncCommandsImpl

public interface RedisClusterAsyncCommands<K,V>
extends 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>, RedisGeoAsyncCommands<K,V>, BaseRedisAsyncCommands<K,V>, RedisClusterAsyncConnection<K,V>

A complete asynchronous and thread-safe cluster Redis API with 400+ Methods.

Since:

4.0

Author:

Mark Paluch

Method Summary

Modifier and Type	Method and Description
RedisFuture<String>	asking() The asking command is required after a -ASK redirection.
String	auth(String password) Authenticate to the server.
RedisFuture<String>	clusterAddSlots(int... slots) Adds slots to the cluster node.
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>	clusterFailover(boolean force) Failover a cluster node.
RedisFuture<String>	clusterFlushslots() Delete all the slots associated with the specified node.
RedisFuture<String>	clusterForget(String nodeId) Blacklist 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<String>	clusterReplicate(String nodeId) Turn this node into a slave 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 slave, it turns into a master Only for hard reset: a new Node ID is generated Only for hard reset: currentEpoch and configEpoch are set to 0 The new configuration is saved and the cluster state updated If the node was a slave, the whole data set is flushed away
RedisFuture<String>	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<String>>	clusterSlaves(String nodeId) List slaves for a certain node identified by its nodeId.
RedisFuture<List<Object>>	clusterSlots() Get array of cluster slots to node mappings.
RedisFuture<Long>	del(K... keys) Delete a key with pipelining.
RedisFuture<List<V>>	mget(K... keys) Get the values of all the given keys with pipelining.
RedisFuture<String>	mset(Map<K,V> map) Set multiple keys to multiple values with pipelining.
RedisFuture<Boolean>	msetnx(Map<K,V> map) Set multiple keys to multiple values, only if none of the keys exist with pipelining.
RedisFuture<String>	readOnly() Tells a Redis cluster slave node that the client is ok reading possibly stale data and is not interested in running write queries.
RedisFuture<String>	readWrite() Resets readOnly flag.
void	setTimeout(long timeout, TimeUnit unit) Set the default timeout for operations.

Methods inherited from interface com.lambdaworks.redis.api.async.RedisHashAsyncCommands

hdel, hexists, hget, hgetall, hgetall, hincrby, hincrbyfloat, hkeys, hkeys, hlen, hmget, hmget, hmset, hscan, hscan, hscan, hscan, hscan, hscan, hscan, hscan, hset, hsetnx, hstrlen, hvals, hvals

Methods inherited from interface com.lambdaworks.redis.api.async.RedisKeyAsyncCommands

dump, exists, expire, expireat, expireat, keys, keys, migrate, move, objectEncoding, objectIdletime, objectRefcount, persist, pexpire, pexpireat, pexpireat, pttl, randomkey, rename, renamenx, restore, scan, scan, scan, scan, scan, scan, scan, scan, sort, sort, sort, sort, sortStore, ttl, type, unlink

Methods inherited from interface com.lambdaworks.redis.api.async.RedisStringAsyncCommands

append, bitcount, bitcount, bitopAnd, bitopNot, bitopOr, bitopXor, bitpos, bitpos, decr, decrby, get, getbit, getrange, getset, incr, incrby, incrbyfloat, mget, psetex, set, set, setbit, setex, setnx, setrange, strlen

Methods inherited from interface com.lambdaworks.redis.api.async.RedisListAsyncCommands

blpop, brpop, brpoplpush, lindex, linsert, llen, lpop, lpush, lpushx, lrange, lrange, lrem, lset, ltrim, rpop, rpoplpush, rpush, rpushx

Methods inherited from interface com.lambdaworks.redis.api.async.RedisSetAsyncCommands

sadd, scard, sdiff, sdiff, sdiffstore, sinter, sinter, sinterstore, sismember, smembers, smembers, smove, spop, srandmember, srandmember, srandmember, srem, sscan, sscan, sscan, sscan, sscan, sscan, sscan, sscan, sunion, sunion, sunionstore

Methods inherited from interface com.lambdaworks.redis.api.async.RedisSortedSetAsyncCommands

zadd, zadd, zadd, zadd, zaddincr, zcard, zcount, zcount, zincrby, zinterstore, zinterstore, zlexcount, zrange, zrange, zrangebylex, zrangebylex, zrangebyscore, zrangebyscore, zrangebyscore, zrangebyscore, zrangebyscore, zrangebyscore, zrangebyscore, zrangebyscore, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangeWithScores, zrangeWithScores, zrank, zrem, zremrangebylex, zremrangebyrank, zremrangebyscore, zremrangebyscore, zrevrange, zrevrange, zrevrangebyscore, zrevrangebyscore, zrevrangebyscore, zrevrangebyscore, zrevrangebyscore, zrevrangebyscore, zrevrangebyscore, zrevrangebyscore, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangeWithScores, zrevrangeWithScores, zrevrank, zscan, zscan, zscan, zscan, zscan, zscan, zscan, zscan, zscore, zunionstore, zunionstore

Methods inherited from interface com.lambdaworks.redis.api.async.RedisScriptingAsyncCommands

digest, eval, eval, evalsha, evalsha, scriptExists, scriptFlush, scriptKill, scriptLoad

Methods inherited from interface com.lambdaworks.redis.api.async.RedisServerAsyncCommands

bgrewriteaof, bgsave, clientGetname, clientKill, clientKill, clientList, clientPause, clientSetname, command, commandCount, commandInfo, commandInfo, configGet, configResetstat, configRewrite, configSet, dbsize, debugCrashAndRecover, debugHtstats, debugObject, debugOom, debugReload, debugRestart, debugSdslen, debugSegfault, flushall, flushallAsync, flushdb, flushdbAsync, info, info, lastsave, save, shutdown, slaveof, slaveofNoOne, slowlogGet, slowlogGet, slowlogLen, slowlogReset, sync, time

Methods inherited from interface com.lambdaworks.redis.api.async.RedisHLLAsyncCommands

pfadd, pfcount, pfmerge

Methods inherited from interface com.lambdaworks.redis.api.async.RedisGeoAsyncCommands

geoadd, geoadd, geodist, geopos, georadius, georadius, georadiusbymember, georadiusbymember

Methods inherited from interface com.lambdaworks.redis.RedisHashesAsyncConnection

hdel, hexists, hget, hgetall, hgetall, hincrby, hincrbyfloat, hkeys, hkeys, hlen, hmget, hmget, hmset, hscan, hscan, hscan, hscan, hscan, hscan, hscan, hscan, hset, hsetnx, hstrlen, hvals, hvals

Methods inherited from interface com.lambdaworks.redis.RedisKeysAsyncConnection

dump, exists, exists, expire, expireat, expireat, keys, keys, migrate, move, objectEncoding, objectIdletime, objectRefcount, persist, pexpire, pexpireat, pexpireat, pttl, randomkey, rename, renamenx, restore, scan, scan, scan, scan, scan, scan, scan, scan, sort, sort, sort, sort, sortStore, ttl, type, unlink

Methods inherited from interface com.lambdaworks.redis.RedisStringsAsyncConnection

append, bitcount, bitcount, bitopAnd, bitopNot, bitopOr, bitopXor, bitpos, bitpos, decr, decrby, get, getbit, getrange, getset, incr, incrby, incrbyfloat, mget, psetex, set, set, setbit, setex, setnx, setrange, strlen

Methods inherited from interface com.lambdaworks.redis.RedisListsAsyncConnection

blpop, brpop, brpoplpush, lindex, linsert, llen, lpop, lpush, lpushx, lrange, lrange, lrem, lset, ltrim, rpop, rpoplpush, rpush, rpushx

Methods inherited from interface com.lambdaworks.redis.RedisSetsAsyncConnection

sadd, scard, sdiff, sdiff, sdiffstore, sinter, sinter, sinterstore, sismember, smembers, smembers, smove, spop, srandmember, srandmember, srandmember, srem, sscan, sscan, sscan, sscan, sscan, sscan, sscan, sscan, sunion, sunion, sunionstore

Methods inherited from interface com.lambdaworks.redis.RedisSortedSetsAsyncConnection

zadd, zadd, zadd, zadd, zaddincr, zcard, zcount, zcount, zincrby, zinterstore, zinterstore, zlexcount, zrange, zrange, zrangebylex, zrangebylex, zrangebyscore, zrangebyscore, zrangebyscore, zrangebyscore, zrangebyscore, zrangebyscore, zrangebyscore, zrangebyscore, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangeWithScores, zrangeWithScores, zrank, zrem, zremrangebylex, zremrangebyrank, zremrangebyscore, zremrangebyscore, zrevrange, zrevrange, zrevrangebyscore, zrevrangebyscore, zrevrangebyscore, zrevrangebyscore, zrevrangebyscore, zrevrangebyscore, zrevrangebyscore, zrevrangebyscore, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangeWithScores, zrevrangeWithScores, zrevrank, zscan, zscan, zscan, zscan, zscan, zscan, zscan, zscan, zscore, zunionstore, zunionstore

Methods inherited from interface com.lambdaworks.redis.RedisScriptingAsyncConnection

eval, eval, evalsha, evalsha, scriptExists, scriptFlush, scriptKill, scriptLoad

Methods inherited from interface com.lambdaworks.redis.RedisServerAsyncConnection

bgrewriteaof, bgsave, clientGetname, clientKill, clientKill, clientList, clientPause, clientSetname, command, commandCount, commandInfo, commandInfo, configGet, configResetstat, configRewrite, configSet, dbsize, debugHtstats, debugObject, debugOom, debugSegfault, flushall, flushallAsync, flushdb, flushdbAsync, info, info, lastsave, save, shutdown, slaveof, slaveofNoOne, slowlogGet, slowlogGet, slowlogLen, slowlogReset, sync, time

Methods inherited from interface com.lambdaworks.redis.RedisHLLAsyncConnection

pfadd, pfcount, pfmerge

Methods inherited from interface com.lambdaworks.redis.RedisGeoAsyncConnection

geoadd, geoadd, geodist, geopos, georadius, georadius, georadiusbymember, georadiusbymember

Methods inherited from interface com.lambdaworks.redis.BaseRedisAsyncConnection

digest, discard, exec, flushCommands, multi, setAutoFlushCommands, unwatch, watch

Methods inherited from interface com.lambdaworks.redis.api.async.BaseRedisAsyncCommands

reset

Method Detail

setTimeout

void setTimeout(long timeout,
                TimeUnit unit)

Set the default timeout for operations.

Specified by:

setTimeout in interface RedisClusterAsyncConnection<K,V>

Parameters:

timeout - the timeout value

unit - the unit of the timeout value

auth

String auth(String password)

Authenticate to the server.

Specified by:

auth in interface RedisClusterAsyncConnection<K,V>

Parameters:

password - the password

Returns:

String simple-string-reply

clusterMeet

RedisFuture<String> clusterMeet(String ip,
                                int port)

Meet another cluster node to include the node into the cluster. The command starts the cluster handshake and returns with OK when the node was added to the cluster.

Specified by:

clusterMeet in interface RedisClusterAsyncConnection<K,V>

Parameters:

ip - IP address of the host

port - port number.

Returns:

String simple-string-reply

clusterForget

RedisFuture<String> clusterForget(String nodeId)

Blacklist and remove the cluster node from the cluster.

Specified by:

clusterForget in interface RedisClusterAsyncConnection<K,V>

Parameters:

nodeId - the node Id

Returns:

String simple-string-reply

clusterAddSlots

RedisFuture<String> clusterAddSlots(int... slots)

Adds slots to the cluster node. The current node will become the master for the specified slots.

Specified by:

clusterAddSlots in interface RedisClusterAsyncConnection<K,V>

Parameters:

slots - one or more slots from 0 to 16384

Returns:

String simple-string-reply

clusterDelSlots

RedisFuture<String> clusterDelSlots(int... slots)

Removes slots from the cluster node.

Specified by:

clusterDelSlots in interface RedisClusterAsyncConnection<K,V>

Parameters:

slots - one or more slots from 0 to 16384

Returns:

String simple-string-reply

clusterSetSlotNode

RedisFuture<String> clusterSetSlotNode(int slot,
                                       String nodeId)

Assign a slot to a node. The command migrates the specified slot from the current node to the specified node in nodeId

Specified by:

clusterSetSlotNode in interface RedisClusterAsyncConnection<K,V>

Parameters:

slot - the slot

nodeId - the id of the node that will become the master for the slot

Returns:

String simple-string-reply

clusterSetSlotStable

RedisFuture<String> clusterSetSlotStable(int slot)

Clears migrating / importing state from the slot.

Specified by:

clusterSetSlotStable in interface RedisClusterAsyncConnection<K,V>

Parameters:

slot - the slot

Returns:

String simple-string-reply

clusterSetSlotMigrating

RedisFuture<String> clusterSetSlotMigrating(int slot,
                                            String nodeId)

Flag a slot as MIGRATING (outgoing) towards the node specified in nodeId. The slot must be handled by the current node in order to be migrated.

Specified by:

clusterSetSlotMigrating in interface RedisClusterAsyncConnection<K,V>

Parameters:

slot - the slot

nodeId - the id of the node is targeted to become the master for the slot

Returns:

String simple-string-reply

clusterSetSlotImporting

RedisFuture<String> clusterSetSlotImporting(int slot,
                                            String nodeId)

Flag a slot as IMPORTING (incoming) from the node specified in nodeId.

Specified by:

clusterSetSlotImporting in interface RedisClusterAsyncConnection<K,V>

Parameters:

slot - the slot

nodeId - the id of the node is the master of the slot

Returns:

String simple-string-reply

clusterInfo

RedisFuture<String> clusterInfo()

Get information and statistics about the cluster viewed by the current node.

Specified by:

clusterInfo in interface RedisClusterAsyncConnection<K,V>

Returns:

String bulk-string-reply as a collection of text lines.

clusterMyId

RedisFuture<String> clusterMyId()

Obtain the nodeId for the currently connected node.

Specified by:

clusterMyId in interface RedisClusterAsyncConnection<K,V>

Returns:

String simple-string-reply

clusterNodes

RedisFuture<String> clusterNodes()

Obtain details about all cluster nodes. Can be parsed using ClusterPartitionParser.parse(java.lang.String)

Specified by:

clusterNodes in interface RedisClusterAsyncConnection<K,V>

Returns:

String bulk-string-reply as a collection of text lines

clusterSlaves

RedisFuture<List<String>> clusterSlaves(String nodeId)

List slaves for a certain node identified by its nodeId. Can be parsed using ClusterPartitionParser.parse(java.lang.String)

Specified by:

clusterSlaves in interface RedisClusterAsyncConnection<K,V>

Parameters:

nodeId - node id of the master node

Returns:

List<String> array-reply list of slaves. The command returns data in the same format as clusterNodes() but one line per slave.

clusterGetKeysInSlot

RedisFuture<List<K>> clusterGetKeysInSlot(int slot,
                                          int count)

Retrieve the list of keys within the slot.

Specified by:

clusterGetKeysInSlot in interface RedisClusterAsyncConnection<K,V>

Parameters:

slot - the slot

count - maximal number of keys

Returns:

List<K> array-reply list of keys

clusterCountKeysInSlot

RedisFuture<Long> clusterCountKeysInSlot(int slot)

Returns the number of keys in the specified Redis Cluster hash slot.

Specified by:

clusterCountKeysInSlot in interface RedisClusterAsyncConnection<K,V>

Parameters:

slot - the slot

Returns:

Integer reply: The number of keys in the specified hash slot, or an error if the hash slot is invalid.

clusterCountFailureReports

RedisFuture<Long> clusterCountFailureReports(String nodeId)

Returns the number of failure reports for the specified node. Failure reports are the way Redis Cluster uses in order to promote a PFAIL state, that means a node is not reachable, to a FAIL state, that means that the majority of masters in the cluster agreed within a window of time that the node is not reachable.

Specified by:

clusterCountFailureReports in interface RedisClusterAsyncConnection<K,V>

Parameters:

nodeId - the node id

Returns:

Integer reply: The number of active failure reports for the node.

clusterKeyslot

RedisFuture<Long> clusterKeyslot(K key)

Returns an integer identifying the hash slot the specified key hashes to. This command is mainly useful for debugging and testing, since it exposes via an API the underlying Redis implementation of the hashing algorithm. Basically the same as SlotHash.getSlot(byte[]). If not, call Houston and report that we've got a problem.

Specified by:

clusterKeyslot in interface RedisClusterAsyncConnection<K,V>

Parameters:

key - the key.

Returns:

Integer reply: The hash slot number.

clusterSaveconfig

RedisFuture<String> clusterSaveconfig()

Forces a node to save the nodes.conf configuration on disk.

Specified by:

clusterSaveconfig in interface RedisClusterAsyncConnection<K,V>

Returns:

String simple-string-reply: OK or an error if the operation fails.

clusterSetConfigEpoch

RedisFuture<String> clusterSetConfigEpoch(long configEpoch)

This command sets a specific config epoch in a fresh node. It only works when:

• The nodes table of the node is empty.
• The node current config epoch is zero.

Specified by:

clusterSetConfigEpoch in interface RedisClusterAsyncConnection<K,V>

Parameters:

configEpoch - the config epoch

Returns:

String simple-string-reply: OK or an error if the operation fails.

clusterSlots

RedisFuture<List<Object>> clusterSlots()

Get array of cluster slots to node mappings.

Specified by:

clusterSlots in interface RedisClusterAsyncConnection<K,V>

Returns:

RedisFuture<List<Object>> array-reply nested list of slot ranges with IP/Port mappings.

asking

RedisFuture<String> asking()

The asking command is required after a -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.

Specified by:

asking in interface RedisClusterAsyncConnection<K,V>

Returns:

String simple-string-reply

clusterReplicate

RedisFuture<String> clusterReplicate(String nodeId)

Turn this node into a slave of the node with the id nodeId.

Specified by:

clusterReplicate in interface RedisClusterAsyncConnection<K,V>

Parameters:

nodeId - master node id

Returns:

String simple-string-reply

clusterFailover

RedisFuture<String> clusterFailover(boolean force)

Failover a cluster node. Turns the currently connected node into a master and the master into its slave.

Specified by:

clusterFailover in interface RedisClusterAsyncConnection<K,V>

Parameters:

force - do not coordinate with master if true

Returns:

String simple-string-reply

clusterReset

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 slave, it turns into a master
• Only for hard reset: a new Node ID is generated
• Only for hard reset: currentEpoch and configEpoch are set to 0
• The new configuration is saved and the cluster state updated
• If the node was a slave, the whole data set is flushed away

Specified by:

clusterReset in interface RedisClusterAsyncConnection<K,V>

Parameters:

hard - true for hard reset. Generates a new nodeId and currentEpoch/configEpoch are set to 0

Returns:

String simple-string-reply

clusterFlushslots

RedisFuture<String> clusterFlushslots()

Delete all the slots associated with the specified node. The number of deleted slots is returned.

Specified by:

clusterFlushslots in interface RedisClusterAsyncConnection<K,V>

Returns:

String simple-string-reply

readOnly

RedisFuture<String> readOnly()

Tells a Redis cluster slave node that the client is ok reading possibly stale data and is not interested in running write queries.

Specified by:

readOnly in interface BaseRedisAsyncCommands<K,V>

Specified by:

readOnly in interface RedisClusterAsyncConnection<K,V>

Returns:

String simple-string-reply

readWrite

RedisFuture<String> readWrite()

Resets readOnly flag.

Specified by:

readWrite in interface BaseRedisAsyncCommands<K,V>

Specified by:

readWrite in interface RedisClusterAsyncConnection<K,V>

Returns:

String simple-string-reply

del

RedisFuture<Long> del(K... keys)

Delete a key with pipelining. Cross-slot keys will result in multiple calls to the particular cluster nodes.

Specified by:

del in interface RedisKeyAsyncCommands<K,V>

Specified by:

del in interface RedisKeysAsyncConnection<K,V>

Parameters:

keys - the key

Returns:

RedisFuture<Long> integer-reply The number of keys that were removed.

mget

RedisFuture<List<V>> mget(K... keys)

Get the values of all the given keys with pipelining. Cross-slot keys will result in multiple calls to the particular cluster nodes.

Specified by:

mget in interface RedisStringAsyncCommands<K,V>

Specified by:

mget in interface RedisStringsAsyncConnection<K,V>

Parameters:

keys - the key

Returns:

RedisFuture<List<V>> array-reply list of values at the specified keys.

mset

RedisFuture<String> mset(Map<K,V> map)

Set multiple keys to multiple values with pipelining. Cross-slot keys will result in multiple calls to the particular cluster nodes.

Specified by:

mset in interface RedisStringAsyncCommands<K,V>

Specified by:

mset in interface RedisStringsAsyncConnection<K,V>

Parameters:

map - the null

Returns:

RedisFuture<String> simple-string-reply always OK since MSET can't fail.

msetnx

RedisFuture<Boolean> msetnx(Map<K,V> map)

Set multiple keys to multiple values, only if none of the keys exist with pipelining. Cross-slot keys will result in multiple calls to the particular cluster nodes.

Specified by:

msetnx in interface RedisStringAsyncCommands<K,V>

Specified by:

msetnx in interface RedisStringsAsyncConnection<K,V>

Parameters:

map - the null

Returns:

RedisFuture<Boolean> integer-reply specifically: 1 if the all the keys were set. 0 if no key was set (at least one key already existed).