クラス LogicalStreamBuilder
java.lang.Object
org.postgresql.replication.fluent.AbstractStreamBuilder<ChainedLogicalStreamBuilder>
org.postgresql.replication.fluent.logical.LogicalStreamBuilder
- すべての実装されたインタフェース:
ChainedCommonStreamBuilder<ChainedLogicalStreamBuilder>
,CommonOptions
,ChainedLogicalStreamBuilder
,LogicalReplicationOptions
public class LogicalStreamBuilder
extends AbstractStreamBuilder<ChainedLogicalStreamBuilder>
implements ChainedLogicalStreamBuilder, LogicalReplicationOptions
-
フィールドの概要
クラスから継承されたフィールド org.postgresql.replication.fluent.AbstractStreamBuilder
slotName, startPosition, statusIntervalMs
-
コンストラクタの概要
コンストラクタ -
メソッドの概要
修飾子とタイプメソッド説明@Nullable String
Required parameter for logical replication.Parameters for output plugin.int
Specifies the number of millisecond between status packets sent back to the server.protected ChainedLogicalStreamBuilder
self()
start()
Open logical replication stream.withSlotOption
(String optionName, boolean optionValue) withSlotOption
(String optionName, int optionValue) withSlotOption
(String optionName, String optionValue) withSlotOptions
(Properties options) Specify start position from which backend will start stream changes.クラスから継承されたメソッド org.postgresql.replication.fluent.AbstractStreamBuilder
withSlotName, withStatusInterval
クラスから継承されたメソッド java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
インタフェースから継承されたメソッド org.postgresql.replication.fluent.ChainedCommonStreamBuilder
withSlotName, withStatusInterval
-
コンストラクタの詳細
-
LogicalStreamBuilder
- パラメータ:
startCallback
- not null callback that should be execute after build parameters for start replication
-
-
メソッドの詳細
-
self
-
start
インタフェースからコピーされた説明:ChainedLogicalStreamBuilder
Open logical replication stream.- 定義:
start
インタフェース内ChainedLogicalStreamBuilder
- 戻り値:
- not null PGReplicationStream available for fetch data in logical form
- 例外:
SQLException
- if there are errors
-
getSlotName
インタフェースからコピーされた説明:LogicalReplicationOptions
Required parameter for logical replication.- 定義:
getSlotName
インタフェース内CommonOptions
- 定義:
getSlotName
インタフェース内LogicalReplicationOptions
- 戻り値:
- not null logical replication slot name that already exists on server and free.
-
withStartPosition
インタフェースからコピーされた説明:ChainedCommonStreamBuilder
Specify start position from which backend will start stream changes. If parameter will not specify, streaming starts from restart_lsn. For more details see pg_replication_slots description.- 定義:
withStartPosition
インタフェース内ChainedCommonStreamBuilder<ChainedLogicalStreamBuilder>
- オーバーライド:
withStartPosition
クラス内AbstractStreamBuilder<ChainedLogicalStreamBuilder>
- パラメータ:
lsn
- not null position from which need start replicate changes- 戻り値:
- not null fluent
-
withSlotOption
- 定義:
withSlotOption
インタフェース内ChainedLogicalStreamBuilder
- パラメータ:
optionName
- name of optionoptionValue
- boolean value- 戻り値:
- ChainedLogicalStreamBuilder
-
withSlotOption
- 定義:
withSlotOption
インタフェース内ChainedLogicalStreamBuilder
- パラメータ:
optionName
- name of optionoptionValue
- integer value- 戻り値:
- ChainedLogicalStreamBuilder
-
withSlotOption
- 定義:
withSlotOption
インタフェース内ChainedLogicalStreamBuilder
- パラメータ:
optionName
- name of optionoptionValue
- String value- 戻り値:
- ChainedLogicalStreamBuilder
-
withSlotOptions
- 定義:
withSlotOptions
インタフェース内ChainedLogicalStreamBuilder
- パラメータ:
options
- properties- 戻り値:
- ChainedLogicalStreamBuilder
-
getStartLSNPosition
- 定義:
getStartLSNPosition
インタフェース内CommonOptions
- 戻り値:
- the position to start replication. This cannot be null.
-
getSlotOptions
インタフェースからコピーされた説明:LogicalReplicationOptions
Parameters for output plugin. Parameters will be set to output plugin that register for specified replication slot name.- 定義:
getSlotOptions
インタフェース内LogicalReplicationOptions
- 戻り値:
- list options that will be pass to output_plugin for that was create replication slot
-
getStatusInterval
public int getStatusInterval()インタフェースからコピーされた説明:CommonOptions
Specifies the number of millisecond between status packets sent back to the server. This allows for easier monitoring of the progress from server. A value of zero disables the periodic status updates completely, although an update will still be sent when requested by the server, to avoid timeout disconnect. The default value is 10 seconds.- 定義:
getStatusInterval
インタフェース内CommonOptions
- 戻り値:
- the current status interval
-