redis.clients.jedis

Class ClusterCommandObjects

java.lang.Object

redis.clients.jedis.CommandObjects

redis.clients.jedis.ClusterCommandObjects

public class ClusterCommandObjects
extends CommandObjects

Field Summary

Fields inherited from class redis.clients.jedis.CommandObjects

keyPreProcessor

Constructor Summary

Constructors

Constructor and Description
ClusterCommandObjects(RedisProtocol protocol)

Method Summary

Modifier and Type	Method and Description
java.util.List<CommandObject<java.lang.Long>>	delMultiShard(byte[]... keys) Creates multiple DEL command objects, one for each hash slot group.
java.util.List<CommandObject<java.lang.Long>>	delMultiShard(java.lang.String... keys) Creates multiple DEL command objects, one for each hash slot group.
java.util.List<CommandObject<java.lang.Long>>	existsMultiShard(byte[]... keys) Creates multiple EXISTS command objects, one for each hash slot group.
java.util.List<CommandObject<java.lang.Long>>	existsMultiShard(java.lang.String... keys) Creates multiple EXISTS command objects, one for each hash slot group.
protected java.util.List<CommandArguments>	groupArgumentsByKeyHashSlot(CommandArguments args, byte[][] keys, IParams params) Groups keys by their hash slot and creates separate CommandArguments for each slot.
protected java.util.List<CommandArguments>	groupArgumentsByKeyHashSlot(CommandArguments args, java.lang.String[] keys, IParams params) Groups keys by their hash slot and creates separate CommandArguments for each slot.
protected java.util.List<CommandArguments>	groupArgumentsByKeyValueHashSlot(CommandArguments args, byte[][] keysValues, IParams params) Groups key-value pairs by their hash slot and creates separate CommandArguments for each slot.
protected java.util.List<CommandArguments>	groupArgumentsByKeyValueHashSlot(CommandArguments args, java.lang.String[] keysValues, IParams params) Groups key-value pairs by their hash slot and creates separate CommandArguments for each slot.
protected java.util.List<CommandArguments>	groupArgumentsByKeyValueHashSlotWithKeyCount(CommandArguments args, byte[][] keysValues, IParams params) Groups key-value pairs by their hash slot and creates separate CommandArguments for each slot.
protected java.util.List<CommandArguments>	groupArgumentsByKeyValueHashSlotWithKeyCount(CommandArguments args, java.lang.String[] keysValues, IParams params) Groups key-value pairs by their hash slot and creates separate CommandArguments for each slot.
CommandObject<HotkeysInfo>	hotkeysGet()
CommandObject<java.lang.String>	hotkeysReset()
CommandObject<java.lang.String>	hotkeysStart(HotkeysParams params)
CommandObject<java.lang.String>	hotkeysStop()
java.util.List<CommandObject<java.util.List<byte[]>>>	mgetMultiShard(byte[]... keys) Creates multiple MGET command objects, one for each hash slot group.
java.util.List<CommandObject<java.util.List<java.lang.String>>>	mgetMultiShard(java.lang.String... keys) Creates multiple MGET command objects, one for each hash slot group.
java.util.List<CommandObject<java.lang.Boolean>>	msetexMultiShard(MSetExParams params, byte[]... keysvalues) Creates multiple MSETEX command objects, one for each hash slot group.
java.util.List<CommandObject<java.lang.Boolean>>	msetexMultiShard(MSetExParams params, java.lang.String... keysvalues) Creates multiple MSETEX command objects, one for each hash slot group.
java.util.List<CommandObject<java.lang.String>>	msetMultiShard(byte[]... keysvalues) Creates multiple MSET command objects, one for each hash slot group.
java.util.List<CommandObject<java.lang.String>>	msetMultiShard(java.lang.String... keysvalues) Creates multiple MSET command objects, one for each hash slot group.
CommandObject<ScanResult<byte[]>>	scan(byte[] cursor)
CommandObject<ScanResult<byte[]>>	scan(byte[] cursor, ScanParams params)
CommandObject<ScanResult<byte[]>>	scan(byte[] cursor, ScanParams params, byte[] type)
CommandObject<ScanResult<java.lang.String>>	scan(java.lang.String cursor)
CommandObject<ScanResult<java.lang.String>>	scan(java.lang.String cursor, ScanParams params)
CommandObject<ScanResult<java.lang.String>>	scan(java.lang.String cursor, ScanParams params, java.lang.String type)
java.util.List<CommandObject<java.lang.Long>>	touchMultiShard(byte[]... keys) Creates multiple TOUCH command objects, one for each hash slot group.
java.util.List<CommandObject<java.lang.Long>>	touchMultiShard(java.lang.String... keys) Creates multiple TOUCH command objects, one for each hash slot group.
java.util.List<CommandObject<java.lang.Long>>	unlinkMultiShard(byte[]... keys) Creates multiple UNLINK command objects, one for each hash slot group.
java.util.List<CommandObject<java.lang.Long>>	unlinkMultiShard(java.lang.String... keys) Creates multiple UNLINK command objects, one for each hash slot group.
CommandObject<KeyValue<java.lang.Long,java.lang.Long>>	waitAOF(long numLocal, long numReplicas, long timeout)
CommandObject<java.lang.Long>	waitReplicas(int replicas, long timeout)

Methods inherited from class redis.clients.jedis.CommandObjects

append, append, arcount, arcount, ardel, ardel, ardel, ardel, ardelrange, ardelrange, ardelrange, ardelrange, arget, arget, argetrange, argetrange, argrep, argrep, argrepWithValues, argrepWithValues, arinfo, arinfo, arinfoFull, arinfoFull, arinsert, arinsert, arinsert, arinsert, arlastitems, arlastitems, arlastitems, arlastitems, arlen, arlen, armget, armget, armset, armset, arnext, arnext, aropAggregate, aropAggregate, aropBitwise, aropBitwise, aropCount, aropCount, aropCount, aropCount, arring, arring, arring, arring, arscan, arscan, arscan, arscan, arseek, arseek, arset, arset, arset, arset, bfAdd, bfCard, bfExists, bfInfo, bfInsert, bfInsert, bfLoadChunk, bfMAdd, bfMExists, bfReserve, bfReserve, bfScanDump, bitcount, bitcount, bitcount, bitcount, bitcount, bitcount, bitfield, bitfield, bitfieldReadonly, bitfieldReadonly, bitop, bitop, bitpos, bitpos, bitpos, bitpos, blmove, blmove, blmovem, blmovem, blmovem, blmovem, blmpop, blmpop, blmpop, blmpop, blpop, blpop, blpop, blpop, blpop, blpop, brpop, brpop, brpop, brpop, brpop, brpop, brpoplpush, brpoplpush, bzmpop, bzmpop, bzmpop, bzmpop, bzpopmax, bzpopmax, bzpopmin, bzpopmin, cfAdd, cfAddNx, cfCount, cfDel, cfExists, cfInfo, cfInsert, cfInsert, cfInsertNx, cfInsertNx, cfLoadChunk, cfMExists, cfReserve, cfReserve, cfScanDump, cmsIncrBy, cmsInfo, cmsInitByDim, cmsInitByProb, cmsMerge, cmsMerge, cmsQuery, commandArguments, configGet, configGet, configSet, configSet, copy, copy, copy, copy, dbSize, decr, decr, decrBy, decrBy, del, del, del, del, delex, delex, digestKey, digestKey, dump, dump, echo, eval, eval, eval, eval, eval, eval, eval, eval, evalReadonly, evalReadonly, evalsha, evalsha, evalsha, evalsha, evalsha, evalsha, evalsha, evalsha, evalshaReadonly, evalshaReadonly, exists, exists, exists, exists, expire, expire, expire, expire, expireAt, expireAt, expireAt, expireAt, expireTime, expireTime, fcall, fcall, fcallReadonly, fcallReadonly, flushAll, flushDB, ftAggregate, ftAliasAdd, ftAliasDel, ftAliasList, ftAliasUpdate, ftAlter, ftAlter, ftConfigGet, ftConfigGet, ftConfigSet, ftConfigSet, ftCreate, ftCreate, ftCursorDel, ftCursorRead, ftDictAdd, ftDictAddBySampleKey, ftDictDel, ftDictDelBySampleKey, ftDictDump, ftDictDumpBySampleKey, ftDropIndex, ftDropIndexDD, ftExplain, ftExplainCLI, ftHybrid, ftInfo, ftList, ftProfileAggregate, ftProfileSearch, ftProfileSearch, ftSearch, ftSearch, ftSearch, ftSearch, ftSpellCheck, ftSpellCheck, ftSugAdd, ftSugAddIncr, ftSugDel, ftSugGet, ftSugGet, ftSugGetWithScores, ftSugGetWithScores, ftSugLen, ftSynDump, ftSynUpdate, ftTagVals, functionDelete, functionDelete, functionDump, functionFlush, functionFlush, functionKill, functionList, functionList, functionList, functionListBinary, functionListWithCode, functionListWithCode, functionListWithCode, functionListWithCodeBinary, functionLoad, functionLoad, functionLoadReplace, functionLoadReplace, functionRestore, functionRestore, functionStats, functionStatsBinary, geoadd, geoadd, geoadd, geoadd, geoadd, geoadd, geodist, geodist, geodist, geodist, geohash, geohash, geopos, geopos, georadius, georadius, georadius, georadius, georadiusByMember, georadiusByMember, georadiusByMember, georadiusByMember, georadiusByMemberReadonly, georadiusByMemberReadonly, georadiusByMemberReadonly, georadiusByMemberReadonly, georadiusByMemberStore, georadiusByMemberStore, georadiusReadonly, georadiusReadonly, georadiusReadonly, georadiusReadonly, georadiusStore, georadiusStore, geosearch, geosearch, geosearch, geosearch, geosearch, geosearch, geosearch, geosearch, geosearch, geosearch, geosearchStore, geosearchStore, geosearchStore, geosearchStore, geosearchStore, geosearchStore, geosearchStore, geosearchStore, geosearchStore, geosearchStore, geosearchStoreStoreDist, geosearchStoreStoreDist, get, get, getbit, getbit, getDel, getDel, getEx, getEx, getProtocol, getrange, getrange, getSet, getSet, hdel, hdel, hexists, hexists, hexpire, hexpire, hexpire, hexpire, hexpireAt, hexpireAt, hexpireAt, hexpireAt, hexpireTime, hexpireTime, hget, hget, hgetAll, hgetAll, hgetdel, hgetdel, hgetex, hgetex, hincrBy, hincrBy, hincrByFloat, hincrByFloat, hkeys, hkeys, hlen, hlen, hmget, hmget, hmset, hmset, hpersist, hpersist, hpexpire, hpexpire, hpexpire, hpexpire, hpexpireAt, hpexpireAt, hpexpireAt, hpexpireAt, hpexpireTime, hpexpireTime, hpttl, hpttl, hrandfield, hrandfield, hrandfield, hrandfield, hrandfieldWithValues, hrandfieldWithValues, hscan, hscan, hscanNoValues, hscanNoValues, hset, hset, hset, hset, hsetex, hsetex, hsetex, hsetex, hsetnx, hsetnx, hsetObject, hsetObject, hstrlen, hstrlen, httl, httl, hvals, hvals, incr, incr, incrBy, incrBy, incrByFloat, incrByFloat, increx, increx, increx, increx, increx, increx, info, info, jsonArrAppend, jsonArrAppend, jsonArrAppend, jsonArrAppendWithEscape, jsonArrIndex, jsonArrIndex, jsonArrIndexWithEscape, jsonArrInsert, jsonArrInsert, jsonArrInsertWithEscape, jsonArrLen, jsonArrLen, jsonArrLen, jsonArrPop, jsonArrPop, jsonArrPop, jsonArrPop, jsonArrPop, jsonArrPop, jsonArrPop, jsonArrPop, jsonArrTrim, jsonArrTrim, jsonClear, jsonClear, jsonClear, jsonDebugMemory, jsonDebugMemory, jsonDebugMemory, jsonDel, jsonDel, jsonDel, jsonGet, jsonGet, jsonGet, jsonGet, jsonGet, jsonGetAsPlainString, jsonMerge, jsonMerge, jsonMGet, jsonMGet, jsonNumIncrBy, jsonNumIncrBy, jsonObjKeys, jsonObjKeys, jsonObjKeys, jsonObjLen, jsonObjLen, jsonObjLen, jsonSet, jsonSet, jsonSet, jsonSet, jsonSetWithEscape, jsonSetWithEscape, jsonSetWithPlainString, jsonStrAppend, jsonStrAppend, jsonStrAppend, jsonStrLen, jsonStrLen, jsonStrLen, jsonToggle, jsonToggle, jsonType, jsonType, jsonType, keys, keys, lcs, lcs, lindex, lindex, linsert, linsert, llen, llen, lmove, lmove, lmovem, lmovem, lmovem, lmovem, lmpop, lmpop, lmpop, lmpop, lpop, lpop, lpop, lpop, lpos, lpos, lpos, lpos, lpos, lpos, lpush, lpush, lpushx, lpushx, lrange, lrange, lrem, lrem, lset, lset, ltrim, ltrim, memoryUsage, memoryUsage, memoryUsage, memoryUsage, mget, mget, migrate, migrate, migrate, migrate, migrate, migrate, migrate, migrate, mset, mset, msetex, msetex, msetnx, msetnx, objectEncoding, objectEncoding, objectFreq, objectFreq, objectIdletime, objectIdletime, objectRefcount, objectRefcount, persist, persist, pexpire, pexpire, pexpire, pexpire, pexpireAt, pexpireAt, pexpireAt, pexpireAt, pexpireTime, pexpireTime, pfadd, pfadd, pfcount, pfcount, pfcount, pfcount, pfmerge, pfmerge, ping, psetex, psetex, pttl, pttl, publish, publish, randomBinaryKey, randomKey, rename, rename, renamenx, renamenx, restore, restore, restore, restore, rpop, rpop, rpop, rpop, rpoplpush, rpoplpush, rpush, rpush, rpushx, rpushx, sadd, sadd, scard, scard, scriptExists, scriptExists, scriptExists, scriptFlush, scriptFlush, scriptFlush, scriptFlush, scriptFlush, scriptKill, scriptKill, scriptKill, scriptLoad, scriptLoad, scriptLoad, sdiff, sdiff, sdiffcard, sdiffcard, sdiffcard, sdiffcard, sdiffcard, sdiffcard, sdiffcard, sdiffstore, sdiffstore, set, set, set, set, setbit, setbit, setDefaultSearchDialect, setex, setex, setGet, setGet, setGet, setGet, setJsonObjectMapper, setKeyArgumentPreProcessor, setnx, setnx, setrange, setrange, sinter, sinter, sintercard, sintercard, sintercard, sintercard, sinterstore, sinterstore, sismember, sismember, slowlogReset, smembers, smembers, smismember, smismember, smove, smove, sort, sort, sort, sort, sort, sort, sort, sort, sortReadonly, sortReadonly, spop, spop, spop, spop, spublish, spublish, srandmember, srandmember, srandmember, srandmember, srem, srem, sscan, sscan, strlen, strlen, substr, substr, sunion, sunion, sunioncard, sunioncard, sunioncard, sunioncard, sunioncard, sunioncard, sunioncard, sunionstore, sunionstore, tdigestAdd, tdigestByRank, tdigestByRevRank, tdigestCDF, tdigestCreate, tdigestCreate, tdigestInfo, tdigestMax, tdigestMerge, tdigestMerge, tdigestMin, tdigestQuantile, tdigestRank, tdigestReset, tdigestRevRank, tdigestTrimmedMean, topkAdd, topkIncrBy, topkInfo, topkList, topkListWithCount, topkQuery, topkReserve, topkReserve, touch, touch, touch, touch, tsAdd, tsAdd, tsAdd, tsAdd, tsAlter, tsCreate, tsCreate, tsCreateRule, tsCreateRule, tsDecrBy, tsDecrBy, tsDecrBy, tsDel, tsDeleteRule, tsGet, tsGet, tsIncrBy, tsIncrBy, tsIncrBy, tsInfo, tsInfoDebug, tsMAdd, tsMGet, tsMRange, tsMRange, tsMRevRange, tsMRevRange, tsNRange, tsNRange, tsNRevRange, tsNRevRange, tsQueryIndex, tsQueryLabels, tsQueryLabelValues, tsRange, tsRange, tsRead, tsRead, tsRevRange, tsRevRange, ttl, ttl, type, type, unlink, unlink, unlink, unlink, vadd, vadd, vadd, vadd, vadd, vadd, vaddFP32, vaddFP32, vaddFP32, vaddFP32, vaddFP32, vaddFP32, vcard, vcard, vdim, vdim, vemb, vemb, vembRaw, vembRaw, vgetattr, vgetattr, vinfo, vismember, vismember, vlinks, vlinks, vlinksWithScores, vlinksWithScores, vrandmember, vrandmember, vrandmember, vrandmember, vrem, vrem, vsetattr, vsetattr, vsim, vsim, vsim, vsim, vsimByElement, vsimByElement, vsimByElement, vsimByElement, vsimByElementWithScores, vsimByElementWithScores, vsimByElementWithScoresAndAttribs, vsimByElementWithScoresAndAttribs, vsimWithScores, vsimWithScores, vsimWithScoresAndAttribs, vsimWithScoresAndAttribs, waitAOF, waitAOF, waitReplicas, waitReplicas, watch, watch, xack, xack, xackdel, xackdel, xackdel, xackdel, xadd, xadd, xadd, xautoclaim, xautoclaim, xautoclaimJustId, xautoclaimJustId, xcfgset, xcfgset, xclaim, xclaim, xclaimJustId, xclaimJustId, xdel, xdel, xdelex, xdelex, xdelex, xdelex, xgroupCreate, xgroupCreate, xgroupCreateConsumer, xgroupCreateConsumer, xgroupDelConsumer, xgroupDelConsumer, xgroupDestroy, xgroupDestroy, xgroupSetID, xgroupSetID, xinfoConsumers, xinfoConsumers, xinfoConsumers2, xinfoGroups, xinfoGroups, xinfoStream, xinfoStream, xinfoStreamFull, xinfoStreamFull, xinfoStreamFull, xinfoStreamFull, xlen, xlen, xnack, xnack, xpending, xpending, xpending, xpending, xrange, xrange, xrange, xrange, xrange, xrange, xread, xread, xreadAsMap, xreadBinary, xreadBinary, xreadBinaryAsMap, xreadBinaryAsMap, xreadGroup, xreadGroup, xreadGroupAsMap, xreadGroupBinary, xreadGroupBinary, xreadGroupBinaryAsMap, xreadGroupBinaryAsMap, xrevrange, xrevrange, xrevrange, xrevrange, xrevrange, xrevrange, xtrim, xtrim, xtrim, xtrim, zadd, zadd, zadd, zadd, zadd, zadd, zadd, zadd, zaddIncr, zaddIncr, zcard, zcard, zcount, zcount, zcount, zcount, zdiff, zdiff, zdiffstore, zdiffStore, zdiffstore, zdiffStore, zdiffWithScores, zdiffWithScores, zincrby, zincrby, zincrby, zincrby, zinter, zinter, zintercard, zintercard, zintercard, zintercard, zinterstore, zinterstore, zinterstore, zinterstore, zinterWithScores, zinterWithScores, zlexcount, zlexcount, zmpop, zmpop, zmpop, zmpop, zmscore, zmscore, zpopmax, zpopmax, zpopmax, zpopmax, zpopmin, zpopmin, zpopmin, zpopmin, zrandmember, zrandmember, zrandmember, zrandmember, zrandmemberWithScores, zrandmemberWithScores, zrange, zrange, zrange, zrange, zrangeByLex, zrangeByLex, zrangeByLex, zrangeByLex, zrangeByScore, zrangeByScore, zrangeByScore, zrangeByScore, zrangeByScore, zrangeByScore, zrangeByScore, zrangeByScore, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangestore, zrangestore, zrangeWithScores, zrangeWithScores, zrangeWithScores, zrangeWithScores, zrank, zrank, zrankWithScore, zrankWithScore, zrem, zrem, zremrangeByLex, zremrangeByLex, zremrangeByRank, zremrangeByRank, zremrangeByScore, zremrangeByScore, zremrangeByScore, zremrangeByScore, zrevrange, zrevrange, zrevrangeByLex, zrevrangeByLex, zrevrangeByLex, zrevrangeByLex, zrevrangeByScore, zrevrangeByScore, zrevrangeByScore, zrevrangeByScore, zrevrangeByScore, zrevrangeByScore, zrevrangeByScore, zrevrangeByScore, zrevrangeByScoreWithScores, zrevrangeByScoreWithScores, zrevrangeByScoreWithScores, zrevrangeByScoreWithScores, zrevrangeByScoreWithScores, zrevrangeByScoreWithScores, zrevrangeByScoreWithScores, zrevrangeByScoreWithScores, zrevrangeWithScores, zrevrangeWithScores, zrevrank, zrevrank, zrevrankWithScore, zrevrankWithScore, zscan, zscan, zscore, zscore, zunion, zunion, zunionstore, zunionstore, zunionstore, zunionstore, zunionWithScores, zunionWithScores

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ClusterCommandObjects

public ClusterCommandObjects(RedisProtocol protocol)

Method Detail

scan

public final CommandObject<ScanResult<java.lang.String>> scan(java.lang.String cursor)

Overrides:

scan in class CommandObjects

scan

public final CommandObject<ScanResult<java.lang.String>> scan(java.lang.String cursor,
                                                              ScanParams params)

Overrides:

scan in class CommandObjects

scan

public final CommandObject<ScanResult<java.lang.String>> scan(java.lang.String cursor,
                                                              ScanParams params,
                                                              java.lang.String type)

Overrides:

scan in class CommandObjects

scan

public final CommandObject<ScanResult<byte[]>> scan(byte[] cursor)

Overrides:

scan in class CommandObjects

scan

public final CommandObject<ScanResult<byte[]>> scan(byte[] cursor,
                                                    ScanParams params)

Overrides:

scan in class CommandObjects

scan

public final CommandObject<ScanResult<byte[]>> scan(byte[] cursor,
                                                    ScanParams params,
                                                    byte[] type)

Overrides:

scan in class CommandObjects

waitReplicas

public final CommandObject<java.lang.Long> waitReplicas(int replicas,
                                                        long timeout)

Overrides:

waitReplicas in class CommandObjects

waitAOF

public CommandObject<KeyValue<java.lang.Long,java.lang.Long>> waitAOF(long numLocal,
                                                                      long numReplicas,
                                                                      long timeout)

Overrides:

waitAOF in class CommandObjects

hotkeysStart

public CommandObject<java.lang.String> hotkeysStart(HotkeysParams params)

Overrides:

hotkeysStart in class CommandObjects

hotkeysStop

public CommandObject<java.lang.String> hotkeysStop()

Overrides:

hotkeysStop in class CommandObjects

hotkeysReset

public CommandObject<java.lang.String> hotkeysReset()

Overrides:

hotkeysReset in class CommandObjects

hotkeysGet

public CommandObject<HotkeysInfo> hotkeysGet()

Overrides:

hotkeysGet in class CommandObjects

groupArgumentsByKeyValueHashSlot

protected java.util.List<CommandArguments> groupArgumentsByKeyValueHashSlot(CommandArguments args,
                                                                            java.lang.String[] keysValues,
                                                                            IParams params)

Groups key-value pairs by their hash slot and creates separate CommandArguments for each slot. This enables commands with multiple keys to be properly distributed across Redis cluster nodes by ensuring that each resulting command only operates on keys that hash to the same slot.

Parameters:

args - the original command arguments to copy (the command itself will be preserved)

keysValues - variable number of key-value pairs to be grouped (must be even length)

params - additional parameters for the command (may be null)

Returns:

a list of CommandArguments objects, each containing only keys/values that belong to the same hash slot

Throws:

java.lang.IllegalArgumentException - if keysValues has odd length

groupArgumentsByKeyValueHashSlot

protected java.util.List<CommandArguments> groupArgumentsByKeyValueHashSlot(CommandArguments args,
                                                                            byte[][] keysValues,
                                                                            IParams params)

Groups key-value pairs by their hash slot and creates separate CommandArguments for each slot. This enables commands with multiple keys to be properly distributed across Redis cluster nodes by ensuring that each resulting command only operates on keys that hash to the same slot.

Parameters:

args - the original command arguments to copy (the command itself will be preserved)

keysValues - variable number of key-value pairs to be grouped (must be even length)

params - additional parameters for the command (may be null)

Returns:

a list of CommandArguments objects, each containing only keys/values that belong to the same hash slot

Throws:

java.lang.IllegalArgumentException - if keysValues has odd length

groupArgumentsByKeyHashSlot

protected java.util.List<CommandArguments> groupArgumentsByKeyHashSlot(CommandArguments args,
                                                                       java.lang.String[] keys,
                                                                       IParams params)

Groups keys by their hash slot and creates separate CommandArguments for each slot. This enables commands with multiple keys (like DEL, EXISTS, MGET) to be properly distributed across Redis cluster nodes by ensuring that each resulting command only operates on keys that hash to the same slot.

Order Preservation: This method preserves the order of keys as they appear in the input array. Consecutive keys that hash to the same slot are grouped together into a single CommandArguments, but non-consecutive keys with the same slot are kept in separate CommandArguments to maintain order. For example, if input keys map to slots [A, B, A], the result will be 3 separate CommandArguments (not 2), ensuring that when results are concatenated, they match the original input key order.

Parameters:

args - the original command arguments to copy (the command itself will be preserved)

keys - variable number of keys to be grouped

params - additional parameters for the command (may be null)

Returns:

a list of CommandArguments objects, each containing only keys that belong to the same hash slot, preserving the original key order

groupArgumentsByKeyHashSlot

protected java.util.List<CommandArguments> groupArgumentsByKeyHashSlot(CommandArguments args,
                                                                       byte[][] keys,
                                                                       IParams params)

Groups keys by their hash slot and creates separate CommandArguments for each slot. This enables commands with multiple keys (like DEL, EXISTS, MGET) to be properly distributed across Redis cluster nodes by ensuring that each resulting command only operates on keys that hash to the same slot.

Order Preservation: This method preserves the order of keys as they appear in the input array. Consecutive keys that hash to the same slot are grouped together into a single CommandArguments, but non-consecutive keys with the same slot are kept in separate CommandArguments to maintain order. For example, if input keys map to slots [A, B, A], the result will be 3 separate CommandArguments (not 2), ensuring that when results are concatenated, they match the original input key order.

Parameters:

args - the original command arguments to copy (the command itself will be preserved)

keys - variable number of keys to be grouped

params - additional parameters for the command (may be null)

Returns:

a list of CommandArguments objects, each containing only keys that belong to the same hash slot, preserving the original key order

groupArgumentsByKeyValueHashSlotWithKeyCount

protected java.util.List<CommandArguments> groupArgumentsByKeyValueHashSlotWithKeyCount(CommandArguments args,
                                                                                        java.lang.String[] keysValues,
                                                                                        IParams params)

Groups key-value pairs by their hash slot and creates separate CommandArguments for each slot. Inserts the key count after the command but before the keys (for commands like MSETEX).

Order Preservation: This method preserves the order of key-value pairs as they appear in the input array. Consecutive pairs that hash to the same slot are grouped together, but non-consecutive pairs with the same slot are kept in separate CommandArguments to maintain order.

Parameters:

args - the original command arguments to copy (the command itself will be preserved)

keysValues - variable number of key-value pairs to be grouped (must be even length)

params - additional parameters for the command (may be null)

Returns:

a list of CommandArguments objects, each containing only keys/values that belong to the same hash slot

Throws:

java.lang.IllegalArgumentException - if keysValues has odd length

groupArgumentsByKeyValueHashSlotWithKeyCount

protected java.util.List<CommandArguments> groupArgumentsByKeyValueHashSlotWithKeyCount(CommandArguments args,
                                                                                        byte[][] keysValues,
                                                                                        IParams params)

Groups key-value pairs by their hash slot and creates separate CommandArguments for each slot. Inserts the key count after the command but before the keys (for commands like MSETEX).

Parameters:

args - the original command arguments to copy (the command itself will be preserved)

keysValues - variable number of key-value pairs to be grouped (must be even length)

params - additional parameters for the command (may be null)

Returns:

a list of CommandArguments objects, each containing only keys/values that belong to the same hash slot

Throws:

java.lang.IllegalArgumentException - if keysValues has odd length

delMultiShard

public java.util.List<CommandObject<java.lang.Long>> delMultiShard(java.lang.String... keys)

Creates multiple DEL command objects, one for each hash slot group. This enables the DEL command to be executed across multiple Redis cluster shards when keys hash to different slots.

Parameters:

keys - the keys to delete

Returns:

a list of CommandObject instances, each containing keys that belong to the same hash slot

delMultiShard

public java.util.List<CommandObject<java.lang.Long>> delMultiShard(byte[]... keys)

Creates multiple DEL command objects, one for each hash slot group. This enables the DEL command to be executed across multiple Redis cluster shards when keys hash to different slots.

Parameters:

keys - the keys to delete

Returns:

a list of CommandObject instances, each containing keys that belong to the same hash slot

existsMultiShard

public java.util.List<CommandObject<java.lang.Long>> existsMultiShard(java.lang.String... keys)

Creates multiple EXISTS command objects, one for each hash slot group. This enables the EXISTS command to be executed across multiple Redis cluster shards when keys hash to different slots.

Parameters:

keys - the keys to check for existence

Returns:

a list of CommandObject instances, each containing keys that belong to the same hash slot

existsMultiShard

public java.util.List<CommandObject<java.lang.Long>> existsMultiShard(byte[]... keys)

Creates multiple EXISTS command objects, one for each hash slot group. This enables the EXISTS command to be executed across multiple Redis cluster shards when keys hash to different slots.

Parameters:

keys - the keys to check for existence

Returns:

a list of CommandObject instances, each containing keys that belong to the same hash slot

mgetMultiShard

public java.util.List<CommandObject<java.util.List<java.lang.String>>> mgetMultiShard(java.lang.String... keys)

Creates multiple MGET command objects, one for each hash slot group. This enables the MGET command to be executed across multiple Redis cluster shards when keys hash to different slots.

Order Preservation: The returned commands preserve the order of keys as they appear in the input array. When the results from all commands are concatenated in order, the values will correspond positionally to the input keys.

Parameters:

keys - the keys to retrieve values for

Returns:

a list of CommandObject instances, each containing keys that belong to the same hash slot

mgetMultiShard

public java.util.List<CommandObject<java.util.List<byte[]>>> mgetMultiShard(byte[]... keys)

Creates multiple MGET command objects, one for each hash slot group. This enables the MGET command to be executed across multiple Redis cluster shards when keys hash to different slots.

Order Preservation: The returned commands preserve the order of keys as they appear in the input array. When the results from all commands are concatenated in order, the values will correspond positionally to the input keys.

Parameters:

keys - the keys to retrieve values for

Returns:

a list of CommandObject instances, each containing keys that belong to the same hash slot

msetMultiShard

public java.util.List<CommandObject<java.lang.String>> msetMultiShard(java.lang.String... keysvalues)

Creates multiple MSET command objects, one for each hash slot group. This enables the MSET command to be executed across multiple Redis cluster shards when keys hash to different slots.

Parameters:

keysvalues - alternating keys and values (key1, value1, key2, value2, ...)

Returns:

a list of CommandObject instances, each containing key-value pairs that belong to the same hash slot

msetMultiShard

public java.util.List<CommandObject<java.lang.String>> msetMultiShard(byte[]... keysvalues)

Creates multiple MSET command objects, one for each hash slot group. This enables the MSET command to be executed across multiple Redis cluster shards when keys hash to different slots.

Parameters:

keysvalues - alternating keys and values (key1, value1, key2, value2, ...)

Returns:

a list of CommandObject instances, each containing key-value pairs that belong to the same hash slot

touchMultiShard

public java.util.List<CommandObject<java.lang.Long>> touchMultiShard(java.lang.String... keys)

Creates multiple TOUCH command objects, one for each hash slot group. This enables the TOUCH command to be executed across multiple Redis cluster shards when keys hash to different slots.

Parameters:

keys - the keys to touch

Returns:

a list of CommandObject instances, each containing keys that belong to the same hash slot

touchMultiShard

public java.util.List<CommandObject<java.lang.Long>> touchMultiShard(byte[]... keys)

Creates multiple TOUCH command objects, one for each hash slot group. This enables the TOUCH command to be executed across multiple Redis cluster shards when keys hash to different slots.

Parameters:

keys - the keys to touch

Returns:

a list of CommandObject instances, each containing keys that belong to the same hash slot

unlinkMultiShard

public java.util.List<CommandObject<java.lang.Long>> unlinkMultiShard(java.lang.String... keys)

Creates multiple UNLINK command objects, one for each hash slot group. This enables the UNLINK command to be executed across multiple Redis cluster shards when keys hash to different slots.

Parameters:

keys - the keys to unlink

Returns:

a list of CommandObject instances, each containing keys that belong to the same hash slot

unlinkMultiShard

public java.util.List<CommandObject<java.lang.Long>> unlinkMultiShard(byte[]... keys)

Creates multiple UNLINK command objects, one for each hash slot group. This enables the UNLINK command to be executed across multiple Redis cluster shards when keys hash to different slots.

Parameters:

keys - the keys to unlink

Returns:

a list of CommandObject instances, each containing keys that belong to the same hash slot

msetexMultiShard

public java.util.List<CommandObject<java.lang.Boolean>> msetexMultiShard(MSetExParams params,
                                                                         java.lang.String... keysvalues)

Creates multiple MSETEX command objects, one for each hash slot group. This enables the MSETEX command to be executed across multiple Redis cluster shards when keys hash to different slots. Each command preserves the provided parameters (expiration, NX/XX conditions).

Parameters:

params - the MSETEX parameters (expiration, NX/XX conditions)

keysvalues - alternating keys and values (key1, value1, key2, value2, ...)

Returns:

a list of CommandObject instances, each containing key-value pairs that belong to the same hash slot

msetexMultiShard

public java.util.List<CommandObject<java.lang.Boolean>> msetexMultiShard(MSetExParams params,
                                                                         byte[]... keysvalues)

Creates multiple MSETEX command objects, one for each hash slot group. This enables the MSETEX command to be executed across multiple Redis cluster shards when keys hash to different slots. Each command preserves the provided parameters (expiration, NX/XX conditions).

Parameters:

params - the MSETEX parameters (expiration, NX/XX conditions)

keysvalues - alternating keys and values (key1, value1, key2, value2, ...)

Returns:

a list of CommandObject instances, each containing key-value pairs that belong to the same hash slot