Package net.spy.memcached.tapmessage
Class RequestMessage
java.lang.Object
net.spy.memcached.compat.SpyObject
net.spy.memcached.tapmessage.BaseMessage
net.spy.memcached.tapmessage.RequestMessage
A tap request message that is used to start tap streams, perform sasl
authentication, and maintain the health of tap streams.
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate long
private List
<TapRequestFlag> private boolean
private boolean
private boolean
private boolean
private String
private short[]
Fields inherited from class net.spy.memcached.tapmessage.BaseMessage
cas, datatype, extralength, HEADER_LENGTH, keylength, magic, opaque, opcode, totalbody, vbucket
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptiongetBytes()
Encodes the message into binary.getFlags()
Returns the flags for this message.void
setBackfill
(long date) Stream all keys inserted into the server after a given date.void
Sets the flags for the tap stream.void
Sets a name for this tap stream.void
setvBucketCheckpoints
(Map<Short, Long> vbchkpnts) Sets a map of vbucket checkpoints.void
setVbucketlist
(short[] vbs) Sets a list of vbuckets to stream keys from.Methods inherited from class net.spy.memcached.tapmessage.BaseMessage
decodeInt, decodeIntHostOrder, decodeLong, decodeShort, getCas, getDatatype, getExtralength, getKeylength, getMagic, getMessageLength, getOpaque, getOpcode, getTotalbody, getVbucket, setCas, setDatatype, setExtralength, setMagic, setOpaque, setOpcode, setTotalbody, setVbucket
-
Field Details
-
hasBackfill
private boolean hasBackfill -
hasVBucketList
private boolean hasVBucketList -
hasVBucketCheckpoints
private boolean hasVBucketCheckpoints -
hasFlags
private boolean hasFlags -
flagList
-
vblist
private short[] vblist -
name
-
backfilldate
private long backfilldate -
vBucketCheckpoints
-
-
Constructor Details
-
RequestMessage
public RequestMessage()Create a tap request message. These messages are used to start tap streams.
-
-
Method Details
-
setFlags
Sets the flags for the tap stream. These flags decide what kind of tap stream will be received.- Parameters:
f
- The flags to use for this tap stream.
-
getFlags
Returns the flags for this message.- Returns:
- An int value of flags set for this tap message.
-
setBackfill
public void setBackfill(long date) Stream all keys inserted into the server after a given date.- Parameters:
date
- - The date to stream keys from. Null to stream all keys.
-
setVbucketlist
public void setVbucketlist(short[] vbs) Sets a list of vbuckets to stream keys from.- Parameters:
vbs
- - A list of vbuckets.
-
setvBucketCheckpoints
Sets a map of vbucket checkpoints.- Parameters:
vbchkpnts
- - A map of vbucket checkpoint identifiers
-
setName
Sets a name for this tap stream. If the tap stream fails this name can be used to try to restart the tap stream from where it last left off.- Parameters:
n
- The name for the tap stream.
-
getBytes
Encodes the message into binary.- Specified by:
getBytes
in classBaseMessage
- Returns:
- The ByteBuffer representation of the message.
-