diff --git a/src/main/java/io/vertx/redis/client/Command.java b/src/main/java/io/vertx/redis/client/Command.java index 3de0b7ab..02c63570 100644 --- a/src/main/java/io/vertx/redis/client/Command.java +++ b/src/main/java/io/vertx/redis/client/Command.java @@ -307,7 +307,7 @@ public interface Command { Command SORT = new CommandImpl("sort", -2, false, false, true, new KeyLocator(true, new BeginSearchIndex(1), new FindKeysRange(0, 1, 0))); Command SORT_RO = new CommandImpl("sort_ro", -2, true, false, true, new KeyLocator(true, new BeginSearchIndex(1), new FindKeysRange(0, 1, 0))); Command SPOP = new CommandImpl("spop", -2, false, false, false, new KeyLocator(false, new BeginSearchIndex(1), new FindKeysRange(0, 1, 0))); - Command SPUBLISH = new CommandImpl("spublish", 3, null, true, false, new KeyLocator(null, new BeginSearchIndex(1), new FindKeysRange(0, 1, 0))); + Command SPUBLISH = new CommandImpl("spublish", 3, null, false, false, new KeyLocator(null, new BeginSearchIndex(1), new FindKeysRange(0, 1, 0))); Command SRANDMEMBER = new CommandImpl("srandmember", -2, true, false, false, new KeyLocator(true, new BeginSearchIndex(1), new FindKeysRange(0, 1, 0))); Command SREM = new CommandImpl("srem", -3, false, false, false, new KeyLocator(false, new BeginSearchIndex(1), new FindKeysRange(0, 1, 0))); Command SSCAN = new CommandImpl("sscan", -3, true, false, false, new KeyLocator(true, new BeginSearchIndex(1), new FindKeysRange(0, 1, 0))); diff --git a/src/main/java/io/vertx/redis/client/RedisAPI.java b/src/main/java/io/vertx/redis/client/RedisAPI.java index 78c4cce8..64511936 100644 --- a/src/main/java/io/vertx/redis/client/RedisAPI.java +++ b/src/main/java/io/vertx/redis/client/RedisAPI.java @@ -27,7 +27,7 @@ /** * Auto generated Redis API client wrapper. - * @version redis_version:7.0.9 + * @version redis_version:7.0.12 */ @VertxGen public interface RedisAPI { @@ -45,7 +45,7 @@ static RedisAPI api(RedisConnection connection) { void close(); /** - * Redis command ftAdd. + * Redis command FT.ADD. * @return Future response. */ default Future<@Nullable Response> ftAdd(List args) { @@ -53,7 +53,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command ftAggregate. + * Redis command FT.AGGREGATE. * @return Future response. */ default Future<@Nullable Response> ftAggregate(List args) { @@ -61,7 +61,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command ftAliasadd. + * Redis command FT.ALIASADD. * @return Future response. */ default Future<@Nullable Response> ftAliasadd(List args) { @@ -69,7 +69,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command ftAliasdel. + * Redis command FT.ALIASDEL. * @return Future response. */ default Future<@Nullable Response> ftAliasdel(List args) { @@ -77,7 +77,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command ftAliasupdate. + * Redis command FT.ALIASUPDATE. * @return Future response. */ default Future<@Nullable Response> ftAliasupdate(List args) { @@ -85,7 +85,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command ftAlter. + * Redis command FT.ALTER. * @return Future response. */ default Future<@Nullable Response> ftAlter(List args) { @@ -93,7 +93,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command ftConfig. + * Redis command FT.CONFIG. * @return Future response. */ default Future<@Nullable Response> ftConfig(List args) { @@ -101,7 +101,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command ftCreate. + * Redis command FT.CREATE. * @return Future response. */ default Future<@Nullable Response> ftCreate(List args) { @@ -109,7 +109,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command ftCursor. + * Redis command FT.CURSOR. * @return Future response. */ default Future<@Nullable Response> ftCursor(List args) { @@ -117,7 +117,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command ftDebug. + * Redis command FT.DEBUG. * @return Future response. */ default Future<@Nullable Response> ftDebug(List args) { @@ -125,7 +125,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command ftDel. + * Redis command FT.DEL. * @return Future response. */ default Future<@Nullable Response> ftDel(List args) { @@ -133,7 +133,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command ftDictadd. + * Redis command FT.DICTADD. * @return Future response. */ default Future<@Nullable Response> ftDictadd(List args) { @@ -141,7 +141,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command ftDictdel. + * Redis command FT.DICTDEL. * @return Future response. */ default Future<@Nullable Response> ftDictdel(List args) { @@ -149,7 +149,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command ftDictdump. + * Redis command FT.DICTDUMP. * @return Future response. */ default Future<@Nullable Response> ftDictdump(List args) { @@ -157,7 +157,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command ftDrop. + * Redis command FT.DROP. * @return Future response. */ default Future<@Nullable Response> ftDrop(List args) { @@ -165,7 +165,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command ftDropindex. + * Redis command FT.DROPINDEX. * @return Future response. */ default Future<@Nullable Response> ftDropindex(List args) { @@ -173,7 +173,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command ftExplain. + * Redis command FT.EXPLAIN. * @return Future response. */ default Future<@Nullable Response> ftExplain(List args) { @@ -181,7 +181,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command ftExplaincli. + * Redis command FT.EXPLAINCLI. * @return Future response. */ default Future<@Nullable Response> ftExplaincli(List args) { @@ -189,7 +189,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command ftGet. + * Redis command FT.GET. * @return Future response. */ default Future<@Nullable Response> ftGet(List args) { @@ -197,7 +197,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command ftInfo. + * Redis command FT.INFO. * @return Future response. */ default Future<@Nullable Response> ftInfo(List args) { @@ -205,7 +205,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command ftMget. + * Redis command FT.MGET. * @return Future response. */ default Future<@Nullable Response> ftMget(List args) { @@ -213,7 +213,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command ftProfile. + * Redis command FT.PROFILE. * @return Future response. */ default Future<@Nullable Response> ftProfile(List args) { @@ -221,7 +221,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command ftSafeadd. + * Redis command FT.SAFEADD. * @return Future response. */ default Future<@Nullable Response> ftSafeadd(List args) { @@ -229,7 +229,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command ftSearch. + * Redis command FT.SEARCH. * @return Future response. */ default Future<@Nullable Response> ftSearch(List args) { @@ -237,7 +237,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command ftSpellcheck. + * Redis command FT.SPELLCHECK. * @return Future response. */ default Future<@Nullable Response> ftSpellcheck(List args) { @@ -245,7 +245,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command ftSugadd. + * Redis command FT.SUGADD. * @return Future response. */ default Future<@Nullable Response> ftSugadd(List args) { @@ -253,7 +253,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command ftSugdel. + * Redis command FT.SUGDEL. * @return Future response. */ default Future<@Nullable Response> ftSugdel(List args) { @@ -261,7 +261,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command ftSugget. + * Redis command FT.SUGGET. * @return Future response. */ default Future<@Nullable Response> ftSugget(List args) { @@ -269,7 +269,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command ftSuglen. + * Redis command FT.SUGLEN. * @return Future response. */ default Future<@Nullable Response> ftSuglen(List args) { @@ -277,7 +277,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command ftSynadd. + * Redis command FT.SYNADD. * @return Future response. */ default Future<@Nullable Response> ftSynadd(List args) { @@ -285,7 +285,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command ftSyndump. + * Redis command FT.SYNDUMP. * @return Future response. */ default Future<@Nullable Response> ftSyndump(List args) { @@ -293,7 +293,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command ftSynupdate. + * Redis command FT.SYNUPDATE. * @return Future response. */ default Future<@Nullable Response> ftSynupdate(List args) { @@ -301,7 +301,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command ftTagvals. + * Redis command FT.TAGVALS. * @return Future response. */ default Future<@Nullable Response> ftTagvals(List args) { @@ -309,7 +309,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command ftAliasaddifnx. + * Redis command FT._ALIASADDIFNX. * @return Future response. */ default Future<@Nullable Response> ftAliasaddifnx(List args) { @@ -317,7 +317,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command ftAliasdelifx. + * Redis command FT._ALIASDELIFX. * @return Future response. */ default Future<@Nullable Response> ftAliasdelifx(List args) { @@ -325,7 +325,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command ftAlterifnx. + * Redis command FT._ALTERIFNX. * @return Future response. */ default Future<@Nullable Response> ftAlterifnx(List args) { @@ -333,7 +333,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command ftCreateifnx. + * Redis command FT._CREATEIFNX. * @return Future response. */ default Future<@Nullable Response> ftCreateifnx(List args) { @@ -341,7 +341,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command ftDropifx. + * Redis command FT._DROPIFX. * @return Future response. */ default Future<@Nullable Response> ftDropifx(List args) { @@ -349,7 +349,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command ftDropindexifx. + * Redis command FT._DROPINDEXIFX. * @return Future response. */ default Future<@Nullable Response> ftDropindexifx(List args) { @@ -357,7 +357,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command ftList. + * Redis command FT._LIST. * @return Future response. */ default Future<@Nullable Response> ftList(List args) { @@ -365,7 +365,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command acl. + * Redis command ACL. * @return Future response. */ default Future<@Nullable Response> acl(List args) { @@ -373,7 +373,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command append. + * Redis command APPEND. * @return Future response. */ default Future<@Nullable Response> append(String arg0, String arg1) { @@ -381,7 +381,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command asking. + * Redis command ASKING. * @return Future response. */ default Future<@Nullable Response> asking() { @@ -389,7 +389,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command auth. + * Redis command AUTH. * @return Future response. */ default Future<@Nullable Response> auth(List args) { @@ -397,7 +397,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command bfAdd. + * Redis command BF.ADD. * @return Future response. */ default Future<@Nullable Response> bfAdd(List args) { @@ -405,7 +405,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command bfCard. + * Redis command BF.CARD. * @return Future response. */ default Future<@Nullable Response> bfCard(List args) { @@ -413,7 +413,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command bfDebug. + * Redis command BF.DEBUG. * @return Future response. */ default Future<@Nullable Response> bfDebug(List args) { @@ -421,7 +421,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command bfExists. + * Redis command BF.EXISTS. * @return Future response. */ default Future<@Nullable Response> bfExists(List args) { @@ -429,7 +429,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command bfInfo. + * Redis command BF.INFO. * @return Future response. */ default Future<@Nullable Response> bfInfo(List args) { @@ -437,7 +437,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command bfInsert. + * Redis command BF.INSERT. * @return Future response. */ default Future<@Nullable Response> bfInsert(List args) { @@ -445,7 +445,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command bfLoadchunk. + * Redis command BF.LOADCHUNK. * @return Future response. */ default Future<@Nullable Response> bfLoadchunk(List args) { @@ -453,7 +453,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command bfMadd. + * Redis command BF.MADD. * @return Future response. */ default Future<@Nullable Response> bfMadd(List args) { @@ -461,7 +461,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command bfMexists. + * Redis command BF.MEXISTS. * @return Future response. */ default Future<@Nullable Response> bfMexists(List args) { @@ -469,7 +469,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command bfReserve. + * Redis command BF.RESERVE. * @return Future response. */ default Future<@Nullable Response> bfReserve(List args) { @@ -477,7 +477,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command bfScandump. + * Redis command BF.SCANDUMP. * @return Future response. */ default Future<@Nullable Response> bfScandump(List args) { @@ -485,7 +485,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command bgrewriteaof. + * Redis command BGREWRITEAOF. * @return Future response. */ default Future<@Nullable Response> bgrewriteaof() { @@ -493,7 +493,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command bgsave. + * Redis command BGSAVE. * @return Future response. */ default Future<@Nullable Response> bgsave(List args) { @@ -501,7 +501,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command bitcount. + * Redis command BITCOUNT. * @return Future response. */ default Future<@Nullable Response> bitcount(List args) { @@ -509,7 +509,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command bitfield. + * Redis command BITFIELD. * @return Future response. */ default Future<@Nullable Response> bitfield(List args) { @@ -517,7 +517,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command bitfieldRo. + * Redis command BITFIELD_RO. * @return Future response. */ default Future<@Nullable Response> bitfieldRo(List args) { @@ -525,7 +525,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command bitop. + * Redis command BITOP. * @return Future response. */ default Future<@Nullable Response> bitop(List args) { @@ -533,7 +533,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command bitpos. + * Redis command BITPOS. * @return Future response. */ default Future<@Nullable Response> bitpos(List args) { @@ -541,7 +541,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command blmove. + * Redis command BLMOVE. * @return Future response. */ default Future<@Nullable Response> blmove(String arg0, String arg1, String arg2, String arg3, String arg4) { @@ -549,7 +549,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command blmpop. + * Redis command BLMPOP. * @return Future response. */ default Future<@Nullable Response> blmpop(List args) { @@ -557,7 +557,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command blpop. + * Redis command BLPOP. * @return Future response. */ default Future<@Nullable Response> blpop(List args) { @@ -565,7 +565,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command brpop. + * Redis command BRPOP. * @return Future response. */ default Future<@Nullable Response> brpop(List args) { @@ -573,7 +573,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command brpoplpush. + * Redis command BRPOPLPUSH. * @return Future response. */ default Future<@Nullable Response> brpoplpush(String arg0, String arg1, String arg2) { @@ -581,7 +581,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command bzmpop. + * Redis command BZMPOP. * @return Future response. */ default Future<@Nullable Response> bzmpop(List args) { @@ -589,7 +589,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command bzpopmax. + * Redis command BZPOPMAX. * @return Future response. */ default Future<@Nullable Response> bzpopmax(List args) { @@ -597,7 +597,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command bzpopmin. + * Redis command BZPOPMIN. * @return Future response. */ default Future<@Nullable Response> bzpopmin(List args) { @@ -605,7 +605,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command cfAdd. + * Redis command CF.ADD. * @return Future response. */ default Future<@Nullable Response> cfAdd(List args) { @@ -613,7 +613,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command cfAddnx. + * Redis command CF.ADDNX. * @return Future response. */ default Future<@Nullable Response> cfAddnx(List args) { @@ -621,7 +621,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command cfCompact. + * Redis command CF.COMPACT. * @return Future response. */ default Future<@Nullable Response> cfCompact(List args) { @@ -629,7 +629,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command cfCount. + * Redis command CF.COUNT. * @return Future response. */ default Future<@Nullable Response> cfCount(List args) { @@ -637,7 +637,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command cfDebug. + * Redis command CF.DEBUG. * @return Future response. */ default Future<@Nullable Response> cfDebug(List args) { @@ -645,7 +645,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command cfDel. + * Redis command CF.DEL. * @return Future response. */ default Future<@Nullable Response> cfDel(List args) { @@ -653,7 +653,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command cfExists. + * Redis command CF.EXISTS. * @return Future response. */ default Future<@Nullable Response> cfExists(List args) { @@ -661,7 +661,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command cfInfo. + * Redis command CF.INFO. * @return Future response. */ default Future<@Nullable Response> cfInfo(List args) { @@ -669,7 +669,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command cfInsert. + * Redis command CF.INSERT. * @return Future response. */ default Future<@Nullable Response> cfInsert(List args) { @@ -677,7 +677,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command cfInsertnx. + * Redis command CF.INSERTNX. * @return Future response. */ default Future<@Nullable Response> cfInsertnx(List args) { @@ -685,7 +685,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command cfLoadchunk. + * Redis command CF.LOADCHUNK. * @return Future response. */ default Future<@Nullable Response> cfLoadchunk(List args) { @@ -693,7 +693,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command cfMexists. + * Redis command CF.MEXISTS. * @return Future response. */ default Future<@Nullable Response> cfMexists(List args) { @@ -701,7 +701,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command cfReserve. + * Redis command CF.RESERVE. * @return Future response. */ default Future<@Nullable Response> cfReserve(List args) { @@ -709,7 +709,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command cfScandump. + * Redis command CF.SCANDUMP. * @return Future response. */ default Future<@Nullable Response> cfScandump(List args) { @@ -717,7 +717,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command client. + * Redis command CLIENT. * @return Future response. */ default Future<@Nullable Response> client(List args) { @@ -725,7 +725,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command cluster. + * Redis command CLUSTER. * @return Future response. */ default Future<@Nullable Response> cluster(List args) { @@ -733,7 +733,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command cmsIncrby. + * Redis command CMS.INCRBY. * @return Future response. */ default Future<@Nullable Response> cmsIncrby(List args) { @@ -741,7 +741,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command cmsInfo. + * Redis command CMS.INFO. * @return Future response. */ default Future<@Nullable Response> cmsInfo(List args) { @@ -749,7 +749,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command cmsInitbydim. + * Redis command CMS.INITBYDIM. * @return Future response. */ default Future<@Nullable Response> cmsInitbydim(List args) { @@ -757,7 +757,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command cmsInitbyprob. + * Redis command CMS.INITBYPROB. * @return Future response. */ default Future<@Nullable Response> cmsInitbyprob(List args) { @@ -765,7 +765,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command cmsMerge. + * Redis command CMS.MERGE. * @return Future response. */ default Future<@Nullable Response> cmsMerge(List args) { @@ -773,7 +773,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command cmsQuery. + * Redis command CMS.QUERY. * @return Future response. */ default Future<@Nullable Response> cmsQuery(List args) { @@ -781,7 +781,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command command. + * Redis command COMMAND. * @return Future response. */ default Future<@Nullable Response> command(List args) { @@ -789,7 +789,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command config. + * Redis command CONFIG. * @return Future response. */ default Future<@Nullable Response> config(List args) { @@ -797,7 +797,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command copy. + * Redis command COPY. * @return Future response. */ default Future<@Nullable Response> copy(List args) { @@ -805,7 +805,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command dbsize. + * Redis command DBSIZE. * @return Future response. */ default Future<@Nullable Response> dbsize() { @@ -813,7 +813,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command debug. + * Redis command DEBUG. * @return Future response. */ default Future<@Nullable Response> debug(List args) { @@ -821,7 +821,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command decr. + * Redis command DECR. * @return Future response. */ default Future<@Nullable Response> decr(String arg0) { @@ -829,7 +829,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command decrby. + * Redis command DECRBY. * @return Future response. */ default Future<@Nullable Response> decrby(String arg0, String arg1) { @@ -837,7 +837,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command del. + * Redis command DEL. * @return Future response. */ default Future<@Nullable Response> del(List args) { @@ -845,7 +845,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command discard. + * Redis command DISCARD. * @return Future response. */ default Future<@Nullable Response> discard() { @@ -853,7 +853,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command dump. + * Redis command DUMP. * @return Future response. */ default Future<@Nullable Response> dump(String arg0) { @@ -861,7 +861,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command echo. + * Redis command ECHO. * @return Future response. */ default Future<@Nullable Response> echo(String arg0) { @@ -869,7 +869,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command eval. + * Redis command EVAL. * @return Future response. */ default Future<@Nullable Response> eval(List args) { @@ -877,7 +877,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command evalRo. + * Redis command EVAL_RO. * @return Future response. */ default Future<@Nullable Response> evalRo(List args) { @@ -885,7 +885,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command evalsha. + * Redis command EVALSHA. * @return Future response. */ default Future<@Nullable Response> evalsha(List args) { @@ -893,7 +893,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command evalshaRo. + * Redis command EVALSHA_RO. * @return Future response. */ default Future<@Nullable Response> evalshaRo(List args) { @@ -901,7 +901,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command exec. + * Redis command EXEC. * @return Future response. */ default Future<@Nullable Response> exec() { @@ -909,7 +909,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command exists. + * Redis command EXISTS. * @return Future response. */ default Future<@Nullable Response> exists(List args) { @@ -917,7 +917,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command expire. + * Redis command EXPIRE. * @return Future response. */ default Future<@Nullable Response> expire(List args) { @@ -925,7 +925,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command expireat. + * Redis command EXPIREAT. * @return Future response. */ default Future<@Nullable Response> expireat(List args) { @@ -933,7 +933,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command expiretime. + * Redis command EXPIRETIME. * @return Future response. */ default Future<@Nullable Response> expiretime(String arg0) { @@ -941,7 +941,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command failover. + * Redis command FAILOVER. * @return Future response. */ default Future<@Nullable Response> failover(List args) { @@ -949,7 +949,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command fcall. + * Redis command FCALL. * @return Future response. */ default Future<@Nullable Response> fcall(List args) { @@ -957,7 +957,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command fcallRo. + * Redis command FCALL_RO. * @return Future response. */ default Future<@Nullable Response> fcallRo(List args) { @@ -965,7 +965,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command flushall. + * Redis command FLUSHALL. * @return Future response. */ default Future<@Nullable Response> flushall(List args) { @@ -973,7 +973,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command flushdb. + * Redis command FLUSHDB. * @return Future response. */ default Future<@Nullable Response> flushdb(List args) { @@ -981,7 +981,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command function. + * Redis command FUNCTION. * @return Future response. */ default Future<@Nullable Response> function(List args) { @@ -989,7 +989,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command geoadd. + * Redis command GEOADD. * @return Future response. */ default Future<@Nullable Response> geoadd(List args) { @@ -997,7 +997,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command geodist. + * Redis command GEODIST. * @return Future response. */ default Future<@Nullable Response> geodist(List args) { @@ -1005,7 +1005,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command geohash. + * Redis command GEOHASH. * @return Future response. */ default Future<@Nullable Response> geohash(List args) { @@ -1013,7 +1013,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command geopos. + * Redis command GEOPOS. * @return Future response. */ default Future<@Nullable Response> geopos(List args) { @@ -1021,7 +1021,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command georadius. + * Redis command GEORADIUS. * @return Future response. */ default Future<@Nullable Response> georadius(List args) { @@ -1029,7 +1029,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command georadiusRo. + * Redis command GEORADIUS_RO. * @return Future response. */ default Future<@Nullable Response> georadiusRo(List args) { @@ -1037,7 +1037,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command georadiusbymember. + * Redis command GEORADIUSBYMEMBER. * @return Future response. */ default Future<@Nullable Response> georadiusbymember(List args) { @@ -1045,7 +1045,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command georadiusbymemberRo. + * Redis command GEORADIUSBYMEMBER_RO. * @return Future response. */ default Future<@Nullable Response> georadiusbymemberRo(List args) { @@ -1053,7 +1053,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command geosearch. + * Redis command GEOSEARCH. * @return Future response. */ default Future<@Nullable Response> geosearch(List args) { @@ -1061,7 +1061,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command geosearchstore. + * Redis command GEOSEARCHSTORE. * @return Future response. */ default Future<@Nullable Response> geosearchstore(List args) { @@ -1069,7 +1069,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command get. + * Redis command GET. * @return Future response. */ default Future<@Nullable Response> get(String arg0) { @@ -1077,7 +1077,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command getbit. + * Redis command GETBIT. * @return Future response. */ default Future<@Nullable Response> getbit(String arg0, String arg1) { @@ -1085,7 +1085,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command getdel. + * Redis command GETDEL. * @return Future response. */ default Future<@Nullable Response> getdel(String arg0) { @@ -1093,7 +1093,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command getex. + * Redis command GETEX. * @return Future response. */ default Future<@Nullable Response> getex(List args) { @@ -1101,7 +1101,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command getrange. + * Redis command GETRANGE. * @return Future response. */ default Future<@Nullable Response> getrange(String arg0, String arg1, String arg2) { @@ -1109,7 +1109,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command getset. + * Redis command GETSET. * @return Future response. */ default Future<@Nullable Response> getset(String arg0, String arg1) { @@ -1117,7 +1117,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command graphBulk. + * Redis command GRAPH.BULK. * @return Future response. */ default Future<@Nullable Response> graphBulk(List args) { @@ -1125,7 +1125,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command graphConfig. + * Redis command GRAPH.CONFIG. * @return Future response. */ default Future<@Nullable Response> graphConfig(List args) { @@ -1133,7 +1133,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command graphDebug. + * Redis command GRAPH.DEBUG. * @return Future response. */ default Future<@Nullable Response> graphDebug(List args) { @@ -1141,7 +1141,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command graphDelete. + * Redis command GRAPH.DELETE. * @return Future response. */ default Future<@Nullable Response> graphDelete(List args) { @@ -1149,7 +1149,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command graphExplain. + * Redis command GRAPH.EXPLAIN. * @return Future response. */ default Future<@Nullable Response> graphExplain(List args) { @@ -1157,7 +1157,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command graphList. + * Redis command GRAPH.LIST. * @return Future response. */ default Future<@Nullable Response> graphList(List args) { @@ -1165,7 +1165,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command graphProfile. + * Redis command GRAPH.PROFILE. * @return Future response. */ default Future<@Nullable Response> graphProfile(List args) { @@ -1173,7 +1173,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command graphQuery. + * Redis command GRAPH.QUERY. * @return Future response. */ default Future<@Nullable Response> graphQuery(List args) { @@ -1181,7 +1181,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command graphRoQuery. + * Redis command GRAPH.RO_QUERY. * @return Future response. */ default Future<@Nullable Response> graphRoQuery(List args) { @@ -1189,7 +1189,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command graphSlowlog. + * Redis command GRAPH.SLOWLOG. * @return Future response. */ default Future<@Nullable Response> graphSlowlog(List args) { @@ -1197,7 +1197,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command hdel. + * Redis command HDEL. * @return Future response. */ default Future<@Nullable Response> hdel(List args) { @@ -1205,7 +1205,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command hello. + * Redis command HELLO. * @return Future response. */ default Future<@Nullable Response> hello(List args) { @@ -1213,7 +1213,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command hexists. + * Redis command HEXISTS. * @return Future response. */ default Future<@Nullable Response> hexists(String arg0, String arg1) { @@ -1221,7 +1221,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command hget. + * Redis command HGET. * @return Future response. */ default Future<@Nullable Response> hget(String arg0, String arg1) { @@ -1229,7 +1229,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command hgetall. + * Redis command HGETALL. * @return Future response. */ default Future<@Nullable Response> hgetall(String arg0) { @@ -1237,7 +1237,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command hincrby. + * Redis command HINCRBY. * @return Future response. */ default Future<@Nullable Response> hincrby(String arg0, String arg1, String arg2) { @@ -1245,7 +1245,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command hincrbyfloat. + * Redis command HINCRBYFLOAT. * @return Future response. */ default Future<@Nullable Response> hincrbyfloat(String arg0, String arg1, String arg2) { @@ -1253,7 +1253,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command hkeys. + * Redis command HKEYS. * @return Future response. */ default Future<@Nullable Response> hkeys(String arg0) { @@ -1261,7 +1261,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command hlen. + * Redis command HLEN. * @return Future response. */ default Future<@Nullable Response> hlen(String arg0) { @@ -1269,7 +1269,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command hmget. + * Redis command HMGET. * @return Future response. */ default Future<@Nullable Response> hmget(List args) { @@ -1277,7 +1277,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command hmset. + * Redis command HMSET. * @return Future response. */ default Future<@Nullable Response> hmset(List args) { @@ -1285,7 +1285,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command hrandfield. + * Redis command HRANDFIELD. * @return Future response. */ default Future<@Nullable Response> hrandfield(List args) { @@ -1293,7 +1293,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command hscan. + * Redis command HSCAN. * @return Future response. */ default Future<@Nullable Response> hscan(List args) { @@ -1301,7 +1301,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command hset. + * Redis command HSET. * @return Future response. */ default Future<@Nullable Response> hset(List args) { @@ -1309,7 +1309,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command hsetnx. + * Redis command HSETNX. * @return Future response. */ default Future<@Nullable Response> hsetnx(String arg0, String arg1, String arg2) { @@ -1317,7 +1317,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command hstrlen. + * Redis command HSTRLEN. * @return Future response. */ default Future<@Nullable Response> hstrlen(String arg0, String arg1) { @@ -1325,7 +1325,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command hvals. + * Redis command HVALS. * @return Future response. */ default Future<@Nullable Response> hvals(String arg0) { @@ -1333,7 +1333,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command incr. + * Redis command INCR. * @return Future response. */ default Future<@Nullable Response> incr(String arg0) { @@ -1341,7 +1341,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command incrby. + * Redis command INCRBY. * @return Future response. */ default Future<@Nullable Response> incrby(String arg0, String arg1) { @@ -1349,7 +1349,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command incrbyfloat. + * Redis command INCRBYFLOAT. * @return Future response. */ default Future<@Nullable Response> incrbyfloat(String arg0, String arg1) { @@ -1357,7 +1357,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command info. + * Redis command INFO. * @return Future response. */ default Future<@Nullable Response> info(List args) { @@ -1365,7 +1365,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command jsonArrappend. + * Redis command JSON.ARRAPPEND. * @return Future response. */ default Future<@Nullable Response> jsonArrappend(List args) { @@ -1373,7 +1373,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command jsonArrindex. + * Redis command JSON.ARRINDEX. * @return Future response. */ default Future<@Nullable Response> jsonArrindex(List args) { @@ -1381,7 +1381,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command jsonArrinsert. + * Redis command JSON.ARRINSERT. * @return Future response. */ default Future<@Nullable Response> jsonArrinsert(List args) { @@ -1389,7 +1389,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command jsonArrlen. + * Redis command JSON.ARRLEN. * @return Future response. */ default Future<@Nullable Response> jsonArrlen(List args) { @@ -1397,7 +1397,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command jsonArrpop. + * Redis command JSON.ARRPOP. * @return Future response. */ default Future<@Nullable Response> jsonArrpop(List args) { @@ -1405,7 +1405,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command jsonArrtrim. + * Redis command JSON.ARRTRIM. * @return Future response. */ default Future<@Nullable Response> jsonArrtrim(List args) { @@ -1413,7 +1413,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command jsonClear. + * Redis command JSON.CLEAR. * @return Future response. */ default Future<@Nullable Response> jsonClear(List args) { @@ -1421,7 +1421,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command jsonDebug. + * Redis command JSON.DEBUG. * @return Future response. */ default Future<@Nullable Response> jsonDebug(List args) { @@ -1429,7 +1429,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command jsonDel. + * Redis command JSON.DEL. * @return Future response. */ default Future<@Nullable Response> jsonDel(List args) { @@ -1437,7 +1437,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command jsonForget. + * Redis command JSON.FORGET. * @return Future response. */ default Future<@Nullable Response> jsonForget(List args) { @@ -1445,7 +1445,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command jsonGet. + * Redis command JSON.GET. * @return Future response. */ default Future<@Nullable Response> jsonGet(List args) { @@ -1453,7 +1453,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command jsonMget. + * Redis command JSON.MGET. * @return Future response. */ default Future<@Nullable Response> jsonMget(List args) { @@ -1461,7 +1461,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command jsonNumincrby. + * Redis command JSON.NUMINCRBY. * @return Future response. */ default Future<@Nullable Response> jsonNumincrby(List args) { @@ -1469,7 +1469,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command jsonNummultby. + * Redis command JSON.NUMMULTBY. * @return Future response. */ default Future<@Nullable Response> jsonNummultby(List args) { @@ -1477,7 +1477,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command jsonNumpowby. + * Redis command JSON.NUMPOWBY. * @return Future response. */ default Future<@Nullable Response> jsonNumpowby(List args) { @@ -1485,7 +1485,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command jsonObjkeys. + * Redis command JSON.OBJKEYS. * @return Future response. */ default Future<@Nullable Response> jsonObjkeys(List args) { @@ -1493,7 +1493,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command jsonObjlen. + * Redis command JSON.OBJLEN. * @return Future response. */ default Future<@Nullable Response> jsonObjlen(List args) { @@ -1501,7 +1501,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command jsonResp. + * Redis command JSON.RESP. * @return Future response. */ default Future<@Nullable Response> jsonResp(List args) { @@ -1509,7 +1509,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command jsonSet. + * Redis command JSON.SET. * @return Future response. */ default Future<@Nullable Response> jsonSet(List args) { @@ -1517,7 +1517,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command jsonStrappend. + * Redis command JSON.STRAPPEND. * @return Future response. */ default Future<@Nullable Response> jsonStrappend(List args) { @@ -1525,7 +1525,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command jsonStrlen. + * Redis command JSON.STRLEN. * @return Future response. */ default Future<@Nullable Response> jsonStrlen(List args) { @@ -1533,7 +1533,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command jsonToggle. + * Redis command JSON.TOGGLE. * @return Future response. */ default Future<@Nullable Response> jsonToggle(List args) { @@ -1541,7 +1541,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command jsonType. + * Redis command JSON.TYPE. * @return Future response. */ default Future<@Nullable Response> jsonType(List args) { @@ -1549,7 +1549,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command keys. + * Redis command KEYS. * @return Future response. */ default Future<@Nullable Response> keys(String arg0) { @@ -1557,7 +1557,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command lastsave. + * Redis command LASTSAVE. * @return Future response. */ default Future<@Nullable Response> lastsave() { @@ -1565,7 +1565,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command latency. + * Redis command LATENCY. * @return Future response. */ default Future<@Nullable Response> latency(List args) { @@ -1573,7 +1573,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command lcs. + * Redis command LCS. * @return Future response. */ default Future<@Nullable Response> lcs(List args) { @@ -1581,7 +1581,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command lindex. + * Redis command LINDEX. * @return Future response. */ default Future<@Nullable Response> lindex(String arg0, String arg1) { @@ -1589,7 +1589,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command linsert. + * Redis command LINSERT. * @return Future response. */ default Future<@Nullable Response> linsert(String arg0, String arg1, String arg2, String arg3) { @@ -1597,7 +1597,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command llen. + * Redis command LLEN. * @return Future response. */ default Future<@Nullable Response> llen(String arg0) { @@ -1605,7 +1605,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command lmove. + * Redis command LMOVE. * @return Future response. */ default Future<@Nullable Response> lmove(String arg0, String arg1, String arg2, String arg3) { @@ -1613,7 +1613,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command lmpop. + * Redis command LMPOP. * @return Future response. */ default Future<@Nullable Response> lmpop(List args) { @@ -1621,7 +1621,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command lolwut. + * Redis command LOLWUT. * @return Future response. */ default Future<@Nullable Response> lolwut(List args) { @@ -1629,7 +1629,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command lpop. + * Redis command LPOP. * @return Future response. */ default Future<@Nullable Response> lpop(List args) { @@ -1637,7 +1637,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command lpos. + * Redis command LPOS. * @return Future response. */ default Future<@Nullable Response> lpos(List args) { @@ -1645,7 +1645,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command lpush. + * Redis command LPUSH. * @return Future response. */ default Future<@Nullable Response> lpush(List args) { @@ -1653,7 +1653,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command lpushx. + * Redis command LPUSHX. * @return Future response. */ default Future<@Nullable Response> lpushx(List args) { @@ -1661,7 +1661,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command lrange. + * Redis command LRANGE. * @return Future response. */ default Future<@Nullable Response> lrange(String arg0, String arg1, String arg2) { @@ -1669,7 +1669,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command lrem. + * Redis command LREM. * @return Future response. */ default Future<@Nullable Response> lrem(String arg0, String arg1, String arg2) { @@ -1677,7 +1677,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command lset. + * Redis command LSET. * @return Future response. */ default Future<@Nullable Response> lset(String arg0, String arg1, String arg2) { @@ -1685,7 +1685,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command ltrim. + * Redis command LTRIM. * @return Future response. */ default Future<@Nullable Response> ltrim(String arg0, String arg1, String arg2) { @@ -1693,7 +1693,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command memory. + * Redis command MEMORY. * @return Future response. */ default Future<@Nullable Response> memory(List args) { @@ -1701,7 +1701,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command mget. + * Redis command MGET. * @return Future response. */ default Future<@Nullable Response> mget(List args) { @@ -1709,7 +1709,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command migrate. + * Redis command MIGRATE. * @return Future response. */ default Future<@Nullable Response> migrate(List args) { @@ -1717,7 +1717,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command module. + * Redis command MODULE. * @return Future response. */ default Future<@Nullable Response> module(List args) { @@ -1725,7 +1725,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command monitor. + * Redis command MONITOR. * @return Future response. */ default Future<@Nullable Response> monitor() { @@ -1733,7 +1733,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command move. + * Redis command MOVE. * @return Future response. */ default Future<@Nullable Response> move(String arg0, String arg1) { @@ -1741,7 +1741,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command mset. + * Redis command MSET. * @return Future response. */ default Future<@Nullable Response> mset(List args) { @@ -1749,7 +1749,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command msetnx. + * Redis command MSETNX. * @return Future response. */ default Future<@Nullable Response> msetnx(List args) { @@ -1757,7 +1757,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command multi. + * Redis command MULTI. * @return Future response. */ default Future<@Nullable Response> multi() { @@ -1765,7 +1765,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command object. + * Redis command OBJECT. * @return Future response. */ default Future<@Nullable Response> object(List args) { @@ -1773,7 +1773,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command persist. + * Redis command PERSIST. * @return Future response. */ default Future<@Nullable Response> persist(String arg0) { @@ -1781,7 +1781,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command pexpire. + * Redis command PEXPIRE. * @return Future response. */ default Future<@Nullable Response> pexpire(List args) { @@ -1789,7 +1789,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command pexpireat. + * Redis command PEXPIREAT. * @return Future response. */ default Future<@Nullable Response> pexpireat(List args) { @@ -1797,7 +1797,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command pexpiretime. + * Redis command PEXPIRETIME. * @return Future response. */ default Future<@Nullable Response> pexpiretime(String arg0) { @@ -1805,7 +1805,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command pfadd. + * Redis command PFADD. * @return Future response. */ default Future<@Nullable Response> pfadd(List args) { @@ -1813,7 +1813,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command pfcount. + * Redis command PFCOUNT. * @return Future response. */ default Future<@Nullable Response> pfcount(List args) { @@ -1821,7 +1821,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command pfdebug. + * Redis command PFDEBUG. * @return Future response. */ default Future<@Nullable Response> pfdebug(String arg0, String arg1) { @@ -1829,7 +1829,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command pfmerge. + * Redis command PFMERGE. * @return Future response. */ default Future<@Nullable Response> pfmerge(List args) { @@ -1837,7 +1837,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command pfselftest. + * Redis command PFSELFTEST. * @return Future response. */ default Future<@Nullable Response> pfselftest() { @@ -1845,7 +1845,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command ping. + * Redis command PING. * @return Future response. */ default Future<@Nullable Response> ping(List args) { @@ -1853,7 +1853,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command psetex. + * Redis command PSETEX. * @return Future response. */ default Future<@Nullable Response> psetex(String arg0, String arg1, String arg2) { @@ -1861,7 +1861,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command psubscribe. + * Redis command PSUBSCRIBE. * @return Future response. */ default Future<@Nullable Response> psubscribe(List args) { @@ -1869,7 +1869,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command psync. + * Redis command PSYNC. * @return Future response. */ default Future<@Nullable Response> psync(List args) { @@ -1877,7 +1877,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command pttl. + * Redis command PTTL. * @return Future response. */ default Future<@Nullable Response> pttl(String arg0) { @@ -1885,7 +1885,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command publish. + * Redis command PUBLISH. * @return Future response. */ default Future<@Nullable Response> publish(String arg0, String arg1) { @@ -1893,7 +1893,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command pubsub. + * Redis command PUBSUB. * @return Future response. */ default Future<@Nullable Response> pubsub(List args) { @@ -1901,7 +1901,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command punsubscribe. + * Redis command PUNSUBSCRIBE. * @return Future response. */ default Future<@Nullable Response> punsubscribe(List args) { @@ -1909,7 +1909,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command quit. + * Redis command QUIT. * @return Future response. */ default Future<@Nullable Response> quit(List args) { @@ -1917,7 +1917,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command randomkey. + * Redis command RANDOMKEY. * @return Future response. */ default Future<@Nullable Response> randomkey() { @@ -1925,7 +1925,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command readonly. + * Redis command READONLY. * @return Future response. */ default Future<@Nullable Response> readonly() { @@ -1933,7 +1933,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command readwrite. + * Redis command READWRITE. * @return Future response. */ default Future<@Nullable Response> readwrite() { @@ -1941,7 +1941,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command rename. + * Redis command RENAME. * @return Future response. */ default Future<@Nullable Response> rename(String arg0, String arg1) { @@ -1949,7 +1949,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command renamenx. + * Redis command RENAMENX. * @return Future response. */ default Future<@Nullable Response> renamenx(String arg0, String arg1) { @@ -1957,7 +1957,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command replconf. + * Redis command REPLCONF. * @return Future response. */ default Future<@Nullable Response> replconf(List args) { @@ -1965,7 +1965,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command replicaof. + * Redis command REPLICAOF. * @return Future response. */ default Future<@Nullable Response> replicaof(String arg0, String arg1) { @@ -1973,7 +1973,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command reset. + * Redis command RESET. * @return Future response. */ default Future<@Nullable Response> reset() { @@ -1981,7 +1981,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command restore. + * Redis command RESTORE. * @return Future response. */ default Future<@Nullable Response> restore(List args) { @@ -1989,7 +1989,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command restoreAsking. + * Redis command RESTORE-ASKING. * @return Future response. */ default Future<@Nullable Response> restoreAsking(List args) { @@ -1997,7 +1997,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command role. + * Redis command ROLE. * @return Future response. */ default Future<@Nullable Response> role() { @@ -2005,7 +2005,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command rpop. + * Redis command RPOP. * @return Future response. */ default Future<@Nullable Response> rpop(List args) { @@ -2013,7 +2013,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command rpoplpush. + * Redis command RPOPLPUSH. * @return Future response. */ default Future<@Nullable Response> rpoplpush(String arg0, String arg1) { @@ -2021,7 +2021,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command rpush. + * Redis command RPUSH. * @return Future response. */ default Future<@Nullable Response> rpush(List args) { @@ -2029,7 +2029,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command rpushx. + * Redis command RPUSHX. * @return Future response. */ default Future<@Nullable Response> rpushx(List args) { @@ -2037,7 +2037,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command sadd. + * Redis command SADD. * @return Future response. */ default Future<@Nullable Response> sadd(List args) { @@ -2045,7 +2045,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command save. + * Redis command SAVE. * @return Future response. */ default Future<@Nullable Response> save() { @@ -2053,7 +2053,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command scan. + * Redis command SCAN. * @return Future response. */ default Future<@Nullable Response> scan(List args) { @@ -2061,7 +2061,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command scard. + * Redis command SCARD. * @return Future response. */ default Future<@Nullable Response> scard(String arg0) { @@ -2069,7 +2069,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command script. + * Redis command SCRIPT. * @return Future response. */ default Future<@Nullable Response> script(List args) { @@ -2077,7 +2077,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command sdiff. + * Redis command SDIFF. * @return Future response. */ default Future<@Nullable Response> sdiff(List args) { @@ -2085,7 +2085,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command sdiffstore. + * Redis command SDIFFSTORE. * @return Future response. */ default Future<@Nullable Response> sdiffstore(List args) { @@ -2093,7 +2093,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command select. + * Redis command SELECT. * @return Future response. */ default Future<@Nullable Response> select(String arg0) { @@ -2101,7 +2101,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command set. + * Redis command SET. * @return Future response. */ default Future<@Nullable Response> set(List args) { @@ -2109,7 +2109,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command setbit. + * Redis command SETBIT. * @return Future response. */ default Future<@Nullable Response> setbit(String arg0, String arg1, String arg2) { @@ -2117,7 +2117,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command setex. + * Redis command SETEX. * @return Future response. */ default Future<@Nullable Response> setex(String arg0, String arg1, String arg2) { @@ -2125,7 +2125,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command setnx. + * Redis command SETNX. * @return Future response. */ default Future<@Nullable Response> setnx(String arg0, String arg1) { @@ -2133,7 +2133,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command setrange. + * Redis command SETRANGE. * @return Future response. */ default Future<@Nullable Response> setrange(String arg0, String arg1, String arg2) { @@ -2141,7 +2141,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command shutdown. + * Redis command SHUTDOWN. * @return Future response. */ default Future<@Nullable Response> shutdown(List args) { @@ -2149,7 +2149,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command sinter. + * Redis command SINTER. * @return Future response. */ default Future<@Nullable Response> sinter(List args) { @@ -2157,7 +2157,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command sintercard. + * Redis command SINTERCARD. * @return Future response. */ default Future<@Nullable Response> sintercard(List args) { @@ -2165,7 +2165,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command sinterstore. + * Redis command SINTERSTORE. * @return Future response. */ default Future<@Nullable Response> sinterstore(List args) { @@ -2173,7 +2173,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command sismember. + * Redis command SISMEMBER. * @return Future response. */ default Future<@Nullable Response> sismember(String arg0, String arg1) { @@ -2181,7 +2181,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command slaveof. + * Redis command SLAVEOF. * @return Future response. */ default Future<@Nullable Response> slaveof(String arg0, String arg1) { @@ -2189,7 +2189,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command slowlog. + * Redis command SLOWLOG. * @return Future response. */ default Future<@Nullable Response> slowlog(List args) { @@ -2197,7 +2197,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command smembers. + * Redis command SMEMBERS. * @return Future response. */ default Future<@Nullable Response> smembers(String arg0) { @@ -2205,7 +2205,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command smismember. + * Redis command SMISMEMBER. * @return Future response. */ default Future<@Nullable Response> smismember(List args) { @@ -2213,7 +2213,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command smove. + * Redis command SMOVE. * @return Future response. */ default Future<@Nullable Response> smove(String arg0, String arg1, String arg2) { @@ -2221,7 +2221,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command sort. + * Redis command SORT. * @return Future response. */ default Future<@Nullable Response> sort(List args) { @@ -2229,7 +2229,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command sortRo. + * Redis command SORT_RO. * @return Future response. */ default Future<@Nullable Response> sortRo(List args) { @@ -2237,7 +2237,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command spop. + * Redis command SPOP. * @return Future response. */ default Future<@Nullable Response> spop(List args) { @@ -2245,7 +2245,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command spublish. + * Redis command SPUBLISH. * @return Future response. */ default Future<@Nullable Response> spublish(String arg0, String arg1) { @@ -2253,7 +2253,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command srandmember. + * Redis command SRANDMEMBER. * @return Future response. */ default Future<@Nullable Response> srandmember(List args) { @@ -2261,7 +2261,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command srem. + * Redis command SREM. * @return Future response. */ default Future<@Nullable Response> srem(List args) { @@ -2269,7 +2269,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command sscan. + * Redis command SSCAN. * @return Future response. */ default Future<@Nullable Response> sscan(List args) { @@ -2277,7 +2277,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command ssubscribe. + * Redis command SSUBSCRIBE. * @return Future response. */ default Future<@Nullable Response> ssubscribe(List args) { @@ -2285,7 +2285,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command strlen. + * Redis command STRLEN. * @return Future response. */ default Future<@Nullable Response> strlen(String arg0) { @@ -2293,7 +2293,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command subscribe. + * Redis command SUBSCRIBE. * @return Future response. */ default Future<@Nullable Response> subscribe(List args) { @@ -2301,7 +2301,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command substr. + * Redis command SUBSTR. * @return Future response. */ default Future<@Nullable Response> substr(String arg0, String arg1, String arg2) { @@ -2309,7 +2309,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command sunion. + * Redis command SUNION. * @return Future response. */ default Future<@Nullable Response> sunion(List args) { @@ -2317,7 +2317,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command sunionstore. + * Redis command SUNIONSTORE. * @return Future response. */ default Future<@Nullable Response> sunionstore(List args) { @@ -2325,7 +2325,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command sunsubscribe. + * Redis command SUNSUBSCRIBE. * @return Future response. */ default Future<@Nullable Response> sunsubscribe(List args) { @@ -2333,7 +2333,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command swapdb. + * Redis command SWAPDB. * @return Future response. */ default Future<@Nullable Response> swapdb(String arg0, String arg1) { @@ -2341,7 +2341,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command sync. + * Redis command SYNC. * @return Future response. */ default Future<@Nullable Response> sync() { @@ -2349,7 +2349,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command tdigestAdd. + * Redis command TDIGEST.ADD. * @return Future response. */ default Future<@Nullable Response> tdigestAdd(List args) { @@ -2357,7 +2357,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command tdigestByrank. + * Redis command TDIGEST.BYRANK. * @return Future response. */ default Future<@Nullable Response> tdigestByrank(List args) { @@ -2365,7 +2365,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command tdigestByrevrank. + * Redis command TDIGEST.BYREVRANK. * @return Future response. */ default Future<@Nullable Response> tdigestByrevrank(List args) { @@ -2373,7 +2373,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command tdigestCdf. + * Redis command TDIGEST.CDF. * @return Future response. */ default Future<@Nullable Response> tdigestCdf(List args) { @@ -2381,7 +2381,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command tdigestCreate. + * Redis command TDIGEST.CREATE. * @return Future response. */ default Future<@Nullable Response> tdigestCreate(List args) { @@ -2389,7 +2389,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command tdigestInfo. + * Redis command TDIGEST.INFO. * @return Future response. */ default Future<@Nullable Response> tdigestInfo(List args) { @@ -2397,7 +2397,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command tdigestMax. + * Redis command TDIGEST.MAX. * @return Future response. */ default Future<@Nullable Response> tdigestMax(List args) { @@ -2405,7 +2405,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command tdigestMerge. + * Redis command TDIGEST.MERGE. * @return Future response. */ default Future<@Nullable Response> tdigestMerge(List args) { @@ -2413,7 +2413,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command tdigestMin. + * Redis command TDIGEST.MIN. * @return Future response. */ default Future<@Nullable Response> tdigestMin(List args) { @@ -2421,7 +2421,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command tdigestQuantile. + * Redis command TDIGEST.QUANTILE. * @return Future response. */ default Future<@Nullable Response> tdigestQuantile(List args) { @@ -2429,7 +2429,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command tdigestRank. + * Redis command TDIGEST.RANK. * @return Future response. */ default Future<@Nullable Response> tdigestRank(List args) { @@ -2437,7 +2437,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command tdigestReset. + * Redis command TDIGEST.RESET. * @return Future response. */ default Future<@Nullable Response> tdigestReset(List args) { @@ -2445,7 +2445,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command tdigestRevrank. + * Redis command TDIGEST.REVRANK. * @return Future response. */ default Future<@Nullable Response> tdigestRevrank(List args) { @@ -2453,7 +2453,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command tdigestTrimmedMean. + * Redis command TDIGEST.TRIMMED_MEAN. * @return Future response. */ default Future<@Nullable Response> tdigestTrimmedMean(List args) { @@ -2461,7 +2461,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command time. + * Redis command TIME. * @return Future response. */ default Future<@Nullable Response> time() { @@ -2469,7 +2469,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command timeseriesClusterset. + * Redis command TIMESERIES.CLUSTERSET. * @return Future response. */ default Future<@Nullable Response> timeseriesClusterset(List args) { @@ -2477,7 +2477,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command timeseriesClustersetfromshard. + * Redis command TIMESERIES.CLUSTERSETFROMSHARD. * @return Future response. */ default Future<@Nullable Response> timeseriesClustersetfromshard(List args) { @@ -2485,7 +2485,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command timeseriesHello. + * Redis command TIMESERIES.HELLO. * @return Future response. */ default Future<@Nullable Response> timeseriesHello(List args) { @@ -2493,7 +2493,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command timeseriesInfocluster. + * Redis command TIMESERIES.INFOCLUSTER. * @return Future response. */ default Future<@Nullable Response> timeseriesInfocluster(List args) { @@ -2501,7 +2501,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command timeseriesInnercommunication. + * Redis command TIMESERIES.INNERCOMMUNICATION. * @return Future response. */ default Future<@Nullable Response> timeseriesInnercommunication(List args) { @@ -2509,7 +2509,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command timeseriesNetworktest. + * Redis command TIMESERIES.NETWORKTEST. * @return Future response. */ default Future<@Nullable Response> timeseriesNetworktest(List args) { @@ -2517,7 +2517,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command timeseriesRefreshcluster. + * Redis command TIMESERIES.REFRESHCLUSTER. * @return Future response. */ default Future<@Nullable Response> timeseriesRefreshcluster(List args) { @@ -2525,7 +2525,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command topkAdd. + * Redis command TOPK.ADD. * @return Future response. */ default Future<@Nullable Response> topkAdd(List args) { @@ -2533,7 +2533,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command topkCount. + * Redis command TOPK.COUNT. * @return Future response. */ default Future<@Nullable Response> topkCount(List args) { @@ -2541,7 +2541,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command topkIncrby. + * Redis command TOPK.INCRBY. * @return Future response. */ default Future<@Nullable Response> topkIncrby(List args) { @@ -2549,7 +2549,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command topkInfo. + * Redis command TOPK.INFO. * @return Future response. */ default Future<@Nullable Response> topkInfo(List args) { @@ -2557,7 +2557,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command topkList. + * Redis command TOPK.LIST. * @return Future response. */ default Future<@Nullable Response> topkList(List args) { @@ -2565,7 +2565,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command topkQuery. + * Redis command TOPK.QUERY. * @return Future response. */ default Future<@Nullable Response> topkQuery(List args) { @@ -2573,7 +2573,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command topkReserve. + * Redis command TOPK.RESERVE. * @return Future response. */ default Future<@Nullable Response> topkReserve(List args) { @@ -2581,7 +2581,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command touch. + * Redis command TOUCH. * @return Future response. */ default Future<@Nullable Response> touch(List args) { @@ -2589,7 +2589,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command tsAdd. + * Redis command TS.ADD. * @return Future response. */ default Future<@Nullable Response> tsAdd(List args) { @@ -2597,7 +2597,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command tsAlter. + * Redis command TS.ALTER. * @return Future response. */ default Future<@Nullable Response> tsAlter(List args) { @@ -2605,7 +2605,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command tsCreate. + * Redis command TS.CREATE. * @return Future response. */ default Future<@Nullable Response> tsCreate(List args) { @@ -2613,7 +2613,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command tsCreaterule. + * Redis command TS.CREATERULE. * @return Future response. */ default Future<@Nullable Response> tsCreaterule(List args) { @@ -2621,7 +2621,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command tsDecrby. + * Redis command TS.DECRBY. * @return Future response. */ default Future<@Nullable Response> tsDecrby(List args) { @@ -2629,7 +2629,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command tsDel. + * Redis command TS.DEL. * @return Future response. */ default Future<@Nullable Response> tsDel(List args) { @@ -2637,7 +2637,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command tsDeleterule. + * Redis command TS.DELETERULE. * @return Future response. */ default Future<@Nullable Response> tsDeleterule(List args) { @@ -2645,7 +2645,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command tsGet. + * Redis command TS.GET. * @return Future response. */ default Future<@Nullable Response> tsGet(List args) { @@ -2653,7 +2653,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command tsIncrby. + * Redis command TS.INCRBY. * @return Future response. */ default Future<@Nullable Response> tsIncrby(List args) { @@ -2661,7 +2661,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command tsInfo. + * Redis command TS.INFO. * @return Future response. */ default Future<@Nullable Response> tsInfo(List args) { @@ -2669,7 +2669,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command tsMadd. + * Redis command TS.MADD. * @return Future response. */ default Future<@Nullable Response> tsMadd(List args) { @@ -2677,7 +2677,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command tsMget. + * Redis command TS.MGET. * @return Future response. */ default Future<@Nullable Response> tsMget(List args) { @@ -2685,7 +2685,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command tsMrange. + * Redis command TS.MRANGE. * @return Future response. */ default Future<@Nullable Response> tsMrange(List args) { @@ -2693,7 +2693,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command tsMrevrange. + * Redis command TS.MREVRANGE. * @return Future response. */ default Future<@Nullable Response> tsMrevrange(List args) { @@ -2701,7 +2701,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command tsQueryindex. + * Redis command TS.QUERYINDEX. * @return Future response. */ default Future<@Nullable Response> tsQueryindex(List args) { @@ -2709,7 +2709,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command tsRange. + * Redis command TS.RANGE. * @return Future response. */ default Future<@Nullable Response> tsRange(List args) { @@ -2717,7 +2717,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command tsRevrange. + * Redis command TS.REVRANGE. * @return Future response. */ default Future<@Nullable Response> tsRevrange(List args) { @@ -2725,7 +2725,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command ttl. + * Redis command TTL. * @return Future response. */ default Future<@Nullable Response> ttl(String arg0) { @@ -2733,7 +2733,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command type. + * Redis command TYPE. * @return Future response. */ default Future<@Nullable Response> type(String arg0) { @@ -2741,7 +2741,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command unlink. + * Redis command UNLINK. * @return Future response. */ default Future<@Nullable Response> unlink(List args) { @@ -2749,7 +2749,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command unsubscribe. + * Redis command UNSUBSCRIBE. * @return Future response. */ default Future<@Nullable Response> unsubscribe(List args) { @@ -2757,7 +2757,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command unwatch. + * Redis command UNWATCH. * @return Future response. */ default Future<@Nullable Response> unwatch() { @@ -2765,7 +2765,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command wait. + * Redis command WAIT. * @return Future response. */ default Future<@Nullable Response> wait(String arg0, String arg1) { @@ -2773,7 +2773,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command watch. + * Redis command WATCH. * @return Future response. */ default Future<@Nullable Response> watch(List args) { @@ -2781,7 +2781,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command xack. + * Redis command XACK. * @return Future response. */ default Future<@Nullable Response> xack(List args) { @@ -2789,7 +2789,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command xadd. + * Redis command XADD. * @return Future response. */ default Future<@Nullable Response> xadd(List args) { @@ -2797,7 +2797,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command xautoclaim. + * Redis command XAUTOCLAIM. * @return Future response. */ default Future<@Nullable Response> xautoclaim(List args) { @@ -2805,7 +2805,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command xclaim. + * Redis command XCLAIM. * @return Future response. */ default Future<@Nullable Response> xclaim(List args) { @@ -2813,7 +2813,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command xdel. + * Redis command XDEL. * @return Future response. */ default Future<@Nullable Response> xdel(List args) { @@ -2821,7 +2821,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command xgroup. + * Redis command XGROUP. * @return Future response. */ default Future<@Nullable Response> xgroup(List args) { @@ -2829,7 +2829,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command xinfo. + * Redis command XINFO. * @return Future response. */ default Future<@Nullable Response> xinfo(List args) { @@ -2837,7 +2837,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command xlen. + * Redis command XLEN. * @return Future response. */ default Future<@Nullable Response> xlen(String arg0) { @@ -2845,7 +2845,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command xpending. + * Redis command XPENDING. * @return Future response. */ default Future<@Nullable Response> xpending(List args) { @@ -2853,7 +2853,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command xrange. + * Redis command XRANGE. * @return Future response. */ default Future<@Nullable Response> xrange(List args) { @@ -2861,7 +2861,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command xread. + * Redis command XREAD. * @return Future response. */ default Future<@Nullable Response> xread(List args) { @@ -2869,7 +2869,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command xreadgroup. + * Redis command XREADGROUP. * @return Future response. */ default Future<@Nullable Response> xreadgroup(List args) { @@ -2877,7 +2877,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command xrevrange. + * Redis command XREVRANGE. * @return Future response. */ default Future<@Nullable Response> xrevrange(List args) { @@ -2885,7 +2885,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command xsetid. + * Redis command XSETID. * @return Future response. */ default Future<@Nullable Response> xsetid(List args) { @@ -2893,7 +2893,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command xtrim. + * Redis command XTRIM. * @return Future response. */ default Future<@Nullable Response> xtrim(List args) { @@ -2901,7 +2901,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command zadd. + * Redis command ZADD. * @return Future response. */ default Future<@Nullable Response> zadd(List args) { @@ -2909,7 +2909,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command zcard. + * Redis command ZCARD. * @return Future response. */ default Future<@Nullable Response> zcard(String arg0) { @@ -2917,7 +2917,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command zcount. + * Redis command ZCOUNT. * @return Future response. */ default Future<@Nullable Response> zcount(String arg0, String arg1, String arg2) { @@ -2925,7 +2925,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command zdiff. + * Redis command ZDIFF. * @return Future response. */ default Future<@Nullable Response> zdiff(List args) { @@ -2933,7 +2933,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command zdiffstore. + * Redis command ZDIFFSTORE. * @return Future response. */ default Future<@Nullable Response> zdiffstore(List args) { @@ -2941,7 +2941,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command zincrby. + * Redis command ZINCRBY. * @return Future response. */ default Future<@Nullable Response> zincrby(String arg0, String arg1, String arg2) { @@ -2949,7 +2949,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command zinter. + * Redis command ZINTER. * @return Future response. */ default Future<@Nullable Response> zinter(List args) { @@ -2957,7 +2957,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command zintercard. + * Redis command ZINTERCARD. * @return Future response. */ default Future<@Nullable Response> zintercard(List args) { @@ -2965,7 +2965,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command zinterstore. + * Redis command ZINTERSTORE. * @return Future response. */ default Future<@Nullable Response> zinterstore(List args) { @@ -2973,7 +2973,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command zlexcount. + * Redis command ZLEXCOUNT. * @return Future response. */ default Future<@Nullable Response> zlexcount(String arg0, String arg1, String arg2) { @@ -2981,7 +2981,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command zmpop. + * Redis command ZMPOP. * @return Future response. */ default Future<@Nullable Response> zmpop(List args) { @@ -2989,7 +2989,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command zmscore. + * Redis command ZMSCORE. * @return Future response. */ default Future<@Nullable Response> zmscore(List args) { @@ -2997,7 +2997,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command zpopmax. + * Redis command ZPOPMAX. * @return Future response. */ default Future<@Nullable Response> zpopmax(List args) { @@ -3005,7 +3005,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command zpopmin. + * Redis command ZPOPMIN. * @return Future response. */ default Future<@Nullable Response> zpopmin(List args) { @@ -3013,7 +3013,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command zrandmember. + * Redis command ZRANDMEMBER. * @return Future response. */ default Future<@Nullable Response> zrandmember(List args) { @@ -3021,7 +3021,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command zrange. + * Redis command ZRANGE. * @return Future response. */ default Future<@Nullable Response> zrange(List args) { @@ -3029,7 +3029,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command zrangebylex. + * Redis command ZRANGEBYLEX. * @return Future response. */ default Future<@Nullable Response> zrangebylex(List args) { @@ -3037,7 +3037,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command zrangebyscore. + * Redis command ZRANGEBYSCORE. * @return Future response. */ default Future<@Nullable Response> zrangebyscore(List args) { @@ -3045,7 +3045,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command zrangestore. + * Redis command ZRANGESTORE. * @return Future response. */ default Future<@Nullable Response> zrangestore(List args) { @@ -3053,7 +3053,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command zrank. + * Redis command ZRANK. * @return Future response. */ default Future<@Nullable Response> zrank(String arg0, String arg1) { @@ -3061,7 +3061,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command zrem. + * Redis command ZREM. * @return Future response. */ default Future<@Nullable Response> zrem(List args) { @@ -3069,7 +3069,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command zremrangebylex. + * Redis command ZREMRANGEBYLEX. * @return Future response. */ default Future<@Nullable Response> zremrangebylex(String arg0, String arg1, String arg2) { @@ -3077,7 +3077,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command zremrangebyrank. + * Redis command ZREMRANGEBYRANK. * @return Future response. */ default Future<@Nullable Response> zremrangebyrank(String arg0, String arg1, String arg2) { @@ -3085,7 +3085,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command zremrangebyscore. + * Redis command ZREMRANGEBYSCORE. * @return Future response. */ default Future<@Nullable Response> zremrangebyscore(String arg0, String arg1, String arg2) { @@ -3093,7 +3093,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command zrevrange. + * Redis command ZREVRANGE. * @return Future response. */ default Future<@Nullable Response> zrevrange(List args) { @@ -3101,7 +3101,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command zrevrangebylex. + * Redis command ZREVRANGEBYLEX. * @return Future response. */ default Future<@Nullable Response> zrevrangebylex(List args) { @@ -3109,7 +3109,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command zrevrangebyscore. + * Redis command ZREVRANGEBYSCORE. * @return Future response. */ default Future<@Nullable Response> zrevrangebyscore(List args) { @@ -3117,7 +3117,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command zrevrank. + * Redis command ZREVRANK. * @return Future response. */ default Future<@Nullable Response> zrevrank(String arg0, String arg1) { @@ -3125,7 +3125,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command zscan. + * Redis command ZSCAN. * @return Future response. */ default Future<@Nullable Response> zscan(List args) { @@ -3133,7 +3133,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command zscore. + * Redis command ZSCORE. * @return Future response. */ default Future<@Nullable Response> zscore(String arg0, String arg1) { @@ -3141,7 +3141,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command zunion. + * Redis command ZUNION. * @return Future response. */ default Future<@Nullable Response> zunion(List args) { @@ -3149,7 +3149,7 @@ static RedisAPI api(RedisConnection connection) { } /** - * Redis command zunionstore. + * Redis command ZUNIONSTORE. * @return Future response. */ default Future<@Nullable Response> zunionstore(List args) { diff --git a/src/main/java/io/vertx/redis/client/impl/RedisClusterClient.java b/src/main/java/io/vertx/redis/client/impl/RedisClusterClient.java index baf5dd4c..77a11c26 100644 --- a/src/main/java/io/vertx/redis/client/impl/RedisClusterClient.java +++ b/src/main/java/io/vertx/redis/client/impl/RedisClusterClient.java @@ -29,7 +29,8 @@ import java.util.HashMap; import java.util.List; import java.util.Map; -import java.util.concurrent.atomic.AtomicBoolean; +import java.util.Set; +import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicReference; import java.util.function.Function; @@ -119,8 +120,10 @@ public static void addMasterOnlyCommand(Command command) { addMasterOnlyCommand(SUBSCRIBE); addMasterOnlyCommand(PSUBSCRIBE); + addMasterOnlyCommand(SSUBSCRIBE); addReducer(UNSUBSCRIBE, list -> SimpleStringType.OK); addReducer(PUNSUBSCRIBE, list -> SimpleStringType.OK); + addReducer(SUNSUBSCRIBE, list -> SimpleStringType.OK); } private final RedisClusterConnectOptions connectOptions; @@ -154,12 +157,12 @@ private void connect(Slots slots, Handler> onConnec final int totalUniqueEndpoints = slots.endpoints().length; if (poolOptions.getMaxSize() < totalUniqueEndpoints) { // this isn't a valid setup, the connection pool will not accommodate all the required connections - onConnected.handle(Future.failedFuture("RedisOptions maxPoolSize < Cluster size(" + totalUniqueEndpoints + "): The pool is not able to hold all required connections!")); + onConnected.handle(Future.failedFuture(new RedisConnectException("RedisOptions maxPoolSize < Cluster size(" + totalUniqueEndpoints + "): The pool is not able to hold all required connections!"))); return; } // create a cluster connection - final AtomicBoolean failed = new AtomicBoolean(false); + final Set failures = ConcurrentHashMap.newKeySet(); final AtomicInteger counter = new AtomicInteger(); final Map connections = new HashMap<>(); @@ -167,8 +170,8 @@ private void connect(Slots slots, Handler> onConnec connectionManager.getConnection(endpoint, RedisReplicas.NEVER != connectOptions.getUseReplicas() ? cmd(READONLY) : null) .onFailure(err -> { // failed try with the next endpoint - failed.set(true); - connectionComplete(counter, slots, connections, failed, onConnected); + failures.add(err); + connectionComplete(counter, slots, connections, failures, onConnected); }) .onSuccess(cconn -> { // there can be concurrent access to the connection map @@ -177,16 +180,16 @@ private void connect(Slots slots, Handler> onConnec synchronized (connections) { connections.put(endpoint, cconn); } - connectionComplete(counter, slots, connections, failed, onConnected); + connectionComplete(counter, slots, connections, failures, onConnected); }); } } private void connectionComplete(AtomicInteger counter, Slots slots, Map connections, - AtomicBoolean failed, Handler> onConnected) { + Set failures, Handler> onConnected) { if (counter.incrementAndGet() == slots.endpoints().length) { // end condition - if (failed.get()) { + if (!failures.isEmpty()) { // cleanup // during an error we lock the map because we will change it @@ -199,7 +202,11 @@ private void connectionComplete(AtomicInteger counter, Slots slots, Map this.slots.set(null), connections))); @@ -228,7 +235,8 @@ private Future getSlots(ContextInternal context) { private void getSlots(List endpoints, int index, Handler> onGotSlots) { if (index >= endpoints.size()) { // stop condition - onGotSlots.handle(Future.failedFuture("Cannot connect to any of the provided endpoints")); + onGotSlots.handle(Future.failedFuture(new RedisConnectException("Cannot connect to any of the provided endpoints"))); + scheduleCachedSlotsExpiration(); return; } @@ -249,7 +257,7 @@ private void getSlots(List endpoints, int index, Handler this.slots.set(null)); + scheduleCachedSlotsExpiration(); } }); }); @@ -267,4 +275,8 @@ private Future getSlots(String endpoint, RedisConnection conn) { return Future.succeededFuture(new Slots(endpoint, reply)); }); } + + private void scheduleCachedSlotsExpiration() { + vertx.setTimer(connectOptions.getHashSlotCacheTTL(), ignored -> this.slots.set(null)); + } } diff --git a/src/main/java/io/vertx/redis/client/impl/RedisClusterConnection.java b/src/main/java/io/vertx/redis/client/impl/RedisClusterConnection.java index a7afc198..15529357 100644 --- a/src/main/java/io/vertx/redis/client/impl/RedisClusterConnection.java +++ b/src/main/java/io/vertx/redis/client/impl/RedisClusterConnection.java @@ -19,17 +19,16 @@ public class RedisClusterConnection implements RedisConnection { private static final Logger LOG = LoggerFactory.getLogger(RedisClusterConnection.class); - // we need some randomness, it doesn't need - // to be secure or unpredictable + // we need some randomness, it doesn't need to be cryptographically secure private static final Random RANDOM = new Random(); // number of attempts/redirects when we get connection errors // or when we get MOVED/ASK responses private static final int RETRIES = 16; - // reduce from list fo responses to a single response + // reduce from list of responses to a single response private static final Map, Response>> REDUCERS = new HashMap<>(); - // List of commands they should run every time only against master nodes + // List of commands that should always run only against master nodes private static final List MASTER_ONLY_COMMANDS = new ArrayList<>(); public static void addReducer(Command command, Function, Response> fn) { diff --git a/src/main/java/io/vertx/redis/client/impl/RedisConnectException.java b/src/main/java/io/vertx/redis/client/impl/RedisConnectException.java new file mode 100644 index 00000000..76276dc3 --- /dev/null +++ b/src/main/java/io/vertx/redis/client/impl/RedisConnectException.java @@ -0,0 +1,19 @@ +package io.vertx.redis.client.impl; + +import java.net.ConnectException; + +/** + * Used to signal connection failure in certain Redis clients that don't propagate underlying + * exceptions directly, but use a custom logic. Intentionally a subclass of {@code ConnectException}, + * so that users of Redis clients can handle connection failures uniformly. + */ +class RedisConnectException extends ConnectException { + RedisConnectException(String msg) { + super(msg); + } + + @Override + public Throwable fillInStackTrace() { + return this; + } +} diff --git a/src/main/java/io/vertx/redis/client/impl/RedisReplicationClient.java b/src/main/java/io/vertx/redis/client/impl/RedisReplicationClient.java index 25c37d54..b01a42c9 100644 --- a/src/main/java/io/vertx/redis/client/impl/RedisReplicationClient.java +++ b/src/main/java/io/vertx/redis/client/impl/RedisReplicationClient.java @@ -116,7 +116,7 @@ public Future connect() { private void connect(List endpoints, int index, Handler> onConnect) { if (index >= endpoints.size()) { // stop condition - onConnect.handle(Future.failedFuture("Cannot connect to any of the provided endpoints")); + onConnect.handle(Future.failedFuture(new RedisConnectException("Cannot connect to any of the provided endpoints"))); return; } @@ -145,7 +145,7 @@ private void connect(List endpoints, int index, Handler { if (err) { @@ -40,6 +40,8 @@ redis.info((err, info) => { let args = ""; let argLen = 0; + let identifier = cmd[0].replace('.', '_').replace('-', '_').replace(':', '').toUpperCase(); + if (cmd[1] > 0) { for (let i = 0; i < cmd[1] - 1; i++) { if (i !== 0) { @@ -63,7 +65,7 @@ redis.info((err, info) => { } commands.push({ - enum: cmd[0].replace('-', '_').replace(':', '').replace('.', '_').toUpperCase(), + enum: identifier, name: cmd[0], safename: cmd[0].replace('-', ' ').replace(':', '').toUpperCase(), arity: cmd[1], @@ -79,7 +81,7 @@ redis.info((err, info) => { write: cmd[2].indexOf('write') !== -1, readOnly: cmd[2].indexOf('readonly') !== -1, movable: cmd[2].indexOf('movablekeys') !== -1, - pubsub: cmd[2].indexOf('pubsub') !== -1 && !excludedPubSub.includes(cmd[0].replace('-', '_').replace(':', '').toUpperCase()) + pubsub: cmd[2].indexOf('pubsub') !== -1 && !excludedPubSub.includes(identifier) }); }); diff --git a/tools/package.json b/tools/package.json index d1cc0eea..6950ea4a 100644 --- a/tools/package.json +++ b/tools/package.json @@ -8,7 +8,7 @@ "redis": "^2.8.0" }, "scripts": { - "--prestart": "docker run --rm --net=host redis/redis-stack-server:7.0.6-RC8", + "--prestart": "docker run --rm --net=host redis/redis-stack-server:7.0.6-RC9", "start": "node commands.js" } } diff --git a/tools/redis-api.hbs b/tools/redis-api.hbs index 3fba6d0b..ad3171ca 100644 --- a/tools/redis-api.hbs +++ b/tools/redis-api.hbs @@ -46,7 +46,7 @@ public interface RedisAPI { {{#each .}} /** - * Redis command {{ camelcase safename }}. + * Redis command {{ uppercase name }}. * @return Future response. */ default Future<@Nullable Response> {{ camelcase safename }}({{{ types }}}) {