Modifier and Type | Method and Description |
---|---|
LogSequenceNumber |
V3PGReplicationStream.getLastAppliedLSN() |
LogSequenceNumber |
V3PGReplicationStream.getLastFlushedLSN() |
LogSequenceNumber |
V3PGReplicationStream.getLastReceiveLSN() |
Modifier and Type | Method and Description |
---|---|
void |
V3PGReplicationStream.setAppliedLSN(LogSequenceNumber applied) |
void |
V3PGReplicationStream.setFlushedLSN(LogSequenceNumber flushed) |
Constructor and Description |
---|
V3PGReplicationStream(CopyDual copyDual,
LogSequenceNumber startLSN,
long updateIntervalMs,
ReplicationType replicationType) |
Modifier and Type | Field and Description |
---|---|
static LogSequenceNumber |
LogSequenceNumber.INVALID_LSN
Zero is used indicate an invalid pointer.
|
Modifier and Type | Method and Description |
---|---|
LogSequenceNumber |
ReplicationSlotInfo.getConsistentPoint()
LSN at which we became consistent.
|
LogSequenceNumber |
PGReplicationStream.getLastAppliedLSN()
Last applied lsn send in update message to backed.
|
LogSequenceNumber |
PGReplicationStream.getLastFlushedLSN()
Last flushed lsn send in update message to backend.
|
LogSequenceNumber |
PGReplicationStream.getLastReceiveLSN()
Parameter updates by execute
PGReplicationStream.read() method. |
static LogSequenceNumber |
LogSequenceNumber.valueOf(long value) |
static LogSequenceNumber |
LogSequenceNumber.valueOf(String strValue)
Create LSN instance by string represent LSN.
|
Modifier and Type | Method and Description |
---|---|
int |
LogSequenceNumber.compareTo(LogSequenceNumber o) |
void |
PGReplicationStream.setAppliedLSN(LogSequenceNumber applied)
Parameter used only physical replication and define which lsn already was apply on standby.
|
void |
PGReplicationStream.setFlushedLSN(LogSequenceNumber flushed)
Set flushed LSN.
|
Constructor and Description |
---|
ReplicationSlotInfo(String slotName,
ReplicationType replicationType,
LogSequenceNumber consistentPoint,
String snapshotName,
String outputPlugin) |
Modifier and Type | Field and Description |
---|---|
protected LogSequenceNumber |
AbstractStreamBuilder.startPosition |
Modifier and Type | Method and Description |
---|---|
LogSequenceNumber |
CommonOptions.getStartLSNPosition() |
Modifier and Type | Method and Description |
---|---|
T |
AbstractStreamBuilder.withStartPosition(LogSequenceNumber lsn) |
T |
ChainedCommonStreamBuilder.withStartPosition(LogSequenceNumber lsn)
Specify start position from which backend will start stream changes.
|
Modifier and Type | Method and Description |
---|---|
LogSequenceNumber |
LogicalStreamBuilder.getStartLSNPosition() |
Modifier and Type | Method and Description |
---|---|
ChainedLogicalStreamBuilder |
LogicalStreamBuilder.withStartPosition(LogSequenceNumber lsn) |
Modifier and Type | Method and Description |
---|---|
LogSequenceNumber |
PhysicalStreamBuilder.getStartLSNPosition() |
Copyright © 2019 PostgreSQL Global Development Group. All rights reserved.