Package 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.
-
-
Field Summary
Fields Modifier and Type Field Description static int
MAX_KEY_LENGTH
Maximum supported key length.
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description 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<java.lang.Boolean>
append(java.lang.String key, java.lang.Object val)
<T> java.util.concurrent.Future<java.lang.Boolean>
append(java.lang.String key, T val, Transcoder<T> tc)
java.util.concurrent.Future<CASResponse>
asyncCAS(java.lang.String key, long casId, int exp, java.lang.Object value)
<T> OperationFuture<CASResponse>
asyncCAS(java.lang.String key, long casId, int exp, T value, Transcoder<T> tc)
java.util.concurrent.Future<CASResponse>
asyncCAS(java.lang.String key, long casId, java.lang.Object value)
<T> java.util.concurrent.Future<CASResponse>
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.Long>
asyncDecr(java.lang.String key, int by, long def)
java.util.concurrent.Future<java.lang.Long>
asyncDecr(java.lang.String key, int by, long def, int exp)
java.util.concurrent.Future<java.lang.Long>
asyncDecr(java.lang.String key, long by)
java.util.concurrent.Future<java.lang.Long>
asyncDecr(java.lang.String key, long by, long def)
java.util.concurrent.Future<java.lang.Long>
asyncDecr(java.lang.String key, long by, long def, int exp)
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<CASValue<java.lang.Object>>
asyncGetAndTouch(java.lang.String key, int exp)
<T> java.util.concurrent.Future<CASValue<T>>
asyncGetAndTouch(java.lang.String key, int exp, Transcoder<T> tc)
BulkFuture<java.util.Map<java.lang.String,java.lang.Object>>
asyncGetBulk(java.lang.String... keys)
BulkFuture<java.util.Map<java.lang.String,java.lang.Object>>
asyncGetBulk(java.util.Collection<java.lang.String> keys)
<T> BulkFuture<java.util.Map<java.lang.String,T>>
asyncGetBulk(java.util.Collection<java.lang.String> keys, java.util.Iterator<Transcoder<T>> tcs)
<T> BulkFuture<java.util.Map<java.lang.String,T>>
asyncGetBulk(java.util.Collection<java.lang.String> keys, Transcoder<T> tc)
BulkFuture<java.util.Map<java.lang.String,java.lang.Object>>
asyncGetBulk(java.util.Iterator<java.lang.String> keys)
<T> BulkFuture<java.util.Map<java.lang.String,T>>
asyncGetBulk(java.util.Iterator<java.lang.String> keys, java.util.Iterator<Transcoder<T>> tcs)
<T> BulkFuture<java.util.Map<java.lang.String,T>>
asyncGetBulk(java.util.Iterator<java.lang.String> keys, Transcoder<T> tc)
<T> BulkFuture<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)
java.util.concurrent.Future<java.lang.Long>
asyncIncr(java.lang.String key, int by, long def)
java.util.concurrent.Future<java.lang.Long>
asyncIncr(java.lang.String key, int by, long def, int exp)
java.util.concurrent.Future<java.lang.Long>
asyncIncr(java.lang.String key, long by)
java.util.concurrent.Future<java.lang.Long>
asyncIncr(java.lang.String key, long by, long def)
java.util.concurrent.Future<java.lang.Long>
asyncIncr(java.lang.String key, long by, long def, int exp)
java.util.concurrent.CountDownLatch
broadcastOp(BroadcastOpFactory of)
java.util.concurrent.CountDownLatch
broadcastOp(BroadcastOpFactory of, java.util.Collection<MemcachedNode> nodes)
CASResponse
cas(java.lang.String key, long casId, int exp, java.lang.Object value)
<T> CASResponse
cas(java.lang.String key, long casId, int exp, T value, Transcoder<T> tc)
CASResponse
cas(java.lang.String key, long casId, java.lang.Object value)
<T> CASResponse
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)
long
decr(java.lang.String key, long by)
long
decr(java.lang.String key, long by, long def)
long
decr(java.lang.String key, long by, long def, int exp)
java.util.concurrent.Future<java.lang.Boolean>
delete(java.lang.String key)
java.util.concurrent.Future<java.lang.Boolean>
delete(java.lang.String key, long cas)
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)
<T> T
get(java.lang.String key, Transcoder<T> tc)
CASValue<java.lang.Object>
getAndTouch(java.lang.String key, int exp)
<T> CASValue<T>
getAndTouch(java.lang.String key, int exp, Transcoder<T> tc)
java.util.Collection<java.net.SocketAddress>
getAvailableServers()
java.util.Map<java.lang.String,java.lang.Object>
getBulk(java.lang.String... keys)
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.util.Iterator<java.lang.String> keys)
<T> java.util.Map<java.lang.String,T>
getBulk(java.util.Iterator<java.lang.String> keys, Transcoder<T> tc)
<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)
<T> CASValue<T>
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)
long
incr(java.lang.String key, long by)
long
incr(java.lang.String key, long by, long def)
long
incr(java.lang.String key, long 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)
java.util.concurrent.Future<java.lang.Boolean>
prepend(java.lang.String key, java.lang.Object val)
<T> java.util.concurrent.Future<java.lang.Boolean>
prepend(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)
<T> java.util.concurrent.Future<java.lang.Boolean>
touch(java.lang.String key, int exp)
<T> java.util.concurrent.Future<java.lang.Boolean>
touch(java.lang.String key, int exp, Transcoder<T> tc)
boolean
waitForQueues(long timeout, java.util.concurrent.TimeUnit unit)
-
-
-
Field Detail
-
MAX_KEY_LENGTH
static final int MAX_KEY_LENGTH
Maximum supported key length.- See Also:
- Constant Field Values
-
-
Method Detail
-
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
java.util.concurrent.Future<java.lang.Boolean> append(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)
-
append
<T> java.util.concurrent.Future<java.lang.Boolean> append(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
java.util.concurrent.Future<java.lang.Boolean> prepend(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)
-
prepend
<T> java.util.concurrent.Future<java.lang.Boolean> prepend(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)
-
asyncCAS
java.util.concurrent.Future<CASResponse> asyncCAS(java.lang.String key, long casId, int exp, java.lang.Object value)
-
asyncCAS
<T> OperationFuture<CASResponse> asyncCAS(java.lang.String key, long casId, int exp, T value, Transcoder<T> tc)
-
cas
<T> CASResponse cas(java.lang.String key, long casId, int exp, T value, Transcoder<T> tc)
-
cas
CASResponse cas(java.lang.String key, long casId, java.lang.Object value)
-
cas
CASResponse cas(java.lang.String key, long casId, int exp, java.lang.Object value)
-
cas
<T> CASResponse cas(java.lang.String key, long casId, T value, Transcoder<T> tc)
-
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)
-
asyncGetAndTouch
java.util.concurrent.Future<CASValue<java.lang.Object>> asyncGetAndTouch(java.lang.String key, int exp)
-
asyncGetAndTouch
<T> java.util.concurrent.Future<CASValue<T>> asyncGetAndTouch(java.lang.String key, int exp, Transcoder<T> tc)
-
getAndTouch
CASValue<java.lang.Object> getAndTouch(java.lang.String key, int exp)
-
getAndTouch
<T> CASValue<T> getAndTouch(java.lang.String key, int exp, Transcoder<T> tc)
-
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)
-
gets
CASValue<java.lang.Object> gets(java.lang.String key)
-
get
<T> T get(java.lang.String key, Transcoder<T> tc)
-
get
java.lang.Object get(java.lang.String key)
-
asyncGetBulk
<T> BulkFuture<java.util.Map<java.lang.String,T>> asyncGetBulk(java.util.Iterator<java.lang.String> keys, java.util.Iterator<Transcoder<T>> tcs)
-
asyncGetBulk
<T> BulkFuture<java.util.Map<java.lang.String,T>> asyncGetBulk(java.util.Collection<java.lang.String> keys, java.util.Iterator<Transcoder<T>> tcs)
-
asyncGetBulk
<T> BulkFuture<java.util.Map<java.lang.String,T>> asyncGetBulk(java.util.Iterator<java.lang.String> keys, Transcoder<T> tc)
-
asyncGetBulk
<T> BulkFuture<java.util.Map<java.lang.String,T>> asyncGetBulk(java.util.Collection<java.lang.String> keys, Transcoder<T> tc)
-
asyncGetBulk
BulkFuture<java.util.Map<java.lang.String,java.lang.Object>> asyncGetBulk(java.util.Iterator<java.lang.String> keys)
-
asyncGetBulk
BulkFuture<java.util.Map<java.lang.String,java.lang.Object>> asyncGetBulk(java.util.Collection<java.lang.String> keys)
-
asyncGetBulk
<T> BulkFuture<java.util.Map<java.lang.String,T>> asyncGetBulk(Transcoder<T> tc, java.lang.String... keys)
-
asyncGetBulk
BulkFuture<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.Iterator<java.lang.String> keys, Transcoder<T> tc)
-
getBulk
<T> java.util.Map<java.lang.String,T> getBulk(java.util.Collection<java.lang.String> keys, Transcoder<T> tc)
-
getBulk
java.util.Map<java.lang.String,java.lang.Object> getBulk(java.util.Iterator<java.lang.String> keys)
-
getBulk
java.util.Map<java.lang.String,java.lang.Object> getBulk(java.util.Collection<java.lang.String> keys)
-
getBulk
<T> java.util.Map<java.lang.String,T> getBulk(Transcoder<T> tc, java.lang.String... keys)
-
getBulk
java.util.Map<java.lang.String,java.lang.Object> getBulk(java.lang.String... keys)
-
touch
<T> java.util.concurrent.Future<java.lang.Boolean> touch(java.lang.String key, int exp, Transcoder<T> tc)
-
touch
<T> java.util.concurrent.Future<java.lang.Boolean> touch(java.lang.String key, int exp)
-
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, long by)
-
incr
long incr(java.lang.String key, int by)
-
decr
long decr(java.lang.String key, long by)
-
decr
long decr(java.lang.String key, int by)
-
asyncIncr
java.util.concurrent.Future<java.lang.Long> asyncIncr(java.lang.String key, long by)
-
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, long by)
-
asyncDecr
java.util.concurrent.Future<java.lang.Long> asyncDecr(java.lang.String key, int by)
-
incr
long incr(java.lang.String key, long by, long def, int exp)
-
incr
long incr(java.lang.String key, int by, long def, int exp)
-
decr
long decr(java.lang.String key, long by, long def, int exp)
-
decr
long decr(java.lang.String key, int by, long def, int exp)
-
asyncIncr
java.util.concurrent.Future<java.lang.Long> asyncIncr(java.lang.String key, long by, long def, int exp)
-
asyncIncr
java.util.concurrent.Future<java.lang.Long> asyncIncr(java.lang.String key, int by, long def, int exp)
-
asyncDecr
java.util.concurrent.Future<java.lang.Long> asyncDecr(java.lang.String key, long by, long def, int exp)
-
asyncDecr
java.util.concurrent.Future<java.lang.Long> asyncDecr(java.lang.String key, int by, long def, int exp)
-
incr
long incr(java.lang.String key, long by, long def)
-
incr
long incr(java.lang.String key, int by, long def)
-
decr
long decr(java.lang.String key, long by, long def)
-
decr
long decr(java.lang.String key, int by, long def)
-
asyncIncr
java.util.concurrent.Future<java.lang.Long> asyncIncr(java.lang.String key, long by, long def)
-
asyncIncr
java.util.concurrent.Future<java.lang.Long> asyncIncr(java.lang.String key, int by, long def)
-
asyncDecr
java.util.concurrent.Future<java.lang.Long> asyncDecr(java.lang.String key, long by, long def)
-
asyncDecr
java.util.concurrent.Future<java.lang.Long> asyncDecr(java.lang.String key, int by, long def)
-
delete
java.util.concurrent.Future<java.lang.Boolean> delete(java.lang.String key)
-
delete
java.util.concurrent.Future<java.lang.Boolean> delete(java.lang.String key, long cas)
-
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)
-
broadcastOp
java.util.concurrent.CountDownLatch broadcastOp(BroadcastOpFactory of)
-
broadcastOp
java.util.concurrent.CountDownLatch broadcastOp(BroadcastOpFactory of, java.util.Collection<MemcachedNode> nodes)
-
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.
-
-