Class SingleKeyOperationImpl
- java.lang.Object
-
- net.spy.memcached.compat.SpyObject
-
- net.spy.memcached.protocol.BaseOperationImpl
-
- net.spy.memcached.protocol.binary.OperationImpl
-
- net.spy.memcached.protocol.binary.SingleKeyOperationImpl
-
- All Implemented Interfaces:
KeyedOperation
,Operation
,VBucketAware
- Direct Known Subclasses:
ConcatenationOperationImpl
,DeleteOperationImpl
,GetAndTouchOperationImpl
,GetlOperationImpl
,GetOperationImpl
,GetsOperationImpl
,KeyStatsOperationImpl
,MutatorOperationImpl
,ObserveOperationImpl
,ReplicaGetOperationImpl
,ReplicaGetsOperationImpl
,StoreOperationImpl
,TouchOperationImpl
,UnlockOperationImpl
abstract class SingleKeyOperationImpl extends OperationImpl implements VBucketAware, KeyedOperation
Binary operations that contain a single key and are VBucket aware operations should extend this class.
-
-
Field Summary
Fields Modifier and Type Field Description protected java.lang.String
key
-
Fields inherited from class net.spy.memcached.protocol.binary.OperationImpl
DUMMY_OPCODE, EMPTY_BYTES, ERR_2BIG, ERR_BUSY, ERR_DELTA_BADVAL, ERR_EXISTS, ERR_INTERNAL, ERR_INVAL, ERR_NO_MEM, ERR_NOT_FOUND, ERR_NOT_MY_VBUCKET, ERR_NOT_STORED, ERR_NOT_SUPPORTED, ERR_TEMP_FAIL, ERR_UNKNOWN_COMMAND, errorCode, keyLen, MIN_RECV_PACKET, opaque, REQ_MAGIC, RES_MAGIC, responseCas, responseCmd, responseOpaque, STATUS_OK, SUCCESS, vbucket
-
Fields inherited from class net.spy.memcached.protocol.BaseOperationImpl
callback, CANCELLED, notMyVbucketNodes, TIMED_OUT
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
SingleKeyOperationImpl(byte c, int o, java.lang.String k, OperationCallback cb)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addNotMyVbucketNode(MemcachedNode node)
java.util.Collection<java.lang.String>
getKeys()
Get the keys requested in this GetOperation.java.util.Collection<MemcachedNode>
getNotMyVbucketNodes()
short
getVBucket(java.lang.String k)
void
setNotMyVbucketNodes(java.util.Collection<MemcachedNode> nodes)
void
setVBucket(java.lang.String k, short vb)
java.lang.String
toString()
-
Methods inherited from class net.spy.memcached.protocol.binary.OperationImpl
decodeByte, decodeInt, decodeLong, decodePayload, decodeShort, decodeUnsignedInt, finishedPayload, generateOpaque, getErrorMsg, getStatusForErrorCode, opaqueIsValid, prepareBuffer, readFromBuffer, resetInput
-
Methods inherited from class net.spy.memcached.protocol.BaseOperationImpl
addClone, cancel, getBuffer, getCallback, getCloneCount, getException, getHandlingNode, getState, getWriteCompleteTimestamp, handleError, handleRead, hasErrored, initialize, isCancelled, isTimedOut, isTimedOut, isTimedOutUnsent, setBuffer, setCallback, setCloneCount, setHandlingNode, timeOut, transitionState, wasCancelled, writeComplete, writing
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface net.spy.memcached.ops.Operation
addClone, cancel, getBuffer, getCallback, getCloneCount, getErrorMsg, getException, getHandlingNode, getState, getWriteCompleteTimestamp, handleRead, hasErrored, initialize, isCancelled, isTimedOut, isTimedOut, isTimedOutUnsent, readFromBuffer, setCloneCount, setHandlingNode, timeOut, writeComplete, writing
-
-
-
-
Constructor Detail
-
SingleKeyOperationImpl
protected SingleKeyOperationImpl(byte c, int o, java.lang.String k, OperationCallback cb)
-
-
Method Detail
-
getKeys
public java.util.Collection<java.lang.String> getKeys()
Description copied from interface:KeyedOperation
Get the keys requested in this GetOperation.- Specified by:
getKeys
in interfaceKeyedOperation
-
getNotMyVbucketNodes
public java.util.Collection<MemcachedNode> getNotMyVbucketNodes()
- Specified by:
getNotMyVbucketNodes
in interfaceVBucketAware
-
addNotMyVbucketNode
public void addNotMyVbucketNode(MemcachedNode node)
- Specified by:
addNotMyVbucketNode
in interfaceVBucketAware
-
setNotMyVbucketNodes
public void setNotMyVbucketNodes(java.util.Collection<MemcachedNode> nodes)
- Specified by:
setNotMyVbucketNodes
in interfaceVBucketAware
-
setVBucket
public void setVBucket(java.lang.String k, short vb)
- Specified by:
setVBucket
in interfaceVBucketAware
-
getVBucket
public short getVBucket(java.lang.String k)
- Specified by:
getVBucket
in interfaceVBucketAware
-
toString
public java.lang.String toString()
- Overrides:
toString
in classOperationImpl
-
-