org.jredis.ri.alphazero

Class JRedisFutureSupport

java.lang.Object

org.jredis.ri.alphazero.JRedisFutureSupport

All Implemented Interfaces:

JRedisFuture

Direct Known Subclasses:

JRedisAsyncClient, JRedisChunkedPipeline, JRedisPipeline

public abstract class JRedisFutureSupport
extends Object
implements JRedisFuture

[TODO: document me!]

Since:

alpha.0

Version:

alpha.0, Apr 10, 2009

Author:

Joubin Houshyar (alphazero@sensesay.net)

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	JRedisFutureSupport.FutureBit
static class	JRedisFutureSupport.FutureBoolean
static class	JRedisFutureSupport.FutureByteArray
static class	JRedisFutureSupport.FutureByteArrayList
static class	JRedisFutureSupport.FutureDataDictionary
static class	JRedisFutureSupport.FutureDouble
static class	JRedisFutureSupport.FutureInfo
static class	JRedisFutureSupport.FutureKeyList
static class	JRedisFutureSupport.FutureLong
static class	JRedisFutureSupport.FutureObjectInfo
static class	JRedisFutureSupport.FutureRedisType
static class	JRedisFutureSupport.FutureResultBase
static class	JRedisFutureSupport.FutureSortStoreResp
static class	JRedisFutureSupport.FutureStatus
static class	JRedisFutureSupport.FutureString
static class	JRedisFutureSupport.FutureZSetList

Field Summary

Fields

Modifier and Type	Field and Description
static boolean	CacheKeys

Constructor Summary

Constructors

Constructor and Description
JRedisFutureSupport()

Method Summary

Modifier and Type	Method and Description
<K> Future<Long>	append(K key, byte[] value)
<K> Future<Long>	append(K key, Number value)
<K> Future<Long>	append(K key, String value)
<K,T extends Serializable> Future<Long>	append(K key, T value)
<K> JRedisFutureSupport.FutureString	bgrewriteaof()
<K> JRedisFutureSupport.FutureStatus	bgsave()
<K> Future<Long>	dbsize()
<K> Future<ObjectInfo>	debug(K key)
<K> Future<Long>	decr(K key)
<K> Future<Long>	decrby(K key, int delta)
<K> Future<Long>	del(K... keys)
<K> Future<byte[]>	echo(byte[] msg)
<K> Future<byte[]>	echo(Number msg)
<K> Future<byte[]>	echo(String msg)
<K,T extends Serializable> Future<byte[]>	echo(T msg)
<K> Future<Boolean>	exists(K key)
<K> Future<Boolean>	expire(K key, int ttlseconds)
<K> Future<Boolean>	expireat(K key, long epochtime)
JRedisFutureSupport.FutureStatus	flush() Optional connection control command.
<K> JRedisFutureSupport.FutureStatus	flushall() Flushes all dbs in the connect Redis server, regardless of which db was selected on connect time.
<K> JRedisFutureSupport.FutureStatus	flushdb() Flushes the db you selected when connecting to Redis server.
<K> Future<byte[]>	get(K key)
<K> Future<Boolean>	getbit(K key, int offset)
<K> Future<byte[]>	getset(K key, byte[] value)
<K> Future<byte[]>	getset(K key, Number value)
<K> Future<byte[]>	getset(K key, String value)
<K,T extends Serializable> Future<byte[]>	getset(K key, T value)
<K> Future<Boolean>	hdel(K key, K entry)
<K> Future<Boolean>	hexists(K key, K entry)
<K> Future<byte[]>	hget(K key, K entry)
<K> Future<Map<byte[],byte[]>>	hgetall(K key)
<K> Future<Long>	hincrby(K key, K field, long increment)
<K> Future<List<byte[]>>	hkeys(K key)
<K> Future<Long>	hlen(K key)
<K> Future<Boolean>	hset(K key, K field, byte[] value)
<K> Future<Boolean>	hset(K key, K field, Number numberValue)
<K> Future<Boolean>	hset(K key, K field, String stringValue)
<K,T extends Serializable> Future<Boolean>	hset(K key, K field, T object)
<K> Future<List<byte[]>>	hvals(K key)
<K> Future<Long>	incr(K key)
<K> Future<Long>	incrby(K key, int delta)
<K> Future<Map<String,String>>	info()
<K> Future<List<byte[]>>	keys() Convenience method.
<K> Future<List<byte[]>>	keys(K pattern)
<K> Future<Long>	keystolist(String pattern, String listname)
<K> Future<Long>	lastsave()
<K> Future<byte[]>	lindex(K key, long index)
<K> JRedisFutureSupport.FutureLong	linsert(K key, boolean after, byte[] oldvalue, byte[] newvalue)
<K> JRedisFutureSupport.FutureLong	linsertAfter(K key, byte[] oldvalue, byte[] newvalue)
<K> JRedisFutureSupport.FutureLong	linsertBefore(K key, byte[] oldvalue, byte[] newvalue)
<K> Future<Long>	llen(K key) Given a 'list' key, returns the number of items in the list.
<K> Future<byte[]>	lpop(K key)
<K> JRedisFutureSupport.FutureLong	lpush(K key, byte[] value)
<K> JRedisFutureSupport.FutureLong	lpush(K key, Number value)
<K> JRedisFutureSupport.FutureLong	lpush(K key, String value)
<K,T extends Serializable> JRedisFutureSupport.FutureLong	lpush(K key, T value)
<K> JRedisFutureSupport.FutureLong	lpushx(K key, byte[] value)
<K> Future<List<byte[]>>	lrange(K key, long from, long to)
<K> Future<Long>	lrem(K key, byte[] value, int count)
<K> Future<Long>	lrem(K listKey, Number numberValue, int count)
<K> Future<Long>	lrem(K listKey, String value, int count)
<K,T extends Serializable> Future<Long>	lrem(K listKey, T object, int count)
<K> JRedisFutureSupport.FutureStatus	lset(K key, long index, byte[] value)
<K> JRedisFutureSupport.FutureStatus	lset(K key, long index, Number numberValue)
<K> JRedisFutureSupport.FutureStatus	lset(K key, long index, String value)
<K,T extends Serializable> JRedisFutureSupport.FutureStatus	lset(K key, long index, T object)
<K> JRedisFutureSupport.FutureStatus	ltrim(K key, long keepFrom, long keepTo)
<K> Future<List<byte[]>>	mget(String... keys)
<K> Future<Boolean>	move(K key, int dbIndex) Moves the given key from the currently selected db to the one indicated by dbIndex.
<K> JRedisFutureSupport.FutureStatus	mset(KeyValueSet.ByteArrays<K> keyValueMap)
<K> JRedisFutureSupport.FutureStatus	mset(KeyValueSet.Numbers<K> keyValueMap)
<K,T extends Serializable> JRedisFutureSupport.FutureStatus	mset(KeyValueSet.Objects<K,T> keyValueMap)
<K> JRedisFutureSupport.FutureStatus	mset(KeyValueSet.Strings<K> keyValueMap)
<K> JRedisFutureSupport.FutureStatus	mset(Map<K,byte[]> keyValueMap)
<K> Future<Boolean>	msetnx(KeyValueSet.ByteArrays<K> keyValueMap)
<K> Future<Boolean>	msetnx(KeyValueSet.Numbers<K> keyValueMap)
<K,T extends Serializable> Future<Boolean>	msetnx(KeyValueSet.Objects<K,T> keyValueMap)
<K> Future<Boolean>	msetnx(KeyValueSet.Strings<K> keyValueMap)
<K> Future<Boolean>	msetnx(Map<K,byte[]> keyValueMap)
<K> JRedisFutureSupport.FutureStatus	ping() Ping redis
protected abstract Future<Response>	queueRequest(Command cmd, byte[]... args) This method mimics the eponymous Connection#queueRequest(Command, byte[]...) which defines the blocking api semantics of Synchronous connections.
<K> JRedisFutureSupport.FutureStatus	quit() Disconnects the client.
<K> Future<byte[]>	randomkey()
<K> JRedisFutureSupport.FutureStatus	rename(K oldkey, K newkey)
<K> Future<Boolean>	renamenx(K oldkey, K newkey)
<K> Future<byte[]>	rpop(K key)
<K> JRedisFutureSupport.FutureByteArray	rpoplpush(String srcList, String destList)
<K> JRedisFutureSupport.FutureLong	rpush(K key, byte[] value)
<K> JRedisFutureSupport.FutureLong	rpush(K key, Number value)
<K> JRedisFutureSupport.FutureLong	rpush(K key, String value)
<K,T extends Serializable> JRedisFutureSupport.FutureLong	rpush(K key, T value)
<K> JRedisFutureSupport.FutureLong	rpushx(K key, byte[] value)
<K> Future<Boolean>	sadd(K key, byte[] member)
<K> Future<Boolean>	sadd(K key, Number value)
<K> Future<Boolean>	sadd(K key, String value)
<K,T extends Serializable> Future<Boolean>	sadd(K key, T value)
<K> JRedisFutureSupport.FutureStatus	save()
<K> Future<Long>	scard(K key)
<K> Future<List<byte[]>>	sdiff(K set1, K... sets)
<K> JRedisFutureSupport.FutureStatus	sdiffstore(K dest, K... sets)
<K> JRedisFutureSupport.FutureStatus	set(K key, byte[] value) Bind the value to key.
<K> JRedisFutureSupport.FutureStatus	set(K key, Number value) Convenient method for String numeric values binding
<K> JRedisFutureSupport.FutureStatus	set(K key, String value) Convenient method for String data binding
<K,T extends Serializable> JRedisFutureSupport.FutureStatus	set(K key, T value) Binds the given java Object to the key.
<K> Future<Boolean>	setbit(K key, int offset, boolean value)
<K> Future<Boolean>	setnx(K key, byte[] value)
<K> Future<Boolean>	setnx(K key, Number value)
<K> Future<Boolean>	setnx(K key, String value)
<K,T extends Serializable> Future<Boolean>	setnx(K key, T value)
<K> Future<List<byte[]>>	sinter(K set1, K... sets)
<K> JRedisFutureSupport.FutureStatus	sinterstore(K dest, K... sets)
<K> Future<Boolean>	sismember(K key, byte[] member)
<K> Future<Boolean>	sismember(K key, Number numberValue)
<K> Future<Boolean>	sismember(K key, String value)
<K,T extends Serializable> Future<Boolean>	sismember(K key, T object)
<K> Future<ResponseStatus>	slaveof(String host, int port)
<K> Future<ResponseStatus>	slaveofnone() Convenience method.
<K> Future<List<byte[]>>	smembers(K key)
<K> Future<Boolean>	smove(K srcKey, K destKey, byte[] member)
<K> Future<Boolean>	smove(K srcKey, K destKey, Number numberValue)
<K> Future<Boolean>	smove(K srcKey, K destKey, String stringValue)
<K,T extends Serializable> Future<Boolean>	smove(K srcKey, K destKey, T object)
<K> Sort	sort(K key) For Usage details regarding sort semantics, see JRedis.sort(K).
<K> Future<byte[]>	spop(K key)
<K> Future<byte[]>	srandmember(K key)
<K> Future<Boolean>	srem(K key, byte[] member)
<K> Future<Boolean>	srem(K key, Number value)
<K> Future<Boolean>	srem(K key, String value)
<K,T extends Serializable> Future<Boolean>	srem(K key, T value)
<K> Future<byte[]>	substr(K key, long from, long to)
<K> Future<List<byte[]>>	sunion(K set1, K... sets)
<K> JRedisFutureSupport.FutureStatus	sunionstore(K dest, K... sets)
<K> Future<Long>	ttl(K key)
<K> Future<RedisType>	type(K key)
<K> Future<Boolean>	zadd(K key, double score, byte[] member)
<K> Future<Boolean>	zadd(K key, double score, Number value)
<K> Future<Boolean>	zadd(K key, double score, String value)
<K,T extends Serializable> Future<Boolean>	zadd(K key, double score, T value)
<K> Future<Long>	zcard(K key)
<K> Future<Long>	zcount(K key, double minScore, double maxScore)
<K> Future<Double>	zincrby(K key, double score, byte[] member)
<K> Future<Double>	zincrby(K key, double score, Number value)
<K> Future<Double>	zincrby(K key, double score, String value)
<K,T extends Serializable> Future<Double>	zincrby(K key, double score, T value)
<K> Future<List<byte[]>>	zrange(K key, long from, long to)
<K> Future<List<byte[]>>	zrangebyscore(K key, double minScore, double maxScore)
<K> Future<List<ZSetEntry>>	zrangebyscoreSubset(K key, double minScore, double maxScore)
<K> Future<List<ZSetEntry>>	zrangeSubset(K key, long from, long to) Equivalent to JRedis#zrange(String, long, long) with the Command.Option#WITHSCORES.
<K> Future<Long>	zrank(K key, byte[] member)
<K> Future<Long>	zrank(K key, Number value)
<K> Future<Long>	zrank(K key, String value)
<K,T extends Serializable> Future<Long>	zrank(K key, T value)
<K> Future<Boolean>	zrem(K key, byte[] member)
<K> Future<Boolean>	zrem(K key, Number value)
<K> Future<Boolean>	zrem(K key, String value)
<K,T extends Serializable> Future<Boolean>	zrem(K key, T value)
<K> Future<Long>	zremrangebyrank(K key, long minRank, long maxRank)
<K> Future<Long>	zremrangebyscore(K key, double minScore, double maxScore)
<K> Future<List<byte[]>>	zrevrange(K key, long from, long to)
<K> Future<List<ZSetEntry>>	zrevrangeSubset(K key, long from, long to) Equivalent to JRedis#zrange(String, long, long) with the Command.Option#WITHSCORES.
<K> Future<Long>	zrevrank(K key, byte[] member)
<K> Future<Long>	zrevrank(K key, Number value)
<K> Future<Long>	zrevrank(K key, String value)
<K,T extends Serializable> Future<Long>	zrevrank(K key, T value)
<K> Future<Double>	zscore(K key, byte[] member)
<K> Future<Double>	zscore(K key, Number value)
<K> Future<Double>	zscore(K key, String value)
<K,T extends Serializable> Future<Double>	zscore(K key, T value)

Methods inherited from class java.lang.Object

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

Field Detail

CacheKeys

public static final boolean CacheKeys

See Also:

Constant Field Values

Constructor Detail

JRedisFutureSupport

public JRedisFutureSupport()

Method Detail

queueRequest

protected abstract Future<Response> queueRequest(Command cmd,
                                                 byte[]... args)
                                          throws ClientRuntimeException,
                                                 ProviderException

This method mimics the eponymous Connection#queueRequest(Command, byte[]...) which defines the blocking api semantics of Synchronous connections. The extending class can either directly (a) implement the protocol requirements, or, (b) delegate to a Connection instance, or, (c) utilize a pool of Connections.

Parameters:

cmd -

args -

Returns:

Throws:

ClientRuntimeException

ProviderException

bgsave

public <K> JRedisFutureSupport.FutureStatus bgsave()

Specified by:

bgsave in interface JRedisFuture

bgrewriteaof

public <K> JRedisFutureSupport.FutureString bgrewriteaof()

Specified by:

bgrewriteaof in interface JRedisFuture

Returns:

ack message.

ping

public <K> JRedisFutureSupport.FutureStatus ping()

Description copied from interface: JRedisFuture

Ping redis

Specified by:

ping in interface JRedisFuture

flushall

public <K> JRedisFutureSupport.FutureStatus flushall()

Description copied from interface: JRedisFuture

Flushes all dbs in the connect Redis server, regardless of which db was selected on connect time. Remember that there is no rollback.

Specified by:

flushall in interface JRedisFuture

Returns:

flushdb

public <K> JRedisFutureSupport.FutureStatus flushdb()

Description copied from interface: JRedisFuture

Flushes the db you selected when connecting to Redis server. Typically, implementations will select db 0 on connecting if non was specified. Remember that there is no roll-back.

Specified by:

flushdb in interface JRedisFuture

Returns:

slaveof

public <K> Future<ResponseStatus> slaveof(String host,
                                          int port)

Specified by:

slaveof in interface JRedisFuture

Parameters:

host - ip address

slaveofnone

public <K> Future<ResponseStatus> slaveofnone()

Description copied from interface: JRedisFuture

Convenience method. Turns off replication.

Specified by:

slaveofnone in interface JRedisFuture

rename

public <K> JRedisFutureSupport.FutureStatus rename(K oldkey,
                                                   K newkey)

Specified by:

rename in interface JRedisFuture

renamenx

public <K> Future<Boolean> renamenx(K oldkey,
                                    K newkey)

Specified by:

renamenx in interface JRedisFuture

Returns:

rpush

public <K> JRedisFutureSupport.FutureLong rpush(K key,
                                                byte[] value)

Specified by:

rpush in interface JRedisFuture

rpushx

public <K> JRedisFutureSupport.FutureLong rpushx(K key,
                                                 byte[] value)

lpushx

public <K> JRedisFutureSupport.FutureLong lpushx(K key,
                                                 byte[] value)

linsert

public <K> JRedisFutureSupport.FutureLong linsert(K key,
                                                  boolean after,
                                                  byte[] oldvalue,
                                                  byte[] newvalue)

linsertAfter

public <K> JRedisFutureSupport.FutureLong linsertAfter(K key,
                                                       byte[] oldvalue,
                                                       byte[] newvalue)

linsertBefore

public <K> JRedisFutureSupport.FutureLong linsertBefore(K key,
                                                        byte[] oldvalue,
                                                        byte[] newvalue)

rpoplpush

public <K> JRedisFutureSupport.FutureByteArray rpoplpush(String srcList,
                                                         String destList)

Specified by:

rpoplpush in interface JRedisFuture

Returns:

rpush

public <K> JRedisFutureSupport.FutureLong rpush(K key,
                                                String value)

Specified by:

rpush in interface JRedisFuture

rpush

public <K> JRedisFutureSupport.FutureLong rpush(K key,
                                                Number value)

Specified by:

rpush in interface JRedisFuture

rpush

public <K,T extends Serializable> JRedisFutureSupport.FutureLong rpush(K key,
                                                                       T value)

Specified by:

rpush in interface JRedisFuture

sadd

public <K> Future<Boolean> sadd(K key,
                                byte[] member)

Specified by:

sadd in interface JRedisFuture

Returns:

sadd

public <K> Future<Boolean> sadd(K key,
                                String value)

Specified by:

sadd in interface JRedisFuture

sadd

public <K> Future<Boolean> sadd(K key,
                                Number value)

Specified by:

sadd in interface JRedisFuture

sadd

public <K,T extends Serializable> Future<Boolean> sadd(K key,
                                                       T value)

Specified by:

sadd in interface JRedisFuture

zadd

public <K> Future<Boolean> zadd(K key,
                                double score,
                                byte[] member)

Specified by:

zadd in interface JRedisFuture

Returns:

zadd

public <K> Future<Boolean> zadd(K key,
                                double score,
                                String value)

Specified by:

zadd in interface JRedisFuture

zadd

public <K> Future<Boolean> zadd(K key,
                                double score,
                                Number value)

Specified by:

zadd in interface JRedisFuture

zadd

public <K,T extends Serializable> Future<Boolean> zadd(K key,
                                                       double score,
                                                       T value)

Specified by:

zadd in interface JRedisFuture

zincrby

public <K> Future<Double> zincrby(K key,
                                  double score,
                                  byte[] member)

Specified by:

zincrby in interface JRedisFuture

Returns:

zincrby

public <K> Future<Double> zincrby(K key,
                                  double score,
                                  String value)

Specified by:

zincrby in interface JRedisFuture

zincrby

public <K> Future<Double> zincrby(K key,
                                  double score,
                                  Number value)

Specified by:

zincrby in interface JRedisFuture

zincrby

public <K,T extends Serializable> Future<Double> zincrby(K key,
                                                         double score,
                                                         T value)

Specified by:

zincrby in interface JRedisFuture

save

public <K> JRedisFutureSupport.FutureStatus save()

Specified by:

save in interface JRedisFuture

setbit

public <K> Future<Boolean> setbit(K key,
                                  int offset,
                                  boolean value)

Specified by:

setbit in interface JRedisFuture

getbit

public <K> Future<Boolean> getbit(K key,
                                  int offset)

Specified by:

getbit in interface JRedisFuture

set

public <K> JRedisFutureSupport.FutureStatus set(K key,
                                                byte[] value)

Description copied from interface: JRedisFuture

Bind the value to key.

Specified by:

set in interface JRedisFuture

Parameters:

key - any UTF-8 String

value - any bytes. For current data size limitations, refer to Redis documentation.

set

public <K> JRedisFutureSupport.FutureStatus set(K key,
                                                String value)

Description copied from interface: JRedisFuture

Convenient method for String data binding

Specified by:

set in interface JRedisFuture

See Also:

JRedis#set(String, byte[])}

set

public <K> JRedisFutureSupport.FutureStatus set(K key,
                                                Number value)

Description copied from interface: JRedisFuture

Convenient method for String numeric values binding

Specified by:

set in interface JRedisFuture

See Also:

JRedis#set(String, byte[])}

set

public <K,T extends Serializable> JRedisFutureSupport.FutureStatus set(K key,
                                                                       T value)

Description copied from interface: JRedisFuture

Binds the given java Object to the key. Serialization format is implementation specific. Simple implementations may apply the basic Serializable protocol.

Specified by:

set in interface JRedisFuture

See Also:

JRedis#set(String, byte[])}

getset

public <K> Future<byte[]> getset(K key,
                                 byte[] value)

Specified by:

getset in interface JRedisFuture

getset

public <K> Future<byte[]> getset(K key,
                                 String value)

Specified by:

getset in interface JRedisFuture

getset

public <K> Future<byte[]> getset(K key,
                                 Number value)

Specified by:

getset in interface JRedisFuture

getset

public <K,T extends Serializable> Future<byte[]> getset(K key,
                                                        T value)

Specified by:

getset in interface JRedisFuture

setnx

public <K> Future<Boolean> setnx(K key,
                                 byte[] value)

Specified by:

setnx in interface JRedisFuture

Returns:

setnx

public <K> Future<Boolean> setnx(K key,
                                 String value)

Specified by:

setnx in interface JRedisFuture

setnx

public <K> Future<Boolean> setnx(K key,
                                 Number value)

Specified by:

setnx in interface JRedisFuture

setnx

public <K,T extends Serializable> Future<Boolean> setnx(K key,
                                                        T value)

Specified by:

setnx in interface JRedisFuture

append

public <K> Future<Long> append(K key,
                               byte[] value)

Specified by:

append in interface JRedisFuture

Returns:

the length (byte count) of appended key.

append

public <K> Future<Long> append(K key,
                               String value)

Specified by:

append in interface JRedisFuture

append

public <K> Future<Long> append(K key,
                               Number value)

Specified by:

append in interface JRedisFuture

append

public <K,T extends Serializable> Future<Long> append(K key,
                                                      T value)

Specified by:

append in interface JRedisFuture

sismember

public <K> Future<Boolean> sismember(K key,
                                     byte[] member)

Specified by:

sismember in interface JRedisFuture

Returns:

sismember

public <K> Future<Boolean> sismember(K key,
                                     String value)

Specified by:

sismember in interface JRedisFuture

sismember

public <K> Future<Boolean> sismember(K key,
                                     Number numberValue)

Specified by:

sismember in interface JRedisFuture

sismember

public <K,T extends Serializable> Future<Boolean> sismember(K key,
                                                            T object)

Specified by:

sismember in interface JRedisFuture

smove

public <K> Future<Boolean> smove(K srcKey,
                                 K destKey,
                                 byte[] member)

Specified by:

smove in interface JRedisFuture

Returns:

smove

public <K> Future<Boolean> smove(K srcKey,
                                 K destKey,
                                 String stringValue)

Specified by:

smove in interface JRedisFuture

smove

public <K> Future<Boolean> smove(K srcKey,
                                 K destKey,
                                 Number numberValue)

Specified by:

smove in interface JRedisFuture

smove

public <K,T extends Serializable> Future<Boolean> smove(K srcKey,
                                                        K destKey,
                                                        T object)

Specified by:

smove in interface JRedisFuture

hset

public <K> Future<Boolean> hset(K key,
                                K field,
                                byte[] value)

Specified by:

hset in interface JRedisFuture

Returns:

hset

public <K> Future<Boolean> hset(K key,
                                K field,
                                String stringValue)

Specified by:

hset in interface JRedisFuture

Returns:

hincrby

public <K> Future<Long> hincrby(K key,
                                K field,
                                long increment)

Specified by:

hincrby in interface JRedisFuture

Returns:

hset

public <K> Future<Boolean> hset(K key,
                                K field,
                                Number numberValue)

Specified by:

hset in interface JRedisFuture

Returns:

hset

public <K,T extends Serializable> Future<Boolean> hset(K key,
                                                       K field,
                                                       T object)

Specified by:

hset in interface JRedisFuture

Returns:

hget

public <K> Future<byte[]> hget(K key,
                               K entry)

Specified by:

hget in interface JRedisFuture

Returns:

hexists

public <K> Future<Boolean> hexists(K key,
                                   K entry)

Specified by:

hexists in interface JRedisFuture

Returns:

true if the spec'd field exists for the spec'd (hash type) key

hdel

public <K> Future<Boolean> hdel(K key,
                                K entry)

Specified by:

hdel in interface JRedisFuture

Returns:

true if the spec'd field exists for the spec'd (hash type) key

hlen

public <K> Future<Long> hlen(K key)

Specified by:

hlen in interface JRedisFuture

Returns:

# of fields/entries for the given hash type key

hkeys

public <K> Future<List<byte[]>> hkeys(K key)

Specified by:

hkeys in interface JRedisFuture

Returns:

list of keys in the given hashtable.

hvals

public <K> Future<List<byte[]>> hvals(K key)

Specified by:

hvals in interface JRedisFuture

Returns:

list of values in the given hashtable.

hgetall

public <K> Future<Map<byte[],byte[]>> hgetall(K key)

Specified by:

hgetall in interface JRedisFuture

Returns:

the given hash as a Map

incr

public <K> Future<Long> incr(K key)

Specified by:

incr in interface JRedisFuture

Returns:

incrby

public <K> Future<Long> incrby(K key,
                               int delta)

Specified by:

incrby in interface JRedisFuture

Returns:

decr

public <K> Future<Long> decr(K key)

Specified by:

decr in interface JRedisFuture

Returns:

decrby

public <K> Future<Long> decrby(K key,
                               int delta)

Specified by:

decrby in interface JRedisFuture

Returns:

llen

public <K> Future<Long> llen(K key)

Description copied from interface: JRedisFuture

Given a 'list' key, returns the number of items in the list.

Specified by:

llen in interface JRedisFuture

Returns:

scard

public <K> Future<Long> scard(K key)

Specified by:

scard in interface JRedisFuture

Returns:

zcard

public <K> Future<Long> zcard(K key)

Specified by:

zcard in interface JRedisFuture

Returns:

srandmember

public <K> Future<byte[]> srandmember(K key)

Specified by:

srandmember in interface JRedisFuture

Returns:

spop

public <K> Future<byte[]> spop(K key)

Specified by:

spop in interface JRedisFuture

Returns:

dbsize

public <K> Future<Long> dbsize()

Specified by:

dbsize in interface JRedisFuture

Returns:

lastsave

public <K> Future<Long> lastsave()

Specified by:

lastsave in interface JRedisFuture

Returns:

get

public <K> Future<byte[]> get(K key)

Specified by:

get in interface JRedisFuture

Returns:

lindex

public <K> Future<byte[]> lindex(K key,
                                 long index)

Specified by:

lindex in interface JRedisFuture

Returns:

lpop

public <K> Future<byte[]> lpop(K key)

Specified by:

lpop in interface JRedisFuture

Returns:

rpop

public <K> Future<byte[]> rpop(K key)

Specified by:

rpop in interface JRedisFuture

Returns:

randomkey

public <K> Future<byte[]> randomkey()

Specified by:

randomkey in interface JRedisFuture

Returns:

type

public <K> Future<RedisType> type(K key)

Specified by:

type in interface JRedisFuture

Returns:

info

public <K> Future<Map<String,String>> info()

Specified by:

info in interface JRedisFuture

Returns:

debug

public <K> Future<ObjectInfo> debug(K key)

Specified by:

debug in interface JRedisFuture

Returns:

mget

public <K> Future<List<byte[]>> mget(String... keys)

Specified by:

mget in interface JRedisFuture

Returns:

mset

public <K> JRedisFutureSupport.FutureStatus mset(Map<K,byte[]> keyValueMap)

Specified by:

mset in interface JRedisFuture

Parameters:

keyValueMap - a Mapping of String key names to byte[] values.

Returns:

Future indicating if all of sets were OK or not

mset

public <K> JRedisFutureSupport.FutureStatus mset(KeyValueSet.ByteArrays<K> keyValueMap)

Specified by:

mset in interface JRedisFuture

mset

public <K> JRedisFutureSupport.FutureStatus mset(KeyValueSet.Strings<K> keyValueMap)

Specified by:

mset in interface JRedisFuture

mset

public <K> JRedisFutureSupport.FutureStatus mset(KeyValueSet.Numbers<K> keyValueMap)

Specified by:

mset in interface JRedisFuture

mset

public <K,T extends Serializable> JRedisFutureSupport.FutureStatus mset(KeyValueSet.Objects<K,T> keyValueMap)

Specified by:

mset in interface JRedisFuture

msetnx

public <K> Future<Boolean> msetnx(Map<K,byte[]> keyValueMap)

Specified by:

msetnx in interface JRedisFuture

Parameters:

keyValueMap - a Mapping of String key names to byte[] values.

Returns:

Future indicating if all of sets were OK or not

msetnx

public <K> Future<Boolean> msetnx(KeyValueSet.ByteArrays<K> keyValueMap)

Specified by:

msetnx in interface JRedisFuture

msetnx

public <K> Future<Boolean> msetnx(KeyValueSet.Strings<K> keyValueMap)

Specified by:

msetnx in interface JRedisFuture

msetnx

public <K> Future<Boolean> msetnx(KeyValueSet.Numbers<K> keyValueMap)

Specified by:

msetnx in interface JRedisFuture

msetnx

public <K,T extends Serializable> Future<Boolean> msetnx(KeyValueSet.Objects<K,T> keyValueMap)

Specified by:

msetnx in interface JRedisFuture

smembers

public <K> Future<List<byte[]>> smembers(K key)

Specified by:

smembers in interface JRedisFuture

Returns:

keys

public <K> Future<List<byte[]>> keys()

Description copied from interface: JRedisFuture

Convenience method. Equivalent to calling jredis.keys("*");

Specified by:

keys in interface JRedisFuture

Returns:

See Also:

JRedis#keys(String)}

keys

public <K> Future<List<byte[]>> keys(K pattern)

Specified by:

keys in interface JRedisFuture

Returns:

keystolist

public <K> Future<Long> keystolist(String pattern,
                                   String listname)

lrange

public <K> Future<List<byte[]>> lrange(K key,
                                       long from,
                                       long to)

Specified by:

lrange in interface JRedisFuture

Returns:

substr

public <K> Future<byte[]> substr(K key,
                                 long from,
                                 long to)

Specified by:

substr in interface JRedisFuture

Returns:

zrange

public <K> Future<List<byte[]>> zrange(K key,
                                       long from,
                                       long to)

Specified by:

zrange in interface JRedisFuture

Returns:

zrangebyscore

public <K> Future<List<byte[]>> zrangebyscore(K key,
                                              double minScore,
                                              double maxScore)

Specified by:

zrangebyscore in interface JRedisFuture

Returns:

zrangebyscoreSubset

public <K> Future<List<ZSetEntry>> zrangebyscoreSubset(K key,
                                                       double minScore,
                                                       double maxScore)

Specified by:

zrangebyscoreSubset in interface JRedisFuture

Returns:

zremrangebyscore

public <K> Future<Long> zremrangebyscore(K key,
                                         double minScore,
                                         double maxScore)

Specified by:

zremrangebyscore in interface JRedisFuture

Returns:

number of removed elements

zcount

public <K> Future<Long> zcount(K key,
                               double minScore,
                               double maxScore)

Specified by:

zcount in interface JRedisFuture

Returns:

number of removed elements

zremrangebyrank

public <K> Future<Long> zremrangebyrank(K key,
                                        long minRank,
                                        long maxRank)

Specified by:

zremrangebyrank in interface JRedisFuture

Returns:

number of removed elements

zrevrange

public <K> Future<List<byte[]>> zrevrange(K key,
                                          long from,
                                          long to)

Specified by:

zrevrange in interface JRedisFuture

Returns:

zrangeSubset

public <K> Future<List<ZSetEntry>> zrangeSubset(K key,
                                                long from,
                                                long to)

Description copied from interface: JRedisFuture

Equivalent to JRedis#zrange(String, long, long) with the Command.Option#WITHSCORES. Unlike the general ZRANGE command that only returns the values, this method returns both values and associated scores for the specified range.

Specified by:

zrangeSubset in interface JRedisFuture

Returns:

See Also:

JRedis#zrange(String, long, long), ZSetEntry

zrevrangeSubset

public <K> Future<List<ZSetEntry>> zrevrangeSubset(K key,
                                                   long from,
                                                   long to)

Description copied from interface: JRedisFuture

Equivalent to JRedis#zrange(String, long, long) with the Command.Option#WITHSCORES. Unlike the general ZRANGE command that only returns the values, this method returns both values and associated scores for the specified range.

Specified by:

zrevrangeSubset in interface JRedisFuture

Returns:

See Also:

JRedis#zrevrange(String, long, long), ZSetEntry

sort

public <K> Sort sort(K key)

Description copied from interface: JRedisFuture

For Usage details regarding sort semantics, see JRedis.sort(K). The only difference in usage is that you must use the Query.execAsync() method which returns a Future instances.

Usage:

 Future>  futureResults = redis.sort("my-list-or-set-key").BY("weight*").LIMIT(1, 11).GET("object*").DESC().ALPHA().execAsync();
 List results = futureResult.get();  // wait for the asynchronous response to be processed
 for(byte[] item : results) {
     // do something with item ..
  }
 

Specified by:

sort in interface JRedisFuture

See Also:

Redis, Future

quit

public <K> JRedisFutureSupport.FutureStatus quit()

Description copied from interface: JRedisFuture

Disconnects the client.

Specified by:

quit in interface JRedisFuture

flush

public JRedisFutureSupport.FutureStatus flush()

Description copied from interface: JRedisFuture

Optional connection control command.

Specified by:

flush in interface JRedisFuture

Returns:

sinter

public <K> Future<List<byte[]>> sinter(K set1,
                                       K... sets)

Specified by:

sinter in interface JRedisFuture

Returns:

sunion

public <K> Future<List<byte[]>> sunion(K set1,
                                       K... sets)

Specified by:

sunion in interface JRedisFuture

Returns:

sdiff

public <K> Future<List<byte[]>> sdiff(K set1,
                                      K... sets)

Specified by:

sdiff in interface JRedisFuture

Returns:

sinterstore

public <K> JRedisFutureSupport.FutureStatus sinterstore(K dest,
                                                        K... sets)

Specified by:

sinterstore in interface JRedisFuture

sunionstore

public <K> JRedisFutureSupport.FutureStatus sunionstore(K dest,
                                                        K... sets)

Specified by:

sunionstore in interface JRedisFuture

sdiffstore

public <K> JRedisFutureSupport.FutureStatus sdiffstore(K dest,
                                                       K... sets)

Specified by:

sdiffstore in interface JRedisFuture

del

public <K> Future<Long> del(K... keys)

Specified by:

del in interface JRedisFuture

Parameters:

keys - one or more, non-null, non-zero-length, keys to be deleted

Returns:

Future of number keys actually deleted.

exists

public <K> Future<Boolean> exists(K key)

Specified by:

exists in interface JRedisFuture

Returns:

lpush

public <K> JRedisFutureSupport.FutureLong lpush(K key,
                                                byte[] value)

Specified by:

lpush in interface JRedisFuture

lpush

public <K> JRedisFutureSupport.FutureLong lpush(K key,
                                                String value)

Specified by:

lpush in interface JRedisFuture

lpush

public <K> JRedisFutureSupport.FutureLong lpush(K key,
                                                Number value)

Specified by:

lpush in interface JRedisFuture

lpush

public <K,T extends Serializable> JRedisFutureSupport.FutureLong lpush(K key,
                                                                       T value)

Specified by:

lpush in interface JRedisFuture

lrem

public <K> Future<Long> lrem(K key,
                             byte[] value,
                             int count)

Specified by:

lrem in interface JRedisFuture

Returns:

lrem

public <K> Future<Long> lrem(K listKey,
                             String value,
                             int count)

Specified by:

lrem in interface JRedisFuture

lrem

public <K> Future<Long> lrem(K listKey,
                             Number numberValue,
                             int count)

Specified by:

lrem in interface JRedisFuture

lrem

public <K,T extends Serializable> Future<Long> lrem(K listKey,
                                                    T object,
                                                    int count)

Specified by:

lrem in interface JRedisFuture

lset

public <K> JRedisFutureSupport.FutureStatus lset(K key,
                                                 long index,
                                                 byte[] value)

Specified by:

lset in interface JRedisFuture

lset

public <K> JRedisFutureSupport.FutureStatus lset(K key,
                                                 long index,
                                                 String value)

Specified by:

lset in interface JRedisFuture

lset

public <K> JRedisFutureSupport.FutureStatus lset(K key,
                                                 long index,
                                                 Number numberValue)

Specified by:

lset in interface JRedisFuture

lset

public <K,T extends Serializable> JRedisFutureSupport.FutureStatus lset(K key,
                                                                        long index,
                                                                        T object)

Specified by:

lset in interface JRedisFuture

move

public <K> Future<Boolean> move(K key,
                                int dbIndex)

Description copied from interface: JRedisFuture

Moves the given key from the currently selected db to the one indicated by dbIndex.

Specified by:

move in interface JRedisFuture

Returns:

srem

public <K> Future<Boolean> srem(K key,
                                byte[] member)

Specified by:

srem in interface JRedisFuture

Returns:

srem

public <K> Future<Boolean> srem(K key,
                                String value)

Specified by:

srem in interface JRedisFuture

srem

public <K> Future<Boolean> srem(K key,
                                Number value)

Specified by:

srem in interface JRedisFuture

srem

public <K,T extends Serializable> Future<Boolean> srem(K key,
                                                       T value)

Specified by:

srem in interface JRedisFuture

zrem

public <K> Future<Boolean> zrem(K key,
                                byte[] member)

Specified by:

zrem in interface JRedisFuture

Returns:

zrem

public <K> Future<Boolean> zrem(K key,
                                String value)

Specified by:

zrem in interface JRedisFuture

zrem

public <K> Future<Boolean> zrem(K key,
                                Number value)

Specified by:

zrem in interface JRedisFuture

zrem

public <K,T extends Serializable> Future<Boolean> zrem(K key,
                                                       T value)

Specified by:

zrem in interface JRedisFuture

zscore

public <K> Future<Double> zscore(K key,
                                 byte[] member)

Specified by:

zscore in interface JRedisFuture

Returns:

zscore

public <K> Future<Double> zscore(K key,
                                 String value)

Specified by:

zscore in interface JRedisFuture

zscore

public <K> Future<Double> zscore(K key,
                                 Number value)

Specified by:

zscore in interface JRedisFuture

zscore

public <K,T extends Serializable> Future<Double> zscore(K key,
                                                        T value)

Specified by:

zscore in interface JRedisFuture

zrank

public <K> Future<Long> zrank(K key,
                              byte[] member)

Specified by:

zrank in interface JRedisFuture

Returns:

zrank

public <K> Future<Long> zrank(K key,
                              String value)

Specified by:

zrank in interface JRedisFuture

zrank

public <K> Future<Long> zrank(K key,
                              Number value)

Specified by:

zrank in interface JRedisFuture

zrank

public <K,T extends Serializable> Future<Long> zrank(K key,
                                                     T value)

Specified by:

zrank in interface JRedisFuture

zrevrank

public <K> Future<Long> zrevrank(K key,
                                 byte[] member)

Specified by:

zrevrank in interface JRedisFuture

Returns:

zrevrank

public <K> Future<Long> zrevrank(K key,
                                 String value)

Specified by:

zrevrank in interface JRedisFuture

zrevrank

public <K> Future<Long> zrevrank(K key,
                                 Number value)

Specified by:

zrevrank in interface JRedisFuture

zrevrank

public <K,T extends Serializable> Future<Long> zrevrank(K key,
                                                        T value)

Specified by:

zrevrank in interface JRedisFuture

ltrim

public <K> JRedisFutureSupport.FutureStatus ltrim(K key,
                                                  long keepFrom,
                                                  long keepTo)

Specified by:

ltrim in interface JRedisFuture

expire

public <K> Future<Boolean> expire(K key,
                                  int ttlseconds)

Specified by:

expire in interface JRedisFuture

Returns:

expireat

public <K> Future<Boolean> expireat(K key,
                                    long epochtime)

Specified by:

expireat in interface JRedisFuture

Returns:

See Also:

System#currentTimeMillis()}

ttl

public <K> Future<Long> ttl(K key)

Specified by:

ttl in interface JRedisFuture

Returns:

echo

public <K> Future<byte[]> echo(byte[] msg)

Specified by:

echo in interface JRedisFuture

Parameters:

msg -

Returns:

echo

public <K> Future<byte[]> echo(String msg)

Specified by:

echo in interface JRedisFuture

echo

public <K> Future<byte[]> echo(Number msg)

Specified by:

echo in interface JRedisFuture

echo

public <K,T extends Serializable> Future<byte[]> echo(T msg)

Specified by:

echo in interface JRedisFuture