public abstract class AbstractStreamBuilder<T extends ChainedCommonStreamBuilder<T>> extends java.lang.Object implements ChainedCommonStreamBuilder<T>
Modifier and Type | Field and Description |
---|---|
protected boolean |
automaticFlush |
protected java.lang.String |
slotName |
protected LogSequenceNumber |
startPosition |
protected int |
statusIntervalMs |
Constructor and Description |
---|
AbstractStreamBuilder() |
Modifier and Type | Method and Description |
---|---|
protected abstract T |
self() |
T |
withAutomaticFlush(boolean automaticFlush)
Specify if backend should flush data after receive notification from client.
|
T |
withSlotName(java.lang.String slotName)
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.
|
T |
withStartPosition(LogSequenceNumber lsn)
Specify start position from which backend will start stream changes.
|
T |
withStatusInterval(int time,
java.util.concurrent.TimeUnit format)
Specifies the number of time between status packets sent back to the server.
|
protected int statusIntervalMs
protected LogSequenceNumber startPosition
protected java.lang.String slotName
protected boolean automaticFlush
protected abstract T self()
public T withStatusInterval(int time, java.util.concurrent.TimeUnit format)
ChainedCommonStreamBuilder
withStatusInterval
in interface ChainedCommonStreamBuilder<T extends ChainedCommonStreamBuilder<T>>
time
- positive timeformat
- format for specified timepublic T withStartPosition(LogSequenceNumber lsn)
ChainedCommonStreamBuilder
withStartPosition
in interface ChainedCommonStreamBuilder<T extends ChainedCommonStreamBuilder<T>>
lsn
- not null position from which need start replicate changespublic T withSlotName(java.lang.String slotName)
ChainedCommonStreamBuilder
withSlotName
in interface ChainedCommonStreamBuilder<T extends ChainedCommonStreamBuilder<T>>
slotName
- not null replication slot already exists on server.public T withAutomaticFlush(boolean automaticFlush)
ChainedCommonStreamBuilder
withAutomaticFlush
in interface ChainedCommonStreamBuilder<T extends ChainedCommonStreamBuilder<T>>
automaticFlush
- true if advance FlushLSN to ServerLSN data after receive notificationCopyright © 2025 PostgreSQL Global Development Group. All rights reserved.