Uses of Interface
net.spy.memcached.ops.Operation
Packages that use Operation
Package
Description
Memcached client and transformation utils
Auth Utilities.
Internal utilities.
Fundamental protocol operation interfaces
Base classes for protocol abstractions.
Low-level operations for the memcached ascii protocol
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 OperationModifier and TypeFieldDescriptionMemcachedConnection.retryOps
Holds operations that need to be retried.Methods in net.spy.memcached that return OperationModifier and TypeMethodDescriptionMemcachedNode.getCurrentReadOp()
Get the operation at the top of the queue that is requiring input.MemcachedNodeROImpl.getCurrentReadOp()
MemcachedNode.getCurrentWriteOp()
Get the operation at the top of the queue that has information available to write.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.BroadcastOpFactory.newOp
(MemcachedNode n, CountDownLatch latch) Construct a new operation for delivery to the given node.MemcachedNode.removeCurrentReadOp()
Remove the operation at the top of the queue that is requiring input.MemcachedNodeROImpl.removeCurrentReadOp()
MemcachedNode.removeCurrentWriteOp()
Remove the operation at the top of the queue that has information available to write.MemcachedNodeROImpl.removeCurrentWriteOp()
Methods in net.spy.memcached that return types with arguments of type OperationModifier and TypeMethodDescriptionOperationFactory.clone
(KeyedOperation op) Clone an operation.ConnectionFactory.createOperationQueue()
Create a BlockingQueue for operations for a connection.DefaultConnectionFactory.createOperationQueue()
ConnectionFactory.createReadOperationQueue()
Create a BlockingQueue for the operations currently expecting to read responses from memcached.DefaultConnectionFactory.createReadOperationQueue()
ConnectionFactory.createWriteOperationQueue()
Create a BlockingQueue for the operations currently expecting to write requests to memcached.DefaultConnectionFactory.createWriteOperationQueue()
MemcachedNode.destroyInputQueue()
Extract all queued items for this node destructively.MemcachedNodeROImpl.destroyInputQueue()
Methods in net.spy.memcached with parameters of type OperationModifier and TypeMethodDescriptionvoid
Add an operation to the queue.void
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 givenOperation
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
Insert an operation to the beginning of the queue.void
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 OperationModifier and TypeMethodDescriptionvoid
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 OperationModifier and TypeMethodDescriptionprivate 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 OperationFields in net.spy.memcached.internal with type parameters of type OperationModifier and TypeFieldDescriptionprivate final Collection
<Operation> CheckedOperationTimeoutException.operations
private final Collection
<Operation> BulkGetFuture.ops
Methods in net.spy.memcached.internal that return types with arguments of type OperationModifier and TypeMethodDescriptionCheckedOperationTimeoutException.getOperations()
Get the operation that timed out.Methods in net.spy.memcached.internal with parameters of type OperationModifier and TypeMethodDescriptionvoid
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 OperationModifier and TypeMethodDescriptionprivate static String
CheckedOperationTimeoutException.createMessage
(String message, Collection<Operation> ops) 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 OperationModifierConstructorDescriptionCheckedOperationTimeoutException
(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 OperationModifierConstructorDescriptionBulkGetFuture
(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.opsModifier and TypeInterfaceDescriptioninterface
Operation that represents compare-and-swap.interface
ConcatenationOperation is used to append or prepend data to an existing object in the cache.interface
Deletion operation.interface
Flush operation marker.interface
Gat operation.interface
Getl operation.interface
Get operation.interface
Gets operation (get with CAS identifier support).interface
Operations that contain keys.interface
incr and decr operations.interface
The NOOP Operation.interface
Observe operation.interface
Replica get operation.interface
Replica get operation.interface
Operation for beginning a SASL auth cycle.interface
Operation for listing supported SASL mechanisms.interface
Operation for proceeding in a SASL auth negotiation.interface
Stats fetching operation.interface
Operation that represents object storage.interface
Tap operation.interface
Touch operation marker.interface
Unlock operation.interface
Version operation.Methods in net.spy.memcached.ops that return types with arguments of type OperationModifier and TypeMethodDescriptionBaseOperationFactory.clone
(KeyedOperation op) protected abstract Collection
<? extends Operation> BaseOperationFactory.cloneGet
(KeyedOperation op) ArrayOperationQueueFactory.create()
LinkedOperationQueueFactory.create()
OperationQueueFactory.create()
Create an instance of a queue.Methods in net.spy.memcached.ops with parameters of type Operation -
Uses of Operation in net.spy.memcached.protocol
Classes in net.spy.memcached.protocol that implement OperationModifier and TypeClassDescriptionclass
Base class for protocol-specific operation implementations.Fields in net.spy.memcached.protocol declared as OperationFields in net.spy.memcached.protocol with type parameters of type OperationModifier and TypeFieldDescriptionBaseOperationImpl.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
TCPMemcachedNodeImpl.reconnectBlocked
protected final BlockingQueue
<Operation> TCPMemcachedNodeImpl.writeQ
Methods in net.spy.memcached.protocol that return OperationModifier and TypeMethodDescriptionfinal 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 OperationMethods in net.spy.memcached.protocol with parameters of type OperationModifier and TypeMethodDescriptionvoid
final void
final void
Constructor parameters in net.spy.memcached.protocol with type arguments of type OperationModifierConstructorDescriptionTCPMemcachedNodeImpl
(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 OperationModifier and TypeClassDescriptionclass
Base class for get and gets handlers.(package private) class
Base class for ascii store operations (add, set, replace, append, prepend).(package private) class
class
Operation for ascii concatenations.(package private) final class
Operation to delete an item from the cache.(package private) final class
Memcached flush_all operation.class
Implementation of the get and touch operation.(package private) class
Implementation of the getl operation.(package private) class
Operation for retrieving data.(package private) class
Implementation of the gets operation.(package private) final class
Operation for mutating integers inside of memcached.(package private) class
Operations on a memcached connection.(package private) final class
Optimized Get operation for folding a bunch of gets together.(package private) final class
Operation to retrieve statistics from a memcached server.(package private) final class
Operation to store data in a memcached server.(package private) final class
Memcached touch operation.(package private) final class
Operation to delete an item from the cache.(package private) final class
Operation to request the version of a memcached server.Methods in net.spy.memcached.protocol.ascii that return types with arguments of type OperationModifier and TypeMethodDescriptionprotected Collection
<? extends Operation> AsciiOperationFactory.cloneGet
(KeyedOperation op) Constructor parameters in net.spy.memcached.protocol.ascii with type arguments of type OperationModifierConstructorDescriptionAsciiMemcachedNodeImpl
(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 OperationModifier and TypeClassDescription(package private) class
(package private) class
(package private) class
class
Implementation of the get and touch operation.class
Implementation of the get and lock operation.(package private) class
Implementation of the get operation.class
Implementation of the gets operation.class
A StatsOperationImpl.class
(package private) class
Binary operations that contain multiple keys and are VBucket aware operations should extend this class.(package private) class
(package private) class
Implementation of a noop operation.(package private) class
class
Base class for binary operations.(package private) final class
Optimized Get operation for folding a bunch of gets together.class
Optimized Set operation for folding a bunch of sets together.class
Implementation of the replica get operation.class
Implementation of the replica gets operation.class
SASL authenticator.class
SASL authenticator.(package private) class
class
A SASLStepOperationImpl.(package private) class
Binary operations that contain a single key and are VBucket aware operations should extend this class.class
A StatsOperationImpl.(package private) class
class
Implementation of a tap ACK operation.class
Implementation of a tap backfill operation.class
Implementation of a custom tap operation.class
Implementation of a tap dump operation.class
Abstract implementation of a tap operation.class
Operation to reset a timeout in Membase server.(package private) class
(package private) class
Methods in net.spy.memcached.protocol.binary that return types with arguments of type OperationModifier and TypeMethodDescriptionprotected Collection
<? extends Operation> BinaryOperationFactory.cloneGet
(KeyedOperation op) Constructor parameters in net.spy.memcached.protocol.binary with type arguments of type OperationModifierConstructorDescriptionBinaryMemcachedNodeImpl
(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)