redis.clients.jedis
Class Pipeline
java.lang.Object
redis.clients.jedis.Queable
redis.clients.jedis.Pipeline
- Direct Known Subclasses:
- PipelineBlock
public class Pipeline
- extends Queable
Method Summary |
Response<Long> |
append(byte[] key,
byte[] value)
|
Response<Long> |
append(String key,
String value)
|
Response<String> |
bgrewriteaof()
|
Response<String> |
bgsave()
|
Response<List<String>> |
blpop(byte[]... args)
|
Response<List<String>> |
blpop(String... args)
|
Response<List<String>> |
brpop(byte[]... args)
|
Response<List<String>> |
brpop(String... args)
|
Response<String> |
brpoplpush(byte[] source,
byte[] destination,
int timeout)
|
Response<String> |
brpoplpush(String source,
String destination,
int timeout)
|
Response<String> |
configGet(String pattern)
|
Response<String> |
configResetStat()
|
Response<String> |
configSet(String parameter,
String value)
|
Response<Long> |
dbSize()
|
Response<Long> |
decr(byte[] key)
|
Response<Long> |
decr(String key)
|
Response<Long> |
decrBy(byte[] key,
long integer)
|
Response<Long> |
decrBy(String key,
long integer)
|
Response<Long> |
del(byte[]... keys)
|
Response<Long> |
del(String... keys)
|
Response<String> |
discard()
|
Response<String> |
echo(byte[] string)
|
Response<String> |
echo(String string)
|
Response<List<Object>> |
exec()
|
Response<Boolean> |
exists(byte[] key)
|
Response<Boolean> |
exists(String key)
|
Response<Long> |
expire(byte[] key,
int seconds)
|
Response<Long> |
expire(String key,
int seconds)
|
Response<Long> |
expireAt(byte[] key,
long unixTime)
|
Response<Long> |
expireAt(String key,
long unixTime)
|
Response<String> |
flushAll()
|
Response<String> |
flushDB()
|
Response<byte[]> |
get(byte[] key)
|
Response<String> |
get(String key)
|
Response<Boolean> |
getbit(String key,
long offset)
|
Response<String> |
getrange(String key,
long startOffset,
long endOffset)
|
protected
|
getResponse(Builder<T> builder)
|
Response<byte[]> |
getSet(byte[] key,
byte[] value)
|
Response<String> |
getSet(String key,
String value)
|
Response<Long> |
hdel(byte[] key,
byte[] field)
|
Response<Long> |
hdel(String key,
String field)
|
Response<Boolean> |
hexists(byte[] key,
byte[] field)
|
Response<Boolean> |
hexists(String key,
String field)
|
Response<String> |
hget(byte[] key,
byte[] field)
|
Response<String> |
hget(String key,
String field)
|
Response<Map<String,String>> |
hgetAll(byte[] key)
|
Response<Map<String,String>> |
hgetAll(String key)
|
Response<Long> |
hincrBy(byte[] key,
byte[] field,
long value)
|
Response<Long> |
hincrBy(String key,
String field,
long value)
|
Response<Set<String>> |
hkeys(byte[] key)
|
Response<Set<String>> |
hkeys(String key)
|
Response<Long> |
hlen(byte[] key)
|
Response<Long> |
hlen(String key)
|
Response<List<String>> |
hmget(byte[] key,
byte[]... fields)
|
Response<List<String>> |
hmget(String key,
String... fields)
|
Response<String> |
hmset(byte[] key,
Map<byte[],byte[]> hash)
|
Response<String> |
hmset(String key,
Map<String,String> hash)
|
Response<Long> |
hset(byte[] key,
byte[] field,
byte[] value)
|
Response<Long> |
hset(String key,
String field,
String value)
|
Response<Long> |
hsetnx(byte[] key,
byte[] field,
byte[] value)
|
Response<Long> |
hsetnx(String key,
String field,
String value)
|
Response<List<String>> |
hvals(byte[] key)
|
Response<List<String>> |
hvals(String key)
|
Response<Long> |
incr(byte[] key)
|
Response<Long> |
incr(String key)
|
Response<Long> |
incrBy(byte[] key,
long integer)
|
Response<Long> |
incrBy(String key,
long integer)
|
Response<String> |
info()
|
Response<Set<String>> |
keys(byte[] pattern)
|
Response<Set<String>> |
keys(String pattern)
|
Response<Long> |
lastsave()
|
Response<String> |
lindex(byte[] key,
int index)
|
Response<String> |
lindex(String key,
int index)
|
Response<Long> |
linsert(byte[] key,
BinaryClient.LIST_POSITION where,
byte[] pivot,
byte[] value)
|
Response<Long> |
linsert(String key,
BinaryClient.LIST_POSITION where,
String pivot,
String value)
|
Response<Long> |
llen(byte[] key)
|
Response<Long> |
llen(String key)
|
Response<String> |
lpop(byte[] key)
|
Response<String> |
lpop(String key)
|
Response<Long> |
lpush(byte[] key,
byte[] string)
|
Response<Long> |
lpush(String key,
String string)
|
Response<Long> |
lpushx(byte[] key,
byte[] bytes)
|
Response<Long> |
lpushx(String key,
String string)
|
Response<List<String>> |
lrange(byte[] key,
long start,
long end)
|
Response<List<String>> |
lrange(String key,
long start,
long end)
|
Response<Long> |
lrem(byte[] key,
long count,
byte[] value)
|
Response<Long> |
lrem(String key,
long count,
String value)
|
Response<String> |
lset(byte[] key,
long index,
byte[] value)
|
Response<String> |
lset(String key,
long index,
String value)
|
Response<String> |
ltrim(byte[] key,
long start,
long end)
|
Response<String> |
ltrim(String key,
long start,
long end)
|
Response<List<String>> |
mget(byte[]... keys)
|
Response<List<String>> |
mget(String... keys)
|
Response<Long> |
move(byte[] key,
int dbIndex)
|
Response<Long> |
move(String key,
int dbIndex)
|
Response<String> |
mset(byte[]... keysvalues)
|
Response<String> |
mset(String... keysvalues)
|
Response<Long> |
msetnx(byte[]... keysvalues)
|
Response<Long> |
msetnx(String... keysvalues)
|
void |
multi()
|
Response<Long> |
persist(byte[] key)
|
Response<Long> |
persist(String key)
|
Response<String> |
ping()
|
Response<Long> |
publish(byte[] channel,
byte[] message)
|
Response<Long> |
publish(String channel,
String message)
|
Response<String> |
randomKey()
|
Response<String> |
rename(byte[] oldkey,
byte[] newkey)
|
Response<String> |
rename(String oldkey,
String newkey)
|
Response<Long> |
renamenx(byte[] oldkey,
byte[] newkey)
|
Response<Long> |
renamenx(String oldkey,
String newkey)
|
Response<String> |
rpop(byte[] key)
|
Response<String> |
rpop(String key)
|
Response<String> |
rpoplpush(byte[] srckey,
byte[] dstkey)
|
Response<String> |
rpoplpush(String srckey,
String dstkey)
|
Response<Long> |
rpush(byte[] key,
byte[] string)
|
Response<Long> |
rpush(String key,
String string)
|
Response<Long> |
rpushx(byte[] key,
byte[] string)
|
Response<Long> |
rpushx(String key,
String string)
|
Response<Long> |
sadd(byte[] key,
byte[] member)
|
Response<Long> |
sadd(String key,
String member)
|
Response<String> |
save()
|
Response<Long> |
scard(byte[] key)
|
Response<Long> |
scard(String key)
|
Response<Set<String>> |
sdiff(byte[]... keys)
|
Response<Set<String>> |
sdiff(String... keys)
|
Response<Long> |
sdiffstore(byte[] dstkey,
byte[]... keys)
|
Response<Long> |
sdiffstore(String dstkey,
String... keys)
|
Response<String> |
select(int index)
|
Response<String> |
set(byte[] key,
byte[] value)
|
Response<String> |
set(String key,
String value)
|
Response<Boolean> |
setbit(String key,
long offset,
boolean value)
|
void |
setClient(Client client)
|
Response<String> |
setex(byte[] key,
int seconds,
byte[] value)
|
Response<String> |
setex(String key,
int seconds,
String value)
|
Response<Long> |
setnx(byte[] key,
byte[] value)
|
Response<Long> |
setnx(String key,
String value)
|
Response<Long> |
setrange(String key,
long offset,
String value)
|
Response<String> |
shutdown()
|
Response<Set<String>> |
sinter(byte[]... keys)
|
Response<Set<String>> |
sinter(String... keys)
|
Response<Long> |
sinterstore(byte[] dstkey,
byte[]... keys)
|
Response<Long> |
sinterstore(String dstkey,
String... keys)
|
Response<Boolean> |
sismember(byte[] key,
byte[] member)
|
Response<Boolean> |
sismember(String key,
String member)
|
Response<Set<String>> |
smembers(byte[] key)
|
Response<Set<String>> |
smembers(String key)
|
Response<Long> |
smove(byte[] srckey,
byte[] dstkey,
byte[] member)
|
Response<Long> |
smove(String srckey,
String dstkey,
String member)
|
Response<Long> |
sort(byte[] key)
|
Response<List<String>> |
sort(byte[] key,
byte[] dstkey)
|
Response<List<String>> |
sort(byte[] key,
SortingParams sortingParameters)
|
Response<List<String>> |
sort(byte[] key,
SortingParams sortingParameters,
byte[] dstkey)
|
Response<Long> |
sort(String key)
|
Response<List<String>> |
sort(String key,
SortingParams sortingParameters)
|
Response<List<String>> |
sort(String key,
SortingParams sortingParameters,
String dstkey)
|
Response<List<String>> |
sort(String key,
String dstkey)
|
Response<String> |
spop(byte[] key)
|
Response<String> |
spop(String key)
|
Response<String> |
srandmember(byte[] key)
|
Response<String> |
srandmember(String key)
|
Response<Long> |
srem(byte[] key,
byte[] member)
|
Response<Long> |
srem(String key,
String member)
|
Response<Long> |
strlen(byte[] key)
|
Response<Long> |
strlen(String key)
|
Response<String> |
substr(byte[] key,
int start,
int end)
|
Response<String> |
substr(String key,
int start,
int end)
|
Response<Set<String>> |
sunion(byte[]... keys)
|
Response<Set<String>> |
sunion(String... keys)
|
Response<Long> |
sunionstore(byte[] dstkey,
byte[]... keys)
|
Response<Long> |
sunionstore(String dstkey,
String... keys)
|
void |
sync()
Syncronize pipeline by reading all responses. |
List<Object> |
syncAndReturnAll()
Syncronize pipeline by reading all responses. |
Response<Long> |
ttl(byte[] key)
|
Response<Long> |
ttl(String key)
|
Response<String> |
type(byte[] key)
|
Response<String> |
type(String key)
|
Response<String> |
watch(byte[]... keys)
|
Response<String> |
watch(String... keys)
|
Response<Long> |
zadd(byte[] key,
double score,
byte[] member)
|
Response<Long> |
zadd(String key,
double score,
String member)
|
Response<Long> |
zcard(byte[] key)
|
Response<Long> |
zcard(String key)
|
Response<Long> |
zcount(byte[] key,
double min,
double max)
|
Response<Long> |
zcount(String key,
double min,
double max)
|
Response<Double> |
zincrby(byte[] key,
double score,
byte[] member)
|
Response<Double> |
zincrby(String key,
double score,
String member)
|
Response<Long> |
zinterstore(byte[] dstkey,
byte[]... sets)
|
Response<Long> |
zinterstore(byte[] dstkey,
ZParams params,
byte[]... sets)
|
Response<Long> |
zinterstore(String dstkey,
String... sets)
|
Response<Long> |
zinterstore(String dstkey,
ZParams params,
String... sets)
|
Response<Set<String>> |
zrange(byte[] key,
int start,
int end)
|
Response<Set<String>> |
zrange(String key,
int start,
int end)
|
Response<Set<String>> |
zrangeByScore(byte[] key,
byte[] min,
byte[] max)
|
Response<Set<String>> |
zrangeByScore(byte[] key,
byte[] min,
byte[] max,
int offset,
int count)
|
Response<Set<String>> |
zrangeByScore(byte[] key,
double min,
double max)
|
Response<Set<String>> |
zrangeByScore(byte[] key,
double min,
double max,
int offset,
int count)
|
Response<Set<String>> |
zrangeByScore(String key,
double min,
double max)
|
Response<Set<String>> |
zrangeByScore(String key,
double min,
double max,
int offset,
int count)
|
Response<Set<String>> |
zrangeByScore(String key,
String min,
String max)
|
Response<Set<Tuple>> |
zrangeByScoreWithScores(byte[] key,
byte[] min,
byte[] max)
|
Response<Set<Tuple>> |
zrangeByScoreWithScores(byte[] key,
byte[] min,
byte[] max,
int offset,
int count)
|
Response<Set<Tuple>> |
zrangeByScoreWithScores(byte[] key,
double min,
double max)
|
Response<Set<Tuple>> |
zrangeByScoreWithScores(byte[] key,
double min,
double max,
int offset,
int count)
|
Response<Set<Tuple>> |
zrangeByScoreWithScores(String key,
double min,
double max)
|
Response<Set<Tuple>> |
zrangeByScoreWithScores(String key,
double min,
double max,
int offset,
int count)
|
Response<Set<Tuple>> |
zrangeWithScores(byte[] key,
int start,
int end)
|
Response<Set<Tuple>> |
zrangeWithScores(String key,
int start,
int end)
|
Response<Long> |
zrank(byte[] key,
byte[] member)
|
Response<Long> |
zrank(String key,
String member)
|
Response<Long> |
zrem(byte[] key,
byte[] member)
|
Response<Long> |
zrem(String key,
String member)
|
Response<Long> |
zremrangeByRank(byte[] key,
int start,
int end)
|
Response<Long> |
zremrangeByRank(String key,
int start,
int end)
|
Response<Long> |
zremrangeByScore(byte[] key,
byte[] start,
byte[] end)
|
Response<Long> |
zremrangeByScore(byte[] key,
double start,
double end)
|
Response<Long> |
zremrangeByScore(String key,
double start,
double end)
|
Response<Set<String>> |
zrevrange(byte[] key,
int start,
int end)
|
Response<Set<String>> |
zrevrange(String key,
int start,
int end)
|
Response<Set<String>> |
zrevrangeByScore(byte[] key,
byte[] max,
byte[] min)
|
Response<Set<String>> |
zrevrangeByScore(byte[] key,
byte[] max,
byte[] min,
int offset,
int count)
|
Response<Set<String>> |
zrevrangeByScore(byte[] key,
double max,
double min)
|
Response<Set<String>> |
zrevrangeByScore(byte[] key,
double max,
double min,
int offset,
int count)
|
Response<Set<String>> |
zrevrangeByScore(String key,
double max,
double min)
|
Response<Set<String>> |
zrevrangeByScore(String key,
double max,
double min,
int offset,
int count)
|
Response<Set<String>> |
zrevrangeByScore(String key,
String max,
String min)
|
Response<Set<Tuple>> |
zrevrangeByScoreWithScores(byte[] key,
byte[] max,
byte[] min)
|
Response<Set<Tuple>> |
zrevrangeByScoreWithScores(byte[] key,
byte[] max,
byte[] min,
int offset,
int count)
|
Response<Set<Tuple>> |
zrevrangeByScoreWithScores(byte[] key,
double max,
double min)
|
Response<Set<Tuple>> |
zrevrangeByScoreWithScores(byte[] key,
double max,
double min,
int offset,
int count)
|
Response<Set<Tuple>> |
zrevrangeByScoreWithScores(String key,
double max,
double min)
|
Response<Set<Tuple>> |
zrevrangeByScoreWithScores(String key,
double max,
double min,
int offset,
int count)
|
Response<Set<Tuple>> |
zrevrangeWithScores(byte[] key,
int start,
int end)
|
Response<Set<Tuple>> |
zrevrangeWithScores(String key,
int start,
int end)
|
Response<Long> |
zrevrank(byte[] key,
byte[] member)
|
Response<Long> |
zrevrank(String key,
String member)
|
Response<Double> |
zscore(byte[] key,
byte[] member)
|
Response<Double> |
zscore(String key,
String member)
|
Response<Long> |
zunionstore(byte[] dstkey,
byte[]... sets)
|
Response<Long> |
zunionstore(byte[] dstkey,
ZParams params,
byte[]... sets)
|
Response<Long> |
zunionstore(String dstkey,
String... sets)
|
Response<Long> |
zunionstore(String dstkey,
ZParams params,
String... sets)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Pipeline
public Pipeline()
getResponse
protected <T> Response<T> getResponse(Builder<T> builder)
- Overrides:
getResponse
in class Queable
setClient
public void setClient(Client client)
sync
public void sync()
- Syncronize pipeline by reading all responses. This operation close the
pipeline. In order to get return values from pipelined commands, capture
the different Response> of the commands you execute.
syncAndReturnAll
public List<Object> syncAndReturnAll()
- Syncronize pipeline by reading all responses. This operation close the
pipeline. Whenever possible try to avoid using this version and use
Pipeline.sync() as it won't go through all the responses and generate the
right response type (usually it is a waste of time).
- Returns:
- A list of all the responses in the order you executed them.
- See Also:
sync
append
public Response<Long> append(String key,
String value)
append
public Response<Long> append(byte[] key,
byte[] value)
blpop
public Response<List<String>> blpop(String... args)
blpop
public Response<List<String>> blpop(byte[]... args)
brpop
public Response<List<String>> brpop(String... args)
brpop
public Response<List<String>> brpop(byte[]... args)
decr
public Response<Long> decr(String key)
decr
public Response<Long> decr(byte[] key)
decrBy
public Response<Long> decrBy(String key,
long integer)
decrBy
public Response<Long> decrBy(byte[] key,
long integer)
del
public Response<Long> del(String... keys)
del
public Response<Long> del(byte[]... keys)
echo
public Response<String> echo(String string)
echo
public Response<String> echo(byte[] string)
exists
public Response<Boolean> exists(String key)
exists
public Response<Boolean> exists(byte[] key)
expire
public Response<Long> expire(String key,
int seconds)
expire
public Response<Long> expire(byte[] key,
int seconds)
expireAt
public Response<Long> expireAt(String key,
long unixTime)
expireAt
public Response<Long> expireAt(byte[] key,
long unixTime)
get
public Response<String> get(String key)
get
public Response<byte[]> get(byte[] key)
getbit
public Response<Boolean> getbit(String key,
long offset)
getrange
public Response<String> getrange(String key,
long startOffset,
long endOffset)
getSet
public Response<String> getSet(String key,
String value)
getSet
public Response<byte[]> getSet(byte[] key,
byte[] value)
hdel
public Response<Long> hdel(String key,
String field)
hdel
public Response<Long> hdel(byte[] key,
byte[] field)
hexists
public Response<Boolean> hexists(String key,
String field)
hexists
public Response<Boolean> hexists(byte[] key,
byte[] field)
hget
public Response<String> hget(String key,
String field)
hget
public Response<String> hget(byte[] key,
byte[] field)
hgetAll
public Response<Map<String,String>> hgetAll(String key)
hgetAll
public Response<Map<String,String>> hgetAll(byte[] key)
hincrBy
public Response<Long> hincrBy(String key,
String field,
long value)
hincrBy
public Response<Long> hincrBy(byte[] key,
byte[] field,
long value)
hkeys
public Response<Set<String>> hkeys(String key)
hkeys
public Response<Set<String>> hkeys(byte[] key)
hlen
public Response<Long> hlen(String key)
hlen
public Response<Long> hlen(byte[] key)
hmget
public Response<List<String>> hmget(String key,
String... fields)
hmget
public Response<List<String>> hmget(byte[] key,
byte[]... fields)
hmset
public Response<String> hmset(String key,
Map<String,String> hash)
hmset
public Response<String> hmset(byte[] key,
Map<byte[],byte[]> hash)
hset
public Response<Long> hset(String key,
String field,
String value)
hset
public Response<Long> hset(byte[] key,
byte[] field,
byte[] value)
hsetnx
public Response<Long> hsetnx(String key,
String field,
String value)
hsetnx
public Response<Long> hsetnx(byte[] key,
byte[] field,
byte[] value)
hvals
public Response<List<String>> hvals(String key)
hvals
public Response<List<String>> hvals(byte[] key)
incr
public Response<Long> incr(String key)
incr
public Response<Long> incr(byte[] key)
incrBy
public Response<Long> incrBy(String key,
long integer)
incrBy
public Response<Long> incrBy(byte[] key,
long integer)
keys
public Response<Set<String>> keys(String pattern)
keys
public Response<Set<String>> keys(byte[] pattern)
lindex
public Response<String> lindex(String key,
int index)
lindex
public Response<String> lindex(byte[] key,
int index)
linsert
public Response<Long> linsert(String key,
BinaryClient.LIST_POSITION where,
String pivot,
String value)
linsert
public Response<Long> linsert(byte[] key,
BinaryClient.LIST_POSITION where,
byte[] pivot,
byte[] value)
llen
public Response<Long> llen(String key)
llen
public Response<Long> llen(byte[] key)
lpop
public Response<String> lpop(String key)
lpop
public Response<String> lpop(byte[] key)
lpush
public Response<Long> lpush(String key,
String string)
lpush
public Response<Long> lpush(byte[] key,
byte[] string)
lpushx
public Response<Long> lpushx(String key,
String string)
lpushx
public Response<Long> lpushx(byte[] key,
byte[] bytes)
lrange
public Response<List<String>> lrange(String key,
long start,
long end)
lrange
public Response<List<String>> lrange(byte[] key,
long start,
long end)
lrem
public Response<Long> lrem(String key,
long count,
String value)
lrem
public Response<Long> lrem(byte[] key,
long count,
byte[] value)
lset
public Response<String> lset(String key,
long index,
String value)
lset
public Response<String> lset(byte[] key,
long index,
byte[] value)
ltrim
public Response<String> ltrim(String key,
long start,
long end)
ltrim
public Response<String> ltrim(byte[] key,
long start,
long end)
mget
public Response<List<String>> mget(String... keys)
mget
public Response<List<String>> mget(byte[]... keys)
move
public Response<Long> move(String key,
int dbIndex)
move
public Response<Long> move(byte[] key,
int dbIndex)
mset
public Response<String> mset(String... keysvalues)
mset
public Response<String> mset(byte[]... keysvalues)
msetnx
public Response<Long> msetnx(String... keysvalues)
msetnx
public Response<Long> msetnx(byte[]... keysvalues)
persist
public Response<Long> persist(String key)
persist
public Response<Long> persist(byte[] key)
rename
public Response<String> rename(String oldkey,
String newkey)
rename
public Response<String> rename(byte[] oldkey,
byte[] newkey)
renamenx
public Response<Long> renamenx(String oldkey,
String newkey)
renamenx
public Response<Long> renamenx(byte[] oldkey,
byte[] newkey)
rpop
public Response<String> rpop(String key)
rpop
public Response<String> rpop(byte[] key)
rpoplpush
public Response<String> rpoplpush(String srckey,
String dstkey)
rpoplpush
public Response<String> rpoplpush(byte[] srckey,
byte[] dstkey)
rpush
public Response<Long> rpush(String key,
String string)
rpush
public Response<Long> rpush(byte[] key,
byte[] string)
rpushx
public Response<Long> rpushx(String key,
String string)
rpushx
public Response<Long> rpushx(byte[] key,
byte[] string)
sadd
public Response<Long> sadd(String key,
String member)
sadd
public Response<Long> sadd(byte[] key,
byte[] member)
scard
public Response<Long> scard(String key)
scard
public Response<Long> scard(byte[] key)
sdiff
public Response<Set<String>> sdiff(String... keys)
sdiff
public Response<Set<String>> sdiff(byte[]... keys)
sdiffstore
public Response<Long> sdiffstore(String dstkey,
String... keys)
sdiffstore
public Response<Long> sdiffstore(byte[] dstkey,
byte[]... keys)
set
public Response<String> set(String key,
String value)
set
public Response<String> set(byte[] key,
byte[] value)
setbit
public Response<Boolean> setbit(String key,
long offset,
boolean value)
setex
public Response<String> setex(String key,
int seconds,
String value)
setex
public Response<String> setex(byte[] key,
int seconds,
byte[] value)
setnx
public Response<Long> setnx(String key,
String value)
setnx
public Response<Long> setnx(byte[] key,
byte[] value)
setrange
public Response<Long> setrange(String key,
long offset,
String value)
sinter
public Response<Set<String>> sinter(String... keys)
sinter
public Response<Set<String>> sinter(byte[]... keys)
sinterstore
public Response<Long> sinterstore(String dstkey,
String... keys)
sinterstore
public Response<Long> sinterstore(byte[] dstkey,
byte[]... keys)
sismember
public Response<Boolean> sismember(String key,
String member)
sismember
public Response<Boolean> sismember(byte[] key,
byte[] member)
smembers
public Response<Set<String>> smembers(String key)
smembers
public Response<Set<String>> smembers(byte[] key)
smove
public Response<Long> smove(String srckey,
String dstkey,
String member)
smove
public Response<Long> smove(byte[] srckey,
byte[] dstkey,
byte[] member)
sort
public Response<Long> sort(String key)
sort
public Response<Long> sort(byte[] key)
sort
public Response<List<String>> sort(String key,
SortingParams sortingParameters)
sort
public Response<List<String>> sort(byte[] key,
SortingParams sortingParameters)
sort
public Response<List<String>> sort(String key,
SortingParams sortingParameters,
String dstkey)
sort
public Response<List<String>> sort(byte[] key,
SortingParams sortingParameters,
byte[] dstkey)
sort
public Response<List<String>> sort(String key,
String dstkey)
sort
public Response<List<String>> sort(byte[] key,
byte[] dstkey)
spop
public Response<String> spop(String key)
spop
public Response<String> spop(byte[] key)
srandmember
public Response<String> srandmember(String key)
srandmember
public Response<String> srandmember(byte[] key)
srem
public Response<Long> srem(String key,
String member)
srem
public Response<Long> srem(byte[] key,
byte[] member)
strlen
public Response<Long> strlen(String key)
strlen
public Response<Long> strlen(byte[] key)
substr
public Response<String> substr(String key,
int start,
int end)
substr
public Response<String> substr(byte[] key,
int start,
int end)
sunion
public Response<Set<String>> sunion(String... keys)
sunion
public Response<Set<String>> sunion(byte[]... keys)
sunionstore
public Response<Long> sunionstore(String dstkey,
String... keys)
sunionstore
public Response<Long> sunionstore(byte[] dstkey,
byte[]... keys)
ttl
public Response<Long> ttl(String key)
ttl
public Response<Long> ttl(byte[] key)
type
public Response<String> type(String key)
type
public Response<String> type(byte[] key)
watch
public Response<String> watch(String... keys)
watch
public Response<String> watch(byte[]... keys)
zadd
public Response<Long> zadd(String key,
double score,
String member)
zadd
public Response<Long> zadd(byte[] key,
double score,
byte[] member)
zcard
public Response<Long> zcard(String key)
zcard
public Response<Long> zcard(byte[] key)
zcount
public Response<Long> zcount(String key,
double min,
double max)
zcount
public Response<Long> zcount(byte[] key,
double min,
double max)
zincrby
public Response<Double> zincrby(String key,
double score,
String member)
zincrby
public Response<Double> zincrby(byte[] key,
double score,
byte[] member)
zinterstore
public Response<Long> zinterstore(String dstkey,
String... sets)
zinterstore
public Response<Long> zinterstore(byte[] dstkey,
byte[]... sets)
zinterstore
public Response<Long> zinterstore(String dstkey,
ZParams params,
String... sets)
zinterstore
public Response<Long> zinterstore(byte[] dstkey,
ZParams params,
byte[]... sets)
zrange
public Response<Set<String>> zrange(String key,
int start,
int end)
zrange
public Response<Set<String>> zrange(byte[] key,
int start,
int end)
zrangeByScore
public Response<Set<String>> zrangeByScore(String key,
double min,
double max)
zrangeByScore
public Response<Set<String>> zrangeByScore(byte[] key,
double min,
double max)
zrangeByScore
public Response<Set<String>> zrangeByScore(String key,
String min,
String max)
zrangeByScore
public Response<Set<String>> zrangeByScore(byte[] key,
byte[] min,
byte[] max)
zrangeByScore
public Response<Set<String>> zrangeByScore(String key,
double min,
double max,
int offset,
int count)
zrangeByScore
public Response<Set<String>> zrangeByScore(byte[] key,
double min,
double max,
int offset,
int count)
zrangeByScore
public Response<Set<String>> zrangeByScore(byte[] key,
byte[] min,
byte[] max,
int offset,
int count)
zrangeByScoreWithScores
public Response<Set<Tuple>> zrangeByScoreWithScores(String key,
double min,
double max)
zrangeByScoreWithScores
public Response<Set<Tuple>> zrangeByScoreWithScores(byte[] key,
double min,
double max)
zrangeByScoreWithScores
public Response<Set<Tuple>> zrangeByScoreWithScores(byte[] key,
byte[] min,
byte[] max)
zrangeByScoreWithScores
public Response<Set<Tuple>> zrangeByScoreWithScores(String key,
double min,
double max,
int offset,
int count)
zrangeByScoreWithScores
public Response<Set<Tuple>> zrangeByScoreWithScores(byte[] key,
double min,
double max,
int offset,
int count)
zrangeByScoreWithScores
public Response<Set<Tuple>> zrangeByScoreWithScores(byte[] key,
byte[] min,
byte[] max,
int offset,
int count)
zrevrangeByScore
public Response<Set<String>> zrevrangeByScore(String key,
double max,
double min)
zrevrangeByScore
public Response<Set<String>> zrevrangeByScore(byte[] key,
double max,
double min)
zrevrangeByScore
public Response<Set<String>> zrevrangeByScore(String key,
String max,
String min)
zrevrangeByScore
public Response<Set<String>> zrevrangeByScore(byte[] key,
byte[] max,
byte[] min)
zrevrangeByScore
public Response<Set<String>> zrevrangeByScore(String key,
double max,
double min,
int offset,
int count)
zrevrangeByScore
public Response<Set<String>> zrevrangeByScore(byte[] key,
double max,
double min,
int offset,
int count)
zrevrangeByScore
public Response<Set<String>> zrevrangeByScore(byte[] key,
byte[] max,
byte[] min,
int offset,
int count)
zrevrangeByScoreWithScores
public Response<Set<Tuple>> zrevrangeByScoreWithScores(String key,
double max,
double min)
zrevrangeByScoreWithScores
public Response<Set<Tuple>> zrevrangeByScoreWithScores(byte[] key,
double max,
double min)
zrevrangeByScoreWithScores
public Response<Set<Tuple>> zrevrangeByScoreWithScores(byte[] key,
byte[] max,
byte[] min)
zrevrangeByScoreWithScores
public Response<Set<Tuple>> zrevrangeByScoreWithScores(String key,
double max,
double min,
int offset,
int count)
zrevrangeByScoreWithScores
public Response<Set<Tuple>> zrevrangeByScoreWithScores(byte[] key,
double max,
double min,
int offset,
int count)
zrevrangeByScoreWithScores
public Response<Set<Tuple>> zrevrangeByScoreWithScores(byte[] key,
byte[] max,
byte[] min,
int offset,
int count)
zrangeWithScores
public Response<Set<Tuple>> zrangeWithScores(String key,
int start,
int end)
zrangeWithScores
public Response<Set<Tuple>> zrangeWithScores(byte[] key,
int start,
int end)
zrank
public Response<Long> zrank(String key,
String member)
zrank
public Response<Long> zrank(byte[] key,
byte[] member)
zrem
public Response<Long> zrem(String key,
String member)
zrem
public Response<Long> zrem(byte[] key,
byte[] member)
zremrangeByRank
public Response<Long> zremrangeByRank(String key,
int start,
int end)
zremrangeByRank
public Response<Long> zremrangeByRank(byte[] key,
int start,
int end)
zremrangeByScore
public Response<Long> zremrangeByScore(String key,
double start,
double end)
zremrangeByScore
public Response<Long> zremrangeByScore(byte[] key,
double start,
double end)
zremrangeByScore
public Response<Long> zremrangeByScore(byte[] key,
byte[] start,
byte[] end)
zrevrange
public Response<Set<String>> zrevrange(String key,
int start,
int end)
zrevrange
public Response<Set<String>> zrevrange(byte[] key,
int start,
int end)
zrevrangeWithScores
public Response<Set<Tuple>> zrevrangeWithScores(String key,
int start,
int end)
zrevrangeWithScores
public Response<Set<Tuple>> zrevrangeWithScores(byte[] key,
int start,
int end)
zrevrank
public Response<Long> zrevrank(String key,
String member)
zrevrank
public Response<Long> zrevrank(byte[] key,
byte[] member)
zscore
public Response<Double> zscore(String key,
String member)
zscore
public Response<Double> zscore(byte[] key,
byte[] member)
zunionstore
public Response<Long> zunionstore(String dstkey,
String... sets)
zunionstore
public Response<Long> zunionstore(byte[] dstkey,
byte[]... sets)
zunionstore
public Response<Long> zunionstore(String dstkey,
ZParams params,
String... sets)
zunionstore
public Response<Long> zunionstore(byte[] dstkey,
ZParams params,
byte[]... sets)
bgrewriteaof
public Response<String> bgrewriteaof()
bgsave
public Response<String> bgsave()
configGet
public Response<String> configGet(String pattern)
configSet
public Response<String> configSet(String parameter,
String value)
brpoplpush
public Response<String> brpoplpush(String source,
String destination,
int timeout)
brpoplpush
public Response<String> brpoplpush(byte[] source,
byte[] destination,
int timeout)
configResetStat
public Response<String> configResetStat()
save
public Response<String> save()
lastsave
public Response<Long> lastsave()
discard
public Response<String> discard()
exec
public Response<List<Object>> exec()
multi
public void multi()
publish
public Response<Long> publish(String channel,
String message)
publish
public Response<Long> publish(byte[] channel,
byte[] message)
flushDB
public Response<String> flushDB()
flushAll
public Response<String> flushAll()
info
public Response<String> info()
dbSize
public Response<Long> dbSize()
shutdown
public Response<String> shutdown()
ping
public Response<String> ping()
randomKey
public Response<String> randomKey()
select
public Response<String> select(int index)
Copyright © 2012. All Rights Reserved.