Class RequestMessage


public class RequestMessage extends BaseMessage
A tap request message that is used to start tap streams, perform sasl authentication, and maintain the health of tap streams.
  • Field Details

    • hasBackfill

      private boolean hasBackfill
    • hasVBucketList

      private boolean hasVBucketList
    • hasVBucketCheckpoints

      private boolean hasVBucketCheckpoints
    • hasFlags

      private boolean hasFlags
    • flagList

      private List<TapRequestFlag> flagList
    • vblist

      private short[] vblist
    • name

      private String name
    • backfilldate

      private long backfilldate
    • vBucketCheckpoints

      private Map<Short,Long> vBucketCheckpoints
  • Constructor Details

    • RequestMessage

      public RequestMessage()
      Create a tap request message. These messages are used to start tap streams.
  • Method Details

    • setFlags

      public void setFlags(TapRequestFlag f)
      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

      public List<TapRequestFlag> 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

      public void setvBucketCheckpoints(Map<Short,Long> vbchkpnts)
      Sets a map of vbucket checkpoints.
      Parameters:
      vbchkpnts - - A map of vbucket checkpoint identifiers
    • setName

      public void setName(String n)
      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

      public ByteBuffer getBytes()
      Encodes the message into binary.
      Specified by:
      getBytes in class BaseMessage
      Returns:
      The ByteBuffer representation of the message.