public class RedisAdvancedClusterReactiveCommandsImpl<K,V> extends AbstractRedisReactiveCommands<K,V> implements RedisAdvancedClusterReactiveCommands<K,V>
codec, commandBuilder, connection, multi| Constructor and Description |
|---|
RedisAdvancedClusterReactiveCommandsImpl(StatefulRedisClusterConnectionImpl<K,V> connection,
RedisCodec<K,V> codec)
Initialize a new connection.
|
| Modifier and Type | Method and Description |
|---|---|
Observable<String> |
clientSetname(K name)
Set the current connection name.
|
Observable<Long> |
clusterCountKeysInSlot(int slot)
Returns the number of keys in the specified Redis Cluster hash
slot. |
Observable<K> |
clusterGetKeysInSlot(int slot,
int count)
Retrieve the list of keys within the
slot. |
Observable<Long> |
dbsize()
Return the number of keys in the selected database.
|
Observable<Long> |
del(Iterable<K> keys) |
Observable<Long> |
del(K... keys)
Delete one or more keys.
|
protected <T> Map<String,Observable<T>> |
executeOnMasters(Function<RedisClusterReactiveCommands<K,V>,Observable<T>> function)
Run a command on all available masters,
|
protected <T> Map<String,Observable<T>> |
executeOnNodes(Function<RedisClusterReactiveCommands<K,V>,Observable<T>> function,
Function<RedisClusterNode,Boolean> filter)
Run a command on all available nodes that match
filter. |
Observable<Long> |
exists(Iterable<K> keys) |
Observable<Long> |
exists(K... keys)
Determine how many keys exist.
|
Observable<String> |
flushall()
Remove all keys from all databases.
|
Observable<String> |
flushdb()
Remove all keys from the current database.
|
Observable<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. |
Observable<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. |
Observable<V> |
georadiusbymember(K key,
V member,
double distance,
GeoArgs.Unit unit)
Retrieve members selected by distance with the center of
member. |
Observable<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.
|
StatefulRedisClusterConnectionImpl<K,V> |
getStatefulConnection() |
Observable<K> |
keys(K pattern)
Find all keys matching the given pattern.
|
Observable<Long> |
keys(KeyStreamingChannel<K> channel,
K pattern)
Find all keys matching the given pattern.
|
Observable<V> |
mget(Iterable<K> keys) |
Observable<V> |
mget(K... keys)
Get the values of all the given keys.
|
Observable<Long> |
mget(ValueStreamingChannel<V> channel,
Iterable<K> keys) |
Observable<Long> |
mget(ValueStreamingChannel<V> channel,
K... keys)
Stream over the values of all the given keys.
|
Observable<String> |
mset(Map<K,V> map)
Set multiple keys to multiple values.
|
Observable<Boolean> |
msetnx(Map<K,V> map)
Set multiple keys to multiple values, only if none of the keys exist.
|
Observable<V> |
randomkey()
Return a random key from the keyspace.
|
Observable<KeyScanCursor<K>> |
scan()
Incrementally iterate the keys space.
|
Observable<StreamScanCursor> |
scan(KeyStreamingChannel<K> channel)
Incrementally iterate the keys space.
|
Observable<StreamScanCursor> |
scan(KeyStreamingChannel<K> channel,
ScanArgs scanArgs)
Incrementally iterate the keys space.
|
Observable<StreamScanCursor> |
scan(KeyStreamingChannel<K> channel,
ScanCursor scanCursor)
Incrementally iterate the keys space.
|
Observable<StreamScanCursor> |
scan(KeyStreamingChannel<K> channel,
ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate the keys space.
|
Observable<KeyScanCursor<K>> |
scan(ScanArgs scanArgs)
Incrementally iterate the keys space.
|
Observable<KeyScanCursor<K>> |
scan(ScanCursor scanCursor)
Incrementally iterate the keys space.
|
Observable<KeyScanCursor<K>> |
scan(ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate the keys space.
|
Observable<String> |
scriptFlush()
Remove all the scripts from the script cache.
|
Observable<String> |
scriptKill()
Kill the script currently in execution.
|
Observable<String> |
scriptLoad(V script)
Load the specified Lua script into the script cache.
|
Observable<Success> |
shutdown(boolean save)
Synchronously save the dataset to disk and then shut down the server.
|
Observable<Long> |
touch(Iterable<K> keys) |
Observable<Long> |
touch(K... keys)
Touch one or more keys.
|
Observable<Long> |
unlink(Iterable<K> keys) |
Observable<Long> |
unlink(K... keys)
Unlink one or more keys (non blocking DEL).
|
append, asking, auth, bgrewriteaof, bgsave, bitcount, bitcount, bitfield, bitopAnd, bitopNot, bitopOr, bitopXor, bitpos, bitpos, bitpos, blpop, brpop, brpoplpush, bzpopmax, bzpopmin, clientGetname, clientKill, clientKill, clientList, clientPause, clientUnblock, close, clusterAddSlots, clusterBumpepoch, clusterCountFailureReports, clusterDelSlots, clusterFailover, clusterFlushslots, clusterForget, clusterInfo, clusterKeyslot, clusterMeet, clusterMyId, clusterNodes, clusterReplicate, clusterReset, clusterSaveconfig, clusterSetConfigEpoch, clusterSetSlotImporting, clusterSetSlotMigrating, clusterSetSlotNode, clusterSetSlotStable, clusterSlaves, clusterSlots, command, commandCount, commandInfo, commandInfo, configGet, configResetstat, configRewrite, configSet, createDissolvingObservable, createDissolvingObservable, createObservable, createObservable, debugCrashAndRecover, debugHtstats, debugObject, debugOom, debugReload, debugRestart, debugSdslen, debugSegfault, decr, decrby, digest, discard, dispatch, dispatch, dump, echo, eval, eval, evalsha, evalsha, exec, exists, expire, expireat, expireat, flushallAsync, flushdbAsync, geoadd, geoadd, geodist, geohash, geopos, georadius_ro, georadius_ro, georadius, georadiusbymember_ro, georadiusbymember_ro, georadiusbymember, get, getbit, getConnection, getrange, getset, getSuccessObservable, 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, incr, incrby, incrbyfloat, info, info, isOpen, lastsave, lindex, linsert, llen, lpop, lpush, lpushx, lpushx, lrange, lrange, lrem, lset, ltrim, migrate, migrate, move, multi, objectEncoding, objectIdletime, objectRefcount, persist, pexpire, pexpireat, pexpireat, pfadd, pfadd, pfcount, pfcount, pfmerge, pfmerge, ping, psetex, pttl, publish, pubsubChannels, pubsubChannels, pubsubNumpat, pubsubNumsub, quit, readOnly, readWrite, rename, renamenx, reset, restore, restore, role, rpop, rpoplpush, rpush, rpushx, rpushx, sadd, save, scard, scriptExists, sdiff, sdiff, sdiffstore, select, set, set, setbit, setex, setnx, setrange, setTimeout, sinter, sinter, sinterstore, sismember, slaveof, slaveofNoOne, slowlogGet, slowlogGet, slowlogLen, slowlogReset, smembers, smembers, smove, sort, sort, sort, sort, sortStore, spop, spop, srandmember, srandmember, srandmember, srem, sscan, sscan, sscan, sscan, sscan, sscan, sscan, sscan, strlen, sunion, sunion, sunionstore, swapdb, sync, time, ttl, type, unwatch, waitForReplication, watch, xack, xadd, xadd, xadd, xadd, xclaim, xclaim, xdel, xgroupCreate, xgroupDelconsumer, xgroupDestroy, xgroupSetid, xlen, xpending, xpending, xpending, xrange, xrange, xread, xread, xreadgroup, xreadgroup, xrevrange, xrevrange, xtrim, xtrim, zadd, zadd, zadd, zadd, zadd, zadd, zaddincr, zaddincr, zcard, zcount, zcount, zcount, zincrby, zinterstore, zinterstore, zlexcount, zlexcount, zpopmax, zpopmax, zpopmin, zpopmin, 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, 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, zrevrangeWithScores, zrevrangeWithScores, zrevrank, zscan, zscan, zscan, zscan, zscan, zscan, zscan, zscan, zscore, zunionstore, zunionstoreclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitasking, auth, clusterAddSlots, clusterBumpepoch, clusterCountFailureReports, clusterDelSlots, clusterFailover, clusterFlushslots, clusterForget, clusterInfo, clusterKeyslot, clusterMeet, clusterMyId, clusterNodes, clusterReplicate, clusterReset, clusterSaveconfig, clusterSetConfigEpoch, clusterSetSlotImporting, clusterSetSlotMigrating, clusterSetSlotNode, clusterSetSlotStable, clusterSlaves, clusterSlots, readOnly, readWrite, setTimeoutclose, dispatch, dispatch, echo, isOpen, ping, publish, pubsubChannels, pubsubChannels, pubsubNumpat, pubsubNumsub, quit, reset, role, waitForReplicationgeoadd, geoadd, geodist, geohash, geopos, georadius, georadiusbymemberhdel, hexists, hget, hgetall, hgetall, hincrby, hincrbyfloat, hkeys, hkeys, hlen, hmget, hmget, hmset, hscan, hscan, hscan, hscan, hscan, hscan, hscan, hscan, hset, hsetnx, hstrlen, hvals, hvalspfadd, pfcount, pfmergedump, expire, expireat, expireat, migrate, migrate, move, objectEncoding, objectIdletime, objectRefcount, persist, pexpire, pexpireat, pexpireat, pttl, rename, renamenx, restore, restore, sort, sort, sort, sort, sortStore, ttl, typeblpop, brpop, brpoplpush, lindex, linsert, llen, lpop, lpush, lpushx, lpushx, lrange, lrange, lrem, lset, ltrim, rpop, rpoplpush, rpush, rpushx, rpushxdigest, eval, eval, evalsha, evalsha, scriptExistsbgrewriteaof, bgsave, clientGetname, clientKill, clientKill, clientList, clientPause, clientUnblock, 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, timesadd, scard, sdiff, sdiff, sdiffstore, sinter, sinter, sinterstore, sismember, smembers, smembers, smove, spop, spop, srandmember, srandmember, srandmember, srem, sscan, sscan, sscan, sscan, sscan, sscan, sscan, sscan, sunion, sunion, sunionstorebzpopmax, bzpopmin, zadd, zadd, zadd, zadd, zadd, zadd, zaddincr, zaddincr, zcard, zcount, zcount, zcount, zincrby, zinterstore, zinterstore, zlexcount, zlexcount, zpopmax, zpopmax, zpopmin, zpopmin, 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, 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, zrevrangeWithScores, zrevrangeWithScores, zrevrank, zscan, zscan, zscan, zscan, zscan, zscan, zscan, zscan, zscore, zunionstore, zunionstorexack, xadd, xadd, xadd, xadd, xclaim, xclaim, xdel, xgroupCreate, xgroupDelconsumer, xgroupDestroy, xgroupSetid, xlen, xpending, xpending, xpending, xrange, xrange, xread, xread, xreadgroup, xreadgroup, xrevrange, xrevrange, xtrim, xtrimappend, bitcount, bitcount, bitfield, bitopAnd, bitopNot, bitopOr, bitopXor, bitpos, bitpos, bitpos, decr, decrby, get, getbit, getrange, getset, incr, incrby, incrbyfloat, psetex, set, set, setbit, setex, setnx, setrange, strlenpublic RedisAdvancedClusterReactiveCommandsImpl(StatefulRedisClusterConnectionImpl<K,V> connection, RedisCodec<K,V> codec)
connection - the stateful connectioncodec - Codec used to encode/decode keys and values.public Observable<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 nameOK if the connection name was successfully set.RedisServerReactiveCommands.clientSetname(Object)public Observable<Long> clusterCountKeysInSlot(int slot)
RedisClusterReactiveCommandsslot.clusterCountKeysInSlot in interface RedisClusterReactiveCommands<K,V>clusterCountKeysInSlot in class AbstractRedisReactiveCommands<K,V>slot - the slotpublic Observable<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 Observable<Long> dbsize()
RedisServerReactiveCommandsdbsize in interface RedisServerReactiveCommands<K,V>dbsize in interface RedisAdvancedClusterReactiveCommands<K,V>dbsize in class AbstractRedisReactiveCommands<K,V>RedisServerReactiveCommands.dbsize()public Observable<Long> del(K... keys)
RedisKeyReactiveCommandsdel in interface RedisKeyReactiveCommands<K,V>del in interface RedisAdvancedClusterReactiveCommands<K,V>del in interface RedisClusterReactiveCommands<K,V>del in class AbstractRedisReactiveCommands<K,V>keys - the keysRedisKeyReactiveCommands.del(Object[])public Observable<Long> del(Iterable<K> keys)
del in class AbstractRedisReactiveCommands<K,V>public Observable<Long> exists(K... keys)
RedisKeyReactiveCommandsexists in interface RedisKeyReactiveCommands<K,V>exists in interface RedisAdvancedClusterReactiveCommands<K,V>exists in class AbstractRedisReactiveCommands<K,V>keys - the keyspublic Observable<Long> exists(Iterable<K> keys)
exists in class AbstractRedisReactiveCommands<K,V>public Observable<String> flushall()
RedisServerReactiveCommandsflushall in interface RedisServerReactiveCommands<K,V>flushall in interface RedisAdvancedClusterReactiveCommands<K,V>flushall in class AbstractRedisReactiveCommands<K,V>RedisServerReactiveCommands.flushall()public Observable<String> flushdb()
RedisServerReactiveCommandsflushdb in interface RedisServerReactiveCommands<K,V>flushdb in interface RedisAdvancedClusterReactiveCommands<K,V>flushdb in class AbstractRedisReactiveCommands<K,V>RedisServerReactiveCommands.flushdb()public Observable<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 setlongitude - the longitude coordinate according to WGS84latitude - the latitude coordinate according to WGS84distance - radius distanceunit - distance unitpublic Observable<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 setlongitude - the longitude coordinate according to WGS84latitude - the latitude coordinate according to WGS84distance - radius distanceunit - distance unitgeoArgs - args to control the resultGeoWithin contains only fields which were requested by GeoArgspublic Observable<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 setmember - reference memberdistance - radius distanceunit - distance unitpublic Observable<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 setmember - reference memberdistance - radius distanceunit - distance unitgeoArgs - args to control the resultGeoWithin contains only fields which were requested by GeoArgspublic Observable<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 Observable<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 channelpattern - the patternpattern.RedisKeyReactiveCommands.keys(KeyStreamingChannel, Object)public Observable<V> mget(K... keys)
RedisStringReactiveCommandsmget in interface RedisStringReactiveCommands<K,V>mget in interface RedisAdvancedClusterReactiveCommands<K,V>mget in interface RedisClusterReactiveCommands<K,V>mget in class AbstractRedisReactiveCommands<K,V>keys - the keyRedisStringReactiveCommands.mget(Object[])public Observable<V> mget(Iterable<K> keys)
mget in class AbstractRedisReactiveCommands<K,V>public Observable<Long> mget(ValueStreamingChannel<V> channel, K... keys)
RedisStringReactiveCommandsmget in interface RedisStringReactiveCommands<K,V>mget in class AbstractRedisReactiveCommands<K,V>channel - the channelkeys - the keyspublic Observable<Long> mget(ValueStreamingChannel<V> channel, Iterable<K> keys)
mget in class AbstractRedisReactiveCommands<K,V>public Observable<Boolean> msetnx(Map<K,V> map)
RedisStringReactiveCommandsmsetnx in interface RedisStringReactiveCommands<K,V>msetnx in interface RedisAdvancedClusterReactiveCommands<K,V>msetnx in interface RedisClusterReactiveCommands<K,V>msetnx in class AbstractRedisReactiveCommands<K,V>map - the null1 if the all the keys were set. 0 if no key was set (at least one key already existed).RedisStringReactiveCommands.msetnx(Map)public Observable<String> mset(Map<K,V> map)
RedisStringReactiveCommandsmset in interface RedisStringReactiveCommands<K,V>mset in interface RedisAdvancedClusterReactiveCommands<K,V>mset in interface RedisClusterReactiveCommands<K,V>mset in class AbstractRedisReactiveCommands<K,V>map - the nullOK since MSET can't fail.RedisStringReactiveCommands.mset(Map)public Observable<V> randomkey()
RedisKeyReactiveCommandsrandomkey in interface RedisKeyReactiveCommands<K,V>randomkey in interface RedisAdvancedClusterReactiveCommands<K,V>randomkey in class AbstractRedisReactiveCommands<K,V>RedisKeyReactiveCommands.randomkey()public Observable<String> scriptFlush()
RedisScriptingReactiveCommandsscriptFlush in interface RedisScriptingReactiveCommands<K,V>scriptFlush in interface RedisAdvancedClusterReactiveCommands<K,V>scriptFlush in class AbstractRedisReactiveCommands<K,V>RedisScriptingReactiveCommands.scriptFlush()public Observable<String> scriptKill()
RedisScriptingReactiveCommandsscriptKill in interface RedisScriptingReactiveCommands<K,V>scriptKill in interface RedisAdvancedClusterReactiveCommands<K,V>scriptKill in class AbstractRedisReactiveCommands<K,V>RedisScriptingReactiveCommands.scriptKill()public Observable<String> scriptLoad(V script)
RedisScriptingReactiveCommandsscriptLoad in interface RedisScriptingReactiveCommands<K,V>scriptLoad in interface RedisAdvancedClusterReactiveCommands<K,V>scriptLoad in class AbstractRedisReactiveCommands<K,V>script - script contentpublic Observable<Success> 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 operationRedisServerReactiveCommands.shutdown(boolean)public Observable<Long> touch(K... keys)
RedisKeyReactiveCommandstouch in interface RedisKeyReactiveCommands<K,V>touch in interface RedisAdvancedClusterReactiveCommands<K,V>touch in class AbstractRedisReactiveCommands<K,V>keys - the keyspublic Observable<Long> touch(Iterable<K> keys)
touch in class AbstractRedisReactiveCommands<K,V>public Observable<Long> unlink(K... keys)
RedisKeyReactiveCommandsunlink in interface RedisKeyReactiveCommands<K,V>unlink in interface RedisAdvancedClusterReactiveCommands<K,V>unlink in class AbstractRedisReactiveCommands<K,V>keys - the keysRedisKeyReactiveCommands.unlink(Object[])public Observable<Long> unlink(Iterable<K> keys)
unlink in class AbstractRedisReactiveCommands<K,V>protected <T> Map<String,Observable<T>> executeOnMasters(Function<RedisClusterReactiveCommands<K,V>,Observable<T>> function)
T - result typefunction - function producing the commandprotected <T> Map<String,Observable<T>> executeOnNodes(Function<RedisClusterReactiveCommands<K,V>,Observable<T>> function, Function<RedisClusterNode,Boolean> filter)
filter.T - result typefunction - function producing the commandfilter - filter function for the node selectionpublic StatefulRedisClusterConnectionImpl<K,V> getStatefulConnection()
getStatefulConnection in interface RedisAdvancedClusterReactiveCommands<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 Observable<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 Observable<KeyScanCursor<K>> scan(ScanArgs scanArgs)
RedisKeyReactiveCommandsscan in interface RedisKeyReactiveCommands<K,V>scan in interface RedisAdvancedClusterReactiveCommands<K,V>scan in class AbstractRedisReactiveCommands<K,V>scanArgs - scan argumentsRedisKeyReactiveCommands.scan(ScanArgs)public Observable<KeyScanCursor<K>> scan(ScanCursor scanCursor, ScanArgs scanArgs)
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 nullscanArgs - scan argumentsRedisKeyReactiveCommands.scan(ScanCursor, ScanArgs)public Observable<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 nullRedisKeyReactiveCommands.scan(ScanCursor)public Observable<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 keyRedisKeyReactiveCommands.scan(KeyStreamingChannel)public Observable<StreamScanCursor> scan(KeyStreamingChannel<K> channel, ScanArgs scanArgs)
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 keyscanArgs - scan argumentsRedisKeyReactiveCommands.scan(KeyStreamingChannel, ScanArgs)public Observable<StreamScanCursor> scan(KeyStreamingChannel<K> channel, ScanCursor scanCursor, ScanArgs scanArgs)
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 keyscanCursor - cursor to resume from a previous scan, must not be nullscanArgs - scan argumentsRedisKeyReactiveCommands.scan(KeyStreamingChannel, ScanCursor, ScanArgs)public Observable<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 keyscanCursor - cursor to resume from a previous scan, must not be nullRedisKeyReactiveCommands.scan(ScanCursor, ScanArgs)Copyright © 2018 lettuce.io. All rights reserved.