public interface RedisAdvancedClusterAsyncCommands<K,V> extends RedisClusterAsyncCommands<K,V>, RedisAdvancedClusterAsyncConnection<K,V>
Modifier and Type | Method and Description |
---|---|
default AsyncNodeSelection<K,V> |
all()
Select all known cluster nodes.
|
RedisFuture<String> |
clientSetname(K name)
Set the current connection name on all cluster nodes with pipelining.
|
RedisFuture<Long> |
dbsize()
Return the number of keys in the selected database on all cluster masters.
|
RedisFuture<Long> |
del(K... keys)
Delete one or more keys with pipelining.
|
RedisFuture<String> |
flushall()
Remove all keys from all databases on all cluster masters with pipelining.
|
RedisFuture<String> |
flushdb()
Remove all keys from the current database on all cluster masters with pipelining.
|
RedisClusterAsyncCommands<K,V> |
getConnection(String nodeId)
Retrieve a connection to the specified cluster node using the nodeId.
|
RedisClusterAsyncCommands<K,V> |
getConnection(String host,
int port)
Retrieve a connection to the specified cluster node using the nodeId.
|
StatefulRedisClusterConnection<K,V> |
getStatefulConnection() |
RedisFuture<List<K>> |
keys(K pattern)
Find all keys matching the given pattern on all cluster masters.
|
RedisFuture<Long> |
keys(KeyStreamingChannel<K> channel,
K pattern)
Find all keys matching the given pattern on all cluster masters.
|
default AsyncNodeSelection<K,V> |
masters()
Select all masters.
|
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.
|
AsyncNodeSelection<K,V> |
nodes(java.util.function.Predicate<RedisClusterNode> predicate)
Select nodes by a predicate and keeps a static selection.
|
AsyncNodeSelection<K,V> |
nodes(java.util.function.Predicate<RedisClusterNode> predicate,
boolean dynamic)
Select nodes by a predicate
|
RedisFuture<V> |
randomkey()
Return a random key from the keyspace on a random master.
|
AsyncNodeSelection<K,V> |
readonly(java.util.function.Predicate<RedisClusterNode> predicate)
Select slave nodes by a predicate and keeps a static selection.
|
RedisFuture<String> |
scriptFlush()
Remove all the scripts from the script cache on all cluster nodes.
|
RedisFuture<String> |
scriptKill()
Kill the script currently in execution on all cluster nodes.
|
void |
shutdown(boolean save)
Synchronously save the dataset to disk and then shut down all nodes of the cluster.
|
default AsyncNodeSelection<K,V> |
slaves()
Select all slaves.
|
default AsyncNodeSelection<K,V> |
slaves(java.util.function.Predicate<RedisClusterNode> predicate)
Select all slaves.
|
RedisFuture<Long> |
unlink(K... keys)
Unlink one or more keys with pipelining.
|
asking, auth, clusterAddSlots, clusterCountFailureReports, clusterCountKeysInSlot, clusterDelSlots, clusterFailover, clusterFlushslots, clusterForget, clusterGetKeysInSlot, clusterInfo, clusterKeyslot, clusterMeet, clusterMyId, clusterNodes, clusterReplicate, clusterReset, clusterSaveconfig, clusterSetConfigEpoch, clusterSetSlotImporting, clusterSetSlotMigrating, clusterSetSlotNode, clusterSetSlotStable, clusterSlaves, clusterSlots, readOnly, readWrite, setTimeout
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
dump, exists, expire, expireat, expireat, migrate, move, objectEncoding, objectIdletime, objectRefcount, persist, pexpire, pexpireat, pexpireat, pttl, rename, renamenx, restore, scan, scan, scan, scan, scan, scan, scan, scan, sort, sort, sort, sort, sortStore, ttl, type
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
blpop, brpop, brpoplpush, lindex, linsert, llen, lpop, lpush, lpushx, lrange, lrange, lrem, lset, ltrim, rpop, rpoplpush, rpush, rpushx
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
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
digest, eval, eval, evalsha, evalsha, scriptExists, scriptLoad
bgrewriteaof, bgsave, clientGetname, clientKill, clientKill, clientList, clientPause, command, commandCount, commandInfo, commandInfo, configGet, configResetstat, configRewrite, configSet, debugCrashAndRecover, debugHtstats, debugObject, debugOom, debugReload, debugRestart, debugSdslen, debugSegfault, flushallAsync, flushdbAsync, info, info, lastsave, save, slaveof, slaveofNoOne, slowlogGet, slowlogGet, slowlogLen, slowlogReset, sync, time
pfadd, pfcount, pfmerge
geoadd, geoadd, geodist, geopos, georadius, georadius, georadiusbymember, georadiusbymember
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
dump, exists, exists, expire, expireat, expireat, migrate, move, objectEncoding, objectIdletime, objectRefcount, persist, pexpire, pexpireat, pexpireat, pttl, rename, renamenx, restore, scan, scan, scan, scan, scan, scan, scan, scan, sort, sort, sort, sort, sortStore, ttl, type
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
blpop, brpop, brpoplpush, lindex, linsert, llen, lpop, lpush, lpushx, lrange, lrange, lrem, lset, ltrim, rpop, rpoplpush, rpush, rpushx
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
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
eval, eval, evalsha, evalsha, scriptExists, scriptLoad
bgrewriteaof, bgsave, clientGetname, clientKill, clientKill, clientList, clientPause, command, commandCount, commandInfo, commandInfo, configGet, configResetstat, configRewrite, configSet, debugHtstats, debugObject, debugOom, debugSegfault, flushallAsync, flushdbAsync, info, info, lastsave, save, slaveof, slaveofNoOne, slowlogGet, slowlogGet, slowlogLen, slowlogReset, sync, time
pfadd, pfcount, pfmerge
geoadd, geoadd, geodist, geopos, georadius, georadius, georadiusbymember, georadiusbymember
close, digest, discard, echo, exec, flushCommands, isOpen, multi, ping, publish, pubsubChannels, pubsubChannels, pubsubNumpat, pubsubNumsub, quit, role, setAutoFlushCommands, unwatch, waitForReplication, watch
reset
RedisClusterAsyncCommands<K,V> getConnection(String nodeId)
RedisAdvancedClusterAsyncCommands
, node-connections do not route commands to other cluster
nodesgetConnection
in interface RedisAdvancedClusterAsyncConnection<K,V>
nodeId
- the node IdRedisClusterAsyncCommands<K,V> getConnection(String host, int port)
RedisAdvancedClusterAsyncCommands
, node-connections do not route commands to other cluster nodesgetConnection
in interface RedisAdvancedClusterAsyncConnection<K,V>
host
- the hostport
- the portStatefulRedisClusterConnection<K,V> getStatefulConnection()
getStatefulConnection
in interface RedisAdvancedClusterAsyncConnection<K,V>
default AsyncNodeSelection<K,V> masters()
default AsyncNodeSelection<K,V> slaves()
default AsyncNodeSelection<K,V> slaves(java.util.function.Predicate<RedisClusterNode> predicate)
predicate
- Predicate to filter nodesdefault AsyncNodeSelection<K,V> all()
AsyncNodeSelection<K,V> readonly(java.util.function.Predicate<RedisClusterNode> predicate)
NodeSelectionSupport
does not change when the cluster view changes.predicate
- Predicate to filter nodespredicate
AsyncNodeSelection<K,V> nodes(java.util.function.Predicate<RedisClusterNode> predicate)
NodeSelectionSupport
does
not change when the cluster view changes.predicate
- Predicate to filter nodespredicate
AsyncNodeSelection<K,V> nodes(java.util.function.Predicate<RedisClusterNode> predicate, boolean dynamic)
predicate
- Predicate to filter nodesdynamic
- Defines, whether the set of nodes within the NodeSelectionSupport
can change when the cluster view
changes.predicate
RedisFuture<Long> del(K... keys)
del
in interface RedisClusterAsyncCommands<K,V>
del
in interface RedisKeyAsyncCommands<K,V>
del
in interface RedisKeysAsyncConnection<K,V>
keys
- the keysRedisFuture<Long> unlink(K... keys)
unlink
in interface RedisKeyAsyncCommands<K,V>
unlink
in interface RedisKeysAsyncConnection<K,V>
keys
- the keysRedisFuture<List<V>> mget(K... keys)
mget
in interface RedisClusterAsyncCommands<K,V>
mget
in interface RedisStringAsyncCommands<K,V>
mget
in interface RedisStringsAsyncConnection<K,V>
keys
- the keyRedisFuture<String> mset(Map<K,V> map)
mset
in interface RedisClusterAsyncCommands<K,V>
mset
in interface RedisStringAsyncCommands<K,V>
mset
in interface RedisStringsAsyncConnection<K,V>
map
- the mapOK
since MSET
can't fail.RedisFuture<Boolean> msetnx(Map<K,V> map)
msetnx
in interface RedisClusterAsyncCommands<K,V>
msetnx
in interface RedisStringAsyncCommands<K,V>
msetnx
in interface RedisStringsAsyncConnection<K,V>
map
- the null1
if the all the keys were set. 0
if no key was set (at least one key already existed).RedisFuture<String> clientSetname(K name)
clientSetname
in interface RedisServerAsyncCommands<K,V>
clientSetname
in interface RedisServerAsyncConnection<K,V>
name
- the client nameOK
if the connection name was successfully set.RedisFuture<String> flushall()
flushall
in interface RedisServerAsyncCommands<K,V>
flushall
in interface RedisServerAsyncConnection<K,V>
RedisFuture<String> flushdb()
flushdb
in interface RedisServerAsyncCommands<K,V>
flushdb
in interface RedisServerAsyncConnection<K,V>
RedisFuture<Long> dbsize()
dbsize
in interface RedisServerAsyncCommands<K,V>
dbsize
in interface RedisServerAsyncConnection<K,V>
RedisFuture<List<K>> keys(K pattern)
keys
in interface RedisKeyAsyncCommands<K,V>
keys
in interface RedisKeysAsyncConnection<K,V>
pattern
- the pattern type: patternkey (pattern)pattern
.RedisFuture<Long> keys(KeyStreamingChannel<K> channel, K pattern)
keys
in interface RedisKeyAsyncCommands<K,V>
keys
in interface RedisKeysAsyncConnection<K,V>
channel
- the channelpattern
- the patternpattern
.RedisFuture<V> randomkey()
randomkey
in interface RedisKeyAsyncCommands<K,V>
randomkey
in interface RedisKeysAsyncConnection<K,V>
RedisFuture<String> scriptFlush()
scriptFlush
in interface RedisScriptingAsyncCommands<K,V>
scriptFlush
in interface RedisScriptingAsyncConnection<K,V>
RedisFuture<String> scriptKill()
scriptKill
in interface RedisScriptingAsyncCommands<K,V>
scriptKill
in interface RedisScriptingAsyncConnection<K,V>
void shutdown(boolean save)
shutdown
in interface RedisServerAsyncCommands<K,V>
shutdown
in interface RedisServerAsyncConnection<K,V>
save
- true force save operationCopyright © 2016. All rights reserved.