org.postgresql.core.v3.replication

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 and Description
V3ReplicationProtocol(QueryExecutor queryExecutor, PGStream pgStream)

Method Summary

Modifier and Type	Method and Description
PGReplicationStream	startLogical(LogicalReplicationOptions options)
PGReplicationStream	startPhysical(PhysicalReplicationOptions options)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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 interface ReplicationProtocol

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 interface ReplicationProtocol

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