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()
      • 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)
      • 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)
      • 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

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