public abstract class JRedisFutureSupport extends Object implements JRedisFuture
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 |
Modifier and Type | Field and Description |
---|---|
static boolean |
CacheKeys |
Constructor and Description |
---|
JRedisFutureSupport() |
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> |
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> |
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> |
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> |
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> |
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> |
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> |
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> |
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> |
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> |
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> |
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> |
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> |
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> |
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> |
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> |
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> |
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> |
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> |
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> |
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> |
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> |
zscore(K key,
T value) |
public static final boolean CacheKeys
protected abstract Future<Response> queueRequest(Command cmd, byte[]... args) throws ClientRuntimeException, ProviderException
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 Connection
s.cmd
- args
- ClientRuntimeException
ProviderException
public <K> JRedisFutureSupport.FutureStatus bgsave()
bgsave
in interface JRedisFuture
public <K> JRedisFutureSupport.FutureString bgrewriteaof()
bgrewriteaof
in interface JRedisFuture
public <K> JRedisFutureSupport.FutureStatus ping()
JRedisFuture
ping
in interface JRedisFuture
public <K> JRedisFutureSupport.FutureStatus flushall()
JRedisFuture
flushall
in interface JRedisFuture
public <K> JRedisFutureSupport.FutureStatus flushdb()
JRedisFuture
flushdb
in interface JRedisFuture
public <K> Future<ResponseStatus> slaveof(String host, int port)
slaveof
in interface JRedisFuture
host
- ip addresspublic <K> Future<ResponseStatus> slaveofnone()
JRedisFuture
slaveofnone
in interface JRedisFuture
public <K> JRedisFutureSupport.FutureStatus rename(K oldkey, K newkey)
rename
in interface JRedisFuture
public <K> Future<Boolean> renamenx(K oldkey, K newkey)
renamenx
in interface JRedisFuture
public <K> JRedisFutureSupport.FutureLong rpush(K key, byte[] value)
rpush
in interface JRedisFuture
public <K> JRedisFutureSupport.FutureLong rpushx(K key, byte[] value)
public <K> JRedisFutureSupport.FutureLong lpushx(K key, byte[] value)
public <K> JRedisFutureSupport.FutureLong linsert(K key, boolean after, byte[] oldvalue, byte[] newvalue)
public <K> JRedisFutureSupport.FutureLong linsertAfter(K key, byte[] oldvalue, byte[] newvalue)
public <K> JRedisFutureSupport.FutureLong linsertBefore(K key, byte[] oldvalue, byte[] newvalue)
public <K> JRedisFutureSupport.FutureByteArray rpoplpush(String srcList, String destList)
rpoplpush
in interface JRedisFuture
public <K> JRedisFutureSupport.FutureLong rpush(K key, String value)
rpush
in interface JRedisFuture
public <K> JRedisFutureSupport.FutureLong rpush(K key, Number value)
rpush
in interface JRedisFuture
public <K,T extends Serializable> JRedisFutureSupport.FutureLong rpush(K key, T value)
rpush
in interface JRedisFuture
public <K> Future<Boolean> sadd(K key, byte[] member)
sadd
in interface JRedisFuture
public <K> Future<Boolean> sadd(K key, String value)
sadd
in interface JRedisFuture
public <K> Future<Boolean> sadd(K key, Number value)
sadd
in interface JRedisFuture
public <K,T extends Serializable> Future<Boolean> sadd(K key, T value)
sadd
in interface JRedisFuture
public <K> Future<Boolean> zadd(K key, double score, byte[] member)
zadd
in interface JRedisFuture
public <K> Future<Boolean> zadd(K key, double score, String value)
zadd
in interface JRedisFuture
public <K> Future<Boolean> zadd(K key, double score, Number value)
zadd
in interface JRedisFuture
public <K,T extends Serializable> Future<Boolean> zadd(K key, double score, T value)
zadd
in interface JRedisFuture
public <K> Future<Double> zincrby(K key, double score, byte[] member)
zincrby
in interface JRedisFuture
public <K> Future<Double> zincrby(K key, double score, String value)
zincrby
in interface JRedisFuture
public <K> Future<Double> zincrby(K key, double score, Number value)
zincrby
in interface JRedisFuture
public <K,T extends Serializable> Future<Double> zincrby(K key, double score, T value)
zincrby
in interface JRedisFuture
public <K> JRedisFutureSupport.FutureStatus save()
save
in interface JRedisFuture
public <K> Future<Boolean> setbit(K key, int offset, boolean value)
setbit
in interface JRedisFuture
public <K> Future<Boolean> getbit(K key, int offset)
getbit
in interface JRedisFuture
public <K> JRedisFutureSupport.FutureStatus set(K key, byte[] value)
JRedisFuture
set
in interface JRedisFuture
key
- any UTF-8 String
value
- any bytes. For current data size limitations, refer to
Redis documentation.public <K> JRedisFutureSupport.FutureStatus set(K key, String value)
JRedisFuture
String
data bindingset
in interface JRedisFuture
JRedis#set(String, byte[])}
public <K> JRedisFutureSupport.FutureStatus set(K key, Number value)
JRedisFuture
String
numeric values bindingset
in interface JRedisFuture
JRedis#set(String, byte[])}
public <K,T extends Serializable> JRedisFutureSupport.FutureStatus set(K key, T value)
JRedisFuture
Object
to the key. Serialization format is
implementation specific. Simple implementations may apply the basic Serializable
protocol.set
in interface JRedisFuture
JRedis#set(String, byte[])}
public <K> Future<byte[]> getset(K key, byte[] value)
getset
in interface JRedisFuture
public <K> Future<byte[]> getset(K key, String value)
getset
in interface JRedisFuture
public <K> Future<byte[]> getset(K key, Number value)
getset
in interface JRedisFuture
public <K,T extends Serializable> Future<byte[]> getset(K key, T value)
getset
in interface JRedisFuture
public <K> Future<Boolean> setnx(K key, byte[] value)
setnx
in interface JRedisFuture
public <K> Future<Boolean> setnx(K key, String value)
setnx
in interface JRedisFuture
public <K> Future<Boolean> setnx(K key, Number value)
setnx
in interface JRedisFuture
public <K,T extends Serializable> Future<Boolean> setnx(K key, T value)
setnx
in interface JRedisFuture
public <K> Future<Long> append(K key, byte[] value)
append
in interface JRedisFuture
public <K> Future<Long> append(K key, String value)
append
in interface JRedisFuture
public <K> Future<Long> append(K key, Number value)
append
in interface JRedisFuture
public <K,T extends Serializable> Future<Long> append(K key, T value)
append
in interface JRedisFuture
public <K> Future<Boolean> sismember(K key, byte[] member)
sismember
in interface JRedisFuture
public <K> Future<Boolean> sismember(K key, String value)
sismember
in interface JRedisFuture
public <K> Future<Boolean> sismember(K key, Number numberValue)
sismember
in interface JRedisFuture
public <K,T extends Serializable> Future<Boolean> sismember(K key, T object)
sismember
in interface JRedisFuture
public <K> Future<Boolean> smove(K srcKey, K destKey, byte[] member)
smove
in interface JRedisFuture
public <K> Future<Boolean> smove(K srcKey, K destKey, String stringValue)
smove
in interface JRedisFuture
public <K> Future<Boolean> smove(K srcKey, K destKey, Number numberValue)
smove
in interface JRedisFuture
public <K,T extends Serializable> Future<Boolean> smove(K srcKey, K destKey, T object)
smove
in interface JRedisFuture
public <K> Future<Boolean> hset(K key, K field, byte[] value)
hset
in interface JRedisFuture
public <K> Future<Boolean> hset(K key, K field, String stringValue)
hset
in interface JRedisFuture
public <K> Future<Long> hincrby(K key, K field, long increment)
hincrby
in interface JRedisFuture
public <K> Future<Boolean> hset(K key, K field, Number numberValue)
hset
in interface JRedisFuture
public <K,T extends Serializable> Future<Boolean> hset(K key, K field, T object)
hset
in interface JRedisFuture
public <K> Future<byte[]> hget(K key, K entry)
hget
in interface JRedisFuture
public <K> Future<Boolean> hexists(K key, K entry)
hexists
in interface JRedisFuture
public <K> Future<Boolean> hdel(K key, K entry)
hdel
in interface JRedisFuture
public <K> Future<Long> hlen(K key)
hlen
in interface JRedisFuture
public <K> Future<List<byte[]>> hkeys(K key)
hkeys
in interface JRedisFuture
public <K> Future<List<byte[]>> hvals(K key)
hvals
in interface JRedisFuture
public <K> Future<Map<byte[],byte[]>> hgetall(K key)
hgetall
in interface JRedisFuture
public <K> Future<Long> incr(K key)
incr
in interface JRedisFuture
public <K> Future<Long> incrby(K key, int delta)
incrby
in interface JRedisFuture
public <K> Future<Long> decr(K key)
decr
in interface JRedisFuture
public <K> Future<Long> decrby(K key, int delta)
decrby
in interface JRedisFuture
public <K> Future<Long> llen(K key)
JRedisFuture
llen
in interface JRedisFuture
public <K> Future<Long> scard(K key)
scard
in interface JRedisFuture
public <K> Future<Long> zcard(K key)
zcard
in interface JRedisFuture
public <K> Future<byte[]> srandmember(K key)
srandmember
in interface JRedisFuture
public <K> Future<byte[]> spop(K key)
spop
in interface JRedisFuture
public <K> Future<Long> dbsize()
dbsize
in interface JRedisFuture
public <K> Future<Long> lastsave()
lastsave
in interface JRedisFuture
public <K> Future<byte[]> get(K key)
get
in interface JRedisFuture
public <K> Future<byte[]> lindex(K key, long index)
lindex
in interface JRedisFuture
public <K> Future<byte[]> lpop(K key)
lpop
in interface JRedisFuture
public <K> Future<byte[]> rpop(K key)
rpop
in interface JRedisFuture
public <K> Future<byte[]> randomkey()
randomkey
in interface JRedisFuture
public <K> Future<RedisType> type(K key)
type
in interface JRedisFuture
public <K> Future<Map<String,String>> info()
info
in interface JRedisFuture
public <K> Future<ObjectInfo> debug(K key)
debug
in interface JRedisFuture
public <K> Future<List<byte[]>> mget(String... keys)
mget
in interface JRedisFuture
public <K> JRedisFutureSupport.FutureStatus mset(Map<K,byte[]> keyValueMap)
mset
in interface JRedisFuture
keyValueMap
- a Map
ping of String
key names to byte[] values.public <K> JRedisFutureSupport.FutureStatus mset(KeyValueSet.ByteArrays<K> keyValueMap)
mset
in interface JRedisFuture
public <K> JRedisFutureSupport.FutureStatus mset(KeyValueSet.Strings<K> keyValueMap)
mset
in interface JRedisFuture
public <K> JRedisFutureSupport.FutureStatus mset(KeyValueSet.Numbers<K> keyValueMap)
mset
in interface JRedisFuture
public <K,T extends Serializable> JRedisFutureSupport.FutureStatus mset(KeyValueSet.Objects<K,T> keyValueMap)
mset
in interface JRedisFuture
public <K> Future<Boolean> msetnx(Map<K,byte[]> keyValueMap)
msetnx
in interface JRedisFuture
keyValueMap
- a Map
ping of String
key names to byte[] values.public <K> Future<Boolean> msetnx(KeyValueSet.ByteArrays<K> keyValueMap)
msetnx
in interface JRedisFuture
public <K> Future<Boolean> msetnx(KeyValueSet.Strings<K> keyValueMap)
msetnx
in interface JRedisFuture
public <K> Future<Boolean> msetnx(KeyValueSet.Numbers<K> keyValueMap)
msetnx
in interface JRedisFuture
public <K,T extends Serializable> Future<Boolean> msetnx(KeyValueSet.Objects<K,T> keyValueMap)
msetnx
in interface JRedisFuture
public <K> Future<List<byte[]>> smembers(K key)
smembers
in interface JRedisFuture
public <K> Future<List<byte[]>> keys()
JRedisFuture
jredis.keys("*");
keys
in interface JRedisFuture
JRedis#keys(String)}
public <K> Future<List<byte[]>> keys(K pattern)
keys
in interface JRedisFuture
public <K> Future<List<byte[]>> lrange(K key, long from, long to)
lrange
in interface JRedisFuture
public <K> Future<byte[]> substr(K key, long from, long to)
substr
in interface JRedisFuture
public <K> Future<List<byte[]>> zrange(K key, long from, long to)
zrange
in interface JRedisFuture
public <K> Future<List<byte[]>> zrangebyscore(K key, double minScore, double maxScore)
zrangebyscore
in interface JRedisFuture
public <K> Future<List<ZSetEntry>> zrangebyscoreSubset(K key, double minScore, double maxScore)
zrangebyscoreSubset
in interface JRedisFuture
public <K> Future<Long> zremrangebyscore(K key, double minScore, double maxScore)
zremrangebyscore
in interface JRedisFuture
public <K> Future<Long> zcount(K key, double minScore, double maxScore)
zcount
in interface JRedisFuture
public <K> Future<Long> zremrangebyrank(K key, long minRank, long maxRank)
zremrangebyrank
in interface JRedisFuture
public <K> Future<List<byte[]>> zrevrange(K key, long from, long to)
zrevrange
in interface JRedisFuture
public <K> Future<List<ZSetEntry>> zrangeSubset(K key, long from, long to)
JRedisFuture
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.zrangeSubset
in interface JRedisFuture
JRedis#zrange(String, long, long)
,
ZSetEntry
public <K> Future<List<ZSetEntry>> zrevrangeSubset(K key, long from, long to)
JRedisFuture
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.zrevrangeSubset
in interface JRedisFuture
JRedis#zrevrange(String, long, long)
,
ZSetEntry
public <K> Sort sort(K key)
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
sort
in interface JRedisFuture
Redis
,
Future
public <K> JRedisFutureSupport.FutureStatus quit()
JRedisFuture
quit
in interface JRedisFuture
public JRedisFutureSupport.FutureStatus flush()
JRedisFuture
flush
in interface JRedisFuture
public <K> Future<List<byte[]>> sinter(K set1, K... sets)
sinter
in interface JRedisFuture
public <K> Future<List<byte[]>> sunion(K set1, K... sets)
sunion
in interface JRedisFuture
public <K> Future<List<byte[]>> sdiff(K set1, K... sets)
sdiff
in interface JRedisFuture
public <K> JRedisFutureSupport.FutureStatus sinterstore(K dest, K... sets)
sinterstore
in interface JRedisFuture
public <K> JRedisFutureSupport.FutureStatus sunionstore(K dest, K... sets)
sunionstore
in interface JRedisFuture
public <K> JRedisFutureSupport.FutureStatus sdiffstore(K dest, K... sets)
sdiffstore
in interface JRedisFuture
public <K> Future<Long> del(K... keys)
del
in interface JRedisFuture
keys
- one or more, non-null, non-zero-length, keys to be deletedpublic <K> Future<Boolean> exists(K key)
exists
in interface JRedisFuture
public <K> JRedisFutureSupport.FutureLong lpush(K key, byte[] value)
lpush
in interface JRedisFuture
public <K> JRedisFutureSupport.FutureLong lpush(K key, String value)
lpush
in interface JRedisFuture
public <K> JRedisFutureSupport.FutureLong lpush(K key, Number value)
lpush
in interface JRedisFuture
public <K,T extends Serializable> JRedisFutureSupport.FutureLong lpush(K key, T value)
lpush
in interface JRedisFuture
public <K> Future<Long> lrem(K key, byte[] value, int count)
lrem
in interface JRedisFuture
public <K> Future<Long> lrem(K listKey, String value, int count)
lrem
in interface JRedisFuture
public <K> Future<Long> lrem(K listKey, Number numberValue, int count)
lrem
in interface JRedisFuture
public <K,T extends Serializable> Future<Long> lrem(K listKey, T object, int count)
lrem
in interface JRedisFuture
public <K> JRedisFutureSupport.FutureStatus lset(K key, long index, byte[] value)
lset
in interface JRedisFuture
public <K> JRedisFutureSupport.FutureStatus lset(K key, long index, String value)
lset
in interface JRedisFuture
public <K> JRedisFutureSupport.FutureStatus lset(K key, long index, Number numberValue)
lset
in interface JRedisFuture
public <K,T extends Serializable> JRedisFutureSupport.FutureStatus lset(K key, long index, T object)
lset
in interface JRedisFuture
public <K> Future<Boolean> move(K key, int dbIndex)
JRedisFuture
dbIndex
.move
in interface JRedisFuture
public <K> Future<Boolean> srem(K key, byte[] member)
srem
in interface JRedisFuture
public <K> Future<Boolean> srem(K key, String value)
srem
in interface JRedisFuture
public <K> Future<Boolean> srem(K key, Number value)
srem
in interface JRedisFuture
public <K,T extends Serializable> Future<Boolean> srem(K key, T value)
srem
in interface JRedisFuture
public <K> Future<Boolean> zrem(K key, byte[] member)
zrem
in interface JRedisFuture
public <K> Future<Boolean> zrem(K key, String value)
zrem
in interface JRedisFuture
public <K> Future<Boolean> zrem(K key, Number value)
zrem
in interface JRedisFuture
public <K,T extends Serializable> Future<Boolean> zrem(K key, T value)
zrem
in interface JRedisFuture
public <K> Future<Double> zscore(K key, byte[] member)
zscore
in interface JRedisFuture
public <K> Future<Double> zscore(K key, String value)
zscore
in interface JRedisFuture
public <K> Future<Double> zscore(K key, Number value)
zscore
in interface JRedisFuture
public <K,T extends Serializable> Future<Double> zscore(K key, T value)
zscore
in interface JRedisFuture
public <K> Future<Long> zrank(K key, byte[] member)
zrank
in interface JRedisFuture
public <K> Future<Long> zrank(K key, String value)
zrank
in interface JRedisFuture
public <K> Future<Long> zrank(K key, Number value)
zrank
in interface JRedisFuture
public <K,T extends Serializable> Future<Long> zrank(K key, T value)
zrank
in interface JRedisFuture
public <K> Future<Long> zrevrank(K key, byte[] member)
zrevrank
in interface JRedisFuture
public <K> Future<Long> zrevrank(K key, String value)
zrevrank
in interface JRedisFuture
public <K> Future<Long> zrevrank(K key, Number value)
zrevrank
in interface JRedisFuture
public <K,T extends Serializable> Future<Long> zrevrank(K key, T value)
zrevrank
in interface JRedisFuture
public <K> JRedisFutureSupport.FutureStatus ltrim(K key, long keepFrom, long keepTo)
ltrim
in interface JRedisFuture
public <K> Future<Boolean> expire(K key, int ttlseconds)
expire
in interface JRedisFuture
public <K> Future<Boolean> expireat(K key, long epochtime)
expireat
in interface JRedisFuture
System#currentTimeMillis()}
public <K> Future<Long> ttl(K key)
ttl
in interface JRedisFuture
public <K> Future<byte[]> echo(byte[] msg)
echo
in interface JRedisFuture
msg
- public <K> Future<byte[]> echo(String msg)
echo
in interface JRedisFuture
public <K> Future<byte[]> echo(Number msg)
echo
in interface JRedisFuture
public <K,T extends Serializable> Future<byte[]> echo(T msg)
echo
in interface JRedisFuture
Copyright © 2009–2015. All rights reserved.