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,
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 |
---|---|
Collection<Operation> |
OperationFactory.clone(KeyedOperation op)
Clone an operation.
|
BlockingQueue<Operation> |
DefaultConnectionFactory.createOperationQueue() |
BlockingQueue<Operation> |
ConnectionFactory.createOperationQueue()
Create a BlockingQueue for operations for a connection.
|
BlockingQueue<Operation> |
DefaultConnectionFactory.createReadOperationQueue() |
BlockingQueue<Operation> |
ConnectionFactory.createReadOperationQueue()
Create a BlockingQueue for the operations currently expecting to read
responses from memcached.
|
BlockingQueue<Operation> |
DefaultConnectionFactory.createWriteOperationQueue() |
BlockingQueue<Operation> |
ConnectionFactory.createWriteOperationQueue()
Create a BlockingQueue for the operations currently expecting to write
requests to memcached.
|
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)
Enqueue an operation on the given node.
|
protected void |
MemcachedConnection.addOperation(String key,
Operation o)
Add an operation to a connection identified by the given key.
|
void |
TapConnectionProvider.addTapAckOp(MemcachedNode node,
Operation op) |
void |
MemcachedConnection.enqueueOperation(String key,
Operation o)
Enqueue the given
Operation with the used key. |
void |
MemcachedNode.insertOp(Operation o)
Insert an operation to the beginning of the queue.
|
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.
|
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.
|
Modifier and Type | Method and Description |
---|---|
void |
MemcachedConnection.addOperations(Map<MemcachedNode,Operation> ops)
Enqueue the given list of operations on each handling node.
|
void |
MemcachedConnection.redistributeOperations(Collection<Operation> ops)
Redistribute the given list of operations to (potentially) other nodes.
|
Modifier and Type | Method and Description |
---|---|
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(String message,
Operation op)
Construct a CheckedOperationTimeoutException with the given message and
operation.
|
Constructor and Description |
---|
BulkGetFuture(Map<String,Future<T>> m,
Collection<Operation> getOps,
CountDownLatch l,
ExecutorService service) |
CheckedOperationTimeoutException(String message,
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 |
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.
|
Modifier and Type | Method and Description |
---|---|
Collection<Operation> |
BaseOperationFactory.clone(KeyedOperation op) |
protected abstract Collection<? extends Operation> |
BaseOperationFactory.cloneGet(KeyedOperation op) |
BlockingQueue<Operation> |
LinkedOperationQueueFactory.create() |
BlockingQueue<Operation> |
OperationQueueFactory.create()
Create an instance of a queue.
|
BlockingQueue<Operation> |
ArrayOperationQueueFactory.create() |
Modifier and Type | Method and Description |
---|---|
void |
Operation.addClone(Operation op)
Add the clone from this operation.
|
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 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 |
---|---|
Collection<Operation> |
TCPMemcachedNodeImpl.destroyInputQueue() |
Modifier and Type | Method and Description |
---|---|
void |
BaseOperationImpl.addClone(Operation op) |
void |
TCPMemcachedNodeImpl.addOp(Operation op) |
void |
TCPMemcachedNodeImpl.insertOp(Operation op) |
Constructor and 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) |
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) |
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) |
Modifier and Type | Class and Description |
---|---|
class |
ConcatenationOperationImpl
Operation for ascii concatenations.
|
Modifier and Type | Method and Description |
---|---|
protected Collection<? extends Operation> |
AsciiOperationFactory.cloneGet(KeyedOperation op) |
Constructor and 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) |
AsciiMemcachedNodeImpl(SocketAddress sa,
SocketChannel c,
int bufSize,
BlockingQueue<Operation> rq,
BlockingQueue<Operation> wq,
BlockingQueue<Operation> iq,
Long opQueueMaxBlockTimeNs,
long dt,
long at,
ConnectionFactory fa) |
AsciiMemcachedNodeImpl(SocketAddress sa,
SocketChannel c,
int bufSize,
BlockingQueue<Operation> rq,
BlockingQueue<Operation> wq,
BlockingQueue<Operation> iq,
Long opQueueMaxBlockTimeNs,
long dt,
long at,
ConnectionFactory fa) |
Modifier and Type | Class and Description |
---|---|
class |
GetAndTouchOperationImpl
Implementation of the get and touch operation.
|
class |
GetlOperationImpl
Implementation of the get and lock operation.
|
class |
GetsOperationImpl
Implementation of the gets operation.
|
class |
KeyStatsOperationImpl
A StatsOperationImpl.
|
class |
MultiGetOperationImpl |
class |
OperationImpl
Base class for binary operations.
|
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.
|
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 Collection<? extends Operation> |
BinaryOperationFactory.cloneGet(KeyedOperation op) |
Constructor and 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) |
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) |
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) |
Copyright © 2023. All rights reserved.