| Modifier and Type | Field and Description |
|---|---|
| private static final int | |
| protected @Nullable String | |
| protected LogSequenceNumber | |
| protected int |
| Access | Constructor and Description |
|---|---|
| public |
| Modifier and Type | Method and Description |
|---|---|
| protected abstract T | |
| public T | withSlotName(String
not null replication slot already exists on server. slotName)Implements org. Replication slots provide an automated way to ensure that the master does not remove WAL segments until they have been received by all standbys, and that the master does not remove rows which could cause a recovery conflict even when the standby is disconnected. |
| public T | withStartPosition(LogSequenceNumber
not null position from which need start replicate changes lsn)Implements org. Specify start position from which backend will start stream changes. |
| public T | withStatusInterval(int
positive time time, TimeUnit format for specified time format)Implements org. Specifies the number of time between status packets sent back to the server. |
| DEFAULT_STATUS_INTERVAL | back to summary |
|---|---|
| private static final int DEFAULT_STATUS_INTERVAL | |
| slotName | back to summary |
|---|---|
| protected @Nullable String slotName | |
| startPosition | back to summary |
|---|---|
| protected LogSequenceNumber startPosition | |
| statusIntervalMs | back to summary |
|---|---|
| protected int statusIntervalMs | |
| AbstractStreamBuilder | back to summary |
|---|---|
| public AbstractStreamBuilder() | |
| self | back to summary |
|---|---|
| protected abstract T self() | |
| withSlotName | back to summary |
|---|---|
| public T withSlotName(String slotName) Implements org. Doc from org. Replication slots provide an automated way to ensure that the master does not remove WAL segments until they have been received by all standbys, and that the master does not remove rows which could cause a recovery conflict even when the standby is disconnected. | |
| withStartPosition | back to summary |
|---|---|
| public T withStartPosition(LogSequenceNumber lsn) Implements org. Doc from org. Specify start position from which backend will start stream changes. If parameter will not specify, streaming starts from restart_lsn. For more details see pg_replication_slots description.
| |
| withStatusInterval | back to summary |
|---|---|
| public T withStatusInterval(int time, TimeUnit format) Implements org. Doc from org. Specifies the number of time between status packets sent back to the server. This allows for easier monitoring of the progress from server. A value of zero disables the periodic status updates completely, although an update will still be sent when requested by the server, to avoid timeout disconnect. The default value is 10 seconds. | |