Top Description Methods
org.postgresql.replication.fluent

public Interface ChainedCommonStreamBuilder<T extends ChainedCommonStreamBuilder<T>>

Known Direct Subinterfaces
org.postgresql.replication.fluent.logical.ChainedLogicalStreamBuilder, org.postgresql.replication.fluent.physical.ChainedPhysicalStreamBuilder
Known Direct Implementers
org.postgresql.replication.fluent.AbstractStreamBuilder
Imports
org.postgresql.replication.LogSequenceNumber, java.util.concurrent.TimeUnit

Fluent interface for specify common parameters for Logical and Physical replication.

Method Summary

Modifier and TypeMethod and Description
public T

Returns:

this instance as a fluent interface
withSlotName
(String
not null replication slot already exists on server.
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.

public T

Returns:

not null fluent
withStartPosition
(LogSequenceNumber
not null position from which need start replicate changes
lsn
)

Specify start position from which backend will start stream changes.

public T

Returns:

not null fluent
withStatusInterval
(int
positive time
time
,
TimeUnit
format for specified time
format
)

Specifies the number of time between status packets sent back to the server.

Method Detail

withSlotNameback to summary
public T withSlotName(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.

Parameters
slotName:String

not null replication slot already exists on server.

Returns:T

this instance as a fluent interface

withStartPositionback to summary
public T withStartPosition(LogSequenceNumber lsn)

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.

Parameters
lsn:LogSequenceNumber

not null position from which need start replicate changes

Returns:T

not null fluent

withStatusIntervalback to summary
public T withStatusInterval(int time, TimeUnit format)

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.

Parameters
time:int

positive time

format:TimeUnit

format for specified time

Returns:T

not null fluent