Modifier and Type | Method | Description |
---|---|---|
LogSequenceNumber |
V3PGReplicationStream.getLastAppliedLSN() |
|
LogSequenceNumber |
V3PGReplicationStream.getLastFlushedLSN() |
|
LogSequenceNumber |
V3PGReplicationStream.getLastReceiveLSN() |
Modifier and Type | Method | Description |
---|---|---|
void |
V3PGReplicationStream.setAppliedLSN(LogSequenceNumber applied) |
|
void |
V3PGReplicationStream.setFlushedLSN(LogSequenceNumber flushed) |
Constructor | Description |
---|---|
V3PGReplicationStream(CopyDual copyDual,
LogSequenceNumber startLSN,
long updateIntervalMs,
ReplicationType replicationType) |
Modifier and Type | Field | Description |
---|---|---|
static LogSequenceNumber |
LogSequenceNumber.INVALID_LSN |
Zero is used indicate an invalid pointer.
|
Modifier and Type | Method | Description |
---|---|---|
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(java.lang.String strValue) |
Create LSN instance by string represent LSN.
|
Modifier and Type | Method | Description |
---|---|---|
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.
|
Modifier and Type | Field | Description |
---|---|---|
protected LogSequenceNumber |
AbstractStreamBuilder.startPosition |
Modifier and Type | Method | Description |
---|---|---|
LogSequenceNumber |
CommonOptions.getStartLSNPosition() |
Modifier and Type | Method | 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 | Description |
---|---|---|
LogSequenceNumber |
LogicalStreamBuilder.getStartLSNPosition() |
Modifier and Type | Method | Description |
---|---|---|
ChainedLogicalStreamBuilder |
LogicalStreamBuilder.withStartPosition(LogSequenceNumber lsn) |
Modifier and Type | Method | Description |
---|---|---|
LogSequenceNumber |
PhysicalStreamBuilder.getStartLSNPosition() |
Copyright © 2018 PostgreSQL Global Development Group. All rights reserved.