net.spy.memcached
Interface MemcachedClientIF
- All Known Implementing Classes:
- MemcachedClient
public interface MemcachedClientIF
This interface is provided as a helper for testing clients of the MemcachedClient.
Method Summary |
java.util.concurrent.Future<java.lang.Boolean> |
add(java.lang.String key,
int exp,
java.lang.Object o)
|
<T> java.util.concurrent.Future<java.lang.Boolean> |
|
add(java.lang.String key,
int exp,
T o,
Transcoder<T> tc)
|
boolean |
addObserver(ConnectionObserver obs)
|
java.util.concurrent.Future<java.lang.Boolean> |
append(long cas,
java.lang.String key,
java.lang.Object val)
|
<T> java.util.concurrent.Future<java.lang.Boolean> |
|
append(long cas,
java.lang.String key,
T val,
Transcoder<T> tc)
|
java.util.concurrent.Future<CASResponse> |
asyncCAS(java.lang.String key,
long casId,
java.lang.Object value)
|
|
asyncCAS(java.lang.String key,
long casId,
T value,
Transcoder<T> tc)
|
java.util.concurrent.Future<java.lang.Long> |
asyncDecr(java.lang.String key,
int by)
|
java.util.concurrent.Future<java.lang.Object> |
asyncGet(java.lang.String key)
|
<T> java.util.concurrent.Future<T> |
|
asyncGet(java.lang.String key,
Transcoder<T> tc)
|
java.util.concurrent.Future<java.util.Map<java.lang.String,java.lang.Object>> |
asyncGetBulk(java.util.Collection<java.lang.String> keys)
|
<T> java.util.concurrent.Future<java.util.Map<java.lang.String,T>> |
|
asyncGetBulk(java.util.Collection<java.lang.String> keys,
Transcoder<T> tc)
|
java.util.concurrent.Future<java.util.Map<java.lang.String,java.lang.Object>> |
asyncGetBulk(java.lang.String... keys)
|
<T> java.util.concurrent.Future<java.util.Map<java.lang.String,T>> |
|
asyncGetBulk(Transcoder<T> tc,
java.lang.String... keys)
|
java.util.concurrent.Future<CASValue<java.lang.Object>> |
asyncGets(java.lang.String key)
|
<T> java.util.concurrent.Future<CASValue<T>> |
|
asyncGets(java.lang.String key,
Transcoder<T> tc)
|
java.util.concurrent.Future<java.lang.Long> |
asyncIncr(java.lang.String key,
int by)
|
CASResponse |
cas(java.lang.String key,
long casId,
java.lang.Object value)
|
|
cas(java.lang.String key,
long casId,
T value,
Transcoder<T> tc)
|
long |
decr(java.lang.String key,
int by)
|
long |
decr(java.lang.String key,
int by,
long def)
|
long |
decr(java.lang.String key,
int by,
long def,
int exp)
|
java.util.concurrent.Future<java.lang.Boolean> |
delete(java.lang.String key)
|
java.util.concurrent.Future<java.lang.Boolean> |
flush()
|
java.util.concurrent.Future<java.lang.Boolean> |
flush(int delay)
|
java.lang.Object |
get(java.lang.String key)
|
|
get(java.lang.String key,
Transcoder<T> tc)
|
java.util.Collection<java.net.SocketAddress> |
getAvailableServers()
|
java.util.Map<java.lang.String,java.lang.Object> |
getBulk(java.util.Collection<java.lang.String> keys)
|
<T> java.util.Map<java.lang.String,T> |
|
getBulk(java.util.Collection<java.lang.String> keys,
Transcoder<T> tc)
|
java.util.Map<java.lang.String,java.lang.Object> |
getBulk(java.lang.String... keys)
|
<T> java.util.Map<java.lang.String,T> |
|
getBulk(Transcoder<T> tc,
java.lang.String... keys)
|
NodeLocator |
getNodeLocator()
|
CASValue<java.lang.Object> |
gets(java.lang.String key)
|
|
gets(java.lang.String key,
Transcoder<T> tc)
|
java.util.Map<java.net.SocketAddress,java.util.Map<java.lang.String,java.lang.String>> |
getStats()
|
java.util.Map<java.net.SocketAddress,java.util.Map<java.lang.String,java.lang.String>> |
getStats(java.lang.String prefix)
|
Transcoder<java.lang.Object> |
getTranscoder()
|
java.util.Collection<java.net.SocketAddress> |
getUnavailableServers()
|
java.util.Map<java.net.SocketAddress,java.lang.String> |
getVersions()
|
long |
incr(java.lang.String key,
int by)
|
long |
incr(java.lang.String key,
int by,
long def)
|
long |
incr(java.lang.String key,
int by,
long def,
int exp)
|
java.util.Set<java.lang.String> |
listSaslMechanisms()
Get the set of SASL mechanisms supported by the servers. |
java.util.concurrent.Future<java.lang.Boolean> |
prepend(long cas,
java.lang.String key,
java.lang.Object val)
|
<T> java.util.concurrent.Future<java.lang.Boolean> |
|
prepend(long cas,
java.lang.String key,
T val,
Transcoder<T> tc)
|
boolean |
removeObserver(ConnectionObserver obs)
|
java.util.concurrent.Future<java.lang.Boolean> |
replace(java.lang.String key,
int exp,
java.lang.Object o)
|
<T> java.util.concurrent.Future<java.lang.Boolean> |
|
replace(java.lang.String key,
int exp,
T o,
Transcoder<T> tc)
|
java.util.concurrent.Future<java.lang.Boolean> |
set(java.lang.String key,
int exp,
java.lang.Object o)
|
<T> java.util.concurrent.Future<java.lang.Boolean> |
|
set(java.lang.String key,
int exp,
T o,
Transcoder<T> tc)
|
void |
shutdown()
|
boolean |
shutdown(long timeout,
java.util.concurrent.TimeUnit unit)
|
boolean |
waitForQueues(long timeout,
java.util.concurrent.TimeUnit unit)
|
MAX_KEY_LENGTH
static final int MAX_KEY_LENGTH
- Maximum supported key length.
- See Also:
- Constant Field Values
getAvailableServers
java.util.Collection<java.net.SocketAddress> getAvailableServers()
getUnavailableServers
java.util.Collection<java.net.SocketAddress> getUnavailableServers()
getTranscoder
Transcoder<java.lang.Object> getTranscoder()
getNodeLocator
NodeLocator getNodeLocator()
append
java.util.concurrent.Future<java.lang.Boolean> append(long cas,
java.lang.String key,
java.lang.Object val)
append
<T> java.util.concurrent.Future<java.lang.Boolean> append(long cas,
java.lang.String key,
T val,
Transcoder<T> tc)
prepend
java.util.concurrent.Future<java.lang.Boolean> prepend(long cas,
java.lang.String key,
java.lang.Object val)
prepend
<T> java.util.concurrent.Future<java.lang.Boolean> prepend(long cas,
java.lang.String key,
T val,
Transcoder<T> tc)
asyncCAS
<T> java.util.concurrent.Future<CASResponse> asyncCAS(java.lang.String key,
long casId,
T value,
Transcoder<T> tc)
asyncCAS
java.util.concurrent.Future<CASResponse> asyncCAS(java.lang.String key,
long casId,
java.lang.Object value)
cas
<T> CASResponse cas(java.lang.String key,
long casId,
T value,
Transcoder<T> tc)
throws OperationTimeoutException
- Throws:
OperationTimeoutException
cas
CASResponse cas(java.lang.String key,
long casId,
java.lang.Object value)
throws OperationTimeoutException
- Throws:
OperationTimeoutException
add
<T> java.util.concurrent.Future<java.lang.Boolean> add(java.lang.String key,
int exp,
T o,
Transcoder<T> tc)
add
java.util.concurrent.Future<java.lang.Boolean> add(java.lang.String key,
int exp,
java.lang.Object o)
set
<T> java.util.concurrent.Future<java.lang.Boolean> set(java.lang.String key,
int exp,
T o,
Transcoder<T> tc)
set
java.util.concurrent.Future<java.lang.Boolean> set(java.lang.String key,
int exp,
java.lang.Object o)
replace
<T> java.util.concurrent.Future<java.lang.Boolean> replace(java.lang.String key,
int exp,
T o,
Transcoder<T> tc)
replace
java.util.concurrent.Future<java.lang.Boolean> replace(java.lang.String key,
int exp,
java.lang.Object o)
asyncGet
<T> java.util.concurrent.Future<T> asyncGet(java.lang.String key,
Transcoder<T> tc)
asyncGet
java.util.concurrent.Future<java.lang.Object> asyncGet(java.lang.String key)
asyncGets
<T> java.util.concurrent.Future<CASValue<T>> asyncGets(java.lang.String key,
Transcoder<T> tc)
asyncGets
java.util.concurrent.Future<CASValue<java.lang.Object>> asyncGets(java.lang.String key)
gets
<T> CASValue<T> gets(java.lang.String key,
Transcoder<T> tc)
throws OperationTimeoutException
- Throws:
OperationTimeoutException
gets
CASValue<java.lang.Object> gets(java.lang.String key)
throws OperationTimeoutException
- Throws:
OperationTimeoutException
get
<T> T get(java.lang.String key,
Transcoder<T> tc)
throws OperationTimeoutException
- Throws:
OperationTimeoutException
get
java.lang.Object get(java.lang.String key)
throws OperationTimeoutException
- Throws:
OperationTimeoutException
asyncGetBulk
<T> java.util.concurrent.Future<java.util.Map<java.lang.String,T>> asyncGetBulk(java.util.Collection<java.lang.String> keys,
Transcoder<T> tc)
asyncGetBulk
java.util.concurrent.Future<java.util.Map<java.lang.String,java.lang.Object>> asyncGetBulk(java.util.Collection<java.lang.String> keys)
asyncGetBulk
<T> java.util.concurrent.Future<java.util.Map<java.lang.String,T>> asyncGetBulk(Transcoder<T> tc,
java.lang.String... keys)
asyncGetBulk
java.util.concurrent.Future<java.util.Map<java.lang.String,java.lang.Object>> asyncGetBulk(java.lang.String... keys)
getBulk
<T> java.util.Map<java.lang.String,T> getBulk(java.util.Collection<java.lang.String> keys,
Transcoder<T> tc)
throws OperationTimeoutException
- Throws:
OperationTimeoutException
getBulk
java.util.Map<java.lang.String,java.lang.Object> getBulk(java.util.Collection<java.lang.String> keys)
throws OperationTimeoutException
- Throws:
OperationTimeoutException
getBulk
<T> java.util.Map<java.lang.String,T> getBulk(Transcoder<T> tc,
java.lang.String... keys)
throws OperationTimeoutException
- Throws:
OperationTimeoutException
getBulk
java.util.Map<java.lang.String,java.lang.Object> getBulk(java.lang.String... keys)
throws OperationTimeoutException
- Throws:
OperationTimeoutException
getVersions
java.util.Map<java.net.SocketAddress,java.lang.String> getVersions()
getStats
java.util.Map<java.net.SocketAddress,java.util.Map<java.lang.String,java.lang.String>> getStats()
getStats
java.util.Map<java.net.SocketAddress,java.util.Map<java.lang.String,java.lang.String>> getStats(java.lang.String prefix)
incr
long incr(java.lang.String key,
int by)
throws OperationTimeoutException
- Throws:
OperationTimeoutException
decr
long decr(java.lang.String key,
int by)
throws OperationTimeoutException
- Throws:
OperationTimeoutException
incr
long incr(java.lang.String key,
int by,
long def,
int exp)
throws OperationTimeoutException
- Throws:
OperationTimeoutException
decr
long decr(java.lang.String key,
int by,
long def,
int exp)
throws OperationTimeoutException
- Throws:
OperationTimeoutException
asyncIncr
java.util.concurrent.Future<java.lang.Long> asyncIncr(java.lang.String key,
int by)
asyncDecr
java.util.concurrent.Future<java.lang.Long> asyncDecr(java.lang.String key,
int by)
incr
long incr(java.lang.String key,
int by,
long def)
throws OperationTimeoutException
- Throws:
OperationTimeoutException
decr
long decr(java.lang.String key,
int by,
long def)
throws OperationTimeoutException
- Throws:
OperationTimeoutException
delete
java.util.concurrent.Future<java.lang.Boolean> delete(java.lang.String key)
flush
java.util.concurrent.Future<java.lang.Boolean> flush(int delay)
flush
java.util.concurrent.Future<java.lang.Boolean> flush()
shutdown
void shutdown()
shutdown
boolean shutdown(long timeout,
java.util.concurrent.TimeUnit unit)
waitForQueues
boolean waitForQueues(long timeout,
java.util.concurrent.TimeUnit unit)
addObserver
boolean addObserver(ConnectionObserver obs)
removeObserver
boolean removeObserver(ConnectionObserver obs)
listSaslMechanisms
java.util.Set<java.lang.String> listSaslMechanisms()
- Get the set of SASL mechanisms supported by the servers.
- Returns:
- the union of all SASL mechanisms supported by the servers.