|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Operation | |
---|---|
net.spy.memcached | Memcached client and transformation utils |
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 |
---|
Methods in net.spy.memcached that return Operation | |
---|---|
Operation |
MemcachedNode.getCurrentReadOp()
Get the operation at the top of the queue that is requiring input. |
Operation |
MemcachedNode.getCurrentWriteOp()
Get the operation at the top of the queue that has information available to write. |
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 |
MemcachedNode.removeCurrentWriteOp()
Remove the operation at the top of the queue that has information available to write. |
Methods in net.spy.memcached that return types with arguments of type Operation | |
---|---|
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. |
Methods in net.spy.memcached with parameters of type Operation | |
---|---|
void |
MemcachedNode.addOp(Operation op)
Add an operation to the queue. |
void |
MemcachedConnection.addOperation(MemcachedNode node,
Operation o)
|
void |
MemcachedConnection.addOperation(String key,
Operation o)
Add an operation to the given connection. |
Method parameters in net.spy.memcached with type arguments of type Operation | |
---|---|
void |
MemcachedConnection.addOperations(Map<MemcachedNode,Operation> ops)
|
Uses of Operation in net.spy.memcached.internal |
---|
Methods in net.spy.memcached.internal that return types with arguments of type Operation | |
---|---|
Collection<Operation> |
CheckedOperationTimeoutException.getOperations()
Get the operation that timed out. |
Methods in net.spy.memcached.internal with parameters of type Operation | |
---|---|
void |
GetFuture.setOperation(Operation to)
|
void |
OperationFuture.setOperation(Operation to)
|
Constructors in net.spy.memcached.internal with parameters of type Operation | |
---|---|
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 | |
---|---|
BulkGetFuture(Map<String,Future<T>> m,
Collection<Operation> getOps,
CountDownLatch l)
|
|
CheckedOperationTimeoutException(String message,
Collection<Operation> ops)
|
Uses of Operation in net.spy.memcached.ops |
---|
Subinterfaces of Operation in net.spy.memcached.ops | |
---|---|
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 |
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 |
StatsOperation
Stats fetching operation. |
interface |
StoreOperation
Operation that represents object storage. |
interface |
VersionOperation
Version operation. |
Methods in net.spy.memcached.ops that return types with arguments of type Operation | |
---|---|
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. |
Uses of Operation in net.spy.memcached.protocol |
---|
Fields in net.spy.memcached.protocol declared as Operation | |
---|---|
protected Operation |
TCPMemcachedNodeImpl.optimizedOp
|
Fields in net.spy.memcached.protocol with type parameters of type Operation | |
---|---|
protected BlockingQueue<Operation> |
TCPMemcachedNodeImpl.writeQ
|
Methods in net.spy.memcached.protocol that return Operation | |
---|---|
Operation |
TCPMemcachedNodeImpl.getCurrentReadOp()
|
Operation |
TCPMemcachedNodeImpl.getCurrentWriteOp()
|
Operation |
TCPMemcachedNodeImpl.removeCurrentReadOp()
|
Operation |
TCPMemcachedNodeImpl.removeCurrentWriteOp()
|
Methods in net.spy.memcached.protocol that return types with arguments of type Operation | |
---|---|
Collection<Operation> |
TCPMemcachedNodeImpl.destroyInputQueue()
|
Methods in net.spy.memcached.protocol with parameters of type Operation | |
---|---|
void |
TCPMemcachedNodeImpl.addOp(Operation op)
|
Constructor parameters in net.spy.memcached.protocol with type arguments of type Operation | |
---|---|
TCPMemcachedNodeImpl(SocketAddress sa,
SocketChannel c,
int bufSize,
BlockingQueue<Operation> rq,
BlockingQueue<Operation> wq,
BlockingQueue<Operation> iq)
|
|
TCPMemcachedNodeImpl(SocketAddress sa,
SocketChannel c,
int bufSize,
BlockingQueue<Operation> rq,
BlockingQueue<Operation> wq,
BlockingQueue<Operation> iq)
|
|
TCPMemcachedNodeImpl(SocketAddress sa,
SocketChannel c,
int bufSize,
BlockingQueue<Operation> rq,
BlockingQueue<Operation> wq,
BlockingQueue<Operation> iq)
|
Uses of Operation in net.spy.memcached.protocol.ascii |
---|
Classes in net.spy.memcached.protocol.ascii that implement Operation | |
---|---|
class |
ConcatenationOperationImpl
Operation for ascii concatenations. |
Methods in net.spy.memcached.protocol.ascii that return types with arguments of type Operation | |
---|---|
protected Collection<? extends Operation> |
AsciiOperationFactory.cloneGet(KeyedOperation op)
|
Constructor parameters in net.spy.memcached.protocol.ascii with type arguments of type Operation | |
---|---|
AsciiMemcachedNodeImpl(SocketAddress sa,
SocketChannel c,
int bufSize,
BlockingQueue<Operation> rq,
BlockingQueue<Operation> wq,
BlockingQueue<Operation> iq)
|
|
AsciiMemcachedNodeImpl(SocketAddress sa,
SocketChannel c,
int bufSize,
BlockingQueue<Operation> rq,
BlockingQueue<Operation> wq,
BlockingQueue<Operation> iq)
|
|
AsciiMemcachedNodeImpl(SocketAddress sa,
SocketChannel c,
int bufSize,
BlockingQueue<Operation> rq,
BlockingQueue<Operation> wq,
BlockingQueue<Operation> iq)
|
Uses of Operation in net.spy.memcached.protocol.binary |
---|
Classes in net.spy.memcached.protocol.binary that implement Operation | |
---|---|
class |
OptimizedSetImpl
|
class |
StatsOperationImpl
|
Methods in net.spy.memcached.protocol.binary that return types with arguments of type Operation | |
---|---|
protected Collection<? extends Operation> |
BinaryOperationFactory.cloneGet(KeyedOperation op)
|
Constructor parameters in net.spy.memcached.protocol.binary with type arguments of type Operation | |
---|---|
BinaryMemcachedNodeImpl(SocketAddress sa,
SocketChannel c,
int bufSize,
BlockingQueue<Operation> rq,
BlockingQueue<Operation> wq,
BlockingQueue<Operation> iq)
|
|
BinaryMemcachedNodeImpl(SocketAddress sa,
SocketChannel c,
int bufSize,
BlockingQueue<Operation> rq,
BlockingQueue<Operation> wq,
BlockingQueue<Operation> iq)
|
|
BinaryMemcachedNodeImpl(SocketAddress sa,
SocketChannel c,
int bufSize,
BlockingQueue<Operation> rq,
BlockingQueue<Operation> wq,
BlockingQueue<Operation> iq)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |