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 and Description
static int	MAX_KEY_LENGTH Maximum supported key length.

Method Summary

Methods

Modifier and Type	Method and 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.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)
BulkFuture<java.util.Map<java.lang.String,java.lang.Object>>	asyncGetBulk(java.lang.String... keys)
<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.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)
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)
<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.