Top Fields Constructors Methods
org.postgresql.core.v3.replication

public Class V3ReplicationProtocol

extends Object
implements ReplicationProtocol
Class Inheritance
All Implemented Interfaces
org.postgresql.core.ReplicationProtocol
Static Imports
org.postgresql.util.internal.Nullness.castNonNull

Field Summary

Modifier and TypeField and Description
private static final Logger
LOGGER

private final PGStream
pgStream

private final QueryExecutor
queryExecutor

Constructor Summary

AccessConstructor and Description
public
V3ReplicationProtocol(QueryExecutor queryExecutor, PGStream pgStream)

Method Summary

Modifier and TypeMethod and Description
private void
configureSocketTimeout(CommonOptions options)

private String
createStartLogicalQuery(LogicalReplicationOptions options)

START_REPLICATION SLOT slot_name LOGICAL XXX/XXX [ ( option_name [option_value] [, ...

private String
createStartPhysicalQuery(PhysicalReplicationOptions options)

START_REPLICATION [SLOT slot_name] [PHYSICAL] XXX/XXX.

private PGReplicationStream
initializeReplication(String query, CommonOptions options, ReplicationType replicationType)

public PGReplicationStream
startLogical(LogicalReplicationOptions
not null options for logical replication stream
options)

Implements org.postgresql.core.ReplicationProtocol.startLogical.

public PGReplicationStream
startPhysical(PhysicalReplicationOptions
not null options for physical replication stream
options)

Implements org.postgresql.core.ReplicationProtocol.startPhysical.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

LOGGERback to summary
private static final Logger LOGGER
pgStreamback to summary
private final PGStream pgStream
queryExecutorback to summary
private final QueryExecutor queryExecutor

Constructor Detail

V3ReplicationProtocolback to summary
public V3ReplicationProtocol(QueryExecutor queryExecutor, PGStream pgStream)

Method Detail

configureSocketTimeoutback to summary
private void configureSocketTimeout(CommonOptions options) throws PSQLException
createStartLogicalQueryback to summary
private String createStartLogicalQuery(LogicalReplicationOptions options)

START_REPLICATION SLOT slot_name LOGICAL XXX/XXX [ ( option_name [option_value] [, ... ] ) ]

createStartPhysicalQueryback to summary
private String createStartPhysicalQuery(PhysicalReplicationOptions options)

START_REPLICATION [SLOT slot_name] [PHYSICAL] XXX/XXX.

initializeReplicationback to summary
private PGReplicationStream initializeReplication(String query, CommonOptions options, ReplicationType replicationType) throws SQLException
startLogicalback to summary
public PGReplicationStream startLogical(LogicalReplicationOptions options) throws SQLException

Implements org.postgresql.core.ReplicationProtocol.startLogical.

Parameters
options:LogicalReplicationOptions

Doc from org.postgresql.core.ReplicationProtocol.startLogical.

not null options for logical replication stream

Returns:PGReplicationStream

Doc from org.postgresql.core.ReplicationProtocol.startLogical.

not null stream instance from which available fetch wal logs that was decode by output plugin

Annotations
@Override
Exceptions
SQLException:

Doc from org.postgresql.core.ReplicationProtocol.startLogical.

on error

startPhysicalback to summary
public PGReplicationStream startPhysical(PhysicalReplicationOptions options) throws SQLException

Implements org.postgresql.core.ReplicationProtocol.startPhysical.

Parameters
options:PhysicalReplicationOptions

Doc from org.postgresql.core.ReplicationProtocol.startPhysical.

not null options for physical replication stream

Returns:PGReplicationStream

Doc from org.postgresql.core.ReplicationProtocol.startPhysical.

not null stream instance from which available fetch wal logs

Annotations
@Override
Exceptions
SQLException:

Doc from org.postgresql.core.ReplicationProtocol.startPhysical.

on error