Class AbstractStreamBuilder<T extends ChainedCommonStreamBuilder<T>>

    • Method Summary

      All Methods Instance Methods Abstract Methods Concrete Methods 
      Modifier and Type Method Description
      protected abstract T self()  
      T withSlotName​(java.lang.String slotName)
      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.
      T withStartPosition​(LogSequenceNumber lsn)
      Specify start position from which backend will start stream changes.
      T withStatusInterval​(int time, java.util.concurrent.TimeUnit format)
      Specifies the number of time between status packets sent back to the server.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Field Detail

      • statusIntervalMs

        protected int statusIntervalMs
      • slotName

        protected java.lang.String slotName
    • Constructor Detail

      • AbstractStreamBuilder

        public AbstractStreamBuilder()
    • Method Detail

      • self

        protected abstract T self()
      • withStatusInterval

        public T withStatusInterval​(int time,
                                    java.util.concurrent.TimeUnit format)
        Description copied from interface: ChainedCommonStreamBuilder
        Specifies the number of time 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:
        withStatusInterval in interface ChainedCommonStreamBuilder<T extends ChainedCommonStreamBuilder<T>>
        Parameters:
        time - positive time
        format - format for specified time
        Returns:
        not null fluent
      • withSlotName

        public T withSlotName​(java.lang.String slotName)
        Description copied from interface: ChainedCommonStreamBuilder
        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:
        withSlotName in interface ChainedCommonStreamBuilder<T extends ChainedCommonStreamBuilder<T>>
        Parameters:
        slotName - not null replication slot already exists on server.
        Returns:
        this instance as a fluent interface