public class MultiGetOperationImpl extends OperationImpl implements GetOperation
GetOperation.Callback
Modifier and Type | Field and Description |
---|---|
protected Map<String,Short> |
vbmap |
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
callback, CANCELLED, notMyVbucketNodes, TIMED_OUT
Constructor and Description |
---|
MultiGetOperationImpl(Collection<String> k,
OperationCallback cb) |
Modifier and Type | Method and Description |
---|---|
protected int |
addKey(String k)
Add a key (and return its new opaque value).
|
void |
addNotMyVbucketNode(MemcachedNode node) |
protected void |
finishedPayload(byte[] pl) |
Collection<String> |
getKeys()
Get the keys requested in this GetOperation.
|
Collection<MemcachedNode> |
getNotMyVbucketNodes() |
List<String> |
getRetryKeys()
Returns the keys to redistribute.
|
short |
getVBucket(String k) |
void |
initialize()
Initialize this operation.
|
protected boolean |
opaqueIsValid()
Validate an opaque value from the header.
|
void |
setNotMyVbucketNodes(Collection<MemcachedNode> nodes) |
void |
setVBucket(String k,
short vb) |
String |
toString() |
decodePayload, getErrorMsg, getStatusForErrorCode, prepareBuffer, readFromBuffer, resetInput
addClone, cancel, getBuffer, getCallback, getCloneCount, getException, getHandlingNode, getState, getWriteCompleteTimestamp, handleError, handleRead, hasErrored, isCancelled, isTimedOut, isTimedOut, isTimedOutUnsent, setBuffer, setCallback, setCloneCount, setHandlingNode, timeOut, transitionState, wasCancelled, writeComplete, writing
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getKeys
addClone, cancel, getBuffer, getCallback, getCloneCount, getErrorMsg, getException, getHandlingNode, getState, getWriteCompleteTimestamp, handleRead, hasErrored, isCancelled, isTimedOut, isTimedOut, isTimedOutUnsent, readFromBuffer, setCloneCount, setHandlingNode, timeOut, writeComplete, writing
public MultiGetOperationImpl(Collection<String> k, OperationCallback cb)
protected int addKey(String k)
public void initialize()
Operation
initialize
in interface Operation
initialize
in class BaseOperationImpl
protected void finishedPayload(byte[] pl) throws IOException
finishedPayload
in class OperationImpl
IOException
protected boolean opaqueIsValid()
OperationImpl
opaqueIsValid
in class OperationImpl
public List<String> getRetryKeys()
public Collection<String> getKeys()
KeyedOperation
getKeys
in interface KeyedOperation
public Collection<MemcachedNode> getNotMyVbucketNodes()
getNotMyVbucketNodes
in interface VBucketAware
public void addNotMyVbucketNode(MemcachedNode node)
addNotMyVbucketNode
in interface VBucketAware
public void setNotMyVbucketNodes(Collection<MemcachedNode> nodes)
setNotMyVbucketNodes
in interface VBucketAware
public void setVBucket(String k, short vb)
setVBucket
in interface VBucketAware
public short getVBucket(String k)
getVBucket
in interface VBucketAware
public String toString()
toString
in class OperationImpl
Copyright © 2023. All rights reserved.