public interface RedisAdvancedClusterReactiveCommands<K,V> extends RedisClusterReactiveCommands<K,V>
Modifier and Type | Method and Description |
---|---|
Mono<String> |
clientSetname(K name)
Set the current connection name on all cluster nodes with pipelining.
|
Mono<Long> |
dbsize()
Return the number of keys in the selected database on all cluster masters.
|
Mono<Long> |
del(K... keys)
Delete one or more keys with pipelining.
|
Mono<Long> |
exists(K... keys)
Determine how many keys exist with pipelining.
|
Mono<String> |
flushall()
Remove all keys from all databases on all cluster masters with pipelining.
|
Mono<String> |
flushallAsync()
Remove all keys asynchronously from all databases on all cluster upstream nodes with pipelining.
|
Mono<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 host and port.
|
StatefulRedisClusterConnection<K,V> |
getStatefulConnection()
Deprecated.
|
Flux<K> |
keys(K pattern)
Find all keys matching the given pattern on all cluster masters.
|
Mono<Long> |
keys(KeyStreamingChannel<K> channel,
K pattern)
Find all keys matching the given pattern on all cluster masters.
|
Flux<KeyValue<K,V>> |
mget(K... keys)
Get the values of all the given keys with pipelining.
|
Mono<String> |
mset(Map<K,V> map)
Set multiple keys to multiple values with pipelining.
|
Mono<Boolean> |
msetnx(Map<K,V> map)
Set multiple keys to multiple values, only if none of the keys exist with pipelining.
|
Mono<K> |
randomkey()
Return a random key from the keyspace on a random master.
|
Mono<KeyScanCursor<K>> |
scan()
Incrementally iterate the keys space over the whole Cluster.
|
Mono<StreamScanCursor> |
scan(KeyStreamingChannel<K> channel)
Incrementally iterate the keys space over the whole Cluster.
|
Mono<StreamScanCursor> |
scan(KeyStreamingChannel<K> channel,
ScanArgs scanArgs)
Incrementally iterate the keys space over the whole Cluster.
|
Mono<StreamScanCursor> |
scan(KeyStreamingChannel<K> channel,
ScanCursor scanCursor)
Incrementally iterate the keys space over the whole Cluster.
|
Mono<StreamScanCursor> |
scan(KeyStreamingChannel<K> channel,
ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate the keys space over the whole Cluster.
|
Mono<KeyScanCursor<K>> |
scan(ScanArgs scanArgs)
Incrementally iterate the keys space over the whole Cluster.
|
Mono<KeyScanCursor<K>> |
scan(ScanCursor scanCursor)
Incrementally iterate the keys space over the whole Cluster.
|
Mono<KeyScanCursor<K>> |
scan(ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate the keys space over the whole Cluster.
|
Mono<String> |
scriptFlush()
Remove all the scripts from the script cache on all cluster nodes.
|
Mono<String> |
scriptKill()
Kill the script currently in execution on all cluster nodes.
|
Mono<String> |
scriptLoad(byte[] script)
Load the specified Lua script into the script cache on all cluster nodes.
|
Mono<String> |
scriptLoad(String script)
Load the specified Lua script into the script cache on all cluster nodes.
|
Mono<Void> |
shutdown(boolean save)
Synchronously save the dataset to disk and then shut down all nodes of the cluster.
|
Mono<Long> |
touch(K... keys)
Touch one or more keys with pipelining.
|
Mono<Long> |
unlink(K... keys)
Unlink one or more keys with pipelining.
|
asking, auth, auth, clusterAddSlots, clusterAddSlotsRange, clusterBumpepoch, clusterCountFailureReports, clusterCountKeysInSlot, clusterDelSlots, clusterDelSlotsRange, clusterFailover, clusterFailover, clusterFlushslots, clusterForget, clusterGetKeysInSlot, clusterInfo, clusterKeyslot, clusterMeet, clusterMyId, clusterNodes, clusterReplicas, clusterReplicate, clusterReset, clusterSaveconfig, clusterSetConfigEpoch, clusterSetSlotImporting, clusterSetSlotMigrating, clusterSetSlotNode, clusterSetSlotStable, clusterShards, clusterSlaves, clusterSlots, readOnly, readWrite, setTimeout
dispatch, dispatch, echo, flushCommands, isOpen, ping, publish, pubsubChannels, pubsubChannels, pubsubNumpat, pubsubNumsub, quit, reset, role, setAutoFlushCommands, waitForReplication
aclCat, aclCat, aclDeluser, aclDryRun, aclDryRun, aclGenpass, aclGenpass, aclGetuser, aclList, aclLoad, aclLog, aclLog, aclLogReset, aclSave, aclSetuser, aclUsers, aclWhoami
geoadd, geoadd, geoadd, geoadd, geoadd, geoadd, geodist, geohash, geopos, georadius, georadius, georadius, georadiusbymember, georadiusbymember, georadiusbymember, geosearch, geosearch, geosearchstore
hdel, hexists, hget, hgetall, hgetall, hincrby, hincrbyfloat, hkeys, hkeys, hlen, hmget, hmget, hmset, hrandfield, hrandfield, hrandfieldWithvalues, hrandfieldWithvalues, hscan, hscan, hscan, hscan, hscan, hscan, hscan, hscan, hset, hset, hsetnx, hstrlen, hvals, hvals
pfadd, pfcount, pfmerge
copy, copy, dump, expire, expire, expire, expire, expireat, expireat, expireat, expireat, expireat, expireat, expiretime, migrate, migrate, move, objectEncoding, objectFreq, objectIdletime, objectRefcount, persist, pexpire, pexpire, pexpire, pexpire, pexpireat, pexpireat, pexpireat, pexpireat, pexpireat, pexpireat, pexpiretime, pttl, rename, renamenx, restore, restore, sort, sort, sort, sort, sortReadOnly, sortReadOnly, sortReadOnly, sortReadOnly, sortStore, ttl, type
blmove, blmove, blmpop, blmpop, blpop, blpop, brpop, brpop, brpoplpush, brpoplpush, lindex, linsert, llen, lmove, lmpop, lpop, lpop, lpos, lpos, lpos, lpos, lpush, lpushx, lrange, lrange, lrem, lset, ltrim, rpop, rpop, rpoplpush, rpush, rpushx
digest, digest, eval, eval, eval, eval, evalReadOnly, evalsha, evalsha, evalshaReadOnly, scriptExists, scriptFlush
bgrewriteaof, bgsave, clientCaching, clientGetname, clientGetredir, clientId, clientKill, clientKill, clientList, clientNoEvict, clientPause, clientTracking, clientUnblock, command, commandCount, commandInfo, commandInfo, configGet, configGet, configResetstat, configRewrite, configSet, configSet, debugCrashAndRecover, debugHtstats, debugObject, debugOom, debugReload, debugRestart, debugSdslen, debugSegfault, flushall, flushdb, flushdbAsync, info, info, lastsave, memoryUsage, replicaof, replicaofNoOne, save, shutdown, slaveof, slaveofNoOne, slowlogGet, slowlogGet, slowlogLen, slowlogReset, time
sadd, scard, sdiff, sdiff, sdiffstore, sinter, sinter, sintercard, sintercard, sinterstore, sismember, smembers, smembers, smismember, smove, spop, spop, srandmember, srandmember, srandmember, srem, sscan, sscan, sscan, sscan, sscan, sscan, sscan, sscan, sunion, sunion, sunionstore
bzpopmax, bzpopmax, bzpopmin, bzpopmin, zadd, zadd, zadd, zadd, zadd, zadd, zaddincr, zaddincr, zcard, zcount, zcount, zcount, zdiff, zdiffstore, zdiffWithScores, zincrby, zinter, zinter, zintercard, zintercard, zinterstore, zinterstore, zinterWithScores, zinterWithScores, zlexcount, zlexcount, zmscore, zpopmax, zpopmax, zpopmin, zpopmin, zrandmember, zrandmember, zrandmemberWithScores, zrandmemberWithScores, zrange, zrange, zrangebylex, zrangebylex, zrangebylex, zrangebylex, zrangebyscore, zrangebyscore, zrangebyscore, zrangebyscore, zrangebyscore, zrangebyscore, zrangebyscore, zrangebyscore, zrangebyscore, zrangebyscore, zrangebyscore, zrangebyscore, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangebyscoreWithScores, zrangestore, zrangestorebylex, zrangestorebyscore, zrangeWithScores, zrangeWithScores, zrank, zrem, zremrangebylex, zremrangebylex, zremrangebyrank, zremrangebyscore, zremrangebyscore, zremrangebyscore, zrevrange, zrevrange, zrevrangebylex, zrevrangebylex, zrevrangebyscore, zrevrangebyscore, zrevrangebyscore, zrevrangebyscore, zrevrangebyscore, zrevrangebyscore, zrevrangebyscore, zrevrangebyscore, zrevrangebyscore, zrevrangebyscore, zrevrangebyscore, zrevrangebyscore, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangebyscoreWithScores, zrevrangestore, zrevrangestorebylex, zrevrangestorebyscore, zrevrangeWithScores, zrevrangeWithScores, zrevrank, zscan, zscan, zscan, zscan, zscan, zscan, zscan, zscan, zscore, zunion, zunion, zunionstore, zunionstore, zunionWithScores, zunionWithScores
xack, xadd, xadd, xadd, xadd, xautoclaim, xclaim, xclaim, xdel, xgroupCreate, xgroupCreate, xgroupCreateconsumer, xgroupDelconsumer, xgroupDestroy, xgroupSetid, xinfoConsumers, xinfoGroups, xinfoStream, xlen, xpending, xpending, xpending, xpending, xrange, xrange, xread, xread, xreadgroup, xreadgroup, xrevrange, xrevrange, xtrim, xtrim, xtrim
append, bitcount, bitcount, bitfield, bitopAnd, bitopNot, bitopOr, bitopXor, bitpos, bitpos, bitpos, decr, decrby, get, getbit, getdel, getex, getrange, getset, incr, incrby, incrbyfloat, mget, psetex, set, set, setbit, setex, setGet, setGet, setnx, setrange, stralgoLcs, strlen
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 nodes. Host and
port connections are verified by default for cluster membership, see
ClusterClientOptions.isValidateClusterNodeMembership()
.host
- the hostport
- the port@Deprecated StatefulRedisClusterConnection<K,V> getStatefulConnection()
Mono<Long> del(K... keys)
del
in interface RedisKeyReactiveCommands<K,V>
keys
- the keysRedisKeyReactiveCommands.del(Object[])
Mono<Long> unlink(K... keys)
unlink
in interface RedisKeyReactiveCommands<K,V>
keys
- the keysRedisKeyReactiveCommands.unlink(Object[])
Mono<Long> exists(K... keys)
exists
in interface RedisKeyReactiveCommands<K,V>
keys
- the keysFlux<KeyValue<K,V>> mget(K... keys)
mget
in interface RedisStringReactiveCommands<K,V>
keys
- the keyRedisStringReactiveCommands.mget(Object[])
Mono<String> mset(Map<K,V> map)
mset
in interface RedisStringReactiveCommands<K,V>
map
- the mapOK
since MSET
can't fail.RedisStringReactiveCommands.mset(Map)
Mono<Boolean> msetnx(Map<K,V> map)
msetnx
in interface RedisStringReactiveCommands<K,V>
map
- the map1
if the all the keys were set. 0
if no key was set (at least one key already existed).RedisStringReactiveCommands.msetnx(Map)
Mono<String> clientSetname(K name)
clientSetname
in interface RedisServerReactiveCommands<K,V>
name
- the client nameOK
if the connection name was successfully set.RedisServerReactiveCommands.clientSetname(Object)
Mono<String> flushall()
flushall
in interface RedisServerReactiveCommands<K,V>
RedisServerReactiveCommands.flushall()
Mono<String> flushallAsync()
flushallAsync
in interface RedisServerReactiveCommands<K,V>
RedisServerReactiveCommands.flushallAsync()
Mono<String> flushdb()
flushdb
in interface RedisServerReactiveCommands<K,V>
RedisServerReactiveCommands.flushdb()
Mono<Long> dbsize()
dbsize
in interface RedisServerReactiveCommands<K,V>
RedisServerReactiveCommands.dbsize()
Flux<K> keys(K pattern)
keys
in interface RedisKeyReactiveCommands<K,V>
pattern
- the pattern type: patternkey (pattern)pattern
.RedisKeyReactiveCommands.keys(Object)
Mono<Long> keys(KeyStreamingChannel<K> channel, K pattern)
keys
in interface RedisKeyReactiveCommands<K,V>
channel
- the channelpattern
- the patternpattern
.RedisKeyReactiveCommands.keys(KeyStreamingChannel, Object)
Mono<K> randomkey()
randomkey
in interface RedisKeyReactiveCommands<K,V>
Mono
that completes empty when the database is empty.RedisKeyReactiveCommands.randomkey()
Mono<String> scriptFlush()
scriptFlush
in interface RedisScriptingReactiveCommands<K,V>
RedisScriptingReactiveCommands.scriptFlush()
Mono<String> scriptKill()
scriptKill
in interface RedisScriptingReactiveCommands<K,V>
RedisScriptingReactiveCommands.scriptKill()
Mono<String> scriptLoad(String script)
scriptLoad
in interface RedisScriptingReactiveCommands<K,V>
script
- script contentMono<String> scriptLoad(byte[] script)
scriptLoad
in interface RedisScriptingReactiveCommands<K,V>
script
- script contentMono<Void> shutdown(boolean save)
shutdown
in interface RedisServerReactiveCommands<K,V>
save
- true
force save operationRedisServerReactiveCommands.shutdown(boolean)
Mono<KeyScanCursor<K>> scan()
scan
in interface RedisKeyReactiveCommands<K,V>
RedisKeyReactiveCommands.scan(ScanArgs)
Mono<KeyScanCursor<K>> scan(ScanArgs scanArgs)
scan
in interface RedisKeyReactiveCommands<K,V>
scanArgs
- scan argumentsRedisKeyReactiveCommands.scan(ScanArgs)
Mono<KeyScanCursor<K>> scan(ScanCursor scanCursor, ScanArgs scanArgs)
scan
in interface RedisKeyReactiveCommands<K,V>
scanCursor
- cursor to resume the scan. It's required to reuse the scanCursor
instance from the previous
scan()
call.scanArgs
- scan argumentsRedisKeyReactiveCommands.scan(ScanCursor, ScanArgs)
Mono<KeyScanCursor<K>> scan(ScanCursor scanCursor)
scan
in interface RedisKeyReactiveCommands<K,V>
scanCursor
- cursor to resume the scan. It's required to reuse the scanCursor
instance from the previous
scan()
call.RedisKeyReactiveCommands.scan(ScanCursor)
Mono<StreamScanCursor> scan(KeyStreamingChannel<K> channel)
scan
in interface RedisKeyReactiveCommands<K,V>
channel
- streaming channel that receives a call for every keyRedisKeyReactiveCommands.scan(KeyStreamingChannel)
Mono<StreamScanCursor> scan(KeyStreamingChannel<K> channel, ScanArgs scanArgs)
scan
in interface RedisKeyReactiveCommands<K,V>
channel
- streaming channel that receives a call for every keyscanArgs
- scan argumentsRedisKeyReactiveCommands.scan(KeyStreamingChannel, ScanArgs)
Mono<StreamScanCursor> scan(KeyStreamingChannel<K> channel, ScanCursor scanCursor, ScanArgs scanArgs)
scan
in interface RedisKeyReactiveCommands<K,V>
channel
- streaming channel that receives a call for every keyscanCursor
- cursor to resume the scan. It's required to reuse the scanCursor
instance from the previous
scan()
call.scanArgs
- scan argumentsRedisKeyReactiveCommands.scan(KeyStreamingChannel, ScanCursor, ScanArgs)
Mono<StreamScanCursor> scan(KeyStreamingChannel<K> channel, ScanCursor scanCursor)
scan
in interface RedisKeyReactiveCommands<K,V>
channel
- streaming channel that receives a call for every keyscanCursor
- cursor to resume the scan. It's required to reuse the scanCursor
instance from the previous
scan()
call.RedisKeyReactiveCommands.scan(ScanCursor, ScanArgs)
Mono<Long> touch(K... keys)
touch
in interface RedisKeyReactiveCommands<K,V>
keys
- the keysCopyright © 2023 lettuce.io. All rights reserved.