Class V3ReplicationProtocol
java.lang.Object
org.postgresql.core.v3.replication.V3ReplicationProtocol
- All Implemented Interfaces:
ReplicationProtocol
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate static final Logger
private final PGStream
private final QueryExecutor
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprivate void
configureSocketTimeout
(CommonOptions options) private String
START_REPLICATION SLOT slot_name LOGICAL XXX/XXX [ ( option_name [option_value] [, ...private String
START_REPLICATION [SLOT slot_name] [PHYSICAL] XXX/XXX.private PGReplicationStream
initializeReplication
(String query, CommonOptions options, ReplicationType replicationType) startLogical
(LogicalReplicationOptions options) startPhysical
(PhysicalReplicationOptions options)
-
Field Details
-
LOGGER
-
queryExecutor
-
pgStream
-
-
Constructor Details
-
V3ReplicationProtocol
-
-
Method Details
-
startLogical
- Specified by:
startLogical
in interfaceReplicationProtocol
- Parameters:
options
- not null options for logical replication stream- Returns:
- not null stream instance from which available fetch wal logs that was decode by output plugin
- Throws:
SQLException
- on error
-
startPhysical
- Specified by:
startPhysical
in interfaceReplicationProtocol
- Parameters:
options
- not null options for physical replication stream- Returns:
- not null stream instance from which available fetch wal logs
- Throws:
SQLException
- on error
-
initializeReplication
private PGReplicationStream initializeReplication(String query, CommonOptions options, ReplicationType replicationType) throws SQLException - Throws:
SQLException
-
createStartPhysicalQuery
START_REPLICATION [SLOT slot_name] [PHYSICAL] XXX/XXX. -
createStartLogicalQuery
START_REPLICATION SLOT slot_name LOGICAL XXX/XXX [ ( option_name [option_value] [, ... ] ) ] -
configureSocketTimeout
- Throws:
PSQLException
-