All Classes and Interfaces
Class
Description
The
AbstractListenableFuture implements common functionality shared
by all futures that implement the ListenableFuture.Abstract implementation of Logger providing most of the common framework.
This abstract class implements methods needed by all
MetricCollectors.Convenience utilities for simplifying common address parsing.
NodeLocator implementation for dealing with simple array lookups using a
modulus of the hash code and node list length.
OperationQueueFactory that uses an ArrayBlockingQueue.
Memcached node for the ASCII protocol.
Operation factory for the ascii protocol.
Information required to specify authentication mechanisms and callbacks.
A thread that does SASL authentication.
This will ensure no more than one AuthThread will exist for a given
MemcachedNode.
Base class for a Map interface to memcached.
Base class for get and gets handlers.
The BaseMessage implements the header of a tap message.
Base class for operation factories.
Base class for protocol-specific operation implementations.
Base class for any transcoders that may want to work with serialized or
compressed data.
Base class for ascii store operations (add, set, replace, append, prepend).
Simple thread factory that can set daemon status on threads and give them
names.
Default connection factory for binary wire protocol connections.
Implementation of MemcachedNode for speakers of the binary protocol.
Factory for binary operations.
Factory for creating Operations to be broadcast.
Additional flexibility for asyncGetBulk
A listener that will be notified once the bulk get future completes.
Future for handling results from bulk gets.
Cached data with its attributes.
CacheLoader provides efficient mechanisms for storing lots of data.
If you are interested in the results of your data load, this interface will
receive them.
A Map interface to memcached.
Operation status indicating an operation was cancelled.
Defines a mutation mechanism for a high-level CAS client interface.
Object that provides mutation via CAS over a given memcache client.
Operation that represents compare-and-swap.
OperationStatus subclass for indicating CAS status.
Response codes for a CAS operation.
A value with a CAS identifier.
Timeout exception that tracks the original operation.
CloseUtil exists to provide a safe means to close anything closeable.
ConcatenationOperation is used to append or prepend data to an existing
object in the cache.
Operation for ascii concatenations.
Types of concatenation operations.
Factory for creating instances of MemcachedConnection.
Builder for more easily configuring a ConnectionFactory.
Type of node locator to use.
Type of protocol to use for connections.
Users of this interface will be notified when changes to the state of
connections take place.
Default implementation of ConnectionFactory.
Known hashing algorithms for locating a server for a key.
A Default implementation of the configuration required for the
KetamaNodeLocator algorithm to run.
Default logger implementation.
A
MetricCollector that uses the Codahale Metrics library.Deletion operation.
Delete operation callback.
Operation to delete an item from the cache.
Failure modes for node failures.
Flush operation marker.
Memcached flush_all operation.
A generic listener that will be notified once the future completes.
Gat operation.
Operation callback for the gat request.
Implementation of the get and touch operation.
Implementation of the get and touch operation.
Wrapper callback for use in optimized gets.
A listener that will be notified once the get future completes.
Future returned for GET operations.
Getl operation.
Operation callback for the getl request.
Implementation of the getl operation.
Implementation of the get and lock operation.
Get operation.
Operation callback for the get request.
Operation for retrieving data.
Implementation of the get operation.
Gets operation (get with CAS identifier support).
Operation callback for the Gets request.
Implementation of the gets operation.
Implementation of the gets operation.
Intents to provide hash for locating a server for a key.
Registry of known hashing algorithms for locating a server for a key.
A future that fires immediately.
Transcoder that serializes and unserializes longs.
ConnectionFactory instance that sets up a ketama compatible connection.
Implements an Iterator which the KetamaNodeLoctaor may return to a client for
iterating through alternate nodes for a given key.
Known key formats used in Ketama for assigning nodes around the ring
This is an implementation of the Ketama consistent hash strategy from
last.fm.
Defines the set of all configuration dependencies required for the
KetamaNodeLocator algorithm to run.
Operations that contain keys.
A StatsOperationImpl.
Utilities for processing key values.
Levels for logging.
OperationQueueFactory that creates LinkedBlockingQueue (unbounded) operation
queues.
A
Future that accepts one or more listeners that will be executed
asynchronously.Logging implementation using log4j.
Abstract mechanism for dealing with logs from various objects.
Factory to get logger instances.
Transcoder that serializes and unserializes longs.
Client to a memcached server.
This interface is provided as a helper for testing clients of the
MemcachedClient.
Main class for handling connections to a memcached cluster.
Interface defining a connection to a memcached server.
Builds a tap message.
Defines a common API for all
MetricCollectors.Defines the type of metric collection to use.
MultiOperationCallback for get operations.
MultiOperationCallback for get operations.
Binary operations that contain multiple keys and are VBucket aware operations
should extend this class.
An operation callback that will capture receivedStatus and complete
invocations and dispatch to a single callback.
MultiOperationCallback for replica get operations.
Type of mutation to perform.
incr and decr operations.
Operation for mutating integers inside of memcached.
Interface for locating a node by hash value.
A
MetricCollector that does nothing.The NOOP Operation.
Implementation of a noop operation.
Observe operation.
Operation callback for the Observe request.
Response codes for a Observe operation.
Base interface for all operations.
Callback that's invoked with the response of an operation.
A listener that will be notified once the operation future completes.
Error classification.
Exceptions thrown when protocol errors occur.
Factory that builds operations for protocol handlers.
Managed future for operations.
Operations on a memcached connection.
Base class for binary operations.
Factory used for creating operation queues.
Data read types.
State of this operation.
Status indicator.
Thrown by
MemcachedClient when any internal operations timeout.Optimized Get operation for folding a bunch of gets together.
Optimized Get operation for folding a bunch of gets together.
Optimized Set operation for folding a bunch of sets together.
PersistTo codes for a Observe operation.
Callback handler for doing plain auth.
Proxy callback used for dispatching callbacks over optimized gets.
Replica get operation.
Operation callback for the replica get request.
Implementation of the replica get operation.
Replica get operation.
Operation callback for the replica get request.
Implementation of the replica gets operation.
ReplicateTo codes for a Observe operation.
A tap request message that is used to start tap streams, perform sasl
authentication, and maintain the health of tap streams.
A representation of a tap stream message sent from a tap stream server.
Operation for beginning a SASL auth cycle.
SASL authenticator.
SASL authenticator.
Operation for listing supported SASL mechanisms.
Operation for proceeding in a SASL auth negotiation.
A SASLStepOperationImpl.
Transcoder that serializes and compresses objects.
An iterator that returns a single element for as many elements as are needed
from the iterator; in other words, #hasNext() never returns false.
Binary operations that contain a single key and are VBucket aware operations
should extend this class.
Logging Implementation using the SLF4J
logging facade.
Superclass for all Spy Objects.
Superclass for all Spy Threads.
Stats fetching operation.
Callback for stats operation.
Operation to retrieve statistics from a memcached server.
A StatsOperationImpl.
Represents status and error codes from the binary protocol.
Operation that represents object storage.
Operation callback to get the CAS value.
Operation to store data in a memcached server.
The type of storage operation to perform.
Utility methods on string objects.
Logging implementation using the sun logger.
Thread that invokes a callable multiple times concurrently.
An acknowledgment message used to tell the server we have received a
series of messages.
Implementation of a tap ACK operation.
Implementation of a tap backfill operation.
A tap client for memcached.
A TapConnectionProvider.
Implementation of a custom tap operation.
Implementation of a tap dump operation.
The Magic enum contains a list all of the different magic that can be passed
in a tap message in the flag field.
The Opcode enum contains a list all of the different opcodes that can be
passed in a tap message in the flag field.
Tap operation.
Operation callback for the tap dump request.
Abstract implementation of a tap operation.
The Flag enum contains a list all of the different flags that can be passed
in a tap message in the flag field.
The Flag enum contains a list all of the different flags that can be passed
in a tap message in the flag field.
Holds multiple operations put together for a tap stream.
Represents a node with the memcached cluster, along with buffering and
operation queues.
Operation status indicating an operation was timed out.
Touch operation marker.
Memcached touch operation.
Operation to reset a timeout in Membase server.
Transcoder is an interface for classes that convert between byte arrays and
objects for storage in the cache.
Utility class for transcoding Java types.
Asynchronous transcoder.
Unlock operation.
Operation to delete an item from the cache.
The Util class provides utility functions for converting portions of byte
arrays to values and putting values into byte arrays.
Operations that depend on a VBucket number being sent to the server are
required to implement this interface.
Version operation.
Operation to request the version of a memcached server.
Transcoder that provides compatibility with Greg Whalin's memcached client.
Handles old whalin (tested with v1.6) encoding: data type is in the first
byte of the value.