Uses of Interface
net.spy.memcached.ops.Operation
-
Packages that use Operation Package Description net.spy.memcached Memcached client and transformation utilsnet.spy.memcached.auth Auth Utilities.net.spy.memcached.internal Internal utilities.net.spy.memcached.ops Fundamental protocol operation interfacesnet.spy.memcached.protocol Base classes for protocol abstractions.net.spy.memcached.protocol.ascii Low-level operations for the memcached ascii protocolnet.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 java.util.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, java.nio.ByteBuffer rbuf)
Deal with an operation where the channel reached the end of a stream.Operation
BroadcastOpFactory. newOp(MemcachedNode n, java.util.concurrent.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 java.util.Collection<Operation>
OperationFactory. clone(KeyedOperation op)
Clone an operation.java.util.concurrent.BlockingQueue<Operation>
ConnectionFactory. createOperationQueue()
Create a BlockingQueue for operations for a connection.java.util.concurrent.BlockingQueue<Operation>
DefaultConnectionFactory. createOperationQueue()
java.util.concurrent.BlockingQueue<Operation>
ConnectionFactory. createReadOperationQueue()
Create a BlockingQueue for the operations currently expecting to read responses from memcached.java.util.concurrent.BlockingQueue<Operation>
DefaultConnectionFactory. createReadOperationQueue()
java.util.concurrent.BlockingQueue<Operation>
ConnectionFactory. createWriteOperationQueue()
Create a BlockingQueue for the operations currently expecting to write requests to memcached.java.util.concurrent.BlockingQueue<Operation>
DefaultConnectionFactory. createWriteOperationQueue()
java.util.Collection<Operation>
MemcachedNode. destroyInputQueue()
Extract all queued items for this node destructively.java.util.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(java.lang.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(java.lang.String key, Operation o)
Enqueue the givenOperation
with the used key.private Operation
MemcachedConnection. handleReadsWhenChannelEndOfStream(Operation currentOp, MemcachedNode node, java.nio.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, java.nio.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(java.util.Map<MemcachedNode,Operation> ops)
Enqueue the given list of operations on each handling node.private void
MemcachedConnection. cancelOperations(java.util.Collection<Operation> ops)
Cancel the given collection of operations.void
MemcachedConnection. redistributeOperations(java.util.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, java.lang.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 java.util.Collection<Operation>
CheckedOperationTimeoutException. operations
private java.util.Collection<Operation>
BulkGetFuture. ops
Methods in net.spy.memcached.internal that return types with arguments of type Operation Modifier and Type Method Description java.util.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 java.lang.String
CheckedOperationTimeoutException. createMessage(java.lang.String message, java.util.Collection<Operation> ops)
private java.util.Map<java.lang.String,T>
BulkGetFuture. internalGet(long to, java.util.concurrent.TimeUnit unit, java.util.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 Constructor Description CheckedOperationTimeoutException(java.lang.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 Constructor Description BulkGetFuture(java.util.Map<java.lang.String,java.util.concurrent.Future<T>> m, java.util.Collection<Operation> getOps, java.util.concurrent.CountDownLatch l, java.util.concurrent.ExecutorService service)
CheckedOperationTimeoutException(java.lang.String message, java.util.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 java.util.Collection<Operation>
BaseOperationFactory. clone(KeyedOperation op)
protected abstract java.util.Collection<? extends Operation>
BaseOperationFactory. cloneGet(KeyedOperation op)
java.util.concurrent.BlockingQueue<Operation>
ArrayOperationQueueFactory. create()
java.util.concurrent.BlockingQueue<Operation>
LinkedOperationQueueFactory. create()
java.util.concurrent.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 java.util.List<Operation>
BaseOperationImpl. clones
If the operation gets cloned, the reference is used to cascade cancellations and timeouts.private java.util.concurrent.BlockingQueue<Operation>
TCPMemcachedNodeImpl. inputQueue
private java.util.concurrent.BlockingQueue<Operation>
TCPMemcachedNodeImpl. readQ
private java.util.ArrayList<Operation>
TCPMemcachedNodeImpl. reconnectBlocked
protected java.util.concurrent.BlockingQueue<Operation>
TCPMemcachedNodeImpl. writeQ
Methods in net.spy.memcached.protocol that return Operation Modifier and Type Method Description Operation
TCPMemcachedNodeImpl. getCurrentReadOp()
Operation
TCPMemcachedNodeImpl. getCurrentWriteOp()
private Operation
TCPMemcachedNodeImpl. getNextWritableOp()
Operation
TCPMemcachedNodeImpl. removeCurrentReadOp()
Operation
TCPMemcachedNodeImpl. removeCurrentWriteOp()
Methods in net.spy.memcached.protocol that return types with arguments of type Operation Modifier and Type Method Description java.util.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)
void
TCPMemcachedNodeImpl. addOp(Operation op)
void
TCPMemcachedNodeImpl. insertOp(Operation op)
Constructor parameters in net.spy.memcached.protocol with type arguments of type Operation Constructor Description TCPMemcachedNodeImpl(java.net.SocketAddress sa, java.nio.channels.SocketChannel c, int bufSize, java.util.concurrent.BlockingQueue<Operation> rq, java.util.concurrent.BlockingQueue<Operation> wq, java.util.concurrent.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) class
DeleteOperationImpl
Operation to delete an item from the cache.(package private) 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) class
MutatorOperationImpl
Operation for mutating integers inside of memcached.(package private) class
OperationImpl
Operations on a memcached connection.(package private) class
OptimizedGetImpl
Optimized Get operation for folding a bunch of gets together.(package private) class
StatsOperationImpl
Operation to retrieve statistics from a memcached server.(package private) class
StoreOperationImpl
Operation to store data in a memcached server.(package private) class
TouchOperationImpl
Memcached touch operation.(package private) class
UnlockOperationImpl
Operation to delete an item from the cache.(package private) 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 java.util.Collection<? extends Operation>
AsciiOperationFactory. cloneGet(KeyedOperation op)
Constructor parameters in net.spy.memcached.protocol.ascii with type arguments of type Operation Constructor Description AsciiMemcachedNodeImpl(java.net.SocketAddress sa, java.nio.channels.SocketChannel c, int bufSize, java.util.concurrent.BlockingQueue<Operation> rq, java.util.concurrent.BlockingQueue<Operation> wq, java.util.concurrent.BlockingQueue<Operation> iq, java.lang.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) 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 java.util.Collection<? extends Operation>
BinaryOperationFactory. cloneGet(KeyedOperation op)
Constructor parameters in net.spy.memcached.protocol.binary with type arguments of type Operation Constructor Description BinaryMemcachedNodeImpl(java.net.SocketAddress sa, java.nio.channels.SocketChannel c, int bufSize, java.util.concurrent.BlockingQueue<Operation> rq, java.util.concurrent.BlockingQueue<Operation> wq, java.util.concurrent.BlockingQueue<Operation> iq, java.lang.Long opQueueMaxBlockTimeNs, boolean waitForAuth, long dt, long at, ConnectionFactory fa)
-