public abstract class MultiKeyPipelineBase extends PipelineBase implements MultiKeyBinaryRedisPipeline, MultiKeyCommandsPipeline, ClusterPipeline, BinaryScriptingCommandsPipeline, ScriptingCommandsPipeline, BasicRedisPipeline
| 构造器和说明 |
|---|
MultiKeyPipelineBase() |
| 限定符和类型 | 方法和说明 |
|---|---|
Response<java.lang.String> |
bgrewriteaof() |
Response<java.lang.String> |
bgsave() |
Response<java.lang.Long> |
bitop(BitOP op,
byte[] destKey,
byte[]... srcKeys) |
Response<java.lang.Long> |
bitop(BitOP op,
java.lang.String destKey,
java.lang.String... srcKeys) |
Response<byte[]> |
blmove(byte[] srcKey,
byte[] dstKey,
ListDirection from,
ListDirection to,
double timeout) |
Response<java.lang.String> |
blmove(java.lang.String srcKey,
java.lang.String dstKey,
ListDirection from,
ListDirection to,
double timeout) |
Response<java.util.List<byte[]>> |
blpop(byte[]... args) |
Response<java.util.List<byte[]>> |
blpop(double timeout,
byte[]... keys) |
Response<KeyedListElement> |
blpop(double timeout,
java.lang.String... keys) |
Response<java.util.List<java.lang.String>> |
blpop(int timeout,
byte[]... keys)
已过时。
|
Response<java.util.List<java.lang.String>> |
blpop(int timeout,
java.lang.String... keys) |
Response<java.util.List<java.lang.String>> |
blpop(java.lang.String... args) |
Response<java.util.Map<java.lang.String,java.lang.String>> |
blpopMap(int timeout,
java.lang.String... keys)
|
Response<java.util.List<byte[]>> |
brpop(byte[]... args) |
Response<java.util.List<byte[]>> |
brpop(double timeout,
byte[]... keys) |
Response<KeyedListElement> |
brpop(double timeout,
java.lang.String... keys) |
Response<java.util.List<java.lang.String>> |
brpop(int timeout,
byte[]... keys)
已过时。
|
Response<java.util.List<java.lang.String>> |
brpop(int timeout,
java.lang.String... keys) |
Response<java.util.List<java.lang.String>> |
brpop(java.lang.String... args) |
Response<byte[]> |
brpoplpush(byte[] source,
byte[] destination,
int timeout) |
Response<java.lang.String> |
brpoplpush(java.lang.String source,
java.lang.String destination,
int timeout) |
Response<java.util.Map<java.lang.String,java.lang.String>> |
brpopMap(int timeout,
java.lang.String... keys)
|
Response<java.util.List<byte[]>> |
bzpopmax(double timeout,
byte[]... keys) |
Response<KeyedZSetElement> |
bzpopmax(double timeout,
java.lang.String... keys) |
Response<java.util.List<byte[]>> |
bzpopmin(double timeout,
byte[]... keys) |
Response<KeyedZSetElement> |
bzpopmin(double timeout,
java.lang.String... keys) |
Response<java.lang.String> |
clusterAddSlots(int... slots) |
Response<java.lang.String> |
clusterDelSlots(int... slots) |
Response<java.util.List<java.lang.String>> |
clusterGetKeysInSlot(int slot,
int count) |
Response<java.lang.String> |
clusterInfo() |
Response<java.lang.String> |
clusterMeet(java.lang.String ip,
int port) |
Response<java.lang.String> |
clusterNodes() |
Response<java.lang.String> |
clusterSetSlotImporting(int slot,
java.lang.String nodeId) |
Response<java.lang.String> |
clusterSetSlotMigrating(int slot,
java.lang.String nodeId) |
Response<java.lang.String> |
clusterSetSlotNode(int slot,
java.lang.String nodeId) |
Response<java.util.List<java.lang.String>> |
configGet(java.lang.String pattern) |
Response<java.lang.String> |
configResetStat() |
Response<java.lang.String> |
configSet(java.lang.String parameter,
java.lang.String value) |
Response<java.lang.Boolean> |
copy(byte[] srcKey,
byte[] dstKey,
boolean replace) |
Response<java.lang.Boolean> |
copy(byte[] srcKey,
byte[] dstKey,
int db,
boolean replace) |
Response<java.lang.Boolean> |
copy(java.lang.String srcKey,
java.lang.String dstKey,
boolean replace) |
Response<java.lang.Boolean> |
copy(java.lang.String srcKey,
java.lang.String dstKey,
int db,
boolean replace) |
Response<java.lang.Long> |
dbSize() |
Response<java.lang.Long> |
del(byte[]... keys) |
Response<java.lang.Long> |
del(java.lang.String... keys) |
Response<java.lang.Object> |
eval(byte[] script) |
Response<java.lang.Object> |
eval(byte[] script,
byte[] keyCount,
byte[]... params) |
Response<java.lang.Object> |
eval(byte[] script,
int keyCount,
byte[]... params) |
Response<java.lang.Object> |
eval(byte[] script,
java.util.List<byte[]> keys,
java.util.List<byte[]> args) |
Response<java.lang.Object> |
eval(java.lang.String script) |
Response<java.lang.Object> |
eval(java.lang.String script,
int keyCount,
java.lang.String... params) |
Response<java.lang.Object> |
eval(java.lang.String script,
java.util.List<java.lang.String> keys,
java.util.List<java.lang.String> args) |
Response<java.lang.Object> |
evalsha(byte[] sha1) |
Response<java.lang.Object> |
evalsha(byte[] sha1,
int keyCount,
byte[]... params) |
Response<java.lang.Object> |
evalsha(byte[] sha1,
java.util.List<byte[]> keys,
java.util.List<byte[]> args) |
Response<java.lang.Object> |
evalsha(java.lang.String sha1) |
Response<java.lang.Object> |
evalsha(java.lang.String sha1,
int keyCount,
java.lang.String... params) |
Response<java.lang.Object> |
evalsha(java.lang.String sha1,
java.util.List<java.lang.String> keys,
java.util.List<java.lang.String> args) |
Response<java.lang.Long> |
exists(byte[]... keys) |
Response<java.lang.Long> |
exists(java.lang.String... keys) |
Response<java.lang.String> |
flushAll() |
Response<java.lang.String> |
flushAll(FlushMode flushMode) |
Response<java.lang.String> |
flushDB() |
Response<java.lang.String> |
flushDB(FlushMode flushMode) |
Response<java.lang.Long> |
georadiusByMemberStore(byte[] key,
byte[] member,
double radius,
GeoUnit unit,
GeoRadiusParam param,
GeoRadiusStoreParam storeParam) |
Response<java.lang.Long> |
georadiusByMemberStore(java.lang.String key,
java.lang.String member,
double radius,
GeoUnit unit,
GeoRadiusParam param,
GeoRadiusStoreParam storeParam) |
Response<java.lang.Long> |
georadiusStore(byte[] key,
double longitude,
double latitude,
double radius,
GeoUnit unit,
GeoRadiusParam param,
GeoRadiusStoreParam storeParam) |
Response<java.lang.Long> |
georadiusStore(java.lang.String key,
double longitude,
double latitude,
double radius,
GeoUnit unit,
GeoRadiusParam param,
GeoRadiusStoreParam storeParam) |
Response<java.lang.String> |
info() |
Response<java.lang.String> |
info(java.lang.String section) |
Response<java.util.Set<byte[]>> |
keys(byte[] pattern) |
Response<java.util.Set<java.lang.String>> |
keys(java.lang.String pattern) |
Response<java.lang.Long> |
lastsave() |
Response<byte[]> |
lmove(byte[] srcKey,
byte[] dstKey,
ListDirection from,
ListDirection to) |
Response<java.lang.String> |
lmove(java.lang.String srcKey,
java.lang.String dstKey,
ListDirection from,
ListDirection to) |
Response<java.util.List<byte[]>> |
mget(byte[]... keys) |
Response<java.util.List<java.lang.String>> |
mget(java.lang.String... keys) |
Response<java.lang.String> |
migrate(java.lang.String host,
int port,
int destinationDB,
int timeout,
MigrateParams params,
byte[]... keys) |
Response<java.lang.String> |
migrate(java.lang.String host,
int port,
int destinationDB,
int timeout,
MigrateParams params,
java.lang.String... keys) |
Response<java.util.List<Module>> |
moduleList() |
Response<java.lang.String> |
moduleLoad(java.lang.String path) |
Response<java.lang.String> |
moduleUnload(java.lang.String name) |
Response<java.lang.String> |
mset(byte[]... keysvalues) |
Response<java.lang.String> |
mset(java.lang.String... keysvalues) |
Response<java.lang.Long> |
msetnx(byte[]... keysvalues) |
Response<java.lang.Long> |
msetnx(java.lang.String... keysvalues) |
Response<java.lang.Long> |
pfcount(byte[]... keys) |
Response<java.lang.Long> |
pfcount(java.lang.String... keys) |
Response<java.lang.String> |
pfmerge(byte[] destkey,
byte[]... sourcekeys) |
Response<java.lang.String> |
pfmerge(java.lang.String destkey,
java.lang.String... sourcekeys) |
Response<java.lang.String> |
ping() |
Response<java.lang.Long> |
publish(byte[] channel,
byte[] message) |
Response<java.lang.Long> |
publish(java.lang.String channel,
java.lang.String message) |
Response<java.lang.String> |
randomKey() |
Response<byte[]> |
randomKeyBinary() |
Response<java.lang.String> |
rename(byte[] oldkey,
byte[] newkey) |
Response<java.lang.String> |
rename(java.lang.String oldkey,
java.lang.String newkey) |
Response<java.lang.Long> |
renamenx(byte[] oldkey,
byte[] newkey) |
Response<java.lang.Long> |
renamenx(java.lang.String oldkey,
java.lang.String newkey) |
Response<byte[]> |
rpoplpush(byte[] srckey,
byte[] dstkey) |
Response<java.lang.String> |
rpoplpush(java.lang.String srckey,
java.lang.String dstkey) |
Response<java.lang.String> |
save() |
Response<java.util.Set<byte[]>> |
sdiff(byte[]... keys) |
Response<java.util.Set<java.lang.String>> |
sdiff(java.lang.String... keys) |
Response<java.lang.Long> |
sdiffstore(byte[] dstkey,
byte[]... keys) |
Response<java.lang.Long> |
sdiffstore(java.lang.String dstkey,
java.lang.String... keys) |
Response<java.lang.String> |
select(int index) |
Response<java.lang.Object> |
sendCommand(ProtocolCommand cmd,
byte[]... args) |
Response<java.lang.Object> |
sendCommand(ProtocolCommand cmd,
java.lang.String... args) |
Response<java.lang.String> |
shutdown() |
Response<java.util.Set<byte[]>> |
sinter(byte[]... keys) |
Response<java.util.Set<java.lang.String>> |
sinter(java.lang.String... keys) |
Response<java.lang.Long> |
sinterstore(byte[] dstkey,
byte[]... keys) |
Response<java.lang.Long> |
sinterstore(java.lang.String dstkey,
java.lang.String... keys) |
Response<java.lang.Long> |
smove(byte[] srckey,
byte[] dstkey,
byte[] member) |
Response<java.lang.Long> |
smove(java.lang.String srckey,
java.lang.String dstkey,
java.lang.String member) |
Response<java.lang.Long> |
sort(byte[] key,
byte[] dstkey) |
Response<java.lang.Long> |
sort(byte[] key,
SortingParams sortingParameters,
byte[] dstkey) |
Response<java.lang.Long> |
sort(java.lang.String key,
SortingParams sortingParameters,
java.lang.String dstkey) |
Response<java.lang.Long> |
sort(java.lang.String key,
java.lang.String dstkey) |
Response<java.util.Set<byte[]>> |
sunion(byte[]... keys) |
Response<java.util.Set<java.lang.String>> |
sunion(java.lang.String... keys) |
Response<java.lang.Long> |
sunionstore(byte[] dstkey,
byte[]... keys) |
Response<java.lang.Long> |
sunionstore(java.lang.String dstkey,
java.lang.String... keys) |
Response<java.lang.String> |
swapDB(int index1,
int index2) |
Response<java.util.List<java.lang.String>> |
time() |
Response<java.lang.Long> |
touch(byte[]... keys) |
Response<java.lang.Long> |
touch(java.lang.String... keys) |
Response<java.lang.Long> |
unlink(byte[]... keys) |
Response<java.lang.Long> |
unlink(java.lang.String... keys) |
Response<java.lang.String> |
unwatch() |
Response<java.lang.String> |
watch(byte[]... keys) |
Response<java.lang.String> |
watch(java.lang.String... keys) |
Response<java.util.List<java.util.Map.Entry<java.lang.String,java.util.List<StreamEntry>>>> |
xread(int count,
long block,
java.util.Map.Entry<java.lang.String,StreamEntryID>... streams) |
Response<java.util.List<byte[]>> |
xread(int count,
long block,
java.util.Map<byte[],byte[]> streams) |
Response<java.util.List<byte[]>> |
xread(XReadParams xReadParams,
java.util.Map.Entry<byte[],byte[]>... streams) |
Response<java.util.List<java.util.Map.Entry<java.lang.String,java.util.List<StreamEntry>>>> |
xread(XReadParams xReadParams,
java.util.Map<java.lang.String,StreamEntryID> streams) |
Response<java.util.List<byte[]>> |
xreadGroup(byte[] groupname,
byte[] consumer,
int count,
long block,
boolean noAck,
java.util.Map<byte[],byte[]> streams) |
Response<java.util.List<byte[]>> |
xreadGroup(byte[] groupname,
byte[] consumer,
XReadGroupParams xReadGroupParams,
java.util.Map.Entry<byte[],byte[]>... streams) |
Response<java.util.List<java.util.Map.Entry<java.lang.String,java.util.List<StreamEntry>>>> |
xreadGroup(java.lang.String groupname,
java.lang.String consumer,
int count,
long block,
boolean noAck,
java.util.Map.Entry<java.lang.String,StreamEntryID>... streams) |
Response<java.util.List<java.util.Map.Entry<java.lang.String,java.util.List<StreamEntry>>>> |
xreadGroup(java.lang.String groupname,
java.lang.String consumer,
XReadGroupParams xReadGroupParams,
java.util.Map<java.lang.String,StreamEntryID> streams) |
Response<java.util.Set<byte[]>> |
zdiff(byte[]... keys) |
Response<java.util.Set<java.lang.String>> |
zdiff(java.lang.String... keys) |
Response<java.lang.Long> |
zdiffStore(byte[] dstkey,
byte[]... keys) |
Response<java.lang.Long> |
zdiffStore(java.lang.String dstkey,
java.lang.String... keys) |
Response<java.util.Set<Tuple>> |
zdiffWithScores(byte[]... keys) |
Response<java.util.Set<Tuple>> |
zdiffWithScores(java.lang.String... keys) |
Response<java.util.Set<byte[]>> |
zinter(ZParams params,
byte[]... keys) |
Response<java.util.Set<java.lang.String>> |
zinter(ZParams params,
java.lang.String... keys) |
Response<java.lang.Long> |
zinterstore(byte[] dstkey,
byte[]... sets) |
Response<java.lang.Long> |
zinterstore(byte[] dstkey,
ZParams params,
byte[]... sets) |
Response<java.lang.Long> |
zinterstore(java.lang.String dstkey,
java.lang.String... sets) |
Response<java.lang.Long> |
zinterstore(java.lang.String dstkey,
ZParams params,
java.lang.String... sets) |
Response<java.util.Set<Tuple>> |
zinterWithScores(ZParams params,
byte[]... keys) |
Response<java.util.Set<Tuple>> |
zinterWithScores(ZParams params,
java.lang.String... keys) |
Response<java.util.Set<byte[]>> |
zunion(ZParams params,
byte[]... keys) |
Response<java.util.Set<java.lang.String>> |
zunion(ZParams params,
java.lang.String... keys) |
Response<java.lang.Long> |
zunionstore(byte[] dstkey,
byte[]... sets) |
Response<java.lang.Long> |
zunionstore(byte[] dstkey,
ZParams params,
byte[]... sets) |
Response<java.lang.Long> |
zunionstore(java.lang.String dstkey,
java.lang.String... sets) |
Response<java.lang.Long> |
zunionstore(java.lang.String dstkey,
ZParams params,
java.lang.String... sets) |
Response<java.util.Set<Tuple>> |
zunionWithScores(ZParams params,
byte[]... keys) |
Response<java.util.Set<Tuple>> |
zunionWithScores(ZParams params,
java.lang.String... keys) |
append, append, bitcount, bitcount, bitcount, bitcount, bitfield, bitfield, bitfieldReadonly, bitfieldReadonly, bitpos, bitpos, bitpos, bitpos, blpop, blpop, brpop, brpop, decr, decr, decrBy, decrBy, del, del, dump, dump, echo, echo, exists, exists, expire, expire, expireAt, expireAt, 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, georadiusReadonly, georadiusReadonly, georadiusReadonly, georadiusReadonly, get, get, getbit, getbit, getDel, getDel, getEx, getEx, getrange, getrange, getSet, getSet, hdel, hdel, hexists, hexists, hget, hget, hgetAll, hgetAll, hincrBy, hincrBy, hincrByFloat, hincrByFloat, hkeys, hkeys, hlen, hlen, hmget, hmget, hmset, hmset, hrandfield, hrandfield, hrandfield, hrandfield, hrandfieldWithValues, hrandfieldWithValues, hset, hset, hset, hset, hsetnx, hsetnx, hstrlen, hstrlen, hvals, hvals, incr, incr, incrBy, incrBy, incrByFloat, incrByFloat, lindex, lindex, linsert, linsert, llen, llen, lpop, lpop, lpop, lpop, lpos, lpos, lpos, lpos, lpos, lpos, lpush, lpush, lpushx, lpushx, lrange, lrange, lrem, lrem, lset, lset, ltrim, ltrim, migrate, migrate, move, move, objectEncoding, objectEncoding, objectFreq, objectFreq, objectIdletime, objectIdletime, objectRefcount, objectRefcount, persist, persist, pexpire, pexpire, pexpireAt, pexpireAt, pfadd, pfadd, pfcount, pfcount, psetex, psetex, pttl, pttl, restore, restore, restore, restore, restoreReplace, restoreReplace, rpop, rpop, rpop, rpop, rpush, rpush, rpushx, rpushx, sadd, sadd, scard, scard, sendCommand, sendCommand, set, set, set, set, setbit, setbit, setex, setex, setnx, setnx, setrange, setrange, sismember, sismember, smembers, smembers, smismember, smismember, sort, sort, sort, sort, spop, spop, spop, spop, srandmember, srandmember, srandmember, srandmember, srem, srem, strlen, strlen, substr, substr, touch, touch, ttl, ttl, type, type, unlink, unlink, xack, xack, xadd, xadd, xadd, xadd, xadd, xadd, xclaim, xclaim, xclaim, xclaim, xclaimJustId, xclaimJustId, xdel, xdel, xgroupCreate, xgroupCreate, xgroupDelConsumer, xgroupDelConsumer, xgroupDestroy, xgroupDestroy, xgroupSetID, xgroupSetID, xlen, xlen, xpending, xpending, xpending, xpending, xpending, xpending, xpendingBinary, xrange, xrange, xrange, xrange, xrevrange, xrevrange, xrevrange, xrevrange, xtrim, xtrim, xtrim, xtrim, zadd, zadd, zadd, zadd, zadd, zadd, zadd, zadd, zaddIncr, zaddIncr, zcard, zcard, zcount, zcount, zcount, zcount, zincrby, zincrby, zincrby, zincrby, zlexcount, zlexcount, zmscore, zmscore, zpopmax, zpopmax, zpopmax, zpopmax, zpopmin, zpopmin, zpopmin, zpopmin, zrandmember, zrandmember, zrandmember, zrandmember, zrandmemberWithScores, zrandmemberWithScores, zrange, zrange, zrangeByLex, zrangeByLex, zrangeByLex, zrangeByLex, zrangeByScore, zrangeByScore, zrangeByScore, zrangeByScore, zrangeByScore, zrangeByScore, zrangeByScore, zrangeByScore, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeByScoreWithScores, zrangeWithScores, zrangeWithScores, zrank, zrank, 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, zscore, zscoremigrateexpire, restore, restoreReplace, setexexpire, restore, restoreReplace, setexpublic Response<java.lang.Boolean> copy(byte[] srcKey, byte[] dstKey, int db, boolean replace)
copy 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.lang.Boolean> copy(byte[] srcKey, byte[] dstKey, boolean replace)
copy 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.lang.Boolean> copy(java.lang.String srcKey, java.lang.String dstKey, int db, boolean replace)
copy 在接口中 MultiKeyCommandsPipelinepublic Response<java.lang.Boolean> copy(java.lang.String srcKey, java.lang.String dstKey, boolean replace)
copy 在接口中 MultiKeyCommandsPipelinepublic Response<java.lang.String> lmove(java.lang.String srcKey, java.lang.String dstKey, ListDirection from, ListDirection to)
lmove 在接口中 MultiKeyCommandsPipelinepublic Response<byte[]> lmove(byte[] srcKey, byte[] dstKey, ListDirection from, ListDirection to)
lmove 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.lang.String> blmove(java.lang.String srcKey, java.lang.String dstKey, ListDirection from, ListDirection to, double timeout)
blmove 在接口中 MultiKeyCommandsPipelinepublic Response<byte[]> blmove(byte[] srcKey, byte[] dstKey, ListDirection from, ListDirection to, double timeout)
blmove 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.util.List<java.lang.String>> blpop(java.lang.String... args)
blpop 在接口中 MultiKeyCommandsPipelinepublic Response<java.util.List<byte[]>> blpop(byte[]... args)
blpop 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.util.List<java.lang.String>> blpop(int timeout, java.lang.String... keys)
blpop 在接口中 MultiKeyCommandsPipeline@Deprecated public Response<java.util.Map<java.lang.String,java.lang.String>> blpopMap(int timeout, java.lang.String... keys)
@Deprecated public Response<java.util.List<java.lang.String>> blpop(int timeout, byte[]... keys)
public Response<KeyedListElement> blpop(double timeout, java.lang.String... keys)
blpop 在接口中 MultiKeyCommandsPipelinepublic Response<java.util.List<byte[]>> blpop(double timeout, byte[]... keys)
blpop 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.util.List<java.lang.String>> brpop(java.lang.String... args)
brpop 在接口中 MultiKeyCommandsPipelinepublic Response<java.util.List<byte[]>> brpop(byte[]... args)
brpop 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.util.List<java.lang.String>> brpop(int timeout, java.lang.String... keys)
brpop 在接口中 MultiKeyCommandsPipeline@Deprecated public Response<java.util.Map<java.lang.String,java.lang.String>> brpopMap(int timeout, java.lang.String... keys)
@Deprecated public Response<java.util.List<java.lang.String>> brpop(int timeout, byte[]... keys)
public Response<KeyedListElement> brpop(double timeout, java.lang.String... keys)
brpop 在接口中 MultiKeyCommandsPipelinepublic Response<java.util.List<byte[]>> brpop(double timeout, byte[]... keys)
brpop 在接口中 MultiKeyBinaryRedisPipelinepublic Response<KeyedZSetElement> bzpopmax(double timeout, java.lang.String... keys)
bzpopmax 在接口中 MultiKeyCommandsPipelinepublic Response<java.util.List<byte[]>> bzpopmax(double timeout, byte[]... keys)
bzpopmax 在接口中 MultiKeyBinaryRedisPipelinepublic Response<KeyedZSetElement> bzpopmin(double timeout, java.lang.String... keys)
bzpopmin 在接口中 MultiKeyCommandsPipelinepublic Response<java.util.List<byte[]>> bzpopmin(double timeout, byte[]... keys)
bzpopmin 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.lang.Long> del(java.lang.String... keys)
del 在接口中 MultiKeyCommandsPipelinepublic Response<java.lang.Long> del(byte[]... keys)
del 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.lang.Long> unlink(java.lang.String... keys)
unlink 在接口中 MultiKeyCommandsPipelinepublic Response<java.lang.Long> unlink(byte[]... keys)
unlink 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.lang.Long> exists(java.lang.String... keys)
exists 在接口中 MultiKeyCommandsPipelinepublic Response<java.lang.Long> exists(byte[]... keys)
exists 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.util.Set<java.lang.String>> keys(java.lang.String pattern)
keys 在接口中 MultiKeyCommandsPipelinepublic Response<java.util.Set<byte[]>> keys(byte[] pattern)
keys 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.util.List<java.lang.String>> mget(java.lang.String... keys)
mget 在接口中 MultiKeyCommandsPipelinepublic Response<java.util.List<byte[]>> mget(byte[]... keys)
mget 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.lang.String> mset(java.lang.String... keysvalues)
mset 在接口中 MultiKeyCommandsPipelinepublic Response<java.lang.String> mset(byte[]... keysvalues)
mset 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.lang.Long> msetnx(java.lang.String... keysvalues)
msetnx 在接口中 MultiKeyCommandsPipelinepublic Response<java.lang.Long> msetnx(byte[]... keysvalues)
msetnx 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.lang.String> rename(java.lang.String oldkey, java.lang.String newkey)
rename 在接口中 MultiKeyCommandsPipelinepublic Response<java.lang.String> rename(byte[] oldkey, byte[] newkey)
rename 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.lang.Long> renamenx(java.lang.String oldkey, java.lang.String newkey)
renamenx 在接口中 MultiKeyCommandsPipelinepublic Response<java.lang.Long> renamenx(byte[] oldkey, byte[] newkey)
renamenx 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.lang.String> rpoplpush(java.lang.String srckey, java.lang.String dstkey)
rpoplpush 在接口中 MultiKeyCommandsPipelinepublic Response<byte[]> rpoplpush(byte[] srckey, byte[] dstkey)
rpoplpush 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.util.Set<java.lang.String>> sdiff(java.lang.String... keys)
sdiff 在接口中 MultiKeyCommandsPipelinepublic Response<java.util.Set<byte[]>> sdiff(byte[]... keys)
sdiff 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.lang.Long> sdiffstore(java.lang.String dstkey, java.lang.String... keys)
sdiffstore 在接口中 MultiKeyCommandsPipelinepublic Response<java.lang.Long> sdiffstore(byte[] dstkey, byte[]... keys)
sdiffstore 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.util.Set<java.lang.String>> sinter(java.lang.String... keys)
sinter 在接口中 MultiKeyCommandsPipelinepublic Response<java.util.Set<byte[]>> sinter(byte[]... keys)
sinter 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.lang.Long> sinterstore(java.lang.String dstkey, java.lang.String... keys)
sinterstore 在接口中 MultiKeyCommandsPipelinepublic Response<java.lang.Long> sinterstore(byte[] dstkey, byte[]... keys)
sinterstore 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.lang.Long> smove(java.lang.String srckey, java.lang.String dstkey, java.lang.String member)
smove 在接口中 MultiKeyCommandsPipelinepublic Response<java.lang.Long> smove(byte[] srckey, byte[] dstkey, byte[] member)
smove 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.lang.Long> sort(java.lang.String key, SortingParams sortingParameters, java.lang.String dstkey)
sort 在接口中 MultiKeyCommandsPipelinepublic Response<java.lang.Long> sort(byte[] key, SortingParams sortingParameters, byte[] dstkey)
sort 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.lang.Long> sort(java.lang.String key, java.lang.String dstkey)
sort 在接口中 MultiKeyCommandsPipelinepublic Response<java.lang.Long> sort(byte[] key, byte[] dstkey)
sort 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.util.Set<java.lang.String>> sunion(java.lang.String... keys)
sunion 在接口中 MultiKeyCommandsPipelinepublic Response<java.util.Set<byte[]>> sunion(byte[]... keys)
sunion 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.lang.Long> sunionstore(java.lang.String dstkey, java.lang.String... keys)
sunionstore 在接口中 MultiKeyCommandsPipelinepublic Response<java.lang.Long> sunionstore(byte[] dstkey, byte[]... keys)
sunionstore 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.lang.String> watch(java.lang.String... keys)
watch 在接口中 MultiKeyCommandsPipelinepublic Response<java.lang.String> watch(byte[]... keys)
watch 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.lang.String> unwatch()
unwatch 在接口中 MultiKeyBinaryRedisPipelineunwatch 在接口中 MultiKeyCommandsPipelinepublic Response<java.util.Set<byte[]>> zdiff(byte[]... keys)
zdiff 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.util.Set<Tuple>> zdiffWithScores(byte[]... keys)
zdiffWithScores 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.util.Set<java.lang.String>> zdiff(java.lang.String... keys)
zdiff 在接口中 MultiKeyCommandsPipelinepublic Response<java.util.Set<Tuple>> zdiffWithScores(java.lang.String... keys)
zdiffWithScores 在接口中 MultiKeyCommandsPipelinepublic Response<java.lang.Long> zdiffStore(byte[] dstkey, byte[]... keys)
zdiffStore 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.lang.Long> zdiffStore(java.lang.String dstkey, java.lang.String... keys)
zdiffStore 在接口中 MultiKeyCommandsPipelinepublic Response<java.util.Set<byte[]>> zinter(ZParams params, byte[]... keys)
zinter 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.util.Set<Tuple>> zinterWithScores(ZParams params, byte[]... keys)
zinterWithScores 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.util.Set<java.lang.String>> zinter(ZParams params, java.lang.String... keys)
zinter 在接口中 MultiKeyCommandsPipelinepublic Response<java.util.Set<Tuple>> zinterWithScores(ZParams params, java.lang.String... keys)
zinterWithScores 在接口中 MultiKeyCommandsPipelinepublic Response<java.lang.Long> zinterstore(java.lang.String dstkey, java.lang.String... sets)
zinterstore 在接口中 MultiKeyCommandsPipelinepublic Response<java.lang.Long> zinterstore(byte[] dstkey, byte[]... sets)
zinterstore 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.lang.Long> zinterstore(java.lang.String dstkey, ZParams params, java.lang.String... sets)
zinterstore 在接口中 MultiKeyCommandsPipelinepublic Response<java.lang.Long> zinterstore(byte[] dstkey, ZParams params, byte[]... sets)
zinterstore 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.util.Set<byte[]>> zunion(ZParams params, byte[]... keys)
zunion 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.util.Set<Tuple>> zunionWithScores(ZParams params, byte[]... keys)
zunionWithScores 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.util.Set<java.lang.String>> zunion(ZParams params, java.lang.String... keys)
zunion 在接口中 MultiKeyCommandsPipelinepublic Response<java.util.Set<Tuple>> zunionWithScores(ZParams params, java.lang.String... keys)
zunionWithScores 在接口中 MultiKeyCommandsPipelinepublic Response<java.lang.Long> zunionstore(java.lang.String dstkey, java.lang.String... sets)
zunionstore 在接口中 MultiKeyCommandsPipelinepublic Response<java.lang.Long> zunionstore(byte[] dstkey, byte[]... sets)
zunionstore 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.lang.Long> zunionstore(java.lang.String dstkey, ZParams params, java.lang.String... sets)
zunionstore 在接口中 MultiKeyCommandsPipelinepublic Response<java.lang.Long> zunionstore(byte[] dstkey, ZParams params, byte[]... sets)
zunionstore 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.lang.String> bgrewriteaof()
bgrewriteaof 在接口中 BasicRedisPipelinepublic Response<java.lang.String> bgsave()
bgsave 在接口中 BasicRedisPipelinepublic Response<java.util.List<java.lang.String>> configGet(java.lang.String pattern)
configGet 在接口中 BasicRedisPipelinepublic Response<java.lang.String> configSet(java.lang.String parameter, java.lang.String value)
configSet 在接口中 BasicRedisPipelinepublic Response<java.lang.String> brpoplpush(java.lang.String source, java.lang.String destination, int timeout)
brpoplpush 在接口中 MultiKeyCommandsPipelinepublic Response<byte[]> brpoplpush(byte[] source, byte[] destination, int timeout)
brpoplpush 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.lang.String> configResetStat()
configResetStat 在接口中 BasicRedisPipelinepublic Response<java.lang.String> save()
save 在接口中 BasicRedisPipelinepublic Response<java.lang.Long> lastsave()
lastsave 在接口中 BasicRedisPipelinepublic Response<java.lang.Long> publish(java.lang.String channel, java.lang.String message)
publish 在接口中 MultiKeyCommandsPipelinepublic Response<java.lang.Long> publish(byte[] channel, byte[] message)
publish 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.lang.String> randomKey()
randomKey 在接口中 MultiKeyCommandsPipelinepublic Response<byte[]> randomKeyBinary()
randomKeyBinary 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.lang.String> flushDB()
flushDB 在接口中 BasicRedisPipelinepublic Response<java.lang.String> flushAll()
flushAll 在接口中 BasicRedisPipelinepublic Response<java.lang.String> flushDB(FlushMode flushMode)
flushDB 在接口中 BasicRedisPipelinepublic Response<java.lang.String> flushAll(FlushMode flushMode)
flushAll 在接口中 BasicRedisPipelinepublic Response<java.lang.String> info()
info 在接口中 BasicRedisPipelinepublic Response<java.lang.String> info(java.lang.String section)
public Response<java.lang.Long> dbSize()
dbSize 在接口中 BasicRedisPipelinepublic Response<java.lang.String> shutdown()
shutdown 在接口中 BasicRedisPipelinepublic Response<java.lang.String> ping()
ping 在接口中 BasicRedisPipelinepublic Response<java.lang.String> select(int index)
select 在接口中 BasicRedisPipelinepublic Response<java.lang.String> swapDB(int index1, int index2)
swapDB 在接口中 BasicRedisPipelinepublic Response<java.lang.Long> bitop(BitOP op, byte[] destKey, byte[]... srcKeys)
bitop 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.lang.Long> bitop(BitOP op, java.lang.String destKey, java.lang.String... srcKeys)
bitop 在接口中 MultiKeyCommandsPipelinepublic Response<java.lang.String> clusterNodes()
clusterNodes 在接口中 ClusterPipelinepublic Response<java.lang.String> clusterMeet(java.lang.String ip, int port)
clusterMeet 在接口中 ClusterPipelinepublic Response<java.lang.String> clusterAddSlots(int... slots)
clusterAddSlots 在接口中 ClusterPipelinepublic Response<java.lang.String> clusterDelSlots(int... slots)
clusterDelSlots 在接口中 ClusterPipelinepublic Response<java.lang.String> clusterInfo()
clusterInfo 在接口中 ClusterPipelinepublic Response<java.util.List<java.lang.String>> clusterGetKeysInSlot(int slot, int count)
clusterGetKeysInSlot 在接口中 ClusterPipelinepublic Response<java.lang.String> clusterSetSlotNode(int slot, java.lang.String nodeId)
clusterSetSlotNode 在接口中 ClusterPipelinepublic Response<java.lang.String> clusterSetSlotMigrating(int slot, java.lang.String nodeId)
clusterSetSlotMigrating 在接口中 ClusterPipelinepublic Response<java.lang.String> clusterSetSlotImporting(int slot, java.lang.String nodeId)
clusterSetSlotImporting 在接口中 ClusterPipelinepublic Response<java.lang.Object> eval(java.lang.String script)
eval 在接口中 ScriptingCommandsPipelinepublic Response<java.lang.Object> eval(java.lang.String script, java.util.List<java.lang.String> keys, java.util.List<java.lang.String> args)
eval 在接口中 ScriptingCommandsPipelinepublic Response<java.lang.Object> eval(java.lang.String script, int keyCount, java.lang.String... params)
eval 在接口中 ScriptingCommandsPipelinepublic Response<java.lang.Object> evalsha(java.lang.String sha1)
evalsha 在接口中 ScriptingCommandsPipelinepublic Response<java.lang.Object> evalsha(java.lang.String sha1, java.util.List<java.lang.String> keys, java.util.List<java.lang.String> args)
evalsha 在接口中 ScriptingCommandsPipelinepublic Response<java.lang.Object> evalsha(java.lang.String sha1, int keyCount, java.lang.String... params)
evalsha 在接口中 ScriptingCommandsPipelinepublic Response<java.lang.Object> eval(byte[] script)
eval 在接口中 BinaryScriptingCommandsPipelinepublic Response<java.lang.Object> eval(byte[] script, byte[] keyCount, byte[]... params)
eval 在接口中 BinaryScriptingCommandsPipelinepublic Response<java.lang.Object> eval(byte[] script, java.util.List<byte[]> keys, java.util.List<byte[]> args)
eval 在接口中 BinaryScriptingCommandsPipelinepublic Response<java.lang.Object> eval(byte[] script, int keyCount, byte[]... params)
eval 在接口中 BinaryScriptingCommandsPipelinepublic Response<java.lang.Object> evalsha(byte[] sha1)
evalsha 在接口中 BinaryScriptingCommandsPipelinepublic Response<java.lang.Object> evalsha(byte[] sha1, java.util.List<byte[]> keys, java.util.List<byte[]> args)
evalsha 在接口中 BinaryScriptingCommandsPipelinepublic Response<java.lang.Object> evalsha(byte[] sha1, int keyCount, byte[]... params)
evalsha 在接口中 BinaryScriptingCommandsPipelinepublic Response<java.lang.Long> pfcount(java.lang.String... keys)
pfcount 在接口中 MultiKeyCommandsPipelinepublic Response<java.lang.Long> pfcount(byte[]... keys)
pfcount 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.lang.String> pfmerge(byte[] destkey, byte[]... sourcekeys)
pfmerge 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.lang.String> pfmerge(java.lang.String destkey, java.lang.String... sourcekeys)
pfmerge 在接口中 MultiKeyCommandsPipelinepublic Response<java.util.List<java.lang.String>> time()
time 在接口中 BasicRedisPipelinepublic Response<java.lang.Long> touch(java.lang.String... keys)
touch 在接口中 MultiKeyCommandsPipelinepublic Response<java.lang.Long> touch(byte[]... keys)
touch 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.lang.String> moduleUnload(java.lang.String name)
moduleUnload 在接口中 BasicRedisPipelinepublic Response<java.util.List<Module>> moduleList()
moduleList 在接口中 BasicRedisPipelinepublic Response<java.lang.String> moduleLoad(java.lang.String path)
moduleLoad 在接口中 BasicRedisPipelinepublic Response<java.lang.String> migrate(java.lang.String host, int port, int destinationDB, int timeout, MigrateParams params, java.lang.String... keys)
migrate 在接口中 MultiKeyCommandsPipelinepublic Response<java.lang.String> migrate(java.lang.String host, int port, int destinationDB, int timeout, MigrateParams params, byte[]... keys)
migrate 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.lang.Object> sendCommand(ProtocolCommand cmd, java.lang.String... args)
public Response<java.lang.Object> sendCommand(ProtocolCommand cmd, byte[]... args)
public Response<java.lang.Long> georadiusStore(java.lang.String key, double longitude, double latitude, double radius, GeoUnit unit, GeoRadiusParam param, GeoRadiusStoreParam storeParam)
georadiusStore 在接口中 MultiKeyCommandsPipelinepublic Response<java.lang.Long> georadiusStore(byte[] key, double longitude, double latitude, double radius, GeoUnit unit, GeoRadiusParam param, GeoRadiusStoreParam storeParam)
georadiusStore 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.lang.Long> georadiusByMemberStore(byte[] key, byte[] member, double radius, GeoUnit unit, GeoRadiusParam param, GeoRadiusStoreParam storeParam)
public Response<java.lang.Long> georadiusByMemberStore(java.lang.String key, java.lang.String member, double radius, GeoUnit unit, GeoRadiusParam param, GeoRadiusStoreParam storeParam)
public Response<java.util.List<byte[]>> xread(int count, long block, java.util.Map<byte[],byte[]> streams)
xread 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.util.List<byte[]>> xread(XReadParams xReadParams, java.util.Map.Entry<byte[],byte[]>... streams)
xread 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.util.List<byte[]>> xreadGroup(byte[] groupname, byte[] consumer, int count, long block, boolean noAck, java.util.Map<byte[],byte[]> streams)
xreadGroup 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.util.List<byte[]>> xreadGroup(byte[] groupname, byte[] consumer, XReadGroupParams xReadGroupParams, java.util.Map.Entry<byte[],byte[]>... streams)
xreadGroup 在接口中 MultiKeyBinaryRedisPipelinepublic Response<java.util.List<java.util.Map.Entry<java.lang.String,java.util.List<StreamEntry>>>> xread(int count, long block, java.util.Map.Entry<java.lang.String,StreamEntryID>... streams)
xread 在接口中 MultiKeyCommandsPipelinepublic Response<java.util.List<java.util.Map.Entry<java.lang.String,java.util.List<StreamEntry>>>> xread(XReadParams xReadParams, java.util.Map<java.lang.String,StreamEntryID> streams)
xread 在接口中 MultiKeyCommandsPipelinepublic Response<java.util.List<java.util.Map.Entry<java.lang.String,java.util.List<StreamEntry>>>> xreadGroup(java.lang.String groupname, java.lang.String consumer, int count, long block, boolean noAck, java.util.Map.Entry<java.lang.String,StreamEntryID>... streams)
xreadGroup 在接口中 MultiKeyCommandsPipelinepublic Response<java.util.List<java.util.Map.Entry<java.lang.String,java.util.List<StreamEntry>>>> xreadGroup(java.lang.String groupname, java.lang.String consumer, XReadGroupParams xReadGroupParams, java.util.Map<java.lang.String,StreamEntryID> streams)
xreadGroup 在接口中 MultiKeyCommandsPipeline