Class V3ReplicationProtocol
- java.lang.Object
-
- org.postgresql.core.v3.replication.V3ReplicationProtocol
-
- All Implemented Interfaces:
ReplicationProtocol
public class V3ReplicationProtocol extends java.lang.Object implements ReplicationProtocol
-
-
Constructor Summary
Constructors Constructor Description V3ReplicationProtocol(QueryExecutor queryExecutor, PGStream pgStream)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description PGReplicationStream
startLogical(LogicalReplicationOptions options)
PGReplicationStream
startPhysical(PhysicalReplicationOptions options)
-
-
-
Constructor Detail
-
V3ReplicationProtocol
public V3ReplicationProtocol(QueryExecutor queryExecutor, PGStream pgStream)
-
-
Method Detail
-
startLogical
public PGReplicationStream startLogical(LogicalReplicationOptions options) throws java.sql.SQLException
- 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:
java.sql.SQLException
- on error
-
startPhysical
public PGReplicationStream startPhysical(PhysicalReplicationOptions options) throws java.sql.SQLException
- 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:
java.sql.SQLException
- on error
-
-