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

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

<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.