public interface MultiKeyCommandsPipeline
限定符和类型 | 方法和说明 |
---|---|
Response<java.lang.Long> |
bitop(BitOP op,
java.lang.String destKey,
java.lang.String... srcKeys) |
Response<java.lang.String> |
blmove(java.lang.String srcKey,
java.lang.String dstKey,
ListDirection from,
ListDirection to,
double timeout) |
Response<KeyedListElement> |
blpop(double timeout,
java.lang.String... args) |
Response<java.util.List<java.lang.String>> |
blpop(int timeout,
java.lang.String... args) |
Response<java.util.List<java.lang.String>> |
blpop(java.lang.String... args) |
Response<KeyedListElement> |
brpop(double timeout,
java.lang.String... args) |
Response<java.util.List<java.lang.String>> |
brpop(int timeout,
java.lang.String... args) |
Response<java.util.List<java.lang.String>> |
brpop(java.lang.String... args) |
Response<java.lang.String> |
brpoplpush(java.lang.String source,
java.lang.String destination,
int timeout) |
Response<KeyedZSetElement> |
bzpopmax(double timeout,
java.lang.String... keys) |
Response<KeyedZSetElement> |
bzpopmin(double timeout,
java.lang.String... keys) |
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> |
del(java.lang.String... keys) |
Response<java.lang.Long> |
exists(java.lang.String... keys) |
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(java.lang.String key,
double longitude,
double latitude,
double radius,
GeoUnit unit,
GeoRadiusParam param,
GeoRadiusStoreParam storeParam) |
Response<java.util.Set<java.lang.String>> |
keys(java.lang.String pattern) |
Response<java.lang.String> |
lmove(java.lang.String srcKey,
java.lang.String dstKey,
ListDirection from,
ListDirection to) |
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,
java.lang.String... keys) |
Response<java.lang.String> |
mset(java.lang.String... keysvalues) |
Response<java.lang.Long> |
msetnx(java.lang.String... keysvalues) |
Response<java.lang.Long> |
pfcount(java.lang.String... keys) |
Response<java.lang.String> |
pfmerge(java.lang.String destkey,
java.lang.String... sourcekeys) |
Response<java.lang.Long> |
publish(java.lang.String channel,
java.lang.String message) |
Response<java.lang.String> |
randomKey() |
Response<java.lang.String> |
rename(java.lang.String oldkey,
java.lang.String newkey) |
Response<java.lang.Long> |
renamenx(java.lang.String oldkey,
java.lang.String newkey) |
Response<java.lang.String> |
rpoplpush(java.lang.String srckey,
java.lang.String dstkey) |
Response<java.util.Set<java.lang.String>> |
sdiff(java.lang.String... keys) |
Response<java.lang.Long> |
sdiffstore(java.lang.String dstkey,
java.lang.String... keys) |
Response<java.util.Set<java.lang.String>> |
sinter(java.lang.String... keys) |
Response<java.lang.Long> |
sinterstore(java.lang.String dstkey,
java.lang.String... keys) |
Response<java.lang.Long> |
smove(java.lang.String srckey,
java.lang.String dstkey,
java.lang.String member) |
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<java.lang.String>> |
sunion(java.lang.String... keys) |
Response<java.lang.Long> |
sunionstore(java.lang.String dstkey,
java.lang.String... keys) |
Response<java.lang.Long> |
touch(java.lang.String... keys) |
Response<java.lang.Long> |
unlink(java.lang.String... keys) |
Response<java.lang.String> |
unwatch() |
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<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<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<java.lang.String>> |
zdiff(java.lang.String... keys) |
Response<java.lang.Long> |
zdiffStore(java.lang.String dstkey,
java.lang.String... keys) |
Response<java.util.Set<Tuple>> |
zdiffWithScores(java.lang.String... keys) |
Response<java.util.Set<java.lang.String>> |
zinter(ZParams params,
java.lang.String... keys) |
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,
java.lang.String... keys) |
Response<java.util.Set<java.lang.String>> |
zunion(ZParams params,
java.lang.String... keys) |
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,
java.lang.String... keys) |
Response<java.lang.Boolean> copy(java.lang.String srcKey, java.lang.String dstKey, int db, boolean replace)
Response<java.lang.Boolean> copy(java.lang.String srcKey, java.lang.String dstKey, boolean replace)
Response<java.lang.Long> del(java.lang.String... keys)
Response<java.lang.Long> unlink(java.lang.String... keys)
Response<java.lang.Long> exists(java.lang.String... keys)
Response<java.lang.String> lmove(java.lang.String srcKey, java.lang.String dstKey, ListDirection from, ListDirection to)
Response<java.lang.String> blmove(java.lang.String srcKey, java.lang.String dstKey, ListDirection from, ListDirection to, double timeout)
Response<java.util.List<java.lang.String>> blpop(java.lang.String... args)
Response<java.util.List<java.lang.String>> blpop(int timeout, java.lang.String... args)
Response<KeyedListElement> blpop(double timeout, java.lang.String... args)
Response<java.util.List<java.lang.String>> brpop(java.lang.String... args)
Response<java.util.List<java.lang.String>> brpop(int timeout, java.lang.String... args)
Response<KeyedListElement> brpop(double timeout, java.lang.String... args)
Response<KeyedZSetElement> bzpopmax(double timeout, java.lang.String... keys)
Response<KeyedZSetElement> bzpopmin(double timeout, java.lang.String... keys)
Response<java.util.Set<java.lang.String>> keys(java.lang.String pattern)
Response<java.util.List<java.lang.String>> mget(java.lang.String... keys)
Response<java.lang.String> mset(java.lang.String... keysvalues)
Response<java.lang.Long> msetnx(java.lang.String... keysvalues)
Response<java.lang.String> rename(java.lang.String oldkey, java.lang.String newkey)
Response<java.lang.Long> renamenx(java.lang.String oldkey, java.lang.String newkey)
Response<java.lang.String> rpoplpush(java.lang.String srckey, java.lang.String dstkey)
Response<java.util.Set<java.lang.String>> sdiff(java.lang.String... keys)
Response<java.lang.Long> sdiffstore(java.lang.String dstkey, java.lang.String... keys)
Response<java.util.Set<java.lang.String>> sinter(java.lang.String... keys)
Response<java.lang.Long> sinterstore(java.lang.String dstkey, java.lang.String... keys)
Response<java.lang.Long> smove(java.lang.String srckey, java.lang.String dstkey, java.lang.String member)
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<java.lang.String>> sunion(java.lang.String... keys)
Response<java.lang.Long> sunionstore(java.lang.String dstkey, java.lang.String... keys)
Response<java.lang.String> watch(java.lang.String... keys)
Response<java.lang.String> unwatch()
Response<java.util.Set<java.lang.String>> zdiff(java.lang.String... keys)
Response<java.lang.Long> zdiffStore(java.lang.String dstkey, java.lang.String... keys)
Response<java.util.Set<Tuple>> zinterWithScores(ZParams params, java.lang.String... keys)
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>> zunionWithScores(ZParams params, java.lang.String... keys)
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.lang.String> brpoplpush(java.lang.String source, java.lang.String destination, int timeout)
Response<java.lang.Long> publish(java.lang.String channel, java.lang.String message)
Response<java.lang.String> randomKey()
Response<java.lang.Long> bitop(BitOP op, java.lang.String destKey, java.lang.String... srcKeys)
Response<java.lang.String> pfmerge(java.lang.String destkey, java.lang.String... sourcekeys)
Response<java.lang.Long> pfcount(java.lang.String... keys)
Response<java.lang.Long> touch(java.lang.String... keys)
Response<java.lang.String> migrate(java.lang.String host, int port, int destinationDB, int timeout, MigrateParams params, java.lang.String... keys)
Response<java.lang.Long> georadiusStore(java.lang.String key, double longitude, double latitude, 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)
@Deprecated 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<java.util.Map.Entry<java.lang.String,java.util.List<StreamEntry>>>> xread(XReadParams xReadParams, java.util.Map<java.lang.String,StreamEntryID> streams)
@Deprecated 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)