Class PhysicalStreamBuilder

    • Constructor Detail

      • PhysicalStreamBuilder

        public PhysicalStreamBuilder​(StartPhysicalReplicationCallback startCallback)
        Parameters:
        startCallback - not null callback that should be execute after build parameters for start replication
    • Method Detail

      • getSlotName

        public java.lang.String getSlotName()
        Description copied from interface: CommonOptions
        Replication slots provide an automated way to ensure that the master does not remove WAL segments until they have been received by all standbys, and that the master does not remove rows which could cause a recovery conflict even when the standby is disconnected.
        Specified by:
        getSlotName in interface CommonOptions
        Returns:
        nullable replication slot name that already exists on server and free.
      • getStatusInterval

        public int getStatusInterval()
        Description copied from interface: 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.
        Specified by:
        getStatusInterval in interface CommonOptions
        Returns:
        the current status interval