Top Description Methods
org.postgresql.core

public Interface ReplicationProtocol

Known Direct Implementers
org.postgresql.core.v3.replication.V3ReplicationProtocol
Imports
org.postgresql.replication.PGReplicationStream, org.postgresql.replication.fluent.logical.LogicalReplicationOptions, org.postgresql.replication.fluent.physical.PhysicalReplicationOptions, java.sql.SQLException

Abstracts the protocol-specific details of physic and logic replication.

With each connection open with replication options associate own instance ReplicationProtocol.

Method Summary

Modifier and TypeMethod and Description
public PGReplicationStream

Returns:

not null stream instance from which available fetch wal logs that was decode by output plugin
startLogical(LogicalReplicationOptions
not null options for logical replication stream
options)

public PGReplicationStream

Returns:

not null stream instance from which available fetch wal logs
startPhysical(PhysicalReplicationOptions
not null options for physical replication stream
options)

Method Detail

startLogicalback to summary
public PGReplicationStream startLogical(LogicalReplicationOptions options) throws SQLException
Parameters
options:LogicalReplicationOptions

not null options for logical replication stream

Returns:PGReplicationStream

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

Exceptions
SQLException:
on error
startPhysicalback to summary
public PGReplicationStream startPhysical(PhysicalReplicationOptions options) throws SQLException
Parameters
options:PhysicalReplicationOptions

not null options for physical replication stream

Returns:PGReplicationStream

not null stream instance from which available fetch wal logs

Exceptions
SQLException:
on error