K - Key type.V - Value type.public class RedisAdvancedClusterReactiveCommandsImpl<K,V> extends AbstractRedisReactiveCommands<K,V> implements RedisAdvancedClusterReactiveCommands<K,V>
| Constructor and Description |
|---|
RedisAdvancedClusterReactiveCommandsImpl(StatefulRedisClusterConnection<K,V> connection,
RedisCodec<K,V> codec)
Initialize a new connection.
|
RedisAdvancedClusterReactiveCommandsImpl(StatefulRedisClusterConnectionImpl<K,V> connection,
RedisCodec<K,V> codec)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
Mono<String> |
clientSetname(K name)
Set the current connection name.
|
Mono<Long> |
clusterCountKeysInSlot(int slot)
Returns the number of keys in the specified Redis Cluster hash
slot. |
Flux<K> |
clusterGetKeysInSlot(int slot,
int count)
Retrieve the list of keys within the
slot. |
Mono<Long> |
dbsize()
Return the number of keys in the selected database.
|
Mono<Long> |
del(Iterable<K> keys) |
Mono<Long> |
del(K... keys)
Delete one or more keys.
|
protected <T> Map<String,org.reactivestreams.Publisher<T>> |
executeOnNodes(Function<RedisClusterReactiveCommands<K,V>,? extends org.reactivestreams.Publisher<T>> function,
Predicate<RedisClusterNode> filter)
Run a command on all available nodes that match
filter. |
protected <T> Map<String,org.reactivestreams.Publisher<T>> |
executeOnUpstream(Function<RedisClusterReactiveCommands<K,V>,? extends org.reactivestreams.Publisher<T>> function)
Run a command on all available masters,
|
Mono<Long> |
exists(Iterable<K> keys) |
Mono<Long> |
exists(K... keys)
Determine how many keys exist.
|
Mono<String> |
flushall()
Remove all keys from all databases.
|
Mono<String> |
flushall(FlushMode flushMode)
Remove all keys from all databases using the specified
FlushMode. |
Mono<String> |
flushallAsync()
Remove all keys asynchronously from all databases.
|
Mono<String> |
flushdb()
Remove all keys from the current database.
|
Mono<String> |
flushdb(FlushMode flushMode)
Remove all keys from the current database using the specified
FlushMode. |
Flux<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. |
Flux<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. |
Flux<V> |
georadiusbymember(K key,
V member,
double distance,
GeoArgs.Unit unit)
Retrieve members selected by distance with the center of
member. |
Flux<GeoWithin<V>> |
georadiusbymember(K key,
V member,
double distance,
GeoArgs.Unit unit,
GeoArgs geoArgs)
Retrieve members selected by distance with the center of
member. |
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() |
Flux<K> |
keys(K pattern)
Find all keys matching the given pattern.
|
Mono<Long> |
keys(KeyStreamingChannel<K> channel,
K pattern)
Find all keys matching the given pattern.
|
Flux<KeyValue<K,V>> |
mget(Iterable<K> keys) |
Flux<KeyValue<K,V>> |
mget(K... keys)
Get the values of all the given keys.
|
Mono<Long> |
mget(KeyValueStreamingChannel<K,V> channel,
Iterable<K> keys) |
Mono<Long> |
mget(KeyValueStreamingChannel<K,V> channel,
K... keys)
Stream over the values of all the given keys.
|
Mono<String> |
mset(Map<K,V> map)
Set multiple keys to multiple values.
|
Mono<Boolean> |
msetnx(Map<K,V> map)
Set multiple keys to multiple values, only if none of the keys exist.
|
Mono<K> |
randomkey()
Return a random key from the keyspace.
|
Mono<KeyScanCursor<K>> |
scan()
Incrementally iterate the keys space.
|
Mono<StreamScanCursor> |
scan(KeyStreamingChannel<K> channel)
Incrementally iterate the keys space.
|
Mono<StreamScanCursor> |
scan(KeyStreamingChannel<K> channel,
ScanArgs scanArgs)
Incrementally iterate the keys space.
|
Mono<StreamScanCursor> |
scan(KeyStreamingChannel<K> channel,
ScanCursor scanCursor)
Incrementally iterate the keys space.
|
Mono<StreamScanCursor> |
scan(KeyStreamingChannel<K> channel,
ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate the keys space.
|
Mono<KeyScanCursor<K>> |
scan(ScanArgs scanArgs)
Incrementally iterate the keys space.
|
Mono<KeyScanCursor<K>> |
scan(ScanCursor scanCursor)
Incrementally iterate the keys space.
|
Mono<KeyScanCursor<K>> |
scan(ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate the keys space.
|
Mono<String> |
scriptFlush()
Remove all the scripts from the script cache.
|
Mono<String> |
scriptKill()
Kill the script currently in execution.
|
Mono<String> |
scriptLoad(byte[] script)
Load the specified Lua script into the script cache.
|
Mono<Void> |
shutdown(boolean save)
Synchronously save the dataset to disk and then shut down the server.
|
Mono<Long> |
touch(Iterable<K> keys) |
Mono<Long> |
touch(K... keys)
Touch one or more keys.
|
Mono<Long> |
unlink(Iterable<K> keys) |
Mono<Long> |
unlink(K... keys)
Unlink one or more keys (non blocking DEL).
|
aclCat, aclCat, aclDeluser, aclDryRun, aclDryRun, aclGenpass, aclGenpass, aclGetuser, aclList, aclLoad, aclLog, aclLog, aclLogReset, aclSave, aclSetuser, aclUsers, aclWhoami, append, asking, auth, auth, bgrewriteaof, bgsave, bitcount, bitcount, bitfield, bitopAnd, bitopNot, bitopOr, bitopXor, bitpos, bitpos, bitpos, blmove, blmove, blmpop, blmpop, blpop, blpop, brpop, brpop, brpoplpush, brpoplpush, bzpopmax, bzpopmax, bzpopmin, bzpopmin, clientCaching, clientGetname, clientGetredir, clientId, clientKill, clientKill, clientList, clientNoEvict, clientPause, clientTracking, clientUnblock, close, clusterAddSlots, clusterAddSlotsRange, clusterBumpepoch, clusterCountFailureReports, clusterDelSlots, clusterDelSlotsRange, clusterFailover, clusterFailover, clusterFlushslots, clusterForget, clusterInfo, clusterKeyslot, clusterMeet, clusterMyId, clusterNodes, clusterReplicas, clusterReplicate, clusterReset, clusterSaveconfig, clusterSetConfigEpoch, clusterSetSlotImporting, clusterSetSlotMigrating, clusterSetSlotNode, clusterSetSlotStable, clusterShards, clusterSlaves, clusterSlots, command, commandCount, commandInfo, commandInfo, configGet, configGet, configResetstat, configRewrite, configSet, configSet, copy, copy, createDissolvingFlux, createFlux, createMono, createMono, debugCrashAndRecover, debugHtstats, debugObject, debugOom, debugReload, debugRestart, debugSdslen, debugSegfault, decr, decrby, digest, digest, discard, dispatch, dispatch, dump, echo, eval, eval, eval, eval, evalReadOnly, evalsha, evalsha, evalshaReadOnly, exec, exists, expire, expire, expire, expire, expireat, expireat, expireat, expireat, expireat, expireat, expiretime, flushCommands, flushdbAsync, geoadd, geoadd, geoadd, geoadd, geoadd, geoadd, geodist, geohash, geopos, georadius_ro, georadius_ro, georadius, georadiusbymember_ro, georadiusbymember_ro, georadiusbymember, geosearch, geosearch, geosearchstore, get, getbit, getConnection, getdel, getex, getrange, getset, 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, incr, incrby, incrbyfloat, info, info, isOpen, lastsave, lindex, linsert, llen, lmove, lmpop, lpop, lpop, lpos, lpos, lpos, lpos, lpush, lpushx, lrange, lrange, lrem, lset, ltrim, memoryUsage, mget, migrate, migrate, move, multi, objectEncoding, objectFreq, objectIdletime, objectRefcount, persist, pexpire, pexpire, pexpire, pexpire, pexpireat, pexpireat, pexpireat, pexpireat, pexpireat, pexpireat, pexpiretime, pfadd, pfadd, pfcount, pfcount, pfmerge, pfmerge, ping, psetex, pttl, publish, pubsubChannels, pubsubChannels, pubsubNumpat, pubsubNumsub, quit, readOnly, readWrite, rename, renamenx, replicaof, replicaofNoOne, reset, restore, restore, role, rpop, rpop, rpoplpush, rpush, rpushx, sadd, save, scard, scriptExists, scriptFlush, scriptLoad, sdiff, sdiff, sdiffstore, select, set, set, setAutoFlushCommands, setbit, setex, setGet, setGet, setnx, setrange, setTimeout, shutdown, sinter, sinter, sintercard, sintercard, sinterstore, sismember, slaveof, slaveofNoOne, slowlogGet, slowlogGet, slowlogLen, slowlogReset, smembers, smembers, smismember, smove, sort, sort, sort, sort, sortReadOnly, sortReadOnly, sortReadOnly, sortReadOnly, sortStore, spop, spop, srandmember, srandmember, srandmember, srem, sscan, sscan, sscan, sscan, sscan, sscan, sscan, sscan, stralgoLcs, strlen, sunion, sunion, sunionstore, swapdb, time, ttl, type, unwatch, waitForReplication, watch, 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, 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, zunionWithScoresclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitscriptLoadasking, auth, auth, clusterAddSlots, clusterAddSlotsRange, clusterBumpepoch, clusterCountFailureReports, clusterDelSlots, clusterDelSlotsRange, clusterFailover, clusterFailover, clusterFlushslots, clusterForget, clusterInfo, clusterKeyslot, clusterMeet, clusterMyId, clusterNodes, clusterReplicas, clusterReplicate, clusterReset, clusterSaveconfig, clusterSetConfigEpoch, clusterSetSlotImporting, clusterSetSlotMigrating, clusterSetSlotNode, clusterSetSlotStable, clusterShards, clusterSlaves, clusterSlots, readOnly, readWrite, setTimeoutdispatch, dispatch, echo, flushCommands, isOpen, ping, publish, pubsubChannels, pubsubChannels, pubsubNumpat, pubsubNumsub, quit, reset, role, setAutoFlushCommands, waitForReplicationaclCat, aclCat, aclDeluser, aclDryRun, aclDryRun, aclGenpass, aclGenpass, aclGetuser, aclList, aclLoad, aclLog, aclLog, aclLogReset, aclSave, aclSetuser, aclUsers, aclWhoamigeoadd, geoadd, geoadd, geoadd, geoadd, geoadd, geodist, geohash, geopos, georadius, georadiusbymember, geosearch, geosearch, geosearchstorehdel, 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, hvalspfadd, pfcount, pfmergecopy, 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, typeblmove, 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, rpushxdigest, digest, eval, eval, eval, eval, evalReadOnly, evalsha, evalsha, evalshaReadOnly, scriptExists, scriptFlushbgrewriteaof, 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, flushdbAsync, info, info, lastsave, memoryUsage, replicaof, replicaofNoOne, save, shutdown, slaveof, slaveofNoOne, slowlogGet, slowlogGet, slowlogLen, slowlogReset, timesadd, 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, sunionstorebzpopmax, 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, zunionWithScoresxack, 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, xtrimappend, bitcount, bitcount, bitfield, bitopAnd, bitopNot, bitopOr, bitopXor, bitpos, bitpos, bitpos, decr, decrby, get, getbit, getdel, getex, getrange, getset, incr, incrby, incrbyfloat, psetex, set, set, setbit, setex, setGet, setGet, setnx, setrange, stralgoLcs, strlen@Deprecated public RedisAdvancedClusterReactiveCommandsImpl(StatefulRedisClusterConnectionImpl<K,V> connection, RedisCodec<K,V> codec)
RedisAdvancedClusterReactiveCommandsImpl(StatefulRedisClusterConnection, RedisCodec).connection - the stateful connection.codec - Codec used to encode/decode keys and values.public RedisAdvancedClusterReactiveCommandsImpl(StatefulRedisClusterConnection<K,V> connection, RedisCodec<K,V> codec)
connection - the stateful connection.codec - Codec used to encode/decode keys and values.public Mono<String> clientSetname(K name)
RedisServerReactiveCommandsclientSetname in interface RedisServerReactiveCommands<K,V>clientSetname in interface RedisAdvancedClusterReactiveCommands<K,V>clientSetname in class AbstractRedisReactiveCommands<K,V>name - the client name.OK if the connection name was successfully set.RedisServerReactiveCommands.clientSetname(Object)public Mono<Long> clusterCountKeysInSlot(int slot)
RedisClusterReactiveCommandsslot.clusterCountKeysInSlot in interface RedisClusterReactiveCommands<K,V>clusterCountKeysInSlot in class AbstractRedisReactiveCommands<K,V>slot - the slotpublic Flux<K> clusterGetKeysInSlot(int slot, int count)
RedisClusterReactiveCommandsslot.clusterGetKeysInSlot in interface RedisClusterReactiveCommands<K,V>clusterGetKeysInSlot in class AbstractRedisReactiveCommands<K,V>slot - the slotcount - maximal number of keyspublic Mono<Long> dbsize()
RedisServerReactiveCommandsdbsize in interface RedisServerReactiveCommands<K,V>dbsize in interface RedisAdvancedClusterReactiveCommands<K,V>dbsize in class AbstractRedisReactiveCommands<K,V>RedisServerReactiveCommands.dbsize()public Mono<Long> del(K... keys)
RedisKeyReactiveCommandsdel in interface RedisKeyReactiveCommands<K,V>del in interface RedisAdvancedClusterReactiveCommands<K,V>del in class AbstractRedisReactiveCommands<K,V>keys - the keys.RedisKeyReactiveCommands.del(Object[])public Mono<Long> del(Iterable<K> keys)
del in class AbstractRedisReactiveCommands<K,V>public Mono<Long> exists(K... keys)
RedisKeyReactiveCommandsexists in interface RedisKeyReactiveCommands<K,V>exists in interface RedisAdvancedClusterReactiveCommands<K,V>exists in class AbstractRedisReactiveCommands<K,V>keys - the keys.public Mono<Long> exists(Iterable<K> keys)
exists in class AbstractRedisReactiveCommands<K,V>public Mono<String> flushall()
RedisServerReactiveCommandsflushall in interface RedisServerReactiveCommands<K,V>flushall in interface RedisAdvancedClusterReactiveCommands<K,V>flushall in class AbstractRedisReactiveCommands<K,V>RedisServerReactiveCommands.flushall()public Mono<String> flushall(FlushMode flushMode)
RedisServerReactiveCommandsFlushMode.flushall in interface RedisServerReactiveCommands<K,V>flushall in class AbstractRedisReactiveCommands<K,V>flushMode - the flush mode (sync/async).public Mono<String> flushallAsync()
RedisServerReactiveCommandsflushallAsync in interface RedisServerReactiveCommands<K,V>flushallAsync in interface RedisAdvancedClusterReactiveCommands<K,V>flushallAsync in class AbstractRedisReactiveCommands<K,V>RedisServerReactiveCommands.flushallAsync()public Mono<String> flushdb()
RedisServerReactiveCommandsflushdb in interface RedisServerReactiveCommands<K,V>flushdb in interface RedisAdvancedClusterReactiveCommands<K,V>flushdb in class AbstractRedisReactiveCommands<K,V>RedisServerReactiveCommands.flushdb()public Mono<String> flushdb(FlushMode flushMode)
RedisServerReactiveCommandsFlushMode.flushdb in interface RedisServerReactiveCommands<K,V>flushdb in class AbstractRedisReactiveCommands<K,V>flushMode - the flush mode (sync/async).public Flux<V> georadius(K key, double longitude, double latitude, double distance, GeoArgs.Unit unit)
RedisGeoReactiveCommandslongitude and latitude.georadius in interface RedisGeoReactiveCommands<K,V>georadius in class AbstractRedisReactiveCommands<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 Flux<GeoWithin<V>> georadius(K key, double longitude, double latitude, double distance, GeoArgs.Unit unit, GeoArgs geoArgs)
RedisGeoReactiveCommandslongitude and latitude.georadius in interface RedisGeoReactiveCommands<K,V>georadius in class AbstractRedisReactiveCommands<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 Flux<V> georadiusbymember(K key, V member, double distance, GeoArgs.Unit unit)
RedisGeoReactiveCommandsmember. The member itself is always contained in the
results.georadiusbymember in interface RedisGeoReactiveCommands<K,V>georadiusbymember in class AbstractRedisReactiveCommands<K,V>key - the key of the geo set.member - reference member.distance - radius distance.unit - distance unit.public Flux<GeoWithin<V>> georadiusbymember(K key, V member, double distance, GeoArgs.Unit unit, GeoArgs geoArgs)
RedisGeoReactiveCommandsmember. The member itself is always contained in the
results.georadiusbymember in interface RedisGeoReactiveCommands<K,V>georadiusbymember in class AbstractRedisReactiveCommands<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 Flux<K> keys(K pattern)
RedisKeyReactiveCommandskeys in interface RedisKeyReactiveCommands<K,V>keys in interface RedisAdvancedClusterReactiveCommands<K,V>keys in class AbstractRedisReactiveCommands<K,V>pattern - the pattern type: patternkey (pattern).pattern.RedisKeyReactiveCommands.keys(Object)public Mono<Long> keys(KeyStreamingChannel<K> channel, K pattern)
RedisKeyReactiveCommandskeys in interface RedisKeyReactiveCommands<K,V>keys in interface RedisAdvancedClusterReactiveCommands<K,V>keys in class AbstractRedisReactiveCommands<K,V>channel - the channel.pattern - the pattern.pattern.RedisKeyReactiveCommands.keys(KeyStreamingChannel, Object)public Flux<KeyValue<K,V>> mget(K... keys)
RedisStringReactiveCommandsmget in interface RedisStringReactiveCommands<K,V>mget in interface RedisAdvancedClusterReactiveCommands<K,V>mget in class AbstractRedisReactiveCommands<K,V>keys - the key.RedisStringReactiveCommands.mget(Object[])public Flux<KeyValue<K,V>> mget(Iterable<K> keys)
mget in class AbstractRedisReactiveCommands<K,V>public Mono<Long> mget(KeyValueStreamingChannel<K,V> channel, K... keys)
RedisStringReactiveCommandsmget in interface RedisStringReactiveCommands<K,V>mget in class AbstractRedisReactiveCommands<K,V>channel - the channel.keys - the keys.public Mono<Long> mget(KeyValueStreamingChannel<K,V> channel, Iterable<K> keys)
mget in class AbstractRedisReactiveCommands<K,V>public Mono<Boolean> msetnx(Map<K,V> map)
RedisStringReactiveCommandsmsetnx in interface RedisStringReactiveCommands<K,V>msetnx in interface RedisAdvancedClusterReactiveCommands<K,V>msetnx in class AbstractRedisReactiveCommands<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).RedisStringReactiveCommands.msetnx(Map)public Mono<String> mset(Map<K,V> map)
RedisStringReactiveCommandsmset in interface RedisStringReactiveCommands<K,V>mset in interface RedisAdvancedClusterReactiveCommands<K,V>mset in class AbstractRedisReactiveCommands<K,V>map - the map.OK since MSET can't fail.RedisStringReactiveCommands.mset(Map)public Mono<K> randomkey()
RedisKeyReactiveCommandsrandomkey in interface RedisKeyReactiveCommands<K,V>randomkey in interface RedisAdvancedClusterReactiveCommands<K,V>randomkey in class AbstractRedisReactiveCommands<K,V>null when the database is empty.RedisKeyReactiveCommands.randomkey()public Mono<String> scriptFlush()
RedisScriptingReactiveCommandsscriptFlush in interface RedisScriptingReactiveCommands<K,V>scriptFlush in interface RedisAdvancedClusterReactiveCommands<K,V>scriptFlush in class AbstractRedisReactiveCommands<K,V>RedisScriptingReactiveCommands.scriptFlush()public Mono<String> scriptKill()
RedisScriptingReactiveCommandsscriptKill in interface RedisScriptingReactiveCommands<K,V>scriptKill in interface RedisAdvancedClusterReactiveCommands<K,V>scriptKill in class AbstractRedisReactiveCommands<K,V>RedisScriptingReactiveCommands.scriptKill()public Mono<String> scriptLoad(byte[] script)
RedisScriptingReactiveCommandsscriptLoad in interface RedisScriptingReactiveCommands<K,V>scriptLoad in interface RedisAdvancedClusterReactiveCommands<K,V>scriptLoad in class AbstractRedisReactiveCommands<K,V>script - script content.public Mono<Void> shutdown(boolean save)
RedisServerReactiveCommandsshutdown in interface RedisServerReactiveCommands<K,V>shutdown in interface RedisAdvancedClusterReactiveCommands<K,V>shutdown in class AbstractRedisReactiveCommands<K,V>save - true force save operation.RedisServerReactiveCommands.shutdown(boolean)public Mono<Long> touch(K... keys)
RedisKeyReactiveCommandstouch in interface RedisKeyReactiveCommands<K,V>touch in interface RedisAdvancedClusterReactiveCommands<K,V>touch in class AbstractRedisReactiveCommands<K,V>keys - the keys.public Mono<Long> touch(Iterable<K> keys)
touch in class AbstractRedisReactiveCommands<K,V>public Mono<Long> unlink(K... keys)
RedisKeyReactiveCommandsunlink in interface RedisKeyReactiveCommands<K,V>unlink in interface RedisAdvancedClusterReactiveCommands<K,V>unlink in class AbstractRedisReactiveCommands<K,V>keys - the keys.RedisKeyReactiveCommands.unlink(Object[])public Mono<Long> unlink(Iterable<K> keys)
unlink in class AbstractRedisReactiveCommands<K,V>public RedisClusterReactiveCommands<K,V> getConnection(String nodeId)
RedisAdvancedClusterReactiveCommandsRedisAdvancedClusterReactiveCommands, node-connections do not route commands to other cluster
nodesgetConnection in interface RedisAdvancedClusterReactiveCommands<K,V>nodeId - the node Idpublic RedisClusterReactiveCommands<K,V> getConnection(String host, int port)
RedisAdvancedClusterReactiveCommandsRedisAdvancedClusterReactiveCommands, node-connections do not route commands to other cluster nodes. Host and
port connections are verified by default for cluster membership, see
ClusterClientOptions.isValidateClusterNodeMembership().getConnection in interface RedisAdvancedClusterReactiveCommands<K,V>host - the hostport - the portpublic StatefulRedisClusterConnection<K,V> getStatefulConnection()
getStatefulConnection in interface RedisAdvancedClusterReactiveCommands<K,V>public Mono<KeyScanCursor<K>> scan()
RedisKeyReactiveCommandsscan in interface RedisKeyReactiveCommands<K,V>scan in interface RedisAdvancedClusterReactiveCommands<K,V>scan in class AbstractRedisReactiveCommands<K,V>RedisKeyReactiveCommands.scan(ScanArgs)public Mono<KeyScanCursor<K>> scan(ScanArgs scanArgs)
RedisKeyReactiveCommandsKeyScanArgs to specify SCAN-specific arguments.scan in interface RedisKeyReactiveCommands<K,V>scan in interface RedisAdvancedClusterReactiveCommands<K,V>scan in class AbstractRedisReactiveCommands<K,V>scanArgs - scan arguments.KeyScanArgspublic Mono<KeyScanCursor<K>> scan(ScanCursor scanCursor, ScanArgs scanArgs)
RedisKeyReactiveCommandsKeyScanArgs to specify SCAN-specific arguments.scan in interface RedisKeyReactiveCommands<K,V>scan in interface RedisAdvancedClusterReactiveCommands<K,V>scan in class AbstractRedisReactiveCommands<K,V>scanCursor - cursor to resume from a previous scan, must not be null.scanArgs - scan arguments.KeyScanArgspublic Mono<KeyScanCursor<K>> scan(ScanCursor scanCursor)
RedisKeyReactiveCommandsscan in interface RedisKeyReactiveCommands<K,V>scan in interface RedisAdvancedClusterReactiveCommands<K,V>scan in class AbstractRedisReactiveCommands<K,V>scanCursor - cursor to resume from a previous scan, must not be null.RedisKeyReactiveCommands.scan(ScanCursor)public Mono<StreamScanCursor> scan(KeyStreamingChannel<K> channel)
RedisKeyReactiveCommandsscan in interface RedisKeyReactiveCommands<K,V>scan in interface RedisAdvancedClusterReactiveCommands<K,V>scan in class AbstractRedisReactiveCommands<K,V>channel - streaming channel that receives a call for every key.RedisKeyReactiveCommands.scan(KeyStreamingChannel)public Mono<StreamScanCursor> scan(KeyStreamingChannel<K> channel, ScanArgs scanArgs)
RedisKeyReactiveCommandsKeyScanArgs to specify SCAN-specific arguments.scan in interface RedisKeyReactiveCommands<K,V>scan in interface RedisAdvancedClusterReactiveCommands<K,V>scan in class AbstractRedisReactiveCommands<K,V>channel - streaming channel that receives a call for every key.scanArgs - scan arguments.KeyScanArgspublic Mono<StreamScanCursor> scan(KeyStreamingChannel<K> channel, ScanCursor scanCursor, ScanArgs scanArgs)
RedisKeyReactiveCommandsKeyScanArgs to specify SCAN-specific arguments.scan in interface RedisKeyReactiveCommands<K,V>scan in interface RedisAdvancedClusterReactiveCommands<K,V>scan in class AbstractRedisReactiveCommands<K,V>channel - streaming channel that receives a call for every key.scanCursor - cursor to resume from a previous scan, must not be null.scanArgs - scan arguments.KeyScanArgspublic Mono<StreamScanCursor> scan(KeyStreamingChannel<K> channel, ScanCursor scanCursor)
RedisKeyReactiveCommandsscan in interface RedisKeyReactiveCommands<K,V>scan in interface RedisAdvancedClusterReactiveCommands<K,V>scan in class AbstractRedisReactiveCommands<K,V>channel - streaming channel that receives a call for every key.scanCursor - cursor to resume from a previous scan, must not be null.RedisKeyReactiveCommands.scan(ScanCursor, ScanArgs)protected <T> Map<String,org.reactivestreams.Publisher<T>> executeOnUpstream(Function<RedisClusterReactiveCommands<K,V>,? extends org.reactivestreams.Publisher<T>> function)
T - result typefunction - function producing the commandprotected <T> Map<String,org.reactivestreams.Publisher<T>> executeOnNodes(Function<RedisClusterReactiveCommands<K,V>,? extends org.reactivestreams.Publisher<T>> function, Predicate<RedisClusterNode> filter)
filter.T - result typefunction - function producing the commandfilter - filter function for the node selectionCopyright © 2023 lettuce.io. All rights reserved.