|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||
java.lang.Objectorg.springframework.data.redis.connection.srp.SrpConnection
public class SrpConnection
RedisConnection implementation on top of spullara Redis
Protocol library.
| Nested Class Summary |
|---|
| Nested classes/interfaces inherited from interface org.springframework.data.redis.connection.RedisStringCommands |
|---|
RedisStringCommands.BitOperation |
| Nested classes/interfaces inherited from interface org.springframework.data.redis.connection.RedisListCommands |
|---|
RedisListCommands.Position |
| Nested classes/interfaces inherited from interface org.springframework.data.redis.connection.RedisZSetCommands |
|---|
RedisZSetCommands.Aggregate, RedisZSetCommands.Tuple |
| Nested classes/interfaces inherited from interface org.springframework.data.redis.connection.RedisServerCommands |
|---|
RedisServerCommands.ShutdownOption |
| Constructor Summary | |
|---|---|
SrpConnection(String host,
int port,
BlockingQueue<SrpConnection> queue)
|
|
SrpConnection(String host,
int port,
String password,
BlockingQueue<SrpConnection> queue)
|
|
| Method Summary | ||
|---|---|---|
Long |
append(byte[] key,
byte[] value)
Append a value to key. |
|
void |
bgReWriteAof()
Start an Append Only File rewrite process on server. |
|
void |
bgSave()
Start background saving of db on server. |
|
void |
bgWriteAof()
Deprecated. As of 1.3, use bgReWriteAof(). |
|
Long |
bitCount(byte[] key)
Count the number of set bits (population counting) in value stored at key. |
|
Long |
bitCount(byte[] key,
long begin,
long end)
Count the number of set bits (population counting) of value stored at key between begin and
end. |
|
Long |
bitOp(RedisStringCommands.BitOperation op,
byte[] destination,
byte[]... keys)
Perform bitwise operations between strings. |
|
List<byte[]> |
bLPop(int timeout,
byte[]... keys)
Removes and returns first element from lists stored at keys (see: RedisListCommands.lPop(byte[])). |
|
List<byte[]> |
bRPop(int timeout,
byte[]... keys)
Removes and returns last element from lists stored at keys (see: RedisListCommands.rPop(byte[])). |
|
byte[] |
bRPopLPush(int timeout,
byte[] srcKey,
byte[] dstKey)
Remove the last element from list at srcKey, append it to dstKey and return its value (see
RedisListCommands.rPopLPush(byte[], byte[])). |
|
void |
close()
Closes (or quits) the connection. |
|
List<Object> |
closePipeline()
Executes the commands in the pipeline and returns their result. |
|
protected DataAccessException |
convertSrpAccessException(Exception ex)
|
|
Long |
dbSize()
Get the total number of available keys in currently selected database. |
|
Long |
decr(byte[] key)
Decrement value of key by 1. |
|
Long |
decrBy(byte[] key,
long value)
Increment value of key by value. |
|
Long |
del(byte[]... keys)
Delete given keys. |
|
void |
discard()
Discard all commands issued after RedisTxCommands.multi(). |
|
byte[] |
dump(byte[] key)
Retrieve serialized version of the value stored at key. |
|
byte[] |
echo(byte[] message)
Returns message via server roundtrip. |
|
|
eval(byte[] script,
ReturnType returnType,
int numKeys,
byte[]... keysAndArgs)
Evaluate given script. |
|
|
evalSha(String scriptSha1,
ReturnType returnType,
int numKeys,
byte[]... keysAndArgs)
Evaluate given scriptSha. |
|
List<Object> |
exec()
Executes all queued commands in a transaction started with RedisTxCommands.multi(). |
|
Object |
execute(String command,
byte[]... args)
'Native' or 'raw' execution of the given command along-side the given arguments. |
|
Boolean |
exists(byte[] key)
Determine if given key exists. |
|
Boolean |
expire(byte[] key,
long seconds)
Set time to live for given key in seconds. |
|
Boolean |
expireAt(byte[] key,
long unixTime)
Set the expiration for given key as a UNIX timestamp. |
|
void |
flushAll()
Delete all all keys from all databases. |
|
void |
flushDb()
Delete all keys of the currently selected database. |
|
byte[] |
get(byte[] key)
Get the value of key. |
|
Boolean |
getBit(byte[] key,
long offset)
Get the bit value at offset of value at key. |
|
List<RedisClientInfo> |
getClientList()
Request information and statistics about connected clients. |
|
String |
getClientName()
Returns the name of the current connection. |
|
List<String> |
getConfig(String param)
Load configuration parameters for given pattern from server. |
|
redis.client.RedisClient |
getNativeConnection()
Returns the native connection (the underlying library/driver object). |
|
byte[] |
getRange(byte[] key,
long start,
long end)
Get a substring of value of key between begin and end. |
|
byte[] |
getSet(byte[] key,
byte[] value)
Set value of key and return its old value. |
|
Subscription |
getSubscription()
Returns the current subscription for this connection or null if the connection is not subscribed. |
|
Long |
hDel(byte[] key,
byte[]... fields)
Delete given hash fields. |
|
Boolean |
hExists(byte[] key,
byte[] field)
Determine if given hash field exists. |
|
byte[] |
hGet(byte[] key,
byte[] field)
Get value for given field from hash at key. |
|
Map<byte[],byte[]> |
hGetAll(byte[] key)
Get entire hash stored at key. |
|
Double |
hIncrBy(byte[] key,
byte[] field,
double delta)
Increment value of a hash field by the given delta. |
|
Long |
hIncrBy(byte[] key,
byte[] field,
long delta)
Increment value of a hash field by the given delta. |
|
Set<byte[]> |
hKeys(byte[] key)
Get key set (fields) of hash at key. |
|
Long |
hLen(byte[] key)
Get size of hash at key. |
|
List<byte[]> |
hMGet(byte[] key,
byte[]... fields)
Get values for given fields from hash at key. |
|
void |
hMSet(byte[] key,
Map<byte[],byte[]> tuple)
Set multiple hash fields to multiple values using data provided in hashes |
|
Boolean |
hSet(byte[] key,
byte[] field,
byte[] value)
Set the value of a hash field. |
|
Boolean |
hSetNX(byte[] key,
byte[] field,
byte[] value)
Set the value of a hash field only if field does not exist. |
|
List<byte[]> |
hVals(byte[] key)
Get entry set (values) of hash at field. |
|
Long |
incr(byte[] key)
Increment value of key by 1. |
|
Double |
incrBy(byte[] key,
double value)
Increment value of key by value. |
|
Long |
incrBy(byte[] key,
long value)
Increment value of key by value. |
|
Properties |
info()
Load default server information like mempory cpu utilization replication |
|
Properties |
info(String section)
Load server information for given selection. |
|
boolean |
isClosed()
Indicates whether the underlying connection is closed or not. |
|
boolean |
isPipelined()
Indicates whether the connection is currently pipelined or not. |
|
boolean |
isQueueing()
Indicates whether the connection is in "queue"(or "MULTI") mode or not. |
|
boolean |
isSubscribed()
Indicates whether the current connection is subscribed (to at least one channel) or not. |
|
Set<byte[]> |
keys(byte[] pattern)
Find all keys matching the given pattern. |
|
void |
killClient(String host,
int port)
<<<<<<< HEAD Closes a given client connection identified by ip:port. |
|
Long |
lastSave()
Get time of last RedisServerCommands.bgSave() operation in seconds. |
|
byte[] |
lIndex(byte[] key,
long index)
Get element at index form list at key. |
|
Long |
lInsert(byte[] key,
RedisListCommands.Position where,
byte[] pivot,
byte[] value)
Insert value RedisListCommands.Position.BEFORE or RedisListCommands.Position.AFTER existing pivot for key. |
|
Long |
lLen(byte[] key)
Get the size of list stored at key. |
|
byte[] |
lPop(byte[] key)
Removes and returns first element in list stored at key. |
|
Long |
lPush(byte[] key,
byte[]... values)
Prepend values to key. |
|
Long |
lPushX(byte[] key,
byte[] value)
Prepend values to key only if the list exits. |
|
List<byte[]> |
lRange(byte[] key,
long start,
long end)
Get elements between begin and end from list at key. |
|
Long |
lRem(byte[] key,
long count,
byte[] value)
Removes the first count occurrences of value from the list stored at key. |
|
void |
lSet(byte[] key,
long index,
byte[] value)
Set the value list element at index. |
|
void |
lTrim(byte[] key,
long start,
long end)
Trim list at key to elements between begin and end. |
|
List<byte[]> |
mGet(byte[]... keys)
Get the values of all given keys. |
|
Boolean |
move(byte[] key,
int dbIndex)
Move given key to database with index. |
|
void |
mSet(Map<byte[],byte[]> tuples)
Set multiple keys to multiple values using key-value pairs provided in tuple. |
|
Boolean |
mSetNX(Map<byte[],byte[]> tuples)
Set multiple keys to multiple values using key-value pairs provided in tuple only if the provided key does
not exist. |
|
void |
multi()
Mark the start of a transaction block. |
|
void |
openPipeline()
Activates the pipeline mode for this connection. |
|
Boolean |
persist(byte[] key)
Remove the expiration from given key. |
|
Boolean |
pExpire(byte[] key,
long millis)
Set time to live for given key in milliseconds. |
|
Boolean |
pExpireAt(byte[] key,
long unixTimeInMillis)
Set the expiration for given key as a UNIX timestamp in milliseconds. |
|
String |
ping()
Test connection. |
|
void |
pSetEx(byte[] key,
long milliseconds,
byte[] value)
Set the value and expiration in milliseconds for key. |
|
void |
pSubscribe(MessageListener listener,
byte[]... patterns)
Subscribes the connection to all channels matching the given patterns. |
|
Long |
pTtl(byte[] key)
Get the time to live for key in milliseconds. |
|
Long |
publish(byte[] channel,
byte[] message)
Publishes the given message to the given channel. |
|
byte[] |
randomKey()
Return a random key from the keyspace. |
|
void |
rename(byte[] oldName,
byte[] newName)
Rename key oleName to newName. |
|
Boolean |
renameNX(byte[] oldName,
byte[] newName)
Rename key oleName to newName only if newName does not exist. |
|
void |
resetConfigStats()
Reset statistic counters on server. |
|
void |
restore(byte[] key,
long ttlInMillis,
byte[] serializedValue)
Create key using the serializedValue, previously obtained using RedisKeyCommands.dump(byte[]). |
|
byte[] |
rPop(byte[] key)
Removes and returns last element in list stored at key. |
|
byte[] |
rPopLPush(byte[] srcKey,
byte[] dstKey)
Remove the last element from list at srcKey, append it to dstKey and return its value. |
|
Long |
rPush(byte[] key,
byte[]... values)
Append values to key. |
|
Long |
rPushX(byte[] key,
byte[] value)
Append values to key only if the list exists. |
|
Long |
sAdd(byte[] key,
byte[]... values)
Add given values to set at key. |
|
void |
save()
Synchronous save current db snapshot on server. |
|
Long |
sCard(byte[] key)
Get size of set at key. |
|
List<Boolean> |
scriptExists(String... scriptSha1)
Check if given scriptShas exist in script cache. |
|
void |
scriptFlush()
Flush lua script cache. |
|
void |
scriptKill()
Kill current lua script execution. |
|
String |
scriptLoad(byte[] script)
Load lua script into scripts cache, without executing it. |
|
Set<byte[]> |
sDiff(byte[]... keys)
Diff all sets for given keys. |
|
Long |
sDiffStore(byte[] destKey,
byte[]... keys)
Diff all sets for given keys and store result in destKey |
|
void |
select(int dbIndex)
Select the DB with given positive dbIndex. |
|
void |
set(byte[] key,
byte[] value)
Set value for key. |
|
Boolean |
setBit(byte[] key,
long offset,
boolean value)
Sets the bit at offset in value stored at key. |
|
void |
setClientName(byte[] name)
Assign given name to current connection. |
|
void |
setConfig(String param,
String value)
Set server configuration for key to value. |
|
void |
setConvertPipelineAndTxResults(boolean convertPipelineAndTxResults)
Specifies if pipelined results should be converted to the expected data type. |
|
void |
setEx(byte[] key,
long time,
byte[] value)
Set the value and expiration in seconds for key. |
|
Boolean |
setNX(byte[] key,
byte[] value)
Set value for key, only if key does not exist. |
|
void |
setRange(byte[] key,
byte[] value,
long start)
Overwrite parts of key starting at the specified offset with given value. |
|
void |
shutdown()
Shutdown server. |
|
void |
shutdown(RedisServerCommands.ShutdownOption option)
Shutdown server. |
|
Set<byte[]> |
sInter(byte[]... keys)
Returns the members intersecting all given sets at keys. |
|
Long |
sInterStore(byte[] destKey,
byte[]... keys)
Intersect all given sets at keys and store result in destKey. |
|
Boolean |
sIsMember(byte[] key,
byte[] value)
Check if set at key contains value. |
|
void |
slaveOf(String host,
int port)
Change redis replication setting to new master. |
|
void |
slaveOfNoOne()
Change server into master. |
|
Set<byte[]> |
sMembers(byte[] key)
Get all elements of set at key. |
|
Boolean |
sMove(byte[] srcKey,
byte[] destKey,
byte[] value)
Move value from srcKey to |
|
List<byte[]> |
sort(byte[] key,
SortParameters params)
Sort the elements for key. |
|
Long |
sort(byte[] key,
SortParameters params,
byte[] sortKey)
Sort the elements for key and store result in storeKey. |
|
byte[] |
sPop(byte[] key)
Remove and return a random member from set at key. |
|
byte[] |
sRandMember(byte[] key)
Get random element from set at key. |
|
List<byte[]> |
sRandMember(byte[] key,
long count)
Get count random elements from set at key. |
|
Long |
sRem(byte[] key,
byte[]... values)
Remove given values from set at key and return the number of removed elements. |
|
Long |
strLen(byte[] key)
Get the length of the value stored at key. |
|
void |
subscribe(MessageListener listener,
byte[]... channels)
Subscribes the connection to the given channels. |
|
Set<byte[]> |
sUnion(byte[]... keys)
Union all sets at given keys. |
|
Long |
sUnionStore(byte[] destKey,
byte[]... keys)
Union all sets at given keys and store result in destKey. |
|
Long |
time()
Request server timestamp using TIME command. |
|
Long |
ttl(byte[] key)
Get the time to live for key in seconds. |
|
DataType |
type(byte[] key)
Determine the type stored at key. |
|
void |
unwatch()
Flushes all the previously #watch(byte[]) keys. |
|
void |
watch(byte[]... keys)
Watch given keys for modifications during transaction started with RedisTxCommands.multi(). |
|
Boolean |
zAdd(byte[] key,
double score,
byte[] value)
Add value to a sorted set at key, or update its score if it already exists. |
|
Long |
zAdd(byte[] key,
Set<RedisZSetCommands.Tuple> tuples)
Add tuples to a sorted set at key, or update its score if it already exists. |
|
Long |
zCard(byte[] key)
Get the size of sorted set with key. |
|
Long |
zCount(byte[] key,
double min,
double max)
Count number of elements within sorted set with scores between min and max. |
|
Double |
zIncrBy(byte[] key,
double increment,
byte[] value)
Increment the score of element with value in sorted set by increment. |
|
Long |
zInterStore(byte[] destKey,
byte[]... sets)
Intersect sorted sets and store result in destination key. |
|
Long |
zInterStore(byte[] destKey,
RedisZSetCommands.Aggregate aggregate,
int[] weights,
byte[]... sets)
Intersect sorted sets and store result in destination key. |
|
Set<byte[]> |
zRange(byte[] key,
long start,
long end)
Get elements between begin and end from sorted set. |
|
Set<byte[]> |
zRangeByScore(byte[] key,
double min,
double max)
Get elements where score is between min and max from sorted set. |
|
Set<byte[]> |
zRangeByScore(byte[] key,
double min,
double max,
long offset,
long count)
Get elements in range from begin to end where score is between min and max from
sorted set. |
|
Set<RedisZSetCommands.Tuple> |
zRangeByScoreWithScores(byte[] key,
double min,
double max)
Get set of RedisZSetCommands.Tuples where score is between min and max from sorted set. |
|
Set<RedisZSetCommands.Tuple> |
zRangeByScoreWithScores(byte[] key,
double min,
double max,
long offset,
long count)
Get set of RedisZSetCommands.Tuples in range from begin to end where score is between min and
max from sorted set. |
|
Set<RedisZSetCommands.Tuple> |
zRangeWithScores(byte[] key,
long start,
long end)
Get set of RedisZSetCommands.Tuples between begin and end from sorted set. |
|
Long |
zRank(byte[] key,
byte[] value)
Determine the index of element with value in a sorted set. |
|
Long |
zRem(byte[] key,
byte[]... values)
Remove values from sorted set. |
|
Long |
zRemRange(byte[] key,
long start,
long end)
Remove elements in range between begin and end from sorted set with key. |
|
Long |
zRemRangeByScore(byte[] key,
double min,
double max)
Remove elements with scores between min and max from sorted set with key. |
|
Set<byte[]> |
zRevRange(byte[] key,
long start,
long end)
Get elements in range from begin to end from sorted set ordered high -> low. |
|
Set<byte[]> |
zRevRangeByScore(byte[] key,
double min,
double max)
Get elements where score is between min and max from sorted set ordered high -> low. |
|
Set<byte[]> |
zRevRangeByScore(byte[] key,
double min,
double max,
long offset,
long count)
Get elements in range from begin to end where score is between min and max from
sorted set ordered high -> low. |
|
Set<RedisZSetCommands.Tuple> |
zRevRangeByScoreWithScores(byte[] key,
double min,
double max)
Get set of RedisZSetCommands.Tuple where score is between min and max from sorted set ordered high -> low. |
|
Set<RedisZSetCommands.Tuple> |
zRevRangeByScoreWithScores(byte[] key,
double min,
double max,
long offset,
long count)
Get set of RedisZSetCommands.Tuple in range from begin to end where score is between min and
max from sorted set ordered high -> low. |
|
Set<RedisZSetCommands.Tuple> |
zRevRangeWithScores(byte[] key,
long start,
long end)
Get set of RedisZSetCommands.Tuples in range from begin to end from sorted set ordered high -> low. |
|
Long |
zRevRank(byte[] key,
byte[] value)
Determine the index of element with value in a sorted set when scored high to low. |
|
Double |
zScore(byte[] key,
byte[] value)
Get the score of element with value from sorted set with key key. |
|
Long |
zUnionStore(byte[] destKey,
byte[]... sets)
Union sorted sets and store result in destination key. |
|
Long |
zUnionStore(byte[] destKey,
RedisZSetCommands.Aggregate aggregate,
int[] weights,
byte[]... sets)
Union sorted sets and store result in destination key. |
|
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Constructor Detail |
|---|
public SrpConnection(String host,
int port,
BlockingQueue<SrpConnection> queue)
public SrpConnection(String host,
int port,
String password,
BlockingQueue<SrpConnection> queue)
| Method Detail |
|---|
protected DataAccessException convertSrpAccessException(Exception ex)
public Object execute(String command,
byte[]... args)
RedisCommands
execute in interface RedisCommandscommand - Command to executeargs - Possible command arguments (may be null)
public void close()
throws DataAccessException
RedisConnection
close in interface RedisConnectionDataAccessExceptionpublic boolean isClosed()
RedisConnection
isClosed in interface RedisConnectionpublic redis.client.RedisClient getNativeConnection()
RedisConnection
getNativeConnection in interface RedisConnectionpublic boolean isQueueing()
RedisConnection
isQueueing in interface RedisConnectionpublic boolean isPipelined()
RedisConnection
isPipelined in interface RedisConnectionRedisConnection.openPipeline(),
RedisConnection.isQueueing()public void openPipeline()
RedisConnectionRedisConnection.closePipeline(). Calling this method when the connection is already pipelined has no effect.
Pipelining is used for issuing commands without requesting the response right away but rather at the end of the
batch. While somewhat similar to MULTI, pipelining does not guarantee atomicity - it only tries to improve
performance when issuing a lot of commands (such as in batching scenarios).
Note:
Consider doing some performance testing before using this feature since in many cases the performance benefits are minimal yet the impact on usage are not.
openPipeline in interface RedisConnectionRedisTxCommands.multi()
public List<byte[]> sort(byte[] key,
SortParameters params)
RedisKeyCommandskey.
sort in interface RedisKeyCommandshttp://redis.io/commands/sort
public Long sort(byte[] key,
SortParameters params,
byte[] sortKey)
RedisKeyCommandskey and store result in storeKey.
sort in interface RedisKeyCommandshttp://redis.io/commands/sortpublic Long dbSize()
RedisServerCommands
dbSize in interface RedisServerCommandshttp://redis.io/commands/dbsizepublic void flushDb()
RedisServerCommands
flushDb in interface RedisServerCommandshttp://redis.io/commands/flushdbpublic void flushAll()
RedisServerCommands
flushAll in interface RedisServerCommandshttp://redis.io/commands/flushallpublic void bgSave()
RedisServerCommands
bgSave in interface RedisServerCommandshttp://redis.io/commands/bgsavepublic void bgReWriteAof()
RedisServerCommands
bgReWriteAof in interface RedisServerCommandshttp://redis.io/commands/bgrewriteaof@Deprecated public void bgWriteAof()
bgReWriteAof().
RedisServerCommands
bgWriteAof in interface RedisServerCommandshttp://redis.io/commands/bgrewriteaofpublic void save()
RedisServerCommands
save in interface RedisServerCommandshttp://redis.io/commands/savepublic List<String> getConfig(String param)
RedisServerCommandspattern from server.
getConfig in interface RedisServerCommandshttp://redis.io/commands/config-getpublic Properties info()
RedisServerCommands
info in interface RedisServerCommandshttp://redis.io/commands/infopublic Properties info(String section)
RedisServerCommandsselection.
info in interface RedisServerCommandshttp://redis.io/commands/infopublic Long lastSave()
RedisServerCommandsRedisServerCommands.bgSave() operation in seconds.
lastSave in interface RedisServerCommandshttp://redis.io/commands/lastsave
public void setConfig(String param,
String value)
RedisServerCommandskey to value.
setConfig in interface RedisServerCommandshttp://redis.io/commands/config-setpublic void resetConfigStats()
RedisServerCommandsRedisServerCommands.info().
resetConfigStats in interface RedisServerCommandshttp://redis.io/commands/config-resetstatpublic void shutdown()
RedisServerCommands
shutdown in interface RedisServerCommandshttp://redis.io/commands/shutdownpublic void shutdown(RedisServerCommands.ShutdownOption option)
RedisServerCommands
shutdown in interface RedisServerCommandshttp://redis.io/commands/shutdownpublic byte[] echo(byte[] message)
RedisConnectionCommandsmessage via server roundtrip.
echo in interface RedisConnectionCommandshttp://redis.io/commands/echopublic String ping()
RedisConnectionCommands
ping in interface RedisConnectionCommandshttp://redis.io/commands/pingpublic Long del(byte[]... keys)
RedisKeyCommandskeys.
del in interface RedisKeyCommandshttp://redis.io/commands/delpublic void discard()
RedisTxCommandsRedisTxCommands.multi().
discard in interface RedisTxCommandshttp://redis.io/commands/discardpublic List<Object> exec()
RedisTxCommandsRedisTxCommands.multi(). #watch(byte[]) the operation will fail if any of watched keys has been modified.
exec in interface RedisTxCommandshttp://redis.io/commands/execpublic Boolean exists(byte[] key)
RedisKeyCommandskey exists.
exists in interface RedisKeyCommandshttp://redis.io/commands/exists
public Boolean expire(byte[] key,
long seconds)
RedisKeyCommandskey in seconds.
expire in interface RedisKeyCommandshttp://redis.io/commands/expire
public Boolean expireAt(byte[] key,
long unixTime)
RedisKeyCommandskey as a UNIX timestamp.
expireAt in interface RedisKeyCommandshttp://redis.io/commands/expireat
public Boolean pExpire(byte[] key,
long millis)
RedisKeyCommandskey in milliseconds.
pExpire in interface RedisKeyCommandshttp://redis.io/commands/pexpire
public Boolean pExpireAt(byte[] key,
long unixTimeInMillis)
RedisKeyCommandskey as a UNIX timestamp in milliseconds.
pExpireAt in interface RedisKeyCommandshttp://redis.io/commands/pexpireatpublic Set<byte[]> keys(byte[] pattern)
RedisKeyCommandspattern.
keys in interface RedisKeyCommandshttp://redis.io/commands/keyspublic void multi()
RedisTxCommandsRedisTxCommands.exec() or rolled back using RedisTxCommands.discard()
.
multi in interface RedisTxCommandshttp://redis.io/commands/multipublic Boolean persist(byte[] key)
RedisKeyCommandskey.
persist in interface RedisKeyCommandshttp://redis.io/commands/persist
public Boolean move(byte[] key,
int dbIndex)
RedisKeyCommandskey to database with index.
move in interface RedisKeyCommandshttp://redis.io/commands/movepublic byte[] randomKey()
RedisKeyCommands
randomKey in interface RedisKeyCommandshttp://redis.io/commands/randomkey
public void rename(byte[] oldName,
byte[] newName)
RedisKeyCommandsoleName to newName.
rename in interface RedisKeyCommandshttp://redis.io/commands/rename
public Boolean renameNX(byte[] oldName,
byte[] newName)
RedisKeyCommandsoleName to newName only if newName does not exist.
renameNX in interface RedisKeyCommandshttp://redis.io/commands/renamenxpublic void select(int dbIndex)
RedisConnectionCommandsdbIndex.
select in interface RedisConnectionCommandshttp://redis.io/commands/selectpublic Long ttl(byte[] key)
RedisKeyCommandskey in seconds.
ttl in interface RedisKeyCommandshttp://redis.io/commands/ttlpublic Long pTtl(byte[] key)
RedisKeyCommandskey in milliseconds.
pTtl in interface RedisKeyCommandshttp://redis.io/commands/pttlpublic byte[] dump(byte[] key)
RedisKeyCommandskey.
dump in interface RedisKeyCommandshttp://redis.io/commands/dump
public void restore(byte[] key,
long ttlInMillis,
byte[] serializedValue)
RedisKeyCommandskey using the serializedValue, previously obtained using RedisKeyCommands.dump(byte[]).
restore in interface RedisKeyCommandshttp://redis.io/commands/restorepublic DataType type(byte[] key)
RedisKeyCommandskey.
type in interface RedisKeyCommandshttp://redis.io/commands/typepublic void unwatch()
RedisTxCommands#watch(byte[]) keys.
unwatch in interface RedisTxCommandshttp://redis.io/commands/unwatchpublic void watch(byte[]... keys)
RedisTxCommandskeys for modifications during transaction started with RedisTxCommands.multi().
watch in interface RedisTxCommandshttp://redis.io/commands/watchpublic byte[] get(byte[] key)
RedisStringCommandskey.
get in interface RedisStringCommandshttp://redis.io/commands/get
public void set(byte[] key,
byte[] value)
RedisStringCommandsvalue for key.
set in interface RedisStringCommandshttp://redis.io/commands/set
public byte[] getSet(byte[] key,
byte[] value)
RedisStringCommandskey and return its old value.
getSet in interface RedisStringCommandshttp://redis.io/commands/getset
public Long append(byte[] key,
byte[] value)
RedisStringCommandsvalue to key.
append in interface RedisStringCommandshttp://redis.io/commands/appendpublic List<byte[]> mGet(byte[]... keys)
RedisStringCommandskeys.
mGet in interface RedisStringCommandshttp://redis.io/commands/mgetpublic void mSet(Map<byte[],byte[]> tuples)
RedisStringCommandstuple.
mSet in interface RedisStringCommandshttp://redis.io/commands/msetpublic Boolean mSetNX(Map<byte[],byte[]> tuples)
RedisStringCommandstuple only if the provided key does
not exist.
mSetNX in interface RedisStringCommandshttp://redis.io/commands/msetnx
public void setEx(byte[] key,
long time,
byte[] value)
RedisStringCommandsvalue and expiration in seconds for key.
setEx in interface RedisStringCommandshttp://redis.io/commands/setex
public void pSetEx(byte[] key,
long milliseconds,
byte[] value)
RedisStringCommandsvalue and expiration in milliseconds for key.
pSetEx in interface RedisStringCommandshttp://redis.io/commands/psetex
public Boolean setNX(byte[] key,
byte[] value)
RedisStringCommandsvalue for key, only if key does not exist.
setNX in interface RedisStringCommandshttp://redis.io/commands/setnx
public byte[] getRange(byte[] key,
long start,
long end)
RedisStringCommandskey between begin and end.
getRange in interface RedisStringCommandshttp://redis.io/commands/getrangepublic Long decr(byte[] key)
RedisStringCommandskey by 1.
decr in interface RedisStringCommandshttp://redis.io/commands/decr
public Long decrBy(byte[] key,
long value)
RedisStringCommandskey by value.
decrBy in interface RedisStringCommandshttp://redis.io/commands/decrbypublic Long incr(byte[] key)
RedisStringCommandskey by 1.
incr in interface RedisStringCommandshttp://redis.io/commands/incr
public Long incrBy(byte[] key,
long value)
RedisStringCommandskey by value.
incrBy in interface RedisStringCommandshttp://redis.io/commands/incrby
public Double incrBy(byte[] key,
double value)
RedisStringCommandskey by value.
incrBy in interface RedisStringCommandshttp://redis.io/commands/incrbyfloat
public Boolean getBit(byte[] key,
long offset)
RedisStringCommandsoffset of value at key.
getBit in interface RedisStringCommandshttp://redis.io/commands/getbit
public Boolean setBit(byte[] key,
long offset,
boolean value)
RedisStringCommandsoffset in value stored at key.
setBit in interface RedisStringCommandsoffset.http://redis.io/commands/setbit
public void setRange(byte[] key,
byte[] value,
long start)
RedisStringCommandskey starting at the specified offset with given value.
setRange in interface RedisStringCommandshttp://redis.io/commands/setrangepublic Long strLen(byte[] key)
RedisStringCommandskey.
strLen in interface RedisStringCommandshttp://redis.io/commands/strlenpublic Long bitCount(byte[] key)
RedisStringCommandskey.
bitCount in interface RedisStringCommandshttp://redis.io/commands/bitcount
public Long bitCount(byte[] key,
long begin,
long end)
RedisStringCommandskey between begin and
end.
bitCount in interface RedisStringCommandshttp://redis.io/commands/bitcount
public Long bitOp(RedisStringCommands.BitOperation op,
byte[] destination,
byte[]... keys)
RedisStringCommands
bitOp in interface RedisStringCommandshttp://redis.io/commands/bitop
public Long lPush(byte[] key,
byte[]... values)
RedisListCommandsvalues to key.
lPush in interface RedisListCommandshttp://redis.io/commands/lpush
public Long rPush(byte[] key,
byte[]... values)
RedisListCommandsvalues to key.
rPush in interface RedisListCommandshttp://redis.io/commands/rpush
public List<byte[]> bLPop(int timeout,
byte[]... keys)
RedisListCommandskeys (see: RedisListCommands.lPop(byte[])). timeout reached.
bLPop in interface RedisListCommandshttp://redis.io/commands/blpop
public List<byte[]> bRPop(int timeout,
byte[]... keys)
RedisListCommandskeys (see: RedisListCommands.rPop(byte[])). timeout reached.
bRPop in interface RedisListCommandshttp://redis.io/commands/brpop
public byte[] lIndex(byte[] key,
long index)
RedisListCommandsindex form list at key.
lIndex in interface RedisListCommandshttp://redis.io/commands/lindex
public Long lInsert(byte[] key,
RedisListCommands.Position where,
byte[] pivot,
byte[] value)
RedisListCommandsvalue RedisListCommands.Position.BEFORE or RedisListCommands.Position.AFTER existing pivot for key.
lInsert in interface RedisListCommandshttp://redis.io/commands/linsertpublic Long lLen(byte[] key)
RedisListCommandskey.
lLen in interface RedisListCommandshttp://redis.io/commands/llenpublic byte[] lPop(byte[] key)
RedisListCommandskey.
lPop in interface RedisListCommandshttp://redis.io/commands/lpop
public List<byte[]> lRange(byte[] key,
long start,
long end)
RedisListCommandsbegin and end from list at key.
lRange in interface RedisListCommandshttp://redis.io/commands/lrange
public Long lRem(byte[] key,
long count,
byte[] value)
RedisListCommandscount occurrences of value from the list stored at key.
lRem in interface RedisListCommandshttp://redis.io/commands/lrem
public void lSet(byte[] key,
long index,
byte[] value)
RedisListCommandsvalue list element at index.
lSet in interface RedisListCommandshttp://redis.io/commands/lset
public void lTrim(byte[] key,
long start,
long end)
RedisListCommandskey to elements between begin and end.
lTrim in interface RedisListCommandshttp://redis.io/commands/ltrimpublic byte[] rPop(byte[] key)
RedisListCommandskey.
rPop in interface RedisListCommandshttp://redis.io/commands/rpop
public byte[] rPopLPush(byte[] srcKey,
byte[] dstKey)
RedisListCommandssrcKey, append it to dstKey and return its value.
rPopLPush in interface RedisListCommandshttp://redis.io/commands/rpoplpush
public byte[] bRPopLPush(int timeout,
byte[] srcKey,
byte[] dstKey)
RedisListCommandssrcKey, append it to dstKey and return its value (see
RedisListCommands.rPopLPush(byte[], byte[])). timeout reached.
bRPopLPush in interface RedisListCommandshttp://redis.io/commands/brpoplpush
public Long lPushX(byte[] key,
byte[] value)
RedisListCommandsvalues to key only if the list exits.
lPushX in interface RedisListCommandshttp://redis.io/commands/lpushx
public Long rPushX(byte[] key,
byte[] value)
RedisListCommands values to key only if the list exists.
rPushX in interface RedisListCommandshttp://redis.io/commands/rpushx
public Long sAdd(byte[] key,
byte[]... values)
RedisSetCommandsvalues to set at key.
sAdd in interface RedisSetCommandshttp://redis.io/commands/saddpublic Long sCard(byte[] key)
RedisSetCommandskey.
sCard in interface RedisSetCommandshttp://redis.io/commands/scardpublic Set<byte[]> sDiff(byte[]... keys)
RedisSetCommandskeys.
sDiff in interface RedisSetCommandshttp://redis.io/commands/sdiff
public Long sDiffStore(byte[] destKey,
byte[]... keys)
RedisSetCommandskeys and store result in destKey
sDiffStore in interface RedisSetCommandshttp://redis.io/commands/sdiffstorepublic Set<byte[]> sInter(byte[]... keys)
RedisSetCommandskeys.
sInter in interface RedisSetCommandshttp://redis.io/commands/sinter
public Long sInterStore(byte[] destKey,
byte[]... keys)
RedisSetCommandskeys and store result in destKey.
sInterStore in interface RedisSetCommandshttp://redis.io/commands/sinterstore
public Boolean sIsMember(byte[] key,
byte[] value)
RedisSetCommandskey contains value.
sIsMember in interface RedisSetCommandshttp://redis.io/commands/sismemberpublic Set<byte[]> sMembers(byte[] key)
RedisSetCommandskey.
sMembers in interface RedisSetCommandshttp://redis.io/commands/smembers
public Boolean sMove(byte[] srcKey,
byte[] destKey,
byte[] value)
RedisSetCommandsvalue from srcKey to
sMove in interface RedisSetCommandshttp://redis.io/commands/smovepublic byte[] sPop(byte[] key)
RedisSetCommandskey.
sPop in interface RedisSetCommandshttp://redis.io/commands/spoppublic byte[] sRandMember(byte[] key)
RedisSetCommandskey.
sRandMember in interface RedisSetCommandshttp://redis.io/commands/srandmember
public List<byte[]> sRandMember(byte[] key,
long count)
RedisSetCommandscount random elements from set at key.
sRandMember in interface RedisSetCommandshttp://redis.io/commands/srandmember
public Long sRem(byte[] key,
byte[]... values)
RedisSetCommandsvalues from set at key and return the number of removed elements.
sRem in interface RedisSetCommandshttp://redis.io/commands/srempublic Set<byte[]> sUnion(byte[]... keys)
RedisSetCommandskeys.
sUnion in interface RedisSetCommandshttp://redis.io/commands/sunion
public Long sUnionStore(byte[] destKey,
byte[]... keys)
RedisSetCommandskeys and store result in destKey.
sUnionStore in interface RedisSetCommandshttp://redis.io/commands/sunionstore
public Boolean zAdd(byte[] key,
double score,
byte[] value)
RedisZSetCommandsvalue to a sorted set at key, or update its score if it already exists.
zAdd in interface RedisZSetCommandshttp://redis.io/commands/zadd
public Long zAdd(byte[] key,
Set<RedisZSetCommands.Tuple> tuples)
RedisZSetCommandstuples to a sorted set at key, or update its score if it already exists.
zAdd in interface RedisZSetCommandshttp://redis.io/commands/zaddpublic Long zCard(byte[] key)
RedisZSetCommandskey.
zCard in interface RedisZSetCommandshttp://redis.io/commands/zcard
public Long zCount(byte[] key,
double min,
double max)
RedisZSetCommandsmin and max.
zCount in interface RedisZSetCommandshttp://redis.io/commands/zcount
public Double zIncrBy(byte[] key,
double increment,
byte[] value)
RedisZSetCommandsvalue in sorted set by increment.
zIncrBy in interface RedisZSetCommandshttp://redis.io/commands/zincrby
public Long zInterStore(byte[] destKey,
RedisZSetCommands.Aggregate aggregate,
int[] weights,
byte[]... sets)
RedisZSetCommandssets and store result in destination key.
zInterStore in interface RedisZSetCommandshttp://redis.io/commands/zinterstore
public Long zInterStore(byte[] destKey,
byte[]... sets)
RedisZSetCommandssets and store result in destination key.
zInterStore in interface RedisZSetCommandshttp://redis.io/commands/zinterstore
public Set<byte[]> zRange(byte[] key,
long start,
long end)
RedisZSetCommandsbegin and end from sorted set.
zRange in interface RedisZSetCommandshttp://redis.io/commands/zrange
public Set<RedisZSetCommands.Tuple> zRangeWithScores(byte[] key,
long start,
long end)
RedisZSetCommandsRedisZSetCommands.Tuples between begin and end from sorted set.
zRangeWithScores in interface RedisZSetCommandshttp://redis.io/commands/zrange
public Set<byte[]> zRangeByScore(byte[] key,
double min,
double max)
RedisZSetCommandsmin and max from sorted set.
zRangeByScore in interface RedisZSetCommandshttp://redis.io/commands/zrangebyscore
public Set<RedisZSetCommands.Tuple> zRangeByScoreWithScores(byte[] key,
double min,
double max)
RedisZSetCommandsRedisZSetCommands.Tuples where score is between min and max from sorted set.
zRangeByScoreWithScores in interface RedisZSetCommandshttp://redis.io/commands/zrangebyscore
public Set<RedisZSetCommands.Tuple> zRevRangeWithScores(byte[] key,
long start,
long end)
RedisZSetCommandsRedisZSetCommands.Tuples in range from begin to end from sorted set ordered high -> low.
zRevRangeWithScores in interface RedisZSetCommandshttp://redis.io/commands/zrevrange
public Set<byte[]> zRangeByScore(byte[] key,
double min,
double max,
long offset,
long count)
RedisZSetCommandsbegin to end where score is between min and max from
sorted set.
zRangeByScore in interface RedisZSetCommandshttp://redis.io/commands/zrangebyscore
public Set<RedisZSetCommands.Tuple> zRangeByScoreWithScores(byte[] key,
double min,
double max,
long offset,
long count)
RedisZSetCommandsRedisZSetCommands.Tuples in range from begin to end where score is between min and
max from sorted set.
zRangeByScoreWithScores in interface RedisZSetCommandshttp://redis.io/commands/zrangebyscore
public Set<byte[]> zRevRangeByScore(byte[] key,
double min,
double max,
long offset,
long count)
RedisZSetCommandsbegin to end where score is between min and max from
sorted set ordered high -> low.
zRevRangeByScore in interface RedisZSetCommandshttp://redis.io/commands/zrevrangebyscore
public Set<byte[]> zRevRangeByScore(byte[] key,
double min,
double max)
RedisZSetCommandsmin and max from sorted set ordered high -> low.
zRevRangeByScore in interface RedisZSetCommandshttp://redis.io/commands/zrevrange
public Set<RedisZSetCommands.Tuple> zRevRangeByScoreWithScores(byte[] key,
double min,
double max,
long offset,
long count)
RedisZSetCommandsRedisZSetCommands.Tuple in range from begin to end where score is between min and
max from sorted set ordered high -> low.
zRevRangeByScoreWithScores in interface RedisZSetCommandshttp://redis.io/commands/zrevrangebyscore
public Set<RedisZSetCommands.Tuple> zRevRangeByScoreWithScores(byte[] key,
double min,
double max)
RedisZSetCommandsRedisZSetCommands.Tuple where score is between min and max from sorted set ordered high -> low.
zRevRangeByScoreWithScores in interface RedisZSetCommandshttp://redis.io/commands/zrevrange
public Long zRank(byte[] key,
byte[] value)
RedisZSetCommandsvalue in a sorted set.
zRank in interface RedisZSetCommandshttp://redis.io/commands/zrank
public Long zRem(byte[] key,
byte[]... values)
RedisZSetCommandsvalues from sorted set. Return number of removed elements.
zRem in interface RedisZSetCommandshttp://redis.io/commands/zrem
public Long zRemRange(byte[] key,
long start,
long end)
RedisZSetCommandsbegin and end from sorted set with key.
zRemRange in interface RedisZSetCommandshttp://redis.io/commands/zremrange
public Long zRemRangeByScore(byte[] key,
double min,
double max)
RedisZSetCommandsmin and max from sorted set with key.
zRemRangeByScore in interface RedisZSetCommandshttp://redis.io/commands/zremrangebyscore
public Set<byte[]> zRevRange(byte[] key,
long start,
long end)
RedisZSetCommandsbegin to end from sorted set ordered high -> low.
zRevRange in interface RedisZSetCommandshttp://redis.io/commands/zrevrange
public Long zRevRank(byte[] key,
byte[] value)
RedisZSetCommandsvalue in a sorted set when scored high to low.
zRevRank in interface RedisZSetCommandshttp://redis.io/commands/zrevrank
public Double zScore(byte[] key,
byte[] value)
RedisZSetCommandsvalue from sorted set with key key.
zScore in interface RedisZSetCommandshttp://redis.io/commands/zrem
public Long zUnionStore(byte[] destKey,
RedisZSetCommands.Aggregate aggregate,
int[] weights,
byte[]... sets)
RedisZSetCommandssets and store result in destination key.
zUnionStore in interface RedisZSetCommandshttp://redis.io/commands/zunionstore
public Long zUnionStore(byte[] destKey,
byte[]... sets)
RedisZSetCommandssets and store result in destination key.
zUnionStore in interface RedisZSetCommandshttp://redis.io/commands/zunionstore
public Boolean hSet(byte[] key,
byte[] field,
byte[] value)
RedisHashCommandsvalue of a hash field.
hSet in interface RedisHashCommandshttp://redis.io/commands/hset
public Boolean hSetNX(byte[] key,
byte[] field,
byte[] value)
RedisHashCommandsvalue of a hash field only if field does not exist.
hSetNX in interface RedisHashCommandshttp://redis.io/commands/hsetnx
public Long hDel(byte[] key,
byte[]... fields)
RedisHashCommandsfields.
hDel in interface RedisHashCommandshttp://redis.io/commands/hdel
public Boolean hExists(byte[] key,
byte[] field)
RedisHashCommandsfield exists.
hExists in interface RedisHashCommandshttp://redis.io/commands/hexits
public byte[] hGet(byte[] key,
byte[] field)
RedisHashCommandsfield from hash at key.
hGet in interface RedisHashCommandshttp://redis.io/commands/hgetpublic Map<byte[],byte[]> hGetAll(byte[] key)
RedisHashCommandskey.
hGetAll in interface RedisHashCommandshttp://redis.io/commands/hgetall
public Long hIncrBy(byte[] key,
byte[] field,
long delta)
RedisHashCommandsvalue of a hash field by the given delta.
hIncrBy in interface RedisHashCommandshttp://redis.io/commands/hincrby
public Double hIncrBy(byte[] key,
byte[] field,
double delta)
RedisHashCommandsvalue of a hash field by the given delta.
hIncrBy in interface RedisHashCommandshttp://redis.io/commands/hincrbyfloatpublic Set<byte[]> hKeys(byte[] key)
RedisHashCommandskey.
hKeys in interface RedisHashCommandshttp://redis.io/commands/h?public Long hLen(byte[] key)
RedisHashCommandskey.
hLen in interface RedisHashCommandshttp://redis.io/commands/hlen
public List<byte[]> hMGet(byte[] key,
byte[]... fields)
RedisHashCommandsfields from hash at key.
hMGet in interface RedisHashCommandshttp://redis.io/commands/hmget
public void hMSet(byte[] key,
Map<byte[],byte[]> tuple)
RedisHashCommandshashes
hMSet in interface RedisHashCommandshttp://redis.io/commands/hmsetpublic List<byte[]> hVals(byte[] key)
RedisHashCommandsfield.
hVals in interface RedisHashCommandshttp://redis.io/commands/hvalspublic void scriptFlush()
RedisScriptingCommands
scriptFlush in interface RedisScriptingCommandshttp://redis.io/commands/script-flushpublic void scriptKill()
RedisScriptingCommands
scriptKill in interface RedisScriptingCommandshttp://redis.io/commands/script-killpublic String scriptLoad(byte[] script)
RedisScriptingCommands#evalSha(String, ReturnType, int, byte[]).
scriptLoad in interface RedisScriptingCommandshttp://redis.io/commands/script-loadpublic List<Boolean> scriptExists(String... scriptSha1)
RedisScriptingCommandsscriptShas exist in script cache.
scriptExists in interface RedisScriptingCommandshttp://redis.io/commands/script-exits
public <T> T eval(byte[] script,
ReturnType returnType,
int numKeys,
byte[]... keysAndArgs)
RedisScriptingCommandsscript.
eval in interface RedisScriptingCommandshttp://redis.io/commands/eval
public <T> T evalSha(String scriptSha1,
ReturnType returnType,
int numKeys,
byte[]... keysAndArgs)
RedisScriptingCommandsscriptSha.
evalSha in interface RedisScriptingCommandshttp://redis.io/commands/evalsha
public Long publish(byte[] channel,
byte[] message)
RedisPubSubCommands
publish in interface RedisPubSubCommandschannel - the channel to publish tomessage - message to publish
public Subscription getSubscription()
RedisPubSubCommands
getSubscription in interface RedisPubSubCommandspublic boolean isSubscribed()
RedisPubSubCommands
isSubscribed in interface RedisPubSubCommands
public void pSubscribe(MessageListener listener,
byte[]... patterns)
RedisPubSubCommands
pSubscribe in interface RedisPubSubCommandslistener - message listenerpatterns - channel name patterns
public void subscribe(MessageListener listener,
byte[]... channels)
RedisPubSubCommands
subscribe in interface RedisPubSubCommandslistener - message listenerchannels - channel namespublic void setConvertPipelineAndTxResults(boolean convertPipelineAndTxResults)
closePipeline() and exec() will be of the type returned by the Lettuce driver
convertPipelineAndTxResults - Whether or not to convert pipeline resultspublic List<Object> closePipeline()
RedisConnection
closePipeline in interface RedisConnectionpublic Long time()
RedisServerCommandsTIME command.
time in interface RedisServerCommands
public void killClient(String host,
int port)
RedisServerCommands
killClient in interface RedisServerCommandshost - of connection to close.port - of connection to closepublic void setClientName(byte[] name)
RedisServerCommands
setClientName in interface RedisServerCommands
public void slaveOf(String host,
int port)
RedisServerCommands
slaveOf in interface RedisServerCommandshttp://redis.io/commands/slaveofpublic String getClientName()
RedisServerCommands
getClientName in interface RedisServerCommandshttp://redis.io/commands/client-getnamepublic List<RedisClientInfo> getClientList()
RedisServerCommands
getClientList in interface RedisServerCommandsList of RedisClientInfo objects.http://redis.io/commands/client-listpublic void slaveOfNoOne()
RedisServerCommands
slaveOfNoOne in interface RedisServerCommandshttp://redis.io/commands/slaveof
|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||