Package io.debezium.connector.postgresql.connection

Class PostgresReplicationConnection.ReplicationConnectionBuilder

java.lang.Object

io.debezium.connector.postgresql.connection.PostgresReplicationConnection.ReplicationConnectionBuilder

All Implemented Interfaces:

io.debezium.connector.postgresql.connection.ReplicationConnection.Builder

Enclosing class:

PostgresReplicationConnection

protected static class PostgresReplicationConnection.ReplicationConnectionBuilder
extends Object
implements io.debezium.connector.postgresql.connection.ReplicationConnection.Builder

Field Summary

Fields inherited from interface io.debezium.connector.postgresql.connection.ReplicationConnection.Builder

DEFAULT_DROP_SLOT_ON_CLOSE, DEFAULT_PUBLICATION_NAME, DEFAULT_SLOT_NAME

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ReplicationConnectionBuilder(io.debezium.connector.postgresql.PostgresConnectorConfig config)

Method Summary

Modifier and Type	Method	Description
io.debezium.connector.postgresql.connection.ReplicationConnection	build()
io.debezium.connector.postgresql.connection.ReplicationConnection.Builder	doSnapshot(boolean doSnapshot)
PostgresReplicationConnection.ReplicationConnectionBuilder	dropSlotOnClose(boolean dropSlotOnClose)
io.debezium.connector.postgresql.connection.ReplicationConnection.Builder	jdbcMetadataConnection(PostgresConnection jdbcConnection)
PostgresReplicationConnection.ReplicationConnectionBuilder	statusUpdateInterval(java.time.Duration statusUpdateInterval)
PostgresReplicationConnection.ReplicationConnectionBuilder	streamParams(String slotStreamParams)
PostgresReplicationConnection.ReplicationConnectionBuilder	withPlugin(io.debezium.connector.postgresql.PostgresConnectorConfig.LogicalDecoder plugin)
io.debezium.connector.postgresql.connection.ReplicationConnection.Builder	withPublication(String publicationName)
io.debezium.connector.postgresql.connection.ReplicationConnection.Builder	withPublicationAutocreateMode(io.debezium.connector.postgresql.PostgresConnectorConfig.AutoCreateMode publicationAutocreateMode)
io.debezium.connector.postgresql.connection.ReplicationConnection.Builder	withSchema(io.debezium.connector.postgresql.PostgresSchema schema)
PostgresReplicationConnection.ReplicationConnectionBuilder	withSlot(String slotName)
io.debezium.connector.postgresql.connection.ReplicationConnection.Builder	withTableFilter(RelationalTableFilters tableFilter)
io.debezium.connector.postgresql.connection.ReplicationConnection.Builder	withTypeRegistry(io.debezium.connector.postgresql.TypeRegistry typeRegistry)

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicationConnectionBuilder

protected ReplicationConnectionBuilder(io.debezium.connector.postgresql.PostgresConnectorConfig config)

Method Detail

withSlot

public PostgresReplicationConnection.ReplicationConnectionBuilder withSlot(String slotName)

Specified by:

withSlot in interface io.debezium.connector.postgresql.connection.ReplicationConnection.Builder

withPublication

public io.debezium.connector.postgresql.connection.ReplicationConnection.Builder withPublication(String publicationName)

Specified by:

withPublication in interface io.debezium.connector.postgresql.connection.ReplicationConnection.Builder

withTableFilter

public io.debezium.connector.postgresql.connection.ReplicationConnection.Builder withTableFilter(RelationalTableFilters tableFilter)

Specified by:

withTableFilter in interface io.debezium.connector.postgresql.connection.ReplicationConnection.Builder

withPublicationAutocreateMode

public io.debezium.connector.postgresql.connection.ReplicationConnection.Builder withPublicationAutocreateMode(io.debezium.connector.postgresql.PostgresConnectorConfig.AutoCreateMode publicationAutocreateMode)

Specified by:

withPublicationAutocreateMode in interface io.debezium.connector.postgresql.connection.ReplicationConnection.Builder

withPlugin

public PostgresReplicationConnection.ReplicationConnectionBuilder withPlugin(io.debezium.connector.postgresql.PostgresConnectorConfig.LogicalDecoder plugin)

Specified by:

withPlugin in interface io.debezium.connector.postgresql.connection.ReplicationConnection.Builder

dropSlotOnClose

public PostgresReplicationConnection.ReplicationConnectionBuilder dropSlotOnClose(boolean dropSlotOnClose)

Specified by:

dropSlotOnClose in interface io.debezium.connector.postgresql.connection.ReplicationConnection.Builder

streamParams

public PostgresReplicationConnection.ReplicationConnectionBuilder streamParams(String slotStreamParams)

Specified by:

streamParams in interface io.debezium.connector.postgresql.connection.ReplicationConnection.Builder

statusUpdateInterval

public PostgresReplicationConnection.ReplicationConnectionBuilder statusUpdateInterval(java.time.Duration statusUpdateInterval)

Specified by:

statusUpdateInterval in interface io.debezium.connector.postgresql.connection.ReplicationConnection.Builder

doSnapshot

public io.debezium.connector.postgresql.connection.ReplicationConnection.Builder doSnapshot(boolean doSnapshot)

Specified by:

doSnapshot in interface io.debezium.connector.postgresql.connection.ReplicationConnection.Builder

jdbcMetadataConnection

public io.debezium.connector.postgresql.connection.ReplicationConnection.Builder jdbcMetadataConnection(PostgresConnection jdbcConnection)

Specified by:

jdbcMetadataConnection in interface io.debezium.connector.postgresql.connection.ReplicationConnection.Builder

build

public io.debezium.connector.postgresql.connection.ReplicationConnection build()

Specified by:

build in interface io.debezium.connector.postgresql.connection.ReplicationConnection.Builder

withTypeRegistry

public io.debezium.connector.postgresql.connection.ReplicationConnection.Builder withTypeRegistry(io.debezium.connector.postgresql.TypeRegistry typeRegistry)

Specified by:

withTypeRegistry in interface io.debezium.connector.postgresql.connection.ReplicationConnection.Builder

withSchema

public io.debezium.connector.postgresql.connection.ReplicationConnection.Builder withSchema(io.debezium.connector.postgresql.PostgresSchema schema)

Specified by:

withSchema in interface io.debezium.connector.postgresql.connection.ReplicationConnection.Builder