@InterfaceStability.Experimental @InterfaceAudience.Private public class SnapshotMarkerMessage extends AbstractDCPRequest
Snapshot marker.
Sent by the producer to tell the consumer that a new snapshot is being sent. A snapshot is simply a series of commands that is guaranteed to contain a unique set of keys.
Modifier and Type | Field and Description |
---|---|
static int |
ACK |
static int |
CHECKPOINT |
static int |
DISK |
static int |
MEMORY |
DEFAULT_PARTITION
Constructor and Description |
---|
SnapshotMarkerMessage(short partition,
long startSequenceNumber,
long endSequenceNumber,
int flags,
String bucket) |
SnapshotMarkerMessage(short partition,
long startSequenceNumber,
long endSequenceNumber,
int flags,
String bucket,
String password) |
Modifier and Type | Method and Description |
---|---|
boolean |
ack() |
boolean |
checkpoint() |
boolean |
disk() |
long |
endSequenceNumber() |
int |
flags() |
boolean |
memory() |
long |
startSequenceNumber() |
String |
toString() |
partition, partition
bucket, creationTime, incrementRetryCount, observable, password
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
bucket, incrementRetryCount, observable, password
creationTime
public static final int MEMORY
public static final int DISK
public static final int CHECKPOINT
public static final int ACK
public SnapshotMarkerMessage(short partition, long startSequenceNumber, long endSequenceNumber, int flags, String bucket)
public long startSequenceNumber()
public long endSequenceNumber()
public int flags()
public boolean memory()
public boolean disk()
public boolean checkpoint()
public boolean ack()
public String toString()
toString
in class AbstractDCPRequest
Copyright © 2015 Couchbase, Inc.. All rights reserved.