class RedisSentinelReactiveCommandsImpl<K, V> extends AbstractRedisReactiveCommands<K, V>
        implements RedisSentinelReactiveCommands<K, V> {

    private final SentinelCommandBuilder<K, V> commandBuilder;

    public RedisSentinelReactiveCommandsImpl(StatefulConnection<K, V> connection, RedisCodec<K, V> codec) {
        super(connection, codec);
        commandBuilder = new SentinelCommandBuilder<K, V>(codec);
    }

    @Override
    public Mono<SocketAddress> getMasterAddrByName(K key) {
        return createMono(() -> commandBuilder.getMasterAddrByKey(key));
    }

    @Override
    public Flux<Map<K, V>> masters() {
        return createDissolvingFlux(commandBuilder::masters);
    }

    @Override
    public Mono<Map<K, V>> master(K key) {
        return createMono(() -> commandBuilder.master(key));
    }

    @Override
    public Flux<Map<K, V>> slaves(K key) {
        return createDissolvingFlux(() -> commandBuilder.slaves(key));
    }

    @Override
    public Flux<Map<K, V>> replicas(K key) {
        return createDissolvingFlux(() -> commandBuilder.replicas(key));
    }

    @Override
    public Mono<Long> reset(K key) {
        return createMono(() -> commandBuilder.reset(key));
    }

    @Override
    public Mono<String> failover(K key) {
        return createMono(() -> commandBuilder.failover(key));
    }

    @Override
    public Mono<String> monitor(K key, String ip, int port, int quorum) {
        return createMono(() -> commandBuilder.monitor(key, ip, port, quorum));
    }

    @Override
    public Mono<String> set(K key, String option, V value) {
        return createMono(() -> commandBuilder.set(key, option, value));
    }

    @Override
    public Mono<String> remove(K key) {
        return createMono(() -> commandBuilder.remove(key));
    }

    @Override
    public Mono<String> ping() {
        return createMono(commandBuilder::ping);
    }

    @Override
    public Mono<K> clientGetname() {
        return createMono(commandBuilder::clientGetname);
    }

    @Override
    public Mono<String> clientSetname(K name) {
        return createMono(() -> commandBuilder.clientSetname(name));
    }

    @Override
    public Mono<String> clientSetinfo(String key, String value) {
        return createMono(() -> commandBuilder.clientSetinfo(key, value));
    }

    @Override
    public Mono<String> clientKill(String addr) {
        return createMono(() -> commandBuilder.clientKill(addr));
    }

    @Override
    public Mono<Long> clientKill(KillArgs killArgs) {
        return createMono(() -> commandBuilder.clientKill(killArgs));
    }

    @Override
    public Mono<String> clientPause(long timeout) {
        return createMono(() -> commandBuilder.clientPause(timeout));
    }

    @Override
    public Mono<String> clientList() {
        return createMono(commandBuilder::clientList);
    }

    @Override
    public Mono<String> clientList(ClientListArgs clientListArgs) {
        return createMono(() -> commandBuilder.clientList(clientListArgs));
    }

    @Override
    public Mono<String> clientInfo() {
        return createMono(commandBuilder::clientInfo);
    }

    @Override
    public Mono<String> info() {
        return createMono(commandBuilder::info);
    }

    @Override
    public Mono<String> info(String section) {
        return createMono(() -> commandBuilder.info(section));
    }

    @SuppressWarnings({"unchecked", "rawtypes"})
    @Override
    public <T> Flux<T> dispatch(ProtocolKeyword type, CommandOutput<K, V, ?> output) {

        LettuceAssert.notNull(type, "Command type must not be null");
        LettuceAssert.notNull(output, "CommandOutput type must not be null");

        return (Flux) createFlux(() -> new Command<>(type, output));
    }

    @SuppressWarnings({"unchecked", "rawtypes"})
    @Override
    public <T> Flux<T> dispatch(ProtocolKeyword type, CommandOutput<K, V, ?> output, CommandArgs<K, V> args) {<FILL_FUNCTION_BODY>}

    @Override
    public void close() {
        getStatefulConnection().close();
    }

    @Override
    public boolean isOpen() {
        return getStatefulConnection().isOpen();
    }

    @Override
    public StatefulRedisSentinelConnection<K, V> getStatefulConnection() {
        return (StatefulRedisSentinelConnection<K, V>) super.getConnection();
    }

}


        LettuceAssert.notNull(type, "Command type must not be null");
        LettuceAssert.notNull(output, "CommandOutput type must not be null");
        LettuceAssert.notNull(args, "CommandArgs type must not be null");

        return (Flux) createFlux(() -> new Command<>(type, output, args));
    
<methods>public void <init>(StatefulConnection<K,V>, RedisCodec<K,V>) ,public Mono<Set<io.lettuce.core.AclCategory>> aclCat() ,public Mono<Set<io.lettuce.core.protocol.CommandType>> aclCat(io.lettuce.core.AclCategory) ,public transient Mono<java.lang.Long> aclDeluser(java.lang.String[]) ,public transient Mono<java.lang.String> aclDryRun(java.lang.String, java.lang.String, java.lang.String[]) ,public Mono<java.lang.String> aclDryRun(java.lang.String, RedisCommand<K,V,?>) ,public Mono<java.lang.String> aclGenpass() ,public Mono<java.lang.String> aclGenpass(int) ,public Mono<List<java.lang.Object>> aclGetuser(java.lang.String) ,public Flux<java.lang.String> aclList() ,public Mono<java.lang.String> aclLoad() ,public Flux<Map<java.lang.String,java.lang.Object>> aclLog() ,public Flux<Map<java.lang.String,java.lang.Object>> aclLog(int) ,public Mono<java.lang.String> aclLogReset() ,public Mono<java.lang.String> aclSave() ,public Mono<java.lang.String> aclSetuser(java.lang.String, io.lettuce.core.AclSetuserArgs) ,public Flux<java.lang.String> aclUsers() ,public Mono<java.lang.String> aclWhoami() ,public Mono<java.lang.Long> append(K, V) ,public Mono<java.lang.String> asking() ,public Mono<java.lang.String> auth(java.lang.CharSequence) ,public Mono<java.lang.String> auth(java.lang.String, java.lang.CharSequence) ,public Mono<java.lang.String> bgrewriteaof() ,public Mono<java.lang.String> bgsave() ,public Mono<java.lang.Long> bitcount(K) ,public Mono<java.lang.Long> bitcount(K, long, long) ,public Flux<Value<java.lang.Long>> bitfield(K, io.lettuce.core.BitFieldArgs) ,public transient Mono<java.lang.Long> bitopAnd(K, K[]) ,public Mono<java.lang.Long> bitopNot(K, K) ,public transient Mono<java.lang.Long> bitopOr(K, K[]) ,public transient Mono<java.lang.Long> bitopXor(K, K[]) ,public Mono<java.lang.Long> bitpos(K, boolean) ,public Mono<java.lang.Long> bitpos(K, boolean, long) ,public Mono<java.lang.Long> bitpos(K, boolean, long, long) ,public Mono<V> blmove(K, K, io.lettuce.core.LMoveArgs, long) ,public Mono<V> blmove(K, K, io.lettuce.core.LMoveArgs, double) ,public transient Mono<KeyValue<K,List<V>>> blmpop(long, io.lettuce.core.LMPopArgs, K[]) ,public transient Mono<KeyValue<K,List<V>>> blmpop(double, io.lettuce.core.LMPopArgs, K[]) ,public transient Mono<KeyValue<K,V>> blpop(long, K[]) ,public transient Mono<KeyValue<K,V>> blpop(double, K[]) ,public transient Mono<KeyValue<K,V>> brpop(long, K[]) ,public transient Mono<KeyValue<K,V>> brpop(double, K[]) ,public Mono<V> brpoplpush(long, K, K) ,public Mono<V> brpoplpush(double, K, K) ,public transient Mono<KeyValue<K,ScoredValue<V>>> bzmpop(long, io.lettuce.core.ZPopArgs, K[]) ,public transient Mono<KeyValue<K,List<ScoredValue<V>>>> bzmpop(long, long, io.lettuce.core.ZPopArgs, K[]) ,public transient Mono<KeyValue<K,ScoredValue<V>>> bzmpop(double, io.lettuce.core.ZPopArgs, K[]) ,public transient Mono<KeyValue<K,List<ScoredValue<V>>>> bzmpop(double, int, io.lettuce.core.ZPopArgs, K[]) ,public transient Mono<KeyValue<K,ScoredValue<V>>> bzpopmax(long, K[]) ,public transient Mono<KeyValue<K,ScoredValue<V>>> bzpopmax(double, K[]) ,public transient Mono<KeyValue<K,ScoredValue<V>>> bzpopmin(long, K[]) ,public transient Mono<KeyValue<K,ScoredValue<V>>> bzpopmin(double, K[]) ,public Mono<java.lang.String> clientCaching(boolean) ,public Mono<K> clientGetname() ,public Mono<java.lang.Long> clientGetredir() ,public Mono<java.lang.Long> clientId() ,public Mono<java.lang.String> clientInfo() ,public Mono<java.lang.String> clientKill(java.lang.String) ,public Mono<java.lang.Long> clientKill(io.lettuce.core.KillArgs) ,public Mono<java.lang.String> clientList() ,public Mono<java.lang.String> clientList(io.lettuce.core.ClientListArgs) ,public Mono<java.lang.String> clientNoEvict(boolean) ,public Mono<java.lang.String> clientPause(long) ,public Mono<java.lang.String> clientSetinfo(java.lang.String, java.lang.String) ,public Mono<java.lang.String> clientSetname(K) ,public Mono<java.lang.String> clientTracking(io.lettuce.core.TrackingArgs) ,public Mono<java.lang.Long> clientUnblock(long, io.lettuce.core.UnblockType) ,public void close() ,public transient Mono<java.lang.String> clusterAddSlots(int[]) ,public transient Mono<java.lang.String> clusterAddSlotsRange(Range<java.lang.Integer>[]) ,public Mono<java.lang.String> clusterBumpepoch() ,public Mono<java.lang.Long> clusterCountFailureReports(java.lang.String) ,public Mono<java.lang.Long> clusterCountKeysInSlot(int) ,public transient Mono<java.lang.String> clusterDelSlots(int[]) ,public transient Mono<java.lang.String> clusterDelSlotsRange(Range<java.lang.Integer>[]) ,public Mono<java.lang.String> clusterFailover(boolean) ,public Mono<java.lang.String> clusterFailover(boolean, boolean) ,public Mono<java.lang.String> clusterFlushslots() ,public Mono<java.lang.String> clusterForget(java.lang.String) ,public Flux<K> clusterGetKeysInSlot(int, int) ,public Mono<java.lang.String> clusterInfo() ,public Mono<java.lang.Long> clusterKeyslot(K) ,public Mono<java.lang.String> clusterMeet(java.lang.String, int) ,public Mono<java.lang.String> clusterMyId() ,public Mono<java.lang.String> clusterNodes() ,public Flux<java.lang.String> clusterReplicas(java.lang.String) ,public Mono<java.lang.String> clusterReplicate(java.lang.String) ,public Mono<java.lang.String> clusterReset(boolean) ,public Mono<java.lang.String> clusterSaveconfig() ,public Mono<java.lang.String> clusterSetConfigEpoch(long) ,public Mono<java.lang.String> clusterSetSlotImporting(int, java.lang.String) ,public Mono<java.lang.String> clusterSetSlotMigrating(int, java.lang.String) ,public Mono<java.lang.String> clusterSetSlotNode(int, java.lang.String) ,public Mono<java.lang.String> clusterSetSlotStable(int) ,public Mono<List<java.lang.Object>> clusterShards() ,public Flux<java.lang.String> clusterSlaves(java.lang.String) ,public Flux<java.lang.Object> clusterSlots() ,public Flux<java.lang.Object> command() ,public Mono<java.lang.Long> commandCount() ,public transient Flux<java.lang.Object> commandInfo(java.lang.String[]) ,public transient Flux<java.lang.Object> commandInfo(io.lettuce.core.protocol.CommandType[]) ,public Mono<Map<java.lang.String,java.lang.String>> configGet(java.lang.String) ,public transient Mono<Map<java.lang.String,java.lang.String>> configGet(java.lang.String[]) ,public Mono<java.lang.String> configResetstat() ,public Mono<java.lang.String> configRewrite() ,public Mono<java.lang.String> configSet(java.lang.String, java.lang.String) ,public Mono<java.lang.String> configSet(Map<java.lang.String,java.lang.String>) ,public Mono<java.lang.Boolean> copy(K, K) ,public Mono<java.lang.Boolean> copy(K, K, io.lettuce.core.CopyArgs) ,public Flux<R> createDissolvingFlux(Supplier<RedisCommand<K,V,T>>) ,public Flux<T> createFlux(Supplier<RedisCommand<K,V,T>>) ,public Mono<T> createMono(Supplier<RedisCommand<K,V,T>>) ,public Mono<java.lang.Long> dbsize() ,public Mono<java.lang.String> debugCrashAndRecover(java.lang.Long) ,public Mono<java.lang.String> debugHtstats(int) ,public Mono<java.lang.String> debugObject(K) ,public Mono<java.lang.Void> debugOom() ,public Mono<java.lang.String> debugReload() ,public Mono<java.lang.String> debugRestart(java.lang.Long) ,public Mono<java.lang.String> debugSdslen(K) ,public Mono<java.lang.Void> debugSegfault() ,public Mono<java.lang.Long> decr(K) ,public Mono<java.lang.Long> decrby(K, long) ,public transient Mono<java.lang.Long> del(K[]) ,public Mono<java.lang.Long> del(Iterable<K>) ,public java.lang.String digest(java.lang.String) ,public java.lang.String digest(byte[]) ,public Mono<java.lang.String> discard() ,public Flux<T> dispatch(io.lettuce.core.protocol.ProtocolKeyword, CommandOutput<K,V,?>) ,public Flux<T> dispatch(io.lettuce.core.protocol.ProtocolKeyword, CommandOutput<K,V,?>, CommandArgs<K,V>) ,public Mono<byte[]> dump(K) ,public Mono<V> echo(V) ,public transient Flux<T> eval(java.lang.String, io.lettuce.core.ScriptOutputType, K[]) ,public transient Flux<T> eval(byte[], io.lettuce.core.ScriptOutputType, K[]) ,public transient Flux<T> eval(java.lang.String, io.lettuce.core.ScriptOutputType, K[], V[]) ,public transient Flux<T> eval(byte[], io.lettuce.core.ScriptOutputType, K[], V[]) ,public transient Flux<T> evalReadOnly(byte[], io.lettuce.core.ScriptOutputType, K[], V[]) ,public transient Flux<T> evalsha(java.lang.String, io.lettuce.core.ScriptOutputType, K[]) ,public transient Flux<T> evalsha(java.lang.String, io.lettuce.core.ScriptOutputType, K[], V[]) ,public transient Flux<T> evalshaReadOnly(java.lang.String, io.lettuce.core.ScriptOutputType, K[], V[]) ,public Mono<io.lettuce.core.TransactionResult> exec() ,public Mono<java.lang.Boolean> exists(K) ,public transient Mono<java.lang.Long> exists(K[]) ,public Mono<java.lang.Long> exists(Iterable<K>) ,public Mono<java.lang.Boolean> expire(K, long) ,public Mono<java.lang.Boolean> expire(K, long, io.lettuce.core.ExpireArgs) ,public Mono<java.lang.Boolean> expire(K, java.time.Duration) ,public Mono<java.lang.Boolean> expire(K, java.time.Duration, io.lettuce.core.ExpireArgs) ,public Mono<java.lang.Boolean> expireat(K, long) ,public Mono<java.lang.Boolean> expireat(K, long, io.lettuce.core.ExpireArgs) ,public Mono<java.lang.Boolean> expireat(K, java.util.Date) ,public Mono<java.lang.Boolean> expireat(K, java.util.Date, io.lettuce.core.ExpireArgs) ,public Mono<java.lang.Boolean> expireat(K, java.time.Instant) ,public Mono<java.lang.Boolean> expireat(K, java.time.Instant, io.lettuce.core.ExpireArgs) ,public Mono<java.lang.Long> expiretime(K) ,public transient Flux<T> fcall(java.lang.String, io.lettuce.core.ScriptOutputType, K[]) ,public transient Flux<T> fcall(java.lang.String, io.lettuce.core.ScriptOutputType, K[], V[]) ,public transient Flux<T> fcallReadOnly(java.lang.String, io.lettuce.core.ScriptOutputType, K[]) ,public transient Flux<T> fcallReadOnly(java.lang.String, io.lettuce.core.ScriptOutputType, K[], V[]) ,public void flushCommands() ,public Mono<java.lang.String> flushall() ,public Mono<java.lang.String> flushall(io.lettuce.core.FlushMode) ,public Mono<java.lang.String> flushallAsync() ,public Mono<java.lang.String> flushdb() ,public Mono<java.lang.String> flushdb(io.lettuce.core.FlushMode) ,public Mono<java.lang.String> flushdbAsync() ,public Mono<byte[]> functionDump() ,public Mono<java.lang.String> functionFlush(io.lettuce.core.FlushMode) ,public Mono<java.lang.String> functionKill() ,public Flux<Map<java.lang.String,java.lang.Object>> functionList() ,public Flux<Map<java.lang.String,java.lang.Object>> functionList(java.lang.String) ,public Mono<java.lang.String> functionLoad(java.lang.String) ,public Mono<java.lang.String> functionLoad(java.lang.String, boolean) ,public Mono<java.lang.String> functionRestore(byte[]) ,public Mono<java.lang.String> functionRestore(byte[], io.lettuce.core.FunctionRestoreMode) ,public Mono<java.lang.Long> geoadd(K, double, double, V) ,public Mono<java.lang.Long> geoadd(K, double, double, V, io.lettuce.core.GeoAddArgs) ,public transient Mono<java.lang.Long> geoadd(K, java.lang.Object[]) ,public transient Mono<java.lang.Long> geoadd(K, GeoValue<V>[]) ,public transient Mono<java.lang.Long> geoadd(K, io.lettuce.core.GeoAddArgs, java.lang.Object[]) ,public transient Mono<java.lang.Long> geoadd(K, io.lettuce.core.GeoAddArgs, GeoValue<V>[]) ,public Mono<java.lang.Double> geodist(K, V, V, io.lettuce.core.GeoArgs.Unit) ,public transient Flux<Value<java.lang.String>> geohash(K, V[]) ,public transient Flux<Value<io.lettuce.core.GeoCoordinates>> geopos(K, V[]) ,public Flux<V> georadius(K, double, double, double, io.lettuce.core.GeoArgs.Unit) ,public Flux<GeoWithin<V>> georadius(K, double, double, double, io.lettuce.core.GeoArgs.Unit, io.lettuce.core.GeoArgs) ,public Mono<java.lang.Long> georadius(K, double, double, double, io.lettuce.core.GeoArgs.Unit, GeoRadiusStoreArgs<K>) ,public Flux<V> georadiusbymember(K, V, double, io.lettuce.core.GeoArgs.Unit) ,public Flux<GeoWithin<V>> georadiusbymember(K, V, double, io.lettuce.core.GeoArgs.Unit, io.lettuce.core.GeoArgs) ,public Mono<java.lang.Long> georadiusbymember(K, V, double, io.lettuce.core.GeoArgs.Unit, GeoRadiusStoreArgs<K>) ,public Flux<V> geosearch(K, GeoRef<K>, io.lettuce.core.GeoSearch.GeoPredicate) ,public Flux<GeoWithin<V>> geosearch(K, GeoRef<K>, io.lettuce.core.GeoSearch.GeoPredicate, io.lettuce.core.GeoArgs) ,public Mono<java.lang.Long> geosearchstore(K, K, GeoRef<K>, io.lettuce.core.GeoSearch.GeoPredicate, io.lettuce.core.GeoArgs, boolean) ,public Mono<V> get(K) ,public StatefulConnection<K,V> getConnection() ,public Mono<java.lang.Long> getbit(K, long) ,public Mono<V> getdel(K) ,public Mono<V> getex(K, io.lettuce.core.GetExArgs) ,public Mono<V> getrange(K, long, long) ,public Mono<V> getset(K, V) ,public transient Mono<java.lang.Long> hdel(K, K[]) ,public Mono<java.lang.Boolean> hexists(K, K) ,public Mono<V> hget(K, K) ,public Flux<KeyValue<K,V>> hgetall(K) ,public Mono<java.lang.Long> hgetall(KeyValueStreamingChannel<K,V>, K) ,public Mono<java.lang.Long> hincrby(K, K, long) ,public Mono<java.lang.Double> hincrbyfloat(K, K, double) ,public Flux<K> hkeys(K) ,public Mono<java.lang.Long> hkeys(KeyStreamingChannel<K>, K) ,public Mono<java.lang.Long> hlen(K) ,public transient Flux<KeyValue<K,V>> hmget(K, K[]) ,public transient Mono<java.lang.Long> hmget(KeyValueStreamingChannel<K,V>, K, K[]) ,public Mono<java.lang.String> hmset(K, Map<K,V>) ,public Mono<K> hrandfield(K) ,public Flux<K> hrandfield(K, long) ,public Mono<KeyValue<K,V>> hrandfieldWithvalues(K) ,public Flux<KeyValue<K,V>> hrandfieldWithvalues(K, long) ,public Mono<MapScanCursor<K,V>> hscan(K) ,public Mono<MapScanCursor<K,V>> hscan(K, io.lettuce.core.ScanArgs) ,public Mono<MapScanCursor<K,V>> hscan(K, io.lettuce.core.ScanCursor, io.lettuce.core.ScanArgs) ,public Mono<MapScanCursor<K,V>> hscan(K, io.lettuce.core.ScanCursor) ,public Mono<io.lettuce.core.StreamScanCursor> hscan(KeyValueStreamingChannel<K,V>, K) ,public Mono<io.lettuce.core.StreamScanCursor> hscan(KeyValueStreamingChannel<K,V>, K, io.lettuce.core.ScanArgs) ,public Mono<io.lettuce.core.StreamScanCursor> hscan(KeyValueStreamingChannel<K,V>, K, io.lettuce.core.ScanCursor, io.lettuce.core.ScanArgs) ,public Mono<io.lettuce.core.StreamScanCursor> hscan(KeyValueStreamingChannel<K,V>, K, io.lettuce.core.ScanCursor) ,public Mono<KeyScanCursor<K>> hscanNovalues(K) ,public Mono<KeyScanCursor<K>> hscanNovalues(K, io.lettuce.core.ScanArgs) ,public Mono<KeyScanCursor<K>> hscanNovalues(K, io.lettuce.core.ScanCursor, io.lettuce.core.ScanArgs) ,public Mono<KeyScanCursor<K>> hscanNovalues(K, io.lettuce.core.ScanCursor) ,public Mono<io.lettuce.core.StreamScanCursor> hscanNovalues(KeyStreamingChannel<K>, K) ,public Mono<io.lettuce.core.StreamScanCursor> hscanNovalues(KeyStreamingChannel<K>, K, io.lettuce.core.ScanArgs) ,public Mono<io.lettuce.core.StreamScanCursor> hscanNovalues(KeyStreamingChannel<K>, K, io.lettuce.core.ScanCursor, io.lettuce.core.ScanArgs) ,public Mono<io.lettuce.core.StreamScanCursor> hscanNovalues(KeyStreamingChannel<K>, K, io.lettuce.core.ScanCursor) ,public Mono<java.lang.Boolean> hset(K, K, V) ,public Mono<java.lang.Long> hset(K, Map<K,V>) ,public Mono<java.lang.Boolean> hsetnx(K, K, V) ,public Mono<java.lang.Long> hstrlen(K, K) ,public Flux<V> hvals(K) ,public Mono<java.lang.Long> hvals(ValueStreamingChannel<V>, K) ,public Mono<java.lang.Long> incr(K) ,public Mono<java.lang.Long> incrby(K, long) ,public Mono<java.lang.Double> incrbyfloat(K, double) ,public Mono<java.lang.String> info() ,public Mono<java.lang.String> info(java.lang.String) ,public boolean isOpen() ,public Flux<K> keys(K) ,public Mono<java.lang.Long> keys(KeyStreamingChannel<K>, K) ,public Mono<java.util.Date> lastsave() ,public Mono<V> lindex(K, long) ,public Mono<java.lang.Long> linsert(K, boolean, V, V) ,public Mono<java.lang.Long> llen(K) ,public Mono<V> lmove(K, K, io.lettuce.core.LMoveArgs) ,public transient Mono<KeyValue<K,List<V>>> lmpop(io.lettuce.core.LMPopArgs, K[]) ,public Mono<V> lpop(K) ,public Flux<V> lpop(K, long) ,public Mono<java.lang.Long> lpos(K, V) ,public Mono<java.lang.Long> lpos(K, V, io.lettuce.core.LPosArgs) ,public Flux<java.lang.Long> lpos(K, V, int) ,public Flux<java.lang.Long> lpos(K, V, int, io.lettuce.core.LPosArgs) ,public transient Mono<java.lang.Long> lpush(K, V[]) ,public transient Mono<java.lang.Long> lpushx(K, V[]) ,public Flux<V> lrange(K, long, long) ,public Mono<java.lang.Long> lrange(ValueStreamingChannel<V>, K, long, long) ,public Mono<java.lang.Long> lrem(K, long, V) ,public Mono<java.lang.String> lset(K, long, V) ,public Mono<java.lang.String> ltrim(K, long, long) ,public Mono<java.lang.Long> memoryUsage(K) ,public transient Flux<KeyValue<K,V>> mget(K[]) ,public Flux<KeyValue<K,V>> mget(Iterable<K>) ,public transient Mono<java.lang.Long> mget(KeyValueStreamingChannel<K,V>, K[]) ,public Mono<java.lang.Long> mget(ValueStreamingChannel<V>, Iterable<K>) ,public Mono<java.lang.Long> mget(KeyValueStreamingChannel<K,V>, Iterable<K>) ,public Mono<java.lang.String> migrate(java.lang.String, int, K, int, long) ,public Mono<java.lang.String> migrate(java.lang.String, int, int, long, MigrateArgs<K>) ,public Mono<java.lang.Boolean> move(K, int) ,public Mono<java.lang.String> mset(Map<K,V>) ,public Mono<java.lang.Boolean> msetnx(Map<K,V>) ,public Mono<java.lang.String> multi() ,public Mono<java.lang.String> objectEncoding(K) ,public Mono<java.lang.Long> objectFreq(K) ,public Mono<java.lang.Long> objectIdletime(K) ,public Mono<java.lang.Long> objectRefcount(K) ,public Mono<java.lang.Boolean> persist(K) ,public Mono<java.lang.Boolean> pexpire(K, long) ,public Mono<java.lang.Boolean> pexpire(K, long, io.lettuce.core.ExpireArgs) ,public Mono<java.lang.Boolean> pexpire(K, java.time.Duration) ,public Mono<java.lang.Boolean> pexpire(K, java.time.Duration, io.lettuce.core.ExpireArgs) ,public Mono<java.lang.Boolean> pexpireat(K, java.util.Date) ,public Mono<java.lang.Boolean> pexpireat(K, java.util.Date, io.lettuce.core.ExpireArgs) ,public Mono<java.lang.Boolean> pexpireat(K, java.time.Instant) ,public Mono<java.lang.Boolean> pexpireat(K, java.time.Instant, io.lettuce.core.ExpireArgs) ,public Mono<java.lang.Boolean> pexpireat(K, long) ,public Mono<java.lang.Boolean> pexpireat(K, long, io.lettuce.core.ExpireArgs) ,public Mono<java.lang.Long> pexpiretime(K) ,public transient Mono<java.lang.Long> pfadd(K, V[]) ,public transient Mono<java.lang.Long> pfadd(K, V, V[]) ,public transient Mono<java.lang.Long> pfcount(K[]) ,public transient Mono<java.lang.Long> pfcount(K, K[]) ,public transient Mono<java.lang.String> pfmerge(K, K[]) ,public transient Mono<java.lang.String> pfmerge(K, K, K[]) ,public Mono<java.lang.String> ping() ,public Mono<java.lang.String> psetex(K, long, V) ,public Mono<java.lang.Long> pttl(K) ,public Mono<java.lang.Long> publish(K, V) ,public Flux<K> pubsubChannels() ,public Flux<K> pubsubChannels(K) ,public Mono<java.lang.Long> pubsubNumpat() ,public transient Mono<Map<K,java.lang.Long>> pubsubNumsub(K[]) ,public Flux<K> pubsubShardChannels() ,public Flux<K> pubsubShardChannels(K) ,public transient Mono<Map<K,java.lang.Long>> pubsubShardNumsub(K[]) ,public Mono<java.lang.String> quit() ,public Mono<K> randomkey() ,public Mono<java.lang.String> readOnly() ,public Mono<java.lang.String> readWrite() ,public Mono<java.lang.String> rename(K, K) ,public Mono<java.lang.Boolean> renamenx(K, K) ,public Mono<java.lang.String> replicaof(java.lang.String, int) ,public Mono<java.lang.String> replicaofNoOne() ,public void reset() ,public Mono<java.lang.String> restore(K, long, byte[]) ,public Mono<java.lang.String> restore(K, byte[], io.lettuce.core.RestoreArgs) ,public Flux<java.lang.Object> role() ,public Mono<V> rpop(K) ,public Flux<V> rpop(K, long) ,public Mono<V> rpoplpush(K, K) ,public transient Mono<java.lang.Long> rpush(K, V[]) ,public transient Mono<java.lang.Long> rpushx(K, V[]) ,public transient Mono<java.lang.Long> sadd(K, V[]) ,public Mono<java.lang.String> save() ,public Mono<KeyScanCursor<K>> scan() ,public Mono<KeyScanCursor<K>> scan(io.lettuce.core.ScanArgs) ,public Mono<KeyScanCursor<K>> scan(io.lettuce.core.ScanCursor, io.lettuce.core.ScanArgs) ,public Mono<KeyScanCursor<K>> scan(io.lettuce.core.ScanCursor) ,public Mono<io.lettuce.core.StreamScanCursor> scan(KeyStreamingChannel<K>) ,public Mono<io.lettuce.core.StreamScanCursor> scan(KeyStreamingChannel<K>, io.lettuce.core.ScanArgs) ,public Mono<io.lettuce.core.StreamScanCursor> scan(KeyStreamingChannel<K>, io.lettuce.core.ScanCursor, io.lettuce.core.ScanArgs) ,public Mono<io.lettuce.core.StreamScanCursor> scan(KeyStreamingChannel<K>, io.lettuce.core.ScanCursor) ,public Mono<java.lang.Long> scard(K) ,public transient Flux<java.lang.Boolean> scriptExists(java.lang.String[]) ,public Mono<java.lang.String> scriptFlush() ,public Mono<java.lang.String> scriptFlush(io.lettuce.core.FlushMode) ,public Mono<java.lang.String> scriptKill() ,public Mono<java.lang.String> scriptLoad(java.lang.String) ,public Mono<java.lang.String> scriptLoad(byte[]) ,public transient Flux<V> sdiff(K[]) ,public transient Mono<java.lang.Long> sdiff(ValueStreamingChannel<V>, K[]) ,public transient Mono<java.lang.Long> sdiffstore(K, K[]) ,public Mono<java.lang.String> select(int) ,public Mono<java.lang.String> set(K, V) ,public Mono<java.lang.String> set(K, V, io.lettuce.core.SetArgs) ,public void setAutoFlushCommands(boolean) ,public Mono<V> setGet(K, V) ,public Mono<V> setGet(K, V, io.lettuce.core.SetArgs) ,public void setTimeout(java.time.Duration) ,public Mono<java.lang.Long> setbit(K, long, int) ,public Mono<java.lang.String> setex(K, long, V) ,public Mono<java.lang.Boolean> setnx(K, V) ,public Mono<java.lang.Long> setrange(K, long, V) ,public Mono<java.lang.Void> shutdown(boolean) ,public Mono<java.lang.Void> shutdown(io.lettuce.core.ShutdownArgs) ,public transient Flux<V> sinter(K[]) ,public transient Mono<java.lang.Long> sinter(ValueStreamingChannel<V>, K[]) ,public transient Mono<java.lang.Long> sintercard(K[]) ,public transient Mono<java.lang.Long> sintercard(long, K[]) ,public transient Mono<java.lang.Long> sinterstore(K, K[]) ,public Mono<java.lang.Boolean> sismember(K, V) ,public Mono<java.lang.String> slaveof(java.lang.String, int) ,public Mono<java.lang.String> slaveofNoOne() ,public Flux<java.lang.Object> slowlogGet() ,public Flux<java.lang.Object> slowlogGet(int) ,public Mono<java.lang.Long> slowlogLen() ,public Mono<java.lang.String> slowlogReset() ,public Flux<V> smembers(K) ,public Mono<java.lang.Long> smembers(ValueStreamingChannel<V>, K) ,public transient Flux<java.lang.Boolean> smismember(K, V[]) ,public Mono<java.lang.Boolean> smove(K, K, V) ,public Flux<V> sort(K) ,public Mono<java.lang.Long> sort(ValueStreamingChannel<V>, K) ,public Flux<V> sort(K, io.lettuce.core.SortArgs) ,public Mono<java.lang.Long> sort(ValueStreamingChannel<V>, K, io.lettuce.core.SortArgs) ,public Flux<V> sortReadOnly(K) ,public Mono<java.lang.Long> sortReadOnly(ValueStreamingChannel<V>, K) ,public Flux<V> sortReadOnly(K, io.lettuce.core.SortArgs) ,public Mono<java.lang.Long> sortReadOnly(ValueStreamingChannel<V>, K, io.lettuce.core.SortArgs) ,public Mono<java.lang.Long> sortStore(K, io.lettuce.core.SortArgs, K) ,public Mono<V> spop(K) ,public Flux<V> spop(K, long) ,public Mono<V> srandmember(K) ,public Flux<V> srandmember(K, long) ,public Mono<java.lang.Long> srandmember(ValueStreamingChannel<V>, K, long) ,public transient Mono<java.lang.Long> srem(K, V[]) ,public Mono<ValueScanCursor<V>> sscan(K) ,public Mono<ValueScanCursor<V>> sscan(K, io.lettuce.core.ScanArgs) ,public Mono<ValueScanCursor<V>> sscan(K, io.lettuce.core.ScanCursor, io.lettuce.core.ScanArgs) ,public Mono<ValueScanCursor<V>> sscan(K, io.lettuce.core.ScanCursor) ,public Mono<io.lettuce.core.StreamScanCursor> sscan(ValueStreamingChannel<V>, K) ,public Mono<io.lettuce.core.StreamScanCursor> sscan(ValueStreamingChannel<V>, K, io.lettuce.core.ScanArgs) ,public Mono<io.lettuce.core.StreamScanCursor> sscan(ValueStreamingChannel<V>, K, io.lettuce.core.ScanCursor, io.lettuce.core.ScanArgs) ,public Mono<io.lettuce.core.StreamScanCursor> sscan(ValueStreamingChannel<V>, K, io.lettuce.core.ScanCursor) ,public Mono<io.lettuce.core.StringMatchResult> stralgoLcs(io.lettuce.core.StrAlgoArgs) ,public Mono<java.lang.Long> strlen(K) ,public transient Flux<V> sunion(K[]) ,public transient Mono<java.lang.Long> sunion(ValueStreamingChannel<V>, K[]) ,public transient Mono<java.lang.Long> sunionstore(K, K[]) ,public Mono<java.lang.String> swapdb(int, int) ,public Flux<V> time() ,public transient Mono<java.lang.Long> touch(K[]) ,public Mono<java.lang.Long> touch(Iterable<K>) ,public Mono<java.lang.Long> ttl(K) ,public Mono<java.lang.String> type(K) ,public transient Mono<java.lang.Long> unlink(K[]) ,public Mono<java.lang.Long> unlink(Iterable<K>) ,public Mono<java.lang.String> unwatch() ,public Mono<java.lang.Long> waitForReplication(int, long) ,public transient Mono<java.lang.String> watch(K[]) ,public transient Mono<java.lang.Long> xack(K, K, java.lang.String[]) ,public Mono<java.lang.String> xadd(K, Map<K,V>) ,public Mono<java.lang.String> xadd(K, io.lettuce.core.XAddArgs, Map<K,V>) ,public transient Mono<java.lang.String> xadd(K, java.lang.Object[]) ,public transient Mono<java.lang.String> xadd(K, io.lettuce.core.XAddArgs, java.lang.Object[]) ,public Mono<ClaimedMessages<K,V>> xautoclaim(K, XAutoClaimArgs<K>) ,public transient Flux<StreamMessage<K,V>> xclaim(K, Consumer<K>, long, java.lang.String[]) ,public transient Flux<StreamMessage<K,V>> xclaim(K, Consumer<K>, io.lettuce.core.XClaimArgs, java.lang.String[]) ,public transient Mono<java.lang.Long> xdel(K, java.lang.String[]) ,public Mono<java.lang.String> xgroupCreate(StreamOffset<K>, K) ,public Mono<java.lang.String> xgroupCreate(StreamOffset<K>, K, io.lettuce.core.XGroupCreateArgs) ,public Mono<java.lang.Boolean> xgroupCreateconsumer(K, Consumer<K>) ,public Mono<java.lang.Long> xgroupDelconsumer(K, Consumer<K>) ,public Mono<java.lang.Boolean> xgroupDestroy(K, K) ,public Mono<java.lang.String> xgroupSetid(StreamOffset<K>, K) ,public Flux<java.lang.Object> xinfoConsumers(K, K) ,public Flux<java.lang.Object> xinfoGroups(K) ,public Flux<java.lang.Object> xinfoStream(K) ,public Mono<java.lang.Long> xlen(K) ,public Mono<io.lettuce.core.models.stream.PendingMessages> xpending(K, K) ,public Flux<io.lettuce.core.models.stream.PendingMessage> xpending(K, K, Range<java.lang.String>, io.lettuce.core.Limit) ,public Flux<io.lettuce.core.models.stream.PendingMessage> xpending(K, Consumer<K>, Range<java.lang.String>, io.lettuce.core.Limit) ,public Flux<io.lettuce.core.models.stream.PendingMessage> xpending(K, XPendingArgs<K>) ,public Flux<StreamMessage<K,V>> xrange(K, Range<java.lang.String>) ,public Flux<StreamMessage<K,V>> xrange(K, Range<java.lang.String>, io.lettuce.core.Limit) ,public transient Flux<StreamMessage<K,V>> xread(StreamOffset<K>[]) ,public transient Flux<StreamMessage<K,V>> xread(io.lettuce.core.XReadArgs, StreamOffset<K>[]) ,public transient Flux<StreamMessage<K,V>> xreadgroup(Consumer<K>, StreamOffset<K>[]) ,public transient Flux<StreamMessage<K,V>> xreadgroup(Consumer<K>, io.lettuce.core.XReadArgs, StreamOffset<K>[]) ,public Flux<StreamMessage<K,V>> xrevrange(K, Range<java.lang.String>) ,public Flux<StreamMessage<K,V>> xrevrange(K, Range<java.lang.String>, io.lettuce.core.Limit) ,public Mono<java.lang.Long> xtrim(K, long) ,public Mono<java.lang.Long> xtrim(K, boolean, long) ,public Mono<java.lang.Long> xtrim(K, io.lettuce.core.XTrimArgs) ,public Mono<java.lang.Long> zadd(K, double, V) ,public transient Mono<java.lang.Long> zadd(K, java.lang.Object[]) ,public transient Mono<java.lang.Long> zadd(K, ScoredValue<V>[]) ,public Mono<java.lang.Long> zadd(K, io.lettuce.core.ZAddArgs, double, V) ,public transient Mono<java.lang.Long> zadd(K, io.lettuce.core.ZAddArgs, java.lang.Object[]) ,public transient Mono<java.lang.Long> zadd(K, io.lettuce.core.ZAddArgs, ScoredValue<V>[]) ,public Mono<java.lang.Double> zaddincr(K, double, V) ,public Mono<java.lang.Double> zaddincr(K, io.lettuce.core.ZAddArgs, double, V) ,public Mono<java.lang.Long> zcard(K) ,public Mono<java.lang.Long> zcount(K, double, double) ,public Mono<java.lang.Long> zcount(K, java.lang.String, java.lang.String) ,public Mono<java.lang.Long> zcount(K, Range<? extends java.lang.Number>) ,public transient Flux<V> zdiff(K[]) ,public transient Flux<ScoredValue<V>> zdiffWithScores(K[]) ,public transient Mono<java.lang.Long> zdiffstore(K, K[]) ,public Mono<java.lang.Double> zincrby(K, double, V) ,public transient Flux<V> zinter(K[]) ,public transient Flux<V> zinter(io.lettuce.core.ZAggregateArgs, K[]) ,public transient Flux<ScoredValue<V>> zinterWithScores(K[]) ,public transient Flux<ScoredValue<V>> zinterWithScores(io.lettuce.core.ZAggregateArgs, K[]) ,public transient Mono<java.lang.Long> zintercard(K[]) ,public transient Mono<java.lang.Long> zintercard(long, K[]) ,public transient Mono<java.lang.Long> zinterstore(K, K[]) ,public transient Mono<java.lang.Long> zinterstore(K, io.lettuce.core.ZStoreArgs, K[]) ,public Mono<java.lang.Long> zlexcount(K, java.lang.String, java.lang.String) ,public Mono<java.lang.Long> zlexcount(K, Range<? extends V>) ,public transient Mono<KeyValue<K,ScoredValue<V>>> zmpop(io.lettuce.core.ZPopArgs, K[]) ,public transient Mono<KeyValue<K,List<ScoredValue<V>>>> zmpop(int, io.lettuce.core.ZPopArgs, K[]) ,public transient Mono<List<java.lang.Double>> zmscore(K, V[]) ,public Mono<ScoredValue<V>> zpopmax(K) ,public Flux<ScoredValue<V>> zpopmax(K, long) ,public Mono<ScoredValue<V>> zpopmin(K) ,public Flux<ScoredValue<V>> zpopmin(K, long) ,public Mono<V> zrandmember(K) ,public Flux<V> zrandmember(K, long) ,public Mono<ScoredValue<V>> zrandmemberWithScores(K) ,public Flux<ScoredValue<V>> zrandmemberWithScores(K, long) ,public Flux<V> zrange(K, long, long) ,public Mono<java.lang.Long> zrange(ValueStreamingChannel<V>, K, long, long) ,public Flux<ScoredValue<V>> zrangeWithScores(K, long, long) ,public Mono<java.lang.Long> zrangeWithScores(ScoredValueStreamingChannel<V>, K, long, long) ,public Flux<V> zrangebylex(K, java.lang.String, java.lang.String) ,public Flux<V> zrangebylex(K, Range<? extends V>) ,public Flux<V> zrangebylex(K, java.lang.String, java.lang.String, long, long) ,public Flux<V> zrangebylex(K, Range<? extends V>, io.lettuce.core.Limit) ,public Flux<V> zrangebyscore(K, double, double) ,public Flux<V> zrangebyscore(K, java.lang.String, java.lang.String) ,public Flux<V> zrangebyscore(K, double, double, long, long) ,public Flux<V> zrangebyscore(K, java.lang.String, java.lang.String, long, long) ,public Flux<V> zrangebyscore(K, Range<? extends java.lang.Number>) ,public Flux<V> zrangebyscore(K, Range<? extends java.lang.Number>, io.lettuce.core.Limit) ,public Mono<java.lang.Long> zrangebyscore(ValueStreamingChannel<V>, K, double, double) ,public Mono<java.lang.Long> zrangebyscore(ValueStreamingChannel<V>, K, java.lang.String, java.lang.String) ,public Mono<java.lang.Long> zrangebyscore(ValueStreamingChannel<V>, K, double, double, long, long) ,public Mono<java.lang.Long> zrangebyscore(ValueStreamingChannel<V>, K, Range<? extends java.lang.Number>) ,public Mono<java.lang.Long> zrangebyscore(ValueStreamingChannel<V>, K, java.lang.String, java.lang.String, long, long) ,public Mono<java.lang.Long> zrangebyscore(ValueStreamingChannel<V>, K, Range<? extends java.lang.Number>, io.lettuce.core.Limit) ,public Flux<ScoredValue<V>> zrangebyscoreWithScores(K, double, double) ,public Flux<ScoredValue<V>> zrangebyscoreWithScores(K, java.lang.String, java.lang.String) ,public Flux<ScoredValue<V>> zrangebyscoreWithScores(K, double, double, long, long) ,public Flux<ScoredValue<V>> zrangebyscoreWithScores(K, java.lang.String, java.lang.String, long, long) ,public Flux<ScoredValue<V>> zrangebyscoreWithScores(K, Range<? extends java.lang.Number>) ,public Flux<ScoredValue<V>> zrangebyscoreWithScores(K, Range<? extends java.lang.Number>, io.lettuce.core.Limit) ,public Mono<java.lang.Long> zrangebyscoreWithScores(ScoredValueStreamingChannel<V>, K, double, double) ,public Mono<java.lang.Long> zrangebyscoreWithScores(ScoredValueStreamingChannel<V>, K, java.lang.String, java.lang.String) ,public Mono<java.lang.Long> zrangebyscoreWithScores(ScoredValueStreamingChannel<V>, K, Range<? extends java.lang.Number>) ,public Mono<java.lang.Long> zrangebyscoreWithScores(ScoredValueStreamingChannel<V>, K, double, double, long, long) ,public Mono<java.lang.Long> zrangebyscoreWithScores(ScoredValueStreamingChannel<V>, K, java.lang.String, java.lang.String, long, long) ,public Mono<java.lang.Long> zrangebyscoreWithScores(ScoredValueStreamingChannel<V>, K, Range<? extends java.lang.Number>, io.lettuce.core.Limit) ,public Mono<java.lang.Long> zrangestore(K, K, Range<java.lang.Long>) ,public Mono<java.lang.Long> zrangestorebylex(K, K, Range<? extends V>, io.lettuce.core.Limit) ,public Mono<java.lang.Long> zrangestorebyscore(K, K, Range<? extends java.lang.Number>, io.lettuce.core.Limit) ,public Mono<java.lang.Long> zrank(K, V) ,public Mono<ScoredValue<java.lang.Long>> zrankWithScore(K, V) ,public transient Mono<java.lang.Long> zrem(K, V[]) ,public Mono<java.lang.Long> zremrangebylex(K, java.lang.String, java.lang.String) ,public Mono<java.lang.Long> zremrangebylex(K, Range<? extends V>) ,public Mono<java.lang.Long> zremrangebyrank(K, long, long) ,public Mono<java.lang.Long> zremrangebyscore(K, double, double) ,public Mono<java.lang.Long> zremrangebyscore(K, java.lang.String, java.lang.String) ,public Mono<java.lang.Long> zremrangebyscore(K, Range<? extends java.lang.Number>) ,public Flux<V> zrevrange(K, long, long) ,public Mono<java.lang.Long> zrevrange(ValueStreamingChannel<V>, K, long, long) ,public Flux<ScoredValue<V>> zrevrangeWithScores(K, long, long) ,public Mono<java.lang.Long> zrevrangeWithScores(ScoredValueStreamingChannel<V>, K, long, long) ,public Flux<V> zrevrangebylex(K, Range<? extends V>) ,public Flux<V> zrevrangebylex(K, Range<? extends V>, io.lettuce.core.Limit) ,public Flux<V> zrevrangebyscore(K, double, double) ,public Flux<V> zrevrangebyscore(K, java.lang.String, java.lang.String) ,public Flux<V> zrevrangebyscore(K, Range<? extends java.lang.Number>) ,public Flux<V> zrevrangebyscore(K, double, double, long, long) ,public Flux<V> zrevrangebyscore(K, java.lang.String, java.lang.String, long, long) ,public Flux<V> zrevrangebyscore(K, Range<? extends java.lang.Number>, io.lettuce.core.Limit) ,public Mono<java.lang.Long> zrevrangebyscore(ValueStreamingChannel<V>, K, double, double) ,public Mono<java.lang.Long> zrevrangebyscore(ValueStreamingChannel<V>, K, java.lang.String, java.lang.String) ,public Mono<java.lang.Long> zrevrangebyscore(ValueStreamingChannel<V>, K, Range<? extends java.lang.Number>) ,public Mono<java.lang.Long> zrevrangebyscore(ValueStreamingChannel<V>, K, double, double, long, long) ,public Mono<java.lang.Long> zrevrangebyscore(ValueStreamingChannel<V>, K, java.lang.String, java.lang.String, long, long) ,public Mono<java.lang.Long> zrevrangebyscore(ValueStreamingChannel<V>, K, Range<? extends java.lang.Number>, io.lettuce.core.Limit) ,public Flux<ScoredValue<V>> zrevrangebyscoreWithScores(K, double, double) ,public Flux<ScoredValue<V>> zrevrangebyscoreWithScores(K, java.lang.String, java.lang.String) ,public Flux<ScoredValue<V>> zrevrangebyscoreWithScores(K, Range<? extends java.lang.Number>) ,public Flux<ScoredValue<V>> zrevrangebyscoreWithScores(K, double, double, long, long) ,public Flux<ScoredValue<V>> zrevrangebyscoreWithScores(K, java.lang.String, java.lang.String, long, long) ,public Flux<ScoredValue<V>> zrevrangebyscoreWithScores(K, Range<? extends java.lang.Number>, io.lettuce.core.Limit) ,public Mono<java.lang.Long> zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V>, K, double, double) ,public Mono<java.lang.Long> zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V>, K, java.lang.String, java.lang.String) ,public Mono<java.lang.Long> zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V>, K, Range<? extends java.lang.Number>) ,public Mono<java.lang.Long> zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V>, K, double, double, long, long) ,public Mono<java.lang.Long> zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V>, K, java.lang.String, java.lang.String, long, long) ,public Mono<java.lang.Long> zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V>, K, Range<? extends java.lang.Number>, io.lettuce.core.Limit) ,public Mono<java.lang.Long> zrevrangestore(K, K, Range<java.lang.Long>) ,public Mono<java.lang.Long> zrevrangestorebylex(K, K, Range<? extends V>, io.lettuce.core.Limit) ,public Mono<java.lang.Long> zrevrangestorebyscore(K, K, Range<? extends java.lang.Number>, io.lettuce.core.Limit) ,public Mono<java.lang.Long> zrevrank(K, V) ,public Mono<ScoredValue<java.lang.Long>> zrevrankWithScore(K, V) ,public Mono<ScoredValueScanCursor<V>> zscan(K) ,public Mono<ScoredValueScanCursor<V>> zscan(K, io.lettuce.core.ScanArgs) ,public Mono<ScoredValueScanCursor<V>> zscan(K, io.lettuce.core.ScanCursor, io.lettuce.core.ScanArgs) ,public Mono<ScoredValueScanCursor<V>> zscan(K, io.lettuce.core.ScanCursor) ,public Mono<io.lettuce.core.StreamScanCursor> zscan(ScoredValueStreamingChannel<V>, K) ,public Mono<io.lettuce.core.StreamScanCursor> zscan(ScoredValueStreamingChannel<V>, K, io.lettuce.core.ScanArgs) ,public Mono<io.lettuce.core.StreamScanCursor> zscan(ScoredValueStreamingChannel<V>, K, io.lettuce.core.ScanCursor, io.lettuce.core.ScanArgs) ,public Mono<io.lettuce.core.StreamScanCursor> zscan(ScoredValueStreamingChannel<V>, K, io.lettuce.core.ScanCursor) ,public Mono<java.lang.Double> zscore(K, V) ,public transient Flux<V> zunion(K[]) ,public transient Flux<V> zunion(io.lettuce.core.ZAggregateArgs, K[]) ,public transient Flux<ScoredValue<V>> zunionWithScores(K[]) ,public transient Flux<ScoredValue<V>> zunionWithScores(io.lettuce.core.ZAggregateArgs, K[]) ,public transient Mono<java.lang.Long> zunionstore(K, K[]) ,public transient Mono<java.lang.Long> zunionstore(K, io.lettuce.core.ZStoreArgs, K[]) <variables>private final non-sealed io.lettuce.core.resource.ClientResources clientResources,private final non-sealed RedisCommandBuilder<K,V> commandBuilder,private final non-sealed StatefulConnection<K,V> connection,private volatile EventExecutorGroup scheduler,private final non-sealed boolean tracingEnabled