@InterfaceStability.Experimental @InterfaceAudience.Private @Deprecated public class SnapshotMarkerMessage extends AbstractDCPMessage
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
Deprecated.
|
static int |
CHECKPOINT
Deprecated.
|
static int |
DISK
Deprecated.
|
static int |
MEMORY
Deprecated.
|
DEFAULT_PARTITION
Constructor and Description |
---|
SnapshotMarkerMessage(int totalBodyLength,
short partition,
long startSequenceNumber,
long endSequenceNumber,
int flags,
String bucket)
Deprecated.
|
SnapshotMarkerMessage(int totalBodyLength,
short partition,
long startSequenceNumber,
long endSequenceNumber,
int flags,
String bucket,
String password)
Deprecated.
|
SnapshotMarkerMessage(int totalBodyLength,
short partition,
long startSequenceNumber,
long endSequenceNumber,
int flags,
String bucket,
String username,
String password)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
boolean |
ack()
Deprecated.
|
boolean |
checkpoint()
Deprecated.
|
boolean |
disk()
Deprecated.
|
long |
endSequenceNumber()
Deprecated.
|
int |
flags()
Deprecated.
|
boolean |
memory()
Deprecated.
|
long |
startSequenceNumber()
Deprecated.
|
String |
toString()
Deprecated.
|
key, totalBodyLength
partition, partition
bucket, creationTime, incrementRetryCount, observable, password, retryCount, username
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
partition
bucket, incrementRetryCount, observable, password, retryCount, username
creationTime
public static final int MEMORY
public static final int DISK
public static final int CHECKPOINT
public static final int ACK
@Deprecated public SnapshotMarkerMessage(int totalBodyLength, short partition, long startSequenceNumber, long endSequenceNumber, int flags, String bucket)
@Deprecated public SnapshotMarkerMessage(int totalBodyLength, short partition, long startSequenceNumber, long endSequenceNumber, int flags, String bucket, String password)
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 © 2017 Couchbase, Inc.. All rights reserved.