Package | Description |
---|---|
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
|
Modifier and Type | Method and Description |
---|---|
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,
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 |
MemcachedNode.removeCurrentWriteOp()
Remove the operation at the top of the queue that has information available
to write.
|
Modifier and Type | Method and 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.
|
Modifier and Type | Method and Description |
---|---|
void |
MemcachedNode.addOp(Operation op)
Add an operation to the queue.
|
protected void |
MemcachedConnection.addOperation(MemcachedNode node,
Operation o) |
protected void |
MemcachedConnection.addOperation(java.lang.String key,
Operation o)
Add an operation to the given connection.
|
void |
TapConnectionProvider.addTapAckOp(MemcachedNode node,
Operation op) |
void |
MemcachedConnection.enqueueOperation(java.lang.String key,
Operation o) |
void |
MemcachedNode.insertOp(Operation o)
Insert an operation to the beginning of the queue.
|
void |
MemcachedConnection.insertOperation(MemcachedNode node,
Operation o) |
static void |
MemcachedConnection.opSucceeded(Operation op)
helper method: reset timeout counter.
|
static void |
MemcachedConnection.opTimedOut(Operation op)
helper method: increase timeout count on node attached to this op.
|
Modifier and Type | Method and Description |
---|---|
void |
MemcachedConnection.addOperations(java.util.Map<MemcachedNode,Operation> ops) |
Modifier and Type | Method and Description |
---|---|
java.util.Collection<Operation> |
CheckedOperationTimeoutException.getOperations()
Get the operation that timed out.
|
Modifier and Type | Method and Description |
---|---|
void |
OperationFuture.setOperation(Operation to)
Set the Operation associated with this OperationFuture.
|
void |
GetFuture.setOperation(Operation to) |
Constructor and Description |
---|
CheckedOperationTimeoutException(java.lang.String message,
Operation op)
Construct a CheckedOperationTimeoutException with the given message and
operation.
|
Constructor and Description |
---|
BulkGetFuture(java.util.Map<java.lang.String,java.util.concurrent.Future<T>> m,
java.util.Collection<Operation> getOps,
java.util.concurrent.CountDownLatch l) |
CheckedOperationTimeoutException(java.lang.String message,
java.util.Collection<Operation> ops) |
Modifier and Type | Interface and 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 |
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.
|
Modifier and Type | Method and 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> |
OperationQueueFactory.create()
Create an instance of a queue.
|
java.util.concurrent.BlockingQueue<Operation> |
LinkedOperationQueueFactory.create() |
Modifier and Type | Class and Description |
---|---|
class |
BaseOperationImpl
Base class for protocol-specific operation implementations.
|
Modifier and Type | Field and Description |
---|---|
protected Operation |
TCPMemcachedNodeImpl.optimizedOp |
Modifier and Type | Field and Description |
---|---|
protected java.util.concurrent.BlockingQueue<Operation> |
TCPMemcachedNodeImpl.writeQ |
Modifier and Type | Method and Description |
---|---|
Operation |
TCPMemcachedNodeImpl.getCurrentReadOp() |
Operation |
TCPMemcachedNodeImpl.getCurrentWriteOp() |
Operation |
TCPMemcachedNodeImpl.removeCurrentReadOp() |
Operation |
TCPMemcachedNodeImpl.removeCurrentWriteOp() |
Modifier and Type | Method and Description |
---|---|
java.util.Collection<Operation> |
TCPMemcachedNodeImpl.destroyInputQueue() |
Modifier and Type | Method and Description |
---|---|
void |
TCPMemcachedNodeImpl.addOp(Operation op) |
void |
TCPMemcachedNodeImpl.insertOp(Operation op) |
Constructor and 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) |
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) |
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) |
Modifier and Type | Class and Description |
---|---|
class |
ConcatenationOperationImpl
Operation for ascii concatenations.
|
class |
GetAndTouchOperationImpl
Implementation of the get and touch operation.
|
Modifier and Type | Method and Description |
---|---|
protected java.util.Collection<? extends Operation> |
AsciiOperationFactory.cloneGet(KeyedOperation op) |
Constructor and 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) |
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) |
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) |
Modifier and Type | Class and Description |
---|---|
class |
GetlOperationImpl
Implementation of the get and lock operation.
|
class |
GetsOperationImpl
Implementation of the gets operation.
|
class |
KeyStatsOperationImpl
A StatsOperationImpl.
|
class |
OptimizedSetImpl
Optimized Set operation for folding a bunch of sets together.
|
class |
ReplicaGetOperationImpl
Implementation of the replica get operation.
|
class |
SASLAuthOperationImpl
SASL authenticator.
|
class |
SASLBaseOperationImpl
SASL authenticator.
|
class |
SASLStepOperationImpl
A SASLStepOperationImpl.
|
class |
StatsOperationImpl
A StatsOperationImpl.
|
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.
|
Modifier and Type | Method and Description |
---|---|
protected java.util.Collection<? extends Operation> |
BinaryOperationFactory.cloneGet(KeyedOperation op) |
Constructor and 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) |
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) |
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) |
Copyright © 2006-2009 Dustin Sallings, 2009-2013 Couchbase, Inc.