public interface RedisAdvancedClusterReactiveCommands<K,V> extends RedisClusterReactiveCommands<K,V>
Modifier and Type | Method and Description |
---|---|
Observable<String> |
clientSetname(K name)
Set the current connection name on all cluster nodes with pipelining.
|
Observable<Long> |
dbsize()
Return the number of keys in the selected database on all cluster masters.
|
Observable<Long> |
del(K... keys)
Delete one or more keys with pipelining.
|
Observable<String> |
flushall()
Remove all keys from all databases on all cluster masters with pipelining.
|
Observable<String> |
flushdb()
Remove all keys from the current database on all cluster masters with pipelining.
|
RedisClusterReactiveCommands<K,V> |
getConnection(String nodeId)
Retrieve a connection to the specified cluster node using the nodeId.
|
RedisClusterReactiveCommands<K,V> |
getConnection(String host,
int port)
Retrieve a connection to the specified cluster node using the nodeId.
|
StatefulRedisClusterConnection<K,V> |
getStatefulConnection() |
Observable<K> |
keys(K pattern)
Find all keys matching the given pattern on all cluster masters.
|
Observable<Long> |
keys(KeyStreamingChannel<K> channel,
K pattern)
Find all keys matching the given pattern on all cluster masters.
|
Observable<V> |
mget(K... keys)
Get the values of all the given keys with pipelining.
|
Observable<String> |
mset(Map<K,V> map)
Set multiple keys to multiple values with pipelining.
|
Observable<Boolean> |
msetnx(Map<K,V> map)
Set multiple keys to multiple values, only if none of the keys exist with pipelining.
|
Observable<V> |
randomkey()
Return a random key from the keyspace on a random master.
|
Observable<String> |
scriptFlush()
Remove all the scripts from the script cache on all cluster nodes.
|
Observable<String> |
scriptKill()
Kill the script currently in execution on all cluster nodes.
|
Observable<Success> |
shutdown(boolean save)
Synchronously save the dataset to disk and then shut down all nodes of the cluster.
|
Observable<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
close, echo, isOpen, ping, publish, pubsubChannels, pubsubChannels, pubsubNumpat, pubsubNumsub, quit, reset, role, waitForReplication
RedisClusterReactiveCommands<K,V> getConnection(String nodeId)
RedisAdvancedClusterReactiveCommands
, node-connections do not route commands to other cluster
nodesnodeId
- the node IdRedisClusterReactiveCommands<K,V> getConnection(String host, int port)
RedisAdvancedClusterReactiveCommands
, node-connections do not route commands to other cluster nodeshost
- the hostport
- the portStatefulRedisClusterConnection<K,V> getStatefulConnection()
Observable<Long> del(K... keys)
del
in interface RedisClusterReactiveCommands<K,V>
del
in interface RedisKeyReactiveCommands<K,V>
keys
- the keysObservable<Long> unlink(K... keys)
unlink
in interface RedisKeyReactiveCommands<K,V>
keys
- the keysObservable<V> mget(K... keys)
mget
in interface RedisClusterReactiveCommands<K,V>
mget
in interface RedisStringReactiveCommands<K,V>
keys
- the keyObservable<String> mset(Map<K,V> map)
mset
in interface RedisClusterReactiveCommands<K,V>
mset
in interface RedisStringReactiveCommands<K,V>
map
- the mapOK
since MSET
can't fail.Observable<Boolean> msetnx(Map<K,V> map)
msetnx
in interface RedisClusterReactiveCommands<K,V>
msetnx
in interface RedisStringReactiveCommands<K,V>
map
- the null1
if the all the keys were set. 0
if no key was set (at least one key already existed).Observable<String> clientSetname(K name)
clientSetname
in interface RedisServerReactiveCommands<K,V>
name
- the client nameOK
if the connection name was successfully set.Observable<String> flushall()
flushall
in interface RedisServerReactiveCommands<K,V>
Observable<String> flushdb()
flushdb
in interface RedisServerReactiveCommands<K,V>
Observable<Long> dbsize()
dbsize
in interface RedisServerReactiveCommands<K,V>
Observable<K> keys(K pattern)
keys
in interface RedisKeyReactiveCommands<K,V>
pattern
- the pattern type: patternkey (pattern)pattern
.Observable<Long> keys(KeyStreamingChannel<K> channel, K pattern)
keys
in interface RedisKeyReactiveCommands<K,V>
channel
- the channelpattern
- the patternpattern
.Observable<V> randomkey()
randomkey
in interface RedisKeyReactiveCommands<K,V>
Observable<String> scriptFlush()
scriptFlush
in interface RedisScriptingReactiveCommands<K,V>
Observable<String> scriptKill()
scriptKill
in interface RedisScriptingReactiveCommands<K,V>
Observable<Success> shutdown(boolean save)
shutdown
in interface RedisServerReactiveCommands<K,V>
save
- true force save operationCopyright © 2016. All rights reserved.