K
- Key type.V
- Value type.@ChannelHandler.Sharable public class RedisAsyncConnectionImpl<K,V> extends RedisChannelHandler<K,V> implements RedisAsyncConnection<K,V>, RedisClusterAsyncConnection<K,V>
RedisAsyncConnectionImpl
provided they avoid blocking and transactional operations such as blpop(long, K...)
and multi()
/exec()
.
A ConnectionWatchdog
monitors each connection and reconnects automatically until RedisChannelHandler.close()
is called. All
pending commands will be (re)sent after successful reconnection.ChannelHandler.Sharable
Modifier and Type | Field and Description |
---|---|
protected RedisCodec<K,V> |
codec |
protected com.lambdaworks.redis.RedisCommandBuilder<K,V> |
commandBuilder |
protected MultiOutput<K,V> |
multi |
timeout, unit
Constructor and Description |
---|
RedisAsyncConnectionImpl(RedisChannelWriter<K,V> writer,
RedisCodec<K,V> codec,
long timeout,
TimeUnit unit)
Initialize a new connection.
|
Modifier and Type | Method and Description |
---|---|
void |
activated()
Notification when the connection becomes active (connected).
|
RedisFuture<Long> |
append(K key,
V value)
Append a value to a key.
|
RedisFuture<String> |
asking()
The asking command is required after a
-ASK redirection. |
String |
auth(String password)
Authenticate to the server.
|
RedisFuture<String> |
bgrewriteaof()
Asynchronously rewrite the append-only file.
|
RedisFuture<String> |
bgsave()
Asynchronously save the dataset to disk.
|
RedisFuture<Long> |
bitcount(K key)
Count set bits in a string.
|
RedisFuture<Long> |
bitcount(K key,
long start,
long end)
Count set bits in a string.
|
RedisFuture<List<Long>> |
bitfield(K key,
BitFieldArgs bitFieldArgs)
Execute
BITFIELD with its subcommands. |
RedisFuture<Long> |
bitopAnd(K destination,
K... keys)
Perform bitwise AND between strings.
|
RedisFuture<Long> |
bitopNot(K destination,
K source)
Perform bitwise NOT between strings.
|
RedisFuture<Long> |
bitopOr(K destination,
K... keys)
Perform bitwise OR between strings.
|
RedisFuture<Long> |
bitopXor(K destination,
K... keys)
Perform bitwise XOR between strings.
|
RedisFuture<Long> |
bitpos(K key,
boolean state)
Find first bit set or clear in a string.
|
RedisFuture<Long> |
bitpos(K key,
boolean state,
long start,
long end)
Find first bit set or clear in a string.
|
RedisFuture<KeyValue<K,V>> |
blpop(long timeout,
K... keys)
Remove and get the first element in a list, or block until one is available.
|
RedisFuture<KeyValue<K,V>> |
brpop(long timeout,
K... keys)
Remove and get the last element in a list, or block until one is available.
|
RedisFuture<V> |
brpoplpush(long timeout,
K source,
K destination)
Pop a value from a list, push it to another list and return it; or block until one is available.
|
RedisFuture<K> |
clientGetname()
Get the current connection name.
|
RedisFuture<Long> |
clientKill(KillArgs killArgs)
Kill connections of clients which are filtered by
killArgs |
RedisFuture<String> |
clientKill(String addr)
Kill the connection of a client identified by ip:port.
|
RedisFuture<String> |
clientList()
Get the list of client connections.
|
RedisFuture<String> |
clientPause(long timeout)
Stop processing commands from clients for some time.
|
RedisFuture<String> |
clientSetname(K name)
Set the current connection name.
|
RedisFuture<String> |
clusterAddSlots(int... slots)
Adds slots to the cluster node.
|
RedisFuture<String> |
clusterBumpepoch()
Generate a new config epoch, incrementing the current epoch, assign the new epoch to this node, WITHOUT any consensus and
persist the configuration on disk before sending packets with the new configuration.
|
RedisFuture<Long> |
clusterCountFailureReports(String nodeId)
Returns the number of failure reports for the specified node.
|
RedisFuture<Long> |
clusterCountKeysInSlot(int slot)
Returns the number of keys in the specified Redis Cluster hash
slot . |
RedisFuture<String> |
clusterDelSlots(int... slots)
Removes slots from the cluster node.
|
RedisFuture<String> |
clusterFailover(boolean force)
Failover a cluster node.
|
RedisFuture<String> |
clusterFlushslots()
Delete all the slots associated with the specified node.
|
RedisFuture<String> |
clusterForget(String nodeId)
Blacklist and remove the cluster node from the cluster.
|
RedisFuture<List<K>> |
clusterGetKeysInSlot(int slot,
int count)
Retrieve the list of keys within the
slot . |
RedisFuture<String> |
clusterInfo()
Get information and statistics about the cluster viewed by the current node.
|
RedisFuture<Long> |
clusterKeyslot(K key)
Returns an integer identifying the hash slot the specified key hashes to.
|
RedisFuture<String> |
clusterMeet(String ip,
int port)
Meet another cluster node to include the node into the cluster.
|
RedisFuture<String> |
clusterMyId()
Obtain the nodeId for the currently connected node.
|
RedisFuture<String> |
clusterNodes()
Obtain details about all cluster nodes.
|
RedisFuture<String> |
clusterReplicate(String nodeId)
Turn this node into a slave of the node with the id
nodeId . |
RedisFuture<String> |
clusterReset(boolean hard)
Reset a node performing a soft or hard reset:
All other nodes are forgotten
All the assigned / open slots are released
If the node is a slave, it turns into a master
Only for hard reset: a new Node ID is generated
Only for hard reset: currentEpoch and configEpoch are set to 0
The new configuration is saved and the cluster state updated
If the node was a slave, the whole data set is flushed away
|
RedisFuture<String> |
clusterSaveconfig()
Forces a node to save the nodes.conf configuration on disk.
|
RedisFuture<String> |
clusterSetConfigEpoch(long configEpoch)
This command sets a specific config epoch in a fresh node.
|
RedisFuture<String> |
clusterSetSlotImporting(int slot,
String nodeId)
Flag a slot as IMPORTING (incoming) from the node specified in
nodeId . |
RedisFuture<String> |
clusterSetSlotMigrating(int slot,
String nodeId)
Flag a slot as MIGRATING (outgoing) towards the node specified in
nodeId . |
RedisFuture<String> |
clusterSetSlotNode(int slot,
String nodeId)
Assign a slot to a node.
|
RedisFuture<String> |
clusterSetSlotStable(int slot)
Clears migrating / importing state from the slot.
|
RedisFuture<List<String>> |
clusterSlaves(String nodeId)
List slaves for a certain node identified by its
nodeId . |
RedisFuture<List<Object>> |
clusterSlots()
Get array of cluster slots to node mappings.
|
RedisFuture<List<Object>> |
command()
Returns an array reply of details about all Redis commands.
|
RedisFuture<Long> |
commandCount()
Get total number of Redis commands.
|
RedisFuture<List<Object>> |
commandInfo(CommandType... commands)
Returns an array reply of details about the requested commands.
|
RedisFuture<List<Object>> |
commandInfo(String... commands)
Returns an array reply of details about the requested commands.
|
RedisFuture<List<String>> |
configGet(String parameter)
Get the value of a configuration parameter.
|
RedisFuture<String> |
configResetstat()
Reset the stats returned by INFO.
|
RedisFuture<String> |
configRewrite()
Rewrite the configuration file with the in memory configuration.
|
RedisFuture<String> |
configSet(String parameter,
String value)
Set a configuration parameter to the given value.
|
RedisFuture<Long> |
dbsize()
Return the number of keys in the selected database.
|
RedisFuture<String> |
debugHtstats(int db)
Get debugging information about the internal hash-table state.
|
RedisFuture<String> |
debugObject(K key)
Get debugging information about a key.
|
void |
debugOom()
Make the server crash: Out of memory.
|
void |
debugSegfault()
Make the server crash: Invalid pointer access.
|
RedisFuture<Long> |
decr(K key)
Decrement the integer value of a key by one.
|
RedisFuture<Long> |
decrby(K key,
long amount)
Decrement the integer value of a key by the given number.
|
RedisFuture<Long> |
del(K... keys)
Delete one or more keys.
|
String |
digest(V script)
Create a SHA1 digest from a Lua script.
|
RedisFuture<String> |
discard()
Discard all commands issued after MULTI.
|
protected <T> RedisFuture<T> |
dispatch(CommandType type,
CommandOutput<K,V,T> output) |
protected <T> RedisCommand<K,V,T> |
dispatch(CommandType type,
CommandOutput<K,V,T> output,
CommandArgs<K,V> args) |
<T> RedisFuture<T> |
dispatch(ProtocolKeyword type,
CommandOutput<K,V,T> output)
Dispatch a command to the Redis Server.
|
<T> RedisFuture<T> |
dispatch(ProtocolKeyword type,
CommandOutput<K,V,T> output,
CommandArgs<K,V> args)
Dispatch a command to the Redis Server.
|
<T> RedisCommand<K,V,T> |
dispatch(RedisCommand<K,V,T> cmd) |
RedisFuture<byte[]> |
dump(K key)
Return a serialized version of the value stored at the specified key.
|
RedisFuture<V> |
echo(V msg)
Echo the given string.
|
<T> RedisFuture<T> |
eval(String script,
ScriptOutputType type,
K... keys)
Execute a Lua script server side.
|
<T> RedisFuture<T> |
eval(String script,
ScriptOutputType type,
K[] keys,
V... values)
Execute a Lua script server side.
|
<T> RedisFuture<T> |
evalsha(String digest,
ScriptOutputType type,
K... keys)
Evaluates a script cached on the server side by its SHA1 digest
|
<T> RedisFuture<T> |
evalsha(String digest,
ScriptOutputType type,
K[] keys,
V... values)
Execute a Lua script server side.
|
RedisFuture<List<Object>> |
exec()
Execute all commands issued after MULTI.
|
RedisFuture<Long> |
exists(K... keys)
Determine how many keys exist.
|
RedisFuture<Boolean> |
exists(K key)
Determine if a key exists.
|
RedisFuture<Boolean> |
expire(K key,
long seconds)
Set a key's time to live in seconds.
|
RedisFuture<Boolean> |
expireat(K key,
Date timestamp)
Set the expiration for a key as a UNIX timestamp.
|
RedisFuture<Boolean> |
expireat(K key,
long timestamp)
Set the expiration for a key as a UNIX timestamp.
|
RedisFuture<String> |
flushall()
Remove all keys from all databases.
|
RedisFuture<String> |
flushallAsync()
Remove all keys asynchronously from all databases.
|
RedisFuture<String> |
flushdb()
Remove all keys from the current database.
|
RedisFuture<String> |
flushdbAsync()
Remove all keys asynchronously from the current database.
|
RedisFuture<Long> |
geoadd(K key,
double longitude,
double latitude,
V member)
Single geo add.
|
RedisFuture<Long> |
geoadd(K key,
Object... lngLatMember)
Multi geo add.
|
RedisFuture<Double> |
geodist(K key,
V from,
V to,
GeoArgs.Unit unit)
Retrieve distance between points
from and to . |
RedisFuture<List<String>> |
geohash(K key,
V... members)
Retrieve Geohash strings representing the position of one or more elements in a sorted set value representing a geospatial index.
|
RedisFuture<List<GeoCoordinates>> |
geopos(K key,
V... members)
Get geo coordinates for the
members . |
RedisFuture<Set<V>> |
georadius(K key,
double longitude,
double latitude,
double distance,
GeoArgs.Unit unit)
Retrieve members selected by distance with the center of
longitude and latitude . |
RedisFuture<List<GeoWithin<V>>> |
georadius(K key,
double longitude,
double latitude,
double distance,
GeoArgs.Unit unit,
GeoArgs geoArgs)
Retrieve members selected by distance with the center of
longitude and latitude . |
RedisFuture<Long> |
georadius(K key,
double longitude,
double latitude,
double distance,
GeoArgs.Unit unit,
GeoRadiusStoreArgs<K> geoRadiusStoreArgs)
Perform a
RedisGeoAsyncConnection.georadius(Object, double, double, double, GeoArgs.Unit, GeoArgs) query and store the results in a
sorted set. |
RedisFuture<Set<V>> |
georadiusbymember(K key,
V member,
double distance,
GeoArgs.Unit unit)
Retrieve members selected by distance with the center of
member . |
RedisFuture<List<GeoWithin<V>>> |
georadiusbymember(K key,
V member,
double distance,
GeoArgs.Unit unit,
GeoArgs geoArgs)
Retrieve members selected by distance with the center of
member . |
RedisFuture<Long> |
georadiusbymember(K key,
V member,
double distance,
GeoArgs.Unit unit,
GeoRadiusStoreArgs<K> geoRadiusStoreArgs)
Perform a
RedisGeoAsyncConnection.georadiusbymember(Object, Object, double, GeoArgs.Unit, GeoArgs) query and store the results in a
sorted set. |
RedisFuture<V> |
get(K key)
Get the value of a key.
|
RedisFuture<Long> |
getbit(K key,
long offset)
Returns the bit value at offset in the string value stored at key.
|
RedisFuture<V> |
getrange(K key,
long start,
long end)
Get a substring of the string stored at a key.
|
RedisFuture<V> |
getset(K key,
V value)
Set the string value of a key and return its old value.
|
RedisFuture<Long> |
hdel(K key,
K... fields)
Delete one or more hash fields.
|
RedisFuture<Boolean> |
hexists(K key,
K field)
Determine if a hash field exists.
|
RedisFuture<V> |
hget(K key,
K field)
Get the value of a hash field.
|
RedisFuture<Map<K,V>> |
hgetall(K key)
Get all the fields and values in a hash.
|
RedisFuture<Long> |
hgetall(KeyValueStreamingChannel<K,V> channel,
K key)
Stream over all the fields and values in a hash.
|
RedisFuture<Long> |
hincrby(K key,
K field,
long amount)
Increment the integer value of a hash field by the given number.
|
RedisFuture<Double> |
hincrbyfloat(K key,
K field,
double amount)
Increment the float value of a hash field by the given amount.
|
RedisFuture<List<K>> |
hkeys(K key)
Get all the fields in a hash.
|
RedisFuture<Long> |
hkeys(KeyStreamingChannel<K> channel,
K key)
Get all the fields in a hash.
|
RedisFuture<Long> |
hlen(K key)
Get the number of fields in a hash.
|
RedisFuture<List<V>> |
hmget(K key,
K... fields)
Get the values of all the given hash fields.
|
RedisFuture<Long> |
hmget(ValueStreamingChannel<V> channel,
K key,
K... fields)
Stream over the values of all the given hash fields.
|
RedisFuture<String> |
hmset(K key,
Map<K,V> map)
Set multiple hash fields to multiple values.
|
RedisFuture<MapScanCursor<K,V>> |
hscan(K key)
Incrementally iterate hash fields and associated values.
|
RedisFuture<StreamScanCursor> |
hscan(KeyValueStreamingChannel<K,V> channel,
K key)
Incrementally iterate hash fields and associated values.
|
RedisFuture<StreamScanCursor> |
hscan(KeyValueStreamingChannel<K,V> channel,
K key,
ScanArgs scanArgs)
Incrementally iterate hash fields and associated values.
|
RedisFuture<StreamScanCursor> |
hscan(KeyValueStreamingChannel<K,V> channel,
K key,
ScanCursor scanCursor)
Incrementally iterate hash fields and associated values.
|
RedisFuture<StreamScanCursor> |
hscan(KeyValueStreamingChannel<K,V> channel,
K key,
ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate hash fields and associated values.
|
RedisFuture<MapScanCursor<K,V>> |
hscan(K key,
ScanArgs scanArgs)
Incrementally iterate hash fields and associated values.
|
RedisFuture<MapScanCursor<K,V>> |
hscan(K key,
ScanCursor scanCursor)
Incrementally iterate hash fields and associated values.
|
RedisFuture<MapScanCursor<K,V>> |
hscan(K key,
ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate hash fields and associated values.
|
RedisFuture<Boolean> |
hset(K key,
K field,
V value)
Set the string value of a hash field.
|
RedisFuture<Boolean> |
hsetnx(K key,
K field,
V value)
Set the value of a hash field, only if the field does not exist.
|
RedisFuture<Long> |
hstrlen(K key,
K field)
Get the string length of the field value in a hash.
|
RedisFuture<List<V>> |
hvals(K key)
Get all the values in a hash.
|
RedisFuture<Long> |
hvals(ValueStreamingChannel<V> channel,
K key)
Stream over all the values in a hash.
|
RedisFuture<Long> |
incr(K key)
Increment the integer value of a key by one.
|
RedisFuture<Long> |
incrby(K key,
long amount)
Increment the integer value of a key by the given amount.
|
RedisFuture<Double> |
incrbyfloat(K key,
double amount)
Increment the float value of a key by the given amount.
|
RedisFuture<String> |
info()
Get information and statistics about the server.
|
RedisFuture<String> |
info(String section)
Get information and statistics about the server.
|
protected boolean |
isMulti() |
RedisFuture<List<K>> |
keys(K pattern)
Find all keys matching the given pattern.
|
RedisFuture<Long> |
keys(KeyStreamingChannel<K> channel,
K pattern)
Find all keys matching the given pattern.
|
RedisFuture<Date> |
lastsave()
Get the UNIX time stamp of the last successful save to disk.
|
RedisFuture<V> |
lindex(K key,
long index)
Get an element from a list by its index.
|
RedisFuture<Long> |
linsert(K key,
boolean before,
V pivot,
V value)
Insert an element before or after another element in a list.
|
RedisFuture<Long> |
llen(K key)
Get the length of a list.
|
RedisFuture<V> |
lpop(K key)
Remove and get the first element in a list.
|
RedisFuture<Long> |
lpush(K key,
V... values)
Prepend one or multiple values to a list.
|
RedisFuture<Long> |
lpushx(K key,
V... values)
Prepend values to a list, only if the list exists.
|
RedisFuture<Long> |
lpushx(K key,
V value)
Prepend a value to a list, only if the list exists.
|
RedisFuture<List<V>> |
lrange(K key,
long start,
long stop)
Get a range of elements from a list.
|
RedisFuture<Long> |
lrange(ValueStreamingChannel<V> channel,
K key,
long start,
long stop)
Get a range of elements from a list.
|
RedisFuture<Long> |
lrem(K key,
long count,
V value)
Remove elements from a list.
|
RedisFuture<String> |
lset(K key,
long index,
V value)
Set the value of an element in a list by its index.
|
RedisFuture<String> |
ltrim(K key,
long start,
long stop)
Trim a list to the specified range.
|
RedisFuture<List<V>> |
mget(K... keys)
Get the values of all the given keys.
|
RedisFuture<Long> |
mget(ValueStreamingChannel<V> channel,
K... keys)
Stream the values of all the given keys.
|
RedisFuture<String> |
migrate(String host,
int port,
int db,
long timeout,
MigrateArgs<K> migrateArgs)
Atomically transfer one or more keys from a Redis instance to another one.
|
RedisFuture<String> |
migrate(String host,
int port,
K key,
int db,
long timeout)
Atomically transfer a key from a Redis instance to another one.
|
RedisFuture<Boolean> |
move(K key,
int db)
Move a key to another database.
|
RedisFuture<String> |
mset(Map<K,V> map)
Set multiple keys to multiple values.
|
RedisFuture<Boolean> |
msetnx(Map<K,V> map)
Set multiple keys to multiple values, only if none of the keys exist.
|
RedisFuture<String> |
multi()
Mark the start of a transaction block.
|
RedisFuture<String> |
objectEncoding(K key)
returns the kind of internal representation used in order to store the value associated with a key.
|
RedisFuture<Long> |
objectIdletime(K key)
returns the number of seconds since the object stored at the specified key is idle (not requested by read or write
operations).
|
RedisFuture<Long> |
objectRefcount(K key)
returns the number of references of the value associated with the specified key.
|
RedisFuture<Boolean> |
persist(K key)
Remove the expiration from a key.
|
RedisFuture<Boolean> |
pexpire(K key,
long milliseconds)
Set a key's time to live in milliseconds.
|
RedisFuture<Boolean> |
pexpireat(K key,
Date timestamp)
Set the expiration for a key as a UNIX timestamp specified in milliseconds.
|
RedisFuture<Boolean> |
pexpireat(K key,
long timestamp)
Set the expiration for a key as a UNIX timestamp specified in milliseconds.
|
RedisFuture<Long> |
pfadd(K key,
V value,
V... moreValues)
Adds the specified elements to the specified HyperLogLog.
|
RedisFuture<Long> |
pfcount(K key,
K... moreKeys)
Return the approximated cardinality of the set(s) observed by the HyperLogLog at key(s).
|
RedisFuture<String> |
pfmerge(K destkey,
K sourcekey,
K... moreSourceKeys)
Merge N different HyperLogLogs into a single one.
|
RedisFuture<String> |
ping()
Ping the server.
|
RedisFuture<String> |
psetex(K key,
long milliseconds,
V value)
Set the value and expiration in milliseconds of a key.
|
RedisFuture<Long> |
pttl(K key)
Get the time to live for a key in milliseconds.
|
RedisFuture<Long> |
publish(K channel,
V message)
Post a message to a channel.
|
RedisFuture<List<K>> |
pubsubChannels()
Lists the currently *active channels*.
|
RedisFuture<List<K>> |
pubsubChannels(K channel)
Lists the currently *active channels*.
|
RedisFuture<Long> |
pubsubNumpat()
Returns the number of subscriptions to patterns.
|
RedisFuture<Map<K,Long>> |
pubsubNumsub(K... channels)
Returns the number of subscribers (not counting clients subscribed to patterns) for the specified channels.
|
RedisFuture<String> |
quit()
Close the connection.
|
RedisFuture<V> |
randomkey()
Return a random key from the keyspace.
|
String |
readOnly()
Tells a Redis cluster slave node that the client is ok reading possibly stale data and is not interested in running write
queries.
|
String |
readWrite()
Resets readOnly flag.
|
RedisFuture<String> |
rename(K key,
K newKey)
Rename a key.
|
RedisFuture<Boolean> |
renamenx(K key,
K newKey)
Rename a key, only if the new key does not exist.
|
RedisFuture<String> |
restore(K key,
long ttl,
byte[] value)
Create a key using the provided serialized value, previously obtained using DUMP.
|
RedisFuture<List<Object>> |
role()
Return the role of the instance in the context of replication.
|
RedisFuture<V> |
rpop(K key)
Remove and get the last element in a list.
|
RedisFuture<V> |
rpoplpush(K source,
K destination)
Remove the last element in a list, append it to another list and return it.
|
RedisFuture<Long> |
rpush(K key,
V... values)
Append one or multiple values to a list.
|
RedisFuture<Long> |
rpushx(K key,
V... values)
Append values to a list, only if the list exists.
|
RedisFuture<Long> |
rpushx(K key,
V value)
Append a value to a list, only if the list exists.
|
RedisFuture<Long> |
sadd(K key,
V... members)
Add one or more members to a set.
|
RedisFuture<String> |
save()
Synchronously save the dataset to disk.
|
RedisFuture<KeyScanCursor<K>> |
scan()
Incrementally iterate the keys space.
|
RedisFuture<StreamScanCursor> |
scan(KeyStreamingChannel<K> channel)
Incrementally iterate the keys space.
|
RedisFuture<StreamScanCursor> |
scan(KeyStreamingChannel<K> channel,
ScanArgs scanArgs)
Incrementally iterate the keys space.
|
RedisFuture<StreamScanCursor> |
scan(KeyStreamingChannel<K> channel,
ScanCursor scanCursor)
Incrementally iterate the keys space.
|
RedisFuture<StreamScanCursor> |
scan(KeyStreamingChannel<K> channel,
ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate the keys space.
|
RedisFuture<KeyScanCursor<K>> |
scan(ScanArgs scanArgs)
Incrementally iterate the keys space.
|
RedisFuture<KeyScanCursor<K>> |
scan(ScanCursor scanCursor)
Incrementally iterate the keys space.
|
RedisFuture<KeyScanCursor<K>> |
scan(ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate the keys space.
|
RedisFuture<Long> |
scard(K key)
Get the number of members in a set.
|
RedisFuture<List<Boolean>> |
scriptExists(String... digests)
Check existence of scripts in the script cache.
|
RedisFuture<String> |
scriptFlush()
Remove all the scripts from the script cache.
|
RedisFuture<String> |
scriptKill()
Kill the script currently in execution.
|
RedisFuture<String> |
scriptLoad(V script)
Load the specified Lua script into the script cache.
|
RedisFuture<Set<V>> |
sdiff(K... keys)
Subtract multiple sets.
|
RedisFuture<Long> |
sdiff(ValueStreamingChannel<V> channel,
K... keys)
Subtract multiple sets.
|
RedisFuture<Long> |
sdiffstore(K destination,
K... keys)
Subtract multiple sets and store the resulting set in a key.
|
String |
select(int db)
Change the selected database for the current connection.
|
RedisFuture<String> |
set(K key,
V value)
Set the string value of a key.
|
RedisFuture<String> |
set(K key,
V value,
SetArgs setArgs)
Set the string value of a key.
|
RedisFuture<Long> |
setbit(K key,
long offset,
int value)
Sets or clears the bit at offset in the string value stored at key.
|
RedisFuture<String> |
setex(K key,
long seconds,
V value)
Set the value and expiration of a key.
|
RedisFuture<Boolean> |
setnx(K key,
V value)
Set the value of a key, only if the key does not exist.
|
RedisFuture<Long> |
setrange(K key,
long offset,
V value)
Overwrite part of a string at key starting at the specified offset.
|
void |
shutdown()
Deprecated.
|
void |
shutdown(boolean save)
Synchronously save the dataset to disk and then shut down the server.
|
RedisFuture<Set<V>> |
sinter(K... keys)
Intersect multiple sets.
|
RedisFuture<Long> |
sinter(ValueStreamingChannel<V> channel,
K... keys)
Intersect multiple sets.
|
RedisFuture<Long> |
sinterstore(K destination,
K... keys)
Intersect multiple sets and store the resulting set in a key.
|
RedisFuture<Boolean> |
sismember(K key,
V member)
Determine if a given value is a member of a set.
|
RedisFuture<String> |
slaveof(String host,
int port)
Make the server a slave of another instance.
|
RedisFuture<String> |
slaveofNoOne()
Promote server as master.
|
RedisFuture<List<Object>> |
slowlogGet()
Read the slow log.
|
RedisFuture<List<Object>> |
slowlogGet(int count)
Read the slow log.
|
RedisFuture<Long> |
slowlogLen()
Obtaining the current length of the slow log.
|
RedisFuture<String> |
slowlogReset()
Resetting the slow log.
|
RedisFuture<Set<V>> |
smembers(K key)
Get all the members in a set.
|
RedisFuture<Long> |
smembers(ValueStreamingChannel<V> channel,
K key)
Get all the members in a set.
|
RedisFuture<Boolean> |
smove(K source,
K destination,
V member)
Move a member from one set to another.
|
RedisFuture<List<V>> |
sort(K key)
Sort the elements in a list, set or sorted set.
|
RedisFuture<List<V>> |
sort(K key,
SortArgs sortArgs)
Sort the elements in a list, set or sorted set.
|
RedisFuture<Long> |
sort(ValueStreamingChannel<V> channel,
K key)
Sort the elements in a list, set or sorted set.
|
RedisFuture<Long> |
sort(ValueStreamingChannel<V> channel,
K key,
SortArgs sortArgs)
Sort the elements in a list, set or sorted set.
|
RedisFuture<Long> |
sortStore(K key,
SortArgs sortArgs,
K destination)
Sort the elements in a list, set or sorted set.
|
RedisFuture<V> |
spop(K key)
Remove and return a random member from a set.
|
RedisFuture<Set<V>> |
spop(K key,
long count)
Remove and return one or multiple random members from a set.
|
RedisFuture<V> |
srandmember(K key)
Get one or multiple random members from a set.
|
RedisFuture<Set<V>> |
srandmember(K key,
long count)
Get one or multiple random members from a set.
|
RedisFuture<Long> |
srandmember(ValueStreamingChannel<V> channel,
K key,
long count)
Get one or multiple random members from a set.
|
RedisFuture<Long> |
srem(K key,
V... members)
Remove one or more members from a set.
|
RedisFuture<ValueScanCursor<V>> |
sscan(K key)
Incrementally iterate Set elements.
|
RedisFuture<ValueScanCursor<V>> |
sscan(K key,
ScanArgs scanArgs)
Incrementally iterate Set elements.
|
RedisFuture<ValueScanCursor<V>> |
sscan(K key,
ScanCursor scanCursor)
Incrementally iterate Set elements.
|
RedisFuture<ValueScanCursor<V>> |
sscan(K key,
ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate Set elements.
|
RedisFuture<StreamScanCursor> |
sscan(ValueStreamingChannel<V> channel,
K key)
Incrementally iterate Set elements.
|
RedisFuture<StreamScanCursor> |
sscan(ValueStreamingChannel<V> channel,
K key,
ScanArgs scanArgs)
Incrementally iterate Set elements.
|
RedisFuture<StreamScanCursor> |
sscan(ValueStreamingChannel<V> channel,
K key,
ScanCursor scanCursor)
Incrementally iterate Set elements.
|
RedisFuture<StreamScanCursor> |
sscan(ValueStreamingChannel<V> channel,
K key,
ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate Set elements.
|
static String |
string(double n) |
RedisFuture<Long> |
strlen(K key)
Get the length of the value stored in a key.
|
RedisFuture<Set<V>> |
sunion(K... keys)
Add multiple sets.
|
RedisFuture<Long> |
sunion(ValueStreamingChannel<V> channel,
K... keys)
Add multiple sets.
|
RedisFuture<Long> |
sunionstore(K destination,
K... keys)
Add multiple sets and store the resulting set in a key.
|
RedisFuture<String> |
sync()
Internal command used for replication.
|
RedisFuture<List<V>> |
time()
Return the current server time.
|
RedisFuture<Long> |
touch(K... keys)
Touch one or more keys.
|
RedisFuture<Long> |
ttl(K key)
Get the time to live for a key.
|
RedisFuture<String> |
type(K key)
Determine the type stored at key.
|
RedisFuture<Long> |
unlink(K... keys)
Unlink one or more keys (non blocking DEL).
|
RedisFuture<String> |
unwatch()
Forget about all watched keys.
|
RedisFuture<Long> |
waitForReplication(int replicas,
long timeout)
Wait for replication.
|
RedisFuture<String> |
watch(K... keys)
Watch the given keys to determine execution of the MULTI/EXEC block.
|
RedisFuture<Long> |
zadd(K key,
double score,
V member)
Add one or more members to a sorted set, or update its score if it already exists.
|
RedisFuture<Long> |
zadd(K key,
Object... scoresAndValues)
Add one or more members to a sorted set, or update its score if it already exists.
|
RedisFuture<Long> |
zadd(K key,
ZAddArgs zAddArgs,
double score,
V member)
Add one or more members to a sorted set, or update its score if it already exists.
|
RedisFuture<Long> |
zadd(K key,
ZAddArgs zAddArgs,
Object... scoresAndValues)
Add one or more members to a sorted set, or update its score if it already exists.
|
RedisFuture<Double> |
zaddincr(K key,
double score,
V member)
ZADD acts like ZINCRBY
|
RedisFuture<Long> |
zcard(K key)
Get the number of members in a sorted set.
|
RedisFuture<Long> |
zcount(K key,
double min,
double max)
Count the members in a sorted set with scores within the given values.
|
RedisFuture<Long> |
zcount(K key,
String min,
String max)
Count the members in a sorted set with scores within the given values.
|
RedisFuture<Double> |
zincrby(K key,
double amount,
K member)
Increment the score of a member in a sorted set.
|
RedisFuture<Long> |
zinterstore(K destination,
K... keys)
Intersect multiple sorted sets and store the resulting sorted set in a new key.
|
RedisFuture<Long> |
zinterstore(K destination,
ZStoreArgs storeArgs,
K... keys)
Intersect multiple sorted sets and store the resulting sorted set in a new key.
|
RedisFuture<Long> |
zlexcount(K key,
String min,
String max)
Count the number of members in a sorted set between a given lexicographical range.
|
RedisFuture<List<V>> |
zrange(K key,
long start,
long stop)
Return a range of members in a sorted set, by index.
|
RedisFuture<Long> |
zrange(ValueStreamingChannel<V> channel,
K key,
long start,
long stop)
Stream over a range of members in a sorted set, by index.
|
RedisFuture<List<V>> |
zrangebylex(K key,
String min,
String max)
Return a range of members in a sorted set, by lexicographical range.
|
RedisFuture<List<V>> |
zrangebylex(K key,
String min,
String max,
long offset,
long count)
Return a range of members in a sorted set, by lexicographical range.
|
RedisFuture<List<V>> |
zrangebyscore(K key,
double min,
double max)
Return a range of members in a sorted set, by score.
|
RedisFuture<List<V>> |
zrangebyscore(K key,
double min,
double max,
long offset,
long count)
Return a range of members in a sorted set, by score.
|
RedisFuture<List<V>> |
zrangebyscore(K key,
String min,
String max)
Return a range of members in a sorted set, by score.
|
RedisFuture<List<V>> |
zrangebyscore(K key,
String min,
String max,
long offset,
long count)
Return a range of members in a sorted set, by score.
|
RedisFuture<Long> |
zrangebyscore(ValueStreamingChannel<V> channel,
K key,
double min,
double max)
Stream over a range of members in a sorted set, by score.
|
RedisFuture<Long> |
zrangebyscore(ValueStreamingChannel<V> channel,
K key,
double min,
double max,
long offset,
long count)
Stream over a range of members in a sorted set, by score.
|
RedisFuture<Long> |
zrangebyscore(ValueStreamingChannel<V> channel,
K key,
String min,
String max)
Stream over a range of members in a sorted set, by score.
|
RedisFuture<Long> |
zrangebyscore(ValueStreamingChannel<V> channel,
K key,
String min,
String max,
long offset,
long count)
Stream over a range of members in a sorted set, by score.
|
RedisFuture<List<ScoredValue<V>>> |
zrangebyscoreWithScores(K key,
double min,
double max)
Return a range of members with score in a sorted set, by score.
|
RedisFuture<List<ScoredValue<V>>> |
zrangebyscoreWithScores(K key,
double min,
double max,
long offset,
long count)
Return a range of members with score in a sorted set, by score.
|
RedisFuture<List<ScoredValue<V>>> |
zrangebyscoreWithScores(K key,
String min,
String max)
Return a range of members with score in a sorted set, by score.
|
RedisFuture<List<ScoredValue<V>>> |
zrangebyscoreWithScores(K key,
String min,
String max,
long offset,
long count)
Return a range of members with score in a sorted set, by score.
|
RedisFuture<Long> |
zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
double min,
double max)
Stream over a range of members with scores in a sorted set, by score.
|
RedisFuture<Long> |
zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
double min,
double max,
long offset,
long count)
Stream over a range of members with scores in a sorted set, by score.
|
RedisFuture<Long> |
zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
String min,
String max)
Stream over a range of members with scores in a sorted set, by score.
|
RedisFuture<Long> |
zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
String min,
String max,
long offset,
long count)
Stream over a range of members with scores in a sorted set, by score.
|
RedisFuture<List<ScoredValue<V>>> |
zrangeWithScores(K key,
long start,
long stop)
Return a range of members in a sorted set, by index.
|
RedisFuture<Long> |
zrangeWithScores(ScoredValueStreamingChannel<V> channel,
K key,
long start,
long stop)
Stream over a range of members with scores in a sorted set, by index.
|
RedisFuture<Long> |
zrank(K key,
V member)
Determine the index of a member in a sorted set.
|
RedisFuture<Long> |
zrem(K key,
V... members)
Remove one or more members from a sorted set.
|
RedisFuture<Long> |
zremrangebylex(K key,
String min,
String max)
Remove all members in a sorted set between the given lexicographical range.
|
RedisFuture<Long> |
zremrangebyrank(K key,
long start,
long stop)
Remove all members in a sorted set within the given indexes.
|
RedisFuture<Long> |
zremrangebyscore(K key,
double min,
double max)
Remove all members in a sorted set within the given scores.
|
RedisFuture<Long> |
zremrangebyscore(K key,
String min,
String max)
Remove all members in a sorted set within the given scores.
|
RedisFuture<List<V>> |
zrevrange(K key,
long start,
long stop)
Return a range of members in a sorted set, by index, with scores ordered from high to low.
|
RedisFuture<Long> |
zrevrange(ValueStreamingChannel<V> channel,
K key,
long start,
long stop)
Stream over a range of members in a sorted set, by index, with scores ordered from high to low.
|
RedisFuture<List<V>> |
zrevrangebyscore(K key,
double max,
double min)
Return a range of members in a sorted set, by score, with scores ordered from high to low.
|
RedisFuture<List<V>> |
zrevrangebyscore(K key,
double max,
double min,
long offset,
long count)
Return a range of members in a sorted set, by score, with scores ordered from high to low.
|
RedisFuture<List<V>> |
zrevrangebyscore(K key,
String max,
String min)
Return a range of members in a sorted set, by score, with scores ordered from high to low.
|
RedisFuture<List<V>> |
zrevrangebyscore(K key,
String max,
String min,
long offset,
long count)
Return a range of members in a sorted set, by score, with scores ordered from high to low.
|
RedisFuture<Long> |
zrevrangebyscore(ValueStreamingChannel<V> channel,
K key,
double max,
double min)
Stream over a range of members in a sorted set, by score, with scores ordered from high to low.
|
RedisFuture<Long> |
zrevrangebyscore(ValueStreamingChannel<V> channel,
K key,
double max,
double min,
long offset,
long count)
Stream over a range of members in a sorted set, by score, with scores ordered from high to low.
|
RedisFuture<Long> |
zrevrangebyscore(ValueStreamingChannel<V> channel,
K key,
String max,
String min)
Stream over a range of members in a sorted set, by score, with scores ordered from high to low.
|
RedisFuture<Long> |
zrevrangebyscore(ValueStreamingChannel<V> channel,
K key,
String max,
String min,
long offset,
long count)
Stream over a range of members in a sorted set, by score, with scores ordered from high to low.
|
RedisFuture<List<ScoredValue<V>>> |
zrevrangebyscoreWithScores(K key,
double max,
double min)
Return a range of members with scores in a sorted set, by score, with scores ordered from high to low.
|
RedisFuture<List<ScoredValue<V>>> |
zrevrangebyscoreWithScores(K key,
double max,
double min,
long offset,
long count)
Return a range of members with scores in a sorted set, by score, with scores ordered from high to low.
|
RedisFuture<List<ScoredValue<V>>> |
zrevrangebyscoreWithScores(K key,
String max,
String min)
Return a range of members with scores in a sorted set, by score, with scores ordered from high to low.
|
RedisFuture<List<ScoredValue<V>>> |
zrevrangebyscoreWithScores(K key,
String max,
String min,
long offset,
long count)
Return a range of members with scores in a sorted set, by score, with scores ordered from high to low.
|
RedisFuture<Long> |
zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
double max,
double min)
Stream over a range of members with scores in a sorted set, by score, with scores ordered from high to low.
|
RedisFuture<Long> |
zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
double max,
double min,
long offset,
long count)
Stream over a range of members with scores in a sorted set, by score, with scores ordered from high to low.
|
RedisFuture<Long> |
zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
String max,
String min)
Stream over a range of members with scores in a sorted set, by score, with scores ordered from high to low.
|
RedisFuture<Long> |
zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel,
K key,
String max,
String min,
long offset,
long count)
Stream over a range of members with scores in a sorted set, by score, with scores ordered from high to low.
|
RedisFuture<List<ScoredValue<V>>> |
zrevrangeWithScores(K key,
long start,
long stop)
Return a range of members with scores in a sorted set, by index, with scores ordered from high to low.
|
RedisFuture<Long> |
zrevrangeWithScores(ScoredValueStreamingChannel<V> channel,
K key,
long start,
long stop)
Stream over a range of members with scores in a sorted set, by index, with scores ordered from high to low.
|
RedisFuture<Long> |
zrevrank(K key,
V member)
Determine the index of a member in a sorted set, with scores ordered from high to low.
|
RedisFuture<ScoredValueScanCursor<V>> |
zscan(K key)
Incrementally iterate sorted sets elements and associated scores.
|
RedisFuture<ScoredValueScanCursor<V>> |
zscan(K key,
ScanArgs scanArgs)
Incrementally iterate sorted sets elements and associated scores.
|
RedisFuture<ScoredValueScanCursor<V>> |
zscan(K key,
ScanCursor scanCursor)
Incrementally iterate sorted sets elements and associated scores.
|
RedisFuture<ScoredValueScanCursor<V>> |
zscan(K key,
ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate sorted sets elements and associated scores.
|
RedisFuture<StreamScanCursor> |
zscan(ScoredValueStreamingChannel<V> channel,
K key)
Incrementally iterate sorted sets elements and associated scores.
|
RedisFuture<StreamScanCursor> |
zscan(ScoredValueStreamingChannel<V> channel,
K key,
ScanArgs scanArgs)
Incrementally iterate sorted sets elements and associated scores.
|
RedisFuture<StreamScanCursor> |
zscan(ScoredValueStreamingChannel<V> channel,
K key,
ScanCursor scanCursor)
Incrementally iterate sorted sets elements and associated scores.
|
RedisFuture<StreamScanCursor> |
zscan(ScoredValueStreamingChannel<V> channel,
K key,
ScanCursor scanCursor,
ScanArgs scanArgs)
Incrementally iterate sorted sets elements and associated scores.
|
RedisFuture<Double> |
zscore(K key,
V member)
Get the score associated with the given member in a sorted set.
|
RedisFuture<Long> |
zunionstore(K destination,
K... keys)
Add multiple sorted sets and store the resulting sorted set in a new key.
|
RedisFuture<Long> |
zunionstore(K destination,
ZStoreArgs storeArgs,
K... keys)
Add multiple sorted sets and store the resulting sorted set in a new key.
|
addListener, channelRead, channelRead, channelRegistered, close, deactivated, flushCommands, getChannelWriter, getOptions, getTimeout, getTimeoutUnit, isClosed, isOpen, registerCloseables, reset, setAutoFlushCommands, setOptions, setTimeout
channelActive, channelInactive, channelReadComplete, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered
handlerAdded, handlerRemoved, isSharable
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
setTimeout
close
flushCommands, isOpen, setAutoFlushCommands
handlerAdded, handlerRemoved
protected MultiOutput<K,V> multi
protected RedisCodec<K,V> codec
public RedisAsyncConnectionImpl(RedisChannelWriter<K,V> writer, RedisCodec<K,V> codec, long timeout, TimeUnit unit)
writer
- the channel writercodec
- Codec used to encode/decode keys and values.timeout
- Maximum time to wait for a response.unit
- Unit of time for the timeout.public RedisFuture<Long> append(K key, V value)
RedisStringsAsyncConnection
append
in interface RedisStringsAsyncConnection<K,V>
key
- the keyvalue
- the valuepublic String auth(String password)
RedisAsyncConnection
auth
in interface RedisAsyncConnection<K,V>
password
- the passwordpublic RedisFuture<String> bgrewriteaof()
RedisServerAsyncConnection
bgrewriteaof
in interface RedisServerAsyncConnection<K,V>
OK
.public RedisFuture<String> bgsave()
RedisServerAsyncConnection
bgsave
in interface RedisServerAsyncConnection<K,V>
public RedisFuture<Long> bitcount(K key)
RedisStringsAsyncConnection
bitcount
in interface RedisStringsAsyncConnection<K,V>
key
- the keypublic RedisFuture<Long> bitcount(K key, long start, long end)
RedisStringsAsyncConnection
bitcount
in interface RedisStringsAsyncConnection<K,V>
key
- the keystart
- the startend
- the endpublic RedisFuture<List<Long>> bitfield(K key, BitFieldArgs bitFieldArgs)
RedisStringsAsyncConnection
BITFIELD
with its subcommands.bitfield
in interface RedisStringsAsyncConnection<K,V>
key
- the keybitFieldArgs
- the args containing subcommands, must not be null.public RedisFuture<Long> bitpos(K key, boolean state)
RedisStringsAsyncConnection
bitpos
in interface RedisStringsAsyncConnection<K,V>
key
- the keystate
- the stateBITPOS key 0
will return 24, since up to bit 23 all the bits are 1.
Basically the function consider the right of the string as padded with zeros if you look for clear bits and
specify no range or the start argument only.
However this behavior changes if you are looking for clear bits and specify a range with both
end and end. If no clear bit is found in the specified range, the function
returns -1 as the user specified a clear range and there are no 0 bits in that range.public RedisFuture<Long> bitpos(K key, boolean state, long start, long end)
RedisStringsAsyncConnection
bitpos
in interface RedisStringsAsyncConnection<K,V>
key
- the keystate
- the bit type: longstart
- the start type: longend
- the end type: longBITPOS key 0
will return 24, since up to bit 23 all the bits are 1.
Basically the function consider the right of the string as padded with zeros if you look for clear bits and
specify no range or the start argument only.
However this behavior changes if you are looking for clear bits and specify a range with both
start and end. If no clear bit is found in the specified range, the function
returns -1 as the user specified a clear range and there are no 0 bits in that range.public RedisFuture<Long> bitopAnd(K destination, K... keys)
RedisStringsAsyncConnection
bitopAnd
in interface RedisStringsAsyncConnection<K,V>
destination
- result key of the operationkeys
- operation input key namespublic RedisFuture<Long> bitopNot(K destination, K source)
RedisStringsAsyncConnection
bitopNot
in interface RedisStringsAsyncConnection<K,V>
destination
- result key of the operationsource
- operation input key namespublic RedisFuture<Long> bitopOr(K destination, K... keys)
RedisStringsAsyncConnection
bitopOr
in interface RedisStringsAsyncConnection<K,V>
destination
- result key of the operationkeys
- operation input key namespublic RedisFuture<Long> bitopXor(K destination, K... keys)
RedisStringsAsyncConnection
bitopXor
in interface RedisStringsAsyncConnection<K,V>
destination
- result key of the operationkeys
- operation input key namespublic RedisFuture<KeyValue<K,V>> blpop(long timeout, K... keys)
RedisListsAsyncConnection
blpop
in interface RedisListsAsyncConnection<K,V>
timeout
- the timeout in secondskeys
- the keyspublic RedisFuture<KeyValue<K,V>> brpop(long timeout, K... keys)
RedisListsAsyncConnection
brpop
in interface RedisListsAsyncConnection<K,V>
timeout
- the timeout in secondskeys
- the keyspublic RedisFuture<V> brpoplpush(long timeout, K source, K destination)
RedisListsAsyncConnection
brpoplpush
in interface RedisListsAsyncConnection<K,V>
timeout
- the timeout in secondssource
- the source keydestination
- the destination type: keysource
and pushed to
destination
. If timeout
is reached, apublic RedisFuture<K> clientGetname()
RedisServerAsyncConnection
clientGetname
in interface RedisServerAsyncConnection<K,V>
public RedisFuture<String> clientSetname(K name)
RedisServerAsyncConnection
clientSetname
in interface RedisServerAsyncConnection<K,V>
name
- the client nameOK
if the connection name was successfully set.public RedisFuture<String> clientKill(String addr)
RedisServerAsyncConnection
clientKill
in interface RedisServerAsyncConnection<K,V>
addr
- the addr in format ip:portOK
if the connection exists and has been closedpublic RedisFuture<Long> clientKill(KillArgs killArgs)
RedisServerAsyncConnection
killArgs
clientKill
in interface RedisServerAsyncConnection<K,V>
killArgs
- args for the kill operationpublic RedisFuture<String> clientPause(long timeout)
RedisServerAsyncConnection
clientPause
in interface RedisServerAsyncConnection<K,V>
timeout
- the timeout value in millisecondspublic RedisFuture<String> clientList()
RedisServerAsyncConnection
clientList
in interface RedisServerAsyncConnection<K,V>
public RedisFuture<List<Object>> command()
RedisServerAsyncConnection
command
in interface RedisServerAsyncConnection<K,V>
public RedisFuture<List<Object>> commandInfo(String... commands)
RedisServerAsyncConnection
commandInfo
in interface RedisServerAsyncConnection<K,V>
commands
- the commands to query forpublic RedisFuture<List<Object>> commandInfo(CommandType... commands)
RedisServerAsyncConnection
commandInfo
in interface RedisServerAsyncConnection<K,V>
commands
- the commands to query forpublic RedisFuture<Long> commandCount()
RedisServerAsyncConnection
commandCount
in interface RedisServerAsyncConnection<K,V>
public RedisFuture<List<String>> configGet(String parameter)
RedisServerAsyncConnection
configGet
in interface RedisServerAsyncConnection<K,V>
parameter
- the parameterpublic RedisFuture<String> configResetstat()
RedisServerAsyncConnection
configResetstat
in interface RedisServerAsyncConnection<K,V>
OK
.public RedisFuture<String> configSet(String parameter, String value)
RedisServerAsyncConnection
configSet
in interface RedisServerAsyncConnection<K,V>
parameter
- the parameter namevalue
- the parameter valueOK
when the configuration was set properly. Otherwise an
error is returned.public RedisFuture<String> configRewrite()
RedisServerAsyncConnection
configRewrite
in interface RedisServerAsyncConnection<K,V>
OK
when the configuration was rewritten properly. Otherwise
an error is returned.public RedisFuture<Long> dbsize()
RedisServerAsyncConnection
dbsize
in interface RedisServerAsyncConnection<K,V>
public RedisFuture<String> debugObject(K key)
RedisServerAsyncConnection
debugObject
in interface RedisServerAsyncConnection<K,V>
key
- the keypublic void debugSegfault()
RedisServerAsyncConnection
debugSegfault
in interface RedisServerAsyncConnection<K,V>
public void debugOom()
RedisServerAsyncConnection
debugOom
in interface RedisServerAsyncConnection<K,V>
public RedisFuture<String> debugHtstats(int db)
RedisServerAsyncConnection
debugHtstats
in interface RedisServerAsyncConnection<K,V>
db
- the database numberpublic RedisFuture<Long> decr(K key)
RedisStringsAsyncConnection
decr
in interface RedisStringsAsyncConnection<K,V>
key
- the keykey
after the decrementpublic RedisFuture<Long> decrby(K key, long amount)
RedisStringsAsyncConnection
decrby
in interface RedisStringsAsyncConnection<K,V>
key
- the keyamount
- the decrement type: longkey
after the decrementpublic RedisFuture<Long> del(K... keys)
RedisKeysAsyncConnection
del
in interface RedisKeysAsyncConnection<K,V>
keys
- the keyspublic RedisFuture<Long> unlink(K... keys)
RedisKeysAsyncConnection
unlink
in interface RedisKeysAsyncConnection<K,V>
keys
- the keyspublic RedisFuture<String> discard()
BaseRedisAsyncConnection
discard
in interface BaseRedisAsyncConnection<K,V>
OK
.public RedisFuture<byte[]> dump(K key)
RedisKeysAsyncConnection
dump
in interface RedisKeysAsyncConnection<K,V>
key
- the keypublic RedisFuture<V> echo(V msg)
BaseRedisAsyncConnection
echo
in interface BaseRedisAsyncConnection<K,V>
msg
- the message type: valuepublic <T> RedisFuture<T> eval(String script, ScriptOutputType type, K... keys)
RedisScriptingAsyncConnection
eval
in interface RedisScriptingAsyncConnection<K,V>
T
- expected return typescript
- Lua 5.1 script.type
- output typekeys
- key namespublic <T> RedisFuture<T> eval(String script, ScriptOutputType type, K[] keys, V... values)
RedisScriptingAsyncConnection
eval
in interface RedisScriptingAsyncConnection<K,V>
T
- expected return typescript
- Lua 5.1 script.type
- the typekeys
- the keysvalues
- the valuespublic <T> RedisFuture<T> evalsha(String digest, ScriptOutputType type, K... keys)
RedisScriptingAsyncConnection
evalsha
in interface RedisScriptingAsyncConnection<K,V>
T
- expected return typedigest
- SHA1 of the scripttype
- the typekeys
- the keyspublic <T> RedisFuture<T> evalsha(String digest, ScriptOutputType type, K[] keys, V... values)
RedisScriptingAsyncConnection
evalsha
in interface RedisScriptingAsyncConnection<K,V>
T
- expected return typedigest
- SHA1 of the scripttype
- the typekeys
- the keysvalues
- the valuespublic RedisFuture<Boolean> exists(K key)
RedisKeysAsyncConnection
exists
in interface RedisKeysAsyncConnection<K,V>
key
- the keypublic RedisFuture<Long> exists(K... keys)
RedisKeysAsyncConnection
exists
in interface RedisKeysAsyncConnection<K,V>
keys
- the keyspublic RedisFuture<Boolean> expire(K key, long seconds)
RedisKeysAsyncConnection
expire
in interface RedisKeysAsyncConnection<K,V>
key
- the keyseconds
- the seconds type: longkey
does not exist or the timeout could not
be set.public RedisFuture<Boolean> expireat(K key, Date timestamp)
RedisKeysAsyncConnection
expireat
in interface RedisKeysAsyncConnection<K,V>
key
- the keytimestamp
- the timestamp type: posix timekey
does not exist or the timeout could not
be set (see: EXPIRE
).public RedisFuture<Boolean> expireat(K key, long timestamp)
RedisKeysAsyncConnection
expireat
in interface RedisKeysAsyncConnection<K,V>
key
- the keytimestamp
- the timestamp type: posix timekey
does not exist or the timeout could not
be set (see: EXPIRE
).public RedisFuture<List<Object>> exec()
BaseRedisAsyncConnection
exec
in interface BaseRedisAsyncConnection<K,V>
WATCH
, EXEC
can return apublic RedisFuture<String> flushall()
RedisServerAsyncConnection
flushall
in interface RedisServerAsyncConnection<K,V>
public RedisFuture<String> flushallAsync()
RedisServerAsyncConnection
flushallAsync
in interface RedisServerAsyncConnection<K,V>
public RedisFuture<String> flushdb()
RedisServerAsyncConnection
flushdb
in interface RedisServerAsyncConnection<K,V>
public RedisFuture<String> flushdbAsync()
RedisServerAsyncConnection
flushdbAsync
in interface RedisServerAsyncConnection<K,V>
public RedisFuture<V> get(K key)
RedisStringsAsyncConnection
get
in interface RedisStringsAsyncConnection<K,V>
key
- the keykey
, or null when key
does not
exist.public RedisFuture<Long> getbit(K key, long offset)
RedisStringsAsyncConnection
getbit
in interface RedisStringsAsyncConnection<K,V>
key
- the keyoffset
- the offset type: longpublic RedisFuture<V> getrange(K key, long start, long end)
RedisStringsAsyncConnection
getrange
in interface RedisStringsAsyncConnection<K,V>
key
- the keystart
- the start type: longend
- the end type: longpublic RedisFuture<V> getset(K key, V value)
RedisStringsAsyncConnection
getset
in interface RedisStringsAsyncConnection<K,V>
key
- the keyvalue
- the valuekey
, or null when key
did not exist.public RedisFuture<Long> hdel(K key, K... fields)
RedisHashesAsyncConnection
hdel
in interface RedisHashesAsyncConnection<K,V>
key
- the keyfields
- the field type: keypublic RedisFuture<Boolean> hexists(K key, K field)
RedisHashesAsyncConnection
hexists
in interface RedisHashesAsyncConnection<K,V>
key
- the keyfield
- the field type: keyfield
. false if the hash does not contain field
,
or key
does not exist.public RedisFuture<V> hget(K key, K field)
RedisHashesAsyncConnection
hget
in interface RedisHashesAsyncConnection<K,V>
key
- the keyfield
- the field type: keyfield
, or null
when
field
is not present in the hash or key
does not exist.public RedisFuture<Long> hincrby(K key, K field, long amount)
RedisHashesAsyncConnection
hincrby
in interface RedisHashesAsyncConnection<K,V>
key
- the keyfield
- the field type: keyamount
- the increment type: longfield
after the increment operation.public RedisFuture<Double> hincrbyfloat(K key, K field, double amount)
RedisHashesAsyncConnection
hincrbyfloat
in interface RedisHashesAsyncConnection<K,V>
key
- the keyfield
- the field type: keyamount
- the increment type: doublefield
after the increment.public RedisFuture<Map<K,V>> hgetall(K key)
RedisHashesAsyncConnection
hgetall
in interface RedisHashesAsyncConnection<K,V>
key
- the keykey
does not exist.public RedisFuture<Long> hgetall(KeyValueStreamingChannel<K,V> channel, K key)
RedisHashesAsyncConnection
hgetall
in interface RedisHashesAsyncConnection<K,V>
channel
- the channelkey
- the keypublic RedisFuture<List<K>> hkeys(K key)
RedisHashesAsyncConnection
hkeys
in interface RedisHashesAsyncConnection<K,V>
key
- the keykey
does
not exist.public RedisFuture<Long> hkeys(KeyStreamingChannel<K> channel, K key)
RedisHashesAsyncConnection
hkeys
in interface RedisHashesAsyncConnection<K,V>
channel
- the channelkey
- the keypublic RedisFuture<Long> hlen(K key)
RedisHashesAsyncConnection
hlen
in interface RedisHashesAsyncConnection<K,V>
key
- the keykey
does not
exist.public RedisFuture<Long> hstrlen(K key, K field)
RedisHashesAsyncConnection
hstrlen
in interface RedisHashesAsyncConnection<K,V>
key
- the keyfield
- the field type: keyfield
value, or 0
when
field
is not present in the hash or key
does not exist at all.public RedisFuture<List<V>> hmget(K key, K... fields)
RedisHashesAsyncConnection
hmget
in interface RedisHashesAsyncConnection<K,V>
key
- the keyfields
- the field type: keypublic RedisFuture<Long> hmget(ValueStreamingChannel<V> channel, K key, K... fields)
RedisHashesAsyncConnection
hmget
in interface RedisHashesAsyncConnection<K,V>
channel
- the channelkey
- the keyfields
- the fieldspublic RedisFuture<String> hmset(K key, Map<K,V> map)
RedisHashesAsyncConnection
hmset
in interface RedisHashesAsyncConnection<K,V>
key
- the keymap
- the nullpublic RedisFuture<Boolean> hset(K key, K field, V value)
RedisHashesAsyncConnection
hset
in interface RedisHashesAsyncConnection<K,V>
key
- the keyfield
- the field type: keyvalue
- the valuefield
is a new field in the hash and value
was set. false if
field
already exists in the hash and the value was updated.public RedisFuture<Boolean> hsetnx(K key, K field, V value)
RedisHashesAsyncConnection
hsetnx
in interface RedisHashesAsyncConnection<K,V>
key
- the keyfield
- the field type: keyvalue
- the value1
if field
is a new field in the hash and value
was set. 0
if field
already exists in the hash and no operation was performed.public RedisFuture<List<V>> hvals(K key)
RedisHashesAsyncConnection
hvals
in interface RedisHashesAsyncConnection<K,V>
key
- the keykey
does
not exist.public RedisFuture<Long> hvals(ValueStreamingChannel<V> channel, K key)
RedisHashesAsyncConnection
hvals
in interface RedisHashesAsyncConnection<K,V>
channel
- streaming channel that receives a call for every valuekey
- the keypublic RedisFuture<Long> incr(K key)
RedisStringsAsyncConnection
incr
in interface RedisStringsAsyncConnection<K,V>
key
- the keykey
after the incrementpublic RedisFuture<Long> incrby(K key, long amount)
RedisStringsAsyncConnection
incrby
in interface RedisStringsAsyncConnection<K,V>
key
- the keyamount
- the increment type: longkey
after the incrementpublic RedisFuture<Double> incrbyfloat(K key, double amount)
RedisStringsAsyncConnection
incrbyfloat
in interface RedisStringsAsyncConnection<K,V>
key
- the keyamount
- the increment type: doublekey
after the increment.public RedisFuture<String> info()
RedisServerAsyncConnection
info
in interface RedisServerAsyncConnection<K,V>
public RedisFuture<String> info(String section)
RedisServerAsyncConnection
info
in interface RedisServerAsyncConnection<K,V>
section
- the section type: stringpublic RedisFuture<List<K>> keys(K pattern)
RedisKeysAsyncConnection
keys
in interface RedisKeysAsyncConnection<K,V>
pattern
- the pattern type: patternkey (pattern)pattern
.public RedisFuture<Long> keys(KeyStreamingChannel<K> channel, K pattern)
RedisKeysAsyncConnection
keys
in interface RedisKeysAsyncConnection<K,V>
channel
- the channelpattern
- the patternpattern
.public RedisFuture<Date> lastsave()
RedisServerAsyncConnection
lastsave
in interface RedisServerAsyncConnection<K,V>
public RedisFuture<V> lindex(K key, long index)
RedisListsAsyncConnection
lindex
in interface RedisListsAsyncConnection<K,V>
key
- the keyindex
- the index type: longindex
is out of
range.public RedisFuture<Long> linsert(K key, boolean before, V pivot, V value)
RedisListsAsyncConnection
linsert
in interface RedisListsAsyncConnection<K,V>
key
- the keybefore
- the beforepivot
- the pivotvalue
- the value-1
when the
value pivot
was not found.public RedisFuture<Long> llen(K key)
RedisListsAsyncConnection
llen
in interface RedisListsAsyncConnection<K,V>
key
- the keykey
.public RedisFuture<V> lpop(K key)
RedisListsAsyncConnection
lpop
in interface RedisListsAsyncConnection<K,V>
key
- the keykey
does
not exist.public RedisFuture<Long> lpush(K key, V... values)
RedisListsAsyncConnection
lpush
in interface RedisListsAsyncConnection<K,V>
key
- the keyvalues
- the valuepublic RedisFuture<Long> lpushx(K key, V value)
RedisListsAsyncConnection
lpushx
in interface RedisListsAsyncConnection<K,V>
key
- the keyvalue
- the valuepublic RedisFuture<Long> lpushx(K key, V... values)
RedisListsAsyncConnection
lpushx
in interface RedisListsAsyncConnection<K,V>
key
- the keyvalues
- the valuespublic RedisFuture<List<V>> lrange(K key, long start, long stop)
RedisListsAsyncConnection
lrange
in interface RedisListsAsyncConnection<K,V>
key
- the keystart
- the start type: longstop
- the stop type: longpublic RedisFuture<Long> lrange(ValueStreamingChannel<V> channel, K key, long start, long stop)
RedisListsAsyncConnection
lrange
in interface RedisListsAsyncConnection<K,V>
channel
- the channelkey
- the keystart
- the start type: longstop
- the stop type: longpublic RedisFuture<Long> lrem(K key, long count, V value)
RedisListsAsyncConnection
lrem
in interface RedisListsAsyncConnection<K,V>
key
- the keycount
- the count type: longvalue
- the valuepublic RedisFuture<String> lset(K key, long index, V value)
RedisListsAsyncConnection
lset
in interface RedisListsAsyncConnection<K,V>
key
- the keyindex
- the index type: longvalue
- the valuepublic RedisFuture<String> ltrim(K key, long start, long stop)
RedisListsAsyncConnection
ltrim
in interface RedisListsAsyncConnection<K,V>
key
- the keystart
- the start type: longstop
- the stop type: longpublic RedisFuture<String> migrate(String host, int port, K key, int db, long timeout)
RedisKeysAsyncConnection
migrate
in interface RedisKeysAsyncConnection<K,V>
host
- the hostport
- the portkey
- the keydb
- the databasetimeout
- the timeout in millisecondspublic RedisFuture<String> migrate(String host, int port, int db, long timeout, MigrateArgs<K> migrateArgs)
RedisKeysAsyncConnection
migrate
in interface RedisKeysAsyncConnection<K,V>
host
- the hostport
- the portdb
- the databasetimeout
- the timeout in millisecondsmigrateArgs
- migrate args that allow to configure further optionspublic RedisFuture<List<V>> mget(K... keys)
RedisStringsAsyncConnection
mget
in interface RedisStringsAsyncConnection<K,V>
keys
- the keypublic RedisFuture<Long> mget(ValueStreamingChannel<V> channel, K... keys)
RedisStringsAsyncConnection
mget
in interface RedisStringsAsyncConnection<K,V>
channel
- the channelkeys
- the keyspublic RedisFuture<Boolean> move(K key, int db)
RedisKeysAsyncConnection
move
in interface RedisKeysAsyncConnection<K,V>
key
- the keydb
- the db type: longpublic RedisFuture<String> multi()
BaseRedisAsyncConnection
multi
in interface BaseRedisAsyncConnection<K,V>
OK
.public RedisFuture<String> mset(Map<K,V> map)
RedisStringsAsyncConnection
mset
in interface RedisStringsAsyncConnection<K,V>
map
- the nullOK
since MSET
can't fail.public RedisFuture<Boolean> msetnx(Map<K,V> map)
RedisStringsAsyncConnection
msetnx
in interface RedisStringsAsyncConnection<K,V>
map
- the null1
if the all the keys were set. 0
if no key was set (at least one key already existed).public RedisFuture<String> objectEncoding(K key)
RedisKeysAsyncConnection
objectEncoding
in interface RedisKeysAsyncConnection<K,V>
key
- the keypublic RedisFuture<Long> objectIdletime(K key)
RedisKeysAsyncConnection
objectIdletime
in interface RedisKeysAsyncConnection<K,V>
key
- the keypublic RedisFuture<Long> objectRefcount(K key)
RedisKeysAsyncConnection
objectRefcount
in interface RedisKeysAsyncConnection<K,V>
key
- the keypublic RedisFuture<Boolean> persist(K key)
RedisKeysAsyncConnection
persist
in interface RedisKeysAsyncConnection<K,V>
key
- the keykey
does not exist or does not have an
associated timeout.public RedisFuture<Boolean> pexpire(K key, long milliseconds)
RedisKeysAsyncConnection
pexpire
in interface RedisKeysAsyncConnection<K,V>
key
- the keymilliseconds
- the milliseconds type: longkey
does not exist or the timeout could not
be set.public RedisFuture<Boolean> pexpireat(K key, Date timestamp)
RedisKeysAsyncConnection
pexpireat
in interface RedisKeysAsyncConnection<K,V>
key
- the keytimestamp
- the milliseconds-timestamp type: posix timekey
does not exist or the timeout could not
be set (see: EXPIRE
).public RedisFuture<Boolean> pexpireat(K key, long timestamp)
RedisKeysAsyncConnection
pexpireat
in interface RedisKeysAsyncConnection<K,V>
key
- the keytimestamp
- the milliseconds-timestamp type: posix timekey
does not exist or the timeout could not
be set (see: EXPIRE
).public RedisFuture<String> ping()
BaseRedisAsyncConnection
ping
in interface BaseRedisAsyncConnection<K,V>
public String readOnly()
RedisClusterAsyncConnection
readOnly
in interface RedisClusterAsyncConnection<K,V>
public String readWrite()
RedisClusterAsyncConnection
readWrite
in interface RedisClusterAsyncConnection<K,V>
public RedisFuture<Long> pttl(K key)
RedisKeysAsyncConnection
pttl
in interface RedisKeysAsyncConnection<K,V>
key
- the keypublic RedisFuture<Long> publish(K channel, V message)
BaseRedisAsyncConnection
publish
in interface BaseRedisAsyncConnection<K,V>
channel
- the channel type: keymessage
- the message type: valuepublic RedisFuture<List<K>> pubsubChannels()
BaseRedisAsyncConnection
pubsubChannels
in interface BaseRedisAsyncConnection<K,V>
public RedisFuture<List<K>> pubsubChannels(K channel)
BaseRedisAsyncConnection
pubsubChannels
in interface BaseRedisAsyncConnection<K,V>
channel
- the keypublic RedisFuture<Map<K,Long>> pubsubNumsub(K... channels)
BaseRedisAsyncConnection
pubsubNumsub
in interface BaseRedisAsyncConnection<K,V>
channels
- channel keyspublic RedisFuture<Long> pubsubNumpat()
BaseRedisAsyncConnection
pubsubNumpat
in interface BaseRedisAsyncConnection<K,V>
public RedisFuture<String> quit()
BaseRedisAsyncConnection
quit
in interface BaseRedisAsyncConnection<K,V>
public RedisFuture<List<Object>> role()
BaseRedisAsyncConnection
role
in interface BaseRedisAsyncConnection<K,V>
public RedisFuture<V> randomkey()
RedisKeysAsyncConnection
randomkey
in interface RedisKeysAsyncConnection<K,V>
public RedisFuture<String> rename(K key, K newKey)
RedisKeysAsyncConnection
rename
in interface RedisKeysAsyncConnection<K,V>
key
- the keynewKey
- the newkey type: keypublic RedisFuture<Boolean> renamenx(K key, K newKey)
RedisKeysAsyncConnection
renamenx
in interface RedisKeysAsyncConnection<K,V>
key
- the keynewKey
- the newkey type: keykey
was renamed to newkey
. false if newkey
already exists.public RedisFuture<String> restore(K key, long ttl, byte[] value)
RedisKeysAsyncConnection
restore
in interface RedisKeysAsyncConnection<K,V>
key
- the keyttl
- the ttl type: longvalue
- the serialized-value type: stringpublic RedisFuture<V> rpop(K key)
RedisListsAsyncConnection
rpop
in interface RedisListsAsyncConnection<K,V>
key
- the keykey
does
not exist.public RedisFuture<V> rpoplpush(K source, K destination)
RedisListsAsyncConnection
rpoplpush
in interface RedisListsAsyncConnection<K,V>
source
- the source keydestination
- the destination type: keypublic RedisFuture<Long> rpush(K key, V... values)
RedisListsAsyncConnection
rpush
in interface RedisListsAsyncConnection<K,V>
key
- the keyvalues
- the valuepublic RedisFuture<Long> rpushx(K key, V value)
RedisListsAsyncConnection
rpushx
in interface RedisListsAsyncConnection<K,V>
key
- the keyvalue
- the valuepublic RedisFuture<Long> rpushx(K key, V... values)
RedisListsAsyncConnection
rpushx
in interface RedisListsAsyncConnection<K,V>
key
- the keyvalues
- the valuespublic RedisFuture<Long> sadd(K key, V... members)
RedisSetsAsyncConnection
sadd
in interface RedisSetsAsyncConnection<K,V>
key
- the keymembers
- the member type: valuepublic RedisFuture<String> save()
RedisServerAsyncConnection
save
in interface RedisServerAsyncConnection<K,V>
public RedisFuture<Long> scard(K key)
RedisSetsAsyncConnection
scard
in interface RedisSetsAsyncConnection<K,V>
key
- the keykey
does not exist.public RedisFuture<List<Boolean>> scriptExists(String... digests)
RedisScriptingAsyncConnection
scriptExists
in interface RedisScriptingAsyncConnection<K,V>
digests
- script digestspublic RedisFuture<String> scriptFlush()
RedisScriptingAsyncConnection
scriptFlush
in interface RedisScriptingAsyncConnection<K,V>
public RedisFuture<String> scriptKill()
RedisScriptingAsyncConnection
scriptKill
in interface RedisScriptingAsyncConnection<K,V>
public RedisFuture<String> scriptLoad(V script)
RedisScriptingAsyncConnection
scriptLoad
in interface RedisScriptingAsyncConnection<K,V>
script
- script contentpublic RedisFuture<Set<V>> sdiff(K... keys)
RedisSetsAsyncConnection
sdiff
in interface RedisSetsAsyncConnection<K,V>
keys
- the keypublic RedisFuture<Long> sdiff(ValueStreamingChannel<V> channel, K... keys)
RedisSetsAsyncConnection
sdiff
in interface RedisSetsAsyncConnection<K,V>
channel
- streaming channel that receives a call for every valuekeys
- the keyspublic RedisFuture<Long> sdiffstore(K destination, K... keys)
RedisSetsAsyncConnection
sdiffstore
in interface RedisSetsAsyncConnection<K,V>
destination
- the destination type: keykeys
- the keypublic String select(int db)
RedisAsyncConnection
select
in interface RedisAsyncConnection<K,V>
db
- the database numberpublic RedisFuture<String> set(K key, V value)
RedisStringsAsyncConnection
set
in interface RedisStringsAsyncConnection<K,V>
key
- the keyvalue
- the valueOK
if SET
was executed correctly.public RedisFuture<String> set(K key, V value, SetArgs setArgs)
RedisStringsAsyncConnection
set
in interface RedisStringsAsyncConnection<K,V>
key
- the keyvalue
- the valuesetArgs
- the setArgsOK
if SET
was executed correctly.public RedisFuture<Long> setbit(K key, long offset, int value)
RedisStringsAsyncConnection
setbit
in interface RedisStringsAsyncConnection<K,V>
key
- the keyoffset
- the offset type: longvalue
- the value type: stringpublic RedisFuture<String> setex(K key, long seconds, V value)
RedisStringsAsyncConnection
setex
in interface RedisStringsAsyncConnection<K,V>
key
- the keyseconds
- the seconds type: longvalue
- the valuepublic RedisFuture<String> psetex(K key, long milliseconds, V value)
RedisStringsAsyncConnection
psetex
in interface RedisStringsAsyncConnection<K,V>
key
- the keymilliseconds
- the milliseconds type: longvalue
- the valuepublic RedisFuture<Boolean> setnx(K key, V value)
RedisStringsAsyncConnection
setnx
in interface RedisStringsAsyncConnection<K,V>
key
- the keyvalue
- the value1
if the key was set 0
if the key was not setpublic RedisFuture<Long> setrange(K key, long offset, V value)
RedisStringsAsyncConnection
setrange
in interface RedisStringsAsyncConnection<K,V>
key
- the keyoffset
- the offset type: longvalue
- the value@Deprecated public void shutdown()
public void shutdown(boolean save)
RedisServerAsyncConnection
shutdown
in interface RedisServerAsyncConnection<K,V>
save
- true force save operationpublic RedisFuture<Set<V>> sinter(K... keys)
RedisSetsAsyncConnection
sinter
in interface RedisSetsAsyncConnection<K,V>
keys
- the keypublic RedisFuture<Long> sinter(ValueStreamingChannel<V> channel, K... keys)
RedisSetsAsyncConnection
sinter
in interface RedisSetsAsyncConnection<K,V>
channel
- streaming channel that receives a call for every valuekeys
- the keyspublic RedisFuture<Long> sinterstore(K destination, K... keys)
RedisSetsAsyncConnection
sinterstore
in interface RedisSetsAsyncConnection<K,V>
destination
- the destination type: keykeys
- the keypublic RedisFuture<Boolean> sismember(K key, V member)
RedisSetsAsyncConnection
sismember
in interface RedisSetsAsyncConnection<K,V>
key
- the keymember
- the member type: valuekey
does not exist.public RedisFuture<Boolean> smove(K source, K destination, V member)
RedisSetsAsyncConnection
smove
in interface RedisSetsAsyncConnection<K,V>
source
- the source keydestination
- the destination type: keymember
- the member type: valuesource
and no
operation was performed.public RedisFuture<String> slaveof(String host, int port)
RedisServerAsyncConnection
slaveof
in interface RedisServerAsyncConnection<K,V>
host
- the host type: stringport
- the port type: stringpublic RedisFuture<String> slaveofNoOne()
RedisServerAsyncConnection
slaveofNoOne
in interface RedisServerAsyncConnection<K,V>
public RedisFuture<List<Object>> slowlogGet()
RedisServerAsyncConnection
slowlogGet
in interface RedisServerAsyncConnection<K,V>
public RedisFuture<List<Object>> slowlogGet(int count)
RedisServerAsyncConnection
slowlogGet
in interface RedisServerAsyncConnection<K,V>
count
- the countpublic RedisFuture<Long> slowlogLen()
RedisServerAsyncConnection
slowlogLen
in interface RedisServerAsyncConnection<K,V>
public RedisFuture<String> slowlogReset()
RedisServerAsyncConnection
slowlogReset
in interface RedisServerAsyncConnection<K,V>
public RedisFuture<Set<V>> smembers(K key)
RedisSetsAsyncConnection
smembers
in interface RedisSetsAsyncConnection<K,V>
key
- the keypublic RedisFuture<Long> smembers(ValueStreamingChannel<V> channel, K key)
RedisSetsAsyncConnection
smembers
in interface RedisSetsAsyncConnection<K,V>
channel
- streaming channel that receives a call for every valuekey
- the keypublic RedisFuture<List<V>> sort(K key)
RedisKeysAsyncConnection
sort
in interface RedisKeysAsyncConnection<K,V>
key
- the keypublic RedisFuture<Long> sort(ValueStreamingChannel<V> channel, K key)
RedisKeysAsyncConnection
sort
in interface RedisKeysAsyncConnection<K,V>
channel
- streaming channel that receives a call for every valuekey
- the keypublic RedisFuture<List<V>> sort(K key, SortArgs sortArgs)
RedisKeysAsyncConnection
sort
in interface RedisKeysAsyncConnection<K,V>
key
- the keysortArgs
- sort argumentspublic RedisFuture<Long> sort(ValueStreamingChannel<V> channel, K key, SortArgs sortArgs)
RedisKeysAsyncConnection
sort
in interface RedisKeysAsyncConnection<K,V>
channel
- streaming channel that receives a call for every valuekey
- the keysortArgs
- sort argumentspublic RedisFuture<Long> sortStore(K key, SortArgs sortArgs, K destination)
RedisKeysAsyncConnection
sortStore
in interface RedisKeysAsyncConnection<K,V>
key
- the keysortArgs
- sort argumentsdestination
- the destination key to store sort resultspublic RedisFuture<V> spop(K key)
RedisSetsAsyncConnection
spop
in interface RedisSetsAsyncConnection<K,V>
key
- the keykey
does not exist.public RedisFuture<Set<V>> spop(K key, long count)
RedisSetsAsyncConnection
spop
in interface RedisSetsAsyncConnection<K,V>
key
- the keycount
- number of members to popkey
does not exist.public RedisFuture<V> srandmember(K key)
RedisSetsAsyncConnection
srandmember
in interface RedisSetsAsyncConnection<K,V>
key
- the keycount
argument the command returns a Bulk
Reply with the randomly selected element, or null when key
does not exist.public RedisFuture<Set<V>> srandmember(K key, long count)
RedisSetsAsyncConnection
srandmember
in interface RedisSetsAsyncConnection<K,V>
key
- the keycount
- the count type: longcount
argument the command
returns a Bulk Reply with the randomly selected element, or null when key
does not exist.public RedisFuture<Long> srandmember(ValueStreamingChannel<V> channel, K key, long count)
RedisSetsAsyncConnection
srandmember
in interface RedisSetsAsyncConnection<K,V>
channel
- streaming channel that receives a call for every valuekey
- the keycount
- the countpublic RedisFuture<Long> srem(K key, V... members)
RedisSetsAsyncConnection
srem
in interface RedisSetsAsyncConnection<K,V>
key
- the keymembers
- the member type: valuepublic RedisFuture<Set<V>> sunion(K... keys)
RedisSetsAsyncConnection
sunion
in interface RedisSetsAsyncConnection<K,V>
keys
- the keypublic RedisFuture<Long> sunion(ValueStreamingChannel<V> channel, K... keys)
RedisSetsAsyncConnection
sunion
in interface RedisSetsAsyncConnection<K,V>
channel
- streaming channel that receives a call for every valuekeys
- the keypublic RedisFuture<Long> sunionstore(K destination, K... keys)
RedisSetsAsyncConnection
sunionstore
in interface RedisSetsAsyncConnection<K,V>
destination
- the destination type: keykeys
- the keypublic RedisFuture<String> sync()
RedisServerAsyncConnection
sync
in interface RedisServerAsyncConnection<K,V>
public RedisFuture<Long> strlen(K key)
RedisStringsAsyncConnection
strlen
in interface RedisStringsAsyncConnection<K,V>
key
- the keykey
, or 0
when key
does
not exist.public RedisFuture<Long> touch(K... keys)
RedisKeysAsyncConnection
touch
in interface RedisKeysAsyncConnection<K,V>
keys
- the keyspublic RedisFuture<Long> ttl(K key)
RedisKeysAsyncConnection
ttl
in interface RedisKeysAsyncConnection<K,V>
key
- the keypublic RedisFuture<String> type(K key)
RedisKeysAsyncConnection
type
in interface RedisKeysAsyncConnection<K,V>
key
- the keykey
, or none
when key
does not
exist.public RedisFuture<String> watch(K... keys)
BaseRedisAsyncConnection
watch
in interface BaseRedisAsyncConnection<K,V>
keys
- the keyOK
.public RedisFuture<String> unwatch()
BaseRedisAsyncConnection
unwatch
in interface BaseRedisAsyncConnection<K,V>
OK
.public RedisFuture<Long> zadd(K key, double score, V member)
RedisSortedSetsAsyncConnection
zadd
in interface RedisSortedSetsAsyncConnection<K,V>
key
- the keyscore
- the scoremember
- the memberpublic RedisFuture<Long> zadd(K key, Object... scoresAndValues)
RedisSortedSetsAsyncConnection
zadd
in interface RedisSortedSetsAsyncConnection<K,V>
key
- the keyscoresAndValues
- the scoresAndValue tuples (score,value,score,value,...)public RedisFuture<Long> zadd(K key, ZAddArgs zAddArgs, double score, V member)
RedisSortedSetsAsyncConnection
zadd
in interface RedisSortedSetsAsyncConnection<K,V>
key
- the keyzAddArgs
- arguments for zaddscore
- the scoremember
- the memberpublic RedisFuture<Long> zadd(K key, ZAddArgs zAddArgs, Object... scoresAndValues)
RedisSortedSetsAsyncConnection
zadd
in interface RedisSortedSetsAsyncConnection<K,V>
key
- the keyzAddArgs
- arguments for zaddscoresAndValues
- the scoresAndValue tuples (score,value,score,value,...)public RedisFuture<Double> zaddincr(K key, double score, V member)
RedisSortedSetsAsyncConnection
zaddincr
in interface RedisSortedSetsAsyncConnection<K,V>
key
- the keyscore
- the scoremember
- the memberpublic RedisFuture<Long> zcard(K key)
RedisSortedSetsAsyncConnection
zcard
in interface RedisSortedSetsAsyncConnection<K,V>
key
- the keykey
does not exist.public RedisFuture<Long> zcount(K key, double min, double max)
RedisSortedSetsAsyncConnection
zcount
in interface RedisSortedSetsAsyncConnection<K,V>
key
- the keymin
- min scoremax
- max scorepublic RedisFuture<Long> zcount(K key, String min, String max)
RedisSortedSetsAsyncConnection
zcount
in interface RedisSortedSetsAsyncConnection<K,V>
key
- the keymin
- min scoremax
- max scorepublic RedisFuture<Double> zincrby(K key, double amount, K member)
RedisSortedSetsAsyncConnection
zincrby
in interface RedisSortedSetsAsyncConnection<K,V>
key
- the keyamount
- the increment type: longmember
- the member type: keymember
(a double precision floating point
number), represented as string.public RedisFuture<Long> zinterstore(K destination, K... keys)
RedisSortedSetsAsyncConnection
zinterstore
in interface RedisSortedSetsAsyncConnection<K,V>
destination
- the destinationkeys
- the keysdestination
.public RedisFuture<Long> zinterstore(K destination, ZStoreArgs storeArgs, K... keys)
RedisSortedSetsAsyncConnection
zinterstore
in interface RedisSortedSetsAsyncConnection<K,V>
destination
- the destinationstoreArgs
- the storeArgskeys
- the keysdestination
.public RedisFuture<List<V>> zrange(K key, long start, long stop)
RedisSortedSetsAsyncConnection
zrange
in interface RedisSortedSetsAsyncConnection<K,V>
key
- the keystart
- the startstop
- the stoppublic RedisFuture<List<ScoredValue<V>>> zrangeWithScores(K key, long start, long stop)
RedisSortedSetsAsyncConnection
zrangeWithScores
in interface RedisSortedSetsAsyncConnection<K,V>
key
- the keystart
- the startstop
- the stoppublic RedisFuture<List<V>> zrangebyscore(K key, double min, double max)
RedisSortedSetsAsyncConnection
zrangebyscore
in interface RedisSortedSetsAsyncConnection<K,V>
key
- the keymin
- min scoremax
- max scorepublic RedisFuture<List<V>> zrangebyscore(K key, String min, String max)
RedisSortedSetsAsyncConnection
zrangebyscore
in interface RedisSortedSetsAsyncConnection<K,V>
key
- the keymin
- min scoremax
- max scorepublic RedisFuture<List<V>> zrangebyscore(K key, double min, double max, long offset, long count)
RedisSortedSetsAsyncConnection
zrangebyscore
in interface RedisSortedSetsAsyncConnection<K,V>
key
- the keymin
- min scoremax
- max scoreoffset
- the offsetcount
- the countpublic RedisFuture<List<V>> zrangebyscore(K key, String min, String max, long offset, long count)
RedisSortedSetsAsyncConnection
zrangebyscore
in interface RedisSortedSetsAsyncConnection<K,V>
key
- the keymin
- min scoremax
- max scoreoffset
- the offsetcount
- the countpublic RedisFuture<List<ScoredValue<V>>> zrangebyscoreWithScores(K key, double min, double max)
RedisSortedSetsAsyncConnection
zrangebyscoreWithScores
in interface RedisSortedSetsAsyncConnection<K,V>
key
- the keymin
- min scoremax
- max scorepublic RedisFuture<List<ScoredValue<V>>> zrangebyscoreWithScores(K key, String min, String max)
RedisSortedSetsAsyncConnection
zrangebyscoreWithScores
in interface RedisSortedSetsAsyncConnection<K,V>
key
- the keymin
- min scoremax
- max scorepublic RedisFuture<List<ScoredValue<V>>> zrangebyscoreWithScores(K key, double min, double max, long offset, long count)
RedisSortedSetsAsyncConnection
zrangebyscoreWithScores
in interface RedisSortedSetsAsyncConnection<K,V>
key
- the keymin
- min scoremax
- max scoreoffset
- the offsetcount
- the countpublic RedisFuture<List<ScoredValue<V>>> zrangebyscoreWithScores(K key, String min, String max, long offset, long count)
RedisSortedSetsAsyncConnection
zrangebyscoreWithScores
in interface RedisSortedSetsAsyncConnection<K,V>
key
- the keymin
- min scoremax
- max scoreoffset
- the offsetcount
- the countpublic RedisFuture<Long> zrange(ValueStreamingChannel<V> channel, K key, long start, long stop)
RedisSortedSetsAsyncConnection
zrange
in interface RedisSortedSetsAsyncConnection<K,V>
channel
- streaming channel that receives a call for every valuekey
- the keystart
- the startstop
- the stoppublic RedisFuture<Long> zrangeWithScores(ScoredValueStreamingChannel<V> channel, K key, long start, long stop)
RedisSortedSetsAsyncConnection
zrangeWithScores
in interface RedisSortedSetsAsyncConnection<K,V>
channel
- streaming channel that receives a call for every valuekey
- the keystart
- the startstop
- the stoppublic RedisFuture<Long> zrangebyscore(ValueStreamingChannel<V> channel, K key, double min, double max)
RedisSortedSetsAsyncConnection
zrangebyscore
in interface RedisSortedSetsAsyncConnection<K,V>
channel
- streaming channel that receives a call for every valuekey
- the keymin
- min scoremax
- max scorepublic RedisFuture<Long> zrangebyscore(ValueStreamingChannel<V> channel, K key, String min, String max)
RedisSortedSetsAsyncConnection
zrangebyscore
in interface RedisSortedSetsAsyncConnection<K,V>
channel
- streaming channel that receives a call for every valuekey
- the keymin
- min scoremax
- max scorepublic RedisFuture<Long> zrangebyscore(ValueStreamingChannel<V> channel, K key, double min, double max, long offset, long count)
RedisSortedSetsAsyncConnection
zrangebyscore
in interface RedisSortedSetsAsyncConnection<K,V>
channel
- streaming channel that receives a call for every valuekey
- the keymin
- min scoremax
- max scoreoffset
- the offsetcount
- the countpublic RedisFuture<Long> zrangebyscore(ValueStreamingChannel<V> channel, K key, String min, String max, long offset, long count)
RedisSortedSetsAsyncConnection
zrangebyscore
in interface RedisSortedSetsAsyncConnection<K,V>
channel
- streaming channel that receives a call for every valuekey
- the keymin
- min scoremax
- max scoreoffset
- the offsetcount
- the countpublic RedisFuture<Long> zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, double min, double max)
RedisSortedSetsAsyncConnection
zrangebyscoreWithScores
in interface RedisSortedSetsAsyncConnection<K,V>
channel
- streaming channel that receives a call for every scored valuekey
- the keymin
- min scoremax
- max scorepublic RedisFuture<Long> zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, String min, String max)
RedisSortedSetsAsyncConnection
zrangebyscoreWithScores
in interface RedisSortedSetsAsyncConnection<K,V>
channel
- streaming channel that receives a call for every scored valuekey
- the keymin
- min scoremax
- max scorepublic RedisFuture<Long> zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, double min, double max, long offset, long count)
RedisSortedSetsAsyncConnection
zrangebyscoreWithScores
in interface RedisSortedSetsAsyncConnection<K,V>
channel
- streaming channel that receives a call for every scored valuekey
- the keymin
- min scoremax
- max scoreoffset
- the offsetcount
- the countpublic RedisFuture<Long> zrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, String min, String max, long offset, long count)
RedisSortedSetsAsyncConnection
zrangebyscoreWithScores
in interface RedisSortedSetsAsyncConnection<K,V>
channel
- streaming channel that receives a call for every scored valuekey
- the keymin
- min scoremax
- max scoreoffset
- the offsetcount
- the countpublic RedisFuture<Long> zrank(K key, V member)
RedisSortedSetsAsyncConnection
zrank
in interface RedisSortedSetsAsyncConnection<K,V>
key
- the keymember
- the member type: valuemember
. If member
does not exist in the sorted
set or key
does not exist,public RedisFuture<Long> zrem(K key, V... members)
RedisSortedSetsAsyncConnection
zrem
in interface RedisSortedSetsAsyncConnection<K,V>
key
- the keymembers
- the member type: valuepublic RedisFuture<Long> zremrangebyrank(K key, long start, long stop)
RedisSortedSetsAsyncConnection
zremrangebyrank
in interface RedisSortedSetsAsyncConnection<K,V>
key
- the keystart
- the start type: longstop
- the stop type: longpublic RedisFuture<Long> zremrangebyscore(K key, double min, double max)
RedisSortedSetsAsyncConnection
zremrangebyscore
in interface RedisSortedSetsAsyncConnection<K,V>
key
- the keymin
- min scoremax
- max scorepublic RedisFuture<Long> zremrangebyscore(K key, String min, String max)
RedisSortedSetsAsyncConnection
zremrangebyscore
in interface RedisSortedSetsAsyncConnection<K,V>
key
- the keymin
- min scoremax
- max scorepublic RedisFuture<List<V>> zrevrange(K key, long start, long stop)
RedisSortedSetsAsyncConnection
zrevrange
in interface RedisSortedSetsAsyncConnection<K,V>
key
- the keystart
- the startstop
- the stoppublic RedisFuture<List<ScoredValue<V>>> zrevrangeWithScores(K key, long start, long stop)
RedisSortedSetsAsyncConnection
zrevrangeWithScores
in interface RedisSortedSetsAsyncConnection<K,V>
key
- the keystart
- the startstop
- the stoppublic RedisFuture<List<V>> zrevrangebyscore(K key, double max, double min)
RedisSortedSetsAsyncConnection
zrevrangebyscore
in interface RedisSortedSetsAsyncConnection<K,V>
key
- the keymax
- max scoremin
- min scorepublic RedisFuture<List<V>> zrevrangebyscore(K key, String max, String min)
RedisSortedSetsAsyncConnection
zrevrangebyscore
in interface RedisSortedSetsAsyncConnection<K,V>
key
- the keymax
- max scoremin
- min scorepublic RedisFuture<List<V>> zrevrangebyscore(K key, double max, double min, long offset, long count)
RedisSortedSetsAsyncConnection
zrevrangebyscore
in interface RedisSortedSetsAsyncConnection<K,V>
key
- the keymax
- max scoremin
- min scoreoffset
- the offsetcount
- the countpublic RedisFuture<List<V>> zrevrangebyscore(K key, String max, String min, long offset, long count)
RedisSortedSetsAsyncConnection
zrevrangebyscore
in interface RedisSortedSetsAsyncConnection<K,V>
key
- the keymax
- max scoremin
- min scoreoffset
- the offsetcount
- the countpublic RedisFuture<List<ScoredValue<V>>> zrevrangebyscoreWithScores(K key, double max, double min)
RedisSortedSetsAsyncConnection
zrevrangebyscoreWithScores
in interface RedisSortedSetsAsyncConnection<K,V>
key
- the keymax
- max scoremin
- min scorepublic RedisFuture<List<ScoredValue<V>>> zrevrangebyscoreWithScores(K key, String max, String min)
RedisSortedSetsAsyncConnection
zrevrangebyscoreWithScores
in interface RedisSortedSetsAsyncConnection<K,V>
key
- the keymax
- max scoremin
- min scorepublic RedisFuture<List<ScoredValue<V>>> zrevrangebyscoreWithScores(K key, double max, double min, long offset, long count)
RedisSortedSetsAsyncConnection
zrevrangebyscoreWithScores
in interface RedisSortedSetsAsyncConnection<K,V>
key
- the keymax
- max scoremin
- min scoreoffset
- the offsetcount
- the countpublic RedisFuture<List<ScoredValue<V>>> zrevrangebyscoreWithScores(K key, String max, String min, long offset, long count)
RedisSortedSetsAsyncConnection
zrevrangebyscoreWithScores
in interface RedisSortedSetsAsyncConnection<K,V>
key
- the keymax
- max scoremin
- min scoreoffset
- the offsetcount
- the countpublic RedisFuture<Long> zrevrange(ValueStreamingChannel<V> channel, K key, long start, long stop)
RedisSortedSetsAsyncConnection
zrevrange
in interface RedisSortedSetsAsyncConnection<K,V>
channel
- streaming channel that receives a call for every scored valuekey
- the keystart
- the startstop
- the stoppublic RedisFuture<Long> zrevrangeWithScores(ScoredValueStreamingChannel<V> channel, K key, long start, long stop)
RedisSortedSetsAsyncConnection
zrevrangeWithScores
in interface RedisSortedSetsAsyncConnection<K,V>
channel
- streaming channel that receives a call for every scored valuekey
- the keystart
- the startstop
- the stoppublic RedisFuture<Long> zrevrangebyscore(ValueStreamingChannel<V> channel, K key, double max, double min)
RedisSortedSetsAsyncConnection
zrevrangebyscore
in interface RedisSortedSetsAsyncConnection<K,V>
channel
- streaming channel that receives a call for every valuekey
- the keymax
- max scoremin
- min scorepublic RedisFuture<Long> zrevrangebyscore(ValueStreamingChannel<V> channel, K key, String max, String min)
RedisSortedSetsAsyncConnection
zrevrangebyscore
in interface RedisSortedSetsAsyncConnection<K,V>
channel
- streaming channel that receives a call for every valuekey
- the keymax
- max scoremin
- min scorepublic RedisFuture<Long> zrevrangebyscore(ValueStreamingChannel<V> channel, K key, double max, double min, long offset, long count)
RedisSortedSetsAsyncConnection
zrevrangebyscore
in interface RedisSortedSetsAsyncConnection<K,V>
channel
- streaming channel that receives a call for every valuekey
- the keymax
- max scoremin
- min scoreoffset
- the offsetcount
- the countpublic RedisFuture<Long> zrevrangebyscore(ValueStreamingChannel<V> channel, K key, String max, String min, long offset, long count)
RedisSortedSetsAsyncConnection
zrevrangebyscore
in interface RedisSortedSetsAsyncConnection<K,V>
channel
- streaming channel that receives a call for every valuekey
- the keymax
- max scoremin
- min scoreoffset
- the offsetcount
- the countpublic RedisFuture<Long> zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, double max, double min)
RedisSortedSetsAsyncConnection
zrevrangebyscoreWithScores
in interface RedisSortedSetsAsyncConnection<K,V>
channel
- streaming channel that receives a call for every scored valuekey
- the keymax
- max scoremin
- min scorepublic RedisFuture<Long> zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, String max, String min)
RedisSortedSetsAsyncConnection
zrevrangebyscoreWithScores
in interface RedisSortedSetsAsyncConnection<K,V>
channel
- streaming channel that receives a call for every scored valuekey
- the keymax
- max scoremin
- min scorepublic RedisFuture<Long> zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, double max, double min, long offset, long count)
RedisSortedSetsAsyncConnection
zrevrangebyscoreWithScores
in interface RedisSortedSetsAsyncConnection<K,V>
channel
- streaming channel that receives a call for every scored valuekey
- the keymax
- max scoremin
- min scoreoffset
- the offsetcount
- the countpublic RedisFuture<Long> zrevrangebyscoreWithScores(ScoredValueStreamingChannel<V> channel, K key, String max, String min, long offset, long count)
RedisSortedSetsAsyncConnection
zrevrangebyscoreWithScores
in interface RedisSortedSetsAsyncConnection<K,V>
channel
- streaming channel that receives a call for every scored valuekey
- the keymax
- max scoremin
- min scoreoffset
- the offsetcount
- the countpublic RedisFuture<Long> zrevrank(K key, V member)
RedisSortedSetsAsyncConnection
zrevrank
in interface RedisSortedSetsAsyncConnection<K,V>
key
- the keymember
- the member type: valuemember
. If member
does not exist in the sorted
set or key
does not exist,public RedisFuture<Double> zscore(K key, V member)
RedisSortedSetsAsyncConnection
zscore
in interface RedisSortedSetsAsyncConnection<K,V>
key
- the keymember
- the member type: valuemember
(a double precision floating point
number), represented as string.public RedisFuture<Long> zunionstore(K destination, K... keys)
RedisSortedSetsAsyncConnection
zunionstore
in interface RedisSortedSetsAsyncConnection<K,V>
destination
- destination keykeys
- source keysdestination
.public RedisFuture<Long> zunionstore(K destination, ZStoreArgs storeArgs, K... keys)
RedisSortedSetsAsyncConnection
zunionstore
in interface RedisSortedSetsAsyncConnection<K,V>
destination
- the destinationstoreArgs
- the storeArgskeys
- the keysdestination
.public RedisFuture<KeyScanCursor<K>> scan()
RedisKeysAsyncConnection
scan
in interface RedisKeysAsyncConnection<K,V>
public RedisFuture<KeyScanCursor<K>> scan(ScanArgs scanArgs)
RedisKeysAsyncConnection
scan
in interface RedisKeysAsyncConnection<K,V>
scanArgs
- scan argumentspublic RedisFuture<KeyScanCursor<K>> scan(ScanCursor scanCursor, ScanArgs scanArgs)
RedisKeysAsyncConnection
scan
in interface RedisKeysAsyncConnection<K,V>
scanCursor
- cursor to resume from a previous scanscanArgs
- scan argumentspublic RedisFuture<KeyScanCursor<K>> scan(ScanCursor scanCursor)
RedisKeysAsyncConnection
scan
in interface RedisKeysAsyncConnection<K,V>
scanCursor
- cursor to resume from a previous scanpublic RedisFuture<StreamScanCursor> scan(KeyStreamingChannel<K> channel)
RedisKeysAsyncConnection
scan
in interface RedisKeysAsyncConnection<K,V>
channel
- streaming channel that receives a call for every keypublic RedisFuture<StreamScanCursor> scan(KeyStreamingChannel<K> channel, ScanArgs scanArgs)
RedisKeysAsyncConnection
scan
in interface RedisKeysAsyncConnection<K,V>
channel
- streaming channel that receives a call for every keyscanArgs
- scan argumentspublic RedisFuture<StreamScanCursor> scan(KeyStreamingChannel<K> channel, ScanCursor scanCursor, ScanArgs scanArgs)
RedisKeysAsyncConnection
scan
in interface RedisKeysAsyncConnection<K,V>
channel
- streaming channel that receives a call for every keyscanCursor
- cursor to resume from a previous scanscanArgs
- scan argumentspublic RedisFuture<StreamScanCursor> scan(KeyStreamingChannel<K> channel, ScanCursor scanCursor)
RedisKeysAsyncConnection
scan
in interface RedisKeysAsyncConnection<K,V>
channel
- streaming channel that receives a call for every keyscanCursor
- cursor to resume from a previous scanpublic RedisFuture<ValueScanCursor<V>> sscan(K key)
RedisSetsAsyncConnection
sscan
in interface RedisSetsAsyncConnection<K,V>
key
- the keypublic RedisFuture<ValueScanCursor<V>> sscan(K key, ScanArgs scanArgs)
RedisSetsAsyncConnection
sscan
in interface RedisSetsAsyncConnection<K,V>
key
- the keyscanArgs
- scan argumentspublic RedisFuture<ValueScanCursor<V>> sscan(K key, ScanCursor scanCursor, ScanArgs scanArgs)
RedisSetsAsyncConnection
sscan
in interface RedisSetsAsyncConnection<K,V>
key
- the keyscanCursor
- cursor to resume from a previous scanscanArgs
- scan argumentspublic RedisFuture<ValueScanCursor<V>> sscan(K key, ScanCursor scanCursor)
RedisSetsAsyncConnection
sscan
in interface RedisSetsAsyncConnection<K,V>
key
- the keyscanCursor
- cursor to resume from a previous scanpublic RedisFuture<StreamScanCursor> sscan(ValueStreamingChannel<V> channel, K key)
RedisSetsAsyncConnection
sscan
in interface RedisSetsAsyncConnection<K,V>
channel
- streaming channel that receives a call for every valuekey
- the keypublic RedisFuture<StreamScanCursor> sscan(ValueStreamingChannel<V> channel, K key, ScanArgs scanArgs)
RedisSetsAsyncConnection
sscan
in interface RedisSetsAsyncConnection<K,V>
channel
- streaming channel that receives a call for every valuekey
- the keyscanArgs
- scan argumentspublic RedisFuture<StreamScanCursor> sscan(ValueStreamingChannel<V> channel, K key, ScanCursor scanCursor, ScanArgs scanArgs)
RedisSetsAsyncConnection
sscan
in interface RedisSetsAsyncConnection<K,V>
channel
- streaming channel that receives a call for every valuekey
- the keyscanCursor
- cursor to resume from a previous scanscanArgs
- scan argumentspublic RedisFuture<StreamScanCursor> sscan(ValueStreamingChannel<V> channel, K key, ScanCursor scanCursor)
RedisSetsAsyncConnection
sscan
in interface RedisSetsAsyncConnection<K,V>
channel
- streaming channel that receives a call for every valuekey
- the keyscanCursor
- cursor to resume from a previous scanpublic RedisFuture<MapScanCursor<K,V>> hscan(K key)
RedisHashesAsyncConnection
hscan
in interface RedisHashesAsyncConnection<K,V>
key
- the keypublic RedisFuture<MapScanCursor<K,V>> hscan(K key, ScanArgs scanArgs)
RedisHashesAsyncConnection
hscan
in interface RedisHashesAsyncConnection<K,V>
key
- the keyscanArgs
- scan argumentspublic RedisFuture<MapScanCursor<K,V>> hscan(K key, ScanCursor scanCursor, ScanArgs scanArgs)
RedisHashesAsyncConnection
hscan
in interface RedisHashesAsyncConnection<K,V>
key
- the keyscanCursor
- cursor to resume from a previous scanscanArgs
- scan argumentspublic RedisFuture<MapScanCursor<K,V>> hscan(K key, ScanCursor scanCursor)
RedisHashesAsyncConnection
hscan
in interface RedisHashesAsyncConnection<K,V>
key
- the keyscanCursor
- cursor to resume from a previous scanpublic RedisFuture<StreamScanCursor> hscan(KeyValueStreamingChannel<K,V> channel, K key)
RedisHashesAsyncConnection
hscan
in interface RedisHashesAsyncConnection<K,V>
channel
- streaming channel that receives a call for every key-value pairkey
- the keypublic RedisFuture<StreamScanCursor> hscan(KeyValueStreamingChannel<K,V> channel, K key, ScanArgs scanArgs)
RedisHashesAsyncConnection
hscan
in interface RedisHashesAsyncConnection<K,V>
channel
- streaming channel that receives a call for every key-value pairkey
- the keyscanArgs
- scan argumentspublic RedisFuture<StreamScanCursor> hscan(KeyValueStreamingChannel<K,V> channel, K key, ScanCursor scanCursor, ScanArgs scanArgs)
RedisHashesAsyncConnection
hscan
in interface RedisHashesAsyncConnection<K,V>
channel
- streaming channel that receives a call for every key-value pairkey
- the keyscanCursor
- cursor to resume from a previous scanscanArgs
- scan argumentspublic RedisFuture<StreamScanCursor> hscan(KeyValueStreamingChannel<K,V> channel, K key, ScanCursor scanCursor)
RedisHashesAsyncConnection
hscan
in interface RedisHashesAsyncConnection<K,V>
channel
- streaming channel that receives a call for every key-value pairkey
- the keyscanCursor
- cursor to resume from a previous scanpublic RedisFuture<ScoredValueScanCursor<V>> zscan(K key)
RedisSortedSetsAsyncConnection
zscan
in interface RedisSortedSetsAsyncConnection<K,V>
key
- the keypublic RedisFuture<ScoredValueScanCursor<V>> zscan(K key, ScanArgs scanArgs)
RedisSortedSetsAsyncConnection
zscan
in interface RedisSortedSetsAsyncConnection<K,V>
key
- the keyscanArgs
- scan argumentspublic RedisFuture<ScoredValueScanCursor<V>> zscan(K key, ScanCursor scanCursor, ScanArgs scanArgs)
RedisSortedSetsAsyncConnection
zscan
in interface RedisSortedSetsAsyncConnection<K,V>
key
- the keyscanCursor
- cursor to resume from a previous scanscanArgs
- scan argumentspublic RedisFuture<ScoredValueScanCursor<V>> zscan(K key, ScanCursor scanCursor)
RedisSortedSetsAsyncConnection
zscan
in interface RedisSortedSetsAsyncConnection<K,V>
key
- the keyscanCursor
- cursor to resume from a previous scanpublic RedisFuture<StreamScanCursor> zscan(ScoredValueStreamingChannel<V> channel, K key)
RedisSortedSetsAsyncConnection
zscan
in interface RedisSortedSetsAsyncConnection<K,V>
channel
- streaming channel that receives a call for every scored valuekey
- the keypublic RedisFuture<StreamScanCursor> zscan(ScoredValueStreamingChannel<V> channel, K key, ScanArgs scanArgs)
RedisSortedSetsAsyncConnection
zscan
in interface RedisSortedSetsAsyncConnection<K,V>
channel
- streaming channel that receives a call for every scored valuekey
- the keyscanArgs
- scan argumentspublic RedisFuture<StreamScanCursor> zscan(ScoredValueStreamingChannel<V> channel, K key, ScanCursor scanCursor, ScanArgs scanArgs)
RedisSortedSetsAsyncConnection
zscan
in interface RedisSortedSetsAsyncConnection<K,V>
channel
- streaming channel that receives a call for every scored valuekey
- the keyscanCursor
- cursor to resume from a previous scanscanArgs
- scan argumentspublic RedisFuture<StreamScanCursor> zscan(ScoredValueStreamingChannel<V> channel, K key, ScanCursor scanCursor)
RedisSortedSetsAsyncConnection
zscan
in interface RedisSortedSetsAsyncConnection<K,V>
channel
- streaming channel that receives a call for every scored valuekey
- the keyscanCursor
- cursor to resume from a previous scanpublic String digest(V script)
BaseRedisAsyncConnection
digest
in interface BaseRedisAsyncConnection<K,V>
script
- script contentpublic RedisFuture<List<V>> time()
RedisServerAsyncConnection
time
in interface RedisServerAsyncConnection<K,V>
public RedisFuture<Long> waitForReplication(int replicas, long timeout)
BaseRedisAsyncConnection
waitForReplication
in interface BaseRedisAsyncConnection<K,V>
replicas
- minimum number of replicastimeout
- timeout in millisecondspublic RedisFuture<Long> pfadd(K key, V value, V... moreValues)
RedisHLLAsyncConnection
pfadd
in interface RedisHLLAsyncConnection<K,V>
key
- the keyvalue
- the valuemoreValues
- more valuespublic RedisFuture<String> pfmerge(K destkey, K sourcekey, K... moreSourceKeys)
RedisHLLAsyncConnection
pfmerge
in interface RedisHLLAsyncConnection<K,V>
destkey
- the destination keysourcekey
- the source keymoreSourceKeys
- more source keysOK
.public RedisFuture<Long> pfcount(K key, K... moreKeys)
RedisHLLAsyncConnection
pfcount
in interface RedisHLLAsyncConnection<K,V>
key
- the keymoreKeys
- more keysPFADD
.public RedisFuture<String> clusterBumpepoch()
RedisClusterAsyncConnection
clusterBumpepoch
in interface RedisClusterAsyncConnection<K,V>
public RedisFuture<String> clusterMeet(String ip, int port)
RedisClusterAsyncConnection
clusterMeet
in interface RedisClusterAsyncConnection<K,V>
ip
- IP address of the hostport
- port number.public RedisFuture<String> clusterForget(String nodeId)
RedisClusterAsyncConnection
clusterForget
in interface RedisClusterAsyncConnection<K,V>
nodeId
- the node Idpublic RedisFuture<String> clusterAddSlots(int... slots)
RedisClusterAsyncConnection
clusterAddSlots
in interface RedisClusterAsyncConnection<K,V>
slots
- one or more slots from 0 to 16384public RedisFuture<String> clusterDelSlots(int... slots)
RedisClusterAsyncConnection
clusterDelSlots
in interface RedisClusterAsyncConnection<K,V>
slots
- one or more slots from 0 to 16384public RedisFuture<String> clusterInfo()
RedisClusterAsyncConnection
clusterInfo
in interface RedisClusterAsyncConnection<K,V>
public RedisFuture<String> clusterMyId()
RedisClusterAsyncConnection
clusterMyId
in interface RedisClusterAsyncConnection<K,V>
public RedisFuture<String> clusterNodes()
RedisClusterAsyncConnection
ClusterPartitionParser.parse(java.lang.String)
clusterNodes
in interface RedisClusterAsyncConnection<K,V>
public RedisFuture<List<K>> clusterGetKeysInSlot(int slot, int count)
RedisClusterAsyncConnection
slot
.clusterGetKeysInSlot
in interface RedisClusterAsyncConnection<K,V>
slot
- the slotcount
- maximal number of keyspublic RedisFuture<Long> clusterCountKeysInSlot(int slot)
RedisClusterAsyncConnection
slot
.clusterCountKeysInSlot
in interface RedisClusterAsyncConnection<K,V>
slot
- the slotpublic RedisFuture<Long> clusterCountFailureReports(String nodeId)
RedisClusterAsyncConnection
clusterCountFailureReports
in interface RedisClusterAsyncConnection<K,V>
nodeId
- the node idpublic RedisFuture<Long> clusterKeyslot(K key)
RedisClusterAsyncConnection
SlotHash.getSlot(byte[])
. If not, call Houston and report that we've got a problem.clusterKeyslot
in interface RedisClusterAsyncConnection<K,V>
key
- the key.public RedisFuture<String> clusterSaveconfig()
RedisClusterAsyncConnection
clusterSaveconfig
in interface RedisClusterAsyncConnection<K,V>
OK
or an error if the operation fails.public RedisFuture<String> clusterSetConfigEpoch(long configEpoch)
RedisClusterAsyncConnection
clusterSetConfigEpoch
in interface RedisClusterAsyncConnection<K,V>
configEpoch
- the config epochOK
or an error if the operation fails.public RedisFuture<List<Object>> clusterSlots()
RedisClusterAsyncConnection
clusterSlots
in interface RedisClusterAsyncConnection<K,V>
public RedisFuture<String> clusterSetSlotNode(int slot, String nodeId)
RedisClusterAsyncConnection
nodeId
clusterSetSlotNode
in interface RedisClusterAsyncConnection<K,V>
slot
- the slotnodeId
- the id of the node that will become the master for the slotpublic RedisFuture<String> clusterSetSlotStable(int slot)
RedisClusterAsyncConnection
clusterSetSlotStable
in interface RedisClusterAsyncConnection<K,V>
slot
- the slotpublic RedisFuture<String> clusterSetSlotMigrating(int slot, String nodeId)
RedisClusterAsyncConnection
nodeId
. The slot must be handled by
the current node in order to be migrated.clusterSetSlotMigrating
in interface RedisClusterAsyncConnection<K,V>
slot
- the slotnodeId
- the id of the node is targeted to become the master for the slotpublic RedisFuture<String> clusterSetSlotImporting(int slot, String nodeId)
RedisClusterAsyncConnection
nodeId
.clusterSetSlotImporting
in interface RedisClusterAsyncConnection<K,V>
slot
- the slotnodeId
- the id of the node is the master of the slotpublic RedisFuture<String> clusterFailover(boolean force)
RedisClusterAsyncConnection
clusterFailover
in interface RedisClusterAsyncConnection<K,V>
force
- do not coordinate with master if truepublic RedisFuture<String> clusterReset(boolean hard)
RedisClusterAsyncConnection
clusterReset
in interface RedisClusterAsyncConnection<K,V>
hard
- true for hard reset. Generates a new nodeId and currentEpoch/configEpoch are set to 0public RedisFuture<String> asking()
RedisClusterAsyncConnection
-ASK
redirection. The client should issue ASKING
before to actually send the
command to the target instance. See the Redis Cluster specification for more information.asking
in interface RedisClusterAsyncConnection<K,V>
public RedisFuture<String> clusterReplicate(String nodeId)
RedisClusterAsyncConnection
nodeId
.clusterReplicate
in interface RedisClusterAsyncConnection<K,V>
nodeId
- master node idpublic RedisFuture<String> clusterFlushslots()
RedisClusterAsyncConnection
clusterFlushslots
in interface RedisClusterAsyncConnection<K,V>
public RedisFuture<List<String>> clusterSlaves(String nodeId)
RedisClusterAsyncConnection
nodeId
. Can be parsed using
ClusterPartitionParser.parse(java.lang.String)
clusterSlaves
in interface RedisClusterAsyncConnection<K,V>
nodeId
- node id of the master nodeRedisClusterAsyncConnection.clusterNodes()
but one line per slave.public RedisFuture<Long> zlexcount(K key, String min, String max)
RedisSortedSetsAsyncConnection
zlexcount
in interface RedisSortedSetsAsyncConnection<K,V>
key
- the keymin
- min scoremax
- max scorepublic RedisFuture<Long> zremrangebylex(K key, String min, String max)
RedisSortedSetsAsyncConnection
zremrangebylex
in interface RedisSortedSetsAsyncConnection<K,V>
key
- the keymin
- min scoremax
- max scorepublic RedisFuture<List<V>> zrangebylex(K key, String min, String max)
RedisSortedSetsAsyncConnection
zrangebylex
in interface RedisSortedSetsAsyncConnection<K,V>
key
- the keymin
- min scoremax
- max scorepublic RedisFuture<List<V>> zrangebylex(K key, String min, String max, long offset, long count)
RedisSortedSetsAsyncConnection
zrangebylex
in interface RedisSortedSetsAsyncConnection<K,V>
key
- the keymin
- min scoremax
- max scoreoffset
- the offsetcount
- the countpublic RedisFuture<Long> geoadd(K key, double longitude, double latitude, V member)
RedisGeoAsyncConnection
geoadd
in interface RedisGeoAsyncConnection<K,V>
key
- the key of the geo setlongitude
- the longitude coordinate according to WGS84latitude
- the latitude coordinate according to WGS84member
- the member to addpublic RedisFuture<Long> geoadd(K key, Object... lngLatMember)
RedisGeoAsyncConnection
geoadd
in interface RedisGeoAsyncConnection<K,V>
key
- the key of the geo setlngLatMember
- triplets of double longitude, double latitude and V memberpublic RedisFuture<List<String>> geohash(K key, V... members)
RedisGeoAsyncConnection
geohash
in interface RedisGeoAsyncConnection<K,V>
key
- the key of the geo setmembers
- the membersmembers
. Returns null if a member is not found.public RedisFuture<Set<V>> georadius(K key, double longitude, double latitude, double distance, GeoArgs.Unit unit)
RedisGeoAsyncConnection
longitude
and latitude
.georadius
in interface RedisGeoAsyncConnection<K,V>
key
- the key of the geo setlongitude
- the longitude coordinate according to WGS84latitude
- the latitude coordinate according to WGS84distance
- radius distanceunit
- distance unitpublic RedisFuture<List<GeoWithin<V>>> georadius(K key, double longitude, double latitude, double distance, GeoArgs.Unit unit, GeoArgs geoArgs)
RedisGeoAsyncConnection
longitude
and latitude
.georadius
in interface RedisGeoAsyncConnection<K,V>
key
- the key of the geo setlongitude
- the longitude coordinate according to WGS84latitude
- the latitude coordinate according to WGS84distance
- radius distanceunit
- distance unitgeoArgs
- args to control the resultGeoWithin
contains only fields which were requested by GeoArgs
public RedisFuture<Long> georadius(K key, double longitude, double latitude, double distance, GeoArgs.Unit unit, GeoRadiusStoreArgs<K> geoRadiusStoreArgs)
RedisGeoAsyncConnection
RedisGeoAsyncConnection.georadius(Object, double, double, double, GeoArgs.Unit, GeoArgs)
query and store the results in a
sorted set.georadius
in interface RedisGeoAsyncConnection<K,V>
key
- the key of the geo setlongitude
- the longitude coordinate according to WGS84latitude
- the latitude coordinate according to WGS84distance
- radius distanceunit
- distance unitgeoRadiusStoreArgs
- args to store either the resulting elements with their distance or the resulting elements with
their locations a sorted set.public RedisFuture<Set<V>> georadiusbymember(K key, V member, double distance, GeoArgs.Unit unit)
RedisGeoAsyncConnection
member
. The member itself is always contained in the
results.georadiusbymember
in interface RedisGeoAsyncConnection<K,V>
key
- the key of the geo setmember
- reference memberdistance
- radius distanceunit
- distance unitpublic RedisFuture<List<GeoWithin<V>>> georadiusbymember(K key, V member, double distance, GeoArgs.Unit unit, GeoArgs geoArgs)
RedisGeoAsyncConnection
member
. The member itself is always contained in the
results.georadiusbymember
in interface RedisGeoAsyncConnection<K,V>
key
- the key of the geo setmember
- reference memberdistance
- radius distanceunit
- distance unitgeoArgs
- args to control the resultGeoWithin
contains only fields which were requested by GeoArgs
public RedisFuture<Long> georadiusbymember(K key, V member, double distance, GeoArgs.Unit unit, GeoRadiusStoreArgs<K> geoRadiusStoreArgs)
RedisGeoAsyncConnection
RedisGeoAsyncConnection.georadiusbymember(Object, Object, double, GeoArgs.Unit, GeoArgs)
query and store the results in a
sorted set.georadiusbymember
in interface RedisGeoAsyncConnection<K,V>
key
- the key of the geo setmember
- reference memberdistance
- radius distanceunit
- distance unitgeoRadiusStoreArgs
- args to store either the resulting elements with their distance or the resulting elements with
their locations a sorted set.public RedisFuture<List<GeoCoordinates>> geopos(K key, V... members)
RedisGeoAsyncConnection
members
.geopos
in interface RedisGeoAsyncConnection<K,V>
key
- the key of the geo setmembers
- the membersGeoCoordinates
s representing the x,y position of each element specified in the arguments. For
missing elements null is returned.public RedisFuture<Double> geodist(K key, V from, V to, GeoArgs.Unit unit)
RedisGeoAsyncConnection
from
and to
. If one or more elements are missing null is
returned. Default in meters by , otherwise according to unit
geodist
in interface RedisGeoAsyncConnection<K,V>
key
- the key of the geo setfrom
- from memberto
- to memberunit
- distance unitfrom
and to
. If one or more elements are missing null is
returned.public <T> RedisFuture<T> dispatch(ProtocolKeyword type, CommandOutput<K,V,T> output)
BaseRedisAsyncConnection
dispatch
in interface BaseRedisAsyncConnection<K,V>
T
- response typetype
- the command, must not be null.output
- the command output, must not be null.public <T> RedisFuture<T> dispatch(ProtocolKeyword type, CommandOutput<K,V,T> output, CommandArgs<K,V> args)
BaseRedisAsyncConnection
dispatch
in interface BaseRedisAsyncConnection<K,V>
T
- response typetype
- the command, must not be null.output
- the command output, must not be null.args
- the command arguments, must not be null.protected <T> RedisFuture<T> dispatch(CommandType type, CommandOutput<K,V,T> output)
protected <T> RedisCommand<K,V,T> dispatch(CommandType type, CommandOutput<K,V,T> output, CommandArgs<K,V> args)
public <T> RedisCommand<K,V,T> dispatch(RedisCommand<K,V,T> cmd)
dispatch
in class RedisChannelHandler<K,V>
public static String string(double n)
protected boolean isMulti()
public void activated()
RedisChannelHandler
activated
in class RedisChannelHandler<K,V>
Copyright © 2016. All rights reserved.