RBinaryStream.getOutputStream().write()
BITCOUNT
RBitSet.cardinality(), RBitSet.cardinalityAsync(), RBitSetReactive.cardinality()
BITOP
RBitSet.or(), RBitSet.orAsync(), RBitSetReactive.or();
RBitSet.and(), RBitSet.andAsync(), RBitSetReactive.and();
RBitSet.not();
RBitSet.xor(), RBitSet.xorAsync(), RBitSetReactive.xor()
BITPOS
RBitSet.length(), RBitSet.lengthAsync(), RBitSetReactive.length()
BLPOP
RBlockingQueue.take(), RBlockingQueue.takeAsync(), RBlockingQueueReactive.take();
RBlockingQueue.poll(), RBlockingQueue.pollAsync(), RBlockingQueueReactive.poll();
RBlockingQueue.pollFromAny(), RBlockingQueue.pollFromAnyAsync(), RBlockingQueueReactive.pollFromAny();
BRPOP
RBlockingDeque.takeLast(), RBlockingDeque.takeLastAsync(), RBlockingDequeReactive.takeLast();
BRPOPLPUSH
RBlockingQueue.pollLastAndOfferFirstTo(), RBlockingQueue.pollLastAndOfferFirstToAsync(), RBlockingQueueReactive.pollLastAndOfferFirstTo();
RObject.copy, RObject.copyAsync, RObjectReactive.copy();
CLIENT SETNAME
Config.setClientName();
CLUSTER INFO
ClusterNode.info();
CLUSTER KEYSLOT
RKeys.getSlot(), RKeys.getSlotAsync(), RKeysReactive.getSlot();
CLUSTER NODES
Used in ClusterConnectionManager
RObject.dump(), RObject.dumpAsync(), RObjectReactive.dump();
DBSIZE
RKeys.count(), RKeys.countAsync(), RKeysReactive.count();
RAtomicLong.decrementAndGet(), RAtomicLong.decrementAndGetAsync(), RAtomicLongReactive.decrementAndGetAsync();
RObject.delete(), RObject.deleteAsync(), RObjectReactive.delete();
RKeys.delete(), RKeys.deleteAsync();
STRLEN
RBucket.size(), RBucket.sizeAsync(), RBucketReactive.size();
RScript.eval(), RScript.evalAsync(), RScriptReactive.eval();
CLIENT REPLY
RBatch.executeSkipResult();
EVALSHA
RScript.evalSha(), RScript.evalShaAsync(), RScriptReactive.evalSha();
RBatch.execute(), RBatch.executeAsync(), RBatchReactive.execute();
EXISTS
RObject.isExists(), RObject.isExistsAsync(), RObjectReactive.isExists();
FLUSHALL
RKeys.flushall(), RKeys.flushallAsync(), RKeysReactive.flushall();
FLUSHDB
RKeys.flushdb(), RKeys.flushdbAsync(), RKeysReactive.flushdb();
GEOADD
RGeo.add(), RGeo.addAsync(), RGeoReactive.add();
GEODIST
RGeo.dist(), RGeo.distAsync(), RGeoReactive.dist();
GEOHASH
RGeo.hash(), RGeo.hashAsync(), RGeoReactive.hash();
GEOPOS
RGeo.pos(), RGeo.posAsync(), RGeoReactive.pos();
GEORADIUS
RGeo.radius(), RGeo.radiusAsync(), RGeoReactive.radius();
RGeo.radiusWithDistance(), RGeo.radiusWithDistanceAsync(), RGeoReactive.radiusWithDistance();
RGeo.radiusWithPosition(), RGeo.radiusWithPositionAsync(), RGeoReactive.radiusWithPosition();
GEORADIUSBYMEMBER
RGeo.radius(), RGeo.radiusAsync(), RGeoReactive.radius();
RGeo.radiusWithDistance(), RGeo.radiusWithDistanceAsync(), RGeoReactive.radiusWithDistance();
RGeo.radiusWithPosition(), RGeo.radiusWithPositionAsync(), RGeoReactive.radiusWithPosition();
RBucket.get(), RBucket.getAsync(), RBucketReactive.get();
GETBIT
RBitSet.get(), RBitSet.getAsync(), RBitSetReactive.get();
GETSET
RBucket.getAndSet(), RBucket.getAndSetAsync(), RBucketReactive.getAndSet();
RAtomicLong.getAndSet(), RAtomicLong.getAndSetAsync(), RAtomicLongReactive.getAndSet();
RAtomicDouble.getAndSet(), RAtomicDouble.getAndSetAsync(), RAtomicDoubleReactive.getAndSet();
RMap.fastRemove(), RMap.fastRemoveAsync(), RMapReactive.fastRemove();
HEXISTS
RMap.containsKey(), RMap.containsKeyAsync(), RMapReactive.containsKey();
RMap.get(), RMap.getAsync(), RMapReactive.get();
HSTRLEN
RMap.valueSize(), RMap.valueSizeAsync(), RMapReactive.valueSize();
HGETALL
RMap.readAllEntrySet(), RMap.readAllEntrySetAsync(), RMapReactive.readAllEntrySet();
HINCRBY
RMap.addAndGet(), RMap.addAndGetAsync(), RMapReactive.addAndGet();
HINCRBYFLOAT
RMap.addAndGet(), RMap.addAndGetAsync(), RMapReactive.addAndGet();
HKEYS
RMap.readAllKeySet(), RMap.readAllKeySetAsync(), RMapReactive.readAllKeySet();
RMap.size(), RMap.sizeAsync(), RMapReactive.size();
HMGET
RMap.getAll(), RMap.getAllAsync(), RMapReactive.getAll();
HMSET
RMap.putAll(), RMap.putAllAsync(), RMapReactive.putAll();
RMap.put(), RMap.putAsync(), RMapReactive.put();
HSETNX
RMap.fastPutIfAbsent(), RMap.fastPutIfAbsentAsync, RMapReactive.fastPutIfAbsent();
HVALS
RMap.readAllValues(), RMap.readAllValuesAsync(), RMapReactive.readAllValues();
RAtomicLong.incrementAndGet(), RAtomicLong.incrementAndGetAsync(), RAtomicLongReactive.incrementAndGet();
INCRBY
RAtomicLong.addAndGet(), RAtomicLong.addAndGetAsync(), RAtomicLongReactive.addAndGet();
RKeys.findKeysByPattern(), RKeys.findKeysByPatternAsync(), RKeysReactive.findKeysByPattern();
RedissonClient.findBuckets();
LINDEX
RList.get(), RList.getAsync(), RListReactive.get();
RList.size(), RList.sizeAsync(), RListReactive.Size();
RQueue.poll(), RQueue.pollAsync(), RQueueReactive.poll();
LPUSH
RDeque.addFirst(), RDeque.addFirstAsync();
RDequeReactive.addFirst(), RDeque.offerFirst(), RDeque.offerFirstAsync(), RDequeReactive.offerFirst();
LRANGE
RList.readAll(), RList.readAllAsync(), RListReactive.readAll();
RList.fastRemove(), RList.fastRemoveAsync(), RList.remove(), RList.removeAsync(), RListReactive.remove();
RDeque.removeFirstOccurrence(), RDeque.removeFirstOccurrenceAsync(), RDequeReactive.removeFirstOccurrence();
RDeque.removeLastOccurrence(), RDeque.removeLastOccurrenceAsync(), RDequeReactive.removeLastOccurrence();
RList.fastSet(), RList.fastSetAsync(), RListReactive.fastSet();
LTRIM
RList.trim(), RList.trimAsync(), RListReactive.trim();
LINSERT
RList.addBefore(), RList.addBeforeAsync(), RList.addAfter(), RList.addAfterAsync(), RListReactive.addBefore(), RListReactive.addAfter();
MULTI
RBatch.execute(), RBatch.executeAsync(), RBatchReactive.execute();
RedissonClient.loadBucketValues();
MIGRATE
RObject.migrate(), RObject.migrateAsync();
RObject.move(), RObject.moveAsync();
RedissonClient.saveBuckets();
PERSIST
RExpirable.clearExpire(), RExpirable.clearExpireAsync(), RExpirableReactive.clearExpire();
PEXPIRE
RExpirable.expire(), RExpirable.expireAsync(), RExpirableReactive.expire();
PEXPIREAT
RExpirable.expireAt(), RExpirable.expireAtAsync(), RExpirableReactive.expireAt();
PFADD
RHyperLogLog.add(), RHyperLogLog.addAsync(), RHyperLogLogReactive.add();
RHyperLogLog.addAll(), RHyperLogLog.addAllAsync(), RHyperLogLogReactive.addAll();
PFCOUNT
RHyperLogLog.count(), RHyperLogLog.countAsync(), RHyperLogLogReactive.count();
RHyperLogLog.countWith(), RHyperLogLog.countWithAsync(), RHyperLogLogReactive.countWith();
PFMERGE
RHyperLogLog.mergeWith(), RHyperLogLog.mergeWithAsync(), RHyperLogLogReactive.mergeWith();
Node.ping(); NodesGroup.pingAll();
PSUBSCRIBE
RPatternTopic.addListener();
RExpirable.remainTimeToLive(), RExpirable.remainTimeToLiveAsync(), RExpirableReactive.remainTimeToLive();
PUBLISH
RTopic.publish
PUNSUBSCRIBE
RPatternTopic.removeListener();
RANDOMKEY
RKeys.randomKey(), RKeys.randomKeyAsync(), RKeysReactive.randomKey();
RESTORE
RObject.restore(), RObject.restoreAsync, RObjectReactive.restore();
RENAME
RObject.rename(), RObject.renameAsync(), RObjectReactive.rename();
RENAMENX
RObject.renamenx(), RObject.renamenxAsync(), RObjectReactive.renamenx();
RDeque.pollLast(), RDeque.pollLastAsync(), RDequeReactive.pollLast();
RDeque.removeLast(), RDeque.removeLastAsync(), RDequeReactive.removeLast();
RPOPLPUSH
RDeque.pollLastAndOfferFirstTo(), RDeque.pollLastAndOfferFirstToAsync();
RPUSH
RList.add(), RList.addAsync(), RListReactive.add();
RSet.add(), RSet.addAsync(), RSetReactive.add();
SCARD
RSet.size(), RSet.sizeAsync(), RSetReactive.size();
SCRIPT EXISTS
RScript.scriptExists(), RScript.scriptExistsAsync(), RScriptReactive.scriptExists();
SCRIPT FLUSH
RScript.scriptFlush(), RScript.scriptFlushAsync(), RScriptReactive.scriptFlush();
SCRIPT KILL
RScript.scriptKill(), RScript.scriptKillAsync(), RScriptReactive.scriptKill();
SCRIPT LOAD
RScript.scriptLoad(), RScript.scriptLoadAsync(), RScriptReactive.scriptLoad();
SDIFFSTORE
RSet.diff(), RSet.diffAsync(), RSetReactive.diff();
SELECT
Config.setDatabase();
RBucket.set(); RBucket.setAsync(); RBucketReactive.set();
SETBIT
RBitSet.set(); RBitSet.setAsync(); RBitSet.clear(); RBitSet.clearAsync();
SETEX
RBucket.set(); RBucket.setAsync(); RBucketReactive.set();
SETNX
RBucket.trySet(); RBucket.trySetAsync(); RBucketReactive.trySet();
SISMEMBER
RSet.contains(), RSet.containsAsync(), RSetReactive.contains();
SINTERSTORE
RSet.intersection(), RSet.intersectionAsync(), RSetReactive.intersection();
SINTER
RSet.readIntersection(), RSet.readIntersectionAsync(), RSetReactive.readIntersection();
SMEMBERS
RSet.readAll(), RSet.readAllAsync(), RSetReactive.readAll();
SMOVE
RSet.move(), RSet.moveAsync(), RSetReactive.move();
RSet.removeRandom(), RSet.removeRandomAsync(), RSetReactive.removeRandom();
RSet.remove(), RSet.removeAsync(), RSetReactive.remove();
SUBSCRIBE
RTopic.addListener(), RTopicReactive.addListener();
SUNION
RSet.readUnion(), RSet.readUnionAsync(), RSetReactive.readUnion();
SUNIONSTORE
RSet.union(), RSet.unionAsync(), RSetReactive.union();
RExpirable.remainTimeToLive(), RExpirable.remainTimeToLiveAsync(), RExpirableReactive.remainTimeToLive();
RKeys.getType();
UNSUBSCRIBE
RTopic.removeListener(), RTopicReactive.removeListener();
RBatch.syncSlaves, RBatchReactive.syncSlaves();
RScoredSortedSet.add(), RScoredSortedSet.addAsync(), RScoredSortedSetReactive.add();
ZCARD
RScoredSortedSet.size(), RScoredSortedSet.sizeAsync(), RScoredSortedSetReactive.size();
ZCOUNT
RScoredSortedSet.count(), RScoredSortedSet.countAsync();
ZINCRBY
RScoredSortedSet.addScore(), RScoredSortedSet.addScoreAsync(), RScoredSortedSetReactive.addScore();
ZLEXCOUNT
RLexSortedSet.lexCount(), RLexSortedSet.lexCountAsync(), RLexSortedSetReactive.lexCount();
RLexSortedSet.lexCountHead(), RLexSortedSet.lexCountHeadAsync(), RLexSortedSetReactive.lexCountHead();
RLexSortedSet.lexCountTail(), RLexSortedSet.lexCountTailAsync(), RLexSortedSetReactive.lexCountTail();
ZRANGE
RScoredSortedSet.valueRange(), RScoredSortedSet.valueRangeAsync(), RScoredSortedSetReactive.valueRange();
ZREVRANGE
RScoredSortedSet.valueRangeReversed(), RScoredSortedSet.valueRangeReversedAsync(), RScoredSortedSetReactive.valueRangeReversed();
ZUNIONSTORE
RScoredSortedSet.union(), RScoredSortedSet.unionAsync(), RScoredSortedSetReactive.union();
ZINTERSTORE
RScoredSortedSet.intersection(), RScoredSortedSet.intersectionAsync(), RScoredSortedSetReactive.intersection();
ZRANGEBYLEX
RLexSortedSet.lexRange(), RLexSortedSet.lexRangeAsync(), RLexSortedSetReactive.lexRange();
RLexSortedSet.lexRangeHead(), RLexSortedSet.lexRangeHeadAsync(), RLexSortedSetReactive.lexRangeHead();
RLexSortedSet.lexRangeTail(), RLexSortedSet.lexRangeTailAsync(), RLexSortedSetReactive.lexRangeTail();
ZRANGEBYSCORE
RScoredSortedSet.valueRange(), RScoredSortedSet.valueRangeAsync(), RScoredSortedSetReactive.valueRange();
RScoredSortedSet.entryRange(), RScoredSortedSet.entryRangeAsync(), RScoredSortedSetReactive.entryRange();
RedissonClient.getNodesGroup().getNode().time(), RedissonClient.getClusterNodesGroup().getNode().time();
ZRANK
RScoredSortedSet.rank(), RScoredSortedSet.rankAsync(), RScoredSortedSetReactive.rank();
RScoredSortedSet.remove(), RScoredSortedSet.removeAsync(), RScoredSortedSetReactive.remove();
RScoredSortedSet.removeAll(), RScoredSortedSet.removeAllAsync(), RScoredSortedSetReactive.removeAll();
ZREMRANGEBYLEX
RLexSortedSet.removeRangeByLex(), RLexSortedSet.removeRangeByLexAsync(), RLexSortedSetReactive.removeRangeByLex();
RLexSortedSet.removeRangeHeadByLex(), RLexSortedSet.removeRangeHeadByLexAsync(), RLexSortedSetReactive.removeRangeHeadByLex();
RLexSortedSet.removeRangeTailByLex(), RLexSortedSet.removeRangeTailByLexAsync(), RLexSortedSetReactive.removeRangeTailByLex();
ZREMRANGEBYLEX
RScoredSortedSet.removeRangeByRank(), RScoredSortedSet.removeRangeByRankAsync(), RScoredSortedSetReactive.removeRangeByRank();
ZREMRANGEBYSCORE
RScoredSortedSet.removeRangeByScore(), RScoredSortedSet.removeRangeByScoreAsync(), RScoredSortedSetReactive.removeRangeByScore();
ZREVRANGEBYSCORE
RScoredSortedSet.entryRangeReversed(), RScoredSortedSet.entryRangeReversedAsync(), RScoredSortedSetReactive.entryRangeReversed(), RScoredSortedSet.valueRangeReversed(), RScoredSortedSet.valueRangeReversedAsync(), RScoredSortedSetReactive.valueRangeReversed();
ZREVRANK
RScoredSortedSet.revRank(), RScoredSortedSet.revRankAsync(), RScoredSortedSetReactive.revRank();
ZSCORE
RScoredSortedSet.getScore(), RScoredSortedSet.getScoreAsync(), RScoredSortedSetReactive.getScore();
RKeys.getKeys(), RKeysReactive.getKeys();
SSCAN
RSet.iterator(), RSetReactive.iterator();
HSCAN
RMap.keySet().iterator(), RMap.values().iterator(), RMap.entrySet().iterator(), RMapReactive.keyIterator(), RMapReactive.valueIterator(), RMapReactive.entryIterator();
ZSCAN
RScoredSortedSet.iterator(), RScoredSortedSetReactive.iterator();