Uses of Interface
net.spy.memcached.ops.Operation

Packages that use Operation

Package	Description
net.spy.memcached	Memcached client and transformation utils
net.spy.memcached.auth	Auth Utilities.
net.spy.memcached.internal	Internal utilities.
net.spy.memcached.ops	Fundamental protocol operation interfaces
net.spy.memcached.protocol	Base classes for protocol abstractions.
net.spy.memcached.protocol.ascii	Low-level operations for the memcached ascii protocol
net.spy.memcached.protocol.binary	Low-level operations for the memcached binary protocol

Uses of Operation in net.spy.memcached

Fields in net.spy.memcached with type parameters of type Operation

Modifier and Type	Field	Description
private final List<Operation>	MemcachedConnection.retryOps	Holds operations that need to be retried.

Methods in net.spy.memcached that return Operation

Modifier and Type	Method	Description
Operation	MemcachedNode.getCurrentReadOp()	Get the operation at the top of the queue that is requiring input.
Operation	MemcachedNodeROImpl.getCurrentReadOp()
Operation	MemcachedNode.getCurrentWriteOp()	Get the operation at the top of the queue that has information available to write.
Operation	MemcachedNodeROImpl.getCurrentWriteOp()
private Operation	MemcachedConnection.handleReadsWhenChannelEndOfStream(Operation currentOp, MemcachedNode node, ByteBuffer rbuf)	Deal with an operation where the channel reached the end of a stream.
Operation	BroadcastOpFactory.newOp(MemcachedNode n, CountDownLatch latch)	Construct a new operation for delivery to the given node.
Operation	MemcachedNode.removeCurrentReadOp()	Remove the operation at the top of the queue that is requiring input.
Operation	MemcachedNodeROImpl.removeCurrentReadOp()
Operation	MemcachedNode.removeCurrentWriteOp()	Remove the operation at the top of the queue that has information available to write.
Operation	MemcachedNodeROImpl.removeCurrentWriteOp()

Methods in net.spy.memcached that return types with arguments of type Operation

Modifier and Type	Method	Description
Collection<Operation>	OperationFactory.clone(KeyedOperation op)	Clone an operation.
BlockingQueue<Operation>	ConnectionFactory.createOperationQueue()	Create a BlockingQueue for operations for a connection.
BlockingQueue<Operation>	DefaultConnectionFactory.createOperationQueue()
BlockingQueue<Operation>	ConnectionFactory.createReadOperationQueue()	Create a BlockingQueue for the operations currently expecting to read responses from memcached.
BlockingQueue<Operation>	DefaultConnectionFactory.createReadOperationQueue()
BlockingQueue<Operation>	ConnectionFactory.createWriteOperationQueue()	Create a BlockingQueue for the operations currently expecting to write requests to memcached.
BlockingQueue<Operation>	DefaultConnectionFactory.createWriteOperationQueue()
Collection<Operation>	MemcachedNode.destroyInputQueue()	Extract all queued items for this node destructively.
Collection<Operation>	MemcachedNodeROImpl.destroyInputQueue()

Methods in net.spy.memcached with parameters of type Operation

Modifier and Type	Method	Description
void	MemcachedNode.addOp(Operation op)	Add an operation to the queue.
void	MemcachedNodeROImpl.addOp(Operation op)
protected void	MemcachedConnection.addOperation(String key, Operation o)	Add an operation to a connection identified by the given key.
protected void	MemcachedConnection.addOperation(MemcachedNode node, Operation o)	Enqueue an operation on the given node.
void	TapConnectionProvider.addTapAckOp(MemcachedNode node, Operation op)
void	MemcachedConnection.enqueueOperation(String key, Operation o)	Enqueue the given Operation with the used key.
private Operation	MemcachedConnection.handleReadsWhenChannelEndOfStream(Operation currentOp, MemcachedNode node, ByteBuffer rbuf)	Deal with an operation where the channel reached the end of a stream.
void	MemcachedNode.insertOp(Operation o)	Insert an operation to the beginning of the queue.
void	MemcachedNodeROImpl.insertOp(Operation op)
void	MemcachedConnection.insertOperation(MemcachedNode node, Operation o)	Insert an operation on the given node to the beginning of the queue.
static void	MemcachedConnection.opSucceeded(Operation op)	Reset the timeout counter for the given handling node.
static void	MemcachedConnection.opTimedOut(Operation op)	Increase the timeout counter for the given handling node.
private void	MemcachedConnection.readBufferAndLogMetrics(Operation currentOp, ByteBuffer rbuf, MemcachedNode node)	Read from the buffer and add metrics information.
void	MemcachedConnection.redistributeOperation(Operation op)	Redistribute the given operation to (potentially) other nodes.
void	MemcachedConnection.retryOperation(Operation op)	Add a operation to the retry queue.
private static void	MemcachedConnection.setTimeout(Operation op, boolean isTimeout)	Set the continuous timeout on an operation.

Method parameters in net.spy.memcached with type arguments of type Operation

Modifier and Type	Method	Description
void	MemcachedConnection.addOperations(Map<MemcachedNode, Operation> ops)	Enqueue the given list of operations on each handling node.
private void	MemcachedConnection.cancelOperations(Collection<Operation> ops)	Cancel the given collection of operations.
void	MemcachedConnection.redistributeOperations(Collection<Operation> ops)	Redistribute the given list of operations to (potentially) other nodes.

Uses of Operation in net.spy.memcached.auth

Methods in net.spy.memcached.auth that return Operation

Modifier and Type	Method	Description
private Operation	AuthThread.buildOperation(OperationStatus st, OperationCallback cb, String[] supportedMechs)

Uses of Operation in net.spy.memcached.internal

Fields in net.spy.memcached.internal declared as Operation

Modifier and Type	Field	Description
private Operation	OperationFuture.op

Fields in net.spy.memcached.internal with type parameters of type Operation

Modifier and Type	Field	Description
private final Collection<Operation>	CheckedOperationTimeoutException.operations
private final Collection<Operation>	BulkGetFuture.ops

Methods in net.spy.memcached.internal that return types with arguments of type Operation

Modifier and Type	Method	Description
Collection<Operation>	CheckedOperationTimeoutException.getOperations()	Get the operation that timed out.

Methods in net.spy.memcached.internal with parameters of type Operation

Modifier and Type	Method	Description
void	GetFuture.setOperation(Operation to)
void	OperationFuture.setOperation(Operation to)	Set the Operation associated with this OperationFuture.

Method parameters in net.spy.memcached.internal with type arguments of type Operation

Modifier and Type	Method	Description
private static String	CheckedOperationTimeoutException.createMessage(String message, Collection<Operation> ops)
private Map<String,T>	BulkGetFuture.internalGet(long to, TimeUnit unit, Collection<Operation> timedoutOps)	refactored code common to both get(long, TimeUnit) and getSome(long, TimeUnit).

Constructors in net.spy.memcached.internal with parameters of type Operation

Modifier	Constructor	Description
	CheckedOperationTimeoutException(String message, Operation op)	Construct a CheckedOperationTimeoutException with the given message and operation.

Constructor parameters in net.spy.memcached.internal with type arguments of type Operation

Modifier	Constructor	Description
	BulkGetFuture(Map<String, Future<T>> m, Collection<Operation> getOps, CountDownLatch l, ExecutorService service)
	CheckedOperationTimeoutException(String message, Collection<Operation> ops)

Uses of Operation in net.spy.memcached.ops

Subinterfaces of Operation in net.spy.memcached.ops

Modifier and Type	Interface	Description
interface	CASOperation	Operation that represents compare-and-swap.
interface	ConcatenationOperation	ConcatenationOperation is used to append or prepend data to an existing object in the cache.
interface	DeleteOperation	Deletion operation.
interface	FlushOperation	Flush operation marker.
interface	GetAndTouchOperation	Gat operation.
interface	GetlOperation	Getl operation.
interface	GetOperation	Get operation.
interface	GetsOperation	Gets operation (get with CAS identifier support).
interface	KeyedOperation	Operations that contain keys.
interface	MutatorOperation	incr and decr operations.
interface	NoopOperation	The NOOP Operation.
interface	ObserveOperation	Observe operation.
interface	ReplicaGetOperation	Replica get operation.
interface	ReplicaGetsOperation	Replica get operation.
interface	SASLAuthOperation	Operation for beginning a SASL auth cycle.
interface	SASLMechsOperation	Operation for listing supported SASL mechanisms.
interface	SASLStepOperation	Operation for proceeding in a SASL auth negotiation.
interface	StatsOperation	Stats fetching operation.
interface	StoreOperation	Operation that represents object storage.
interface	TapOperation	Tap operation.
interface	TouchOperation	Touch operation marker.
interface	UnlockOperation	Unlock operation.
interface	VersionOperation	Version operation.

Methods in net.spy.memcached.ops that return types with arguments of type Operation

Modifier and Type	Method	Description
Collection<Operation>	BaseOperationFactory.clone(KeyedOperation op)
protected abstract Collection<? extends Operation>	BaseOperationFactory.cloneGet(KeyedOperation op)
BlockingQueue<Operation>	ArrayOperationQueueFactory.create()
BlockingQueue<Operation>	LinkedOperationQueueFactory.create()
BlockingQueue<Operation>	OperationQueueFactory.create()	Create an instance of a queue.

Methods in net.spy.memcached.ops with parameters of type Operation

Modifier and Type	Method	Description
void	Operation.addClone(Operation op)	Add the clone from this operation.

Uses of Operation in net.spy.memcached.protocol

Classes in net.spy.memcached.protocol that implement Operation

Modifier and Type	Class	Description
class	BaseOperationImpl	Base class for protocol-specific operation implementations.

Fields in net.spy.memcached.protocol declared as Operation

Modifier and Type	Field	Description
protected Operation	TCPMemcachedNodeImpl.optimizedOp

Fields in net.spy.memcached.protocol with type parameters of type Operation

Modifier and Type	Field	Description
private List<Operation>	BaseOperationImpl.clones	If the operation gets cloned, the reference is used to cascade cancellations and timeouts.
private final BlockingQueue<Operation>	TCPMemcachedNodeImpl.inputQueue
private final BlockingQueue<Operation>	TCPMemcachedNodeImpl.readQ
private ArrayList<Operation>	TCPMemcachedNodeImpl.reconnectBlocked
protected final BlockingQueue<Operation>	TCPMemcachedNodeImpl.writeQ

Methods in net.spy.memcached.protocol that return Operation

Modifier and Type	Method	Description
final Operation	TCPMemcachedNodeImpl.getCurrentReadOp()
final Operation	TCPMemcachedNodeImpl.getCurrentWriteOp()
private Operation	TCPMemcachedNodeImpl.getNextWritableOp()
final Operation	TCPMemcachedNodeImpl.removeCurrentReadOp()
final Operation	TCPMemcachedNodeImpl.removeCurrentWriteOp()

Methods in net.spy.memcached.protocol that return types with arguments of type Operation

Modifier and Type	Method	Description
Collection<Operation>	TCPMemcachedNodeImpl.destroyInputQueue()

Methods in net.spy.memcached.protocol with parameters of type Operation

Modifier and Type	Method	Description
void	BaseOperationImpl.addClone(Operation op)
final void	TCPMemcachedNodeImpl.addOp(Operation op)
final void	TCPMemcachedNodeImpl.insertOp(Operation op)

Constructor parameters in net.spy.memcached.protocol with type arguments of type Operation

Modifier	Constructor	Description
	TCPMemcachedNodeImpl(SocketAddress sa, SocketChannel c, int bufSize, BlockingQueue<Operation> rq, BlockingQueue<Operation> wq, BlockingQueue<Operation> iq, long opQueueMaxBlockTime, boolean waitForAuth, long dt, long authWaitTime, ConnectionFactory fact)

Uses of Operation in net.spy.memcached.protocol.ascii

Classes in net.spy.memcached.protocol.ascii that implement Operation

Modifier and Type	Class	Description
class	BaseGetOpImpl	Base class for get and gets handlers.
(package private) class	BaseStoreOperationImpl	Base class for ascii store operations (add, set, replace, append, prepend).
(package private) class	CASOperationImpl
class	ConcatenationOperationImpl	Operation for ascii concatenations.
(package private) final class	DeleteOperationImpl	Operation to delete an item from the cache.
(package private) final class	FlushOperationImpl	Memcached flush_all operation.
class	GetAndTouchOperationImpl	Implementation of the get and touch operation.
(package private) class	GetlOperationImpl	Implementation of the getl operation.
(package private) class	GetOperationImpl	Operation for retrieving data.
(package private) class	GetsOperationImpl	Implementation of the gets operation.
(package private) final class	MutatorOperationImpl	Operation for mutating integers inside of memcached.
(package private) class	OperationImpl	Operations on a memcached connection.
(package private) final class	OptimizedGetImpl	Optimized Get operation for folding a bunch of gets together.
(package private) final class	StatsOperationImpl	Operation to retrieve statistics from a memcached server.
(package private) final class	StoreOperationImpl	Operation to store data in a memcached server.
(package private) final class	TouchOperationImpl	Memcached touch operation.
(package private) final class	UnlockOperationImpl	Operation to delete an item from the cache.
(package private) final class	VersionOperationImpl	Operation to request the version of a memcached server.

Methods in net.spy.memcached.protocol.ascii that return types with arguments of type Operation

Modifier and Type	Method	Description
protected Collection<? extends Operation>	AsciiOperationFactory.cloneGet(KeyedOperation op)

Constructor parameters in net.spy.memcached.protocol.ascii with type arguments of type Operation

Modifier	Constructor	Description
	AsciiMemcachedNodeImpl(SocketAddress sa, SocketChannel c, int bufSize, BlockingQueue<Operation> rq, BlockingQueue<Operation> wq, BlockingQueue<Operation> iq, Long opQueueMaxBlockTimeNs, long dt, long at, ConnectionFactory fa)

Uses of Operation in net.spy.memcached.protocol.binary

Classes in net.spy.memcached.protocol.binary that implement Operation

Modifier and Type	Class	Description
(package private) class	ConcatenationOperationImpl
(package private) class	DeleteOperationImpl
(package private) class	FlushOperationImpl
class	GetAndTouchOperationImpl	Implementation of the get and touch operation.
class	GetlOperationImpl	Implementation of the get and lock operation.
(package private) class	GetOperationImpl	Implementation of the get operation.
class	GetsOperationImpl	Implementation of the gets operation.
class	KeyStatsOperationImpl	A StatsOperationImpl.
class	MultiGetOperationImpl
(package private) class	MultiKeyOperationImpl	Binary operations that contain multiple keys and are VBucket aware operations should extend this class.
(package private) class	MutatorOperationImpl
(package private) class	NoopOperationImpl	Implementation of a noop operation.
(package private) class	ObserveOperationImpl
class	OperationImpl	Base class for binary operations.
(package private) final class	OptimizedGetImpl	Optimized Get operation for folding a bunch of gets together.
class	OptimizedSetImpl	Optimized Set operation for folding a bunch of sets together.
class	ReplicaGetOperationImpl	Implementation of the replica get operation.
class	ReplicaGetsOperationImpl	Implementation of the replica gets operation.
class	SASLAuthOperationImpl	SASL authenticator.
class	SASLBaseOperationImpl	SASL authenticator.
(package private) class	SASLMechsOperationImpl
class	SASLStepOperationImpl	A SASLStepOperationImpl.
(package private) class	SingleKeyOperationImpl	Binary operations that contain a single key and are VBucket aware operations should extend this class.
class	StatsOperationImpl	A StatsOperationImpl.
(package private) class	StoreOperationImpl
class	TapAckOperationImpl	Implementation of a tap ACK operation.
class	TapBackfillOperationImpl	Implementation of a tap backfill operation.
class	TapCustomOperationImpl	Implementation of a custom tap operation.
class	TapDumpOperationImpl	Implementation of a tap dump operation.
class	TapOperationImpl	Abstract implementation of a tap operation.
class	TouchOperationImpl	Operation to reset a timeout in Membase server.
(package private) class	UnlockOperationImpl
(package private) class	VersionOperationImpl

Methods in net.spy.memcached.protocol.binary that return types with arguments of type Operation

Modifier and Type	Method	Description
protected Collection<? extends Operation>	BinaryOperationFactory.cloneGet(KeyedOperation op)

Constructor parameters in net.spy.memcached.protocol.binary with type arguments of type Operation

Modifier	Constructor	Description
	BinaryMemcachedNodeImpl(SocketAddress sa, SocketChannel c, int bufSize, BlockingQueue<Operation> rq, BlockingQueue<Operation> wq, BlockingQueue<Operation> iq, Long opQueueMaxBlockTimeNs, boolean waitForAuth, long dt, long at, ConnectionFactory fa)