Commands mapping
| Redis or Valkey command | Sync / Async API Redisson.create(config) |
Reactive API redisson.reactive() |
RxJava3 API redisson.rxJava() |
|---|---|---|---|
| AUTH | Config.setPassword() | - | - |
| APPEND | RBinaryStream. getOutputStream().write() |
- | - |
| BZPOPMAX | RScoredSortedSet. pollLast() pollLastAsync() |
RScoredSortedSetReactive. pollLast() |
RScoredSortedSetRx. pollLast() |
| BZPOPMIN | RScoredSortedSet. pollFirst() pollFirstAsync() |
RScoredSortedSetReactive. pollFirst() |
RScoredSortedSetRx. pollFirst() |
| BZMPOP | RScoredSortedSet. pollLast() pollLastAsync() pollLastFromAny() pollLastEntriesFromAny() |
RScoredSortedSetReactive. pollLast() pollLastFromAny() pollLastEntriesFromAny() |
RScoredSortedSetRx. pollLast() pollLastFromAny() pollLastEntriesFromAny() |
| BITCOUNT | RBitSet. cardinality() cardinalityAsync() |
RBitSetReactive. cardinality() |
RBitSetRx. cardinality() |
| BITOP | RBitSet. or() and() xor() orAsync() andAsync() xorAsync() |
RBitSetReactive. or() and() xor() |
RBitSetRx. or() and() xor() |
| BITPOS | RBitSet. length() lengthAsync() |
RBitSetReactive. length() |
RBitSetRx. length() |
| BITFIELD | RBitSet. getByte() setByte() incrementAndGetByte() getShort() setShort() incrementAndGetShort() getInteger() setInteger() incrementAndGetInteger() getLong() setLong() incrementAndGetLong() |
RBitSetReactive. getByte() setByte() incrementAndGetByte() getShort() setShort() incrementAndGetShort() getInteger() setInteger() incrementAndGetInteger() getLong() setLong() incrementAndGetLong() |
RBitSetRx. getByte() setByte() incrementAndGetByte() getShort() setShort() incrementAndGetShort() getInteger() setInteger() incrementAndGetInteger() getLong() setLong() incrementAndGetLong() |
| BLMPOP | RBlockingQueue. pollLastFromAny() pollFirstFromAny() pollLastFromAnyAsync() pollFirstFromAnyAsync() |
RBlockingQueueReactive. pollLastFromAny() pollFirstFromAny() |
RBlockingQueueRx. pollLastFromAny() pollFirstFromAny() |
| BLPOP | RBlockingQueue. take() poll() pollFromAny() takeAsync() pollAsync() pollFromAnyAsync() |
RBlockingQueueReactive. take() poll() pollFromAny() |
RBlockingQueueRx. take() poll() pollFromAny() |
| BLMOVE | RBlockingDeque. move() moveAsync() |
RBlockingDequeReactive. move() |
RBlockingDequeRx. move() |
| BRPOP | RBlockingDeque. takeLast() takeLastAsync() |
RBlockingDequeReactive. takeLast() |
RBlockingDequeRx. takeLast() |
| BRPOPLPUSH | RBlockingQueue. pollLastAndOfferFirstTo() pollLastAndOfferFirstToAsync() |
RBlockingQueueReactive. pollLastAndOfferFirstTo() |
RBlockingQueueRx. pollLastAndOfferFirstTo() |
| CONFIG GET | RedisNode. getConfig() getConfigAsync() |
- | - |
| CONFIG SET | RedisNode. setConfig() setConfigAsync() |
- | - |
| COPY | RObject. copy() copyAsync() |
RObjectReactive. copy() |
RObjectRx. copy() |
| CLIENT SETNAME | Config.setClientName() | - | - |
| CLIENT REPLY | BatchOptions.skipResult() | - | - |
| CLIENT TRACKING | RBucket .addListener(TrackingListener) RStream .addListener(TrackingListener) RScoredSortedSet .addListener(TrackingListener) RSet .addListener(TrackingListener) RMap .addListener(TrackingListener) |
RBucketReactive .addListener(TrackingListener) RStreamReactive .addListener(TrackingListener) RScoredSortedSetReactive .addListener(TrackingListener) RSetReactive .addListener(TrackingListener) RMapReactive .addListener(TrackingListener) |
RBucketRx .addListener(TrackingListener) RStreamRx .addListener(TrackingListener) RScoredSortedSetRx .addListener(TrackingListener) RSetRx .addListener(TrackingListener) RMapRx .addListener(TrackingListener) |
| CLUSTER INFO | ClusterNode.info() | - | - |
| CLUSTER KEYSLOT | RKeys. getSlot() getSlotAsync() |
RKeysReactive. getSlot() |
RKeysRx. getSlot() |
| CLUSTER NODES | Used in ClusterConnectionManager | ||
| DECRBY | RAtomicLong. addAndGet() addAndGetAsync() |
RAtomicLongReactive. addAndGet() |
RAtomicLongRx. addAndGet() |
| DUMP | RObject. dump() dumpAsync() |
RObjectReactive. dump() |
RObjectRx. dump() |
| DBSIZE | RKeys. count() countAsync() |
RKeysReactive. count() |
RKeysRx.count() |
| DECR | RAtomicLong. decrementAndGet() decrementAndGetAsync() |
RAtomicLongReactive. decrementAndGet() |
RAtomicLongRx. decrementAndGet() |
| DEL | RObject. delete() deleteAsync() RKeys. delete() deleteAsync() |
RObjectReactive. delete() RKeysReactive. delete() |
RObjectRx. delete() RKeysRx. delete() |
| STRLEN | RBucket. size() sizeAsync() |
RBucketReactive. size() |
RBucketRx. size() |
| EVAL | RScript. eval() evalAsync() |
RScriptReactive. eval() |
RScriptRx. eval() |
| EVALSHA | RScript. evalSha() evalShaAsync() |
RScriptReactive. evalSha() |
RScriptRx. evalSha() |
| EXEC | RBatch. execute() executeAsync() |
RBatchReactive. execute() |
RBatchRx. execute() |
| EXISTS | RObject. isExists() isExistsAsync() |
RObjectReactive. isExists() |
RObjectRx. isExists() |
| FLUSHALL | RKeys. flushall() flushallAsync() |
RKeysReactive. flushall() |
RKeysRx. flushall() |
| FLUSHDB | RKeys. flushdb() flushdbAsync() |
RKeysReactive. flushdb() |
RKeysRx. flushdb() |
| GETRANGE | RBinaryStream. getChannel().read() |
RBinaryStreamReactive. read() |
RBinaryStreamRx. read() |
| GEOADD | RGeo. add() addAsync() |
RGeoReactive. add() |
RGeoRx. add() |
| GEODIST | RGeo. dist() distAsync() |
RGeoReactive. dist() |
RGeoRx. dist() |
| GEOHASH | RGeo. hash() hashAsync() |
RGeoReactive. hash() |
RGeoRx. hash() |
| GEOPOS | RGeo. pos() posAsync() |
RGeoReactive. pos() |
RGeoRx. pos() |
| GEORADIUS | RGeo. radius() radiusAsync() radiusWithDistance() radiusWithDistanceAsync() radiusWithPosition() radiusWithPositionAsync() |
RGeoReactive. radius() radiusWithDistance() radiusWithPosition() |
RGeoRx. radius() radiusWithDistance() radiusWithPosition() |
| GEOSEARCH | RGeo. search() searchAsync() |
RGeoReactive. search() |
RGeoRx. search() |
| GEOSEARCHSTORE | RGeo. storeSearchTo() storeSearchToAsync() |
RGeoReactive. storeSearchTo() |
RGeoRx. storeSearchTo() |
| GET | RBucket. get() getAsync() RBinaryStream. get() getAsync() |
RBucketReactive. get() RBinaryStreamReactive. get() |
RBucketRx. get() RBinaryStreamRx. get() |
| GETEX | RBucket. getAndExpire() getAndExpireAsync() getAndClearExpire() getAndClearExpireAsync() |
RBucketReactive. getAndExpire() getAndClearExpire() |
RBucketRx. getAndExpire() getAndClearExpire() |
| GETBIT | RBitSet. get() getAsync() |
RBitSetReactive. get() |
RBitSetRx. get() |
| GETSET | RBucket. getAndSet() getAndSetAsync() RAtomicLong. getAndSet() getAndSetAsync() RAtomicDouble. getAndSet() getAndSetAsync() |
RBucketReactive. getAndSet() RAtomicLongReactive. getAndSet() RAtomicDoubleReactive. getAndSet() |
RBucketRx. getAndSet() RAtomicLongRx. getAndSet() RAtomicDoubleRx. getAndSet() |
| HDEL | RMap. fastRemove() fastRemoveAsync() |
RMapReactive. fastRemove() |
RMapRx. fastRemove() |
| HEXISTS | RMap. containsKey() containsKeyAsync() |
RMapReactive. containsKey() |
RMapRx. containsKey() |
| HGET | RMap. get() getAsync() |
RMapReactive. get() |
RMapRx. get() |
| HSTRLEN | RMap. valueSize() valueSizeAsync() |
RMapReactive. valueSize() |
RMapRx. valueSize() |
| HGETALL | RMap. readAllEntrySet() readAllEntrySetAsync() |
RMapReactive. readAllEntrySet() |
RMapRx. readAllEntrySet() |
| HINCRBY | RMap. addAndGet() addAndGetAsync() |
RMapReactive. addAndGet() |
RMapRx. addAndGet() |
| HINCRBYFLOAT | RMap. addAndGet() addAndGetAsync() |
RMapReactive. addAndGet() |
RMapRx. addAndGet() |
| HKEYS | RMap. readAllKeySet() readAllKeySetAsync() |
RMapReactive. readAllKeySet() |
RMapRx. readAllKeySet() |
| HLEN | RMap. size() sizeAsync() |
RMapReactive. size() |
RMapRx. size() |
| HMGET | RMap. getAll() getAllAsync() |
RMapReactive. getAll() |
RMapRx. getAll() |
| HMSET | RMap. putAll() putAllAsync() |
RMapReactive. putAll() |
RMapRx. putAll() |
| HRANDFIELD | RMap. putAll() putAllAsync() |
RMapReactive. putAll() |
RMapRx. putAll() |
| HSCAN | RMap. keySet().iterator() values().iterator() entrySet().iterator() |
RMapReactive. keyIterator() valueIterator() entryIterator() |
RMapRx. keyIterator() valueIterator() entryIterator() |
| HSET | RMap. randomEntries() randomKeys() randomEntriesAsync() randomKeysAsync() |
RMapReactive. randomEntries() randomKeys() |
RMapRx. randomEntries() randomKeys() |
| HSETNX | RMap. fastPutIfAbsent() fastPutIfAbsentAsync() |
RMapReactive. fastPutIfAbsent() |
RMapRx. fastPutIfAbsent() |
| HVALS | RMap. readAllValues() readAllValuesAsync() |
RMapReactive. readAllValues() |
RMapRx. readAllValues() |
| HPEXPIRE | RMapCacheNative. put() fastPut() putIfAbsent() fastPutIfAbsent() putAll() expireEntry() putAsync() fastPutAsync() putIfAbsentAsync() fastPutIfAbsentAsync() putAllAsync() expireEntryAsync() |
RMapCacheNativeReactive. put() fastPut() putIfAbsent() fastPutIfAbsent() putAll() expireEntry() |
RMapCacheNativeRx. put() fastPut() putIfAbsent() fastPutIfAbsent() putAll() expireEntry() |
| HPEXPIREAT | RMapCacheNative. put() fastPut() putIfAbsent() fastPutIfAbsent() putAll() expireEntry() putAsync() fastPutAsync() putIfAbsentAsync() fastPutIfAbsentAsync() putAllAsync() expireEntryAsync() |
RMapCacheNativeReactive. put() fastPut() putIfAbsent() fastPutIfAbsent() putAll() expireEntry() |
RMapCacheNativeRx. put() fastPut() putIfAbsent() fastPutIfAbsent() putAll() expireEntry() |
| HEXPIRE | RMapCacheNative. put() fastPut() putIfAbsent() fastPutIfAbsent() putAll() expireEntry() putAsync() fastPutAsync() putIfAbsentAsync() fastPutIfAbsentAsync() putAllAsync() expireEntryAsync() |
RMapCacheNativeReactive. put() fastPut() putIfAbsent() fastPutIfAbsent() putAll() expireEntry() |
RMapCacheNativeRx. put() fastPut() putIfAbsent() fastPutIfAbsent() putAll() expireEntry() |
| HEXPIREAT | RMapCacheNative. put() fastPut() putIfAbsent() fastPutIfAbsent() putAll() expireEntry() putAsync() fastPutAsync() putIfAbsentAsync() fastPutIfAbsentAsync() putAllAsync() expireEntryAsync() |
RMapCacheNativeReactive. put() fastPut() putIfAbsent() fastPutIfAbsent() putAll() expireEntry() |
RMapCacheNativeRx. put() fastPut() putIfAbsent() fastPutIfAbsent() putAll() expireEntry() |
| HPERSIST | RMapCacheNative. clearExpire() clearExpireAsync() |
RMapCacheNativeReactive. clearExpire() |
RMapCacheNativeRx. clearExpire() |
| HPTTL | RMapCacheNative. remainTimeToLive() remainTimeToLiveAsync() |
RMapCacheNativeReactive. remainTimeToLive() |
RMapCacheNativeRx. remainTimeToLive() |
| INCR | RAtomicLong. incrementAndGet() incrementAndGetAsync() |
RAtomicLongReactive. incrementAndGet() |
RAtomicLongRx. incrementAndGet() |
| INCRBY | RAtomicLong. addAndGet() addAndGetAsync() |
RAtomicLongReactive. addAndGet() |
RAtomicLongRx. addAndGet() |
| INCRBYFLOAT | RAtomicDouble. addAndGet() addAndGetAsync() |
RAtomicDoubleReactive. addAndGet() |
RAtomicDoubleRx. addAndGet() |
| JSON.ARRAPPEND | RJsonBucket. arrayAppend() arrayAppendAsync() |
RJsonBucketReactive. arrayAppend() |
RJsonBucketRx. arrayAppend() |
| JSON.ARRINDEX | RJsonBucket. arrayIndex() arrayIndexAsync() |
RJsonBucketReactive. arrayIndex() |
RJsonBucketRx. arrayIndex() |
| JSON.ARRINSERT | RJsonBucket. arrayInsert() arrayInsertAsync() |
RJsonBucketReactive. arrayInsert() |
RJsonBucketRx. arrayInsert() |
| JSON.ARRLEN | RJsonBucket. arraySize() arraySizeAsync() |
RJsonBucketReactive. arraySize() |
RJsonBucketRx. arraySize() |
| JSON.ARRPOP | RJsonBucket. arrayPollLast() arrayPollFirst() arrayPop() arrayPollLastAsync() arrayPollFirstAsync() arrayPopAsync() |
RJsonBucketReactive. arrayPollLast() arrayPollFirst() arrayPop() |
RJsonBucketRx. arrayPollLast() arrayPollFirst() arrayPop() |
| JSON.ARRTRIM | RJsonBucket. arrayTrim() arrayTrimAsync() |
RJsonBucketReactive. arrayTrim() |
RJsonBucketRx. arrayTrim() |
| JSON.CLEAR | RJsonBucket. clear() clearAsync() |
RJsonBucketReactive. clear() |
RJsonBucketRx. clear() |
| JSON.GET | RJsonBucket. get() getAsync() |
RJsonBucketReactive. get() |
RJsonBucketRx. get() |
| JSON.MERGE | RJsonBucket. merge() mergeAsync() |
RJsonBucketReactive. merge() |
RJsonBucketRx. merge() |
| JSON.NUMINCRBY | RJsonBucket. incrementAndGet() incrementAndGetAsync() |
RJsonBucketReactive. incrementAndGet() |
RJsonBucketRx. incrementAndGet() |
| JSON.OBJLEN | RJsonBucket. countKeys() countKeysAsync() |
RJsonBucketReactive. countKeys() |
RJsonBucketRx. countKeys() |
| JSON.OBJKEYS | RJsonBucket. getKeys() getKeysAsync() |
RJsonBucketReactive. getKeys() |
RJsonBucketRx. getKeys() |
| JSON.SET | RJsonBucket. set() setAsync() |
RJsonBucketReactive. set() |
RJsonBucketRx. set() |
| JSON.STRAPPEND | RJsonBucket. stringAppend() stringAppendAsync() |
RJsonBucketReactive. stringAppend() |
RJsonBucketRx. stringAppend() |
| JSON.STRLEN | RJsonBucket. stringSize() stringSizeAsync() |
RJsonBucketReactive. stringSize() |
RJsonBucketRx. stringSize() |
| JSON.TOGGLE | RJsonBucket. toggle() toggleAsync() |
RJsonBucketReactive. toggle() |
RJsonBucketRx. toggle() |
| JSON.TYPE | RJsonBucket. type() typeAsync() |
RJsonBucketReactive. type() |
RJsonBucketRx. type() |
| KEYS | RKeys. getKeysByPattern() getKeysByPatternAsync() |
RKeysReactive. getKeysByPattern() |
RKeysRx. getKeysByPattern() |
| LINDEX | RList. get() getAsync() |
RListReactive. get() |
RListRx. get() |
| LLEN | RList. size() sizeAsync() |
RListReactive. size() |
RListRx. size() |
| LMOVE | RDeque. move() moveAsync() |
RDequeReactive. move() |
RDequeRx. move() |
| LPOP | RQueue. poll() pollAsync() |
RQueueReactive. poll() |
RQueueRx. poll() |
| LPUSH | RDeque. addFirst() addFirstAsync() |
RDequeReactive. addFirst() |
|
| LRANGE | RList. readAll() readAllAsync() |
RListReactive.readAll() | RListRx.readAll() |
| LPUSHX | RDeque. addFirstIfExists() addFirstIfExistsAsync() |
RDequeReactive. addFirstIfExists() |
RDequeRx. addFirstIfExists() |
| LREM | RList. fastRemove() fastRemoveAsync() |
RListReactive. fastRemove() |
RListRx. fastRemove() |
| LSET | RList. fastSet() fastSetAsync() |
RListReactive. fastSet() |
RListRx. fastSet() |
| LTRIM | RList. trim() trimAsync() |
RListReactive. trim() |
RListRx. trim() |
| LINSERT | RList. addBefore() addAfter() addBeforeAsync() addAfterAsync() |
RListReactive. addBefore() addAfter() |
RListRx. addBefore() addAfter() |
| MULTI | RBatch. execute() executeAsync() |
RBatchReactive. execute() |
RBatchRx. execute() |
| MGET | RBuckets. get() getAsync() |
RBucketsReactive. get() |
RBucketsRx. get() |
| MSETNX | RBuckets. trySet() trySetAsync() |
RBucketsReactive. trySet() |
RBucketsRx. trySet() |
| MIGRATE | RObject. migrate() migrateAsync() |
RObjectReactive. migrate() |
RObjectRx. migrate() |
| MOVE | RObject. move() moveAsync() |
RObjectReactive. move() |
RObjectRx. move() |
| MSET | RBuckets. set() setAsync() |
RBucketsReactive. set() |
RBucketsRx. set() |
| PERSIST | RExpirable. clearExpire() clearExpireAsync() |
RExpirableReactive. clearExpire() |
RExpirableRx. clearExpire() |
| PEXPIRE | RExpirable. expire() expireAsync() |
RExpirableReactive. expire() |
RExpirableRx. expire() |
| PEXPIREAT | RExpirable. expireAt() expireAtAsync() |
RExpirableReactive. expireAt() |
RExpirableRx. expireAt() |
| PEXPIRETIME | RExpirable. expireTime() expireTimeAsync() |
RExpirableReactive. expireTime() |
RExpirableRx. expireTime() |
| PFADD | RHyperLogLog. add() addAsync() addAll() addAllAsync() |
RHyperLogLogReactive. add() addAll() |
RHyperLogLogRx. add() addAll() |
| PFCOUNT | RHyperLogLog. count() countAsync() countWith() countWithAsync() |
RHyperLogLogReactive. count() countWith() |
RHyperLogLogRx. count() countWith() |
| PFMERGE | RHyperLogLog. mergeWith() mergeWithAsync() |
RHyperLogLogReactive. mergeWith() |
RHyperLogLogRx. mergeWith() |
| PING | Node.ping() NodesGroup.pingAll() |
- | - |
| PSUBSCRIBE | RPatternTopic. addListener() |
RPatternTopicReactive. addListener() |
RPatternTopicRx. addListener() |
| PSETEX | RBucket. set() setAsync() |
RBucketReactive. set() |
RBucketRx. set() |
| PTTL | RExpirable. remainTimeToLive() remainTimeToLiveAsync() |
RExpirableReactive. remainTimeToLive() |
RExpirableRx. remainTimeToLive() |
| PUBLISH | RTopic. publish() |
RTopicReactive. publish() |
RTopicRx. publish() |
| PUBSUB NUMSUB | RTopic. countSubscribers() countSubscribersAsync() |
RTopicReactive. countSubscribers() |
RTopicRx. countSubscribers() |
| PUNSUBSCRIBE | RPatternTopic. removeListener() |
RPatternTopicReactive. removeListener() |
RPatternTopicRx. removeListener() |
| RANDOMKEY | RKeys. randomKey() randomKeyAsync() |
RKeysReactive. randomKey() |
RKeysRx. randomKey() |
| RESTORE | RObject. restore() restoreAsync() |
RObjectReactive. restore() |
RObjectRx. restore() |
| RENAME | RObject. rename() renameAsync() |
RObjectReactive. rename() |
RObjectRx. rename() |
| RPOP | RDeque. pollLast() removeLast() pollLastAsync() removeLastAsync() |
RDequeReactive. pollLast() removeLast() |
RDequeRx. pollLast() removeLast() |
| RPOPLPUSH | RDeque. pollLastAndOfferFirstTo() pollLastAndOfferFirstToAsync() |
RDequeReactive. pollLastAndOfferFirstTo() |
RDequeRx. pollLastAndOfferFirstTo() |
| RPUSH | RList. add() addAsync() |
RListReactive. add() |
RListRx. add() |
| RPUSHX | RDeque. addLastIfExists() addLastIfExistsAsync() |
RListReactive. addLastIfExists() |
RListRx. addLastIfExists() |
| SADD | RSet. add() addAsync() |
RSetReactive. add() |
RSetRx. add() |
| SETRANGE | RBinaryStream. getChannel().write() |
RBinaryStreamReactive. write() |
RBinaryStreamRx. write() |
| SCAN | RKeys. getKeys() |
RKeysReactive. getKeys() |
RKeysRx. getKeys() |
| SCARD | RSet. size() sizeAsync() |
RSetReactive. size() |
RSetRx. size() |
| SCRIPT EXISTS | RScript. scriptExists() scriptExistsAsync() |
RScriptReactive. scriptExists() |
RScriptRx. scriptExists() |
| SCRIPT FLUSH | RScript. scriptFlush() scriptFlushAsync() |
RScriptReactive. scriptFlush() |
RScriptRx. scriptFlush() |
| SCRIPT KILL | RScript. scriptKill() scriptKillAsync() |
RScriptReactive. scriptKill() |
RScriptRx. scriptKill() |
| SCRIPT LOAD | RScript. scriptLoad() scriptLoadAsync() |
RScriptReactive. scriptLoad() |
RScriptRx. scriptLoad() |
| SDIFFSTORE | RSet. diff() diffAsync() |
RSetReactive. diff() |
RSetRx. diff() |
| SDIFF | RSet. readDiff() readDiffAsync() |
RSetReactive. readDiff() |
RSetRx. readDiff() |
| SRANDMEMBER | RSet. random() randomAsync() |
RSetReactive. random() |
RSetRx. random() |
| SELECT | Config.setDatabase() | - | - |
| SET | RBucket. set() setAsync() |
RBucketReactive. set() |
RBucketRx. set() |
| SETBIT | RBitSet. set() clear() setAsync() clearAsync() |
RBitSetReactive. set() clear() |
RBitSetRx. set() clear() |
| SETEX | RBucket. set() setAsync() |
RBucketReactive. set() |
RBucketRx. set() |
| SETNX | RBucket. setIfAbsent() setIfAbsentAsync() |
RBucketReactive. setIfAbsent() |
RBucketRx. setIfAbsent() |
| SISMEMBER | RSet. contains() containsAsync() |
RSetReactive. contains() |
RSetRx. contains() |
| SINTERSTORE | RSet. intersection() intersectionAsync() |
RSetReactive. intersection() |
RSetRx. intersection() |
| SINTER | RSet. readIntersection() readIntersectionAsync() |
RSetReactive. readIntersection() |
RSetRx. readIntersection() |
| SMEMBERS | RSet. readAll() readAllAsync() |
RSetReactive. readAll() |
RSetRx. readAll() |
| SMOVE | RSet. move() moveAsync() |
RSetReactive. move() |
RSetRx. move() |
| SORT | RList. readSort() sortTo() readSortAsync() sortToAsync() |
RListReactive. readSort() sortTo() |
RListRx. readSort() sortTo() |
| SPOP | RSet. removeRandom() removeRandomAsync() |
RSetReactive. removeRandom() |
RSetRx. removeRandom() |
| SREM | RSet. remove() removeAsync() |
RSetReactive. remove() |
RSetRx. remove() |
| SSCAN | RSet. iterator() |
RSetReactive. iterator() |
RSetRx. iterator() |
| SUBSCRIBE | RTopic. addListener() |
RTopicReactive. addListener() |
RTopicRx. addListener() |
| SUNION | RSet. readUnion() readUnionAsync() |
RSetReactive. readUnion() |
RSetRx. readUnion() |
| SUNIONSTORE | RSet. union() unionAsync() |
RSetReactive. union() |
RSetRx. union() |
| SWAPDB | RKeys. swapdb() swapdbAsync() |
RKeysReactive. swapdb() |
RKeysRx. swapdb() |
| TTL | RExpirable. remainTimeToLive() remainTimeToLiveAsync() |
RExpirableReactive. remainTimeToLive() |
RExpirableRx. remainTimeToLive() |
| TYPE | RKeys. getType() getTypeAsync() |
RKeysReactive. getType() |
RKeysRx. getType() |
| TOUCH | RObject. touch() touchAsync() |
RObjectReactive. touch() |
RObjectRx. touch() |
| UNSUBSCRIBE | RTopic. removeListener() |
RTopicReactive. removeListener() |
RTopicRx. removeListener() |
| UNLINK | RObject. unlink() unlinkAsync() |
RObjectReactive. unlink() |
RObjectRx. unlink() |
| WAIT | BatchOptions. sync() |
BatchOptions. sync() |
BatchOptions. sync() |
| WAITAOF | BatchOptions. syncAOF() |
BatchOptions. syncAOF() |
BatchOptions. syncAOF() |
| ZADD | RScoredSortedSet. add() addAsync() addAll() addAllAsync() |
RScoredSortedSetReactive. add() addAll() |
RScoredSortedSetRx. add() addAll() |
| ZCARD | RScoredSortedSet. size() sizeAsync() |
RScoredSortedSetReactive. size() |
RScoredSortedSetRx. size() |
| ZCOUNT | RScoredSortedSet. count() countAsync() |
RScoredSortedSetReactive. count() |
RScoredSortedSetRx. count() |
| ZDIFF | RScoredSortedSet. readDiff() readDiffAsync() |
RScoredSortedSetReactive. readDiff() |
RScoredSortedSetRx. readDiff() |
| ZDIFFSTORE | RScoredSortedSet. diff() diffAsync() |
RScoredSortedSetReactive. diff() |
RScoredSortedSetRx. diff() |
| ZINCRBY | RScoredSortedSet. addScore() addScoreAsync() |
RScoredSortedSetReactive. addScore() |
RScoredSortedSetRx. addScore() |
| ZINTER | RScoredSortedSet. readIntersection() readIntersectionAsync() |
RScoredSortedSetReactive. readIntersection() |
RScoredSortedSetRx. readIntersection() |
| ZREMRANGEBYRANK | RScoredSortedSet. removeRangeByRank() removeRangeByRankAsync() |
RScoredSortedSetReactive. removeRangeByRank() |
RScoredSortedSetRx. removeRangeByRank() |
| ZREVRANGEBYLEX | RLexSortedSet. rangeReversed() rangeReversedAsync() |
RLexSortedSetReactive. rangeReversed() |
RLexSortedSetSetRx. rangeReversed() |
| ZLEXCOUNT | RLexSortedSet. lexCount() lexCountHead() lexCountTail() lexCountAsync() lexCountHeadAsync() lexCountTailAsync() |
RLexSortedSetReactive. lexCount() lexCountHead() lexCountTail() |
RLexSortedSetRx. lexCount() lexCountHead() lexCountTail() |
| ZRANGE | RScoredSortedSet. valueRange() valueRangeAsync() |
RScoredSortedSetReactive. valueRange() |
RScoredSortedSetRx. valueRange() |
| ZRANDMEMBER | RScoredSortedSet. random() randomAsync() |
RScoredSortedSetReactive. random() |
RScoredSortedSetRx. random() |
| ZREVRANGE | RScoredSortedSet. valueRangeReversed() valueRangeReversedAsync() |
RScoredSortedSetReactive. valueRangeReversed() |
RScoredSortedSetRx. valueRangeReversed() |
| ZUNION | RScoredSortedSet. readUnion() readUnionAsync() |
RScoredSortedSetReactive. readUnion() |
RScoredSortedSetRx. readUnion() |
| ZUNIONSTORE | RScoredSortedSet. union() unionAsync() |
RScoredSortedSetReactive. union() |
RScoredSortedSetRx. union() |
| ZINTERSTORE | RScoredSortedSet. intersection() intersectionAsync() |
RScoredSortedSetReactive. intersection() |
RScoredSortedSetRx. intersection() |
| ZPOPMAX | RScoredSortedSet. pollLast() pollLastAsync() |
RScoredSortedSetReactive. pollLast() |
RScoredSortedSetRx. pollLast() |
| ZPOPMIN | RScoredSortedSet. pollFirst() pollFirstAsync() |
RScoredSortedSetReactive. pollFirst() |
RScoredSortedSetRx. pollFirst() |
| ZMPOP | RScoredSortedSet. pollFirstEntriesFromAny() pollFirstEntriesFromAnyAsync() pollLastFromAny() pollLastFromAnyAsync() pollFirstFromAny() pollFirstFromAnyAsync() |
RScoredSortedSetReactive. pollFirstEntriesFromAny() pollLastFromAny() pollFirstFromAny() |
RScoredSortedSetRx. pollFirstEntriesFromAny() pollLastFromAny() pollFirstFromAny() |
| ZRANGEBYLEX | RLexSortedSet. range() rangeHead() rangeTail() rangeAsync() rangeHeadAsync() rangeTailAsync() |
RLexSortedSetReactive. range() rangeHead() rangeTail() |
RLexSortedSetRx. range() rangeHead() rangeTail() |
| ZRANGEBYSCORE | RScoredSortedSet. valueRange() entryRange() valueRangeAsync() entryRangeAsync() |
RScoredSortedSetReactive. valueRange() entryRange() |
RScoredSortedSetRx. valueRange() entryRange() |
| TIME | RedissonClient. getNodesGroup(). getNode().time() getClusterNodesGroup(). getNode().time() |
- | - |
| ZRANK | RScoredSortedSet. rank() rankAsync() |
RScoredSortedSetReactive. rank() |
RScoredSortedSetRx. rank() |
| ZREM | RScoredSortedSet. remove() removeAll() removeAsync() removeAllAsync() |
RScoredSortedSetReactive. remove() removeAll() |
RScoredSortedSetRx. remove() removeAll() |
| ZREMRANGEBYLEX | RLexSortedSet. removeRange() removeRangeHead() removeRangeTail() removeRangeAsync() removeRangeHeadAsync() removeRangeTailAsync() |
RLexSortedSetReactive. removeRange() removeRangeHead() removeRangeTail() |
RLexSortedSetRx. removeRange() removeRangeHead() removeRangeTail() |
| ZREMRANGEBYSCORE | RScoredSortedSet. removeRangeByScore() removeRangeByScoreAsync() |
RScoredSortedSetReactive. removeRangeByScore() |
RScoredSortedSetRx. removeRangeByScore() |
| ZREVRANGEBYSCORE | RScoredSortedSet. valueRangeReversed() entryRangeReversed() valueRangeReversedAsync() entryRangeReversedAsync() |
RScoredSortedSetReactive. entryRangeReversed() valueRangeReversed() |
RScoredSortedSetRx. entryRangeReversed() valueRangeReversed() |
| ZREVRANK | RScoredSortedSet. revRank() revRankAsync() |
RScoredSortedSetReactive. revRank() |
RScoredSortedSetRx. revRank() |
| ZSCORE | RScoredSortedSet. getScore() getScoreAsync() |
RScoredSortedSetReactive. getScore() |
RScoredSortedSetRx. getScore() |
| XACK | RStream. ack() ackAsync() |
RStreamReactive. ack() |
RStreamRx. ack() |
| XADD | RStream. add() addAsync() |
RStreamReactive. add() |
RStreamRx. add() |
| XAUTOCLAIM | RStream. autoClaim() autoClaimAsync() |
RStreamReactive. autoClaim() |
RStreamRx. autoClaim() |
| XCLAIM | RStream. claim() claimAsync() |
RStreamReactive. claim() |
RStreamRx. claim() |
| XDEL | RStream. remove() removeAsync() |
RStreamReactive. remove() |
RStreamRx. remove() |
| XGROUP | RStream. createGroup() removeGroup() updateGroup() createGroupAsync() removeGroupAsync() updateGroupAsync() |
RStreamReactive. createGroup() removeGroup() updateGroup() |
RStreamRx. createGroup() removeGroup() updateGroup() |
| XINFO | RStream. getInfo() listGroups() listConsumers() getInfoAsync() listGroupsAsync() listConsumersAsync() |
RStreamReactive. getInfo() listGroups() listConsumers() |
RStreamRx. getInfo() listGroups() listConsumers() |
| XLEN | RStream. size() sizeAsync() |
RStreamReactive. size() |
RStreamRx. size() |
| XPENDING | RStream. listPending() listPendingAsync() |
RStreamReactive. listPending() |
RStreamRx. listPending() |
| XRANGE | RStream. range() rangeAsync() |
RStreamReactive. range() |
RStreamRx. range() |
| XREAD | RStream. read() readAsync() |
RStreamReactive. read() |
RStreamRx. read() |
| XREADGROUP | RStream. readGroup() readGroupAsync() |
RStreamReactive. readGroup() |
RStreamRx. readGroup() |
| XREVRANGE | RStream. rangeReversed() rangeReversedAsync() |
RStreamReactive. rangeReversed() |
RStreamRx. rangeReversed() |
| XTRIM | RStream. trim() trimAsync() |
RStreamReactive. trim() |
RStreamRx. trim() |