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

Constructor Summary

Pipeline()

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 <T> Response<T>	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 redis.clients.jedis.Queable

clean, generateResponse

Methods inherited from class java.lang.Object

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

Constructor Detail

Pipeline

public Pipeline()

Method Detail

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)